Skip to content

Commit 5f47aa8

Browse files
authored
PCSM-167: Restore eventsRead during recovery (#150)
1 parent eac7437 commit 5f47aa8

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

pcsm/repl.go

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -116,7 +116,7 @@ func (r *Repl) Checkpoint() *replCheckpoint { //nolint:revive
116116
cp := &replCheckpoint{
117117
StartTime: r.startTime,
118118
PauseTime: r.pauseTime,
119-
EventsRead: r.eventsRead.Load(),
119+
EventsRead: r.eventsApplied,
120120
EventsApplied: r.eventsApplied,
121121
LastReplicatedOpTime: r.lastReplicatedOpTime,
122122
}
@@ -151,6 +151,7 @@ func (r *Repl) Recover(cp *replCheckpoint) error {
151151
r.startTime = cp.StartTime
152152
r.pauseTime = pauseTime
153153
r.eventsApplied = cp.EventsApplied
154+
r.eventsRead.Store(cp.EventsApplied)
154155
r.lastReplicatedOpTime = cp.LastReplicatedOpTime
155156

156157
if cp.UseClientBulkWrite {

0 commit comments

Comments
 (0)