Home
last modified time | relevance | path

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

123

/external/tensorflow/tensorflow/python/distribute/cluster_resolver/
Dcluster_resolver.py108 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
127 task_id=None, argument
185 def __init__(self, cluster_spec, master='', task_type=None, task_id=None, argument
210 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
236 def task_id(self): member in SimpleClusterResolver
244 def task_id(self, task_id): member in SimpleClusterResolver
253 task_id=None, argument
403 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
428 def task_id(self): member in UnionClusterResolver
436 def task_id(self, task_id): member in UnionClusterResolver
[all …]
Dtfconfig_cluster_resolver.py57 task_id=None, argument
85 def task_id(self): member in TFConfigClusterResolver
97 def task_id(self, task_id): member in TFConfigClusterResolver
117 task_id=None, argument
135 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): argument
Dslurm_cluster_resolver.py198 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
222 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()
/external/v8/src/heap/
Dworklist.h32 View(Worklist<EntryType, SEGMENT_SIZE>* worklist, int task_id) in View()
90 bool Push(int task_id, EntryType entry) { in Push()
102 bool Pop(int task_id, EntryType* entry) { in Pop()
120 size_t LocalPushSegmentSize(int task_id) { in LocalPushSegmentSize()
124 bool IsLocalEmpty(int task_id) { in IsLocalEmpty()
143 size_t LocalSize(int task_id) { in LocalSize()
195 void FlushToGlobal(int task_id) { in FlushToGlobal()
380 V8_INLINE Segment*& private_push_segment(int task_id) { in private_push_segment()
384 V8_INLINE Segment*& private_pop_segment(int task_id) { in private_pop_segment()
388 V8_INLINE void PublishPushSegmentToGlobal(int task_id) { in PublishPushSegmentToGlobal()
[all …]
/external/tensorflow/tensorflow/python/distribute/
Dmulti_worker_util.py49 def _validate_cluster_spec(cluster_spec, task_type, task_id): argument
75 def is_chief(cluster_spec, task_type, task_id): argument
125 def id_in_cluster(cluster_spec, task_type, task_id): argument
Ddistribute_coordinator.py116 task_id, argument
291 def task_id(self): member in _WorkerContext
330 task_id, argument
384 task_id=None, argument
527 strategy, eval_strategy, session_config, cluster_spec, task_type, task_id): argument
635 task_id=None, argument
/external/autotest/venv/skylab_suite/
Dsuite_tracking.py120 def _print_task_result_link_annotation(task_id, text): argument
140 def get_task_id_for_task_summaries(task_id): argument
150 def log_create_task(suite_name, task_id): argument
159 def log_wait_task(suite_name, task_id): argument
213 def _log_buildbot_links_for_test_history(task_id, test_name): argument
Dswarming_lib.py172 def get_task_link(task_id): argument
241 def query_task_by_id(self, task_id): argument
254 def abort_task(self, task_id): argument
Dcros_suite.py137 def add_test_by_task_id(self, task_id, test_handler_spec): argument
145 def get_test_by_task_id(self, task_id): argument
152 def remove_test_by_task_id(self, task_id): argument
182 def task_id(self): member in SuiteHandler
/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/autotest/venv/skylab_staging/
Dtest_push.py197 def _verify_suite_creation(swclient, task_id): argument
205 def _verify_test_results(task_id, expected_results): argument
221 def _get_test_views(task_id): argument
Dswarming.py90 def wait_for_suite(self, task_id, board, pool, build, suite_name, timeout_s): argument
168 def task_url(self, task_id): argument
/external/tensorflow/tensorflow/contrib/distribute/python/
Dcollective_all_reduce_strategy_test.py73 task_id=None, argument
125 task_id, argument
149 task_id, argument
221 task_id, argument
277 task_id, argument
310 task_id, argument
Dparameter_server_strategy_test.py81 task_id=None, argument
136 task_id, argument
149 task_id, argument
252 self, task_type, task_id, num_gpus, use_core_strategy=False): argument
404 task_id, argument
478 task_id, argument
570 task_id, argument
/external/tensorflow/tensorflow/contrib/mpi/
Dmpi_utils.h47 const int GetSourceID(const std::string& task_id) const { in GetSourceID()
/external/autotest/client/site_tests/platform_PrinterPpds/
Dtest_multithreaded_processor.py33 def _thread(self, task_id): argument

123