Skip to content

Commit

Permalink
More fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
EinKrebs committed Oct 1, 2024
1 parent ef4bd04 commit 8f6e1ab
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion qdb/memqdb.go
Original file line number Diff line number Diff line change
Expand Up @@ -202,7 +202,8 @@ func (q *MemQDB) DropKeyRange(_ context.Context, id string) error {

lock, ok := q.Locks[id]
if !ok {
if err := ExecuteCommands(q.DumpState, NewUpdateCommand(q.Locks, id, &sync.RWMutex{})); err != nil {
lock = &sync.RWMutex{}
if err := ExecuteCommands(q.DumpState, NewUpdateCommand(q.Locks, id, lock)); err != nil {
return err
}
}
Expand Down

0 comments on commit 8f6e1ab

Please sign in to comment.