Skip to content

Commit

Permalink
MB-44803: Log pause-state at disconnect in DcpProducer::maybeDisconnect
Browse files Browse the repository at this point in the history
Change-Id: I8595ac8dace2183cd0b31a5c29c77eaa8b46635b
Reviewed-on: http://review.couchbase.org/c/kv_engine/+/148278
Tested-by: Build Bot <build@couchbase.com>
Reviewed-by: Dave Rigby <daver@couchbase.com>
  • Loading branch information
paolococchi authored and daverigby committed Mar 12, 2021
1 parent db1ff16 commit af2d9b9
Showing 1 changed file with 6 additions and 5 deletions.
11 changes: 6 additions & 5 deletions engines/ep/src/dcp/producer.cc
Original file line number Diff line number Diff line change
Expand Up @@ -1836,18 +1836,19 @@ cb::engine_errc DcpProducer::maybeDisconnect() {
"the DCP idle timeout of {}s. "
"Sent last message (e.g. mutation/noop/streamEnd) {}s ago. "
"Received last message {}s ago. "
"Last sent noop {}s ago. "
"Last received noop response {}s ago. "
"DCP noop interval is {}s. "
"opaque: {}, pendingRecv: {}.",
"DCP noop [lastSent:{}s, lastRecv:{}s, interval:{}s, "
"opaque:{}, pendingRecv:{}], "
"paused:{}, pausedReason:{}",
dcpIdleTimeout.count(),
(now - lastSendTime),
elapsedTime,
(now - noopCtx.sendTime),
(now - noopCtx.recvTime),
noopCtx.dcpNoopTxInterval.count(),
noopCtx.opaque,
noopCtx.pendingRecv ? "true" : "false");
noopCtx.pendingRecv ? "true" : "false",
isPaused() ? "true" : "false",
to_string(getPausedReason()));
return cb::engine_errc::disconnect;
}
// Returning cb::engine_errc::failed means ignore and continue
Expand Down

0 comments on commit af2d9b9

Please sign in to comment.