File tree Expand file tree Collapse file tree 3 files changed +8
-18
lines changed
Expand file tree Collapse file tree 3 files changed +8
-18
lines changed Original file line number Diff line number Diff line change @@ -19,21 +19,18 @@ macro_rules! block_on {
1919macro_rules! try_coerce_shred {
2020 ( $response: expr) => { {
2121 let shred = if let Some ( response) = $response. clone( ) {
22- let shred = match ( response. shred_data, response. shred_code) {
23- ( Some ( data_shred) , None ) => {
24- Some ( Shred :: ShredData ( data_shred) )
25- // Some(data_shred. ().expect("num data shreds error"))
26- }
22+ match ( response. shred_data, response. shred_code) {
23+ ( Some ( data_shred) , None ) => Some ( Shred :: ShredData ( data_shred) ) ,
2724 ( None , Some ( coding_shred) ) => Some ( Shred :: ShredCode ( coding_shred) ) ,
2825 _ => None ,
29- } ;
30- shred
26+ }
3127 } else {
3228 None
3329 } ;
3430 shred
3531 } } ;
3632}
33+
3734#[ macro_export]
3835macro_rules! send_rpc_call {
3936 ( $url: expr, $body: expr) => { {
Original file line number Diff line number Diff line change @@ -112,10 +112,9 @@ impl ClientService<SampleServiceConfig> for SampleService {
112112 }
113113 } ) ;
114114
115- let sample_indices: Vec < u64 > = Vec :: default ( ) ;
116115 Self {
117116 sampler_handle,
118- sample_indices,
117+ sample_indices : Vec :: default ( ) ,
119118 }
120119 }
121120
@@ -330,7 +329,7 @@ async fn shred_update_loop(
330329 {
331330 let mut status = status_sampler. lock ( ) . unwrap ( ) ;
332331 if let ClientStatus :: Crashed ( _) = & * status {
333- return Err ( anyhow ! ( "" ) ) ;
332+ return Err ( anyhow ! ( "Client crashed " ) ) ;
334333 } else {
335334 * status = ClientStatus :: Active ( String :: from (
336335 "Monitoring Tinydancer: Actively Sampling Shreds" ,
Original file line number Diff line number Diff line change @@ -103,21 +103,15 @@ impl TinyDancer {
103103 db_instance : db. clone ( ) ,
104104 } ) ;
105105
106- let ui_service = if enable_ui_service {
107- Some ( UiService :: new ( UiConfig {
108- client_status,
109- enable_ui_service,
110- tui_monitor,
111- } ) )
112- } else if tui_monitor {
106+ let ui_service = if enable_ui_service || tui_monitor {
113107 Some ( UiService :: new ( UiConfig {
114108 client_status,
115109 enable_ui_service,
116110 tui_monitor,
117111 } ) )
118112 } else {
119113 None
120- } ;
114+ } ;
121115
122116 // run
123117 sample_service
You can’t perform that action at this time.
0 commit comments