|
|
@ -225,8 +225,8 @@ func main() { |
|
|
|
|
|
|
|
|
|
|
|
// Initialize mempool monitor
|
|
|
|
exitMempool := make(chan bool) |
|
|
|
common.StartMempoolMonitor(cache, exitMempool) |
|
|
|
// exitMempool := make(chan bool)
|
|
|
|
// common.StartMempoolMonitor(cache, exitMempool)
|
|
|
|
|
|
|
|
// Start listening
|
|
|
|
listener, err := net.Listen("tcp", opts.bindAddr) |
|
|
@ -242,7 +242,7 @@ func main() { |
|
|
|
signal.Notify(signals, syscall.SIGINT, syscall.SIGTERM) |
|
|
|
go func() { |
|
|
|
s := <-signals |
|
|
|
exitMempool <- true |
|
|
|
// exitMempool <- true
|
|
|
|
log.WithFields(logrus.Fields{ |
|
|
|
"signal": s.String(), |
|
|
|
}).Info("caught signal, stopping gRPC server") |
|
|
|