Method run

interface/video/python/vsi_video_server.py:362–414

(self)

    # Run Video Server
    def run(self):
        logger.info("Video server started")

        try:
            conn = self.listener.accept()
            logger.info(f'Connection accepted {self.listener.address}')
        except Exception:
            logger.error("Connection not accepted")
            return

        while True:
            try:
                recv = conn.recv()
            except EOFError:
                return

            cmd     = recv[0]  # Command
            payload = recv[1:] # Payload

            if  cmd == self.SET_FILENAME:
                logger.info("Set filename called")
                filename_valid = self._setFilename(payload[0], payload[1], payload[2])
                conn.send(filename_valid)

            elif cmd == self.STREAM_CONFIGURE:
                logger.info("Stream configure called")
                configuration_valid = self._configureStream(payload[0], payload[1], payload[2], payload[3])
                conn.send(configuration_valid)

            elif cmd == self.STREAM_ENABLE:
                logger.info("Enable stream called")
                self._enableStream(payload[0])
                conn.send(self.active)

            elif cmd == self.STREAM_DISABLE:
                logger.info("Disable stream called")
                self._disableStream()
                conn.send(self.active)

            elif cmd == self.FRAME_READ:
                logger.info("Read frame called")
                frame = self._readFrame()
                conn.send_bytes(frame)
                conn.send(self.eos)

            elif cmd == self.FRAME_WRITE:
                logger.info("Write frame called")
                frame = conn.recv_bytes()
                self._writeFrame(frame)

            elif cmd == self.CLOSE_SERVER:
                logger.info("Close server connection")
                self.stop()

    # Stop Video Server
    def stop(self):