(graph_name, server_id, server_count, num_clients, shared_mem)
| 71 | |
| 72 | |
| 73 | def run_server(graph_name, server_id, server_count, num_clients, shared_mem): |
| 74 | g = DistGraphServer( |
| 75 | server_id, |
| 76 | "optim_ip_config.txt", |
| 77 | num_clients, |
| 78 | server_count, |
| 79 | "/tmp/dist_graph/{}.json".format(graph_name), |
| 80 | disable_shared_mem=not shared_mem, |
| 81 | ) |
| 82 | print("start server", server_id) |
| 83 | g.start() |
| 84 | |
| 85 | |
| 86 | def initializer(shape, dtype): |
nothing calls this directly
no test coverage detected