Refactor of locking to better detect and handle edge cases. Allow par…

…tial writes on all packet types.
wolfSSL · Nov 4, 2023 · 76cb326 · 76cb326
1 parent 5dbd4ee
commit 76cb326
Show file tree

Hide file tree

Showing 4 changed files with 326 additions and 206 deletions.
diff --git a/examples/multithread/multithread.c b/examples/multithread/multithread.c
@@ -619,11 +619,11 @@ static void *publish_task(void *param)
         MqttClient_CancelMessage(&mqttCtx->client, (MqttObject*)&publish);
     }
 
-    wm_SemLock(&mtLock);
     PRINTF("MQTT Publish: Topic %s, %s (%d)",
         publish.topic_name,
         MqttClient_ReturnCodeToString(rc), rc);
 
+    wm_SemLock(&mtLock);
     mNumMsgsDone++;
     wm_SemUnlock(&mtLock);