svn commit: r895888 - /incubator/cassandra/trunk/src/java/org/apache/cassandra/net/MessagingService.java

[jbellis]

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)