@@ -305,9 +305,10 @@ static void sensor_and_poll_triggers_send(void)
305
305
/* Delayable work used to send messages on the TIMER_CHAN */
306
306
static void timer_work_fn (struct k_work * work )
307
307
{
308
- ARG_UNUSED (work );
308
+ int err ;
309
+ int dummy = 0 ;
309
310
310
- int err , dummy = 0 ;
311
+ ARG_UNUSED ( work ) ;
311
312
312
313
err = zbus_chan_pub (& TIMER_CHAN , & dummy , K_SECONDS (1 ));
313
314
if (err ) {
@@ -357,6 +358,7 @@ static void idle_entry(void *o)
357
358
LOG_DBG ("%s" , __func__ );
358
359
359
360
#if defined(CONFIG_APP_LED )
361
+ int err ;
360
362
/* Blink Yellow */
361
363
struct led_msg led_msg = {
362
364
.type = LED_RGB_SET ,
@@ -368,16 +370,15 @@ static void idle_entry(void *o)
368
370
.repetitions = 10 ,
369
371
};
370
372
371
- int err = zbus_chan_pub (& LED_CHAN , & led_msg , K_SECONDS (1 ));
372
-
373
+ err = zbus_chan_pub (& LED_CHAN , & led_msg , K_SECONDS (1 ));
373
374
if (err ) {
374
375
LOG_ERR ("zbus_chan_pub, error: %d" , err );
375
376
SEND_FATAL_ERROR ();
376
377
return ;
377
378
}
378
379
#endif /* CONFIG_APP_LED */
379
380
380
- k_work_cancel_delayable (& trigger_work );
381
+ ( void ) k_work_cancel_delayable (& trigger_work );
381
382
}
382
383
383
384
static void idle_run (void * o )
@@ -395,6 +396,8 @@ static void idle_run(void *o)
395
396
396
397
static void triggering_entry (void * o )
397
398
{
399
+ int err ;
400
+
398
401
ARG_UNUSED (o );
399
402
400
403
LOG_DBG ("%s" , __func__ );
@@ -411,16 +414,20 @@ static void triggering_entry(void *o)
411
414
.repetitions = 10 ,
412
415
};
413
416
414
- int err = zbus_chan_pub (& LED_CHAN , & led_msg , K_SECONDS (1 ));
415
-
417
+ err = zbus_chan_pub (& LED_CHAN , & led_msg , K_SECONDS (1 ));
416
418
if (err ) {
417
419
LOG_ERR ("zbus_chan_pub, error: %d" , err );
418
420
SEND_FATAL_ERROR ();
419
421
return ;
420
422
}
421
423
#endif /* CONFIG_APP_LED */
422
424
423
- k_work_reschedule (& trigger_work , K_NO_WAIT );
425
+ err = k_work_reschedule (& trigger_work , K_NO_WAIT );
426
+ if (err ) {
427
+ LOG_ERR ("k_work_reschedule, error: %d" , err );
428
+ SEND_FATAL_ERROR ();
429
+ return ;
430
+ }
424
431
}
425
432
426
433
static void triggering_run (void * o )
@@ -435,8 +442,16 @@ static void triggering_run(void *o)
435
442
}
436
443
437
444
if (state_object -> chan == & CONFIG_CHAN ) {
445
+ int err ;
446
+
438
447
LOG_DBG ("Configuration update, new interval: %lld" , state_object -> interval_sec );
439
- k_work_reschedule (& trigger_work , K_SECONDS (state_object -> interval_sec ));
448
+
449
+ err = k_work_reschedule (& trigger_work , K_SECONDS (state_object -> interval_sec ));
450
+ if (err ) {
451
+ LOG_ERR ("k_work_reschedule, error: %d" , err );
452
+ SEND_FATAL_ERROR ();
453
+ }
454
+
440
455
return ;
441
456
}
442
457
}
@@ -445,13 +460,13 @@ static void triggering_run(void *o)
445
460
446
461
static void requesting_location_entry (void * o )
447
462
{
463
+ int err ;
464
+ enum location_msg_type location_msg = LOCATION_SEARCH_TRIGGER ;
465
+
448
466
ARG_UNUSED (o );
449
467
450
468
LOG_DBG ("%s" , __func__ );
451
469
452
- int err ;
453
- enum location_msg_type location_msg = LOCATION_SEARCH_TRIGGER ;
454
-
455
470
err = zbus_chan_pub (& LOCATION_CHAN , & location_msg , K_SECONDS (1 ));
456
471
if (err ) {
457
472
LOG_ERR ("zbus_chan_pub data sample trigger, error: %d" , err );
@@ -480,6 +495,7 @@ static void requesting_location_run(void *o)
480
495
481
496
static void requesting_sensors_and_polling_entry (void * o )
482
497
{
498
+ int err ;
483
499
const struct main_state * state_object = (const struct main_state * )o ;
484
500
485
501
LOG_DBG ("%s" , __func__ );
@@ -488,7 +504,11 @@ static void requesting_sensors_and_polling_entry(void *o)
488
504
489
505
LOG_DBG ("Next trigger in %lld seconds" , state_object -> interval_sec );
490
506
491
- k_work_reschedule (& trigger_work , K_SECONDS (state_object -> interval_sec ));
507
+ err = k_work_reschedule (& trigger_work , K_SECONDS (state_object -> interval_sec ));
508
+ if (err ) {
509
+ LOG_ERR ("k_work_reschedule, error: %d" , err );
510
+ SEND_FATAL_ERROR ();
511
+ }
492
512
}
493
513
494
514
static void requesting_sensors_and_polling_run (void * o )
@@ -512,7 +532,7 @@ static void requesting_sensors_and_polling_exit(void *o)
512
532
513
533
LOG_DBG ("%s" , __func__ );
514
534
515
- k_work_cancel_delayable (& trigger_work );
535
+ ( void ) k_work_cancel_delayable (& trigger_work );
516
536
}
517
537
518
538
/* STATE_FOTA */
@@ -523,7 +543,7 @@ static void fota_entry(void *o)
523
543
524
544
LOG_DBG ("%s" , __func__ );
525
545
526
- k_work_cancel_delayable (& trigger_work );
546
+ ( void ) k_work_cancel_delayable (& trigger_work );
527
547
}
528
548
529
549
static void fota_run (void * o )
@@ -572,15 +592,15 @@ static void fota_downloading_run(void *o)
572
592
573
593
static void fota_network_disconnect_entry (void * o )
574
594
{
575
- ARG_UNUSED (o );
576
-
577
- LOG_DBG ("%s" , __func__ );
578
-
579
595
int err ;
580
596
struct network_msg msg = {
581
597
.type = NETWORK_DISCONNECT
582
598
};
583
599
600
+ ARG_UNUSED (o );
601
+
602
+ LOG_DBG ("%s" , __func__ );
603
+
584
604
err = zbus_chan_pub (& NETWORK_CHAN , & msg , K_SECONDS (1 ));
585
605
if (err ) {
586
606
LOG_ERR ("zbus_chan_pub, error: %d" , err );
0 commit comments