Skip to content

Commit 1f664d8

Browse files
committed
[#13494] Update agent grpcSpanSender state init
1 parent 1290a2e commit 1f664d8

File tree

3 files changed

+11
-0
lines changed

3 files changed

+11
-0
lines changed

agent-module/profiler/src/main/java/com/navercorp/pinpoint/profiler/sender/grpc/SimpleStreamState.java

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -12,6 +12,11 @@ public SimpleStreamState(int limitCount, long limitTime) {
1212
this.limitTime = limitTime;
1313
}
1414

15+
public void init() {
16+
failureTime = 0;
17+
failCount = 0;
18+
}
19+
1520
@Override
1621
public void fail() {
1722
if (failureTime == 0) {
@@ -22,6 +27,9 @@ public void fail() {
2227

2328
@Override
2429
public boolean isFailure() {
30+
if (failureTime == 0) {
31+
return false;
32+
}
2533
final long errorDuration = System.currentTimeMillis() - failureTime;
2634
return errorDuration > limitTime && failCount > limitCount;
2735
}

agent-module/profiler/src/main/java/com/navercorp/pinpoint/profiler/sender/grpc/StreamState.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -6,4 +6,6 @@ public interface StreamState {
66
boolean isFailure();
77

88
void success();
9+
10+
void init();
911
}

agent-module/profiler/src/main/java/com/navercorp/pinpoint/profiler/sender/grpc/stream/DefaultStreamTask.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -81,6 +81,7 @@ public void run() {
8181
private void dispatch(ClientCallStateStreamObserver<ReqT> stream) {
8282
logger.info("dispatch start {}", this);
8383
FinishStatus status = FinishStatus.UNKNOWN;
84+
failState.init();
8485

8586
try {
8687
// while (true) {

0 commit comments

Comments
 (0)