Skip to content

Commit ccb2a17

Browse files
committed
Added lost tracing
1 parent f6b9cbf commit ccb2a17

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

core/src/main/java/tech/ydb/core/impl/call/ReadWriteStreamCall.java

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -88,6 +88,10 @@ public CompletableFuture<Status> start(Observer<R> observer) {
8888
public void sendNext(W message) {
8989
synchronized (call) {
9090
if (flush()) {
91+
if (logger.isTraceEnabled()) {
92+
String msg = TextFormat.shortDebugString((Message) message);
93+
logger.trace("ReadWriteStreamCall[{}] --> {}", traceId, msg);
94+
}
9195
call.sendMessage(message);
9296
} else {
9397
messagesQueue.add(message);
@@ -103,7 +107,8 @@ private boolean flush() {
103107
}
104108

105109
if (logger.isTraceEnabled()) {
106-
logger.trace("ReadWriteStreamCall[{}] --> {}", traceId, TextFormat.shortDebugString((Message) next));
110+
String msg = TextFormat.shortDebugString((Message) next);
111+
logger.trace("ReadWriteStreamCall[{}] --> {}", traceId, msg);
107112
}
108113
call.sendMessage(next);
109114
}

0 commit comments

Comments
 (0)