fluencelabs/rust-libp2p
1
0
Fork 0
mirror of https://github.com/fluencelabs/rust-libp2p synced 2025-05-05 15:42:16 +00:00
Code Issues Projects Releases Wiki Activity

identify/handler: Improve property name (#2639)

Browse Source
This commit is contained in:
Elena Frank 2022-05-11 03:18:20 +02:00 committed by GitHub
parent 5cf68902ce
commit f04f6bb4fc
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
protocols/identify/src/handler.rs
View File

@ -50,12 +50,12 @@ pub struct IdentifyHandler {
>, >,
/// Future that fires when we need to identify the node again. /// Future that fires when we need to identify the node again.
next_id: Delay, trigger_next_identify: Delay,
/// Whether the handler should keep the connection alive. /// Whether the handler should keep the connection alive.
keep_alive: KeepAlive, keep_alive: KeepAlive,
/// The interval of `next_id`, i.e. the recurrent delay. /// The interval of `trigger_next_identify`, i.e. the recurrent delay.
interval: Duration, interval: Duration,
} }
@ -81,7 +81,7 @@ impl IdentifyHandler {
pub fn new(initial_delay: Duration, interval: Duration) -> Self { pub fn new(initial_delay: Duration, interval: Duration) -> Self {
IdentifyHandler { IdentifyHandler {
events: SmallVec::new(), events: SmallVec::new(),
next_id: Delay::new(initial_delay), trigger_next_identify: Delay::new(initial_delay),
keep_alive: KeepAlive::Yes, keep_alive: KeepAlive::Yes,
interval, interval,
} }
@ -165,7 +165,7 @@ impl ConnectionHandler for IdentifyHandler {
IdentifyHandlerEvent::IdentificationError(err), IdentifyHandlerEvent::IdentificationError(err),
)); ));
self.keep_alive = KeepAlive::No; self.keep_alive = KeepAlive::No;
self.next_id.reset(self.interval); self.trigger_next_identify.reset(self.interval);
} }
fn connection_keep_alive(&self) -> KeepAlive { fn connection_keep_alive(&self) -> KeepAlive {
@ -188,10 +188,10 @@ impl ConnectionHandler for IdentifyHandler {
} }
// Poll the future that fires when we need to identify the node again. // Poll the future that fires when we need to identify the node again.
match Future::poll(Pin::new(&mut self.next_id), cx) { match Future::poll(Pin::new(&mut self.trigger_next_identify), cx) {
Poll::Pending => Poll::Pending, Poll::Pending => Poll::Pending,
Poll::Ready(()) => { Poll::Ready(()) => {
self.next_id.reset(self.interval); self.trigger_next_identify.reset(self.interval);
let ev = ConnectionHandlerEvent::OutboundSubstreamRequest { let ev = ConnectionHandlerEvent::OutboundSubstreamRequest {
protocol: SubstreamProtocol::new(EitherUpgrade::A(IdentifyProtocol), ()), protocol: SubstreamProtocol::new(EitherUpgrade::A(IdentifyProtocol), ()),
}; };