Unverified Commit 05482b5b authored by Sergey Pepyakin's avatar Sergey Pepyakin Committed by GitHub
Browse files

Fix run_to_block functions (#2258)

parent 8ee122a7
Pipeline #119982 passed with stages
in 30 minutes and 54 seconds
...@@ -236,14 +236,14 @@ mod tests { ...@@ -236,14 +236,14 @@ mod tests {
while System::block_number() < to { while System::block_number() < to {
let b = System::block_number(); let b = System::block_number();
Dmp::initializer_finalize(); Dmp::initializer_finalize();
if new_session.as_ref().map_or(false, |v| v.contains(&(b + 1))) {
Dmp::initializer_on_new_session(&Default::default());
}
System::on_finalize(b); System::on_finalize(b);
System::on_initialize(b + 1); System::on_initialize(b + 1);
System::set_block_number(b + 1); System::set_block_number(b + 1);
if new_session.as_ref().map_or(false, |v| v.contains(&(b + 1))) {
Dmp::initializer_on_new_session(&Default::default());
}
Dmp::initializer_initialize(b + 1); Dmp::initializer_initialize(b + 1);
} }
} }
......
...@@ -280,7 +280,7 @@ decl_storage! { ...@@ -280,7 +280,7 @@ decl_storage! {
// NOTE that this field is used by parachains via merkle storage proofs, therefore changing // NOTE that this field is used by parachains via merkle storage proofs, therefore changing
// the format will require migration of parachains. // the format will require migration of parachains.
HrmpEgressChannelsIndex: map hasher(twox_64_concat) ParaId => Vec<ParaId>; HrmpEgressChannelsIndex: map hasher(twox_64_concat) ParaId => Vec<ParaId>;
/// Storage for the messages for each channel. /// Storage for the messages for each channel.
/// Invariant: cannot be non-empty if the corresponding channel in `HrmpChannels` is `None`. /// Invariant: cannot be non-empty if the corresponding channel in `HrmpChannels` is `None`.
HrmpChannelContents: map hasher(twox_64_concat) HrmpChannelId => Vec<InboundHrmpMessage<T::BlockNumber>>; HrmpChannelContents: map hasher(twox_64_concat) HrmpChannelId => Vec<InboundHrmpMessage<T::BlockNumber>>;
...@@ -1101,17 +1101,17 @@ mod tests { ...@@ -1101,17 +1101,17 @@ mod tests {
Hrmp::initializer_finalize(); Hrmp::initializer_finalize();
Paras::initializer_finalize(); Paras::initializer_finalize();
System::on_finalize(b);
System::on_initialize(b + 1);
System::set_block_number(b + 1);
if new_session.as_ref().map_or(false, |v| v.contains(&(b + 1))) { if new_session.as_ref().map_or(false, |v| v.contains(&(b + 1))) {
// NOTE: this is in initialization order. // NOTE: this is in initialization order.
Paras::initializer_on_new_session(&Default::default()); Paras::initializer_on_new_session(&Default::default());
Hrmp::initializer_on_new_session(&Default::default()); Hrmp::initializer_on_new_session(&Default::default());
} }
System::on_finalize(b);
System::on_initialize(b + 1);
System::set_block_number(b + 1);
// NOTE: this is in initialization order. // NOTE: this is in initialization order.
Paras::initializer_initialize(b + 1); Paras::initializer_initialize(b + 1);
Hrmp::initializer_initialize(b + 1); Hrmp::initializer_initialize(b + 1);
......
...@@ -1036,16 +1036,16 @@ mod tests { ...@@ -1036,16 +1036,16 @@ mod tests {
Inclusion::initializer_finalize(); Inclusion::initializer_finalize();
Paras::initializer_finalize(); Paras::initializer_finalize();
System::on_finalize(b);
System::on_initialize(b + 1);
System::set_block_number(b + 1);
if let Some(notification) = new_session(b + 1) { if let Some(notification) = new_session(b + 1) {
Paras::initializer_on_new_session(&notification); Paras::initializer_on_new_session(&notification);
Inclusion::initializer_on_new_session(&notification); Inclusion::initializer_on_new_session(&notification);
} }
System::on_finalize(b);
System::on_initialize(b + 1);
System::set_block_number(b + 1);
Paras::initializer_initialize(b + 1); Paras::initializer_initialize(b + 1);
Inclusion::initializer_initialize(b + 1); Inclusion::initializer_initialize(b + 1);
} }
......
...@@ -578,14 +578,14 @@ mod tests { ...@@ -578,14 +578,14 @@ mod tests {
while System::block_number() < to { while System::block_number() < to {
let b = System::block_number(); let b = System::block_number();
Paras::initializer_finalize(); Paras::initializer_finalize();
if new_session.as_ref().map_or(false, |v| v.contains(&(b + 1))) {
Paras::initializer_on_new_session(&Default::default());
}
System::on_finalize(b); System::on_finalize(b);
System::on_initialize(b + 1); System::on_initialize(b + 1);
System::set_block_number(b + 1); System::set_block_number(b + 1);
if new_session.as_ref().map_or(false, |v| v.contains(&(b + 1))) {
Paras::initializer_on_new_session(&Default::default());
}
Paras::initializer_initialize(b + 1); Paras::initializer_initialize(b + 1);
} }
} }
...@@ -1059,8 +1059,8 @@ mod tests { ...@@ -1059,8 +1059,8 @@ mod tests {
assert_eq!(<Paras as Store>::Heads::get(&para_id), Some(Default::default())); assert_eq!(<Paras as Store>::Heads::get(&para_id), Some(Default::default()));
} }
// run to block, with a session change at that block. // run to block №4, with a session change at the end of the block 3.
run_to_block(3, Some(vec![3])); run_to_block(4, Some(vec![4]));
// cleaning up the parachain should place the current parachain code // cleaning up the parachain should place the current parachain code
// into the past code buffer & schedule cleanup. // into the past code buffer & schedule cleanup.
......
...@@ -183,16 +183,16 @@ mod tests { ...@@ -183,16 +183,16 @@ mod tests {
SessionInfo::initializer_finalize(); SessionInfo::initializer_finalize();
Configuration::initializer_finalize(); Configuration::initializer_finalize();
System::on_finalize(b);
System::on_initialize(b + 1);
System::set_block_number(b + 1);
if let Some(notification) = new_session(b + 1) { if let Some(notification) = new_session(b + 1) {
Configuration::initializer_on_new_session(&notification.validators, &notification.queued); Configuration::initializer_on_new_session(&notification.validators, &notification.queued);
SessionInfo::initializer_on_new_session(&notification); SessionInfo::initializer_on_new_session(&notification);
} }
System::on_finalize(b);
System::on_initialize(b + 1);
System::set_block_number(b + 1);
Configuration::initializer_initialize(b + 1); Configuration::initializer_initialize(b + 1);
SessionInfo::initializer_initialize(b + 1); SessionInfo::initializer_initialize(b + 1);
} }
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment