Skip to content

Commit ba02591

Browse files
committed
log when channel not shutdown.
1 parent 8be7eec commit ba02591

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

s2a/src/main/java/io/grpc/s2a/channel/S2AHandshakerServiceChannel.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -30,6 +30,8 @@
3030
import io.grpc.internal.SharedResourceHolder.Resource;
3131
import io.grpc.netty.NettyChannelBuilder;
3232
import java.time.Duration;
33+
import java.util.logging.Level;
34+
import java.util.logging.Logger;
3335
import java.util.Optional;
3436
import java.util.concurrent.ConcurrentMap;
3537
import javax.annotation.concurrent.ThreadSafe;
@@ -132,6 +134,7 @@ public String toString() {
132134
*/
133135
@VisibleForTesting
134136
static class HandshakerServiceChannel extends Channel {
137+
private static final Logger logger = Logger.getLogger(S2AStub.class.getName());
135138
private final ManagedChannel delegate;
136139

137140
static HandshakerServiceChannel create(ManagedChannel delegate) {
@@ -166,6 +169,7 @@ public void close() {
166169
delegate.awaitTermination(CHANNEL_SHUTDOWN_TIMEOUT.getSeconds(), SECONDS);
167170
} catch (InterruptedException e) {
168171
Thread.currentThread().interrupt();
172+
logger.log(Level.WARNING, "Channel to S2A was not shutdown.");
169173
}
170174
}
171175
}

0 commit comments

Comments
 (0)