X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fxapp%2Frmr.go;h=3a52c97cce50b391714f73473ddbc945b121281e;hb=96be5095a97c975d6644cdae6244366a9d2e59fe;hp=3cb4f8481866919390fc2fbfa757f48c5a348a0b;hpb=f49009aad3b16524cb53ae954a0711c17ec4f82a;p=ric-plt%2Fxapp-frame.git diff --git a/pkg/xapp/rmr.go b/pkg/xapp/rmr.go index 3cb4f84..3a52c97 100755 --- a/pkg/xapp/rmr.go +++ b/pkg/xapp/rmr.go @@ -111,13 +111,17 @@ func (m *RMRClient) Start(c MessageConsumer) { m.consumers = append(m.consumers, c) } + var counter int = 0 for { - Logger.Info("rmrClient: Waiting for RMR to be ready ...") - if m.ready = int(C.rmr_ready(m.context)); m.ready == 1 { + Logger.Info("rmrClient: RMR is ready after %d seconds waiting...", counter) break } - time.Sleep(10 * time.Second) + if counter%10 == 0 { + Logger.Info("rmrClient: Waiting for RMR to be ready ...") + } + time.Sleep(1 * time.Second) + counter++ } m.wg.Add(m.numWorkers)