uppal/cgrates
1
0
Fork 1
mirror of https://github.com/cgrates/cgrates.git synced 2026-02-23 16:18:44 +05:00
Code Issues Packages Projects Releases Wiki Activity

some better error checking

Browse Source
This commit is contained in:
Radu Ioan Fericean
2012-08-29 12:09:57 +03:00
parent eb953efeae
commit 1d0f79bf38
1 changed files with 6 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
cmd/cgr-rater/cgr-rater.go
View File

@@ -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) {