michaelh/zephyr
1
0
Fork 0
Code Releases Activity

net: lwm2m: Check return value from lwm2m_rd_client_pause/resume

Browse source 
Check return values from lwm2m_rd_client_pause() and
lwm2m_rd_client_resume() when engine thread suspend is requested.

Signed-off-by: Juha Ylinen <juha.ylinen@nordicsemi.no>
This commit is contained in:
Juha Ylinen 2023-01-04 14:58:17 +02:00 • committed by Carles Cufí
commit eb914f45d1
1 changed files with 16 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

18
subsys/net/lib/lwm2m/lwm2m_engine.c
View file

@ -683,16 +683,30 @@ static void socket_loop(void)
int i, rc; int i, rc;
int64_t timestamp; int64_t timestamp;
int32_t timeout, next_retransmit; int32_t timeout, next_retransmit;
bool rd_client_paused;
while (1) { while (1) {
rd_client_paused = false;
/* Check is Thread Suspend Requested */ /* Check is Thread Suspend Requested */
if (suspend_engine_thread) { if (suspend_engine_thread) {
lwm2m_rd_client_pause(); rc = lwm2m_rd_client_pause();
if (rc == 0) {
rd_client_paused = true;
} else {
LOG_ERR("Could not pause RD client");
}
suspend_engine_thread = false; suspend_engine_thread = false;
active_engine_thread = false; active_engine_thread = false;
k_thread_suspend(engine_thread_id); k_thread_suspend(engine_thread_id);
active_engine_thread = true; active_engine_thread = true;
lwm2m_rd_client_resume();
if (rd_client_paused) {
rc = lwm2m_rd_client_resume();
if (rc < 0) {
LOG_ERR("Could not resume RD client");
}
}
} }
timestamp = k_uptime_get(); timestamp = k_uptime_get();