nip77: fix one possible infinite loop with channels.
This commit is contained in:
+16
-6
@@ -128,17 +128,27 @@ func NegentropySync(
|
|||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
|
done := make(chan struct{})
|
||||||
go func() {
|
go func() {
|
||||||
|
defer close(done)
|
||||||
wg.Wait()
|
wg.Wait()
|
||||||
errch <- nil
|
select {
|
||||||
|
case errch <- nil:
|
||||||
|
case <-ctx.Done():
|
||||||
|
}
|
||||||
}()
|
}()
|
||||||
|
|
||||||
err = <-errch
|
select {
|
||||||
if err != nil {
|
case err = <-errch:
|
||||||
return err
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
return nil
|
||||||
|
case <-ctx.Done():
|
||||||
|
return ctx.Err()
|
||||||
|
case <-done:
|
||||||
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
return nil
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func SyncEventsFromIDs(ctx context.Context, dir Direction) {
|
func SyncEventsFromIDs(ctx context.Context, dir Direction) {
|
||||||
|
|||||||
Reference in New Issue
Block a user