MCPcopy Create free account
hub / github.com/Oneflow-Inc/oneflow / GetTaskStreamIndex

Method GetTaskStreamIndex

oneflow/core/graph/task_stream_index_manager.cpp:39–45  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

37}
38
39TaskStreamIndexManager::stream_index_t TaskStreamIndexManager::GetTaskStreamIndex(
40 TaskType task_type, const DeviceId& device_id) {
41 auto* generator = GetGenerator(device_id);
42 auto stream_index = CHECK_JUST(TaskStreamIndexGetterRegistry::Instance().Dispatch(
43 device_id.device_type(), task_type, generator));
44 return stream_index;
45}
46
47TaskStreamIndexManager::stream_index_t TaskStreamIndexManager::GetComputeTaskStreamIndex(
48 const DeviceId& device_id) {

Callers 2

GetIdStateMethod · 0.80
GetStreamIdFunction · 0.80

Calls 4

EncodeDeviceIdToInt64Function · 0.85
GetCurrStreamIndexMethod · 0.80
DispatchMethod · 0.45
device_typeMethod · 0.45

Tested by

no test coverage detected