diff --git a/cmd/cgr-engine/cgr-engine.go b/cmd/cgr-engine/cgr-engine.go index 7da34b4cd..2e1267be6 100644 --- a/cmd/cgr-engine/cgr-engine.go +++ b/cmd/cgr-engine/cgr-engine.go @@ -418,7 +418,6 @@ func startScheduler(internalSchedulerChan chan *scheduler.Scheduler, cacheDoneCh cacheDoneChan <- cacheDone utils.Logger.Info("Starting CGRateS Scheduler.") sched := scheduler.NewScheduler(ratingDb) - go reloadSchedulerSingnalHandler(sched, ratingDb) time.Sleep(1) internalSchedulerChan <- sched sched.Reload(true) diff --git a/cmd/cgr-engine/registration.go b/cmd/cgr-engine/registration.go index c33cf4596..3e0dd48fb 100644 --- a/cmd/cgr-engine/registration.go +++ b/cmd/cgr-engine/registration.go @@ -25,8 +25,6 @@ import ( "syscall" "github.com/cgrates/cgrates/balancer2go" - "github.com/cgrates/cgrates/engine" - "github.com/cgrates/cgrates/scheduler" "github.com/cgrates/cgrates/utils" "github.com/cgrates/rpcclient" ) @@ -43,22 +41,6 @@ func stopBalancerSignalHandler(bal *balancer2go.Balancer, exitChan chan bool) { exitChan <- true } -func generalSignalHandler(internalCdrStatSChan chan rpcclient.RpcClientConnection, exitChan chan bool) { - c := make(chan os.Signal) - signal.Notify(c, syscall.SIGTERM, syscall.SIGINT, syscall.SIGQUIT) - - sig := <-c - utils.Logger.Info(fmt.Sprintf("Caught signal %v, shuting down cgr-engine\n", sig)) - var dummyInt int - select { - case cdrStats := <-internalCdrStatSChan: - cdrStats.Call("CDRStatsV1.Stop", dummyInt, &dummyInt) - default: - } - - exitChan <- true -} - /* Listens for the SIGTERM, SIGINT, SIGQUIT system signals and gracefuly unregister from balancer and closes the storage before exiting. */ @@ -117,18 +99,6 @@ func registerToBalancer(exitChan chan bool) { utils.Logger.Info("Registration finished!") } -// Listens for the HUP system signal and gracefuly reloads the timers from database. -func reloadSchedulerSingnalHandler(sched *scheduler.Scheduler, getter engine.RatingStorage) { - for { - c := make(chan os.Signal) - signal.Notify(c, syscall.SIGHUP) - sig := <-c - - utils.Logger.Info(fmt.Sprintf("Caught signal %v, reloading action timings.\n", sig)) - sched.Reload(true) - } -} - /* Listens for the SIGTERM, SIGINT, SIGQUIT system signals and shuts down the session manager. */