fix corrupted transfers issue

github-af · github-af · commit 269b60865bb4 · 2026-03-14T21:47:40.000+01:00
diff --git a/lidi-receive/src/dispatch.rs b/lidi-receive/src/dispatch.rs
@@ -94,7 +94,6 @@ pub fn start<ClientNew, ClientEnd>(
                 match protocol::EndpointId::deserialize(payload) {
                     None => {
                         log::error!("client {client_id:x} for invalid endpoint");
-                        continue;
                     }
                     Some(endpoint) => {
                         let (client_sendq, client_recvq) = if 0 < receiver.config.queue_size {
@@ -110,6 +109,7 @@ pub fn start<ClientNew, ClientEnd>(
                             .send((endpoint, client_id, client_recvq))?;
                     }
                 }
+                continue;
             }
             protocol::BlockType::Abort | protocol::BlockType::End => will_end = true,
             protocol::BlockType::Data => (),

Original file line number	Diff line number	Diff line change
`@@ -94,7 +94,6 @@ pub fn start<ClientNew, ClientEnd>(`
`94`	`94`	`match protocol::EndpointId::deserialize(payload) {`
`95`	`95`	`None => {`
`96`	`96`	`log::error!("client {client_id:x} for invalid endpoint");`
`97`		`- continue;`
`98`	`97`	`}`
`99`	`98`	`Some(endpoint) => {`
`100`	`99`	`let (client_sendq, client_recvq) = if 0 < receiver.config.queue_size {`
`@@ -110,6 +109,7 @@ pub fn start<ClientNew, ClientEnd>(`
`110`	`109`	`.send((endpoint, client_id, client_recvq))?;`
`111`	`110`	`}`
`112`	`111`	`}`
	`112`	`+ continue;`
`113`	`113`	`}`
`114`	`114`	`protocol::BlockType::Abort \| protocol::BlockType::End => will_end = true,`
`115`	`115`	`protocol::BlockType::Data => (),`