You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by jb...@apache.org on 2009/03/27 03:19:51 UTC
svn commit: r758980 - in
/incubator/cassandra/trunk/src/org/apache/cassandra/gms:
FailureDetector.java Gossiper.java
Author: jbellis
Date: Fri Mar 27 02:19:51 2009
New Revision: 758980
URL: http://svn.apache.org/viewvc?rev=758980&view=rev
Log:
set normal gossip messages to level `trace`
Modified:
incubator/cassandra/trunk/src/org/apache/cassandra/gms/FailureDetector.java
incubator/cassandra/trunk/src/org/apache/cassandra/gms/Gossiper.java
Modified: incubator/cassandra/trunk/src/org/apache/cassandra/gms/FailureDetector.java
URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/src/org/apache/cassandra/gms/FailureDetector.java?rev=758980&r1=758979&r2=758980&view=diff
==============================================================================
--- incubator/cassandra/trunk/src/org/apache/cassandra/gms/FailureDetector.java (original)
+++ incubator/cassandra/trunk/src/org/apache/cassandra/gms/FailureDetector.java Fri Mar 27 02:19:51 2009
@@ -177,7 +177,7 @@
/* We need this so that we do not suspect a convict. */
boolean isConvicted = false;
double phi = hbWnd.phi(now);
- logger_.info("PHI for " + ep + " : " + phi);
+ logger_.trace("PHI for " + ep + " : " + phi);
/*
if ( phi > phiConvictThreshold_ )
Modified: incubator/cassandra/trunk/src/org/apache/cassandra/gms/Gossiper.java
URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/src/org/apache/cassandra/gms/Gossiper.java?rev=758980&r1=758979&r2=758980&view=diff
==============================================================================
--- incubator/cassandra/trunk/src/org/apache/cassandra/gms/Gossiper.java (original)
+++ incubator/cassandra/trunk/src/org/apache/cassandra/gms/Gossiper.java Fri Mar 27 02:19:51 2009
@@ -76,7 +76,7 @@
if ( !bVal )
doGossipToSeed(message);
- logger_.debug("Performing status check ...");
+ logger_.trace("Performing status check ...");
doStatusCheck();
}
}
@@ -344,7 +344,7 @@
sb.append(gDigest);
sb.append(" ");
}
- logger_.debug("Gossip Digests are : " + sb.toString());
+ logger_.trace("Gossip Digests are : " + sb.toString());
}
public int getCurrentGenerationNumber(EndPoint endpoint)
@@ -367,7 +367,7 @@
ByteArrayOutputStream bos = new ByteArrayOutputStream(Gossiper.MAX_GOSSIP_PACKET_SIZE);
DataOutputStream dos = new DataOutputStream(bos);
GossipDigestAckMessage.serializer().serialize(gDigestAckMessage, dos);
- logger_.debug("@@@@ Size of GossipDigestAckMessage is " + bos.toByteArray().length);
+ logger_.trace("@@@@ Size of GossipDigestAckMessage is " + bos.toByteArray().length);
Message message = new Message(localEndPoint_, Gossiper.GOSSIP_STAGE, GOSSIP_DIGEST_ACK_VERB, new Object[]{bos.toByteArray()});
return message;
}
@@ -392,7 +392,7 @@
}
EndPoint to = eps.get(++rrIndex_);
- logger_.info("Sending a GossipDigestSynMessage to " + to + " ...");
+ logger_.trace("Sending a GossipDigestSynMessage to " + to + " ...");
MessagingService.getMessagingInstance().sendUdpOneWay(message, to);
return seeds_.contains(to);
}
@@ -411,7 +411,7 @@
List<EndPoint> liveEndPoints = new ArrayList<EndPoint>(epSet);
int index = (size == 1) ? 0 : random_.nextInt(size);
EndPoint to = liveEndPoints.get(index);
- logger_.info("Sending a GossipDigestSynMessage to " + to + " ...");
+ logger_.trace("Sending a GossipDigestSynMessage to " + to + " ...");
MessagingService.getMessagingInstance().sendUdpOneWay(message, to);
return seeds_.contains(to);
}
@@ -977,7 +977,7 @@
public void doVerb(Message message)
{
EndPoint from = message.getFrom();
- logger_.info("Received a GossipDigestSynMessage from " + from);
+ logger_.trace("Received a GossipDigestSynMessage from " + from);
byte[] bytes = (byte[])message.getMessageBody()[0];
DataInputStream dis = new DataInputStream( new ByteArrayInputStream(bytes) );
@@ -1001,7 +1001,7 @@
GossipDigestAckMessage gDigestAck = new GossipDigestAckMessage(deltaGossipDigestList, deltaEpStateMap);
Message gDigestAckMessage = Gossiper.instance().makeGossipDigestAckMessage(gDigestAck);
- logger_.info("Sending a GossipDigestAckMessage to " + from);
+ logger_.trace("Sending a GossipDigestAckMessage to " + from);
MessagingService.getMessagingInstance().sendUdpOneWay(gDigestAckMessage, from);
}
catch (IOException e)
@@ -1061,7 +1061,7 @@
public void doVerb(Message message)
{
EndPoint from = message.getFrom();
- logger_.info("Received a GossipDigestAckMessage from " + from);
+ logger_.trace("Received a GossipDigestAckMessage from " + from);
byte[] bytes = (byte[])message.getMessageBody()[0];
DataInputStream dis = new DataInputStream( new ByteArrayInputStream(bytes) );
@@ -1091,7 +1091,7 @@
GossipDigestAck2Message gDigestAck2 = new GossipDigestAck2Message(deltaEpStateMap);
Message gDigestAck2Message = Gossiper.instance().makeGossipDigestAck2Message(gDigestAck2);
- logger_.info("Sending a GossipDigestAck2Message to " + from);
+ logger_.trace("Sending a GossipDigestAck2Message to " + from);
MessagingService.getMessagingInstance().sendUdpOneWay(gDigestAck2Message, from);
}
catch ( IOException e )
@@ -1108,7 +1108,7 @@
public void doVerb(Message message)
{
EndPoint from = message.getFrom();
- logger_.info("Received a GossipDigestAck2Message from " + from);
+ logger_.trace("Received a GossipDigestAck2Message from " + from);
byte[] bytes = (byte[])message.getMessageBody()[0];
DataInputStream dis = new DataInputStream( new ByteArrayInputStream(bytes) );