test: check if sid_process is blocking the queue

check if calling sid_process in a loop will solve the issue Signed-off-by: Robert Gałat <[email protected]>
nrfconnect · Feb 10, 2025 · fe25948 · fe25948
1 parent 1b0630d
commit fe25948
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 7 deletions.
diff --git a/samples/sid_end_device/src/sidewalk.c b/samples/sid_end_device/src/sidewalk.c
@@ -3,6 +3,8 @@
  *
  * SPDX-License-Identifier: LicenseRef-Nordic-5-Clause
  */
+#include <sid_api.h>
+#include <sid_error.h>
 #include <sidewalk.h>
 
 #include <zephyr/kernel.h>
@@ -30,7 +32,8 @@ static void sid_thread_entry(void *context, void *unused, void *unused2)
 	while (1) {
 		int err = k_msgq_get(&sidewalk_thread_msgq, &event, K_FOREVER);
 #if CONFIG_SIDEWALK_TRACE_SIDEWALK_QUEUE
-		LOG_INF("sidewalk workq usage (%d/%d)", k_msgq_num_used_get(&sidewalk_thread_msgq),
+		LOG_INF("sidewalk workq usage (%d/%d) ( after get )",
+			k_msgq_num_used_get(&sidewalk_thread_msgq),
 			CONFIG_SIDEWALK_THREAD_QUEUE_SIZE);
 #endif
 		if (!err) {
@@ -43,6 +46,8 @@ static void sid_thread_entry(void *context, void *unused, void *unused2)
 		} else {
 			LOG_ERR("Sidewalk msgq err %d", err);
 		}
+		sid_error_t _ignore = sid_process(sid->handle);
+		ARG_UNUSED(_ignore);
 	}
 
 	LOG_ERR("Sidewalk thread ends. You should never see this message.");
@@ -76,8 +81,8 @@ int sidewalk_event_send(event_handler_t event, void *ctx, ctx_free free)
 #endif /* CONFIG_SIDEWALK_THREAD_QUEUE_TIMEOUT_VALUE > 0 */
 	result = k_msgq_put(&sidewalk_thread_msgq, (void *)&ctx_event, timeout);
 #if CONFIG_SIDEWALK_TRACE_SIDEWALK_QUEUE
-	LOG_INF("sidewalk workq usage (%d/%d)", k_msgq_num_used_get(&sidewalk_thread_msgq),
-		CONFIG_SIDEWALK_THREAD_QUEUE_SIZE);
+	LOG_INF("sidewalk workq usage (%d/%d) (after put)",
+		k_msgq_num_used_get(&sidewalk_thread_msgq), CONFIG_SIDEWALK_THREAD_QUEUE_SIZE);
 #endif
 	LOG_DBG("sidewalk_event_send event = %p, context = %p, k_msgq_put result %d", (void *)event,
 		ctx, result);

diff --git a/samples/sid_end_device/src/sidewalk_events.c b/samples/sid_end_device/src/sidewalk_events.c
@@ -52,10 +52,11 @@ void sidewalk_event_process(sidewalk_ctx_t *sid, void *ctx)
 		LOG_INF("sidewalk need to be started first.");
 		return;
 	}
-	sid_error_t e = sid_process(sid->handle);
-	if (e) {
-		LOG_ERR("sid process err  %d (%s)", (int)e, SID_ERROR_T_STR(e));
-	}
+	// TODO: sid_process is called in a loop in sidewalk thread for testing
+	// sid_error_t e = sid_process(sid->handle);
+	// if (e) {
+	// 	LOG_ERR("sid process err  %d (%s)", (int)e, SID_ERROR_T_STR(e));
+	// }
 }
 
 void sidewalk_event_platform_init(sidewalk_ctx_t *sid, void *ctx)