Compare commits

...

4 Commits

Author SHA1 Message Date
DuProcess 3d5bb126c5 Trace ticket reattach recovery
ci / test (push) Waiting to run
ci / fuzz-smoke (push) Waiting to run
ci / windows-client (push) Waiting to run
ci / package-release (linux-x86_64, ubuntu-latest) (push) Waiting to run
ci / package-release (macos-aarch64, macos-14) (push) Waiting to run
ci / package-release (macos-x86_64, macos-13) (push) Waiting to run
ci / package-release (windows-x86_64, windows-latest) (push) Waiting to run
ci / remote-bench (push) Waiting to run
2026-07-12 12:15:25 -04:00
DuProcess 37632a96b7 Filter trace reports to latest run
ci / test (push) Waiting to run
ci / fuzz-smoke (push) Waiting to run
ci / windows-client (push) Waiting to run
ci / package-release (linux-x86_64, ubuntu-latest) (push) Waiting to run
ci / package-release (macos-aarch64, macos-14) (push) Waiting to run
ci / package-release (macos-x86_64, macos-13) (push) Waiting to run
ci / package-release (windows-x86_64, windows-latest) (push) Waiting to run
ci / remote-bench (push) Waiting to run
2026-07-12 12:09:37 -04:00
DuProcess e69be4fdf0 Reconnect before input after local sleep
ci / test (push) Waiting to run
ci / fuzz-smoke (push) Waiting to run
ci / windows-client (push) Waiting to run
ci / package-release (linux-x86_64, ubuntu-latest) (push) Waiting to run
ci / package-release (macos-aarch64, macos-14) (push) Waiting to run
ci / package-release (macos-x86_64, macos-13) (push) Waiting to run
ci / package-release (windows-x86_64, windows-latest) (push) Waiting to run
ci / remote-bench (push) Waiting to run
2026-07-12 12:01:46 -04:00
DuProcess fdbd58b628 Fetch remote server trace reports
ci / test (push) Waiting to run
ci / fuzz-smoke (push) Waiting to run
ci / windows-client (push) Waiting to run
ci / package-release (linux-x86_64, ubuntu-latest) (push) Waiting to run
ci / package-release (macos-aarch64, macos-14) (push) Waiting to run
ci / package-release (macos-x86_64, macos-13) (push) Waiting to run
ci / package-release (windows-x86_64, windows-latest) (push) Waiting to run
ci / remote-bench (push) Waiting to run
2026-07-12 11:55:23 -04:00
5 changed files with 505 additions and 60 deletions
Generated
+1 -1
View File
@@ -436,7 +436,7 @@ dependencies = [
[[package]]
name = "dosh"
version = "1.0.0-rc33"
version = "1.0.0-rc37"
dependencies = [
"anyhow",
"base64",
+1 -1
View File
@@ -1,6 +1,6 @@
[package]
name = "dosh"
version = "1.0.0-rc33"
version = "1.0.0-rc37"
edition = "2024"
license = "MIT"
+6 -4
View File
@@ -85,12 +85,14 @@ dosh trace --client-log /tmp/dosh-client.log HOST
Summarize collected traces with:
```sh
dosh trace report --client-log /tmp/dosh-client.log
dosh trace report HOST --client-log /tmp/dosh-client.log
```
Set `DOSH_TRACE=/tmp/dosh-server.log` on `dosh-server` for matching server
events. Trace byte prefixes are enabled for `dosh trace`, so use it only for
short reproductions.
When `HOST` is given, Dosh fetches `/tmp/dosh-server.log` over SSH before
building the report. Set `DOSH_TRACE=/tmp/dosh-server.log` on `dosh-server` for
matching server events. Reports default to the latest traced client/server
process run; add `--all-runs` to include older appended log entries. Trace byte
prefixes are enabled for `dosh trace`, so use it only for short reproductions.
## VS Code
+453 -51
View File
@@ -71,7 +71,7 @@ const MAX_PENDING_USER_INPUT_BYTES: usize = 1024 * 1024;
const STARTUP_INPUT_HOLD: Duration = Duration::from_millis(750);
const POST_SUBMIT_ALL_INPUT_HOLD: Duration = Duration::from_millis(120);
const STALE_TERMINAL_INPUT_AFTER: Duration = Duration::from_secs(2);
const POST_RECONNECT_STALE_INPUT_GRACE: Duration = Duration::from_secs(2);
const POST_RECONNECT_STALE_INPUT_GRACE: Duration = Duration::from_secs(5);
const FOCUS_REPAINT_COOLDOWN: Duration = Duration::from_secs(1);
const ALT_SCREEN_IDLE_REPAINT_AFTER: Duration = Duration::from_secs(15);
const LOCAL_SLEEP_REPAINT_AFTER: Duration = Duration::from_secs(5);
@@ -246,6 +246,10 @@ enum StartupGateMode {
#[tokio::main(flavor = "current_thread")]
async fn main() -> Result<()> {
let mut args = Args::parse();
dosh::trace::event(
"client.start",
&[("version", dosh::build_info::VERSION.to_string())],
);
let config = load_client_config(None).unwrap_or_default();
if args.server.as_deref() == Some("cp") {
return run_cp_command(&config, &args);
@@ -792,9 +796,11 @@ struct TraceOptions {
#[derive(Debug, Clone, PartialEq, Eq)]
struct TraceReportOptions {
host: Option<String>,
client_log: Option<PathBuf>,
server_log: Option<PathBuf>,
server_log: Option<String>,
tail: usize,
latest_run: bool,
}
#[derive(Debug, Default, Clone, PartialEq, Eq)]
@@ -802,6 +808,8 @@ struct TraceReport {
path: PathBuf,
total_lines: usize,
parsed_lines: usize,
skipped_old_run_lines: usize,
latest_run_filtered: bool,
first_ts_ms: Option<u128>,
last_ts_ms: Option<u128>,
events: BTreeMap<String, usize>,
@@ -819,6 +827,10 @@ struct TraceReport {
sent_input_events: usize,
pty_write_events: usize,
reconnect_events: usize,
unknown_resume_events: usize,
ticket_attach_start_events: usize,
ticket_attach_ok_events: usize,
ticket_attach_reject_events: usize,
roam_events: usize,
recent_events: VecDeque<String>,
}
@@ -888,15 +900,17 @@ fn parse_trace_options(command: &[String]) -> Result<TraceOptions> {
}
fn parse_trace_report_options(command: &[String]) -> Result<TraceReportOptions> {
let mut host: Option<String> = None;
let mut client_log: Option<PathBuf> = None;
let mut server_log: Option<PathBuf> = Some(PathBuf::from("/tmp/dosh-server.log"));
let mut server_log: Option<String> = Some("/tmp/dosh-server.log".to_string());
let mut tail = 20usize;
let mut latest_run = true;
let mut index = 0usize;
while index < command.len() {
match command[index].as_str() {
"--client-log" => {
let path = command.get(index + 1).ok_or_else(|| {
anyhow!("usage: dosh trace report [--client-log PATH] [--server-log PATH|none] [--tail N]")
anyhow!("usage: dosh trace report [HOST] [--client-log PATH] [--server-log PATH|none] [--latest-run|--all-runs] [--tail N]")
})?;
client_log = Some(expand_tilde(path));
index += 2;
@@ -911,7 +925,7 @@ fn parse_trace_report_options(command: &[String]) -> Result<TraceReportOptions>
}
"--server-log" => {
let path = command.get(index + 1).ok_or_else(|| {
anyhow!("usage: dosh trace report [--client-log PATH] [--server-log PATH|none] [--tail N]")
anyhow!("usage: dosh trace report [HOST] [--client-log PATH] [--server-log PATH|none] [--latest-run|--all-runs] [--tail N]")
})?;
server_log = parse_optional_trace_path(path);
index += 2;
@@ -927,9 +941,17 @@ fn parse_trace_report_options(command: &[String]) -> Result<TraceReportOptions>
server_log = None;
index += 1;
}
"--latest-run" => {
latest_run = true;
index += 1;
}
"--all-runs" => {
latest_run = false;
index += 1;
}
"--tail" => {
let value = command.get(index + 1).ok_or_else(|| {
anyhow!("usage: dosh trace report [--client-log PATH] [--server-log PATH|none] [--tail N]")
anyhow!("usage: dosh trace report [HOST] [--client-log PATH] [--server-log PATH|none] [--latest-run|--all-runs] [--tail N]")
})?;
tail = parse_trace_tail(value)?;
index += 2;
@@ -941,25 +963,36 @@ fn parse_trace_report_options(command: &[String]) -> Result<TraceReportOptions>
tail = parse_trace_tail(value)?;
index += 1;
}
value => {
value if value.starts_with('-') => {
return Err(anyhow!(
"usage: dosh trace report [--client-log PATH] [--server-log PATH|none] [--tail N] (unknown option {value})"
"usage: dosh trace report [HOST] [--client-log PATH] [--server-log PATH|none] [--latest-run|--all-runs] [--tail N] (unknown option {value})"
));
}
value => {
if host.is_some() {
return Err(anyhow!(
"usage: dosh trace report [HOST] [--client-log PATH] [--server-log PATH|none] [--latest-run|--all-runs] [--tail N]"
));
}
host = Some(value.to_string());
index += 1;
}
}
}
Ok(TraceReportOptions {
host,
client_log,
server_log,
tail,
latest_run,
})
}
fn parse_optional_trace_path(value: &str) -> Option<PathBuf> {
fn parse_optional_trace_path(value: &str) -> Option<String> {
if matches!(value, "" | "none" | "off" | "0") {
None
} else {
Some(expand_tilde(value))
Some(value.to_string())
}
}
@@ -1006,7 +1039,8 @@ fn sanitize_trace_name(value: &str) -> String {
fn run_trace_command(args: &Args) -> Result<()> {
if args.command.first().is_some_and(|value| value == "report") {
return run_trace_report_command(&args.command[1..]);
let config = load_client_config(None).unwrap_or_default();
return run_trace_report_command(&config, args, &args.command[1..]);
}
let options = parse_trace_options(&args.command)?;
if let Some(parent) = options.client_log.parent() {
@@ -1042,7 +1076,11 @@ fn run_trace_command(args: &Args) -> Result<()> {
Ok(())
}
fn run_trace_report_command(command: &[String]) -> Result<()> {
fn run_trace_report_command(
config: &dosh::config::ClientConfig,
args: &Args,
command: &[String],
) -> Result<()> {
let options = parse_trace_report_options(command)?;
let client_log = match options.client_log {
Some(path) => Some(path),
@@ -1050,7 +1088,7 @@ fn run_trace_report_command(command: &[String]) -> Result<()> {
};
println!("Dosh trace report");
if let Some(path) = client_log {
match summarize_trace_file(&path, options.tail) {
match summarize_trace_file_for_report(&path, options.tail, options.latest_run) {
Ok(report) => print_trace_report("client", &report),
Err(err) => println!("[warn] client log {}: {err:#}", path.display()),
}
@@ -1061,7 +1099,21 @@ fn run_trace_report_command(command: &[String]) -> Result<()> {
);
}
if let Some(path) = options.server_log {
match summarize_trace_file(&path, options.tail) {
let server_log = if let Some(host) = options.host.as_deref() {
match fetch_trace_server_log(config, args, host, &path) {
Ok(path) => Some(path),
Err(err) => {
println!("[warn] server log {host}:{path}: {err:#}");
None
}
}
} else {
Some(expand_tilde(&path))
};
let Some(path) = server_log else {
return Ok(());
};
match summarize_trace_file_for_report(&path, options.tail, options.latest_run) {
Ok(report) => print_trace_report("server", &report),
Err(err)
if err
@@ -1076,6 +1128,66 @@ fn run_trace_report_command(command: &[String]) -> Result<()> {
Ok(())
}
fn fetch_trace_server_log(
config: &dosh::config::ClientConfig,
args: &Args,
requested: &str,
remote_log: &str,
) -> Result<PathBuf> {
let hosts = load_hosts_config(None).unwrap_or_default();
let host_config = hosts.hosts.get(requested).cloned().unwrap_or_default();
let server = status_ssh_target(requested, &host_config);
let ssh_port = args.ssh_port.or(host_config.ssh_port).or(config.ssh_port);
if is_local_status_target(&server) {
return Ok(expand_tilde(remote_log));
}
let local_path = fetched_trace_server_log_path(requested);
if let Some(parent) = local_path.parent() {
fs::create_dir_all(parent)
.with_context(|| format!("create trace log directory {}", parent.to_string_lossy()))?;
}
let mut command = Command::new("ssh");
if let Some(ssh_port) = ssh_port {
command.arg("-p").arg(ssh_port.to_string());
}
command.arg("-T");
if let Some(key) = args.ssh_key.as_deref() {
command.arg("-i").arg(key);
}
if let Some(known_hosts) = args.ssh_known_hosts.as_deref() {
command
.arg("-o")
.arg(format!("UserKnownHostsFile={}", known_hosts.display()));
}
let script = format!("test -r {0} && cat {0}", shell_word(remote_log));
let output = command
.arg(&server)
.arg(format!("sh -c {}", shell_word(&script)))
.output()
.with_context(|| format!("fetch server trace log from {server}"))?;
anyhow::ensure!(
output.status.success(),
"{}",
String::from_utf8_lossy(&output.stderr)
);
fs::write(&local_path, &output.stdout)
.with_context(|| format!("write fetched server trace {}", local_path.display()))?;
Ok(local_path)
}
fn fetched_trace_server_log_path(host: &str) -> PathBuf {
let now = SystemTime::now()
.duration_since(UNIX_EPOCH)
.map(|duration| duration.as_secs())
.unwrap_or(0);
trace_cache_dir().join(format!(
"server-{}-{}-{}.log",
sanitize_trace_name(host),
now,
std::process::id()
))
}
fn trace_cache_dir() -> PathBuf {
dirs::cache_dir()
.unwrap_or_else(|| expand_tilde("~/.cache"))
@@ -1120,17 +1232,56 @@ fn newest_client_trace_path() -> Result<Option<PathBuf>> {
}
fn summarize_trace_file(path: &Path, tail: usize) -> Result<TraceReport> {
summarize_trace_file_with_mode(path, tail, true)
}
fn summarize_trace_file_for_report(
path: &Path,
tail: usize,
latest_run: bool,
) -> Result<TraceReport> {
if latest_run {
summarize_trace_file(path, tail)
} else {
summarize_trace_file_with_mode(path, tail, false)
}
}
fn summarize_trace_file_with_mode(
path: &Path,
tail: usize,
latest_run: bool,
) -> Result<TraceReport> {
let file = File::open(path).with_context(|| format!("open trace log {}", path.display()))?;
let mut report = TraceReport {
path: path.to_path_buf(),
..TraceReport::default()
};
let mut parsed = Vec::new();
let mut file_lines = 0usize;
for line in BufReader::new(file).lines() {
let line = line?;
report.total_lines += 1;
let Some(fields) = parse_trace_line(&line) else {
continue;
file_lines += 1;
if let Some(fields) = parse_trace_line(&line) {
parsed.push(fields);
}
}
let latest_run_start = if latest_run {
parsed.iter().rposition(|fields| {
fields
.get("event")
.is_some_and(|event| trace_run_marker(event))
})
} else {
None
};
let parsed_len = parsed.len();
let skipped_old_run_lines = latest_run_start.unwrap_or(0);
let latest_run_filtered = latest_run_start.is_some_and(|index| index > 0);
let mut report = TraceReport {
path: path.to_path_buf(),
total_lines: file_lines.saturating_sub(skipped_old_run_lines),
skipped_old_run_lines,
latest_run_filtered,
..TraceReport::default()
};
for fields in parsed.into_iter().skip(skipped_old_run_lines) {
report.parsed_lines += 1;
if let Some(ts) = fields
.get("ts_ms")
@@ -1193,6 +1344,18 @@ fn summarize_trace_file(path: &Path, tail: usize) -> Result<TraceReport> {
if event.contains("reconnect") || event.contains("resume") {
report.reconnect_events += 1;
}
if event == "server.resume_unknown_client" {
report.unknown_resume_events += 1;
}
if event.ends_with("ticket_attach_start") {
report.ticket_attach_start_events += 1;
}
if event.ends_with("ticket_attach_ok") {
report.ticket_attach_ok_events += 1;
}
if event.ends_with("ticket_attach_reject") {
report.ticket_attach_reject_events += 1;
}
if event.contains("roam") {
report.roam_events += 1;
}
@@ -1204,12 +1367,21 @@ fn summarize_trace_file(path: &Path, tail: usize) -> Result<TraceReport> {
report.recent_events.push_back(rendered);
}
}
if report.total_lines == 0 && parsed_len > 0 {
report.total_lines = parsed_len;
}
Ok(report)
}
fn print_trace_report(label: &str, report: &TraceReport) {
println!();
println!("{label}: {}", report.path.display());
if report.latest_run_filtered {
println!(
" latest_run=true skipped_old_lines={}",
report.skipped_old_run_lines
);
}
println!(
" lines={} parsed={} span_ms={}",
report.total_lines,
@@ -1240,8 +1412,13 @@ fn print_trace_report(label: &str, report: &TraceReport) {
report.hex_events
);
println!(
" reconnect: events={} roam={}",
report.reconnect_events, report.roam_events
" reconnect: events={} unknown_resume={} ticket_attach={}/{}/{} roam={}",
report.reconnect_events,
report.unknown_resume_events,
report.ticket_attach_start_events,
report.ticket_attach_ok_events,
report.ticket_attach_reject_events,
report.roam_events
);
for warning in trace_report_warnings(report) {
println!(" alert: {warning}");
@@ -1262,6 +1439,18 @@ fn print_trace_report(label: &str, report: &TraceReport) {
fn trace_report_warnings(report: &TraceReport) -> Vec<String> {
let mut warnings = Vec::new();
if report.unknown_resume_events > 0 && report.ticket_attach_ok_events == 0 {
warnings.push(format!(
"{} unknown live resume event(s) without ticket attach recovery",
report.unknown_resume_events
));
}
if report.ticket_attach_reject_events > 0 {
warnings.push(format!(
"{} ticket attach reject event(s) observed",
report.ticket_attach_reject_events
));
}
if report.server_mouseish_pty_write_events > 0 {
warnings.push(format!(
"{} mouse-like input event(s) reached the server PTY",
@@ -1292,6 +1481,10 @@ fn trace_report_warnings(report: &TraceReport) -> Vec<String> {
warnings
}
fn trace_run_marker(event: &str) -> bool {
matches!(event, "client.start" | "server.start")
}
fn top_trace_events(events: &BTreeMap<String, usize>, limit: usize) -> Vec<(String, usize)> {
let mut entries: Vec<_> = events
.iter()
@@ -1318,6 +1511,10 @@ fn render_trace_event(fields: &BTreeMap<String, String>) -> String {
"summary",
"bytes",
"silent_ms",
"session",
"mode",
"reason",
"output_seq",
] {
if let Some(value) = fields.get(key) {
parts.push(format!("{key}={value}"));
@@ -5200,6 +5397,14 @@ async fn try_ticket_attach(
requested_env: Vec<EnvVar>,
) -> Result<(Frame, CachedCredential)> {
let addr = resolve_addr(&cached.udp_host, cached.udp_port)?;
dosh::trace::event(
"client.ticket_attach_start",
&[
("server", cached.server.clone()),
("session", cached.session.clone()),
("mode", cached.mode.clone()),
],
);
let client_nonce = crypto::random_12();
let request_key = crypto::hkdf32(
&cached.attach_ticket_psk,
@@ -5236,6 +5441,10 @@ async fn try_ticket_attach(
let ok = recv_response_until(socket, Duration::from_millis(700), |packet| {
if packet.header.kind == PacketKind::AttachReject && packet.header.conn_id == [0u8; 16] {
let reject: AttachReject = protocol::from_body(&packet.body)?;
dosh::trace::event(
"client.ticket_attach_reject",
&[("reason", reject.reason.clone())],
);
return Err(anyhow!("ticket attach rejected: {}", reject.reason));
}
if packet.header.kind != PacketKind::AttachOk {
@@ -5281,6 +5490,15 @@ async fn try_ticket_attach(
next.session_key = ok.session_key;
next.session_key_id = ok.session_key_id;
next.last_rendered_seq = ok.initial_seq;
dosh::trace::event(
"client.ticket_attach_ok",
&[
("session", next.session.clone()),
("mode", next.mode.clone()),
("output_seq", next.last_rendered_seq.to_string()),
("bytes", frame.bytes.len().to_string()),
],
);
Ok((frame, next))
}
@@ -5575,8 +5793,62 @@ async fn run_terminal(
dosh::trace::event("client.escape", &[]);
break;
}
let input_status_tick_gap = last_status_tick_at.elapsed();
let mut refreshed_before_input = false;
if should_reconnect_before_input_for_local_sleep(
forward_only,
input_status_tick_gap,
) {
dosh::trace::event(
"client.local_sleep_input_reconnect_start",
&[(
"tick_gap_ms",
input_status_tick_gap.as_millis().to_string(),
)],
);
last_status_tick_at = Instant::now();
arm_stale_terminal_input_suppression(
&mut stale_terminal_input_suppress_until,
);
if let Some(frame) = reconnect(
&socket,
&mut cred,
&mut send_seq,
last_size,
&mut frame_buffer,
&mut predictor,
)
.await?
{
dosh::trace::event(
"client.local_sleep_input_reconnect_ok",
&[
("output_seq", frame.output_seq.to_string()),
("bytes", frame.bytes.len().to_string()),
],
);
refresh_live_addr(&mut addr, &cred)?;
render_frame(&frame)?;
predictor.observe_output(&frame.bytes);
last_terminal_frame_at = Instant::now();
last_packet_at = Instant::now();
last_focus_repaint_at = Instant::now();
refreshed_before_input = true;
flush_pending_user_input(
&socket,
addr,
&cred,
&mut send_seq,
&mut predictor,
&mut pending_user_input,
&mut pending_user_input_bytes,
)
.await?;
}
}
let saw_focus_in = input_contains_focus_in(&bytes);
if !forward_only
&& !refreshed_before_input
&& saw_focus_in
&& last_focus_repaint_at.elapsed() >= FOCUS_REPAINT_COOLDOWN
{
@@ -6996,6 +7268,13 @@ fn should_strip_stale_terminal_reports(
|| suppress_until.is_some_and(|deadline| Instant::now() < deadline)
}
fn should_reconnect_before_input_for_local_sleep(
forward_only: bool,
status_tick_gap: Duration,
) -> bool {
!forward_only && status_tick_gap >= LOCAL_SLEEP_REPAINT_AFTER
}
fn should_strip_unowned_terminal_reports(alternate_screen: bool, mouse_tracking: bool) -> bool {
!alternate_screen && !mouse_tracking
}
@@ -7053,6 +7332,13 @@ fn should_repaint_idle_terminal(
fn arm_stale_terminal_input_suppression(suppress_until: &mut Option<Instant>) {
*suppress_until = Some(Instant::now() + POST_RECONNECT_STALE_INPUT_GRACE);
dosh::trace::event(
"client.stale_terminal_quarantine_arm",
&[(
"grace_ms",
POST_RECONNECT_STALE_INPUT_GRACE.as_millis().to_string(),
)],
);
}
async fn flush_pending_user_input(
@@ -8992,32 +9278,33 @@ mod tests {
use super::{
ALT_SCREEN_IDLE_REPAINT_AFTER, CachedCredential, DisconnectStatus, DynamicForward,
FRAME_GAP_RESYNC_AFTER_MS, FrameBuffer, LOCAL_SLEEP_REPAINT_AFTER, LocalForward,
MAX_PENDING_USER_INPUT_BYTES, NativeIdentityContext, POST_SUBMIT_ALL_INPUT_HOLD,
PendingStreamOpen, PredictMode, Predictor, RESTART_STATUS_SCRIPT, RemoteForward,
STARTUP_INPUT_HOLD, SshConfig, SshPathTokenContext, StartupGateMode, StatusAction,
UpdateOptions, UpdateRole, auth_allows, cache_key, cache_server_prefix,
cleanup_stream_state, clear_cached_credentials, ensure_tui_safe_status_overlay,
expand_ssh_path_tokens, input_contains_focus_in, input_matches_escape,
is_local_status_target, is_resume_response_for_client, latest_release_download_url,
load_first_native_identity_with_prompt, native_proxy_udp_warning, parse_dynamic_forward,
parse_escape_key, parse_local_forward, parse_remote_forward, parse_ssh_config,
parse_trace_line, parse_trace_options, parse_trace_report_options, parse_trace_summary,
parse_update_options, post_submit_hold_duration, queue_pending_user_input,
queue_stale_pending_user_input, raw_contains_host_table, recv_response_until,
refresh_live_addr, release_tag_download_url, release_tag_from_effective_url,
release_version_from_tag, render_status_clear, render_status_overlay, requested_env,
resolved_startup_command, retire_stream_state, retransmit_stream_opens,
rewrite_forward_command, sanitize_trace_name, selected_predict_mode, selected_udp_host,
server_version_mismatch, should_flush_terminal_input_after_contact,
should_hold_during_startup_gate, should_hold_post_submit_input,
MAX_PENDING_USER_INPUT_BYTES, NativeIdentityContext, POST_RECONNECT_STALE_INPUT_GRACE,
POST_SUBMIT_ALL_INPUT_HOLD, PendingStreamOpen, PredictMode, Predictor,
RESTART_STATUS_SCRIPT, RemoteForward, STARTUP_INPUT_HOLD, SshConfig, SshPathTokenContext,
StartupGateMode, StatusAction, UpdateOptions, UpdateRole, auth_allows, cache_key,
cache_server_prefix, cleanup_stream_state, clear_cached_credentials,
ensure_tui_safe_status_overlay, expand_ssh_path_tokens, input_contains_focus_in,
input_matches_escape, is_local_status_target, is_resume_response_for_client,
latest_release_download_url, load_first_native_identity_with_prompt,
native_proxy_udp_warning, parse_dynamic_forward, parse_escape_key, parse_local_forward,
parse_remote_forward, parse_ssh_config, parse_trace_line, parse_trace_options,
parse_trace_report_options, parse_trace_summary, parse_update_options,
post_submit_hold_duration, queue_pending_user_input, queue_stale_pending_user_input,
raw_contains_host_table, recv_response_until, refresh_live_addr, release_tag_download_url,
release_tag_from_effective_url, release_version_from_tag, render_status_clear,
render_status_overlay, requested_env, resolved_startup_command, retire_stream_state,
retransmit_stream_opens, rewrite_forward_command, sanitize_trace_name,
selected_predict_mode, selected_udp_host, server_version_mismatch,
should_flush_terminal_input_after_contact, should_hold_during_startup_gate,
should_hold_post_submit_input, should_reconnect_before_input_for_local_sleep,
should_repaint_idle_terminal, should_strip_unowned_terminal_reports,
split_after_command_submit, split_trace_tokens, ssh_command_target, ssh_config_uses_proxy,
ssh_destination_host, ssh_username, ssh_with_user, startup_command, status_ssh_target,
strip_stale_mouse_reports, strip_terminal_focus_reports, strip_unowned_terminal_reports,
summarize_trace_file, terminal_private_mode_transition, toml_bare_key_or_quoted,
top_trace_events, trace_report_warnings, unix_update_script, update_installer_url,
update_version_status, upsert_managed_block, valid_forward_host, vscode_safe_alias,
windows_update_script,
summarize_trace_file, summarize_trace_file_with_mode, terminal_private_mode_transition,
toml_bare_key_or_quoted, top_trace_events, trace_report_warnings, unix_update_script,
update_installer_url, update_version_status, upsert_managed_block, valid_forward_host,
vscode_safe_alias, windows_update_script,
};
use dosh::config::{ClientConfig, CommandExtension, HostConfig};
use dosh::native::EnvVar;
@@ -10324,27 +10611,38 @@ mod tests {
#[test]
fn trace_report_options_parse_defaults_and_overrides() {
let parsed = parse_trace_report_options(&[]).unwrap();
assert_eq!(parsed.host, None);
assert_eq!(parsed.client_log, None);
assert_eq!(
parsed.server_log,
Some(std::path::PathBuf::from("/tmp/dosh-server.log"))
);
assert_eq!(parsed.server_log, Some("/tmp/dosh-server.log".to_string()));
assert_eq!(parsed.tail, 20);
assert!(parsed.latest_run);
let parsed = parse_trace_report_options(&[
"palav".to_string(),
"--client-log=/tmp/client.log".to_string(),
"--server-log".to_string(),
"none".to_string(),
"/tmp/server.log".to_string(),
"--all-runs".to_string(),
"--tail".to_string(),
"3".to_string(),
])
.unwrap();
assert_eq!(parsed.host.as_deref(), Some("palav"));
assert_eq!(
parsed.client_log,
Some(std::path::PathBuf::from("/tmp/client.log"))
);
assert_eq!(parsed.server_log, None);
assert_eq!(parsed.server_log.as_deref(), Some("/tmp/server.log"));
assert_eq!(parsed.tail, 3);
assert!(!parsed.latest_run);
let parsed = parse_trace_report_options(&[
"--server-log=none".to_string(),
"--latest-run".to_string(),
])
.unwrap();
assert_eq!(parsed.server_log, None);
assert!(parsed.latest_run);
}
#[test]
@@ -10455,6 +10753,81 @@ mod tests {
);
}
#[test]
fn trace_report_defaults_to_latest_process_run_when_marker_exists() {
let dir = tempfile::tempdir().unwrap();
let path = dir.path().join("server.log");
fs::write(
&path,
concat!(
"ts_ms=10 pid=1 event=server.pty_write session=term seq=1 summary=len=12,esc=false,focus=false,mouseish=true,printable=12\n",
"ts_ms=20 pid=2 event=server.start version=1.0.0 bind=0.0.0.0:50000\n",
"ts_ms=21 pid=2 event=server.resume_start seq=2 ack=1\n",
"ts_ms=22 pid=2 event=server.resume_ok bytes=20\n",
),
)
.unwrap();
let latest = summarize_trace_file(&path, 10).unwrap();
assert!(latest.latest_run_filtered);
assert_eq!(latest.skipped_old_run_lines, 1);
assert_eq!(latest.total_lines, 3);
assert_eq!(latest.server_mouseish_pty_write_events, 0);
assert_eq!(latest.reconnect_events, 2);
let all = summarize_trace_file_with_mode(&path, 10, false).unwrap();
assert!(!all.latest_run_filtered);
assert_eq!(all.skipped_old_run_lines, 0);
assert_eq!(all.total_lines, 4);
assert_eq!(all.server_mouseish_pty_write_events, 1);
}
#[test]
fn trace_report_correlates_unknown_resume_with_ticket_recovery() {
let dir = tempfile::tempdir().unwrap();
let path = dir.path().join("server.log");
fs::write(
&path,
concat!(
"ts_ms=10 pid=1 event=server.start version=1.0.0 bind=0.0.0.0:50000\n",
"ts_ms=11 pid=1 event=server.resume_start client=abc seq=2 ack=1\n",
"ts_ms=12 pid=1 event=server.resume_unknown_client client=abc\n",
"ts_ms=13 pid=1 event=server.ticket_attach_start peer=1.2.3.4:5\n",
"ts_ms=14 pid=1 event=server.ticket_attach_ok session=term mode=read-write client=def output_seq=9 bytes=100\n",
),
)
.unwrap();
let recovered = summarize_trace_file(&path, 10).unwrap();
assert_eq!(recovered.unknown_resume_events, 1);
assert_eq!(recovered.ticket_attach_start_events, 1);
assert_eq!(recovered.ticket_attach_ok_events, 1);
assert!(trace_report_warnings(&recovered).is_empty());
fs::write(
&path,
concat!(
"ts_ms=20 pid=2 event=server.start version=1.0.0 bind=0.0.0.0:50000\n",
"ts_ms=21 pid=2 event=server.resume_unknown_client client=abc\n",
"ts_ms=22 pid=2 event=server.ticket_attach_reject reason='ticket expired'\n",
),
)
.unwrap();
let rejected = summarize_trace_file(&path, 10).unwrap();
let warnings = trace_report_warnings(&rejected);
assert_eq!(rejected.unknown_resume_events, 1);
assert_eq!(rejected.ticket_attach_reject_events, 1);
assert!(warnings.iter().any(|warning| {
warning == "1 unknown live resume event(s) without ticket attach recovery"
}));
assert!(
warnings
.iter()
.any(|warning| warning == "1 ticket attach reject event(s) observed")
);
}
#[test]
fn update_installer_uses_platform_native_script() {
assert_eq!(
@@ -11040,6 +11413,35 @@ mod tests {
));
}
#[test]
fn local_sleep_gap_reconnects_before_forwarding_input() {
assert!(should_reconnect_before_input_for_local_sleep(
false,
LOCAL_SLEEP_REPAINT_AFTER
));
assert!(should_reconnect_before_input_for_local_sleep(
false,
LOCAL_SLEEP_REPAINT_AFTER + Duration::from_secs(10)
));
assert!(!should_reconnect_before_input_for_local_sleep(
false,
LOCAL_SLEEP_REPAINT_AFTER - Duration::from_millis(1)
));
assert!(!should_reconnect_before_input_for_local_sleep(
true,
LOCAL_SLEEP_REPAINT_AFTER + Duration::from_secs(10)
));
}
#[test]
fn reconnect_mouse_quarantine_is_long_enough_for_sleep_wake_noise() {
assert!(POST_RECONNECT_STALE_INPUT_GRACE >= LOCAL_SLEEP_REPAINT_AFTER);
assert_eq!(
strip_stale_mouse_reports(b"35;152;1M\x1b[A35;149;1M"),
b"\x1b[A"
);
}
#[test]
fn non_mouse_escape_input_survives_stale_filter() {
assert_eq!(strip_stale_mouse_reports(b"\x1b[A"), b"\x1b[A");
+43 -2
View File
@@ -200,6 +200,13 @@ async fn serve(config_path: Option<std::path::PathBuf>) -> Result<()> {
.with_context(|| format!("bind {bind}"))?,
);
eprintln!("dosh-server listening on {bind}");
dosh::trace::event(
"server.start",
&[
("version", dosh::build_info::VERSION.to_string()),
("bind", bind.clone()),
],
);
let (pty_tx, mut pty_rx) = mpsc::unbounded_channel();
let state = Arc::new(Mutex::new(ServerState::new(
@@ -1456,6 +1463,7 @@ async fn handle_ticket_attach(
peer: SocketAddr,
body: Vec<u8>,
) -> Result<()> {
dosh::trace::event("server.ticket_attach_start", &[("peer", peer.to_string())]);
let env: TicketAttachEnvelope = protocol::from_body(&body)?;
let opened = {
let locked = state.lock().expect("server state poisoned");
@@ -1479,10 +1487,22 @@ async fn handle_ticket_attach(
};
let (ticket, request_plain) = match opened {
Ok(opened) => opened,
Err(err) => return send_reject(socket, peer, &err.to_string()).await,
Err(err) => {
let reason = err.to_string();
dosh::trace::event("server.ticket_attach_reject", &[("reason", reason.clone())]);
return send_reject(socket, peer, &reason).await;
}
};
let req: TicketAttachBody = protocol::from_body(&request_plain)?;
if req.session != ticket.session || req.mode != ticket.mode {
dosh::trace::event(
"server.ticket_attach_reject",
&[
("session", req.session.clone()),
("mode", req.mode.clone()),
("reason", "ticket scope mismatch".to_string()),
],
);
return send_reject(socket, peer, "ticket scope mismatch").await;
}
@@ -1553,7 +1573,18 @@ async fn handle_ticket_attach(
};
let (client_id, output_seq, snapshot) = match attached {
Ok(attached) => attached,
Err(err) => return send_reject(socket, peer, &err.to_string()).await,
Err(err) => {
let reason = err.to_string();
dosh::trace::event(
"server.ticket_attach_reject",
&[
("session", req.session.clone()),
("mode", req.mode.clone()),
("reason", reason.clone()),
],
);
return send_reject(socket, peer, &reason).await;
}
};
let ok = AttachOk {
@@ -1584,6 +1615,16 @@ async fn handle_ticket_attach(
let body = protocol::to_body(&envelope)?;
let out = protocol::encode_plain(PacketKind::AttachOk, client_id, 1, 0, &body)?;
let _ = send_udp(socket, &out, peer).await?;
dosh::trace::event(
"server.ticket_attach_ok",
&[
("session", ok.session.clone()),
("mode", ok.mode.clone()),
("client", hex_id(client_id)),
("output_seq", output_seq.to_string()),
("bytes", ok.snapshot.len().to_string()),
],
);
Ok(())
}