Method _send_data_async

tensorrt_llm/executor/ipc.py:358–368

Async version of _send_data.

(self,
                               data: bytes,
                               routing_id: Optional[bytes] = None)

            self.socket.send(data, flags=flags)

    async def _send_data_async(self,
                               data: bytes,
                               routing_id: Optional[bytes] = None):
        """Async version of _send_data."""
        if self.socket_type == zmq.ROUTER:
            identity = routing_id if routing_id is not None else self._last_identity
            if identity is None:
                raise ValueError("ROUTER socket requires identity")
            await self.socket.send_multipart([identity, data])
        else:
            await self.socket.send(data)

    def _recv_data(self, return_identity: bool = False) -> Any:
        """Receive data using appropriate API based on socket type."""