pezkuwichain/pezkuwi-subxt
1
0
Fork 0
mirror of https://github.com/pezkuwichain/pezkuwi-subxt.git synced 2026-05-31 02:51:01 +00:00
Code Issues Packages Projects Releases Wiki Activity

Small opt when prune messages (#1389)

Browse Source 
* Small opt when prune messages

* Fix typing error
This commit is contained in:
echo
2022-05-06 16:54:21 +08:00
committed by Bastian Köcher
parent afb6fb6e5a
commit f2a8ca1d3e
1 changed files with 1 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
bridges/modules/messages/src/outbound_lane.rs
+1 -3
View File
@@ -148,19 +148,17 @@ impl<S: OutboundLaneStorage> OutboundLane<S> {
/// Returns number of pruned messages. /// Returns number of pruned messages.
pub fn prune_messages(&mut self, max_messages_to_prune: MessageNonce) -> MessageNonce { pub fn prune_messages(&mut self, max_messages_to_prune: MessageNonce) -> MessageNonce {
let mut pruned_messages = 0; let mut pruned_messages = 0;
let mut anything_changed = false;
let mut data = self.storage.data(); let mut data = self.storage.data();
while pruned_messages < max_messages_to_prune && while pruned_messages < max_messages_to_prune &&
data.oldest_unpruned_nonce <= data.latest_received_nonce data.oldest_unpruned_nonce <= data.latest_received_nonce
{ {
self.storage.remove_message(&data.oldest_unpruned_nonce); self.storage.remove_message(&data.oldest_unpruned_nonce);
anything_changed = true;
pruned_messages += 1; pruned_messages += 1;
data.oldest_unpruned_nonce += 1; data.oldest_unpruned_nonce += 1;
} }
if anything_changed { if pruned_messages > 0 {
self.storage.set_data(data); self.storage.set_data(data);
} }