Mirroristas/etcd
2
0
Fork 0
mirror of https://github.com/etcd-io/etcd.git synced 2024-09-27 06:25:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

clientv3/concurrency: do not swallow error (#11458)

Browse Source
This commit is contained in:
Xiang Li 2020-04-06 12:07:59 -07:00 committed by GitHub
parent be103ea558
commit b41711276e
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
clientv3/concurrency/mutex.go
View File

@ -82,12 +82,11 @@ func (m *Mutex) Lock(ctx context.Context) error {
client := m.s.Client() client := m.s.Client()
// wait for deletion revisions prior to myKey // wait for deletion revisions prior to myKey
// TODO: early termination if the session key is deleted before other session keys with smaller revisions. // TODO: early termination if the session key is deleted before other session keys with smaller revisions.
hdr, werr := waitDeletes(ctx, client, m.pfx, m.myRev-1) _, werr := waitDeletes(ctx, client, m.pfx, m.myRev-1)
// release lock key if wait failed // release lock key if wait failed
if werr != nil { if werr != nil {
m.Unlock(client.Ctx()) m.Unlock(client.Ctx())
} else { return werr
m.hdr = hdr
} }
// make sure the session is not expired, and the owner key still exists. // make sure the session is not expired, and the owner key still exists.