mirrors/navidrome
1
0
Fork 0
mirror of https://github.com/navidrome/navidrome.git synced 2025-04-04 13:07:36 +03:00
Code Issues Projects Releases Packages Wiki Activity

Make tests compatible with GoLang 1.18

Browse source
This commit is contained in:
Deluan 2022-12-23 13:12:36 -05:00 • committed by Deluan Quintão
parent b6eb60f019
commit dc16ccdb93
1 changed files with 9 additions and 11 deletions
Download patch file Download diff file Expand all files Collapse all files

20
utils/pl/pipelines_test.go
View file

@ -53,15 +53,13 @@ var _ = Describe("Pipeline", func() {
} }
close(inC) close(inC)
current := atomic.Int32{} var current, count, max int32
count := atomic.Int32{}
max := atomic.Int32{}
outC, _ := pl.Stage(context.Background(), maxWorkers, inC, func(ctx context.Context, in int) (int, error) { outC, _ := pl.Stage(context.Background(), maxWorkers, inC, func(ctx context.Context, in int) (int, error) {
defer current.Add(-1) defer atomic.AddInt32(&current, -1)
c := current.Add(1) c := atomic.AddInt32(&current, 1)
count.Add(1) atomic.AddInt32(&count, 1)
if c > max.Load() { if c > atomic.LoadInt32(&max) {
max.Store(c) atomic.StoreInt32(&max, c)
} }
time.Sleep(10 * time.Millisecond) // Slow process time.Sleep(10 * time.Millisecond) // Slow process
return 0, nil return 0, nil
@ -70,9 +68,9 @@ var _ = Describe("Pipeline", func() {
for range outC { for range outC {
} }
Expect(count.Load()).To(Equal(int32(numJobs))) Expect(count).To(Equal(int32(numJobs)))
Expect(current.Load()).To(Equal(int32(0))) Expect(current).To(Equal(int32(0)))
Expect(max.Load()).To(Equal(int32(maxWorkers))) Expect(max).To(Equal(int32(maxWorkers)))
}) })
}) })
When("the context is canceled", func() { When("the context is canceled", func() {