mirror of
https://gitlab.torproject.org/tpo/anti-censorship/pluggable-transports/snowflake.git
synced 2025-10-13 20:11:19 -04:00
Remove SIGINT handling (no longer part of pt-spec).
This commit is contained in:
parent
c3f87281be
commit
1fa9bc051c
1 changed files with 8 additions and 9 deletions
|
@ -198,9 +198,9 @@ func main() {
|
|||
var numHandlers int = 0
|
||||
var sig os.Signal
|
||||
sigChan := make(chan os.Signal, 1)
|
||||
signal.Notify(sigChan, syscall.SIGINT, syscall.SIGTERM)
|
||||
signal.Notify(sigChan, syscall.SIGTERM)
|
||||
|
||||
// wait for first signal
|
||||
// keep track of handlers and wait for a signal
|
||||
sig = nil
|
||||
for sig == nil {
|
||||
select {
|
||||
|
@ -209,17 +209,16 @@ func main() {
|
|||
case sig = <-sigChan:
|
||||
}
|
||||
}
|
||||
|
||||
// signal received, shut down
|
||||
for _, ln := range listeners {
|
||||
ln.Close()
|
||||
}
|
||||
snowflakes.End()
|
||||
// wait for second signal or no more handlers
|
||||
sig = nil
|
||||
for sig == nil && numHandlers != 0 {
|
||||
select {
|
||||
case n := <-handlerChan:
|
||||
numHandlers += n
|
||||
case sig = <-sigChan:
|
||||
for n := range handlerChan {
|
||||
numHandlers += n
|
||||
if numHandlers == 0 {
|
||||
break
|
||||
}
|
||||
}
|
||||
log.Println("snowflake is done.")
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue