Skip to content

Commit 51f1994

Browse files
committed
more debug logs
1 parent 194ed6c commit 51f1994

File tree

2 files changed

+4
-0
lines changed

2 files changed

+4
-0
lines changed

client/src/main/java/org/asynchttpclient/netty/channel/DefaultChannelPool.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -238,6 +238,8 @@ public boolean offer(Channel channel, Object partitionKey) {
238238
if (isClosed.get())
239239
return false;
240240

241+
LOGGER.debug("Offering channel {} to pool with key {}", channel, partitionKey);
242+
241243
long now = millisTime();
242244

243245
if (isTtlExpired(channel, now))

client/src/main/java/org/asynchttpclient/netty/handler/AsyncHttpClientHandler.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -66,6 +66,8 @@ public void channelRead(final ChannelHandlerContext ctx, Object msg) throws Exce
6666
Channel channel = ctx.channel();
6767
Object attribute = Channels.getAttribute(channel);
6868

69+
LOGGER.debug("channelRead channel={}, attribute={} msg={}", channel, attribute, msg);
70+
6971
try {
7072
if (attribute instanceof Callback) {
7173
Callback ac = (Callback) attribute;

0 commit comments

Comments
 (0)