@@ -96,19 +96,18 @@ fn main_thread(
96
96
sync_tx. send( true ) . expect( "unable to send sync tx" ) ;
97
97
data. raw_traffic. push( packet. clone( ) ) ;
98
98
99
- if let Some ( text) = console_text( show_timestamps, show_sent_cmds, & packet) {
100
- // append prints
101
- if let Ok ( mut gui_data) = data_lock. write( ) {
102
- gui_data. prints. push( text) ;
103
- }
104
- }
99
+ let text = console_text( show_timestamps, show_sent_cmds, & packet) ;
105
100
106
101
let split_data = split( & packet. payload) ;
107
102
if data. dataset. is_empty( ) || failed_format_counter > 10 {
108
103
// resetting dataset
109
104
data. time = vec![ ] ;
110
105
data. dataset = vec![ vec![ ] ; max( split_data. len( ) , 1 ) ] ;
111
106
if let Ok ( mut gui_data) = data_lock. write( ) {
107
+ // append prints
108
+ if let Some ( text) = text {
109
+ gui_data. prints. push( text) ;
110
+ }
112
111
gui_data. plots = ( 0 ..max( split_data. len( ) , 1 ) )
113
112
. map( |i| ( format!( "Column {i}" ) , vec![ ] ) )
114
113
. collect( ) ;
@@ -127,6 +126,10 @@ fn main_thread(
127
126
128
127
// appending data for GUI thread
129
128
if let Ok ( mut gui_data) = data_lock. write( ) {
129
+ // append prints
130
+ if let Some ( text) = text {
131
+ gui_data. prints. push( text) ;
132
+ }
130
133
// append plot-points
131
134
for ( ( _label, graph) , data_i) in
132
135
gui_data. plots. iter_mut( ) . zip( & data. dataset)
@@ -257,7 +260,7 @@ fn main_thread(
257
260
}
258
261
}
259
262
}
260
- default ( Duration :: from_millis( 10 ) ) => {
263
+ default ( Duration :: from_millis( 1 ) ) => {
261
264
// occasionally push data to GUI
262
265
}
263
266
}
0 commit comments