diff --git a/cmd/cgr-rater/cgr-rater.go b/cmd/cgr-rater/cgr-rater.go index e0827cf53..e1d42b90e 100644 --- a/cmd/cgr-rater/cgr-rater.go +++ b/cmd/cgr-rater/cgr-rater.go @@ -150,18 +150,12 @@ func readConfig(c *conf.ConfigFile) { func listenToRPCRequests(rpcResponder interface{}, rpcAddress string, rpc_encoding string) { l, err := net.Listen("tcp", rpcAddress) if err != nil { - timespans.Logger.Err(fmt.Sprintf("could not connect to %v: %v", rpcAddress, err)) + timespans.Logger.Crit(fmt.Sprintf("Could not listen to %v: %v", rpcAddress, err)) exitChan <- true return } defer l.Close() - if err != nil { - timespans.Logger.Err(fmt.Sprintf("could start the rpc server: %v", err)) - exitChan <- true - return - } - timespans.Logger.Info(fmt.Sprintf("Listening for incomming RPC requests on %v", l.Addr())) rpc.Register(rpcResponder) var serveFunc func(io.ReadWriteCloser) @@ -188,7 +182,11 @@ func listenToHttpRequests() { http.HandleFunc("/getmem", memoryHandler) http.HandleFunc("/raters", ratersHandler) timespans.Logger.Info(fmt.Sprintf("The server is listening on %s", stats_listen)) - http.ListenAndServe(stats_listen, nil) + err := http.ListenAndServe(stats_listen, nil) + if err != nil { + timespans.Logger.Crit(fmt.Sprintf("Could not start the http server: ", err)) + exitChan <- true + } } func startMediator(responder *timespans.Responder, loggerDb timespans.DataStorage) {