From 94fd2db4e223ca3e0fcf8ed12e2151ca3ecf97b3 Mon Sep 17 00:00:00 2001 From: Monica Moniot Date: Thu, 27 Jul 2023 09:39:17 -0400 Subject: [PATCH] added polish --- src/lib.rs | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/lib.rs b/src/lib.rs index 72f210d..d44dfc1 100644 --- a/src/lib.rs +++ b/src/lib.rs @@ -12,7 +12,7 @@ pub trait ApplicationLayer: Sized { fn send_empty_reply(&self, reply_num: SeqNum); fn deserialize<'a>(data: &'a Self::RecvData) -> Self::RecvDataRef<'a>; - fn process(&self, packet: Self::RecvDataRef<'_>, reply: ReplyGuard<'_, Self>, send_data: Option) -> Self::RecvReturn; + fn process(&self, reply_cx: ReplyGuard<'_, Self>, recv_packet: Self::RecvDataRef<'_>, send_data: Option) -> Self::RecvReturn; } pub trait IntoRecvData: Into { @@ -143,7 +143,7 @@ impl SeqQueue { // This should reliably handle sequence number overflow. self.pre_recv_seq_num = seq_num; let data = reply_num.and_then(|r| self.take_send(r)); - Ok(app.process(packet.as_ref(), ReplyGuard { app: Some(&app), seq_queue: self, reply_num: seq_num }, data)) + Ok(app.process(ReplyGuard { app: Some(&app), seq_queue: self, reply_num: seq_num }, packet.as_ref(), data)) } else { self.recv_window[i] = Some(RecvEntry { seq_num, reply_num, data: packet.into() }); if let Some(reply_num) = reply_num { @@ -174,8 +174,8 @@ impl SeqQueue { let entry = self.recv_window[i].take().unwrap(); let data = entry.reply_num.and_then(|r| self.take_send(r)); Ok(app.process( - App::deserialize(&entry.data), ReplyGuard { app: Some(&app), seq_queue: self, reply_num: entry.seq_num }, + App::deserialize(&entry.data), data, )) } else {