bump version to 0.2.3

CHANGELOG.md

@@ -6,6 +6,10 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ## [Unreleased]
 
+## [v0.2.3] - 2020-04-08
+### Fixed
+- fix interval timings concurrent pings
+
 ## [v0.2.2] - 2020-04-06
 ### Added
 - added documentation to the sample config file

Cargo.lock

@@ -430,7 +430,7 @@ dependencies = [
 
 [[package]]
 name = "peshming"
-version = "0.2.2"
+version = "0.2.3"
 dependencies = [
  "chrono 0.4.11 (registry+https://github.com/rust-lang/crates.io-index)",
  "clap 2.33.0 (registry+https://github.com/rust-lang/crates.io-index)",

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "peshming"
-version = "0.2.2"
+version = "0.2.3"
 authors = ["Jan Christian Grünhage <jan.christian@gruenhage.xyz>"]
 edition = "2018"
 description = "Pings configured hosts in a configurable intervals and exposes metrics for prometheus."

README.md

@@ -10,7 +10,7 @@ someone comes up with something better.
 ### Usage:
 ```
 $ peshming --help
-peshming 0.2.2
+peshming 0.2.3
 Jan Christian Grünhage <jan.christian@gruenhage.xyz>
 Pings configured hosts in a configurable intervals and exposes metrics for prometheus.
 

src/ping.rs

@@ -18,13 +18,12 @@
  *   along with this program.  If not, see <https://www.gnu.org/licenses/>.     *
  ********************************************************************************/
 use crate::config::Config;
-use futures_util::stream::StreamExt;
 use lazy_static::lazy_static;
 use log::{error, info, trace};
 use prometheus::*;
 use std::net::IpAddr;
 use std::time::Duration;
-use tokio_ping::Pinger;
+use tokio_ping::{PingFuture, Pinger};
 
 lazy_static! {
     static ref PING_HISTOGRAM: HistogramVec = register_histogram_vec!(
@@ -58,21 +57,17 @@ pub(crate) async fn start_pinging_hosts(
 }
 
 async fn ping_host(pinger: Pinger, host: IpAddr, interval: u64) {
-    let pingchain = pinger.chain(host).timeout(Duration::from_secs(3));
-    let host = host.to_string();
-    let mut stream = pingchain.stream();
+    let mut pingchain = pinger.chain(host).timeout(Duration::from_secs(3));
     let mut interval = tokio::time::interval(Duration::from_millis(interval));
+    let host_string = host.to_string();
     loop {
         interval.tick().await;
-        handle_ping_result(stream.next().await.unwrap(), &host).await;
+        tokio::spawn(handle_ping_result(pingchain.send(), host_string.clone()));
     }
 }
 
-async fn handle_ping_result(
-    result: std::result::Result<Option<Duration>, tokio_ping::Error>,
-    host: &str,
-) {
-    let pong = match result {
+async fn handle_ping_result(result: PingFuture, host: String) {
+    let pong = match result.await {
         Ok(pong) => pong,
         Err(error) => {
             error!("Couldn't ping {}: {}", &host, error);