Home
last modified time | relevance | path

Searched refs:task_id (Results 1 – 25 of 121) sorted by relevance

12345

/external/v8/src/heap/
Dworklist.h32 View(Worklist<EntryType, SEGMENT_SIZE>* worklist, int task_id) in View() argument
33 : worklist_(worklist), task_id_(task_id) {} in View()
90 bool Push(int task_id, EntryType entry) { in Push() argument
91 DCHECK_LT(task_id, num_tasks_); in Push()
92 DCHECK_NOT_NULL(private_push_segment(task_id)); in Push()
93 if (!private_push_segment(task_id)->Push(entry)) { in Push()
94 PublishPushSegmentToGlobal(task_id); in Push()
95 bool success = private_push_segment(task_id)->Push(entry); in Push()
102 bool Pop(int task_id, EntryType* entry) { in Pop() argument
103 DCHECK_LT(task_id, num_tasks_); in Pop()
[all …]
Dconcurrent-marking.cc80 WeakObjects* weak_objects, int task_id) in ConcurrentMarkingVisitor() argument
81 : shared_(shared, task_id), in ConcurrentMarkingVisitor()
82 bailout_(bailout, task_id), in ConcurrentMarkingVisitor()
85 task_id_(task_id) {} in ConcurrentMarkingVisitor()
521 TaskState* task_state, int task_id) in Task() argument
525 task_id_(task_id) {} in Task()
556 void ConcurrentMarking::Run(int task_id, TaskState* task_state) { in Run() argument
562 weak_objects_, task_id); in Run()
567 "Starting concurrent marking task %d\n", task_id); in Run()
577 while (weak_objects_->current_ephemerons.Pop(task_id, &ephemeron)) { in Run()
[all …]
/external/libbrillo/brillo/message_loops/
Dmessage_loop_unittest.cc87 TaskId task_id = this->loop_->PostTask(FROM_HERE, Bind(&SetToTrue, &called)); in TYPED_TEST() local
88 EXPECT_NE(MessageLoop::kTaskIdNull, task_id); in TYPED_TEST()
96 TaskId task_id = this->loop_->PostTask(FROM_HERE, Bind(&SetToTrue, &called)); in TYPED_TEST() local
97 EXPECT_TRUE(this->loop_->CancelTask(task_id)); in TYPED_TEST()
101 EXPECT_FALSE(this->loop_->CancelTask(task_id)); in TYPED_TEST()
106 TaskId task_id = this->loop_->PostDelayedTask( in TYPED_TEST() local
108 EXPECT_NE(MessageLoop::kTaskIdNull, task_id); in TYPED_TEST()
140 TaskId task_id = this->loop_->WatchFileDescriptor( in TYPED_TEST() local
143 EXPECT_NE(MessageLoop::kTaskIdNull, task_id); in TYPED_TEST()
148 EXPECT_TRUE(this->loop_->CancelTask(task_id)); in TYPED_TEST()
[all …]
Dbase_message_loop.cc88 TaskId task_id = NextTaskId(); in PostDelayedTask() local
93 task_id), in PostDelayedTask()
95 DVLOG_LOC(from_here, 1) << "Scheduling delayed task_id " << task_id in PostDelayedTask()
100 delayed_tasks_.emplace(task_id, in PostDelayedTask()
101 DelayedTask{from_here, task_id, std::move(task)}); in PostDelayedTask()
102 return task_id; in PostDelayedTask()
127 TaskId task_id = NextTaskId(); in WatchFileDescriptor() local
130 std::forward_as_tuple(task_id), in WatchFileDescriptor()
132 from_here, this, task_id, fd, base_mode, persistent, task)); in WatchFileDescriptor()
140 << " as task_id " << task_id in WatchFileDescriptor()
[all …]
/external/tensorflow/tensorflow/python/distribute/cluster_resolver/
Dtfconfig_cluster_resolver.py57 task_id=None, argument
72 self._task_id = task_id
85 def task_id(self): member in TFConfigClusterResolver
96 @task_id.setter
97 def task_id(self, task_id): argument
98 self._task_id = task_id
117 task_id=None, argument
120 task_id = self.task_id if task_id is None else task_id
122 task_type, task_id, config_proto)
135 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
[all …]
Dcluster_resolver.py108 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
127 task_id=None, argument
150 master = self.master(task_type, task_id)
154 if task_type is not None and task_id is not None:
156 task_path = '/task:%s' % task_id
185 def __init__(self, cluster_spec, master='', task_type=None, task_id=None, argument
192 self._task_id = task_id
210 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
224 if task_type is not None and task_id is not None:
225 master = self.cluster_spec().task_address(task_type, task_id)
[all …]
Dgce_cluster_resolver.py51 task_id=0, argument
87 self._task_id = task_id
151 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
153 task_id = task_id if task_id is not None else self._task_id
155 if task_type is not None and task_id is not None:
156 master = self.cluster_spec().task_address(task_type, task_id)
169 def task_id(self): member in GCEClusterResolver
178 @task_id.setter
179 def task_id(self, task_id): member in GCEClusterResolver
180 self._task_id = task_id
Dslurm_cluster_resolver.py117 self.task_id = None
175 self.task_id = self._rank - cluster_rank_offset_start
196 return self.task_type, self.task_id
198 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
211 task_id = task_id if task_id is not None else self.task_id
213 if task_type is not None and task_id is not None:
215 self.cluster_spec().task_address(task_type, task_id),
222 task_id=None, argument
225 del task_type, task_id, config_proto
Dkubernetes_cluster_resolver.py93 self.task_id = None
96 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
113 task_id = task_id if task_id is not None else self.task_id
115 if task_type is not None and task_id is not None:
117 self.cluster_spec().task_address(task_type, task_id),
Dcluster_resolver_test.py38 def master(self, task_type=None, task_id=None, rpc_layer=None): argument
114 self.assertEqual(resolver.num_accelerators(task_type="worker1", task_id=0),
116 self.assertEqual(resolver.num_accelerators(task_type="worker2", task_id=3),
118 self.assertEqual(resolver.num_accelerators(task_type="worker2", task_id=4),
162 task_id=1, environment="cloud",
167 self.assertEqual(simple_resolver.task_id, 1)
179 task_id=1, environment="cloud",
184 simple_resolver.task_id = 2
188 self.assertEqual(simple_resolver.task_id, 2)
227 task_id=1, environment="cloud",
[all …]
Dtfconfig_cluster_resolver_test.py159 self.assertEqual(0, cluster_resolver.task_id)
177 cluster_resolver = TFConfigClusterResolver(task_type='ps', task_id=0)
181 self.assertEqual(0, cluster_resolver.task_id)
184 cluster_resolver.task_id = 1
189 self.assertEqual(1, cluster_resolver.task_id)
224 self.assertEqual(1, cluster_resolver.task_id)
287 self.assertEqual(resolver.num_accelerators(task_type='worker2', task_id=3),
/external/autotest/venv/skylab_suite/
Dsuite_tracking.py43 for task_id, hspec in suite_handler.task_to_test_maps.iteritems():
49 _print_task_result_link_annotation(task_id, show_text)
120 def _print_task_result_link_annotation(task_id, text): argument
137 swarming_lib.get_stainless_logs_link(task_id)))
140 def get_task_id_for_task_summaries(task_id): argument
147 return task_id[:-1] + '0'
150 def log_create_task(suite_name, task_id): argument
156 get_task_id_for_task_summaries(task_id))))
159 def log_wait_task(suite_name, task_id): argument
165 get_task_id_for_task_summaries(task_id))))
[all …]
Dtko_test_views.py80 if not args.task_id:
90 views = get(conn, args.task_id)
91 for task_id, rows in views.iteritems():
92 print('Task ID: %s' % task_id)
145 for task_id in task_ids:
146 run_ids += _run_ids_for_request(task_id)
147 task_runs[task_id] = list(reversed(run_ids))
151 for task_id, run_ids in task_runs.iteritems():
154 task_job_idxs[task_id] = run_job_idxs[run_id]
Dswarming_lib.py172 def get_task_link(task_id): argument
173 return '%s/user/task/%s' % (os.environ.get('SWARMING_SERVER'), task_id)
241 def query_task_by_id(self, task_id): argument
249 swarming_cmd = basic_swarming_cmd + ['task/%s/result' % task_id]
254 def abort_task(self, task_id): argument
260 swarming_cmd = basic_swarming_cmd + ['--kill-running', task_id]
266 task_id)
/external/tensorflow/tensorflow/python/distribute/
Ddistribute_coordinator.py116 task_id, argument
140 self._task_id = task_id
151 self._cluster_spec, self.task_type, self.task_id)
180 task_id = 0
184 task_id = 0
187 task_id = self._task_id
192 return prefix + self._cluster_spec.job_tasks(task_type)[task_id or 0]
291 def task_id(self): member in _WorkerContext
330 task_id, argument
345 strategy.configure(session_config, cluster_spec, task_type, task_id)
[all …]
Dmulti_worker_util.py49 def _validate_cluster_spec(cluster_spec, task_type, task_id): argument
70 if task_id >= len(cluster_spec[task_type]):
72 "The `task_id` %d exceeds the maximum id of %s." % (task_id, task_type))
75 def is_chief(cluster_spec, task_type, task_id): argument
91 _validate_cluster_spec(cluster_spec, task_type, task_id)
99 if ("chief" not in cluster_spec and task_type == "worker" and task_id == 0):
106 _validate_cluster_spec(cluster_spec, task_type, task_id=0)
125 def id_in_cluster(cluster_spec, task_type, task_id): argument
144 _validate_cluster_spec(cluster_spec, task_type, task_id)
153 return task_id + len(cluster_spec.get("chief", []))
[all …]
Ddistribute_coordinator_test.py109 task_id=None): argument
111 if task_id == 0:
116 if task_id == 0:
121 if task_id == 0:
127 if (cluster_spec and task_type and task_id is not None and
132 ["/job:%s/task:%d" % (task_type, task_id), "/job:ps"])
252 for task_id in range(len(cluster_spec[task_type])):
258 task_id=task_id,
356 task_id = context.task_id or 0
360 while len(self._worker_context[task_type]) <= task_id:
[all …]
/external/webrtc/webrtc/libjingle/xmpp/
Dpubsubclient_unittest.cc51 const std::string& task_id, in OnPublishResult() argument
53 result_task_id = task_id; in OnPublishResult()
57 const std::string& task_id, in OnPublishError() argument
61 error_task_id = task_id; in OnPublishError()
65 const std::string& task_id) { in OnRetractResult() argument
66 result_task_id = task_id; in OnRetractResult()
70 const std::string& task_id, in OnRetractError() argument
73 error_task_id = task_id; in OnRetractError()
196 std::string task_id; in TEST_F() local
197 client->PublishItem(itemid, payload, &task_id); in TEST_F()
[all …]
Dhangoutpubsubclient.cc244 const std::string& task_id, const XmlElement* item) { in OnPresenterPublishResult() argument
245 SignalPublishPresenterResult(task_id); in OnPresenterPublishResult()
249 const std::string& task_id, const XmlElement* item, in OnPresenterPublishError() argument
251 SignalPublishPresenterError(task_id, stanza); in OnPresenterPublishError()
301 const std::string& task_id, const XmlElement* item) { in OnAudioMutePublishResult() argument
304 SignalRemoteMuteResult(task_id, mutee_nick); in OnAudioMutePublishResult()
306 SignalPublishAudioMuteResult(task_id); in OnAudioMutePublishResult()
311 const std::string& task_id, const XmlElement* item, in OnAudioMutePublishError() argument
315 SignalRemoteMuteError(task_id, mutee_nick, stanza); in OnAudioMutePublishError()
317 SignalPublishAudioMuteError(task_id, stanza); in OnAudioMutePublishError()
[all …]
Dhangoutpubsubclient.h129 void OnPresenterPublishResult(const std::string& task_id,
131 void OnPresenterPublishError(const std::string& task_id,
135 void OnAudioMutePublishResult(const std::string& task_id,
137 void OnAudioMutePublishError(const std::string& task_id,
141 void OnVideoMutePublishResult(const std::string& task_id,
143 void OnVideoMutePublishError(const std::string& task_id,
147 void OnVideoPausePublishResult(const std::string& task_id,
149 void OnVideoPausePublishError(const std::string& task_id,
153 void OnRecordingPublishResult(const std::string& task_id,
155 void OnRecordingPublishError(const std::string& task_id,
[all …]
Dhangoutpubsubclient_unittest.cc91 void OnPublishAudioMuteError(const std::string& task_id, in OnPublishAudioMuteError() argument
94 error_task_id = task_id; in OnPublishAudioMuteError()
97 void OnPublishVideoMuteError(const std::string& task_id, in OnPublishVideoMuteError() argument
100 error_task_id = task_id; in OnPublishVideoMuteError()
103 void OnPublishVideoPauseError(const std::string& task_id, in OnPublishVideoPauseError() argument
106 error_task_id = task_id; in OnPublishVideoPauseError()
109 void OnPublishPresenterError(const std::string& task_id, in OnPublishPresenterError() argument
112 error_task_id = task_id; in OnPublishPresenterError()
115 void OnPublishRecordingError(const std::string& task_id, in OnPublishRecordingError() argument
118 error_task_id = task_id; in OnPublishRecordingError()
[all …]
/external/libchrome/base/task/
Dcancelable_task_tracker_unittest.cc112 CancelableTaskTracker::TaskId task_id = task_tracker_.PostTask( in TEST_F() local
114 EXPECT_NE(CancelableTaskTracker::kBadTaskId, task_id); in TEST_F()
118 task_tracker_.TryCancel(task_id); in TEST_F()
130 CancelableTaskTracker::TaskId task_id = in TEST_F() local
135 EXPECT_NE(CancelableTaskTracker::kBadTaskId, task_id); in TEST_F()
137 task_tracker_.TryCancel(task_id); in TEST_F()
149 CancelableTaskTracker::TaskId task_id = in TEST_F() local
154 EXPECT_NE(CancelableTaskTracker::kBadTaskId, task_id); in TEST_F()
158 task_tracker_.TryCancel(task_id); in TEST_F()
168 CancelableTaskTracker::TaskId task_id = task_tracker_.PostTaskAndReply( in TEST_F() local
[all …]
/external/autotest/venv/skylab_staging/
Dtest_push.py153 task_id = swclient.trigger_suite(
160 _logger.info('Triggered provision suite. Task id: %s', task_id)
162 task_id,
173 task_id = swclient.trigger_suite(
180 _logger.info('Triggered skylab_staging_test suite. Task id: %s', task_id)
181 _verify_suite_creation(swclient, task_id)
183 swclient.task_url(task_id))
185 task_id,
194 _verify_test_results(task_id, _EXPECTED_TEST_RESULTS)
197 def _verify_suite_creation(swclient, task_id): argument
[all …]
/external/tensorflow/tensorflow/contrib/distribute/python/
Dcollective_all_reduce_strategy_test.py73 task_id=None, argument
80 if cluster_spec and task_type and task_id is not None:
84 task_id=task_id,
86 target = 'grpc://' + cluster_spec[task_type][task_id]
97 if task_type and task_id is not None:
102 task_id=task_id)
103 target = 'grpc://' + cluster_spec[task_type][task_id]
125 task_id, argument
131 task_id=task_id,
149 task_id, argument
[all …]
/external/tensorflow/tensorflow/python/tpu/
Ddevice_assignment.py38 task_id = topology.task_ordinal_at_coordinates(coordinates)
39 if task_id not in task_and_cores_to_replicas:
40 task_and_cores_to_replicas[task_id] = {}
41 if logical_core not in task_and_cores_to_replicas[task_id]:
42 task_and_cores_to_replicas[task_id][logical_core] = set()
44 task_and_cores_to_replicas[task_id][logical_core].add(replica)
133 def lookup_replicas(self, task_id, logical_core): argument
147 return self._task_and_cores_to_replicas[task_id][logical_core]
151 format(task_id, logical_core))

12345