@@ -265,15 +265,16 @@ void ActiveStream::registerCursor(CheckpointManager& chkptmgr,
265265 Expects (lockedCursor);
266266 log (spdlog::level::level_enum::info,
267267 " {} ActiveStream::registerCursor name \" {}\" , "
268- " lastProcessedSeqno:{}, result{{tryBackfill:{}, nextSeqno :{}, "
269- " op:{}}}, pendingBackfill:{ }" ,
268+ " lastProcessedSeqno:{}, pendingBackfill :{}, "
269+ " result{{tryBackfill:{}, op:{}, seqno:{}, nextSeqno:{}} }" ,
270270 logPrefix,
271271 name_,
272272 lastProcessedSeqno,
273+ pendingBackfill,
273274 result.tryBackfill ,
274- result.nextSeqno ,
275275 ::to_string ((*lockedCursor->getPos ())->getOperation()),
276- pendingBackfill);
276+ (*lockedCursor->getPos ())->getBySeqno(),
277+ result.nextSeqno);
277278 } catch (std::exception& error) {
278279 log (spdlog::level::level_enum::warn,
279280 " {} Failed to register cursor: {}" ,
@@ -1773,15 +1774,15 @@ void ActiveStream::scheduleBackfill_UNLOCKED(DcpProducer& producer,
17731774 Expects (lockedCursor);
17741775 log (spdlog::level::level_enum::info,
17751776 " {} ActiveStream::scheduleBackfill_UNLOCKED register cursor with "
1776- " name \" {}\" lastProcessedSeqno:{}, result{{tryBackfill:{}, "
1777- " nextSeqno:{}}}, "
1778- " op:{}" ,
1777+ " name \" {}\" lastProcessedSeqno:{}, result{{tryBackfill:{}, op:{}, "
1778+ " seqno:{}, nextSeqno:{}}}" ,
17791779 logPrefix,
17801780 name_,
17811781 lastReadSeqno.load (),
17821782 registerResult.tryBackfill ,
1783- registerResult.nextSeqno ,
1784- ::to_string ((*lockedCursor->getPos ())->getOperation()));
1783+ ::to_string ((*lockedCursor->getPos ())->getOperation()),
1784+ (*lockedCursor->getPos ())->getBySeqno(),
1785+ registerResult.nextSeqno);
17851786
17861787 curChkSeqno = registerResult.nextSeqno;
17871788 tryBackfill = registerResult.tryBackfill;
0 commit comments