Skip to content

Commit

Permalink
remove
Browse files Browse the repository at this point in the history
  • Loading branch information
iceseer committed Jun 21, 2023
1 parent 004722c commit ac467ce
Showing 1 changed file with 0 additions and 28 deletions.
28 changes: 0 additions & 28 deletions core/parachain/validator/impl/parachain_processor.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -189,34 +189,6 @@ namespace kagome::parachain {
}
});

remote_view_sub_ = std::make_shared<network::PeerView::PeerViewSubscriber>(
peer_view_->getRemoteViewObservable(), false);
remote_view_sub_->subscribe(remote_view_sub_->generateSubscriptionSetId(),
network::PeerView::EventType::kViewUpdated);
remote_view_sub_->setCallback(
[wptr{weak_from_this()}](auto /*set_id*/,
auto && /*internal_obj*/,
auto /*event_type*/,
const libp2p::peer::PeerId &peer_id,
const network::View &view) {
if (auto self = wptr.lock()) {
/// clear caches
BOOST_ASSERT(
self->this_context_->get_executor().running_in_this_thread());

if (auto r = self->canProcessParachains(); r.has_error()) {
return;
}

SL_TRACE(self->logger_,
"Update remote view.(peer={}, finalized={}, leaves={})",
peer_id,
view.finalized_number_,
view.heads_.size());
self->broadcastViewExcept(peer_id, view);
}
});

my_view_sub_ = std::make_shared<network::PeerView::MyViewSubscriber>(
peer_view_->getMyViewObservable(), false);
my_view_sub_->subscribe(my_view_sub_->generateSubscriptionSetId(),
Expand Down

0 comments on commit ac467ce

Please sign in to comment.