(
rank,
tmpdir,
disable_shared_mem,
graph_name,
graph_format=["csc", "coo"],
use_graphbolt=False,
)
| 30 | |
| 31 | |
| 32 | def start_server( |
| 33 | rank, |
| 34 | tmpdir, |
| 35 | disable_shared_mem, |
| 36 | graph_name, |
| 37 | graph_format=["csc", "coo"], |
| 38 | use_graphbolt=False, |
| 39 | ): |
| 40 | g = DistGraphServer( |
| 41 | rank, |
| 42 | "rpc_ip_config.txt", |
| 43 | 1, |
| 44 | 1, |
| 45 | tmpdir / (graph_name + ".json"), |
| 46 | disable_shared_mem=disable_shared_mem, |
| 47 | graph_format=graph_format, |
| 48 | use_graphbolt=use_graphbolt, |
| 49 | ) |
| 50 | g.start() |
| 51 | |
| 52 | |
| 53 | def start_sample_client(rank, tmpdir, disable_shared_mem): |
nothing calls this directly
no test coverage detected