MCPcopy
hub / github.com/dmlc/dgl / start

Method start

python/dgl/distributed/dist_graph.py:618–638  ·  view source on GitHub ↗

Start graph store server.

(self)

Source from the content-addressed store, hash-verified

616 gc.collect()
617
618 def start(self):
619 """Start graph store server."""
620 # start server
621 server_state = ServerState(
622 kv_store=self,
623 local_g=self.client_g,
624 partition_book=self.gpb,
625 use_graphbolt=self.use_graphbolt,
626 )
627 print(
628 "start graph service on server {} for part {}".format(
629 self.server_id, self.part_id
630 )
631 )
632 start_server(
633 server_id=self.server_id,
634 ip_config=self.ip_config,
635 num_servers=self.num_servers,
636 num_clients=self.num_clients,
637 server_state=server_state,
638 )
639
640
641class DistGraph:

Callers 15

initializeFunction · 0.95
run_serverFunction · 0.95
run_serverFunction · 0.95
start_serverFunction · 0.95
start_serverFunction · 0.95
execute_remoteFunction · 0.80
submit_jobsFunction · 0.80
execute_remoteFunction · 0.80
submit_jobsFunction · 0.80
single_machine_runFunction · 0.80
__init__Method · 0.80
__init__Method · 0.80

Calls 3

ServerStateClass · 0.85
formatMethod · 0.80
start_serverFunction · 0.70

Tested by 15

run_serverFunction · 0.76
run_serverFunction · 0.76
start_serverFunction · 0.76
start_serverFunction · 0.76
_single_machine_runFunction · 0.64
test_multi_processFunction · 0.64
test_copy_from_gpuFunction · 0.64
test_forking_picklerFunction · 0.64
test_torch_ipcFunction · 0.64
check_sparse_adamFunction · 0.64