Хранилища Subversion pytwidcpp

class PacketProcessor:

        """ Class for processing tcp packets,

        and make DC++ packets. (Merge packets from

        one command). """

        def __init__(self):

                """ Clear buffer and initialize class. """

                buffer = ""

        def _isFull(self, command):

                """ Check buffer for full command. """

                if len(command) == 0:

                        return False

                if command[len(command) - 1] == '|':

                        return True

                else:

                        return False

        def Process(self, socket, packet, commandProcessor):

                """ Process new tcp packet. """

                # Save previous packets

                prev = self.buffer

                # Clear buffer

                self.buffer = ""

                # Merge previous and packet

                buf = prev + packet

                # Split

                commands = buf.split('|')

                # If Merge result not is full command.

                if not self._isFull(buf):

                        # If count of commands in Merge result is 1

                        if len(commands) == 1:

                                # Save Merge result to buffer

                                self.buffer  = commands[0]

                                commands = []

                        else:

                                # Save first from all commands to buffer

                                self.buffer = commands[len(commands) - 1]

                                commands = commands[0:len(commands)-1]

                # Process every command

                for i in commands:

                        commandProcessor(i, socket)

        def ClearBuffer(self):

                self.buffer = ""