Fix unreachable test code

Author: ralight

test/lib/c/03-publish-b2c-qos1.c

@@ -71,7 +71,9 @@ int main(int argc, char *argv[])
 	if(rc != MOSQ_ERR_SUCCESS) return rc;
 
 	while(1){
-		mosquitto_loop(mosq, 300, 1);
+		if(mosquitto_loop(mosq, 300, 1)){
+			break;
+		}
 	}
 	mosquitto_destroy(mosq);
 

test/lib/cpp/03-publish-b2c-qos1-unexpected-puback.cpp

@@ -26,6 +26,7 @@ void mosquittopp_test::on_connect(int rc)
 int main(int argc, char *argv[])
 {
 	mosquittopp_test *mosq;
+	int rc = 1;
 
 	if(argc != 2){
 		return 1;
@@ -39,14 +40,14 @@ int main(int argc, char *argv[])
 	mosq->connect("localhost", port, 5);
 
 	while(1){
-		int rc = mosq->loop(300, 1);
-		if(rc){
-			exit(0);
+		if(mosq->loop(300, 1)){
+			rc = 0;
+			break;
 		}
 	}
 	delete mosq;
 	mosqpp::lib_cleanup();
 
-	return 1;
+	return rc;
 }
 

test/lib/cpp/03-publish-b2c-qos1.cpp

@@ -57,6 +57,7 @@ void mosquittopp_test::on_message(const struct mosquitto_message *msg)
 int main(int argc, char *argv[])
 {
 	mosquittopp_test *mosq;
+	int rc = 1;
 
 	if(argc != 2){
 		return 1;
@@ -70,13 +71,15 @@ int main(int argc, char *argv[])
 	mosq->connect("localhost", port, 60);
 
 	while(1){
-		mosq->loop();
+		if(mosq->loop()){
+			rc = 0;
+			break;
+		}
 	}
-	delete mosq;
 
 	delete mosq;
 	mosqpp::lib_cleanup();
 
-	return 1;
+	return rc;
 }