You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by br...@apache.org on 2021/10/20 15:37:19 UTC
[cassandra] branch cassandra-4.0 updated: Push initial connection
messages to trace
This is an automated email from the ASF dual-hosted git repository.
brandonwilliams pushed a commit to branch cassandra-4.0
in repository https://gitbox.apache.org/repos/asf/cassandra.git
The following commit(s) were added to refs/heads/cassandra-4.0 by this push:
new 71f7b6c Push initial connection messages to trace
71f7b6c is described below
commit 71f7b6cc92be7a96467766decfab7ae5bd7bcd45
Author: Brandon Williams <br...@apache.org>
AuthorDate: Wed Oct 13 13:18:06 2021 -0500
Push initial connection messages to trace
Patch by brandonwilliams; reviewed by bereng for CASSANDRA-17038
---
CHANGES.txt | 1 +
.../org/apache/cassandra/transport/InitialConnectionHandler.java | 6 +++---
2 files changed, 4 insertions(+), 3 deletions(-)
diff --git a/CHANGES.txt b/CHANGES.txt
index e08be9f..5393f7e 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -1,4 +1,5 @@
4.0.2
+ * Push initial client connection messages to trace (CASSANDRA-17038)
* Correct the internode message timestamp if sending node has wrapped (CASSANDRA-16997)
* Avoid race causing us to return null in RangesAtEndpoint (CASSANDRA-16965)
* Avoid rewriting all sstables during cleanup when transient replication is enabled (CASSANDRA-16966)
diff --git a/src/java/org/apache/cassandra/transport/InitialConnectionHandler.java b/src/java/org/apache/cassandra/transport/InitialConnectionHandler.java
index 77e9232..bc53fd2 100644
--- a/src/java/org/apache/cassandra/transport/InitialConnectionHandler.java
+++ b/src/java/org/apache/cassandra/transport/InitialConnectionHandler.java
@@ -74,7 +74,7 @@ public class InitialConnectionHandler extends ByteToMessageDecoder
switch (inbound.header.type)
{
case OPTIONS:
- logger.debug("OPTIONS received {}", inbound.header.version);
+ logger.trace("OPTIONS received {}", inbound.header.version);
List<String> cqlVersions = new ArrayList<>();
cqlVersions.add(QueryProcessor.CQL_VERSION.toString());
@@ -118,7 +118,7 @@ public class InitialConnectionHandler extends ByteToMessageDecoder
promise = AsyncChannelPromise.withListener(ctx, future -> {
if (future.isSuccess())
{
- logger.debug("Response to STARTUP sent, configuring pipeline for {}", inbound.header.version);
+ logger.trace("Response to STARTUP sent, configuring pipeline for {}", inbound.header.version);
configurator.configureModernPipeline(ctx, allocator, inbound.header.version, startup.options);
allocator.release(inbound.header.bodySizeInBytes);
}
@@ -150,7 +150,7 @@ public class InitialConnectionHandler extends ByteToMessageDecoder
final Message.Response response = Dispatcher.processRequest((ServerConnection) connection, startup);
outbound = response.encode(inbound.header.version);
ctx.writeAndFlush(outbound, promise);
- logger.debug("Configured pipeline: {}", ctx.pipeline());
+ logger.trace("Configured pipeline: {}", ctx.pipeline());
break;
default:
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@cassandra.apache.org
For additional commands, e-mail: commits-help@cassandra.apache.org