Stop processCommand high CPU use

Bug: 442400

Stop processCommand high CPU use
Bug: 442400
6c7112b2 · Ian Craggs · e3e40d17 · 6c7112b2
Commit 6c7112b2 authored Aug 26, 2014 by Ian Craggs
Hide whitespace changes
Inline Side-by-side

Showing with 5 additions and 0 deletions

MQTTAsync.c src/MQTTAsync.c +5 -0

No files found.
--- a/src/MQTTAsync.c
+++ b/src/MQTTAsync.c
@@ -1260,7 +1260,12 @@ thread_return_type WINAPI MQTTAsync_sendThread(void* n)
 		int rc;
 		
 		while (commands->count > 0)
+		{
+			int before = commands->count;
 			MQTTAsync_processCommand();
+			if (before == commands->count)
+				break;  /* no commands were processed, so go into a wait */
+		}
 #if !defined(WIN32) && !defined(WIN64)
 		rc =  Thread_wait_cond(send_cond, 1);
 		if ((rc = Thread_wait_cond(send_cond, 1)) != 0 && rc != ETIMEDOUT)