Compare commits
1 Commits
96cb71ccdc
...
4271a94354
Author | SHA1 | Date |
---|---|---|
mwojcik | 4271a94354 |
|
@ -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,
|
||||
|
|
Loading…
Reference in New Issue