Loading src/daemon/daemon.cpp +9 −0 Original line number Diff line number Diff line Loading @@ -493,6 +493,9 @@ main(int argc, const char* argv[]) { "Available: {ofi+sockets, ofi+verbs, ofi+psm2} for TCP, Infiniband, " "and Omni-Path, respectively. (Default ofi+sockets)\n" "Libfabric must have enabled support verbs or psm2."); desc.add_options()( "shuffle", "WIP: Send signal for shuffle phase to all running daemons, then quit."); desc.add_options()( "auto-sm", "Enables intra-node communication (IPCs) via the `na+sm` (shared memory) protocol, " Loading Loading @@ -543,6 +546,12 @@ main(int argc, const char* argv[]) { exit(EXIT_FAILURE); } if (vm.count("shuffle")) { cout << "Starting shuffle...\n"; test_d2d_rpc(); return 0; } /* * Initialize environment and start daemon. Wait until signaled to cancel * before shutting down Loading Loading
src/daemon/daemon.cpp +9 −0 Original line number Diff line number Diff line Loading @@ -493,6 +493,9 @@ main(int argc, const char* argv[]) { "Available: {ofi+sockets, ofi+verbs, ofi+psm2} for TCP, Infiniband, " "and Omni-Path, respectively. (Default ofi+sockets)\n" "Libfabric must have enabled support verbs or psm2."); desc.add_options()( "shuffle", "WIP: Send signal for shuffle phase to all running daemons, then quit."); desc.add_options()( "auto-sm", "Enables intra-node communication (IPCs) via the `na+sm` (shared memory) protocol, " Loading Loading @@ -543,6 +546,12 @@ main(int argc, const char* argv[]) { exit(EXIT_FAILURE); } if (vm.count("shuffle")) { cout << "Starting shuffle...\n"; test_d2d_rpc(); return 0; } /* * Initialize environment and start daemon. Wait until signaled to cancel * before shutting down Loading