Commit d582c17d authored by Lluis Gifre Renom's avatar Lluis Gifre Renom
Browse files

NBI component: 

- Disabled multi-worker as synchronization through Kafka seems not to work, to be corrected
- Disabled heartbeat thread
parent 8033d204

src/nbi/Dockerfile

+2 −1
Original line number Diff line number Diff line
@@ -89,4 +89,5 @@ RUN mkdir -p /var/teraflow/tests/tools 
COPY src/tests/tools/mock_osm/. tests/tools/mock_osm/



# Start the service

ENTRYPOINT ["gunicorn", "--workers", "4", "--worker-class", "eventlet", "--bind", "0.0.0.0:8080", "nbi.service.app:app"]
 
# NOTE: Configured single worker to prevent issues with multi-worker synchronization. To be invetsigated.

ENTRYPOINT ["gunicorn", "--workers", "1", "--worker-class", "eventlet", "--bind", "0.0.0.0:8080", "nbi.service.app:app"]

src/nbi/service/NbiApplication.py

+5 −5
Original line number Diff line number Diff line
@@ -44,13 +44,13 @@ class NbiApplication: 


        # Configure KafkaManager to enable SocketIO Servers running in different

        # gunicorn workers to self-coordinate and share sessions.

        self._sio_client_manager = socketio.KafkaManager(

            url='kafka://{:s}'.format(KafkaConfig.get_kafka_address()),

            channel=KafkaTopic.NBI_SOCKETIO_WORKERS.value

        )

        #self._sio_client_manager = socketio.KafkaManager(

        #    url='kafka://{:s}'.format(KafkaConfig.get_kafka_address()),

        #    channel=KafkaTopic.NBI_SOCKETIO_WORKERS.value

        #)

        self._sio = SocketIO(

            self._app, cors_allowed_origins='*', async_mode='eventlet',

            client_manager=self._sio_client_manager,

            #client_manager=self._sio_client_manager,

            logger=True, engineio_logger=True

        )

src/nbi/service/health_probes/Namespaces.py

+1 −1
Original line number Diff line number Diff line
@@ -24,7 +24,7 @@ class HeartbeatServerNamespace(Namespace): 
    def __init__(self):

        super().__init__(namespace=SIO_NAMESPACE)

        self._thread = HeartbeatThread(self)

        self._thread.start()

        #self._thread.start()



    def stop_thread(self) -> None:

        self._thread.stop()