@@ -48,9 +48,8 @@ use portable_atomic::AtomicBool;
48
48
use portable_atomic_util:: Arc ;
49
49
use zephyr_sys:: {
50
50
k_poll_signal, k_poll_signal_check, k_poll_signal_init, k_poll_signal_raise,
51
- k_poll_signal_reset, k_work, k_work_init, k_work_q, k_work_queue_config,
52
- k_work_queue_init, k_work_queue_start, k_work_submit, k_work_submit_to_queue,
53
- z_thread_stack_element,
51
+ k_poll_signal_reset, k_work, k_work_init, k_work_q, k_work_queue_config, k_work_queue_init,
52
+ k_work_queue_start, k_work_submit, k_work_submit_to_queue, z_thread_stack_element,
54
53
} ;
55
54
56
55
use crate :: {
@@ -421,7 +420,8 @@ impl<T: SimpleAction + Send> ArcWork<T> {
421
420
let work = unsafe { self . 0 . work . get ( ) } ;
422
421
let _ = Arc :: into_raw ( self . 0 ) ;
423
422
424
- let result = SubmitResult :: to_result ( unsafe { k_work_submit_to_queue ( queue. item . get ( ) , work) } ) ;
423
+ let result =
424
+ SubmitResult :: to_result ( unsafe { k_work_submit_to_queue ( queue. item . get ( ) , work) } ) ;
425
425
426
426
Self :: check_drop ( work, & result) ;
427
427
@@ -483,14 +483,15 @@ impl<T: SimpleAction + Send + 'static> StaticWork<T> {
483
483
484
484
/// Submit this work to the a specific work queue.
485
485
pub fn submit_to_queue ( self , queue : & ' static WorkQueue ) -> crate :: Result < SubmitResult > {
486
- SubmitResult :: to_result ( unsafe { k_work_submit_to_queue ( queue. item . get ( ) , self . 0 . work . get ( ) ) } )
486
+ SubmitResult :: to_result ( unsafe {
487
+ k_work_submit_to_queue ( queue. item . get ( ) , self . 0 . work . get ( ) )
488
+ } )
487
489
}
488
490
489
491
/// The handler for static work.
490
492
extern "C" fn handler ( work : * mut k_work ) {
491
493
let ptr = unsafe {
492
- work
493
- . cast :: < u8 > ( )
494
+ work. cast :: < u8 > ( )
494
495
. sub ( mem:: offset_of!( Work <T >, work) )
495
496
. cast :: < Work < T > > ( )
496
497
} ;
@@ -529,7 +530,7 @@ impl<T: SimpleAction + Send + 'static> Work<T> {
529
530
pub const fn new_static ( action : T ) -> Work < T > {
530
531
let work = <ZephyrObject < k_work > >:: new_raw ( ) ;
531
532
532
- unsafe {
533
+ unsafe {
533
534
let addr = work. get_uninit ( ) ;
534
535
( * addr) . handler = Some ( StaticWork :: < T > :: handler) ;
535
536
}
0 commit comments