Searched refs:contexts_ (Results 1 – 10 of 10) sorted by relevance
/external/grpc-grpc/test/cpp/end2end/ |
D | thread_stress_test.cc | 174 CommonStressTestAsyncServer() : contexts_(kNumAsyncServerThreads * 100) {} in CommonStressTestAsyncServer() 215 switch (contexts_[i].state) { in ProcessRpcs() 217 contexts_[i].state = Context::DONE; in ProcessRpcs() 219 send_response.set_message(contexts_[i].recv_request.message()); in ProcessRpcs() 220 contexts_[i].response_writer->Finish(send_response, Status::OK, in ProcessRpcs() 234 contexts_[i].state = Context::READY; in RefreshContext() 235 contexts_[i].srv_ctx.reset(new ServerContext); in RefreshContext() 236 contexts_[i].response_writer.reset( in RefreshContext() 238 contexts_[i].srv_ctx.get())); in RefreshContext() 239 service_.RequestEcho(contexts_[i].srv_ctx.get(), in RefreshContext() [all …]
|
/external/webrtc/modules/desktop_capture/win/ |
D | dxgi_output_duplicator.cc | 356 RTC_DCHECK(std::find(contexts_.begin(), contexts_.end(), context) == in Setup() 357 contexts_.end()); in Setup() 358 contexts_.push_back(context); in Setup() 362 auto it = std::find(contexts_.begin(), contexts_.end(), context); in Unregister() 363 RTC_DCHECK(it != contexts_.end()); in Unregister() 364 contexts_.erase(it); in Unregister() 368 for (Context* dest : contexts_) { in SpreadContextChange()
|
D | dxgi_output_duplicator.h | 131 std::vector<Context*> contexts_; variable
|
/external/libchrome/mojo/public/cpp/system/ |
D | wait_set.cc | 64 DCHECK(!contexts_.count(context->context_value())); in AddHandle() 67 contexts_[context->context_value()] = context; in AddHandle() 83 contexts_.erase(context->context_value()); in AddHandle() 169 auto it = contexts_.find(event.trigger_context); in Wait() 170 DCHECK(it != contexts_.end()); in Wait() 281 contexts_.erase(context->context_value()); in Notify() 317 std::map<uintptr_t, scoped_refptr<Context>> contexts_; member in mojo::WaitSet::State
|
/external/tensorflow/tensorflow/core/distributed_runtime/eager/ |
D | eager_service_impl.h | 54 for (auto it = contexts_.begin(); it != contexts_.end();) { in EagerServiceImpl() 57 it = contexts_.erase(it); in EagerServiceImpl() 75 for (auto& entry : contexts_) { in ~EagerServiceImpl() 224 std::unordered_map<uint64, ServerContext*> contexts_
|
D | eager_service_impl.cc | 209 auto context_it = contexts_.find(request->context_id()); in CreateContext() 210 if (context_it != contexts_.end()) { in CreateContext() 221 contexts_.erase(context_it); in CreateContext() 315 auto context_it = contexts_.find(request->context_id()); in CreateContext() 316 if (context_it != contexts_.end()) { in CreateContext() 321 contexts_.emplace(request->context_id(), in CreateContext() 414 auto iter = contexts_.find(context_id); in CreateMasterContext() 415 if (iter != contexts_.end()) { in CreateMasterContext() 424 contexts_.emplace(context_id, server_context); in CreateMasterContext() 650 contexts_.erase(request->context_id()); in CloseContext() [all …]
|
/external/grpc-grpc/test/cpp/qps/ |
D | server_async.cc | 122 contexts_.emplace_back( in AsyncQpsServerTest() 130 contexts_.emplace_back(new ServerRpcContextStreamingImpl( in AsyncQpsServerTest() 138 contexts_.emplace_back(new ServerRpcContextStreamingFromClientImpl( in AsyncQpsServerTest() 147 contexts_.emplace_back(new ServerRpcContextStreamingFromServerImpl( in AsyncQpsServerTest() 524 std::vector<std::unique_ptr<ServerRpcContext>> contexts_; member in grpc::testing::AsyncQpsServerTest
|
/external/tensorflow/tensorflow/compiler/xla/service/gpu/ |
D | cholesky_thunk.h | 68 absl::flat_hash_map<se::Stream*, CusolverContext> contexts_
|
D | cholesky_thunk.cc | 62 auto result = contexts_.emplace(params.stream, CusolverContext()); in ExecuteOnStream()
|
/external/tensorflow/tensorflow/core/profiler/internal/gpu/ |
D | cupti_tracer.cc | 830 for (auto &ctx : contexts_) { in SyncAndFlush() 847 contexts_.erase(ctx); in TrackContext() 849 contexts_.emplace(ctx); in TrackContext() 857 absl::flat_hash_set<CUcontext> contexts_ TF_GUARDED_BY(mutex_);
|