aboutsummaryrefslogtreecommitdiffstats
path: root/src/ratelimiter.rs
diff options
context:
space:
mode:
authorJake McGinty <me@jake.su>2018-05-15 18:00:32 -0700
committerJake McGinty <me@jake.su>2018-05-15 18:00:32 -0700
commitf92f5df6e2c14e257fbcd90e8d9e8737d084c4cf (patch)
tree4bc5423b9360877f8bad6f98996326fbf04d9035 /src/ratelimiter.rs
parenttests: add test for rekey retry logic (diff)
downloadwireguard-rs-f92f5df6e2c14e257fbcd90e8d9e8737d084c4cf.tar.xz
wireguard-rs-f92f5df6e2c14e257fbcd90e8d9e8737d084c4cf.zip
global: fix clippies and enable warnings in IDE
Diffstat (limited to 'src/ratelimiter.rs')
-rw-r--r--src/ratelimiter.rs7
1 files changed, 3 insertions, 4 deletions
diff --git a/src/ratelimiter.rs b/src/ratelimiter.rs
index 299995e..18082b0 100644
--- a/src/ratelimiter.rs
+++ b/src/ratelimiter.rs
@@ -55,7 +55,7 @@ impl RateLimiter {
pub fn allow(&mut self, addr: &IpAddr) -> bool {
if let Some(entry) = self.table.get_mut(addr) {
- entry.tokens = MAX_TOKENS.min(entry.tokens + entry.last_time.elapsed().subsec_nanos() as u64);
+ entry.tokens = MAX_TOKENS.min(entry.tokens + u64::from(entry.last_time.elapsed().subsec_nanos()));
entry.last_time = Timestamp::now();
if entry.tokens > PACKET_COST {
@@ -83,9 +83,8 @@ impl Future for RateLimiter {
type Error = ();
fn poll(&mut self) -> Poll<Self::Item, Self::Error> {
- match self.rx.poll() {
- Ok(Async::Ready(Some(()))) => self.handle_gc(),
- _ => {},
+ if let Ok(Async::Ready(Some(()))) = self.rx.poll() {
+ self.handle_gc();
}
Ok(Async::NotReady)
}