class UpQSocket(QTcpSocket):
    def __init__(self):
        QTcpSocket.__init__(self)
        self.wait_len = ''
        self.temp = ''
        self.setSocketOption(QTcpSocket.KeepAliveOption, QVariant(1))

    def connectToHost(self, host, port):
        self.temp = ''
        self.wait_len = ''
        QTcpSocket.connectToHost(self, host, port)


class UpQSocketThread(QThread):
    data_ready = pyqtSignal(unicode)

    error = pyqtSignal(int)
    connected = pyqtSignal()
    disconnected = pyqtSignal()

    def __init__(self, host , port):
        QThread.__init__(self)
        self.start()
        self.host = host
        self.port = port

    def state(self):
        return self.socket.state()

    def resend_error(self, error_code):
        self.error.emit(error_code)

    def resend_connected(self):
        self.connected.emit()

    def resend_disconnected(self):
        self.disconnected.emit()

    def run(self):
        self.socket = UpQSocket()
        self.socket.readyRead.connect(self.on_ready_read)#, Qt.DirectConnection)
        self.socket.error.connect(self.resend_error)#, Qt.DirectConnection)
        self.socket.disconnected.connect(self.resend_disconnected)#, Qt.DirectConnection)
        self.socket.connected.connect(self.connected)#, Qt.DirectConnection)
        self.socket.connectToHost(self.host, self.port )
        self.exec_()

    def send(self, data):
        self.socket.writeData('%s|%s' % (len(data), data))

    def close(self):
        self.socket.close()
        self.terminate()

    def on_ready_read(self):
        if self.socket.bytesAvailable():
            data = str(self.socket.readAll())
            while data:
                #process data...