Method run

interface/vstream/python/vsi_video_server.py:653–713

Main server loop. Waits for a client connection, then processes commands in a loop. Handles all supported commands: set filename, configure stream, enable/disable stream, read/write frames, close server. Sends responses or frame data as appropriate.

(self)

    def run(self):
        """
        Main server loop.

        Waits for a client connection, then processes commands in a loop.
        Handles all supported commands: set filename, configure stream, enable/disable stream, read/write frames, close server.
        Sends responses or frame data as appropriate.
        """
        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_MODE:
                current_mode = self._setMode(payload[0])
                conn.send(current_mode)

            elif cmd == self.SET_DEVICE:
                device_valid = self._setDevice(payload[0])
                conn.send(device_valid)

            elif cmd == self.SET_FILENAME:
                filename_valid = self._setFilename(payload[0], payload[1])
                conn.send(filename_valid)

            elif cmd == self.STREAM_CONFIGURE:
                configuration_valid = self._configureStream(payload[0], payload[1], payload[2], payload[3])
                conn.send(configuration_valid)

            elif cmd == self.STREAM_ENABLE:
                self._enableStream()
                conn.send(self.active)

            elif cmd == self.STREAM_DISABLE:
                self._disableStream()
                conn.send(self.active)

            elif cmd == self.FRAME_READ:
                frame = self._readFrame()
                conn.send_bytes(frame)
                conn.send(self.eos)

            elif cmd == self.FRAME_WRITE:
                frame = conn.recv_bytes()
                self._writeFrame(frame)