Fixed Ordering::Acquire -> Ordering::SeqCst typo

src/platform/dummy/bind.rs

@@ -7,7 +7,7 @@ use std::sync::Arc;
 use std::sync::Mutex;
 
 use super::super::bind::*;
-use super::super::Endpoint;
+
 use super::UnitEndpoint;
 
 pub struct VoidOwner {}

src/platform/dummy/tun.rs

@@ -1,3 +1,4 @@
+use std::cmp::min;
 use std::error::Error;
 use std::fmt;
 use std::sync::atomic::{AtomicUsize, Ordering};
@@ -84,9 +85,10 @@ impl Reader for TunReader {
 
     fn read(&self, buf: &mut [u8], offset: usize) -> Result<usize, Self::Error> {
         match self.rx.recv() {
-            Ok(m) => {
+            Ok(msg) => {
-                buf[offset..].copy_from_slice(&m[..]);
+                let n = min(buf.len() - offset, msg.len());
-                Ok(m.len())
+                buf[offset..offset + n].copy_from_slice(&msg[..n]);
+                Ok(n)
             }
             Err(_) => Err(TunError::Disconnected),
         }

src/wireguard/tests.rs

@@ -109,4 +109,6 @@ fn test_pure_wireguard() {
         "192.168.2.20".parse().unwrap(), // src
         "192.168.1.10".parse().unwrap(), // dst
     );
+
+    fake1.write(packet_p1_to_p2);
 }

src/wireguard/timers.rs

@@ -100,7 +100,7 @@ impl <B: bind::Bind>PeerInner<B> {
      */
     pub fn sent_handshake_initiation(&self) {
         *self.last_handshake.lock() = SystemTime::now();
-        self.handshake_queued.store(false, Ordering::Acquire);
+        self.handshake_queued.store(false, Ordering::SeqCst);
         self.timers_any_authenticated_packet_traversal();
         self.timers_any_authenticated_packet_sent();
     }