X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;ds=sidebyside;f=alarm%2Falarm.go;h=f8d909af629b5ae94036a75e60a92336eaa58790;hb=3649fae7a06ad3ad099d0aa4e68f7ca3a2ae5a87;hp=3856fce4312505dc429769ed58c314275222ca30;hpb=6f73fa33d550b6ff5ca2590757e98cec88254812;p=ric-plt%2Falarm-go.git diff --git a/alarm/alarm.go b/alarm/alarm.go index 3856fce..f8d909a 100755 --- a/alarm/alarm.go +++ b/alarm/alarm.go @@ -56,10 +56,10 @@ func InitAlarm(mo, id string) (*RICAlarm, error) { } if os.Getenv("ALARM_IF_RMR") == "" { - go InitRMR(r, "") - } else { - go InitRMR(r, ALARM_MANAGER_RMR_URL) - } + go InitRMR(r, "") + } else { + go InitRMR(r, ALARM_MANAGER_RMR_URL) + } return r, nil } @@ -180,15 +180,15 @@ func (r *RICAlarm) ReceiveMessage(cb func(AlarmMessage)) error { return errors.New("rmrRcv failed!") } -func InitRMR(r *RICAlarm, endpoint string) error { +func InitRMR(r *RICAlarm, endpoint string) error { // Setup static RT for alarm system if endpoint == "" { if r.moId == "my-pod" { - endpoint = "127.0.0.1:4560" - } else if r.moId == "my-pod-lib" { - endpoint = "127.0.0.1:4588" - } - } + endpoint = "127.0.0.1:4560" + } else if r.moId == "my-pod-lib" { + endpoint = "127.0.0.1:4588" + } + } alarmRT := fmt.Sprintf("newrt|start\nrte|13111|%s\nnewrt|end\n", endpoint) alarmRTFile := "/tmp/alarm.rt"