1
0
Fork 0
mirror of https://github.com/ton-blockchain/ton synced 2025-02-13 11:42:18 +00:00
This commit is contained in:
SpyCheese 2023-01-13 19:04:11 +03:00
parent 29851c38ef
commit d324fa5820
2 changed files with 8 additions and 6 deletions

View file

@ -24,7 +24,9 @@ namespace overlay {
void OverlayImpl::del_peer(adnl::AdnlNodeIdShort id) { void OverlayImpl::del_peer(adnl::AdnlNodeIdShort id) {
auto P = peers_.get(id); auto P = peers_.get(id);
CHECK(P != nullptr); if (P == nullptr) {
return;
}
VLOG(OVERLAY_DEBUG) << this << ": deleting peer " << id; VLOG(OVERLAY_DEBUG) << this << ": deleting peer " << id;

View file

@ -177,7 +177,7 @@ void WaitOutMsgQueueProof::run_local() {
[SelfId = actor_id(this)](td::Result<Ref<ShardState>> R) { [SelfId = actor_id(this)](td::Result<Ref<ShardState>> R) {
if (R.is_error()) { if (R.is_error()) {
td::actor::send_closure(SelfId, &WaitOutMsgQueueProof::abort_query, td::actor::send_closure(SelfId, &WaitOutMsgQueueProof::abort_query,
R.move_as_error_prefix("failed to get shard state")); R.move_as_error_prefix("failed to get shard state: "));
} else { } else {
td::actor::send_closure(SelfId, &WaitOutMsgQueueProof::got_state_root, td::actor::send_closure(SelfId, &WaitOutMsgQueueProof::got_state_root,
R.move_as_ok()->root_cell()); R.move_as_ok()->root_cell());
@ -189,7 +189,7 @@ void WaitOutMsgQueueProof::run_local() {
[SelfId = actor_id(this)](td::Result<Ref<BlockData>> R) { [SelfId = actor_id(this)](td::Result<Ref<BlockData>> R) {
if (R.is_error()) { if (R.is_error()) {
td::actor::send_closure(SelfId, &WaitOutMsgQueueProof::abort_query, td::actor::send_closure(SelfId, &WaitOutMsgQueueProof::abort_query,
R.move_as_error_prefix("failed to get block data")); R.move_as_error_prefix("failed to get block data: "));
} else { } else {
td::actor::send_closure(SelfId, &WaitOutMsgQueueProof::got_block_root, td::actor::send_closure(SelfId, &WaitOutMsgQueueProof::got_block_root,
R.move_as_ok()->root_cell()); R.move_as_ok()->root_cell());
@ -247,7 +247,7 @@ void WaitOutMsgQueueProof::run_net() {
void BuildOutMsgQueueProof::abort_query(td::Status reason) { void BuildOutMsgQueueProof::abort_query(td::Status reason) {
if (promise_) { if (promise_) {
LOG(WARNING) << "failed to build msg queue proof for " << block_id_.to_str() << ": " << reason; LOG(DEBUG) << "failed to build msg queue proof for " << block_id_.to_str() << ": " << reason;
promise_.set_error( promise_.set_error(
reason.move_as_error_prefix(PSTRING() << "failed to build msg queue proof for " << block_id_.to_str() << ": ")); reason.move_as_error_prefix(PSTRING() << "failed to build msg queue proof for " << block_id_.to_str() << ": "));
} }
@ -260,7 +260,7 @@ void BuildOutMsgQueueProof::start_up() {
[SelfId = actor_id(this)](td::Result<Ref<ShardState>> R) { [SelfId = actor_id(this)](td::Result<Ref<ShardState>> R) {
if (R.is_error()) { if (R.is_error()) {
td::actor::send_closure(SelfId, &BuildOutMsgQueueProof::abort_query, td::actor::send_closure(SelfId, &BuildOutMsgQueueProof::abort_query,
R.move_as_error_prefix("failed to get shard state")); R.move_as_error_prefix("failed to get shard state: "));
} else { } else {
td::actor::send_closure(SelfId, &BuildOutMsgQueueProof::got_state_root, td::actor::send_closure(SelfId, &BuildOutMsgQueueProof::got_state_root,
R.move_as_ok()->root_cell()); R.move_as_ok()->root_cell());
@ -272,7 +272,7 @@ void BuildOutMsgQueueProof::start_up() {
[SelfId = actor_id(this)](td::Result<Ref<BlockData>> R) { [SelfId = actor_id(this)](td::Result<Ref<BlockData>> R) {
if (R.is_error()) { if (R.is_error()) {
td::actor::send_closure(SelfId, &BuildOutMsgQueueProof::abort_query, td::actor::send_closure(SelfId, &BuildOutMsgQueueProof::abort_query,
R.move_as_error_prefix("failed to get block data")); R.move_as_error_prefix("failed to get block data: "));
} else { } else {
td::actor::send_closure(SelfId, &BuildOutMsgQueueProof::got_block_root, td::actor::send_closure(SelfId, &BuildOutMsgQueueProof::got_block_root,
R.move_as_ok()->root_cell()); R.move_as_ok()->root_cell());