mirror of
https://github.com/pezkuwichain/pezkuwi-subxt.git
synced 2026-06-01 02:11:01 +00:00
grandpa: fix slow gossip test (#4440)
This commit is contained in:
committed by
Robert Habermeier
parent
1fc3060feb
commit
1e550b3dac
@@ -274,16 +274,25 @@ fn good_commit_leads_to_relay() {
|
|||||||
let sender_id = id.clone();
|
let sender_id = id.clone();
|
||||||
let send_message = tester.filter_network_events(move |event| match event {
|
let send_message = tester.filter_network_events(move |event| match event {
|
||||||
Event::EventStream(sender) => {
|
Event::EventStream(sender) => {
|
||||||
|
// Add the sending peer and send the commit
|
||||||
let _ = sender.unbounded_send(NetworkEvent::NotificationStreamOpened {
|
let _ = sender.unbounded_send(NetworkEvent::NotificationStreamOpened {
|
||||||
remote: sender_id.clone(),
|
remote: sender_id.clone(),
|
||||||
engine_id: GRANDPA_ENGINE_ID,
|
engine_id: GRANDPA_ENGINE_ID,
|
||||||
roles: Roles::FULL,
|
roles: Roles::FULL,
|
||||||
});
|
});
|
||||||
|
|
||||||
let _ = sender.unbounded_send(NetworkEvent::NotificationsReceived {
|
let _ = sender.unbounded_send(NetworkEvent::NotificationsReceived {
|
||||||
remote: sender_id.clone(),
|
remote: sender_id.clone(),
|
||||||
messages: vec![(GRANDPA_ENGINE_ID, commit_to_send.clone().into())],
|
messages: vec![(GRANDPA_ENGINE_ID, commit_to_send.clone().into())],
|
||||||
});
|
});
|
||||||
|
|
||||||
|
// Add a random peer which will be the recipient of this message
|
||||||
|
let _ = sender.unbounded_send(NetworkEvent::NotificationStreamOpened {
|
||||||
|
remote: sc_network::PeerId::random(),
|
||||||
|
engine_id: GRANDPA_ENGINE_ID,
|
||||||
|
roles: Roles::FULL,
|
||||||
|
});
|
||||||
|
|
||||||
true
|
true
|
||||||
}
|
}
|
||||||
_ => false,
|
_ => false,
|
||||||
|
|||||||
Reference in New Issue
Block a user