gsadmin/noq
1
0
Fork 0
mirror of https://github.com/n0-computer/noq.git synced 2026-09-25 04:35:17 +00:00
Code Issues Packages Projects Releases Wiki Activity

track sent add and remove address in stats and sent frames

Browse Source
This commit is contained in:
Diva Martínez
2025-11-20 10:41:01 -05:00
parent 9188107ec1
commit 25b20638e5
1 changed files with 11 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
quinn-proto/src/connection/mod.rs
+11
View File
@@ -5300,6 +5300,11 @@ impl Connection {
while space_id == SpaceId::Data && frame::AddAddress::SIZE_BOUND <= buf.remaining_mut() {
if let Some(added_address) = space.pending.add_address.pop_last() {
added_address.write(buf);
sent.retransmits
.get_or_create()
.add_address
.insert(added_address);
self.stats.frame_tx.add_address = self.stats.frame_tx.add_address.saturating_add(1);
} else {
break;
}
@@ -5308,6 +5313,12 @@ impl Connection {
while space_id == SpaceId::Data && frame::RemoveAddress::SIZE_BOUND <= buf.remaining_mut() {
if let Some(removed_address) = space.pending.remove_address.pop_last() {
removed_address.write(buf);
sent.retransmits
.get_or_create()
.remove_address
.insert(removed_address);
self.stats.frame_tx.remove_address =
self.stats.frame_tx.remove_address.saturating_add(1);
} else {
break;
}