Home
last modified time | relevance | path

Searched defs:task_id (Results 1 – 25 of 57) sorted by relevance

123

/external/tensorflow/tensorflow/python/distribute/cluster_resolver/
Dcluster_resolver.py102 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
121 task_id=None, argument
179 def __init__(self, cluster_spec, master='', task_type=None, task_id=None, argument
204 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
230 def task_id(self): member in SimpleClusterResolver
238 def task_id(self, task_id): member in SimpleClusterResolver
247 task_id=None, argument
397 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
422 def task_id(self): member in UnionClusterResolver
430 def task_id(self, task_id): member in UnionClusterResolver
[all …]
Dtfconfig_cluster_resolver.py62 task_id=None, argument
90 def task_id(self): member in TFConfigClusterResolver
102 def task_id(self, task_id): member in TFConfigClusterResolver
122 task_id=None, argument
140 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
Dgce_cluster_resolver.py51 task_id=0, argument
151 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
169 def task_id(self): member in GCEClusterResolver
179 def task_id(self, task_id): member in GCEClusterResolver
Dslurm_cluster_resolver.py198 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
222 task_id=None, argument
Dtpu_cluster_resolver.py175 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
260 task_id=None, argument
Dkubernetes_cluster_resolver.py96 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
/external/libbrillo/brillo/message_loops/
Dmessage_loop_unittest.cc87 TaskId task_id = this->loop_->PostTask(FROM_HERE, Bind(&SetToTrue, &called)); in TYPED_TEST() local
96 TaskId task_id = this->loop_->PostTask(FROM_HERE, Bind(&SetToTrue, &called)); in TYPED_TEST() local
106 TaskId task_id = this->loop_->PostDelayedTask( in TYPED_TEST() local
140 TaskId task_id = this->loop_->WatchFileDescriptor( in TYPED_TEST() local
159 TaskId task_id = this->loop_->WatchFileDescriptor( in TYPED_TEST() local
177 TaskId task_id = this->loop_->WatchFileDescriptor( in TYPED_TEST() local
194 TaskId task_id = this->loop_->WatchFileDescriptor( in TYPED_TEST() local
237 TaskId task_id; in TYPED_TEST() local
240 Bind([](bool* cancel_result, MessageLoop* loop, TaskId* task_id) { in TYPED_TEST()
251 TaskId task_id = this->loop_->WatchFileDescriptor( in TYPED_TEST() local
[all …]
Dbase_message_loop.cc88 TaskId task_id = NextTaskId(); in PostDelayedTask() local
127 TaskId task_id = NextTaskId(); in WatchFileDescriptor() local
169 bool BaseMessageLoop::CancelTask(TaskId task_id) { in CancelTask()
246 void BaseMessageLoop::OnRanPostedTask(MessageLoop::TaskId task_id) { in OnRanPostedTask()
269 void BaseMessageLoop::OnFileReadyPostedTask(MessageLoop::TaskId task_id) { in OnFileReadyPostedTask()
313 MessageLoop::TaskId task_id, in IOTask()
Dmessage_loop_utils.cc17 MessageLoop::TaskId task_id = loop->PostDelayedTask( in MessageLoopRunUntil() local
/external/webrtc/webrtc/libjingle/xmpp/
Dpubsubclient_unittest.cc51 const std::string& task_id, in OnPublishResult()
57 const std::string& task_id, in OnPublishError()
65 const std::string& task_id) { in OnRetractResult()
70 const std::string& task_id, in OnRetractError()
196 std::string task_id; in TEST_F() local
225 std::string task_id; in TEST_F() local
241 std::string task_id; in TEST_F() local
265 std::string task_id; in TEST_F() local
Dhangoutpubsubclient.cc244 const std::string& task_id, const XmlElement* item) { in OnPresenterPublishResult()
249 const std::string& task_id, const XmlElement* item, in OnPresenterPublishError()
301 const std::string& task_id, const XmlElement* item) { in OnAudioMutePublishResult()
311 const std::string& task_id, const XmlElement* item, in OnAudioMutePublishError()
328 const std::string& task_id, const XmlElement* item) { in OnVideoMutePublishResult()
333 const std::string& task_id, const XmlElement* item, in OnVideoMutePublishError()
345 const std::string& task_id, const XmlElement* item) { in OnVideoPausePublishResult()
350 const std::string& task_id, const XmlElement* item, in OnVideoPausePublishError()
362 const std::string& task_id, const XmlElement* item) { in OnRecordingPublishResult()
367 const std::string& task_id, const XmlElement* item, in OnRecordingPublishError()
[all …]
Dhangoutpubsubclient_unittest.cc91 void OnPublishAudioMuteError(const std::string& task_id, in OnPublishAudioMuteError()
97 void OnPublishVideoMuteError(const std::string& task_id, in OnPublishVideoMuteError()
103 void OnPublishVideoPauseError(const std::string& task_id, in OnPublishVideoPauseError()
109 void OnPublishPresenterError(const std::string& task_id, in OnPublishPresenterError()
115 void OnPublishRecordingError(const std::string& task_id, in OnPublishRecordingError()
121 void OnRemoteMuteResult(const std::string& task_id, in OnRemoteMuteResult()
127 void OnRemoteMuteError(const std::string& task_id, in OnRemoteMuteError()
135 void OnMediaBlockResult(const std::string& task_id, in OnMediaBlockResult()
141 void OnMediaBlockError(const std::string& task_id, in OnMediaBlockError()
Dpubsubstateclient.h224 const std::string& task_id, in OnPublishResult()
230 const std::string& task_id, in OnPublishError()
237 const std::string& task_id) { in OnRetractResult()
246 const std::string& task_id, in OnRetractError()
Dxmpptask.h119 std::string task_id() const { return id_; } in task_id() function
/external/tensorflow/tensorflow/python/distribute/
Dmulti_worker_util.py50 def _validate_cluster_spec(cluster_spec, task_type, task_id): argument
97 def is_chief(cluster_spec=None, task_type=None, task_id=None): argument
137 def collective_leader(cluster_spec, task_type, task_id): argument
192 def id_in_cluster(cluster_spec, task_type, task_id): argument
Dparameter_server_strategy_test.py70 task_id=None, argument
110 def _get_test_objects(self, task_type, task_id, num_gpus): argument
118 def _test_device_assignment_distributed(self, task_type, task_id, num_gpus): argument
218 self, task_type, task_id, num_gpus): argument
367 def _test_simple_increment(self, task_type, task_id, num_gpus): argument
431 def _test_minimize_loss_graph(self, task_type, task_id, num_gpus): argument
517 task_id, argument
Dcollective_all_reduce_strategy_test.py66 task_id=None, argument
104 def _get_test_object(self, task_type, task_id, num_gpus=0): argument
123 def _test_minimize_loss_graph(self, task_type, task_id, num_gpus): argument
190 def _test_complex_model(self, task_type, task_id, num_gpus): argument
241 def _test_mixed_precision(self, task_type, task_id, num_gpus): argument
317 def _test_variable_initialization(self, task_type, task_id, num_gpus): argument
347 task_id, argument
Ddistribute_coordinator.py116 task_id, argument
291 def task_id(self): member in _WorkerContext
330 task_id, argument
387 task_id=None, argument
530 strategy, eval_strategy, session_config, cluster_spec, task_type, task_id): argument
638 task_id=None, argument
Dmulti_process_runner.py208 def _message_checking_func(self, task_type, task_id, stdout_collector, argument
232 def _proc_func_wrapper(self, proc_func, task_type, task_id, argument
325 task_id, argument
425 def terminate(self, task_type, task_id): argument
/external/v8/src/heap/
Dworklist.h32 View(Worklist<EntryType, SEGMENT_SIZE>* worklist, int task_id) in View()
93 bool Push(int task_id, EntryType entry) { in Push()
105 bool Pop(int task_id, EntryType* entry) { in Pop()
123 size_t LocalPushSegmentSize(int task_id) { in LocalPushSegmentSize()
127 bool IsLocalEmpty(int task_id) { in IsLocalEmpty()
146 size_t LocalSize(int task_id) { in LocalSize()
201 void FlushToGlobal(int task_id) { in FlushToGlobal()
407 V8_INLINE Segment*& private_push_segment(int task_id) { in private_push_segment()
411 V8_INLINE Segment*& private_pop_segment(int task_id) { in private_pop_segment()
415 V8_INLINE void PublishPushSegmentToGlobal(int task_id) { in PublishPushSegmentToGlobal()
[all …]
Dscavenger-inl.h53 void Scavenger::PromotionList::PushRegularObject(int task_id, HeapObject object, in PushRegularObject()
58 void Scavenger::PromotionList::PushLargeObject(int task_id, HeapObject object, in PushLargeObject()
68 size_t Scavenger::PromotionList::LocalPushSegmentSize(int task_id) { in LocalPushSegmentSize()
73 bool Scavenger::PromotionList::Pop(int task_id, in Pop()
85 void Scavenger::PromotionList::FlushToGlobal(int task_id) { in FlushToGlobal()
100 bool Scavenger::PromotionList::ShouldEagerlyProcessPromotionList(int task_id) { in ShouldEagerlyProcessPromotionList()
/external/libchrome/base/task/
Dcancelable_task_tracker_unittest.cc112 CancelableTaskTracker::TaskId task_id = task_tracker_.PostTask( in TEST_F() local
130 CancelableTaskTracker::TaskId task_id = in TEST_F() local
149 CancelableTaskTracker::TaskId task_id = in TEST_F() local
168 CancelableTaskTracker::TaskId task_id = task_tracker_.PostTaskAndReply( in TEST_F() local
189 CancelableTaskTracker::TaskId task_id = in TEST_F() local
360 void TryCancel(CancelableTaskTracker::TaskId task_id, in TryCancel()
372 CancelableTaskTracker::TaskId task_id = in TEST_F() local
391 CancelableTaskTracker::TaskId task_id = in TEST_F() local
/external/tensorflow/tensorflow/lite/delegates/gpu/common/memory_management/
Dgreedy_by_breadth_assignment.cc36 TaskId task_id; member
56 for (size_t task_id = 0; task_id < task_profiles.size(); ++task_id) { in GreedyByBreadthAssignment() local
/external/autotest/client/site_tests/platform_PrinterPpds/
Dtest_multithreaded_processor.py33 def _thread(self, task_id): argument
/external/v8/src/libplatform/
Ddefault-job.cc72 uint8_t task_id = 0; in AcquireTaskId() local
87 void DefaultJobState::ReleaseTaskId(uint8_t task_id) { in ReleaseTaskId()

123