From 6c21e798b9875305f6620e50032a0d343b0d05ee Mon Sep 17 00:00:00 2001
From: emeroad <emeroad@gmail.com>
Date: Fri, 11 Oct 2024 12:35:45 +0900
Subject: [PATCH] [#11497] Add isReady check to the ping stream

---
 .../pinpoint/profiler/sender/grpc/PingStreamContext.java    | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/agent-module/profiler/src/main/java/com/navercorp/pinpoint/profiler/sender/grpc/PingStreamContext.java b/agent-module/profiler/src/main/java/com/navercorp/pinpoint/profiler/sender/grpc/PingStreamContext.java
index da86083420c5..8d63a0e3190c 100644
--- a/agent-module/profiler/src/main/java/com/navercorp/pinpoint/profiler/sender/grpc/PingStreamContext.java
+++ b/agent-module/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);
+                            }
                         }
                     };