Skip to content

Commit a4d2b6e

Browse files
committed
fix: exit of threads
1 parent b514611 commit a4d2b6e

2 files changed

Lines changed: 3 additions & 3 deletions

File tree

src/packet_processor.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -53,15 +53,15 @@ pub trait Processor: Send {
5353
recv(self.controller_recv()) -> cmd => {
5454
if let Ok(cmd) = cmd {
5555
if self.handle_command(cmd) {
56-
return
56+
std::process::exit(0);
5757
}
5858
}
5959
}
6060

6161
recv(self.packet_recv()) -> pkt => {
6262
if let Ok(pkt) = pkt {
6363
if self.handle_packet(pkt).is_err() {
64-
return
64+
std::process::exit(0);
6565
}
6666
}
6767
}

src/routing_handler.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -288,7 +288,7 @@ impl RoutingHandler {
288288
.network_view
289289
.change_node_type(source_id, NodeType::Drone),
290290

291-
NackType::UnexpectedRecipient(_) => todo!(),
291+
NackType::UnexpectedRecipient(_) => todo!("Should fix network view accordingly"),
292292
}
293293

294294
self.retry_send(session_id, nack.fragment_index, source_id)?;

0 commit comments

Comments
 (0)