Optimize backoff
Signed-off-by: Shiming Zhang <wzshiming@foxmail.com>
This commit is contained in:
parent
88b09e6710
commit
9e576b8891
@ -465,7 +465,6 @@ func (s *store) Writer(ctx context.Context, opts ...content.WriterOpt) (content.
|
|||||||
}
|
}
|
||||||
var lockErr error
|
var lockErr error
|
||||||
for count := uint64(0); count < 10; count++ {
|
for count := uint64(0); count < 10; count++ {
|
||||||
time.Sleep(time.Millisecond * time.Duration(rand.Intn(1<<count)))
|
|
||||||
if err := tryLock(wOpts.Ref); err != nil {
|
if err := tryLock(wOpts.Ref); err != nil {
|
||||||
if !errdefs.IsUnavailable(err) {
|
if !errdefs.IsUnavailable(err) {
|
||||||
return nil, err
|
return nil, err
|
||||||
@ -476,6 +475,7 @@ func (s *store) Writer(ctx context.Context, opts ...content.WriterOpt) (content.
|
|||||||
lockErr = nil
|
lockErr = nil
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
|
time.Sleep(time.Millisecond * time.Duration(rand.Intn(1<<count)))
|
||||||
}
|
}
|
||||||
|
|
||||||
if lockErr != nil {
|
if lockErr != nil {
|
||||||
|
Loading…
Reference in New Issue
Block a user