Searched defs:source_task (Results 1 – 6 of 6) sorted by relevance
40 CoordinatedTask source_task = 4; field68 CoordinatedTask source_task = 5; field80 CoordinatedTask source_task = 4; field97 CoordinatedTask source_task = 5; field110 CoordinatedTask source_task = 1; field117 CoordinatedTask source_task = 1; field202 CoordinatedTask source_task = 4; field211 CoordinatedTask source_task = 2; field
5250 inline const ::tensorflow::CoordinatedTask& CoordinationServiceError::source_task() const { in source_task() function5255 ::tensorflow::CoordinatedTask* source_task) { in unsafe_arena_set_allocated_source_task()5297 …id CoordinationServiceError::set_allocated_source_task(::tensorflow::CoordinatedTask* source_task)… in set_allocated_source_task()5645 inline const ::tensorflow::CoordinatedTask& RegisterTaskRequest::source_task() const { in source_task() function5650 ::tensorflow::CoordinatedTask* source_task) { in unsafe_arena_set_allocated_source_task()5692 …ne void RegisterTaskRequest::set_allocated_source_task(::tensorflow::CoordinatedTask* source_task)… in set_allocated_source_task()5778 inline const ::tensorflow::CoordinatedTask& HeartbeatRequest::source_task() const { in source_task() function5783 ::tensorflow::CoordinatedTask* source_task) { in unsafe_arena_set_allocated_source_task()5825 inline void HeartbeatRequest::set_allocated_source_task(::tensorflow::CoordinatedTask* source_task)… in set_allocated_source_task()5976 inline const ::tensorflow::CoordinatedTask& WaitForAllTasksRequest::source_task() const { in source_task() function[all …]
782 CoordinationServiceError::_Internal::source_task(const CoordinationServiceError* msg) { in source_task() function in tensorflow::CoordinationServiceError::_Internal1708 RegisterTaskRequest::_Internal::source_task(const RegisterTaskRequest* msg) { in source_task() function in tensorflow::RegisterTaskRequest::_Internal2117 HeartbeatRequest::_Internal::source_task(const HeartbeatRequest* msg) { in source_task() function in tensorflow::HeartbeatRequest::_Internal2531 WaitForAllTasksRequest::_Internal::source_task(const WaitForAllTasksRequest* msg) { in source_task() function in tensorflow::WaitForAllTasksRequest::_Internal2997 ShutdownTaskRequest::_Internal::source_task(const ShutdownTaskRequest* msg) { in source_task() function in tensorflow::ShutdownTaskRequest::_Internal3337 ResetTaskRequest::_Internal::source_task(const ResetTaskRequest* msg) { in source_task() function in tensorflow::ResetTaskRequest::_Internal6748 BarrierRequest::_Internal::source_task(const BarrierRequest* msg) { in source_task() function in tensorflow::BarrierRequest::_Internal7208 CancelBarrierRequest::_Internal::source_task(const CancelBarrierRequest* msg) { in source_task() function in tensorflow::CancelBarrierRequest::_Internal
40 CoordinatedTask source_task; in TEST() local59 CoordinatedTask source_task; in TEST() local80 CoordinatedTask* source_task = payload.mutable_source_task(); in TEST() local
717 const CoordinatedTask& source_task, bool is_reported_by_task) { in PropagateError()
131 int source_task = GetDeviceTask(col_params->source_rank, dev_per_task); in InitializeCollectiveParams() local