You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by br...@apache.org on 2011/02/05 21:27:55 UTC
svn commit: r1067513 -
/cassandra/trunk/src/java/org/apache/cassandra/gms/Gossiper.java
Author: brandonwilliams
Date: Sat Feb 5 20:27:55 2011
New Revision: 1067513
URL: http://svn.apache.org/viewvc?rev=1067513&view=rev
Log:
Fix broken merge
Modified:
cassandra/trunk/src/java/org/apache/cassandra/gms/Gossiper.java
Modified: cassandra/trunk/src/java/org/apache/cassandra/gms/Gossiper.java
URL: http://svn.apache.org/viewvc/cassandra/trunk/src/java/org/apache/cassandra/gms/Gossiper.java?rev=1067513&r1=1067512&r2=1067513&view=diff
==============================================================================
--- cassandra/trunk/src/java/org/apache/cassandra/gms/Gossiper.java (original)
+++ cassandra/trunk/src/java/org/apache/cassandra/gms/Gossiper.java Sat Feb 5 20:27:55 2011
@@ -325,7 +325,7 @@ public class Gossiper implements IFailur
ByteArrayOutputStream bos = new ByteArrayOutputStream();
DataOutputStream dos = new DataOutputStream(bos);
GossipDigestAckMessage.serializer().serialize(gDigestAckMessage, dos);
- return new Message(localEndpoint_, StorageService.Verb.GOSSIP_DIGEST_ACK, bos.toByteArray());
+ return new Message(FBUtilities.getLocalAddress(), StorageService.Verb.GOSSIP_DIGEST_ACK, bos.toByteArray());
}
Message makeGossipDigestAck2Message(GossipDigestAck2Message gDigestAck2Message) throws IOException
@@ -431,7 +431,7 @@ public class Gossiper implements IFailur
else
{
logger.info("FatClient " + endpoint + " has been silent for " + FatClientTimeout + "ms, removing from gossip");
- if (!justRemovedEndpoints_.containsKey(endpoint)) // if the node was decommissioned, it will have been removed but still appear as a fat client
+ if (!justRemovedEndpoints.containsKey(endpoint)) // if the node was decommissioned, it will have been removed but still appear as a fat client
removeEndpoint(endpoint); // after quarantine justRemoveEndpoints will remove the state
}
}
@@ -452,7 +452,7 @@ public class Gossiper implements IFailur
if (logger.isDebugEnabled())
logger.debug(QUARANTINE_DELAY + " elapsed, " + entry.getKey() + " gossip quarantine over");
justRemovedEndpoints.remove(entry.getKey());
- endpointStateMap_.remove(entry.getKey());
+ endpointStateMap.remove(entry.getKey());
}
}
}
@@ -482,8 +482,8 @@ public class Gossiper implements IFailur
if ( localHbVersion > version )
{
reqdEndpointState = new EndpointState(epState.getHeartBeatState());
- if (logger_.isTraceEnabled())
- logger_.trace("local heartbeat version " + localHbVersion + " greater than " + version + " for " + forEndpoint);
+ if (logger.isTraceEnabled())
+ logger.trace("local heartbeat version " + localHbVersion + " greater than " + version + " for " + forEndpoint);
}
/* Accumulate all application states whose versions are greater than "version" variable */
for (Entry<ApplicationState, VersionedValue> entry : epState.getApplicationStateMap().entrySet())
@@ -658,8 +658,8 @@ public class Gossiper implements IFailur
}
else
{
- if (logger_.isTraceEnabled())
- logger_.trace("Ignoring remote generation " + remoteGeneration + " < " + localGeneration);
+ if (logger.isTraceEnabled())
+ logger.trace("Ignoring remote generation " + remoteGeneration + " < " + localGeneration);
}
}
else
@@ -677,8 +677,8 @@ public class Gossiper implements IFailur
Map<ApplicationState, VersionedValue> localAppStateMap = localState.getApplicationStateMap();
localState.setHeartBeatState(remoteHbState);
- if (logger_.isTraceEnabled())
- logger_.trace("Updating heartbeat state generation to " + remoteHbState.getGeneration() + " from " + localHbState.getGeneration() + " for " + addr);
+ if (logger.isTraceEnabled())
+ logger.trace("Updating heartbeat state generation to " + remoteHbState.getGeneration() + " from " + localHbState.getGeneration() + " for " + addr);
for (Entry<ApplicationState, VersionedValue> remoteEntry : remoteState.getApplicationStateMap().entrySet())
{
@@ -705,8 +705,8 @@ public class Gossiper implements IFailur
{
/* We are here since we have no data for this endpoint locally so request everthing. */
deltaGossipDigestList.add( new GossipDigest(gDigest.getEndpoint(), remoteGeneration, 0) );
- if (logger_.isTraceEnabled())
- logger_.trace("requestAll for " + gDigest.getEndpoint());
+ if (logger.isTraceEnabled())
+ logger.trace("requestAll for " + gDigest.getEndpoint());
}
/* Send all the data with version greater than maxRemoteVersion */