Loading src/client/preload_util.cpp +2 −0 Original line number Diff line number Diff line Loading @@ -111,6 +111,8 @@ extract_protocol(const string& uri) { protocol = gkfs::rpc::protocol::ofi_psm2; } else if(uri.find(gkfs::rpc::protocol::ofi_verbs) != string::npos) { protocol = gkfs::rpc::protocol::ofi_verbs; } else if(uri.find(gkfs::rpc::protocol::ofi_tcp) != string::npos) { protocol = gkfs::rpc::protocol::ofi_tcp; } // check for shared memory protocol. Can be plain shared memory or real ofi // protocol + auto_sm Loading src/daemon/daemon.cpp +2 −1 Original line number Diff line number Diff line Loading @@ -479,7 +479,8 @@ parse_input(const cli_options& opts, const CLI::App& desc) { rpc_protocol = opts.rpc_protocol; if(rpc_protocol != gkfs::rpc::protocol::ofi_verbs && rpc_protocol != gkfs::rpc::protocol::ofi_sockets && rpc_protocol != gkfs::rpc::protocol::ofi_psm2) { rpc_protocol != gkfs::rpc::protocol::ofi_psm2 && rpc_protocol != gkfs::rpc::protocol::ofi_tcp) { throw runtime_error(fmt::format( "Given RPC protocol '{}' not supported. Check --help for supported protocols.", rpc_protocol)); Loading Loading
src/client/preload_util.cpp +2 −0 Original line number Diff line number Diff line Loading @@ -111,6 +111,8 @@ extract_protocol(const string& uri) { protocol = gkfs::rpc::protocol::ofi_psm2; } else if(uri.find(gkfs::rpc::protocol::ofi_verbs) != string::npos) { protocol = gkfs::rpc::protocol::ofi_verbs; } else if(uri.find(gkfs::rpc::protocol::ofi_tcp) != string::npos) { protocol = gkfs::rpc::protocol::ofi_tcp; } // check for shared memory protocol. Can be plain shared memory or real ofi // protocol + auto_sm Loading
src/daemon/daemon.cpp +2 −1 Original line number Diff line number Diff line Loading @@ -479,7 +479,8 @@ parse_input(const cli_options& opts, const CLI::App& desc) { rpc_protocol = opts.rpc_protocol; if(rpc_protocol != gkfs::rpc::protocol::ofi_verbs && rpc_protocol != gkfs::rpc::protocol::ofi_sockets && rpc_protocol != gkfs::rpc::protocol::ofi_psm2) { rpc_protocol != gkfs::rpc::protocol::ofi_psm2 && rpc_protocol != gkfs::rpc::protocol::ofi_tcp) { throw runtime_error(fmt::format( "Given RPC protocol '{}' not supported. Check --help for supported protocols.", rpc_protocol)); Loading