File tree Expand file tree Collapse file tree 3 files changed +18
-15
lines changed Expand file tree Collapse file tree 3 files changed +18
-15
lines changed Original file line number Diff line number Diff line change @@ -107,9 +107,9 @@ pub fn spin(node: &Node) -> Result<(), RclrsError> {
107
107
108
108
pub fn spin_until_future_complete < T : Unpin + Clone > (
109
109
node : & node:: Node ,
110
- mut future : Arc < Mutex < Box < crate :: future:: RclFuture < T > > > > ,
111
- ) -> Result < <crate :: future:: RclFuture < T > as Future >:: Output , RclReturnCode > {
112
- let mut cx = crate :: future:: create_rcl_waker_context ( ) ;
110
+ mut future : Arc < Mutex < Box < future:: RclFuture < T > > > > ,
111
+ ) -> Result < <future:: RclFuture < T > as Future >:: Output , RclReturnCode > {
112
+ let mut cx = future:: create_rcl_waker_context ( ) ;
113
113
114
114
loop {
115
115
let context_valid = unsafe { rcl_context_is_valid ( & mut * node. context . lock ( ) ) } ;
Original file line number Diff line number Diff line change
1
+ use std:: borrow:: Borrow ;
2
+ use std:: boxed:: Box ;
1
3
use std:: collections:: HashMap ;
4
+ use std:: ffi:: CString ;
2
5
use std:: sync:: atomic:: { AtomicI64 , Ordering } ;
6
+ use std:: sync:: Arc ;
3
7
4
8
use crate :: error:: { ClientErrorCode , ToResult } ;
5
9
use crate :: future:: RclFuture ;
6
10
use crate :: MessageCow ;
11
+ use crate :: Node ;
7
12
use crate :: { rcl_bindings:: * , RclReturnCode } ;
8
- use crate :: { Node , NodeHandle } ;
9
- use alloc:: boxed:: Box ;
10
- use alloc:: sync:: Arc ;
11
- use core:: borrow:: Borrow ;
12
- use cstr_core:: CString ;
13
+
13
14
use parking_lot:: { Mutex , MutexGuard } ;
14
15
use rosidl_runtime_rs:: Message ;
15
16
16
17
pub struct ClientHandle {
17
18
handle : Mutex < rcl_client_t > ,
18
- node_handle : Arc < NodeHandle > ,
19
+ node_handle : Arc < rcl_node_t > ,
19
20
}
20
21
21
22
impl ClientHandle {
Original file line number Diff line number Diff line change
1
+ use std:: borrow:: Borrow ;
2
+ use std:: boxed:: Box ;
3
+ use std:: ffi:: CString ;
4
+ use std:: sync:: Arc ;
5
+
1
6
use crate :: error:: { ServiceErrorCode , ToResult } ;
7
+ use crate :: Node ;
2
8
use crate :: { rcl_bindings:: * , RclReturnCode } ;
3
- use crate :: { Node , NodeHandle } ;
4
- use alloc:: boxed:: Box ;
5
- use alloc:: sync:: Arc ;
6
- use core:: borrow:: Borrow ;
7
- use cstr_core:: CString ;
9
+
8
10
use rosidl_runtime_rs:: Message ;
9
11
10
12
use crate :: node:: publisher:: MessageCow ;
@@ -13,7 +15,7 @@ use parking_lot::{Mutex, MutexGuard};
13
15
14
16
pub struct ServiceHandle {
15
17
handle : Mutex < rcl_service_t > ,
16
- node_handle : Arc < NodeHandle > ,
18
+ node_handle : Arc < rcl_node_t > ,
17
19
}
18
20
19
21
impl ServiceHandle {
You can’t perform that action at this time.
0 commit comments