[#9932] Removed thrift dependency of Agent module`

Author: emeroad

bootstraps/bootstrap-core/src/main/java/com/navercorp/pinpoint/bootstrap/config/TransportModule.java

@@ -26,15 +26,15 @@ public enum TransportModule {
 
     public static TransportModule parse(String transportModule) {
         Objects.requireNonNull(transportModule, "transportModule");
-        if (isEquals(GRPC, transportModule)) {
+
+        if (equalsIgnoreCase(TransportModule.GRPC.name(), transportModule)) {
             return GRPC;
         }
         return GRPC;
     }
 
-    private static boolean isEquals(TransportModule transportModule, String transportModuleString) {
-        final String transportModuleName = transportModule.name();
-        return transportModuleName.equalsIgnoreCase(transportModuleString);
+    private static boolean equalsIgnoreCase(String str1, String str2) {
+        return str1.equalsIgnoreCase(str2);
     }
 
     public static TransportModule parse(String transportModule, TransportModule defaultModule) {

profiler/src/main/java/com/navercorp/pinpoint/profiler/receiver/grpc/GrpcCommandService.java

@@ -16,7 +16,6 @@
 
 package com.navercorp.pinpoint.profiler.receiver.grpc;
 
-import java.util.Objects;
 import com.navercorp.pinpoint.grpc.StatusError;
 import com.navercorp.pinpoint.grpc.StatusErrors;
 import com.navercorp.pinpoint.grpc.client.SupportCommandCodeClientInterceptor;
@@ -27,11 +26,12 @@
 import com.navercorp.pinpoint.profiler.sender.grpc.ReconnectExecutor;
 import com.navercorp.pinpoint.profiler.sender.grpc.Reconnector;
 import com.navercorp.pinpoint.profiler.sender.grpc.StreamUtils;
-
 import io.grpc.stub.ClientCallStreamObserver;
 import io.grpc.stub.ClientResponseObserver;
-import org.apache.logging.log4j.Logger;
 import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
+
+import java.util.Objects;
 
 /**
  * @author Taejin Koo
@@ -157,14 +157,14 @@ public void onError(Throwable t) {
         @Override
         public void onCompleted() {
             logger.info("onCompleted");
-            StreamUtils.close(requestStream);
+            StreamUtils.close(requestStream, GrpcCommandService.this.logger);
             // TODO : needs to check whether needs new action
             reserveReconnect();
         }
 
         private void stop() {
             logger.info("stop");
-            StreamUtils.close(requestStream);
+            StreamUtils.close(requestStream, GrpcCommandService.this.logger);
             commandDispatcher.close();
         }
 

profiler/src/main/java/com/navercorp/pinpoint/profiler/sender/grpc/PingStreamContext.java

@@ -16,7 +16,6 @@
 
 package com.navercorp.pinpoint.profiler.sender.grpc;
 
-import java.util.Objects;
 import com.navercorp.pinpoint.grpc.MessageFormatUtils;
 import com.navercorp.pinpoint.grpc.StatusError;
 import com.navercorp.pinpoint.grpc.StatusErrors;
@@ -25,9 +24,10 @@
 import io.grpc.stub.ClientCallStreamObserver;
 import io.grpc.stub.ClientResponseObserver;
 import io.grpc.stub.StreamObserver;
-import org.apache.logging.log4j.Logger;
 import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
 
+import java.util.Objects;
 import java.util.concurrent.RejectedExecutionException;
 import java.util.concurrent.ScheduledExecutorService;
 import java.util.concurrent.ScheduledFuture;
@@ -140,7 +140,7 @@ private ScheduledFuture<?> schedule(Runnable command) {
 
     public void close() {
         logger.info("{} close()", streamId);
-        StreamUtils.close(this.requestObserver);
+        StreamUtils.close(this.requestObserver, this.logger);
     }
 
     @Override

profiler/src/main/java/com/navercorp/pinpoint/profiler/sender/grpc/StreamUtils.java

@@ -17,6 +17,8 @@
 package com.navercorp.pinpoint.profiler.sender.grpc;
 
 import io.grpc.stub.StreamObserver;
+import org.apache.logging.log4j.Logger;
+
 
 /**
  * @author Woonduk Kang(emeroad)
@@ -26,9 +28,15 @@ public final class StreamUtils {
     private StreamUtils() {
     }
 
-    public static void close(final StreamObserver<?> streamObserver) {
+    public static void close(final StreamObserver<?> streamObserver, Logger logger) {
         if (streamObserver != null) {
-            streamObserver.onCompleted();
+            try {
+                streamObserver.onCompleted();
+            } catch (Throwable th) {
+                if (logger != null) {
+                    logger.info("StreamObserver.onCompleted error", th);
+                }
+            }
         }
     }
 }