Skip to content

Commit

Permalink
move comment
Browse files Browse the repository at this point in the history
  • Loading branch information
mcroomp committed Apr 10, 2024
1 parent 7dc7a8d commit 523637a
Showing 1 changed file with 6 additions and 7 deletions.
13 changes: 6 additions & 7 deletions src/structs/multiplexer.rs
Original file line number Diff line number Diff line change
@@ -1,3 +1,9 @@
/// Implements a multiplexer that reads and writes blocks to a stream from multiple threads.
///
/// The write implementation identifies the blocks by thread_id and tries to write in 64K blocks. The file
/// ends up with an interleaved stream of blocks from each thread.
///
/// The read implementation reads the blocks from the file and sends them to the appropriate worker thread.
use crate::{helpers::*, ExitCode};
use anyhow::{Context, Result};
use byteorder::{ReadBytesExt, WriteBytesExt};
Expand All @@ -8,13 +14,6 @@ use std::{
sync::mpsc::{channel, Receiver, SendError, Sender},
};

/// Implements a multiplexer that reads and writes blocks to a stream from multiple threads.
///
/// The write implementation identifies the blocks by thread_id and tries to write in 64K blocks. The file
/// ends up with an interleaved stream of blocks from each thread.
///
/// The read implementation reads the blocks from the file and sends them to the appropriate worker thread.
/// The message that is sent between the threads
enum Message {
Eof,
Expand Down

0 comments on commit 523637a

Please sign in to comment.