cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sn...@apache.org
Subject [1/6] cassandra git commit: IncomingTcpConnection thread is not named
Date Wed, 29 Apr 2015 17:05:47 GMT
Repository: cassandra
Updated Branches:
  refs/heads/cassandra-2.0 08dbbd689 -> 58f25d526
  refs/heads/cassandra-2.1 ea1beda01 -> 8322d18e1
  refs/heads/trunk 194bad22f -> 1a11d5239


IncomingTcpConnection thread is not named

Patch by Sankalp Kohli; Reviewed by Ariel Weisberg for CASSANDRA-9262


Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/58f25d52
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/58f25d52
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/58f25d52

Branch: refs/heads/cassandra-2.0
Commit: 58f25d526c60fc6c8805332ea48e611d0aa871ac
Parents: 08dbbd6
Author: sankalp kohli <kohlisankalp@gmail.com>
Authored: Wed Apr 29 18:48:30 2015 +0200
Committer: Robert Stupp <snazy@snazy.de>
Committed: Wed Apr 29 18:48:30 2015 +0200

----------------------------------------------------------------------
 CHANGES.txt                                                  | 1 +
 src/java/org/apache/cassandra/net/IncomingTcpConnection.java | 2 +-
 src/java/org/apache/cassandra/net/OutboundTcpConnection.java | 2 +-
 3 files changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/cassandra/blob/58f25d52/CHANGES.txt
----------------------------------------------------------------------
diff --git a/CHANGES.txt b/CHANGES.txt
index c54bc45..213f226 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -1,4 +1,5 @@
 2.0.15:
+ * IncomingTcpConnection thread is not named (CASSANDRA-9262)
  * Ignore gossip SYNs after shutdown (CASSANDRA-9238)
  * Avoid overflow when calculating max sstable size in LCS (CASSANDRA-9235)
  * Make sstable blacklisting work with compression (CASSANDRA-9138)

http://git-wip-us.apache.org/repos/asf/cassandra/blob/58f25d52/src/java/org/apache/cassandra/net/IncomingTcpConnection.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/net/IncomingTcpConnection.java b/src/java/org/apache/cassandra/net/IncomingTcpConnection.java
index 3296cfd..fbdd221 100644
--- a/src/java/org/apache/cassandra/net/IncomingTcpConnection.java
+++ b/src/java/org/apache/cassandra/net/IncomingTcpConnection.java
@@ -41,7 +41,7 @@ public class IncomingTcpConnection extends Thread
 
     public IncomingTcpConnection(int version, boolean compressed, Socket socket)
     {
-        assert socket != null;
+        super("MessagingService-Incoming-" + socket.getInetAddress());
         this.version = version;
         this.compressed = compressed;
         this.socket = socket;

http://git-wip-us.apache.org/repos/asf/cassandra/blob/58f25d52/src/java/org/apache/cassandra/net/OutboundTcpConnection.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/net/OutboundTcpConnection.java b/src/java/org/apache/cassandra/net/OutboundTcpConnection.java
index ac9a1fb..5559df2 100644
--- a/src/java/org/apache/cassandra/net/OutboundTcpConnection.java
+++ b/src/java/org/apache/cassandra/net/OutboundTcpConnection.java
@@ -73,7 +73,7 @@ public class OutboundTcpConnection extends Thread
 
     public OutboundTcpConnection(OutboundTcpConnectionPool pool)
     {
-        super("WRITE-" + pool.endPoint());
+        super("MessagingService-Outgoing-" + pool.endPoint());
         this.poolReference = pool;
     }
 


Mime
View raw message