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 2010/01/05 05:06:17 UTC
svn commit: r895888 -
/incubator/cassandra/trunk/src/java/org/apache/cassandra/net/MessagingService.java
Author: jbellis
Date: Tue Jan 5 04:06:16 2010
New Revision: 895888
URL: http://svn.apache.org/viewvc?rev=895888&view=rev
Log:
r/m unused MS.endPoints_ field
patch by jbellis; reviewed by gdusbabek for CASSANDRA-659
Modified:
incubator/cassandra/trunk/src/java/org/apache/cassandra/net/MessagingService.java
Modified: incubator/cassandra/trunk/src/java/org/apache/cassandra/net/MessagingService.java
URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/src/java/org/apache/cassandra/net/MessagingService.java?rev=895888&r1=895887&r2=895888&view=diff
==============================================================================
--- incubator/cassandra/trunk/src/java/org/apache/cassandra/net/MessagingService.java (original)
+++ incubator/cassandra/trunk/src/java/org/apache/cassandra/net/MessagingService.java Tue Jan 5 04:06:16 2010
@@ -57,9 +57,6 @@
private static ICachetable<String, IAsyncCallback> callbackMap_;
private static ICachetable<String, IAsyncResult> taskCompletionMap_;
- /* Manages the table of endpoints it is listening on */
- private static Set<InetAddress> endPoints_;
-
/* List of sockets we are listening on */
private static Map<InetAddress, SelectionKey> listenSockets_ = new HashMap<InetAddress, SelectionKey>();
@@ -124,7 +121,6 @@
protected MessagingService()
{
verbHandlers_ = new HashMap<String, IVerbHandler>();
- endPoints_ = new HashSet<InetAddress>();
/*
* Leave callbacks in the cachetable long enough that any related messages will arrive
* before the callback is evicted from the table. The concurrency level is set at 128
@@ -197,7 +193,6 @@
SelectionKeyHandler handler = new TcpConnectionHandler(localEp);
SelectionKey key = SelectorManager.getSelectorManager().register(serverChannel, handler, SelectionKey.OP_ACCEPT);
- endPoints_.add(localEp);
listenSockets_.put(localEp, key);
FailureDetector.instance().registerFailureDetectionEventListener(this);
}
@@ -214,7 +209,6 @@
try
{
connection.init(localEp);
- endPoints_.add(localEp);
udpConnections_.put(localEp, connection);
}
catch (IOException e)