 |
|
|
|
.. (parent) |
 |
d |
rwxr-xr-x |
4,096 |
coordination
|
 |
d |
rwxr-xr-x |
4,096 |
eager
|
 |
d |
rwxr-xr-x |
4,096 |
integration_test
|
 |
d |
rwxr-xr-x |
135 |
preemption
|
 |
d |
rwxr-xr-x |
4,096 |
rpc
|
 |
- |
rw-r--r-- |
27,520 |
BUILD
|
 |
- |
rw-r--r-- |
355 |
README.md
|
 |
- |
rw-r--r-- |
19,393 |
base_rendezvous_mgr.cc
|
 |
- |
rw-r--r-- |
11,226 |
base_rendezvous_mgr.h
|
 |
- |
rw-r--r-- |
1,069 |
call_options.h
|
 |
- |
rw-r--r-- |
1,239 |
call_options_test.cc
|
 |
- |
rw-r--r-- |
1,468 |
cancellable_call.cc
|
 |
- |
rw-r--r-- |
2,360 |
cancellable_call.h
|
 |
- |
rw-r--r-- |
14,531 |
cluster_function_library_runtime.cc
|
 |
- |
rw-r--r-- |
4,385 |
cluster_function_library_runtime.h
|
 |
- |
rw-r--r-- |
11,256 |
cluster_function_library_runtime_test.cc
|
 |
- |
rw-r--r-- |
15,736 |
collective_param_resolver_distributed.cc
|
 |
- |
rw-r--r-- |
4,255 |
collective_param_resolver_distributed.h
|
 |
- |
rw-r--r-- |
14,943 |
collective_param_resolver_distributed_test.cc
|
 |
- |
rw-r--r-- |
12,038 |
collective_rma_distributed.cc
|
 |
- |
rw-r--r-- |
2,804 |
collective_rma_distributed.h
|
 |
- |
rw-r--r-- |
24,401 |
collective_rma_distributed_test.cc
|
 |
- |
rw-r--r-- |
2,669 |
device_resolver_distributed.cc
|
 |
- |
rw-r--r-- |
1,839 |
device_resolver_distributed.h
|
 |
- |
rw-r--r-- |
6,683 |
device_resolver_distributed_test.cc
|
 |
- |
rw-r--r-- |
1,515 |
error_payloads.h
|
 |
- |
rw-r--r-- |
22,884 |
graph_mgr.cc
|
 |
- |
rw-r--r-- |
7,868 |
graph_mgr.h
|
 |
- |
rw-r--r-- |
8,243 |
local_master.cc
|
 |
- |
rw-r--r-- |
4,609 |
local_master.h
|
 |
- |
rw-r--r-- |
26,724 |
master.cc
|
 |
- |
rw-r--r-- |
4,164 |
master.h
|
 |
- |
rw-r--r-- |
3,966 |
master_env.h
|
 |
- |
rw-r--r-- |
5,101 |
master_interface.h
|
 |
- |
rw-r--r-- |
80,860 |
master_session.cc
|
 |
- |
rw-r--r-- |
9,984 |
master_session.h
|
 |
- |
rw-r--r-- |
14,604 |
master_test.cc
|
 |
- |
rw-r--r-- |
29,411 |
message_wrappers.cc
|
 |
- |
rw-r--r-- |
30,565 |
message_wrappers.h
|
 |
- |
rw-r--r-- |
13,344 |
message_wrappers_test.cc
|
 |
- |
rw-r--r-- |
3,080 |
partial_run_mgr.cc
|
 |
- |
rw-r--r-- |
3,735 |
partial_run_mgr.h
|
 |
- |
rw-r--r-- |
5,542 |
partial_run_mgr_test.cc
|
 |
- |
rw-r--r-- |
2,789 |
recent_request_ids.cc
|
 |
- |
rw-r--r-- |
4,483 |
recent_request_ids.h
|
 |
- |
rw-r--r-- |
4,299 |
recent_request_ids_test.cc
|
 |
- |
rw-r--r-- |
5,972 |
remote_device.cc
|
 |
- |
rw-r--r-- |
2,812 |
remote_device.h
|
 |
- |
rw-r--r-- |
3,803 |
remote_device_test.cc
|
 |
- |
rw-r--r-- |
4,377 |
rendezvous_mgr_interface.h
|
 |
- |
rw-r--r-- |
990 |
request_id.cc
|
 |
- |
rw-r--r-- |
1,231 |
request_id.h
|
 |
- |
rw-r--r-- |
1,011 |
request_id_test.cc
|
 |
- |
rw-r--r-- |
7,203 |
rpc_collective_executor_mgr.cc
|
 |
- |
rw-r--r-- |
3,843 |
rpc_collective_executor_mgr.h
|
 |
- |
rw-r--r-- |
6,584 |
rpc_collective_executor_mgr_test.cc
|
 |
- |
rw-r--r-- |
8,523 |
rpcbench_test.cc
|
 |
- |
rw-r--r-- |
10,791 |
scheduler.cc
|
 |
- |
rw-r--r-- |
3,601 |
scheduler.h
|
 |
- |
rw-r--r-- |
3,263 |
server_lib.cc
|
 |
- |
rw-r--r-- |
4,943 |
server_lib.h
|
 |
- |
rw-r--r-- |
2,005 |
server_lib_test.cc
|
 |
- |
rw-r--r-- |
20,391 |
session_mgr.cc
|
 |
- |
rw-r--r-- |
6,902 |
session_mgr.h
|
 |
- |
rw-r--r-- |
11,362 |
session_mgr_test.cc
|
 |
- |
rw-r--r-- |
9,763 |
tensor_coding.cc
|
 |
- |
rw-r--r-- |
3,948 |
tensor_coding.h
|
 |
- |
rw-r--r-- |
6,634 |
tensor_coding_test.cc
|
 |
- |
rw-r--r-- |
7,366 |
test_utils.h
|
 |
- |
rw-r--r-- |
19,339 |
worker.cc
|
 |
- |
rw-r--r-- |
5,724 |
worker.h
|
 |
- |
rw-r--r-- |
4,241 |
worker_cache.h
|
 |
- |
rw-r--r-- |
4,977 |
worker_cache_logger.cc
|
 |
- |
rw-r--r-- |
3,417 |
worker_cache_logger.h
|
 |
- |
rw-r--r-- |
3,229 |
worker_cache_partial.cc
|
 |
- |
rw-r--r-- |
2,116 |
worker_cache_partial.h
|
 |
- |
rw-r--r-- |
4,137 |
worker_cache_wrapper.h
|
 |
- |
rw-r--r-- |
2,624 |
worker_env.h
|
 |
- |
rw-r--r-- |
9,237 |
worker_interface.h
|
 |
- |
rw-r--r-- |
7,625 |
worker_session.cc
|
 |
- |
rw-r--r-- |
5,433 |
worker_session.h
|