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

Move conn_ready() around to improve readability

Browse Source
This commit is contained in:
Dirkjan Ochtman
2019-01-17 16:26:05 +01:00
parent 5ee5d5d5ee
commit ea7aa02091
1 changed files with 19 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files
quinn-proto/src/endpoint.rs
+19 -19
View File
@@ -186,25 +186,6 @@ impl Endpoint {
}
}
/// Connection is either ready to accept data or failed.
fn conn_ready(&mut self, ch: ConnectionHandle) {
if self.connections[ch].side().is_server() {
self.incoming_handshakes -= 1;
self.incoming.push_back(ch);
}
if self.config.local_cid_len != 0 && !self.connections[ch].is_closed() {
/// Draft 17 §5.1.1: endpoints SHOULD provide and maintain at least eight
/// connection IDs
const LOCAL_CID_COUNT: usize = 8;
// We've already issued one CID as part of the normal handshake process.
for _ in 1..LOCAL_CID_COUNT {
let cid = self.new_cid();
self.connection_ids.insert(cid, ch);
self.connections[ch].issue_cid(cid);
}
}
}
fn handle_decode(
&mut self,
now: u64,
@@ -593,6 +574,25 @@ impl Endpoint {
}
}
/// Connection is either ready to accept data or failed.
fn conn_ready(&mut self, ch: ConnectionHandle) {
if self.connections[ch].side().is_server() {
self.incoming_handshakes -= 1;
self.incoming.push_back(ch);
}
if self.config.local_cid_len != 0 && !self.connections[ch].is_closed() {
/// Draft 17 §5.1.1: endpoints SHOULD provide and maintain at least eight
/// connection IDs
const LOCAL_CID_COUNT: usize = 8;
// We've already issued one CID as part of the normal handshake process.
for _ in 1..LOCAL_CID_COUNT {
let cid = self.new_cid();
self.connection_ids.insert(cid, ch);
self.connections[ch].issue_cid(cid);
}
}
}
fn forget(&mut self, ch: ConnectionHandle) {
if self.connections[ch].side().is_server() {
self.connection_ids_initial