Add shutdown logging to client, ClientResources, and EventLoopGroupPr…

…ovider #918
redis · Nov 12, 2018 · e1585f3 · e1585f3
1 parent 4454f22
commit e1585f3
Show file tree

Hide file tree

Showing 3 changed files with 13 additions and 0 deletions.
diff --git a/src/main/java/com/lambdaworks/redis/AbstractRedisClient.java b/src/main/java/com/lambdaworks/redis/AbstractRedisClient.java
@@ -402,6 +402,8 @@ public CompletableFuture<Void> shutdownAsync(long quietPeriod, long timeout, Tim
 
         if (shutdown.compareAndSet(false, true)) {
 
+            logger.debug("Initiate shutdown ({}, {}, {})", quietPeriod, timeout, timeUnit);
+
             while (!closeableResources.isEmpty()) {
                 Closeable closeableResource = closeableResources.iterator().next();
                 try {

diff --git a/src/main/java/com/lambdaworks/redis/resource/DefaultClientResources.java b/src/main/java/com/lambdaworks/redis/resource/DefaultClientResources.java
@@ -503,6 +503,8 @@ public Future<Boolean> shutdown() {
     @SuppressWarnings("unchecked")
     public Future<Boolean> shutdown(long quietPeriod, long timeout, TimeUnit timeUnit) {
 
+        logger.debug("Initiate shutdown ({}, {}, {})", quietPeriod, timeout, timeUnit);
+
         shutdownCalled = true;
         DefaultPromise<Boolean> overall = new DefaultPromise<>(GlobalEventExecutor.INSTANCE);
         DefaultPromise<Boolean> lastRelease = new DefaultPromise<>(GlobalEventExecutor.INSTANCE);

diff --git a/src/main/java/com/lambdaworks/redis/resource/DefaultEventLoopGroupProvider.java b/src/main/java/com/lambdaworks/redis/resource/DefaultEventLoopGroupProvider.java
@@ -60,7 +60,9 @@ public DefaultEventLoopGroupProvider(int numberOfThreads) {
 
     @Override
     public <T extends EventLoopGroup> T allocate(Class<T> type) {
+
         synchronized (this) {
+            logger.debug("Allocating executor {}", type.getName());
             return addReference(getOrCreate(type));
         }
     }
@@ -134,6 +136,8 @@ private <T extends EventLoopGroup> T getOrCreate(Class<T> type) {
      */
     public static <T extends EventExecutorGroup> EventExecutorGroup createEventLoopGroup(Class<T> type, int numberOfThreads) {
 
+        logger.debug("Creating executor {}", type.getName());
+
         if (DefaultEventExecutorGroup.class.equals(type)) {
             return new DefaultEventExecutorGroup(numberOfThreads, new DefaultThreadFactory("lettuce-eventExecutorLoop", true));
         }
@@ -156,6 +160,8 @@ public static <T extends EventExecutorGroup> EventExecutorGroup createEventLoopG
     @Override
     public Promise<Boolean> release(EventExecutorGroup eventLoopGroup, long quietPeriod, long timeout, TimeUnit unit) {
 
+        logger.debug("Release executor {}", eventLoopGroup);
+
         Class<?> key = getKey(release(eventLoopGroup));
 
         if ((key == null && eventLoopGroup.isShuttingDown()) || refCounter.containsKey(eventLoopGroup)) {
@@ -193,6 +199,9 @@ public int threadPoolSize() {
     @Override
     @SuppressWarnings("unchecked")
     public Future<Boolean> shutdown(long quietPeriod, long timeout, TimeUnit timeUnit) {
+
+        logger.debug("Initiate shutdown ({}, {}, {})", quietPeriod, timeout, timeUnit);
+
         shutdownCalled = true;
 
         Map<Class<? extends EventExecutorGroup>, EventExecutorGroup> copy = new HashMap<>(eventLoopGroups);