Try #1405:

openebs · Jun 9, 2023 · b7b1174 · b7b1174
2 parents 6265776 + 537ac2f
commit b7b1174
Show file tree

Hide file tree

Showing 12 changed files with 895 additions and 483 deletions.
diff --git a/io-engine/src/bdev/nexus/nexus_bdev.rs b/io-engine/src/bdev/nexus/nexus_bdev.rs
@@ -591,6 +591,7 @@ impl<'n> Nexus<'n> {
         let (sender, recv) = oneshot::channel::<ChannelTraverseStatus>();
 
         self.traverse_io_channels(
+            sender,
             |chan, _sender| -> ChannelTraverseStatus {
                 chan.reconnect_all();
                 ChannelTraverseStatus::Ok
@@ -599,7 +600,6 @@ impl<'n> Nexus<'n> {
                 debug!("{self:?}: all I/O channels reconfigured");
                 sender.send(status).expect("reconfigure channel gone");
             },
-            sender,
         );
 
         let result = recv.await.expect("reconfigure sender already dropped");

diff --git a/io-engine/src/bdev/nexus/nexus_bdev_children.rs b/io-engine/src/bdev/nexus/nexus_bdev_children.rs
@@ -838,12 +838,12 @@ impl<'n> Nexus<'n> {
         // and the I/O would end up logged.
         if has_io_log {
             self.traverse_io_channels(
+                (),
                 |chan, _| {
                     chan.reconnect_io_logs();
                     ChannelTraverseStatus::Ok
                 },
                 |_, _| {},
-                (),
             );
 
             c.io_log_channel()
@@ -1048,9 +1048,9 @@ impl<'n> Nexus<'n> {
             );
 
             self.traverse_io_channels(
+                ctx,
                 update_failfast_cb,
                 update_failfast_done,
-                ctx,
             );
 
             r.await