| 118 | } |
| 119 | |
| 120 | Status VerbsServer::Join() { |
| 121 | Status s = GrpcServer::Join(); |
| 122 | { |
| 123 | mutex_lock l(mu_); |
| 124 | if (verbs_state_ == CONNECTED) { |
| 125 | verbs_state_ = DISCONNECTED; |
| 126 | verbs_thread_.reset(); |
| 127 | } |
| 128 | } |
| 129 | return s; |
| 130 | } |
| 131 | |
| 132 | /* static */ |
| 133 | Status VerbsServer::Create(const ServerDef& server_def, Env* env, |