diff options
| author | maximilien <me@mricher.fr> | 2025-01-17 06:06:14 +0000 |
|---|---|---|
| committer | maximilien <me@mricher.fr> | 2025-01-17 06:06:14 +0000 |
| commit | 294cb9940943d7febc1029ed44145daf57f914d0 (patch) | |
| tree | be9b2912ae92b07ef5e7905372b1bc2a542234c6 /src/net/send.rs | |
| parent | 255b01b626096ef98cf24c9552b39c0372fb4eb3 (diff) | |
| parent | 2eb9fcae20cb7e41b1197f4565db492a97f95736 (diff) | |
| download | garage-294cb9940943d7febc1029ed44145daf57f914d0.tar.gz garage-294cb9940943d7febc1029ed44145daf57f914d0.zip | |
Reviewed-on: https://git.deuxfleurs.fr/Deuxfleurs/garage/pulls/928
Reviewed-by: maximilien <me@mricher.fr>
Diffstat (limited to 'src/net/send.rs')
| -rw-r--r-- | src/net/send.rs | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/net/send.rs b/src/net/send.rs index c60fc6b2..1454eeb7 100644 --- a/src/net/send.rs +++ b/src/net/send.rs @@ -28,7 +28,7 @@ use crate::stream::*; // - if error: // - u8: error kind, encoded using error::io_errorkind_to_u8 // - rest: error message -// - absent for cancel messag +// - absent for cancel message pub(crate) type RequestID = u32; pub(crate) type ChunkLength = u16; @@ -217,7 +217,7 @@ impl<'a> futures::Future for SendQueuePollNextReady<'a> { enum DataFrame { /// a fixed size buffer containing some data + a boolean indicating whether - /// there may be more data comming from this stream. Can be used for some + /// there may be more data coming from this stream. Can be used for some /// optimization. It's an error to set it to false if there is more data, but it is correct /// (albeit sub-optimal) to set it to true if there is nothing coming after Data(Bytes, bool), @@ -310,7 +310,7 @@ pub(crate) trait SendLoop: Sync { // recv_fut is cancellation-safe according to tokio doc, // send_fut is cancellation-safe as implemented above? tokio::select! { - biased; // always read incomming channel first if it has data + biased; // always read incoming channel first if it has data sth = recv_fut => { match sth { Some(SendItem::Stream(id, prio, order_tag, data)) => { |