Home
last modified time | relevance | path

Searched refs:contexts_ (Results 1 – 10 of 10) sorted by relevance

/external/grpc-grpc/test/cpp/end2end/
Dthread_stress_test.cc174 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/
Ddxgi_output_duplicator.cc356 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()
Ddxgi_output_duplicator.h131 std::vector<Context*> contexts_; variable
/external/libchrome/mojo/public/cpp/system/
Dwait_set.cc64 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/
Deager_service_impl.h54 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_
Deager_service_impl.cc209 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/
Dserver_async.cc122 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/
Dcholesky_thunk.h68 absl::flat_hash_map<se::Stream*, CusolverContext> contexts_
Dcholesky_thunk.cc62 auto result = contexts_.emplace(params.stream, CusolverContext()); in ExecuteOnStream()
/external/tensorflow/tensorflow/core/profiler/internal/gpu/
Dcupti_tracer.cc830 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_);