INNER CODE UNIT · Python

read_data

TheXTech/TheXTech · resources/_dev_scripts/xserver.py:192

    def read_data(self):
        # conn is the socket object
        while True:
            try:
                message = self.data_conn.recv(4)
            except BlockingIOError:
                break

            if len(message) != 4:
                self.room.kill(self)
                return

            if message[0] == MESSAGE_FRAME_BEGIN or message[0] == MESSAGE_FRAME_END:
                if self.tcp_frame_no > self.acked_frame:
                    self.acked_frame = self.tcp_frame_no

                    for msg in self.tcp_frame_in_progress:
                        self.room.enqueue_text_event(self.tcp_frame_no, self.id, msg)

View source record →