Skip to content

Commit 5c631e2

Browse files
committed
resolved post-merge conflicts
Signed-off-by: Alex Kehayov <aleks.kehayov@limechain.tech>
1 parent 17a495a commit 5c631e2

File tree

1 file changed

+6
-2
lines changed

1 file changed

+6
-2
lines changed

hedera-node/hedera-app/src/main/java/com/hedera/node/app/blocks/impl/streaming/BlockNodeConnection.java

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -688,7 +688,9 @@ public void sendRequest(@NonNull final PublishStreamRequest request) {
688688
() -> {
689689
if (getConnectionState() == ConnectionState.ACTIVE) {
690690
logWithContext(
691+
logger,
691692
DEBUG,
693+
this,
692694
"Pipeline onNext() timed out after {}ms",
693695
pipelineOperationTimeout.toMillis());
694696
blockStreamMetrics.recordPipelineOperationTimeout();
@@ -803,7 +805,9 @@ private void closePipeline(final boolean callOnComplete) {
803805
final ScheduledFuture<?> timeoutTask = executorService.schedule(
804806
() -> {
805807
logWithContext(
806-
logger, DEBUG, this,
808+
logger,
809+
DEBUG,
810+
this,
807811
"Pipeline onComplete() timed out after {}ms",
808812
pipelineOperationTimeout.toMillis());
809813
blockStreamMetrics.recordPipelineOperationTimeout();
@@ -822,7 +826,7 @@ private void closePipeline(final boolean callOnComplete) {
822826
}
823827
}
824828

825-
logWithContext(DEBUG, "Request pipeline successfully closed.");
829+
logWithContext(logger, DEBUG, this, "Request pipeline successfully closed.");
826830
}
827831
} catch (final Exception e) {
828832
logger.warn(formatLogMessage("Error while completing request pipeline.", this), e);

0 commit comments

Comments
 (0)