51 lines
899 B
Go
51 lines
899 B
Go
/*
|
|
Copyright (C) 2013 Aaron Lindsay <aaron@aclindsay.com>
|
|
*/
|
|
|
|
package asink
|
|
|
|
import (
|
|
"os"
|
|
"os/signal"
|
|
"sync/atomic"
|
|
)
|
|
|
|
var exitWaiterCount int32
|
|
var exitCalled chan int
|
|
var exitWaiterChan chan int
|
|
|
|
func init() {
|
|
exitWaiterCount = 0
|
|
exitWaiterChan = make(chan int)
|
|
exitCalled = make(chan int)
|
|
}
|
|
|
|
func SetupCleanExitOnSignals() {
|
|
go setupCleanExitOnSignals()
|
|
}
|
|
func setupCleanExitOnSignals() {
|
|
//wait to properly close the socket when we're exiting
|
|
exitCode := 0
|
|
sig := make(chan os.Signal, 1)
|
|
signal.Notify(sig, os.Interrupt)
|
|
defer signal.Stop(sig)
|
|
|
|
select {
|
|
case <-sig:
|
|
case exitCode = <-exitCalled:
|
|
}
|
|
|
|
for c := atomic.AddInt32(&exitWaiterCount, -1); c >= 0; c = atomic.AddInt32(&exitWaiterCount, -1) {
|
|
exitWaiterChan <- exitCode
|
|
}
|
|
}
|
|
|
|
func Exit(exitCode int) {
|
|
exitCalled <- exitCode
|
|
}
|
|
|
|
func WaitOnExit() int {
|
|
atomic.AddInt32(&exitWaiterCount, 1)
|
|
return <-exitWaiterChan
|
|
}
|