Commit 49a7c58c authored by Ignacio Corderi's avatar Ignacio Corderi
Browse files

Fixed ASOKVAD-263

parent 486fcab6

kinetic/asyncclient.py

+1 −1
Original line number Diff line number Diff line
@@ -68,7 +68,7 @@ class AsyncClient(baseasync.BaseAsync): 
        self.writer_thread.kill()

        self.reader_thread.kill()



        self.dispatch(super(AsyncClient, self).close)

        super(AsyncClient, self).close()



        self.writer_thread = None

        self.reader_thread = None

kinetic/baseclient.py

+2 −1
Original line number Diff line number Diff line
@@ -128,7 +128,7 @@ class BaseClient(object): 


    def close(self):

        self._closed = True

        if self.isConnected:

        if self._socket:

            self._socket.shutdown(socket.SHUT_RDWR)

            self._socket.close()

        self._buff = ''
@@ -136,6 +136,7 @@ class BaseClient(object): 
        self.connection_id = None

        self._sequence = itertools.count()





    def update_header(self, message):

        """

        Updates the message header with connection specific information.