X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=ricxappframe%2Fxapp_frame.py;h=58596b8c398afc3260b45734514e74bd4ae2e819;hb=refs%2Fchanges%2F89%2F3589%2F2;hp=180c3ae9f91838b96b47246bab7c48d7337da77f;hpb=09894e3c7bdd6eeaae4a84467f5ea6af1a061204;p=ric-plt%2Fxapp-frame-py.git diff --git a/ricxappframe/xapp_frame.py b/ricxappframe/xapp_frame.py index 180c3ae..58596b8 100644 --- a/ricxappframe/xapp_frame.py +++ b/ricxappframe/xapp_frame.py @@ -21,7 +21,7 @@ Framework here means Xapp classes that can be subclassed from threading import Thread from ricxappframe import xapp_rmr from ricxappframe.xapp_sdl import SDLWrapper -from rmr import rmr +from ricxappframe.rmr import rmr from mdclogpy import Logger # constants @@ -76,7 +76,9 @@ class _BaseXapp: def rmr_get_messages(self): """ - returns a generator iterable over all current messages in the queue that have not yet been read by the client xapp + Returns a generator iterable over all items in the queue that have not yet been read by the client xapp. + Each item is a tuple (S, sbuf) where S is a message summary dict and sbuf is the raw message. + The caller MUST call rmr.rmr_free_msg(sbuf) when finished with each sbuf to prevent memory leaks! """ while not self._rmr_loop.rcv_queue.empty(): (summary, sbuf) = self._rmr_loop.rcv_queue.get()