def handle(self):
        self.connection.setblocking(0)
        while not self.server.abort:
            try:
                chunk = self.connection.recv(4)
                if len(chunk) < 4:
                    break
                slen = struct.unpack('>L', chunk)[0]
                chunk = self.connection.recv(slen)
                while len(chunk) < slen:
                    chunk = chunk + self.connection.recv(len(chunk) - slen)
                obj = self.unPickle(chunk)
                record = logging.makeLogRecord(obj)
                self.handleLogRecord(record)
            except socket.error:
                return
dataset/ETHPy150Open chineking/cola/cola/core/logs.py/LogRecordStreamHandler.handle/swapped operands of `-`