| 1284 | } |
| 1285 | |
| 1286 | int Server::Stop(int timeout_ms) { |
| 1287 | if (_status != RUNNING) { |
| 1288 | return -1; |
| 1289 | } |
| 1290 | _status = STOPPING; |
| 1291 | |
| 1292 | LOG(INFO) << "Server[" << version() << "] is going to quit"; |
| 1293 | |
| 1294 | if (_am) { |
| 1295 | _am->StopAccept(timeout_ms); |
| 1296 | } |
| 1297 | if (_internal_am) { |
| 1298 | // TODO: calculate timeout? |
| 1299 | _internal_am->StopAccept(timeout_ms); |
| 1300 | } |
| 1301 | return 0; |
| 1302 | } |
| 1303 | |
| 1304 | // NOTE: Join() can happen before Stop(). |
| 1305 | int Server::Join() { |