From 4dc96a253316a643379f54f5c292690e8c7998dc Mon Sep 17 00:00:00 2001
From: Teun Lassche <contact@thlassche.nl>
Date: Mon, 7 Nov 2016 20:28:17 +0100
Subject: [PATCH] Fix #304 Socket leakage

Signed-off-by: Teun Lassche <contact@thlassche.nl>
---
 lib/mosquitto.c | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/lib/mosquitto.c b/lib/mosquitto.c
index 880657df..732e18f3 100644
--- a/lib/mosquitto.c
+++ b/lib/mosquitto.c
@@ -520,6 +520,10 @@ static int _mosquitto_reconnect(struct mosquitto *mosq, bool blocking)
 
 	_mosquitto_messages_reconnect_reset(mosq);
 
+	if(mosq->sock != INVALID_SOCKET){
+        _mosquitto_socket_close(mosq); //close socket
+    }
+
 #ifdef WITH_SOCKS
 	if(mosq->socks5_host){
 		rc = _mosquitto_socket_connect(mosq, mosq->socks5_host, mosq->socks5_port, mosq->bind_address, blocking);