Merge pull request #1 from Trivernis/develop

Develop

src/event/mod.rs

@@ -1,3 +1,9 @@
+/*
+ * vented asynchronous event based tcp server
+ * Copyright (C) 2020 trivernis
+ * See LICENSE for more information
+ */
+
 use async_std::io::{Read, ReadExt};
 
 use byteorder::{BigEndian, ByteOrder, ReadBytesExt};

src/event/tests.rs

@@ -1,3 +1,9 @@
+/*
+ * vented asynchronous event based tcp server
+ * Copyright (C) 2020 trivernis
+ * See LICENSE for more information
+ */
+
 use serde::{Deserialize, Serialize};
 
 use crate::event::Event;

src/event_handler/mod.rs

@@ -1,3 +1,9 @@
+/*
+ * vented asynchronous event based tcp server
+ * Copyright (C) 2020 trivernis
+ * See LICENSE for more information
+ */
+
 use std::collections::HashMap;
 
 use crate::event::Event;

src/event_handler/tests.rs

@@ -1,3 +1,9 @@
+/*
+ * vented asynchronous event based tcp server
+ * Copyright (C) 2020 trivernis
+ * See LICENSE for more information
+ */
+
 use std::sync::atomic::{AtomicUsize, Ordering};
 use std::sync::Arc;
 

src/lib.rs

@@ -1,3 +1,9 @@
+/*
+ * vented asynchronous event based tcp server
+ * Copyright (C) 2020 trivernis
+ * See LICENSE for more information
+ */
+
 #[macro_use]
 pub mod utils;
 

src/server/data.rs

@@ -1,3 +1,9 @@
+/*
+ * vented asynchronous event based tcp server
+ * Copyright (C) 2020 trivernis
+ * See LICENSE for more information
+ */
+
 use x25519_dalek::PublicKey;
 
 use std::time::{Duration, Instant};

src/server/mod.rs

@@ -1,3 +1,9 @@
+/*
+ * vented asynchronous event based tcp server
+ * Copyright (C) 2020 trivernis
+ * See LICENSE for more information
+ */
+
 use async_std::net::{TcpListener, TcpStream};
 use std::collections::HashMap;
 use std::iter::FromIterator;
@@ -30,6 +36,7 @@ pub mod server_events;
 
 pub(crate) const CRATE_VERSION: &str = env!("CARGO_PKG_VERSION");
 pub const PROTOCOL_VERSION: &str = "1.0";
+pub const RETRY_LIMIT: usize = 3;
 
 type ForwardFutureVector = Arc<Mutex<HashMap<(String, String), AsyncValue<CryptoStream, ()>>>>;
 
@@ -131,7 +138,22 @@ impl VentedServer {
     /// Emits an event to the specified Node
     #[inline]
     pub async fn emit<S: ToString>(&self, node_id: S, event: Event) -> VentedResult<()> {
-        self.send_event(&node_id.to_string(), event, true).await
+        let mut count = 0;
+        loop {
+            match self
+                .send_event(&node_id.to_string(), event.clone(), true)
+                .await
+            {
+                Ok(()) => return Ok(()),
+                Err(e) => {
+                    count += 1;
+                    log::warn!("Failed to send event on try {}: {}", count, e);
+                    if count == RETRY_LIMIT {
+                        return Err(e);
+                    }
+                }
+            }
+        }
     }
 
     /// Adds a handler for the given event.

src/server/server_events.rs

@@ -1,3 +1,9 @@
+/*
+ * vented asynchronous event based tcp server
+ * Copyright (C) 2020 trivernis
+ * See LICENSE for more information
+ */
+
 use std::sync::Arc;
 
 use rand::{thread_rng, RngCore};

src/stream/cryptostream.rs

@@ -1,3 +1,9 @@
+/*
+ * vented asynchronous event based tcp server
+ * Copyright (C) 2020 trivernis
+ * See LICENSE for more information
+ */
+
 use async_std::prelude::*;
 
 use byteorder::{BigEndian, ByteOrder};

src/stream/mod.rs

@@ -1,3 +1,9 @@
+/*
+ * vented asynchronous event based tcp server
+ * Copyright (C) 2020 trivernis
+ * See LICENSE for more information
+ */
+
 pub use crypto_box::PublicKey;
 pub use crypto_box::SecretKey;
 

src/utils/mod.rs

@@ -1,2 +1,8 @@
+/*
+ * vented asynchronous event based tcp server
+ * Copyright (C) 2020 trivernis
+ * See LICENSE for more information
+ */
+
 pub mod result;
 pub mod sync;

src/utils/result.rs

@@ -1,3 +1,9 @@
+/*
+ * vented asynchronous event based tcp server
+ * Copyright (C) 2020 trivernis
+ * See LICENSE for more information
+ */
+
 use std::error::Error;
 use std::{fmt, io};
 

src/utils/sync.rs

@@ -1,6 +1,12 @@
+/*
+ * vented asynchronous event based tcp server
+ * Copyright (C) 2020 trivernis
+ * See LICENSE for more information
+ */
+
+use std::mem;
 use std::sync::Arc;
 use std::time::{Duration, Instant};
-use std::{mem};
 
 use parking_lot::Mutex;