feat: add test case

Author: wardseptember

trpc-core/src/main/java/com/tencent/trpc/core/transport/AbstractClientTransport.java

@@ -229,11 +229,8 @@ protected CompletionStage<Channel> createChannel() throws TransportException {
             if (t != null) {
                 logger.error("Client transport({}) create connection exception", this.toString(), t);
             } else {
-                if (logger.isDebugEnabled()) {
-                    logger.debug("Client transport(remote addr={}, network={}) create connection success",
-                            rAddr, config.getNetwork());
-                }
-
+                logger.debug("Client transport(remote addr={}, network={}) create connection success",
+                        rAddr, config.getNetwork());
             }
             // to prevent connection leakage, do one more check: when the connection is successfully established, if
             // it is found to be closed, close the established connection directly

trpc-core/src/test/java/com/tencent/trpc/core/cluster/RpcClusterClientManagerTest.java

@@ -43,6 +43,10 @@ public void test() throws IllegalArgumentException, IllegalAccessException, NoSu
         Thread.sleep(10);
         RpcClusterClientManager.scanUnusedClient();
         assertEquals(0, clusterMap.get(backendConfig).size());
+        BackendConfig backend = new BackendConfig();
+        backend.setNamingUrl("ip://127.0.0.1:8081");
+        RpcClusterClientManager.getOrCreateClient(backend, config);
+        RpcClusterClientManager.shutdownBackendConfig(backend);
     }
 
     private static class ProtocolConfigTest extends ProtocolConfig {

trpc-core/src/test/java/com/tencent/trpc/core/common/LifecycleBaseTest.java

@@ -0,0 +1,16 @@
+package com.tencent.trpc.core.common;
+
+import org.junit.Test;
+
+public class LifecycleBaseTest {
+
+    @Test
+    public void testDebug() {
+        TestLifecycle testLifecycle = new TestLifecycle();
+        testLifecycle.init();
+    }
+
+    public class TestLifecycle extends LifecycleBase {
+
+    }
+}

trpc-core/src/test/java/com/tencent/trpc/core/trace/TraceServerFilterTest.java

@@ -235,6 +235,26 @@ public void testTRpcExceptionSpan() {
         filter.filter(invoker, request);
     }
 
+    @Test
+    public void testDebugLog() {
+        RpcServerContext context = new RpcServerContext();
+        Request request = new DefRequest();
+        request.setContext(context);
+        RpcInvocation invocation = new RpcInvocation();
+        invocation.setRpcServiceName("rpcServiceName");
+        invocation.setRpcMethodName("rpcMethodName");
+        request.getMeta().setRemoteAddress(InetSocketAddress.createUnresolved("10.0.0.1", 8888));
+        request.getMeta().setLocalAddress(InetSocketAddress.createUnresolved("10.0.0.1", 9999));
+        request.setInvocation(invocation);
+        CompletableFuture<Response> future = new CompletableFuture<Response>();
+        Response rsp = new DefResponse();
+        rsp.setException(TRpcException.newBizException(10, ""));
+        future.complete(rsp);
+        Invoker<?> invoker = (Invoker<?>) PowerMockito.mock(Invoker.class);
+        PowerMockito.when(invoker.invoke(request)).thenReturn(future);
+        filter.filter(invoker, request);
+    }
+
     private static class TestTraceFactory implements TracerFactory {
 
         @Override

trpc-core/src/test/java/com/tencent/trpc/core/transport/handler/ChannelHandlerAdapterTest.java

@@ -0,0 +1,17 @@
+package com.tencent.trpc.core.transport.handler;
+
+import com.tencent.trpc.core.common.config.ProtocolConfig;
+import com.tencent.trpc.core.transport.common.TestChannel;
+import org.junit.Test;
+
+public class ChannelHandlerAdapterTest {
+
+    @Test
+    public void testDebug() {
+        ChannelHandlerAdapter channelHandlerAdapter = new ChannelHandlerAdapter();
+        ProtocolConfig protocolConfig = ProtocolConfig.newInstance();
+        protocolConfig.setIp("127.0.0.1");
+        protocolConfig.setPort(8888);
+        channelHandlerAdapter.disconnected(new TestChannel(protocolConfig));
+    }
+}

trpc-proto/trpc-proto-standard/src/main/java/com/tencent/trpc/proto/standard/stream/TRpcStreamResponder.java

@@ -59,9 +59,7 @@ public TRpcStreamResponder(ProtocolConfig protocolConfig, RpcConnection connecti
             DefMethodInfoRegister methodInfoRegister) {
         super(protocolConfig, connection);
         this.methodInfoRegister = Objects.requireNonNull(methodInfoRegister, "methodInfoRegister is null");
-        if (logger.isDebugEnabled()) {
-            logger.debug("created new rpcResponder for {}", protocolConfig);
-        }
+        logger.debug("created new rpcResponder for {}", protocolConfig);
     }
 
     @Override

trpc-proto/trpc-proto-standard/src/main/java/com/tencent/trpc/proto/standard/stream/client/StreamConsumerInvoker.java

@@ -1,7 +1,7 @@
 /*
  * Tencent is pleased to support the open source community by making tRPC available.
  *
- * Copyright (C) 2023 Tencent. 
+ * Copyright (C) 2023 Tencent.
  * All rights reserved.
  *
  * If you have downloaded a copy of the tRPC source code from Tencent,
@@ -69,7 +69,7 @@ public class StreamConsumerInvoker<T> implements ConsumerInvoker<T> {
     private final ClientTransport clientTransport;
 
     public StreamConsumerInvoker(ConsumerConfig<T> consumerConfig, ProtocolConfig protocolConfig,
-                                 ClientTransport clientTransport) {
+            ClientTransport clientTransport) {
         this.consumerConfig = Objects.requireNonNull(consumerConfig, "consumerConfig is null");
         this.backendConfig = Objects
                 .requireNonNull(consumerConfig.getBackendConfig(), "backendConfig is null");
@@ -144,9 +144,7 @@ private Object doInvoke(Request request, TRpcStreamRequester requester, RpcConne
         AtomicInteger unFinished = new AtomicInteger(STREAM_CLOSE_COUNT_BOTH_DIRECTION);
         Consumer<SignalType> onFinally = s -> {
             if (unFinished.decrementAndGet() == 0) {
-                if (logger.isDebugEnabled()) {
-                    logger.debug("close stream invoker connection: {}", connection);
-                }
+                logger.debug("close stream invoker connection: {}", connection);
                 connection.dispose();
             }
         };

trpc-registry/trpc-registry-api/src/main/java/com/tencent/trpc/registry/center/AbstractFailedRetryRegistryCenter.java

@@ -387,9 +387,7 @@ protected void recoverRegistered() {
             return;
         }
         recoverRegistered.forEach(registerInfo -> {
-            if (logger.isDebugEnabled()) {
-                logger.debug("[Recover] Register registerInfo: {}", registerInfo);
-            }
+            logger.debug("[Recover] Register registerInfo: {}", registerInfo);
             addFailedRegisteredTask(registerInfo);
         });
     }

trpc-registry/trpc-registry-api/src/main/java/com/tencent/trpc/registry/center/AbstractRegistryCenter.java

@@ -110,9 +110,7 @@ public void setPluginConfig(PluginConfig pluginConfig) throws TRpcExtensionExcep
     @Override
     public void register(RegisterInfo registerInfo) {
         Objects.requireNonNull(registerInfo, "registerInfo can not be null");
-        if (logger.isDebugEnabled()) {
-            logger.debug("[register] registerInfo: {}", registerInfo);
-        }
+        logger.debug("[register] registerInfo: {}", registerInfo);
         registeredRegisterInfos.add(registerInfo);
     }
 

trpc-registry/trpc-registry-zookeeper/src/main/java/com/tencent/trpc/registry/transporter/curator/CuratorZookeeperClient.java

@@ -409,10 +409,7 @@ public void unwatch() {
          */
         @Override
         public void process(WatchedEvent event) throws Exception {
-            if (logger.isDebugEnabled()) {
-                logger.debug("curator watcher process. event: {}", event);
-            }
-
+            logger.debug("curator watcher process. event: {}", event);
             if (childListener == null) {
                 return;
             }