Method run

interface/vstream/python/vsi_audio_server.py:565–626

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 audio, close server. Sends responses or audio data as appropriate.

(self)

            logger.error(f"_writeAudio: error writing audio data: {e}")

    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 audio, close server.
        Sends responses or audio data as appropriate.
        """
        logger.info("Audio 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])
                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.AUDIO_READ:
                size = payload[0]
                audio_data = self._readAudio(size)
                conn.send_bytes(audio_data)
                conn.send(self.eos)

            elif cmd == self.AUDIO_WRITE:
                audio_data = conn.recv_bytes()