UDP_generic.py 文件源码

def recv(self):
        message = ""
        length2b, addr = self.comms_socket.recvfrom(2, socket.MSG_PEEK)

        if len(length2b) == 0:
            if self.serverorclient:
                common.internal_print("WTF? Client lost. Closing down thread.", -1)
            else:
                common.internal_print("WTF? Server lost. Closing down.", -1)

            return ("", None)

        if len(length2b) != 2:
            return ("", None)

        length = struct.unpack(">H", length2b)[0]+2
        message, addr = self.comms_socket.recvfrom(length, socket.MSG_TRUNC)
        if (length != len(message)):
            common.internal_print("Error length mismatch", -1)
            return ("", None)

        common.internal_print("UDP read: {0}".format(len(message)-2), 0, self.verbosity, common.DEBUG)

        return message[2:], addr