From 4304bbc92f06ca97dd4a4ac7425f2f27018f1e8c Mon Sep 17 00:00:00 2001 From: sxyazi Date: Thu, 4 Apr 2024 02:10:01 +0800 Subject: [PATCH] .. --- yazi-dds/src/payload.rs | 2 +- yazi-dds/src/server.rs | 3 +-- yazi-dds/src/state.rs | 2 +- 3 files changed, 3 insertions(+), 4 deletions(-) diff --git a/yazi-dds/src/payload.rs b/yazi-dds/src/payload.rs index a9958796..e65b3c8f 100644 --- a/yazi-dds/src/payload.rs +++ b/yazi-dds/src/payload.rs @@ -54,7 +54,7 @@ impl FromStr for Payload<'_> { type Err = anyhow::Error; fn from_str(s: &str) -> Result { - let mut parts = s.splitn(5, ','); + let mut parts = s.splitn(4, ','); let kind = parts.next().ok_or_else(|| anyhow!("empty kind"))?; diff --git a/yazi-dds/src/server.rs b/yazi-dds/src/server.rs index e076b6d2..0f37e54f 100644 --- a/yazi-dds/src/server.rs +++ b/yazi-dds/src/server.rs @@ -42,7 +42,7 @@ impl Server { continue; } - let mut parts = line.splitn(5, ','); + let mut parts = line.splitn(4, ','); let Some(id) = id else { continue }; let Some(kind) = parts.next() else { continue }; let Some(receiver) = parts.next().and_then(|s| s.parse().ok()) else { continue }; @@ -62,7 +62,6 @@ impl Server { } if receiver == 0 && sender <= u16::MAX as u64 { - let Some(_) = parts.next() else { continue }; let Some(body) = parts.next() else { continue }; if !STATE.set(kind, sender as u16, body) { continue } } diff --git a/yazi-dds/src/state.rs b/yazi-dds/src/state.rs index 7a3e5613..9beb8992 100644 --- a/yazi-dds/src/state.rs +++ b/yazi-dds/src/state.rs @@ -83,7 +83,7 @@ impl State { let mut inner = HashMap::new(); while buf.read_line(&mut line).await? > 0 { - let mut parts = line.splitn(5, ','); + let mut parts = line.splitn(4, ','); let Some(kind) = parts.next() else { continue }; let Some(_) = parts.next() else { continue }; let Some(severity) = parts.next().and_then(|s| s.parse::().ok()) else { continue };