Skip to content

Commit

Permalink
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
WIP
Browse files Browse the repository at this point in the history
douglas-raillard-arm committed Nov 9, 2023
1 parent 12529ea commit 0552231
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions tools/analysis/trace-tools/src/lib/parquet.rs
Original file line number Diff line number Diff line change
@@ -247,7 +247,7 @@ where

if len >= CHUNK_SIZE {
let chunk = state.extract_chunk()?;
state.sender.send(chunk);
state.sender.send(chunk).unwrap();
}
Ok(())
}};
@@ -314,7 +314,7 @@ where
match read_state {
Ok(mut read_state) => {
let chunk = read_state.extract_chunk()?;
read_state.sender.send(chunk);
read_state.sender.send(chunk).unwrap();
// Drop the sender which will close the channel so that the writer thread will
// know it's time to finish.
drop(read_state.sender);

0 comments on commit 0552231

Please sign in to comment.