Skip to content

Commit 99ac9ad

Browse files
committed
Prepare to use rldp2 in validator group
1 parent 4e02ba6 commit 99ac9ad

File tree

3 files changed

+8
-4
lines changed

3 files changed

+8
-4
lines changed

validator/manager.cpp

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2633,8 +2633,8 @@ td::actor::ActorOwn<ValidatorGroup> ValidatorManagerImpl::create_validator_group
26332633
descr->addr.is_zero() ? ValidatorFullId{descr->key}.compute_short_id().bits256_value() : descr->addr};
26342634
auto G = td::actor::create_actor<ValidatorGroup>(
26352635
PSTRING() << "valgroup" << shard.to_str(), shard, validator_id, session_id, validator_set, key_seqno, opts,
2636-
keyring_, adnl_, rldp_, overlays_, db_root_, actor_id(this), get_collation_manager(adnl_id), init_session,
2637-
opts_->check_unsafe_resync_allowed(validator_set->get_catchain_seqno()), opts_,
2636+
keyring_, adnl_, rldp_, rldp2_, overlays_, db_root_, actor_id(this), get_collation_manager(adnl_id),
2637+
init_session, opts_->check_unsafe_resync_allowed(validator_set->get_catchain_seqno()), opts_,
26382638
opts_->need_monitor(shard, last_masterchain_state_));
26392639
return G;
26402640
}

validator/validator-group.cpp

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -409,6 +409,7 @@ void ValidatorGroup::create_session() {
409409
}
410410

411411
td::actor::send_closure(rldp_, &rldp::Rldp::add_id, local_adnl_id_);
412+
td::actor::send_closure(rldp2_, &rldp2::Rldp::add_id, local_adnl_id_);
412413
}
413414

414415
void ValidatorGroup::start(std::vector<BlockIdExt> prev, BlockIdExt min_masterchain_block_id) {

validator/validator-group.hpp

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -24,6 +24,7 @@
2424
#include "validator-session/validator-session.h"
2525

2626
#include "rldp/rldp.h"
27+
#include "rldp2/rldp.h"
2728

2829
#include <list>
2930

@@ -77,8 +78,8 @@ class ValidatorGroup : public td::actor::Actor {
7778
td::Ref<ValidatorSet> validator_set, BlockSeqno last_key_block_seqno,
7879
validatorsession::ValidatorSessionOptions config, td::actor::ActorId<keyring::Keyring> keyring,
7980
td::actor::ActorId<adnl::Adnl> adnl, td::actor::ActorId<rldp::Rldp> rldp,
80-
td::actor::ActorId<overlay::Overlays> overlays, std::string db_root,
81-
td::actor::ActorId<ValidatorManager> validator_manager,
81+
td::actor::ActorId<rldp2::Rldp> rldp2, td::actor::ActorId<overlay::Overlays> overlays,
82+
std::string db_root, td::actor::ActorId<ValidatorManager> validator_manager,
8283
td::actor::ActorId<CollationManager> collation_manager, bool create_session,
8384
bool allow_unsafe_self_blocks_resync, td::Ref<ValidatorManagerOptions> opts, bool monitoring_shard)
8485
: shard_(shard)
@@ -90,6 +91,7 @@ class ValidatorGroup : public td::actor::Actor {
9091
, keyring_(keyring)
9192
, adnl_(adnl)
9293
, rldp_(rldp)
94+
, rldp2_(rldp2)
9395
, overlays_(overlays)
9496
, db_root_(std::move(db_root))
9597
, manager_(validator_manager)
@@ -131,6 +133,7 @@ class ValidatorGroup : public td::actor::Actor {
131133
td::actor::ActorId<keyring::Keyring> keyring_;
132134
td::actor::ActorId<adnl::Adnl> adnl_;
133135
td::actor::ActorId<rldp::Rldp> rldp_;
136+
td::actor::ActorId<rldp2::Rldp> rldp2_;
134137
td::actor::ActorId<overlay::Overlays> overlays_;
135138
std::string db_root_;
136139
td::actor::ActorId<ValidatorManager> manager_;

0 commit comments

Comments
 (0)