reivilibre
/
yama
1
0
Fork 0
Code Issues 27 Pull Requests Releases 16 Wiki Activity

Remove unused args

This commit is contained in:
Olivier 'reivilibre' 2021-11-20 10:33:18 +00:00
parent 7b21b43bc6
commit 1c1042e640
2 changed files with 1 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
yama/src/pile/compression.rs
View File

@ -168,7 +168,6 @@ impl<R: RawPile> RawPileCompressor<R> {
&self, &self,
next_stage: Sender<(ChunkId, Vec<u8>)>, next_stage: Sender<(ChunkId, Vec<u8>)>,
input: Receiver<(ChunkId, Vec<u8>)>, input: Receiver<(ChunkId, Vec<u8>)>,
controller_send: &Sender<ControllerMessage>,
worker_id: String, worker_id: String,
) -> anyhow::Result<()> { ) -> anyhow::Result<()> {
// the worker ID has to live forever, so we leak it :/ // the worker ID has to live forever, so we leak it :/
@ -275,7 +274,6 @@ impl<R: RawPile> RawPile for RawPileCompressor<R> {
if let Err(err) = this.storage_pipeline_worker( if let Err(err) = this.storage_pipeline_worker(
subsequent_pipeline, subsequent_pipeline,
receiver, receiver,
&controller_send,
worker_id.to_string(), worker_id.to_string(),
) { ) {
controller_send controller_send

3
yama/src/pile/local_sqlitebloblogs.rs
View File

@ -373,7 +373,6 @@ impl SqliteBloblogPile {
fn storage_pipeline_worker( fn storage_pipeline_worker(
&self, &self,
incoming: Receiver<(ChunkId, Vec<u8>)>, incoming: Receiver<(ChunkId, Vec<u8>)>,
controller_sender: &Sender<ControllerMessage>,
) -> anyhow::Result<()> { ) -> anyhow::Result<()> {
// can hold on to the same bloblog as long as we'd like! // can hold on to the same bloblog as long as we'd like!
const POINTERS_BUFFER_SIZE: usize = 256; const POINTERS_BUFFER_SIZE: usize = 256;
@ -705,7 +704,7 @@ impl RawPile for SqliteBloblogPile {
thread::spawn(move || { thread::spawn(move || {
let worker_id = Arc::new(format!("bloblogwriter")); let worker_id = Arc::new(format!("bloblogwriter"));
if let Err(err) = this.storage_pipeline_worker(incoming, &controller_send) { if let Err(err) = this.storage_pipeline_worker(incoming) {
controller_send controller_send
.send(ControllerMessage::Failure { .send(ControllerMessage::Failure {
worker_id, worker_id,