@@ -235,20 +235,30 @@ impl PulseHandle {
235
235
server. set_source_volume_by_name ( & name, & channel_volumes)
236
236
}
237
237
Message :: UpdateConnection => {
238
- log:: trace!( "Updating Connection {:?}" , server. is_some( ) ) ;
238
+ log:: info!(
239
+ "Updating Connection, server exists: {:?}" ,
240
+ server. is_some( )
241
+ ) ;
239
242
if let Some ( mut cur_server) = server. take ( ) {
240
243
log:: trace!( "getting server info..." ) ;
241
244
if let Err ( _) = cur_server. get_server_info ( ) {
245
+ log:: warn!( "got error, server must be disconnected..." ) ;
242
246
PulseHandle :: send_disconnected ( & mut from_pulse_send) . await ;
243
247
} else {
248
+ log:: trace!( "got server info, still connected..." ) ;
244
249
server = Some ( cur_server) ;
245
250
}
246
- } else if let Ok ( new_server) =
247
- PulseServer :: connect ( ) . and_then ( |server| server. init ( ) )
248
- {
249
- log:: trace!( "got new server..." ) ;
250
- PulseHandle :: send_connected ( & mut from_pulse_send) . await ;
251
- server = Some ( new_server) ;
251
+ } else {
252
+ match PulseServer :: connect ( ) . and_then ( |server| server. init ( ) ) {
253
+ Ok ( new_server) => {
254
+ log:: info!( "Connected to server" ) ;
255
+ PulseHandle :: send_connected ( & mut from_pulse_send) . await ;
256
+ server = Some ( new_server) ;
257
+ }
258
+ Err ( err) => {
259
+ log:: error!( "Failed to connect to server: {:?}" , err) ;
260
+ }
261
+ }
252
262
}
253
263
}
254
264
Message :: SetDefaultSink ( device) => {
0 commit comments