You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mesos.apache.org by vi...@apache.org on 2014/02/26 20:08:31 UTC
git commit: Logged ZooKeeper session expiration event in group.
Repository: mesos
Updated Branches:
refs/heads/master cfc955247 -> 0d52b1190
Logged ZooKeeper session expiration event in group.
Project: http://git-wip-us.apache.org/repos/asf/mesos/repo
Commit: http://git-wip-us.apache.org/repos/asf/mesos/commit/0d52b119
Tree: http://git-wip-us.apache.org/repos/asf/mesos/tree/0d52b119
Diff: http://git-wip-us.apache.org/repos/asf/mesos/diff/0d52b119
Branch: refs/heads/master
Commit: 0d52b119094d6faf217c5249aebdf35cbbf3597d
Parents: cfc9552
Author: Vinod Kone <vi...@twitter.com>
Authored: Wed Feb 26 11:07:41 2014 -0800
Committer: Vinod Kone <vi...@twitter.com>
Committed: Wed Feb 26 11:07:41 2014 -0800
----------------------------------------------------------------------
src/zookeeper/group.cpp | 7 +++++--
1 file changed, 5 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/mesos/blob/0d52b119/src/zookeeper/group.cpp
----------------------------------------------------------------------
diff --git a/src/zookeeper/group.cpp b/src/zookeeper/group.cpp
index 247361d..cff5997 100644
--- a/src/zookeeper/group.cpp
+++ b/src/zookeeper/group.cpp
@@ -450,8 +450,9 @@ void GroupProcess::timedout(int64_t sessionId)
zk->getSessionId() == sessionId) {
// The timer can be reset or replaced and 'zk' can be replaced
// since this method was dispatched.
- LOG(WARNING) << "Timed out waiting to reconnect to ZooKeeper "
- << "(sessionId=" << std::hex << sessionId << ")";
+ LOG(WARNING) << "Timed out waiting to reconnect to ZooKeeper."
+ << " Forcing ZooKeeper session "
+ << "(sessionId=" << std::hex << sessionId << ") expiration";
// Locally determine that the current session has expired.
expired();
@@ -465,6 +466,8 @@ void GroupProcess::expired()
return;
}
+ LOG(INFO) << "ZooKeeper session expired";
+
// Cancel the retries. Group will sync() after it reconnects to ZK.
retrying = false;