Skip to content

Commit

Permalink
Use c++17
Browse files Browse the repository at this point in the history
  • Loading branch information
tvorogme committed Dec 16, 2024
1 parent e06e311 commit 6892954
Show file tree
Hide file tree
Showing 2 changed files with 12 additions and 9 deletions.
9 changes: 6 additions & 3 deletions validator/full-node-private-overlay.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -107,9 +107,12 @@ void FullNodePrivateBlockOverlay::process_telemetry_broadcast(
}
VLOG(FULL_NODE_DEBUG) << "Got telemetry broadcast from " << src;
auto s = td::json_encode<std::string>(td::ToJson(*telemetry), false);
std::erase_if(s, [](char c) {
return c == '\n' || c == '\r';
});
s.erase(
std::remove_if(s.begin(), s.end(), [](char c) {
return c == '\n' || c == '\r';
}),
s.end()
);
telemetry_file_ << s << "\n";
telemetry_file_.flush();
if (telemetry_file_.fail()) {
Expand Down
12 changes: 6 additions & 6 deletions validator/full-node.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -215,7 +215,7 @@ void FullNodeImpl::on_new_masterchain_block(td::Ref<MasterchainState> state, std
}
}
for (const auto &[wc, winfo] : state->get_workchain_list()) {
if (!workchains.contains(wc) && winfo->active && winfo->enabled_since <= state->get_unix_time()) {
if (workchains.find(wc) == workchains.end() && winfo->active && winfo->enabled_since <= state->get_unix_time()) {
all_shards.insert(ShardIdFull(wc));
}
}
Expand All @@ -231,14 +231,14 @@ void FullNodeImpl::on_new_masterchain_block(td::Ref<MasterchainState> state, std
}

for (auto it = shards_.begin(); it != shards_.end(); ) {
if (all_shards.contains(it->first)) {
if (all_shards.find(it->first) != all_shards.end()) {
++it;
} else {
it = shards_.erase(it);
}
}
for (ShardIdFull shard : all_shards) {
bool active = new_active.contains(shard);
bool active = new_active.find(shard) != new_active.end();
bool overlay_exists = !shards_[shard].actor.empty();
if (active || join_all_overlays || overlay_exists) {
update_shard_actor(shard, active);
Expand Down Expand Up @@ -290,7 +290,7 @@ void FullNodeImpl::send_ext_message(AccountIdPrefixFull dst, td::BufferSlice dat
for (auto &[_, private_overlay] : custom_overlays_) {
if (private_overlay.params_.send_shard(dst.as_leaf_shard())) {
for (auto &[local_id, actor] : private_overlay.actors_) {
if (private_overlay.params_.msg_senders_.contains(local_id)) {
if (private_overlay.params_.msg_senders_.find(local_id) != private_overlay.params_.msg_senders_.end()) {
td::actor::send_closure(actor, &FullNodeCustomOverlay::send_external_message, data.clone());
}
}
Expand Down Expand Up @@ -761,7 +761,7 @@ void FullNodeImpl::send_block_broadcast_to_custom_overlays(const BlockBroadcast
for (auto &[_, private_overlay] : custom_overlays_) {
if (private_overlay.params_.send_shard(broadcast.block_id.shard_full())) {
for (auto &[local_id, actor] : private_overlay.actors_) {
if (private_overlay.params_.block_senders_.contains(local_id)) {
if (private_overlay.params_.block_senders_.find(local_id) != private_overlay.params_.block_senders_.end()) {
td::actor::send_closure(actor, &FullNodeCustomOverlay::send_broadcast, broadcast.clone());
}
}
Expand All @@ -784,7 +784,7 @@ void FullNodeImpl::send_block_candidate_broadcast_to_custom_overlays(const Block
for (auto &[_, private_overlay] : custom_overlays_) {
if (private_overlay.params_.send_shard(block_id.shard_full())) {
for (auto &[local_id, actor] : private_overlay.actors_) {
if (private_overlay.params_.block_senders_.contains(local_id)) {
if (private_overlay.params_.block_senders_.find(local_id) != private_overlay.params_.block_senders_.end()) {
td::actor::send_closure(actor, &FullNodeCustomOverlay::send_block_candidate, block_id, cc_seqno,
validator_set_hash, data.clone());
}
Expand Down

0 comments on commit 6892954

Please sign in to comment.