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

Add fatal logs on engine

Browse Source
This commit is contained in:
arberkatellari
2023-08-29 09:44:34 -04:00
committed by Dan Christian Bogos
parent 4c2f752aa6
commit 0a4c2ee12c
2 changed files with 11 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
cmd/cgr-engine/cgr-engine.go
View File

@@ -316,12 +316,11 @@ func runPreload(loader *services.LoaderService, internalLoaderSChan chan rpcclie
func main() {
if err := cgrEngineFlags.Parse(os.Args[1:]); err != nil {
return
log.Fatalf("<%s> error received: <%s>, exiting!", utils.InitS, err.Error())
}
vers, err := utils.GetCGRVersion()
if err != nil {
fmt.Println(err)
return
log.Fatalf("<%s> error received: <%s>, exiting!", utils.InitS, err.Error())
}
goVers := runtime.Version()
if *version {
@@ -361,7 +360,7 @@ func main() {
cpuPath := path.Join(*cpuProfDir, utils.CpuPathCgr)
cpuProfileFile, err = cores.StartCPUProfiling(cpuPath)
if err != nil {
return
log.Fatalf("<%s> error received: <%s>, exiting!", utils.InitS, err.Error())
}
defer func() {
if cS != nil {
@@ -378,7 +377,7 @@ func main() {
if *scheduledShutdown != utils.EmptyString {
shutdownDur, err := utils.ParseDurationWithNanosecs(*scheduledShutdown)
if err != nil {
log.Fatal(err)
log.Fatalf("<%s> error received: <%s>, exiting!", utils.InitS, err.Error())
}
shdWg.Add(1)
go func() { // Schedule shutdown
@@ -401,7 +400,7 @@ func main() {
}
if *checkConfig {
if err := cfg.CheckConfigSanity(); err != nil {
fmt.Println(err)
log.Fatalf("<%s> error received: <%s>, exiting!", utils.InitS, err.Error())
}
return
}
@@ -524,13 +523,13 @@ func main() {
gvService := services.NewGlobalVarS(cfg, srvDep)
shdWg.Add(1)
if err = gvService.Start(); err != nil {
return
log.Fatalf("<%s> error received: <%s>, exiting!", utils.InitS, err.Error())
}
dmService := services.NewDataDBService(cfg, connManager, srvDep)
if dmService.ShouldRun() { // Some services can run without db, ie: ERs
shdWg.Add(1)
if err = dmService.Start(); err != nil {
return
log.Fatalf("<%s> error received: <%s>, exiting!", utils.InitS, err.Error())
}
}
@@ -538,7 +537,7 @@ func main() {
if storDBService.ShouldRun() { // Some services can run without db, ie: ERs
shdWg.Add(1)
if err = storDBService.Start(); err != nil {
return
log.Fatalf("<%s> error received: <%s>, exiting!", utils.InitS, err.Error())
}
}
@@ -562,8 +561,7 @@ func main() {
if anz.ShouldRun() {
shdWg.Add(1)
if err := anz.Start(); err != nil {
fmt.Println(err)
return
log.Fatalf("<%s> error received: <%s>, exiting!", utils.InitS, err.Error())
}
}
@@ -572,8 +570,7 @@ func main() {
coreS := services.NewCoreService(cfg, caps, server, internalCoreSv1Chan, anz, cpuProfileFile, memPrfDirForCores, shdWg, stopMemProf, shdChan, srvDep)
shdWg.Add(1)
if err := coreS.Start(); err != nil {
fmt.Println(err)
return
log.Fatalf("<%s> error received: <%s>, exiting!", utils.InitS, err.Error())
}
cS = coreS.GetCoreS()

1
utils/consts.go
View File

@@ -723,6 +723,7 @@ const (
MetaEventNumber = "*event_number"
LoadIDs = "load_ids"
DNSAgent = "DNSAgent"
InitS = "InitS"
TLSNoCaps = "tls"
UsageID = "UsageID"
Replacement = "Replacement"