From f7a302ca6fba9889c8715b7115e757370c193dd9 Mon Sep 17 00:00:00 2001 From: Lunny Xiao Date: Mon, 16 Aug 2021 04:52:26 +0800 Subject: Upgrade levelqueue 0.4.1 (#16696) --- vendor/gitea.com/lunny/levelqueue/queue.go | 8 ++++---- vendor/modules.txt | 2 +- 2 files changed, 5 insertions(+), 5 deletions(-) (limited to 'vendor') diff --git a/vendor/gitea.com/lunny/levelqueue/queue.go b/vendor/gitea.com/lunny/levelqueue/queue.go index 948e019be8..328769d2bd 100644 --- a/vendor/gitea.com/lunny/levelqueue/queue.go +++ b/vendor/gitea.com/lunny/levelqueue/queue.go @@ -21,8 +21,8 @@ const ( // Queue defines a queue struct type Queue struct { db *leveldb.DB - highLock sync.Mutex - lowLock sync.Mutex + lowLock sync.Mutex // If you are locking both high and low locks, lock the low lock before the high lock + highLock sync.Mutex // If you are locking both high and low locks, lock the low lock before the high lock low int64 high int64 lowKey []byte @@ -295,10 +295,10 @@ func (queue *Queue) LHandle(h func([]byte) error) error { // Close closes the queue (and the underlying db is set to closeUnderlyingDB) func (queue *Queue) Close() error { - queue.highLock.Lock() queue.lowLock.Lock() - defer queue.highLock.Unlock() + queue.highLock.Lock() defer queue.lowLock.Unlock() + defer queue.highLock.Unlock() if !queue.closeUnderlyingDB { queue.db = nil diff --git a/vendor/modules.txt b/vendor/modules.txt index 2f88a5f8b6..6d05310a55 100644 --- a/vendor/modules.txt +++ b/vendor/modules.txt @@ -25,7 +25,7 @@ gitea.com/go-chi/session/couchbase gitea.com/go-chi/session/memcache gitea.com/go-chi/session/mysql gitea.com/go-chi/session/postgres -# gitea.com/lunny/levelqueue v0.4.0 +# gitea.com/lunny/levelqueue v0.4.1 ## explicit gitea.com/lunny/levelqueue # github.com/Azure/go-ntlmssp v0.0.0-20200615164410-66371956d46c -- cgit v1.2.3