fix corrupted transfers issue

github-af · github-af · commit 68fd04776b2d · 2026-03-14T21:47:22.000+01:00
diff --git a/lidi-receive/src/dispatch.rs b/lidi-receive/src/dispatch.rs
@@ -95,7 +95,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 {
@@ -111,6 +110,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
`@@ -95,7 +95,6 @@ pub fn start<ClientNew, ClientEnd>(`
`95`	`95`	`match protocol::EndpointId::deserialize(payload) {`
`96`	`96`	`None => {`
`97`	`97`	`log::error!("client {client_id:x} for invalid endpoint");`
`98`		`- continue;`
`99`	`98`	`}`
`100`	`99`	`Some(endpoint) => {`
`101`	`100`	`let (client_sendq, client_recvq) = if 0 < receiver.config.queue_size {`
`@@ -111,6 +110,7 @@ pub fn start<ClientNew, ClientEnd>(`
`111`	`110`	`.send((endpoint, client_id, client_recvq))?;`
`112`	`111`	`}`
`113`	`112`	`}`
	`113`	`+ continue;`
`114`	`114`	`}`
`115`	`115`	`protocol::BlockType::Abort \| protocol::BlockType::End => will_end = true,`
`116`	`116`	`protocol::BlockType::Data => (),`