mirror of
https://github.com/0glabs/0g-storage-node.git
synced 2024-11-20 15:05:19 +00:00
Compare commits
4 Commits
8978b59b73
...
87b58a1b67
Author | SHA1 | Date | |
---|---|---|---|
|
87b58a1b67 | ||
|
a4dd88f2b8 | ||
|
3dc3d0574f | ||
|
ffcd9c0b25 |
@ -210,7 +210,7 @@ impl PoraService {
|
||||
let timer = time::Instant::now();
|
||||
|
||||
if let Some(answer) = miner.batch_iteration(nonce, self.iter_batch).await {
|
||||
debug!("Hit Pora answer {:?}", answer);
|
||||
info!("Hit Pora answer {:?}", answer);
|
||||
if self.mine_answer_sender.send(answer).is_err() {
|
||||
warn!("Mine submitter channel closed");
|
||||
}
|
||||
|
@ -100,7 +100,7 @@ async fn request_miner_id(
|
||||
.retries(3)
|
||||
.await
|
||||
.map_err(|e| format!("Fail to execute mine answer transaction: {:?}", e))?
|
||||
.ok_or("Request miner id transaction dropped after 3 retires")?;
|
||||
.ok_or("Request miner id transaction dropped after 3 retries")?;
|
||||
|
||||
let first_log = receipt
|
||||
.logs
|
||||
|
@ -167,12 +167,11 @@ impl Submitter {
|
||||
.await
|
||||
.map_err(|e| format!("Fail to execute mine answer transaction: {:?}", e))?
|
||||
.ok_or(format!(
|
||||
"Mine answer transaction dropped after {} retires",
|
||||
"Mine answer transaction dropped after {} retries",
|
||||
SUBMISSION_RETIES
|
||||
))?;
|
||||
|
||||
info!("Submit PoRA success");
|
||||
debug!("Receipt: {:?}", receipt);
|
||||
info!("Submit PoRA success, receipt: {:?}", receipt);
|
||||
|
||||
Ok(())
|
||||
}
|
||||
|
Loading…
Reference in New Issue
Block a user