rust/tantivy
1
0
Fork 0
mirror of https://github.com/quickwit-oss/tantivy.git synced 2026-05-27 13:40:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

merge match, explicit type

Browse Source
This commit is contained in:
Pascal Seitz
2022-06-16 16:50:56 +08:00
parent 4c7dedef29
commit 7bf5962554
1 changed files with 15 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
src/store/writer.rs
View File

@@ -56,9 +56,13 @@ impl StoreWriter {
let thread_builder = thread::Builder::new().name("docstore compressor thread".to_string());
// Data channel to send fs writes, to write only from current thread
let (data_sender, data_receiver) = sync_channel(3);
let (data_sender, data_receiver): (SyncSender<OwnedBytes>, Receiver<OwnedBytes>) =
sync_channel(3);
// Channel to send uncompressed data to compressor channel
let (block_sender, block_receiver) = sync_channel(3);
let (block_sender, block_receiver): (
SyncSender<BlockCompressorMessage>,
Receiver<BlockCompressorMessage>,
) = sync_channel(3);
let thread_join_handle = thread_builder.spawn(move || {
let mut block_compressor = BlockCompressor::new(compressor, data_sender);
while let Ok(packet) = block_receiver.recv() {
@@ -116,17 +120,15 @@ impl StoreWriter {
Ok(data) => {
self.writer.write_all(data.as_slice())?;
}
Err(err) => match err {
TryRecvError::Empty => {
break;
}
TryRecvError::Disconnected => {
return Err(io::Error::new(
io::ErrorKind::Other,
"compressor data channel unexpected closed".to_string(),
));
}
},
Err(TryRecvError::Empty) => {
break;
}
Err(TryRecvError::Disconnected) => {
return Err(io::Error::new(
io::ErrorKind::Other,
"compressor data channel unexpected closed".to_string(),
));
}
}
}