Searched refs:contexts_ (Results 1 – 8 of 8) sorted by relevance
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 …]
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
55 for (auto it = contexts_.begin(); it != contexts_.end();) { in EagerServiceImpl()58 it = contexts_.erase(it); in EagerServiceImpl()76 for (auto& entry : contexts_) { in ~EagerServiceImpl()203 std::unordered_map<uint64, ServerContext*> contexts_ GUARDED_BY(contexts_mu_);
130 } while (contexts_.find(context_id) != contexts_.end()); in CreateContext()131 contexts_.emplace( in CreateContext()255 contexts_.erase(request->context_id()); in CloseContext()307 auto iter = contexts_.find(context_id); in GetServerContext()308 if (iter == contexts_.end()) { in GetServerContext()
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
71 absl::flat_hash_map<se::Stream*, CusolverContext> contexts_ GUARDED_BY(mu_);
66 auto result = contexts_.emplace(stream, CusolverContext()); in ExecuteOnStream()
544 contexts_(isolate), in SnapshotCreatorData()555 PersistentValueVector<Context> contexts_; member621 size_t index = data->contexts_.Size(); in AddContext()622 data->contexts_.Append(context); in AddContext()705 int num_additional_contexts = static_cast<int>(data->contexts_.Size()); in CreateBlob()716 ConvertSerializedObjectsToFixedArray(data->contexts_.Get(i)); in CreateBlob()725 v8::Utils::OpenHandle(*data->contexts_.Get(i)); in CreateBlob()785 v8::Utils::OpenHandle(*data->contexts_.Get(i)); in CreateBlob()788 data->contexts_.Clear(); in CreateBlob()