Skip to content

C
cache
Commit 7fd28581 authored by luxq's avatar luxq
Browse files
Options

add deley for retry

parent 1f9d0666
Show whitespace changes
Inline Side-by-side
Showing with 6 additions and 0 deletions
payment.go
View file @ 7fd28581
...@@ -29,6 +29,7 @@ func (p *Payment) IncrBalance(ctx context.Context, uid string, bal int64) (int64 ...@@ -29,6 +29,7 @@ func (p *Payment) IncrBalance(ctx context.Context, uid string, bal int64) (int64
return 0, err return 0, err
} }
if !locked { if !locked {
time.Sleep(time.Millisecond * 10)
continue continue
} }
defer release() defer release()
...@@ -50,6 +51,7 @@ func (p *Payment) DecrBalance(ctx context.Context, uid string, bal int64) (int64 ...@@ -50,6 +51,7 @@ func (p *Payment) DecrBalance(ctx context.Context, uid string, bal int64) (int64
return 0, err return 0, err
} }
if !locked { if !locked {
time.Sleep(time.Millisecond * 10)
continue continue
} }
defer release() defer release()
...@@ -68,6 +70,7 @@ func (p *Payment) IncrCharge(ctx context.Context, uid string, bal int64) (int64, ...@@ -68,6 +70,7 @@ func (p *Payment) IncrCharge(ctx context.Context, uid string, bal int64) (int64,
return 0, err return 0, err
} }
if !locked { if !locked {
time.Sleep(time.Millisecond * 10)
continue continue
} }
defer release() defer release()
...@@ -91,6 +94,7 @@ func (p *Payment) DecrCharge(ctx context.Context, uid string, bal int64) (int64, ...@@ -91,6 +94,7 @@ func (p *Payment) DecrCharge(ctx context.Context, uid string, bal int64) (int64,
return 0, err return 0, err
} }
if !locked { if !locked {
time.Sleep(time.Millisecond * 10)
continue continue
} }
defer release() defer release()
...@@ -109,6 +113,7 @@ func (p *Payment) IncrCredits(ctx context.Context, uid string, bal int64) (int64 ...@@ -109,6 +113,7 @@ func (p *Payment) IncrCredits(ctx context.Context, uid string, bal int64) (int64
return 0, err return 0, err
} }
if !locked { if !locked {
time.Sleep(time.Millisecond * 10)
continue continue
} }
defer release() defer release()
...@@ -132,6 +137,7 @@ func (p *Payment) DecrCredits(ctx context.Context, uid string, bal int64) (int64 ...@@ -132,6 +137,7 @@ func (p *Payment) DecrCredits(ctx context.Context, uid string, bal int64) (int64
return 0, err return 0, err
} }
if !locked { if !locked {
time.Sleep(time.Millisecond * 10)
continue continue
} }
defer release() defer release()
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment