Skip to content

Commit

Permalink
Small fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
mkeeter committed Oct 15, 2024
1 parent 00c2c37 commit 3a7e2f8
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 2 deletions.
4 changes: 2 additions & 2 deletions upstairs/src/dummy_downstairs_tests.rs
Original file line number Diff line number Diff line change
Expand Up @@ -307,10 +307,10 @@ impl DownstairsHandle {

/// Awaits and acks a `Message::Write { .. }` or `Message::Barrier { .. }`
///
/// Returns the job ID for further checks.
/// Returns `true` if the message was a barrier, `false` otherwise
///
/// # Panics
/// If a non-write message arrives
/// If a message other than `Write` or `Barrier` arrives
pub async fn ack_write_or_barrier(&mut self) -> bool {
let (r, was_barrier) = match self.recv().await.unwrap() {
Message::Write { header, .. } => (
Expand Down
5 changes: 5 additions & 0 deletions upstairs/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -1323,6 +1323,11 @@ impl IOop {
// the downstairs to act based on that.
true
}
IOop::Barrier { .. } => {
// The Barrier IOop doesn't actually touch any extents; it's
// purely for dependency management.
true
}
_ => {
panic!("Unsupported IO check {:?}", self);
}
Expand Down

0 comments on commit 3a7e2f8

Please sign in to comment.