Code Review
/
ric-plt
/
alarm-go.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Support for time-to-live
[ric-plt/alarm-go.git]
/
alarm
/
alarm.go
diff --git
a/alarm/alarm.go
b/alarm/alarm.go
index
3856fce
..
f8d909a
100755
(executable)
--- 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") == "" {
}
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
}
return r, nil
}
@@
-180,15
+180,15
@@
func (r *RICAlarm) ReceiveMessage(cb func(AlarmMessage)) error {
return errors.New("rmrRcv failed!")
}
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" {
// 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"
alarmRT := fmt.Sprintf("newrt|start\nrte|13111|%s\nnewrt|end\n", endpoint)
alarmRTFile := "/tmp/alarm.rt"