Merge pull request #140 from s7techlab/seek-from-callback-bugfix

seek-from-callback-bugfix
s7techlab · Nov 21, 2023 · 3cbe1ea · 3cbe1ea
2 parents 82bbf13 + 2920451
commit 3cbe1ea
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/observer/block_peer_common.go b/observer/block_peer_common.go
@@ -193,9 +193,11 @@ func (bp *BlockPeer) initChannels(ctx context.Context) {
 func (bp *BlockPeer) getSeekFrom(channel string) SeekFromFetcher {
 	seekFrom := ChannelSeekOldest()
 	// at first check seekFrom var, if it is empty, check seekFromFetcher
+	bp.mu.Lock()
 	seekFromNum, exist := bp.seekFrom[channel]
+	bp.mu.Unlock()
 	if exist {
-		seekFrom = ChannelSeekFrom(seekFromNum)
+		seekFrom = ChannelSeekFrom(seekFromNum - 1)
 	} else {
 		// if seekFromFetcher is also empty, use ChannelSeekOldest
 		if bp.seekFromFetcher != nil {