hongshaorou/rustdesk
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

opt: send audio frame when connected

Browse Source
This commit is contained in:
Kingtous 2023-01-29 22:23:18 +08:00
parent 45a6fc3618
commit e7e8e1a18b
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/client/io_loop.rs
View File

@ -90,7 +90,6 @@ impl<T: InvokeUiSession> Remote<T> {
pub async fn io_loop(&mut self, key: &str, token: &str) { pub async fn io_loop(&mut self, key: &str, token: &str) {
let stop_clipboard = self.start_clipboard(); let stop_clipboard = self.start_clipboard();
let stop_client_audio = self.start_client_audio();
let mut last_recv_time = Instant::now(); let mut last_recv_time = Instant::now();
let mut received = false; let mut received = false;
let conn_type = if self.handler.is_file_transfer() { let conn_type = if self.handler.is_file_transfer() {
@ -114,6 +113,8 @@ impl<T: InvokeUiSession> Remote<T> {
SERVER_FILE_TRANSFER_ENABLED.store(true, Ordering::SeqCst); SERVER_FILE_TRANSFER_ENABLED.store(true, Ordering::SeqCst);
self.handler.set_connection_type(peer.is_secured(), direct); // flutter -> connection_ready self.handler.set_connection_type(peer.is_secured(), direct); // flutter -> connection_ready
self.handler.set_connection_info(direct, false); self.handler.set_connection_info(direct, false);
// Start client audio when connection is established.
let stop_client_audio = self.start_client_audio();
// just build for now // just build for now
#[cfg(not(windows))] #[cfg(not(windows))]
@ -218,6 +219,10 @@ impl<T: InvokeUiSession> Remote<T> {
} }
} }
log::debug!("Exit io_loop of id={}", self.handler.id); log::debug!("Exit io_loop of id={}", self.handler.id);
// Stop client audio server.
if let Some(stop) = stop_client_audio {
stop.send(()).ok();
}
} }
Err(err) => { Err(err) => {
self.handler self.handler
@ -227,9 +232,6 @@ impl<T: InvokeUiSession> Remote<T> {
if let Some(stop) = stop_clipboard { if let Some(stop) = stop_clipboard {
stop.send(()).ok(); stop.send(()).ok();
} }
if let Some(stop) = stop_client_audio {
stop.send(()).ok();
}
SERVER_KEYBOARD_ENABLED.store(false, Ordering::SeqCst); SERVER_KEYBOARD_ENABLED.store(false, Ordering::SeqCst);
SERVER_CLIPBOARD_ENABLED.store(false, Ordering::SeqCst); SERVER_CLIPBOARD_ENABLED.store(false, Ordering::SeqCst);
SERVER_FILE_TRANSFER_ENABLED.store(false, Ordering::SeqCst); SERVER_FILE_TRANSFER_ENABLED.store(false, Ordering::SeqCst);