]> git.michaelhowe.org Git - packages/p/paho-mqtt.git/commitdiff
Close connection after sending a DISCONNECT.
authorRoger Light <roger@atchoo.org>
Tue, 4 Feb 2014 17:59:03 +0000 (17:59 +0000)
committerRoger Light <roger@atchoo.org>
Tue, 4 Feb 2014 14:59:30 +0000 (14:59 +0000)
Change-Id: I8b500c721754f2868e55c2d89abffcbbc7ccc95d

src/paho/mqtt/client.py

index 8798c9b00544e536d31f6b1d95697aac16b1c767..c04ddb83d52358227f99d1e171ed5624f4821553 100755 (executable)
@@ -1387,6 +1387,13 @@ class Client(object):
                             self.on_disconnect(self, self._userdata, 0)
                             self._in_callback = False
                         self._callback_mutex.release()
+
+                        if self._ssl:
+                            self._ssl.close()
+                            self._ssl = None
+                        elif self._sock:
+                            self._sock.close()
+                            self._sock = None
                         return MQTT_ERR_SUCCESS
 
                     self._out_packet_mutex.acquire()