Home
last modified time | relevance | path

Searched refs:current_tasks (Results 1 – 6 of 6) sorted by relevance

/external/tensorflow/tensorflow/core/data/service/
Dworker_impl.cc311 std::vector<int64> current_tasks; in Heartbeat() local
315 current_tasks.push_back(task.first); in Heartbeat()
322 current_tasks, new_tasks, tasks_to_delete)); in Heartbeat()
Ddispatcher_impl.cc228 absl::flat_hash_set<int64> current_tasks; in WorkerHeartbeat() local
229 current_tasks.insert(request->current_tasks().cbegin(), in WorkerHeartbeat()
230 request->current_tasks().cend()); in WorkerHeartbeat()
235 if (current_tasks.contains(task->task_id)) { in WorkerHeartbeat()
261 for (int64 current_task : current_tasks) { in WorkerHeartbeat()
Ddata_service.h92 const std::vector<int64>& current_tasks,
Ddata_service.cc62 const std::vector<int64>& current_tasks, std::vector<TaskDef>& new_tasks, in WorkerHeartbeat() argument
68 for (int64 task : current_tasks) { in WorkerHeartbeat()
Ddispatcher.proto18 repeated int64 current_tasks = 2; field
/external/python/cpython3/Modules/
D_asynciomodule.c48 static PyObject *current_tasks; variable
2001 item = _PyDict_GetItem_KnownHash(current_tasks, loop, hash); in enter_task()
2015 return _PyDict_SetItem_KnownHash(current_tasks, loop, task, hash); in enter_task()
2029 item = _PyDict_GetItem_KnownHash(current_tasks, loop, hash); in leave_task()
2041 return _PyDict_DelItem_KnownHash(current_tasks, loop, hash); in leave_task()
3314 Py_CLEAR(current_tasks); in module_free()
3340 current_tasks = PyDict_New(); in module_init()
3341 if (current_tasks == NULL) { in module_init()
3480 Py_INCREF(current_tasks); in PyInit__asyncio()
3481 if (PyModule_AddObject(m, "_current_tasks", current_tasks) < 0) { in PyInit__asyncio()
[all …]