Function run_android_console_command

packages/server/src/android.rs:1984–2008

(port: u16, command: &str)

}

fn run_android_console_command(port: u16, command: &str) -> Result<(), AppError> {
    let mut cache = android_console_connection_cache().lock().unwrap();
    for attempt in 0..2 {
        if let std::collections::hash_map::Entry::Vacant(entry) = cache.entry(port) {
            entry.insert(connect_android_console(port)?);
        }
        let stream = cache
            .get_mut(&port)
            .ok_or_else(|| AppError::native("Android emulator console connection was missing."))?;
        match write_android_console_command(stream, command) {
            Ok(()) => return Ok(()),
            Err(error) if attempt == 0 => {
                cache.remove(&port);
                tracing::debug!("Android emulator console command retry on {port}: {error}");
            }
            Err(error) => {
                cache.remove(&port);
                return Err(error);
            }
        }
    }
    Err(AppError::native(
        "Android emulator console command failed unexpectedly.",
    ))
}

fn connect_android_console(port: u16) -> Result<TcpStream, AppError> {
    let address = SocketAddr::from(([127, 0, 0, 1], port));