[#11497] Add isReady check to the ping stream

pinpoint-apm · Oct 11, 2024 · 6c21e79 · 6c21e79
1 parent 6c779c6
commit 6c21e79
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/...profiler/src/main/java/com/navercorp/pinpoint/profiler/sender/grpc/PingStreamContext.java b/...profiler/src/main/java/com/navercorp/pinpoint/profiler/sender/grpc/PingStreamContext.java
@@ -119,7 +119,11 @@ public void run() {
                         @Override
                         public void run() {
                             PPing pPing = newPing();
-                            requestStream.onNext(pPing);
+                            if (requestStream.isReady()) {
+                                requestStream.onNext(pPing);
+                            } else {
+                                logger.debug("{} ping fail. client is not ready", streamId);
+                            }
                         }
                     };