Loading go-apps/meep-loc-serv/server/loc-serv.go +11 −10 Original line number Diff line number Diff line Loading @@ -215,6 +215,11 @@ func Init() (err error) { } log.Info("SBI Initialized") return nil } // Run - Start Location Service func Run() (err error) { distancePeriodicTicker = time.NewTicker(time.Second) go func() { for range distancePeriodicTicker.C { Loading @@ -222,16 +227,12 @@ func Init() (err error) { } }() return nil } // Run - Start Location Service func Run() (err error) { return sbi.Run() } // Stop - Stop RNIS func Stop() (err error) { distancePeriodicTicker.Stop() return sbi.Stop() } Loading Loading @@ -429,14 +430,12 @@ func checkNotificationDistancePeriodicTrigger() { returnAddr[monitoredAddr] = &distResp } else { skipThisSubscription = true break } case ALL_BEYOND_DISTANCE: if float32(distance) > distanceCheck.Subscription.Distance { returnAddr[monitoredAddr] = &distResp } else { skipThisSubscription = true break } case ANY_WITHIN_DISTANCE: if float32(distance) < distanceCheck.Subscription.Distance { Loading @@ -448,6 +447,8 @@ func checkNotificationDistancePeriodicTrigger() { } default: } if skipThisSubscription { break } if skipThisSubscription { continue Loading Loading
go-apps/meep-loc-serv/server/loc-serv.go +11 −10 Original line number Diff line number Diff line Loading @@ -215,6 +215,11 @@ func Init() (err error) { } log.Info("SBI Initialized") return nil } // Run - Start Location Service func Run() (err error) { distancePeriodicTicker = time.NewTicker(time.Second) go func() { for range distancePeriodicTicker.C { Loading @@ -222,16 +227,12 @@ func Init() (err error) { } }() return nil } // Run - Start Location Service func Run() (err error) { return sbi.Run() } // Stop - Stop RNIS func Stop() (err error) { distancePeriodicTicker.Stop() return sbi.Stop() } Loading Loading @@ -429,14 +430,12 @@ func checkNotificationDistancePeriodicTrigger() { returnAddr[monitoredAddr] = &distResp } else { skipThisSubscription = true break } case ALL_BEYOND_DISTANCE: if float32(distance) > distanceCheck.Subscription.Distance { returnAddr[monitoredAddr] = &distResp } else { skipThisSubscription = true break } case ANY_WITHIN_DISTANCE: if float32(distance) < distanceCheck.Subscription.Distance { Loading @@ -448,6 +447,8 @@ func checkNotificationDistancePeriodicTrigger() { } default: } if skipThisSubscription { break } if skipThisSubscription { continue Loading