Dirty fix to test previous commit
This commit is contained in:
parent
d03943db8d
commit
7e71e4188f
1 changed files with 3 additions and 1 deletions
|
|
@ -1513,7 +1513,9 @@ impl PeerHandler {
|
||||||
let _ = tx.send(WriterRequest::Disconnect(Err(e)));
|
let _ = tx.send(WriterRequest::Disconnect(Err(e)));
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
disk_work_queue_tx.blocking_send(Box::new(work))?;
|
self.state.spawn(error_span!("disk_work"), async move {
|
||||||
|
Ok(disk_work_queue_tx.send(Box::new(work)).await?)
|
||||||
|
});
|
||||||
} else {
|
} else {
|
||||||
self.state
|
self.state
|
||||||
.meta
|
.meta
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue