Loading include/common/common_defs.hpp +1 −0 Original line number Diff line number Diff line Loading @@ -62,6 +62,7 @@ constexpr auto ofi_psm2 = "ofi+psm2"; constexpr auto ofi_sockets = "ofi+sockets"; constexpr auto ofi_tcp = "ofi+tcp"; constexpr auto ofi_verbs = "ofi+verbs"; constexpr auto ofi_opx = "ofi+opx"; constexpr auto na_sm = "na+sm"; } // namespace protocol } // namespace gkfs::rpc Loading src/daemon/daemon.cpp +2 −1 Original line number Diff line number Diff line Loading @@ -498,7 +498,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_opx) { throw runtime_error(fmt::format( "Given RPC protocol '{}' not supported. Check --help for supported protocols.", rpc_protocol)); Loading Loading
include/common/common_defs.hpp +1 −0 Original line number Diff line number Diff line Loading @@ -62,6 +62,7 @@ constexpr auto ofi_psm2 = "ofi+psm2"; constexpr auto ofi_sockets = "ofi+sockets"; constexpr auto ofi_tcp = "ofi+tcp"; constexpr auto ofi_verbs = "ofi+verbs"; constexpr auto ofi_opx = "ofi+opx"; constexpr auto na_sm = "na+sm"; } // namespace protocol } // namespace gkfs::rpc Loading
src/daemon/daemon.cpp +2 −1 Original line number Diff line number Diff line Loading @@ -498,7 +498,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_opx) { throw runtime_error(fmt::format( "Given RPC protocol '{}' not supported. Check --help for supported protocols.", rpc_protocol)); Loading