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 2011/07/29 07:53:52 UTC
svn commit: r1152112 -
/cassandra/trunk/src/java/org/apache/cassandra/net/MessagingService.java
Author: jbellis
Date: Fri Jul 29 05:53:51 2011
New Revision: 1152112
URL: http://svn.apache.org/viewvc?rev=1152112&view=rev
Log:
revert incomplete code, better
Modified:
cassandra/trunk/src/java/org/apache/cassandra/net/MessagingService.java
Modified: cassandra/trunk/src/java/org/apache/cassandra/net/MessagingService.java
URL: http://svn.apache.org/viewvc/cassandra/trunk/src/java/org/apache/cassandra/net/MessagingService.java?rev=1152112&r1=1152111&r2=1152112&view=diff
==============================================================================
--- cassandra/trunk/src/java/org/apache/cassandra/net/MessagingService.java (original)
+++ cassandra/trunk/src/java/org/apache/cassandra/net/MessagingService.java Fri Jul 29 05:53:51 2011
@@ -136,7 +136,7 @@ public final class MessagingService impl
}
};
StorageService.scheduledTasks.scheduleWithFixedDelay(logDropped, LOG_DROPPED_INTERVAL_IN_MS, LOG_DROPPED_INTERVAL_IN_MS, TimeUnit.MILLISECONDS);
-onfi
+
Function<Pair<String, Pair<InetAddress, IMessageCallback>>, ?> timeoutReporter = new Function<Pair<String, Pair<InetAddress, IMessageCallback>>, Object>()
{
public Object apply(Pair<String, Pair<InetAddress, IMessageCallback>> pair)