X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=a1%2Fa1rmr.py;h=58ec1c06958ac80460805059b904863f54e45321;hb=refs%2Fchanges%2F10%2F2310%2F2;hp=2e5dace0ddecf41b6b2d3d3b5986b0723199cd6d;hpb=9d5ad7161f64346c17e9c466bf1992e4257e9bde;p=ric-plt%2Fa1.git diff --git a/a1/a1rmr.py b/a1/a1rmr.py index 2e5dace..58ec1c0 100644 --- a/a1/a1rmr.py +++ b/a1/a1rmr.py @@ -2,8 +2,8 @@ a1s rmr functionality """ # ================================================================================== -# Copyright (c) 2019 Nokia -# Copyright (c) 2018-2019 AT&T Intellectual Property. +# Copyright (c) 2019-2020 Nokia +# Copyright (c) 2018-2020 AT&T Intellectual Property. # # Licensed under the Apache License, Version 2.0 (the "License"); # you may not use this file except in compliance with the License. @@ -31,8 +31,6 @@ mdc_logger = Logger(name=__name__) RETRY_TIMES = int(os.environ.get("A1_RMR_RETRY_TIMES", 4)) - - A1_POLICY_REQUEST = 20010 A1_POLICY_RESPONSE = 20011 A1_POLICY_QUERY = 20012 @@ -53,6 +51,8 @@ class _RmrLoop: self.keep_going = True self.rcv_func = None self.last_ran = time.time() + + # see docs/overview#resiliency for a discussion of this self.instance_send_queue = queue.Queue() # thread safe queue https://docs.python.org/3/library/queue.html # intialize rmr context