Compare commits

..

1 Commits

Author SHA1 Message Date
mwojcik 4271a94354 satman: support sub-subkernels, routing 2023-12-14 15:19:19 +08:00
1 changed files with 10 additions and 8 deletions

View File

@ -239,10 +239,10 @@ fn process_aux_packet(
drtioaux::Packet::RoutingSetRank { rank: _ } => drtioaux::send(0, &drtioaux::Packet::RoutingAck),
drtioaux::Packet::RoutingRetrievePackets => {
let packet = match router.get_upstream_packet() {
Some(packet) => packet,
None => drtioaux::Packet::RoutingNoPackets,
};
let packet = router
.get_upstream_packet()
.or(Some(drtioaux::Packet::RoutingNoPackets))
.unwrap();
drtioaux::send(0, &packet)
}
@ -614,10 +614,12 @@ fn process_aux_packet(
} => {
forward!(_routing_table, _destination, *rank, _repeaters, &packet, timer);
kernel_manager.message_handle_incoming(status, length as usize, &data);
router.send(drtioaux::Packet::SubkernelMessageAck { destination: source },
_routing_table,
*rank,
*self_destination)
router.send(
drtioaux::Packet::SubkernelMessageAck { destination: source },
_routing_table,
*rank,
*self_destination,
)
}
drtioaux::Packet::SubkernelMessageAck {
destination: _destination,