@ -636,9 +636,7 @@ handle_connect_error:
#ifdef WITH_TLS
if(client_cert) X509_free(client_cert);
#endif
if(context){
mqtt3_context_disconnect(db, context);
}
/* We return an error here which means the client is freed later on. */
return rc;
@ -69,6 +69,7 @@ try:
rc = 0
sock.close()
finally:
time.sleep(1)
broker.terminate()
broker.wait()
if rc:
@ -38,6 +38,7 @@ try:
ssock.close()
time.sleep(2)
@ -62,8 +62,10 @@ try:
bridge.terminate()
bridge.wait()
@ -4,6 +4,7 @@
all :
clean :
-rm -f *.vglog
$(MAKE) -C c clean
test-compile :
@ -25,6 +25,7 @@ def start_broker(filename, cmd=None, port=1888):
if c is not None:
c.close()
time.sleep(delay)
return broker
raise IOError