diff options
Diffstat (limited to 'vendor/gitea.com/lunny/levelqueue/uniquequeue.go')
| -rw-r--r-- | vendor/gitea.com/lunny/levelqueue/uniquequeue.go | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/vendor/gitea.com/lunny/levelqueue/uniquequeue.go b/vendor/gitea.com/lunny/levelqueue/uniquequeue.go index a53abb2c4e..8d66e008de 100644 --- a/vendor/gitea.com/lunny/levelqueue/uniquequeue.go +++ b/vendor/gitea.com/lunny/levelqueue/uniquequeue.go @@ -181,6 +181,8 @@ func (queue *UniqueQueue) Len() int64 { func (queue *UniqueQueue) Close() error { _ = queue.q.Close() _ = queue.set.Close() + queue.set.lock.Lock() + defer queue.set.lock.Unlock() if !queue.closeUnderlyingDB { queue.db = nil return nil |