Skip to content

Commit 1587e63

Browse files
committed
fix panic in ledger_manager when send method return Err
1 parent 2421e63 commit 1587e63

File tree

2 files changed

+47
-12
lines changed

2 files changed

+47
-12
lines changed

.idea/openmina.iml

Lines changed: 35 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

node/src/ledger/ledger_manager.rs

Lines changed: 12 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -457,25 +457,25 @@ impl LedgerManager {
457457

458458
impl LedgerCaller {
459459
pub fn call(&self, request: LedgerRequest) {
460-
self.0
461-
.send(LedgerRequestWithChan {
462-
request,
463-
responder: None,
464-
})
465-
.unwrap();
460+
if let Err(err) = self.0.send(LedgerRequestWithChan {
461+
request,
462+
responder: None,
463+
}) {
464+
eprintln!("Error sending request: {:?}", err);
465+
}
466466
}
467467

468468
fn call_sync(
469469
&self,
470470
request: LedgerRequest,
471471
) -> Result<LedgerResponse, std::sync::mpsc::RecvError> {
472472
let (responder, receiver) = std::sync::mpsc::sync_channel(0);
473-
self.0
474-
.send(LedgerRequestWithChan {
475-
request,
476-
responder: Some(responder),
477-
})
478-
.unwrap();
473+
if let Err(err) = self.0.send(LedgerRequestWithChan {
474+
request,
475+
responder: Some(responder),
476+
}) {
477+
eprintln!("Error sending request: {:?}", err);
478+
}
479479
receiver.recv()
480480
}
481481
}

0 commit comments

Comments
 (0)