@@ -310,9 +310,10 @@ static void sensor_and_poll_triggers_send(void)
310
310
/* Delayable work used to send messages on the TIMER_CHAN */
311
311
static void timer_work_fn (struct k_work * work )
312
312
{
313
- ARG_UNUSED (work );
313
+ int err ;
314
+ int dummy = 0 ;
314
315
315
- int err , dummy = 0 ;
316
+ ARG_UNUSED ( work ) ;
316
317
317
318
err = zbus_chan_pub (& TIMER_CHAN , & dummy , K_SECONDS (1 ));
318
319
if (err ) {
@@ -363,6 +364,7 @@ static void idle_entry(void *o)
363
364
LOG_DBG ("%s" , __func__ );
364
365
365
366
#if defined(CONFIG_APP_LED )
367
+ int err ;
366
368
/* Blink Yellow */
367
369
struct led_msg led_msg = {
368
370
.type = LED_RGB_SET ,
@@ -374,16 +376,15 @@ static void idle_entry(void *o)
374
376
.repetitions = 10 ,
375
377
};
376
378
377
- int err = zbus_chan_pub (& LED_CHAN , & led_msg , K_SECONDS (1 ));
378
-
379
+ err = zbus_chan_pub (& LED_CHAN , & led_msg , K_SECONDS (1 ));
379
380
if (err ) {
380
381
LOG_ERR ("zbus_chan_pub, error: %d" , err );
381
382
SEND_FATAL_ERROR ();
382
383
return ;
383
384
}
384
385
#endif /* CONFIG_APP_LED */
385
386
386
- k_work_cancel_delayable (& trigger_work );
387
+ ( void ) k_work_cancel_delayable (& trigger_work );
387
388
}
388
389
389
390
static void idle_run (void * o )
@@ -405,6 +406,8 @@ static void idle_run(void *o)
405
406
406
407
static void triggering_entry (void * o )
407
408
{
409
+ int err ;
410
+
408
411
ARG_UNUSED (o );
409
412
410
413
LOG_DBG ("%s" , __func__ );
@@ -421,16 +424,20 @@ static void triggering_entry(void *o)
421
424
.repetitions = 10 ,
422
425
};
423
426
424
- int err = zbus_chan_pub (& LED_CHAN , & led_msg , K_SECONDS (1 ));
425
-
427
+ err = zbus_chan_pub (& LED_CHAN , & led_msg , K_SECONDS (1 ));
426
428
if (err ) {
427
429
LOG_ERR ("zbus_chan_pub, error: %d" , err );
428
430
SEND_FATAL_ERROR ();
429
431
return ;
430
432
}
431
433
#endif /* CONFIG_APP_LED */
432
434
433
- k_work_reschedule (& trigger_work , K_NO_WAIT );
435
+ err = k_work_reschedule (& trigger_work , K_NO_WAIT );
436
+ if (err < 0 ) {
437
+ LOG_ERR ("k_work_reschedule, error: %d" , err );
438
+ SEND_FATAL_ERROR ();
439
+ return ;
440
+ }
434
441
}
435
442
436
443
static void triggering_run (void * o )
@@ -452,11 +459,19 @@ static void triggering_run(void *o)
452
459
struct configuration config = MSG_TO_CONFIGURATION (state_object -> msg_buf );
453
460
454
461
if (config .config_present ) {
462
+ int err ;
463
+
455
464
LOG_DBG ("Configuration update, new interval: %lld" , config .update_interval );
456
465
457
466
state_object -> interval_sec = config .update_interval ;
458
467
459
- k_work_reschedule (& trigger_work , K_SECONDS (state_object -> interval_sec ));
468
+ err = k_work_reschedule (& trigger_work ,
469
+ K_SECONDS (state_object -> interval_sec ));
470
+ if (err < 0 ) {
471
+ LOG_ERR ("k_work_reschedule, error: %d" , err );
472
+ SEND_FATAL_ERROR ();
473
+ }
474
+
460
475
return ;
461
476
}
462
477
}
@@ -466,13 +481,13 @@ static void triggering_run(void *o)
466
481
467
482
static void requesting_location_entry (void * o )
468
483
{
484
+ int err ;
485
+ enum location_msg_type location_msg = LOCATION_SEARCH_TRIGGER ;
486
+
469
487
ARG_UNUSED (o );
470
488
471
489
LOG_DBG ("%s" , __func__ );
472
490
473
- int err ;
474
- enum location_msg_type location_msg = LOCATION_SEARCH_TRIGGER ;
475
-
476
491
err = zbus_chan_pub (& LOCATION_CHAN , & location_msg , K_SECONDS (1 ));
477
492
if (err ) {
478
493
LOG_ERR ("zbus_chan_pub data sample trigger, error: %d" , err );
@@ -505,6 +520,7 @@ static void requesting_location_run(void *o)
505
520
506
521
static void requesting_sensors_and_polling_entry (void * o )
507
522
{
523
+ int err ;
508
524
const struct main_state * state_object = (const struct main_state * )o ;
509
525
510
526
LOG_DBG ("%s" , __func__ );
@@ -513,7 +529,11 @@ static void requesting_sensors_and_polling_entry(void *o)
513
529
514
530
LOG_DBG ("Next trigger in %lld seconds" , state_object -> interval_sec );
515
531
516
- k_work_reschedule (& trigger_work , K_SECONDS (state_object -> interval_sec ));
532
+ err = k_work_reschedule (& trigger_work , K_SECONDS (state_object -> interval_sec ));
533
+ if (err < 0 ) {
534
+ LOG_ERR ("k_work_reschedule, error: %d" , err );
535
+ SEND_FATAL_ERROR ();
536
+ }
517
537
}
518
538
519
539
static void requesting_sensors_and_polling_run (void * o )
@@ -537,7 +557,7 @@ static void requesting_sensors_and_polling_exit(void *o)
537
557
538
558
LOG_DBG ("%s" , __func__ );
539
559
540
- k_work_cancel_delayable (& trigger_work );
560
+ ( void ) k_work_cancel_delayable (& trigger_work );
541
561
}
542
562
543
563
/* STATE_FOTA */
@@ -548,7 +568,7 @@ static void fota_entry(void *o)
548
568
549
569
LOG_DBG ("%s" , __func__ );
550
570
551
- k_work_cancel_delayable (& trigger_work );
571
+ ( void ) k_work_cancel_delayable (& trigger_work );
552
572
}
553
573
554
574
static void fota_run (void * o )
@@ -602,15 +622,15 @@ static void fota_downloading_run(void *o)
602
622
603
623
static void fota_waiting_for_network_disconnect_entry (void * o )
604
624
{
605
- ARG_UNUSED (o );
606
-
607
- LOG_DBG ("%s" , __func__ );
608
-
609
625
int err ;
610
626
struct network_msg msg = {
611
627
.type = NETWORK_DISCONNECT
612
628
};
613
629
630
+ ARG_UNUSED (o );
631
+
632
+ LOG_DBG ("%s" , __func__ );
633
+
614
634
err = zbus_chan_pub (& NETWORK_CHAN , & msg , K_SECONDS (1 ));
615
635
if (err ) {
616
636
LOG_ERR ("zbus_chan_pub, error: %d" , err );
0 commit comments