Commit 9a1acee 1 parent 49fe340 commit 9a1acee Copy full SHA for 9a1acee
File tree 6 files changed +13
-14
lines changed
6 files changed +13
-14
lines changed Original file line number Diff line number Diff line change 99
99
{
100
100
let zinfo = _self. z . info ( ) . await ;
101
101
let pid = zinfo
102
- . get ( & zenoh:: net:: info:: ZN_INFO_PID_KEY ) ?
102
+ . get ( & zenoh:: net:: info:: ZN_INFO_PID_KEY )
103
+ . ok_or ( ZRPCError :: MissingValue ) ?
103
104
. to_uppercase ( ) ;
104
105
let rid = match zinfo. get ( & zenoh:: net:: info:: ZN_INFO_ROUTER_PID_KEY ) {
105
106
Some ( r_info) => {
Original file line number Diff line number Diff line change @@ -638,7 +638,7 @@ impl<'a> ZNServiceGenerator<'a> {
638
638
S : #service_ident + Send + ' static ,
639
639
{
640
640
let zinfo = _self. z. info( ) . await ;
641
- let pid = zinfo. get( & zenoh:: net:: info:: ZN_INFO_PID_KEY ) ?. to_uppercase( ) ;
641
+ let pid = zinfo. get( & zenoh:: net:: info:: ZN_INFO_PID_KEY ) . ok_or ( ZRPCError :: MissingValue ) ?. to_uppercase( ) ;
642
642
let rid = match zinfo. get( & zenoh:: net:: info:: ZN_INFO_ROUTER_PID_KEY ) {
643
643
Some ( r_info) => {
644
644
if r_info != "" {
Original file line number Diff line number Diff line change @@ -72,10 +72,12 @@ where
72
72
let zsession = _self. z . session ( ) ;
73
73
let zinfo = zsession. info ( ) . await ;
74
74
let pid = zinfo
75
- . get ( & zenoh:: net:: info:: ZN_INFO_PID_KEY ) ?
75
+ . get ( & zenoh:: net:: info:: ZN_INFO_PID_KEY )
76
+ . ok_or ( ZRPCError :: MissingValue ) ?
76
77
. to_uppercase ( ) ;
77
78
let rid = zinfo
78
- . get ( & zenoh:: net:: info:: ZN_INFO_ROUTER_PID_KEY ) ?
79
+ . get ( & zenoh:: net:: info:: ZN_INFO_ROUTER_PID_KEY )
80
+ . ok_or ( ZRPCError :: MissingValue ) ?
79
81
. split ( ',' )
80
82
. collect :: < Vec < _ > > ( ) [ 0 ]
81
83
. to_uppercase ( ) ;
@@ -563,7 +565,8 @@ impl HelloClient {
563
565
let zsession = z. session ( ) ;
564
566
let zinfo = zsession. info ( ) . await ;
565
567
let rid = zinfo
566
- . get ( & zenoh:: net:: info:: ZN_INFO_ROUTER_PID_KEY ) ?
568
+ . get ( & zenoh:: net:: info:: ZN_INFO_ROUTER_PID_KEY )
569
+ . ok_or ( ZRPCError :: MissingValue ) ?
567
570
. split ( ',' )
568
571
. collect :: < Vec < _ > > ( ) [ 0 ]
569
572
. to_uppercase ( ) ;
Original file line number Diff line number Diff line change @@ -515,8 +515,8 @@ impl<'a> ZServiceGenerator<'a> {
515
515
516
516
let zsession = _self. z. session( ) ;
517
517
let zinfo = zsession. info( ) . await ;
518
- let pid = zinfo. get( & zenoh:: net:: info:: ZN_INFO_PID_KEY ) ?. to_uppercase( ) ;
519
- let rid = zinfo. get( & zenoh:: net:: info:: ZN_INFO_ROUTER_PID_KEY ) ?. split( "," ) . collect:: <Vec <_>>( ) [ 0 ] . to_uppercase( ) ;
518
+ let pid = zinfo. get( & zenoh:: net:: info:: ZN_INFO_PID_KEY ) . ok_or ( ZRPCError :: MissingValue ) ?. to_uppercase( ) ;
519
+ let rid = zinfo. get( & zenoh:: net:: info:: ZN_INFO_ROUTER_PID_KEY ) . ok_or ( ZRPCError :: MissingValue ) ?. split( "," ) . collect:: <Vec <_>>( ) [ 0 ] . to_uppercase( ) ;
520
520
let ws = _self. z. workspace( None ) . await ?;
521
521
522
522
@@ -1159,7 +1159,7 @@ impl<'a> ZServiceGenerator<'a> {
1159
1159
let ws = z. workspace( None ) . await ?;
1160
1160
let zsession = z. session( ) ;
1161
1161
let zinfo = zsession. info( ) . await ;
1162
- let rid = zinfo. get( & zenoh:: net:: info:: ZN_INFO_ROUTER_PID_KEY ) ?. split( "," ) . collect:: <Vec <_>>( ) [ 0 ] . to_uppercase( ) ;
1162
+ let rid = zinfo. get( & zenoh:: net:: info:: ZN_INFO_ROUTER_PID_KEY ) . ok_or ( ZRPCError :: MissingValue ) ?. split( "," ) . collect:: <Vec <_>>( ) [ 0 ] . to_uppercase( ) ;
1163
1163
1164
1164
let selector = zenoh:: Selector :: try_from( format!( "{}/*/state" , #eval_path) ) ?;
1165
1165
let mut ds = ws. get( & selector) . await ?;
Original file line number Diff line number Diff line change 11
11
* ADLINK fog05 team, <fog05@adlink-labs.tech>
12
12
*********************************************************************************/
13
13
#![ feature( associated_type_bounds) ]
14
- #![ feature( try_trait) ]
15
14
#![ allow( clippy:: upper_case_acronyms) ]
16
15
17
16
pub mod zchannel;
Original file line number Diff line number Diff line change @@ -104,11 +104,7 @@ impl From<zenoh::ZError> for ZRPCError {
104
104
}
105
105
}
106
106
107
- impl From < std:: option:: NoneError > for ZRPCError {
108
- fn from ( _err : std:: option:: NoneError ) -> Self {
109
- ZRPCError :: MissingValue
110
- }
111
- }
107
+
112
108
impl From < std:: io:: Error > for ZRPCError {
113
109
fn from ( err : std:: io:: Error ) -> Self {
114
110
ZRPCError :: IOError ( err. to_string ( ) )
You can’t perform that action at this time.
0 commit comments