mirror of
https://github.com/fluencelabs/rust-libp2p
synced 2025-04-25 03:02:12 +00:00
Allow configuration of outbound substream in OneShotHandler. (#1521)
Co-authored-by: Pierre Krieger <pierre.krieger1708@gmail.com>
This commit is contained in:
parent
be970466b3
commit
6b4bdc1fe9
@ -54,8 +54,8 @@ where
|
||||
max_dial_negotiated: u32,
|
||||
/// Value to return from `connection_keep_alive`.
|
||||
keep_alive: KeepAlive,
|
||||
/// After the given duration has elapsed, an inactive connection will shutdown.
|
||||
inactive_timeout: Duration,
|
||||
/// The configuration container for the handler
|
||||
config: OneShotHandlerConfig,
|
||||
}
|
||||
|
||||
impl<TInProto, TOutProto, TOutEvent>
|
||||
@ -67,7 +67,7 @@ where
|
||||
#[inline]
|
||||
pub fn new(
|
||||
listen_protocol: SubstreamProtocol<TInProto>,
|
||||
inactive_timeout: Duration
|
||||
config: OneShotHandlerConfig,
|
||||
) -> Self {
|
||||
OneShotHandler {
|
||||
listen_protocol,
|
||||
@ -77,7 +77,7 @@ where
|
||||
dial_negotiated: 0,
|
||||
max_dial_negotiated: 8,
|
||||
keep_alive: KeepAlive::Yes,
|
||||
inactive_timeout,
|
||||
config
|
||||
}
|
||||
}
|
||||
|
||||
@ -121,7 +121,10 @@ where
|
||||
{
|
||||
#[inline]
|
||||
fn default() -> Self {
|
||||
OneShotHandler::new(SubstreamProtocol::new(Default::default()), Duration::from_secs(10))
|
||||
OneShotHandler::new(
|
||||
SubstreamProtocol::new(Default::default()),
|
||||
OneShotHandlerConfig::default()
|
||||
)
|
||||
}
|
||||
}
|
||||
|
||||
@ -157,7 +160,7 @@ where
|
||||
) {
|
||||
// If we're shutting down the connection for inactivity, reset the timeout.
|
||||
if !self.keep_alive.is_yes() {
|
||||
self.keep_alive = KeepAlive::Until(Instant::now() + self.inactive_timeout);
|
||||
self.keep_alive = KeepAlive::Until(Instant::now() + self.config.inactive_timeout);
|
||||
}
|
||||
|
||||
self.events_out.push(out.into());
|
||||
@ -172,7 +175,7 @@ where
|
||||
self.dial_negotiated -= 1;
|
||||
|
||||
if self.dial_negotiated == 0 && self.dial_queue.is_empty() {
|
||||
self.keep_alive = KeepAlive::Until(Instant::now() + self.inactive_timeout);
|
||||
self.keep_alive = KeepAlive::Until(Instant::now() + self.config.inactive_timeout);
|
||||
}
|
||||
|
||||
self.events_out.push(out.into());
|
||||
@ -224,7 +227,8 @@ where
|
||||
self.dial_negotiated += 1;
|
||||
return Poll::Ready(
|
||||
ProtocolsHandlerEvent::OutboundSubstreamRequest {
|
||||
protocol: SubstreamProtocol::new(self.dial_queue.remove(0)),
|
||||
protocol: SubstreamProtocol::new(self.dial_queue.remove(0))
|
||||
.with_timeout(self.config.substream_timeout),
|
||||
info: (),
|
||||
},
|
||||
);
|
||||
@ -236,3 +240,21 @@ where
|
||||
Poll::Pending
|
||||
}
|
||||
}
|
||||
|
||||
/// Configuration parameters for the `OneShotHandler`
|
||||
#[derive(Debug)]
|
||||
pub struct OneShotHandlerConfig {
|
||||
/// After the given duration has elapsed, an inactive connection will shutdown.
|
||||
inactive_timeout: Duration,
|
||||
/// Timeout duration for each newly opened outbound substream.
|
||||
substream_timeout: Duration,
|
||||
}
|
||||
|
||||
impl Default for OneShotHandlerConfig {
|
||||
fn default() -> Self {
|
||||
let inactive_timeout = Duration::from_secs(10);
|
||||
let substream_timeout = Duration::from_secs(10);
|
||||
OneShotHandlerConfig { inactive_timeout, substream_timeout }
|
||||
}
|
||||
}
|
||||
|
||||
|
Loading…
x
Reference in New Issue
Block a user