chg: [main] listen to OS signal when ratelimiting
parent
ab248fa3ad
commit
a7032f58ee
|
@ -200,7 +200,13 @@ func main() {
|
||||||
// copy routine
|
// copy routine
|
||||||
go d4Copy(d4p, c)
|
go d4Copy(d4p, c)
|
||||||
// Block until the rate limiter allow us to continue
|
// Block until the rate limiter allow us to continue
|
||||||
<-ratelimiter
|
select {
|
||||||
|
case <-ratelimiter:
|
||||||
|
continue
|
||||||
|
case <-s:
|
||||||
|
logger.Println("Exiting")
|
||||||
|
exit(d4p, 0)
|
||||||
|
}
|
||||||
} else if d4.retry > 0 {
|
} else if d4.retry > 0 {
|
||||||
go func() {
|
go func() {
|
||||||
logger.Println(fmt.Sprintf("Sleeping for %.f seconds before retry...", d4.retry.Seconds()))
|
logger.Println(fmt.Sprintf("Sleeping for %.f seconds before retry...", d4.retry.Seconds()))
|
||||||
|
|
Loading…
Reference in New Issue