fix: fix redis lock

aldor007 · Oct 20, 2022 · b1bbb6d · b1bbb6d
1 parent 8d4c9a0
commit b1bbb6d
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/pkg/lock/redis.go b/pkg/lock/redis.go
@@ -120,9 +120,11 @@ func (m *RedisLock) Lock(ctx context.Context, key string) (result LockResult, ok
 					select {
 					case <-ch:
 						m.NotifyAndRelease(ctx, key, nil)
+						return
 					case <-result.Cancel:
 						m.memoryLock.Release(ctx, key)
 						pubsub.Close()
+						return
 					case <-ctx.Done():
 						m.memoryLock.Release(ctx, key)
 						pubsub.Close()