Merge pull request #650 from alex268/master

Update log messages in the session pools

Author: alex268

query/src/main/java/tech/ydb/query/impl/SessionPool.java

@@ -252,7 +252,7 @@ public void destroy() {
 
         @Override
         public void close() {
-            logger.trace("QuerySession[{}] closed with broke status {}", getId(), isBroken);
+            logger.trace("QuerySession[{}] closed with broken status {}", getId(), isBroken);
 
             stats.released.increment();
             if (isBroken || isStopped) {
@@ -328,6 +328,7 @@ public void run() {
                 PooledQuerySession session = coldIterator.next();
                 if (!session.getLastActive().isAfter(idleToRemove) && queue.getTotalCount() > minSize) {
                     coldIterator.remove();
+                    logger.debug("QuerySession[{}] was deleted by idle timeout", session.getId());
                 }
             }
         }

table/src/main/java/tech/ydb/table/impl/pool/SessionPool.java

@@ -85,7 +85,7 @@ public SessionPoolStats stats() {
     }
 
     public CompletableFuture<Result<Session>> acquire(Duration timeout) {
-        logger.debug("acquire session with timeout {}", timeout);
+        logger.trace("acquire session with timeout {}", timeout);
 
         CompletableFuture<Result<Session>> future = new CompletableFuture<>();
 
@@ -131,7 +131,7 @@ private boolean pollNext(CompletableFuture<Result<Session>> future) {
 
     private boolean validateSession(ClosableSession session, CompletableFuture<Result<Session>> future) {
         if (session.state().switchToActive(clock.instant())) {
-            logger.debug("session {} accepted", session.getId());
+            logger.trace("session {} accepted", session.getId());
             if (future.complete(Result.success(session))) {
                 stats.acquired.increment();
             } else {
@@ -261,6 +261,7 @@ public void run() {
 
                 if (!state.lastActive().isAfter(idleToRemove) && queue.getTotalCount() > minSize) {
                     coldIterator.remove();
+                    logger.debug("session {} was deleted by idle timeout", session.getId());
                     continue;
                 }
 

table/src/main/java/tech/ydb/table/impl/pool/StatefulSession.java

@@ -116,6 +116,7 @@ private State updated(Instant now, Throwable th, StatusCode code, boolean shutdo
 
             // and if we found it state switch to broken status
             if (broken) {
+                logger.debug("{} broken by status code {}", this, code);
                 return new State(Status.BROKEN, lastActive, now);
             }
 
@@ -125,6 +126,7 @@ private State updated(Instant now, Throwable th, StatusCode code, boolean shutdo
 
             if (status == Status.ACTIVE) {
                 if (shutdownHint) {
+                    logger.debug("{} broken by shutdown hint", this);
                     return new State(Status.NEED_SHUTDOWN, now);
                 }
                 return new State(status, now);