Searched refs:consumers_ (Results 1 – 5 of 5) sorted by relevance
127 consumers_.push_back(Env::Default()->StartThread( in LaunchConsumerThreads()165 for (auto c : consumers_) { in JoinConsumerThreads()173 std::vector<Thread*> consumers_; member in tensorflow::__anon8bb5cd3e0111::GPUAllocatorRetryTest
47 auto it = consumers_.find(ipc_client_id); in GetConsumerForCurrentRequest()48 if (it == consumers_.end()) { in GetConsumerForCurrentRequest()50 consumers_[ipc_client_id].reset(remote_consumer); in GetConsumerForCurrentRequest()61 consumers_.erase(client_id); in OnClientDisconnected()
156 std::map<ipc::ClientID, std::unique_ptr<RemoteConsumer>> consumers_; variable
676 std::set<ConsumerEndpointImpl*> consumers_; variable
457 auto it_and_inserted = consumers_.emplace(endpoint.get()); in ConnectConsumer()472 PERFETTO_DCHECK(consumers_.count(consumer)); in DisconnectConsumer()478 consumers_.erase(consumer); in DisconnectConsumer()492 PERFETTO_DCHECK(consumers_.count(consumer)); in DetachConsumer()517 PERFETTO_DCHECK(consumers_.count(consumer)); in AttachConsumer()