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