leyoda/cosmic-applets
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

chore(audio): more log statements in the UpdateConnection handler

Browse source
This commit is contained in:
Ashley Wulber 2023-03-08 21:26:58 -05:00 • committed by Ashley Wulber
parent 0fee545797
commit 58694c8735
1 changed files with 17 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

24
cosmic-applet-audio/src/pulse.rs
View file

@ -235,20 +235,30 @@ impl PulseHandle {
server.set_source_volume_by_name(&name, &channel_volumes) server.set_source_volume_by_name(&name, &channel_volumes)
} }
Message::UpdateConnection => { Message::UpdateConnection => {
log::trace!("Updating Connection {:?}", server.is_some()); log::info!(
"Updating Connection, server exists: {:?}",
server.is_some()
);
if let Some(mut cur_server) = server.take() { if let Some(mut cur_server) = server.take() {
log::trace!("getting server info..."); log::trace!("getting server info...");
if let Err(_) = cur_server.get_server_info() { if let Err(_) = cur_server.get_server_info() {
log::warn!("got error, server must be disconnected...");
PulseHandle::send_disconnected(&mut from_pulse_send).await; PulseHandle::send_disconnected(&mut from_pulse_send).await;
} else { } else {
log::trace!("got server info, still connected...");
server = Some(cur_server); server = Some(cur_server);
} }
} else if let Ok(new_server) = } else {
PulseServer::connect().and_then(|server| server.init()) match PulseServer::connect().and_then(|server| server.init()) {
{ Ok(new_server) => {
log::trace!("got new server..."); log::info!("Connected to server");
PulseHandle::send_connected(&mut from_pulse_send).await; PulseHandle::send_connected(&mut from_pulse_send).await;
server = Some(new_server); server = Some(new_server);
}
Err(err) => {
log::error!("Failed to connect to server: {:?}", err);
}
}
} }
} }
Message::SetDefaultSink(device) => { Message::SetDefaultSink(device) => {