| 391 | |
| 392 | |
| 393 | void ZooKeeperStorageProcess::expired(int64_t sessionId) |
| 394 | { |
| 395 | if (sessionId != zk->getSessionId()) { |
| 396 | return; |
| 397 | } |
| 398 | |
| 399 | state = DISCONNECTED; |
| 400 | |
| 401 | delete zk; |
| 402 | zk = new ZooKeeper(servers, timeout, watcher); |
| 403 | |
| 404 | state = CONNECTING; |
| 405 | } |
| 406 | |
| 407 | |
| 408 | void ZooKeeperStorageProcess::updated(int64_t sessionId, const string& path) |