X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=E2Manager%2Fmanagers%2Fe2t_keep_alive_worker.go;h=606e339cbc1c0b9a5fc26b4efe6b2a6c29409637;hb=b3805a9d29e2c7f6f14e3fedfa1ba504f734eea9;hp=45c5c0822c8bb85cac661a285ad4d64a256e731b;hpb=efcb4528362460aa2249d319c9752b63bb720fe2;p=ric-plt%2Fe2mgr.git diff --git a/E2Manager/managers/e2t_keep_alive_worker.go b/E2Manager/managers/e2t_keep_alive_worker.go index 45c5c08..606e339 100644 --- a/E2Manager/managers/e2t_keep_alive_worker.go +++ b/E2Manager/managers/e2t_keep_alive_worker.go @@ -14,6 +14,10 @@ // See the License for the specific language governing permissions and // limitations under the License. // + +// This source code is part of the near-RT RIC (RAN Intelligent Controller) +// platform project (RICP). + package managers import ( @@ -49,7 +53,7 @@ func (h E2TKeepAliveWorker) Execute() { ticker := time.NewTicker(time.Duration(h.config.KeepAliveDelayMs) * time.Millisecond) - for _= range ticker.C { + for _ = range ticker.C { h.SendKeepAliveRequest() h.E2TKeepAliveExpired() @@ -80,6 +84,6 @@ func (h E2TKeepAliveWorker) E2TKeepAliveExpired() { func (h E2TKeepAliveWorker) SendKeepAliveRequest() { - request := models.RmrMessage{MsgType: rmrCgo.E2_TERM_KEEP_ALIVE_REQ} - h.rmrSender.SendWithoutLogs(&request) -} \ No newline at end of file + rmrMessage := models.RmrMessage{MsgType: rmrCgo.E2_TERM_KEEP_ALIVE_REQ} + h.rmrSender.SendWithoutLogs(&rmrMessage) +}