static */
| 131 | |
| 132 | /* static */ |
| 133 | Status VerbsServer::Create(const ServerDef& server_def, Env* env, |
| 134 | std::unique_ptr<ServerInterface>* out_server) { |
| 135 | std::unique_ptr<VerbsServer> ret(new VerbsServer(server_def, Env::Default())); |
| 136 | ServiceInitFunction service_func = [&ret](const WorkerEnv* worker_env, |
| 137 | ::grpc::ServerBuilder* builder) { |
| 138 | return SetNewVerbsService(&ret->verbs_service_, worker_env, builder); |
| 139 | }; |
| 140 | TF_RETURN_IF_ERROR(ret->Init(service_func, NewRdmaRendezvousMgr)); |
| 141 | *out_server = std::move(ret); |
| 142 | return Status::OK(); |
| 143 | } |
| 144 | |
| 145 | namespace { |
| 146 |
nothing calls this directly
no test coverage detected