You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ac...@apache.org on 2010/03/29 15:54:47 UTC
svn commit: r928779 - in /qpid/trunk/qpid/cpp/src/qpid/cluster: Cluster.cpp
ClusterTimer.cpp
Author: aconway
Date: Mon Mar 29 13:54:46 2010
New Revision: 928779
URL: http://svn.apache.org/viewvc?rev=928779&view=rev
Log:
Raise ClusterTimer lateness threshold to reduce noisy warnings.
Modified:
qpid/trunk/qpid/cpp/src/qpid/cluster/Cluster.cpp
qpid/trunk/qpid/cpp/src/qpid/cluster/ClusterTimer.cpp
Modified: qpid/trunk/qpid/cpp/src/qpid/cluster/Cluster.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/cluster/Cluster.cpp?rev=928779&r1=928778&r2=928779&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/cluster/Cluster.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/cluster/Cluster.cpp Mon Mar 29 13:54:46 2010
@@ -668,7 +668,7 @@ void Cluster::configChange(const MemberI
QPID_LOG(debug, "Config sequence " << map.getConfigSeq());
store.setConfigSeq(map.getConfigSeq());
- // Update initital status for new members joining.
+ // Update initital status for members joining or leaving.
initMap.configChange(config);
if (initMap.isResendNeeded()) {
mcast.mcastControl(
@@ -757,6 +757,8 @@ void Cluster::initialStatus(const Member
leave(l);
return;
}
+ QPID_LOG_IF(debug, state == PRE_INIT, *this
+ << " received initial status from " << member);
initMap.received(
member,
ClusterInitialStatusBody(ProtocolVersion(), version, active, id,
Modified: qpid/trunk/qpid/cpp/src/qpid/cluster/ClusterTimer.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/cluster/ClusterTimer.cpp?rev=928779&r1=928778&r2=928779&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/cluster/ClusterTimer.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/cluster/ClusterTimer.cpp Mon Mar 29 13:54:46 2010
@@ -38,6 +38,7 @@ ClusterTimer::ClusterTimer(Cluster& c) :
// Allow more generous overrun threshold with cluster as we
// have to do a CPG round trip before executing the task.
overran = 10*sys::TIME_MSEC;
+ late = 100*sys::TIME_MSEC;
}
ClusterTimer::~ClusterTimer() {}
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org