| /external/tensorflow/tensorflow/core/distributed_runtime/coordination/ |
| D | coordination_service_agent_test.cc | 126 TF_ASSERT_OK(agent_->Initialize( in InitializeAgent()
142 std::unique_ptr<CoordinationServiceAgent> agent_ = member in tensorflow::__anon48c549790111::CoordinationServiceAgentTest
162 auto result = agent_->GetKeyValue(test_key); in TEST_F()
182 auto result = agent_->GetKeyValue(test_key, /*timeout=*/absl::Seconds(10)); in TEST_F()
198 auto result = agent_->GetKeyValue(test_key, /*timeout=*/absl::Seconds(1)); in TEST_F()
224 auto result = agent_->GetKeyValue(test_key, /*timeout=*/absl::Seconds(1)); in TEST_F()
268 auto result = agent_->GetKeyValue(test_key, /*timeout=*/absl::Seconds(10)); in TEST_F()
287 std::shared_ptr<CallOptions> get_kv_call_opts = agent_->GetKeyValueAsync( in TEST_F()
313 auto result = agent_->TryGetKeyValue(test_key); in TEST_F()
333 auto result = agent_->GetKeyValueDir(test_key); in TEST_F()
[all …]
|
| D | coordination_service_barrier_proxy.h | 62 agent_(agent), in BarrierProxy()
76 CoordinationServiceAgent* agent_; variable
|
| D | coordination_service_barrier_proxy.cc | 59 status_ = agent_->WaitAtBarrier(key_, timeout_, tasks_); in Wait()
72 agent_->CancelBarrier(key_).IgnoreError(); in Wait()
|
| D | coordination_service_rpc_handler.cc | 35 agent_ = agent; in SetAgentInstance()
129 if (agent_ == nullptr) { in ReportErrorToTaskAsync()
141 agent_->SetError(error); in ReportErrorToTaskAsync()
|
| D | coordination_service_rpc_handler.h | 84 CoordinationServiceAgent* agent_ TF_GUARDED_BY(agent_mu_);
|
| /external/marisa-trie/bindings/ruby/ |
| D | marisa-swig.cxx | 85 : agent_(new (std::nothrow) marisa::Agent), buf_(NULL), buf_size_(0) { in Agent()
86 MARISA_THROW_IF(agent_ == NULL, ::MARISA_MEMORY_ERROR); in Agent()
90 delete agent_; in ~Agent()
111 agent_->set_query(buf_, length); in set_query()
115 agent_->set_query(id); in set_query()
119 return reinterpret_cast<const Key &>(agent_->key()); in key()
123 return reinterpret_cast<const Query &>(agent_->query()); in query()
127 *ptr_out = agent_->key().ptr(); in key_str()
128 *length_out = agent_->key().length(); in key_str()
132 return agent_->key().id(); in key_id()
[all …]
|
| D | marisa-swig.h | 132 marisa::Agent *agent_;
|
| /external/marisa-trie/bindings/python/ |
| D | marisa-swig.cxx | 85 : agent_(new (std::nothrow) marisa::Agent), buf_(NULL), buf_size_(0) { in Agent()
86 MARISA_THROW_IF(agent_ == NULL, ::MARISA_MEMORY_ERROR); in Agent()
90 delete agent_; in ~Agent()
111 agent_->set_query(buf_, length); in set_query()
115 agent_->set_query(id); in set_query()
119 return reinterpret_cast<const Key &>(agent_->key()); in key()
123 return reinterpret_cast<const Query &>(agent_->query()); in query()
127 *ptr_out = agent_->key().ptr(); in key_str()
128 *length_out = agent_->key().length(); in key_str()
132 return agent_->key().id(); in key_id()
[all …]
|
| D | marisa-swig.h | 132 marisa::Agent *agent_;
|
| /external/marisa-trie/bindings/ |
| D | marisa-swig.cxx | 85 : agent_(new (std::nothrow) marisa::Agent), buf_(NULL), buf_size_(0) { in Agent()
86 MARISA_THROW_IF(agent_ == NULL, ::MARISA_MEMORY_ERROR); in Agent()
90 delete agent_; in ~Agent()
111 agent_->set_query(buf_, length); in set_query()
115 agent_->set_query(id); in set_query()
119 return reinterpret_cast<const Key &>(agent_->key()); in key()
123 return reinterpret_cast<const Query &>(agent_->query()); in query()
127 *ptr_out = agent_->key().ptr(); in key_str()
128 *length_out = agent_->key().length(); in key_str()
132 return agent_->key().id(); in key_id()
[all …]
|
| D | marisa-swig.h | 132 marisa::Agent *agent_;
|
| /external/marisa-trie/bindings/perl/ |
| D | marisa-swig.cxx | 85 : agent_(new (std::nothrow) marisa::Agent), buf_(NULL), buf_size_(0) { in Agent()
86 MARISA_THROW_IF(agent_ == NULL, ::MARISA_MEMORY_ERROR); in Agent()
90 delete agent_; in ~Agent()
111 agent_->set_query(buf_, length); in set_query()
115 agent_->set_query(id); in set_query()
119 return reinterpret_cast<const Key &>(agent_->key()); in key()
123 return reinterpret_cast<const Query &>(agent_->query()); in query()
127 *ptr_out = agent_->key().ptr(); in key_str()
128 *length_out = agent_->key().length(); in key_str()
132 return agent_->key().id(); in key_id()
[all …]
|
| D | marisa-swig.h | 132 marisa::Agent *agent_;
|
| /external/webrtc/p2p/base/ |
| D | wrapping_active_ice_controller.cc | 43 agent_(*ice_agent) { in WrappingActiveIceController()
51 : network_thread_(rtc::Thread::Current()), agent_(*ice_agent) { in WrappingActiveIceController()
116 agent_.OnStartedPinging(); in MaybeStartPinging()
123 agent_.UpdateConnectionStates(); in SelectAndPingConnection()
126 wrapped_->SelectConnectionToPing(agent_.GetLastPingSentMs()); in SelectAndPingConnection()
135 agent_.SendPingRequest(result.connection.value()); in HandlePingResult()
166 agent_.UpdateConnectionStates(); in SortAndSwitchToBestConnection()
194 agent_.SwitchSelectedConnection(result.connection.value(), in HandleSwitchResult()
211 agent_.ForgetLearnedStateForConnections( in HandleSwitchResult()
220 agent_.UpdateState(); in UpdateStateOnConnectionsResorted()
[all …]
|
| D | port_allocator.h | 480 return agent_; in user_agent()
490 agent_ = std::string(agent); in set_proxy()
641 std::string agent_; variable
|
| D | wrapping_active_ice_controller.h | 92 IceAgentInterface& agent_ RTC_GUARDED_BY(network_thread_);
|
| /external/tensorflow/tensorflow/core/distributed_runtime/preemption/ |
| D | preemption_sync_manager.cc | 80 CoordinationServiceAgent* agent_; // Not owned. member in tensorflow::__anonf4115fa60111::PreemptionSyncManagerImpl
111 agent_ = agent; in Initialize()
122 [agent = agent_, task_name](StatusOr<absl::Time> death_time) { in Initialize()
146 call_opts_ = agent_->GetKeyValueAsync( in Initialize()
148 [this, agent = agent_](StatusOr<std::string> status_or_death_time) { in Initialize()
219 const Status notified_status = agent_->InsertKeyValue( in ComputeSyncCallCounter()
232 agent_->WaitAtBarrier(kPreemptionBarrier, kPreemptionBarrierTimeout, {}); in ComputeSyncCallCounter()
240 agent_->GetKeyValueDir(kPreemptionCounterDirKey); in ComputeSyncCallCounter()
274 agent_->CancelBarrierAsync(kPreemptionBarrier, [](const Status& status) { in CancelPreemptionBarrier()
|
| /external/openscreen/cast/standalone_receiver/ |
| D | mirroring_application.cc | 29 agent_(agent) {
31 OSP_DCHECK(agent_);
32 agent_->RegisterApplication(this);
36 agent_->UnregisterApplication(this); // ApplicationAgent may call Stop(). in ~MirroringApplication()
92 agent_->StopApplicationIfRunning(this); // ApplicationAgent calls Stop(). in OnPlaybackError()
|
| D | cast_service.cc | 48 agent_(config.task_runner, credentials_.provider.get()), in CastService()
51 &agent_), in CastService()
52 socket_factory_(&agent_, agent_.cast_socket_client()), in CastService()
|
| D | cast_service.h | 79 ApplicationAgent agent_; variable
|
| D | mirroring_application.h | 58 ApplicationAgent* const agent_; variable
|
| /external/openscreen/cast/receiver/ |
| D | application_agent_unittest.cc | 155 agent_.RegisterApplication(&idle_app_, true); in ApplicationAgentTest()
163 ApplicationAgent* agent() { return &agent_; } in agent()
203 static_cast<ReceiverSocketFactory::Client*>(&agent_)->OnConnected( in ConnectAndDoAuth()
246 ApplicationAgent agent_{&task_runner_, &creds_}; member in openscreen::cast::__anon4c36d3aa0111::ApplicationAgentTest
|
| /external/webrtc/rtc_base/ |
| D | socket_adapters.h | 118 std::string agent_, user_, headers_; variable
|
| D | socket_adapters.cc | 228 agent_(user_agent), in AsyncHttpsProxySocket()
348 ss << "User-Agent: " << agent_ << "\r\n"; in SendRequest()
|