@@ -141,10 +141,14 @@ impl Instance {
141
141
loop {
142
142
select ! {
143
143
_ = self . device. update( ) => {
144
+ trace!( "{}: device update" , self . id( ) ) ;
145
+
144
146
// Device update completed
145
147
// TODO: Handle device update errors
146
148
} ,
147
149
message = self . receiver. recv( ) => {
150
+ trace!( "{}: global msg: {:?}" , self . id( ) , message) ;
151
+
148
152
match message {
149
153
Ok ( message) => {
150
154
self . on_input_message( message) . await ;
@@ -159,13 +163,17 @@ impl Instance {
159
163
}
160
164
} ,
161
165
message = self . local_receiver. recv( ) => {
166
+ trace!( "{}: local msg: {:?}" , self . id( ) , message) ;
167
+
162
168
if let Some ( message) = message {
163
169
self . on_input_message( message) . await ;
164
170
} else {
165
171
break Ok ( ( ) ) ;
166
172
}
167
173
} ,
168
174
message = self . muxer. update( ) => {
175
+ trace!( "{}: muxer msg: {:?}" , self . id( ) , message) ;
176
+
169
177
// Muxer update completed
170
178
if let Some ( message) = message {
171
179
self . core. handle_message( message) ;
@@ -174,8 +182,12 @@ impl Instance {
174
182
led_data = self . core. update( ) => {
175
183
// LED data changed
176
184
self . device. set_led_data( led_data) . await ?;
185
+
186
+ trace!( "{}: core update" , self . id( ) ) ;
177
187
} ,
178
188
message = self . handle_rx. recv( ) => {
189
+ trace!( "{}: handle_rx msg: {:?}" , self . id( ) , message) ;
190
+
179
191
if let Some ( message) = message {
180
192
self . handle_instance_message( message) . await ;
181
193
} else {
0 commit comments