gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-17 11:24:44 -07:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #3629 from nats-io/readstate-lock

Browse Source 
When reading state, even on consumer init, should lock.
This commit is contained in:
Derek Collison
2022-11-15 08:00:58 -08:00
committed by GitHub
parent b3b7772b87 b92ea86b80
commit c94a260c97
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
server/consumer.go
View File

@@ -749,7 +749,9 @@ func (mset *stream) addConsumerWithAssignment(config *ConsumerConfig, oname stri
if o.store != nil && o.store.HasState() {
// Restore our saved state.
o.mu.Lock()
o.readStoredState(0)
o.mu.Unlock()
} else {
// Select starting sequence number
o.selectStartingSeqNo()