Adding upstream version 1:115.7.0.upstream/1%115.7.0upstream

Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>

1 files changed, 178 insertions, 0 deletions

diff --git a/third_party/rust/neqo-transport/tests/network.rs b/third_party/rust/neqo-transport/tests/network.rs
new file mode 100644
index 0000000000..8b52e2ca8e
--- /dev/null
+++ b/third_party/rust/neqo-transport/tests/network.rs
@@ -0,0 +1,178 @@
+// Licensed under the Apache License, Version 2.0 <LICENSE-APACHE or
+// http://www.apache.org/licenses/LICENSE-2.0> or the MIT license
+// <LICENSE-MIT or http://opensource.org/licenses/MIT>, at your
+// option. This file may not be copied, modified, or distributed
+// except according to those terms.
+
+#![cfg_attr(feature = "deny-warnings", deny(warnings))]
+#![warn(clippy::pedantic)]
+
+#[macro_use]
+mod sim;
+
+use neqo_transport::{ConnectionError, ConnectionParameters, Error, State};
+use sim::{
+    connection::{ConnectionNode, ReachState, ReceiveData, SendData},
+    network::{Delay, Drop, TailDrop},
+    Simulator,
+};
+use std::ops::Range;
+use std::time::Duration;
+
+/// The amount of transfer.  Much more than this takes a surprising amount of time.
+const TRANSFER_AMOUNT: usize = 1 << 20; // 1M
+const ZERO: Duration = Duration::from_millis(0);
+const DELAY: Duration = Duration::from_millis(50);
+const DELAY_RANGE: Range<Duration> = DELAY..Duration::from_millis(55);
+const JITTER: Duration = Duration::from_millis(10);
+
+const fn weeks(m: u32) -> Duration {
+    Duration::from_secs((m as u64) * 60 * 60 * 24 * 7)
+}
+
+simulate!(
+    connect_direct,
+    [
+        ConnectionNode::default_client(boxed![ReachState::new(State::Confirmed)]),
+        ConnectionNode::default_server(boxed![ReachState::new(State::Confirmed)]),
+    ]
+);
+
+simulate!(
+    idle_timeout,
+    [
+        ConnectionNode::default_client(boxed![
+            ReachState::new(State::Confirmed),
+            ReachState::new(State::Closed(ConnectionError::Transport(
+                Error::IdleTimeout
+            )))
+        ]),
+        ConnectionNode::default_server(boxed![
+            ReachState::new(State::Confirmed),
+            ReachState::new(State::Closed(ConnectionError::Transport(
+                Error::IdleTimeout
+            )))
+        ]),
+    ]
+);
+
+simulate!(
+    idle_timeout_crazy_rtt,
+    [
+        ConnectionNode::new_client(
+            ConnectionParameters::default().idle_timeout(weeks(1000)),
+            boxed![
+                ReachState::new(State::Confirmed),
+                ReachState::new(State::Closed(ConnectionError::Transport(
+                    Error::IdleTimeout
+                )))
+            ]
+        ),
+        Delay::new(weeks(150)..weeks(150)),
+        Drop::percentage(10),
+        ConnectionNode::new_server(
+            ConnectionParameters::default().idle_timeout(weeks(1000)),
+            boxed![
+                ReachState::new(State::Confirmed),
+                ReachState::new(State::Closed(ConnectionError::Transport(
+                    Error::IdleTimeout
+                )))
+            ]
+        ),
+        Delay::new(weeks(100)..weeks(100)),
+        Drop::percentage(10),
+    ],
+);
+
+simulate!(
+    transfer,
+    [
+        ConnectionNode::default_client(boxed![SendData::new(TRANSFER_AMOUNT)]),
+        ConnectionNode::default_server(boxed![ReceiveData::new(TRANSFER_AMOUNT)]),
+    ]
+);
+
+simulate!(
+    connect_fixed_rtt,
+    [
+        ConnectionNode::default_client(boxed![ReachState::new(State::Confirmed)]),
+        Delay::new(DELAY..DELAY),
+        ConnectionNode::default_server(boxed![ReachState::new(State::Confirmed)]),
+        Delay::new(DELAY..DELAY),
+    ],
+);
+
+simulate!(
+    connect_taildrop_jitter,
+    [
+        ConnectionNode::default_client(boxed![ReachState::new(State::Confirmed)]),
+        TailDrop::dsl_uplink(),
+        Delay::new(ZERO..JITTER),
+        ConnectionNode::default_server(boxed![ReachState::new(State::Confirmed)]),
+        TailDrop::dsl_downlink(),
+        Delay::new(ZERO..JITTER),
+    ],
+);
+
+simulate!(
+    connect_taildrop,
+    [
+        ConnectionNode::default_client(boxed![ReachState::new(State::Confirmed)]),
+        TailDrop::dsl_uplink(),
+        ConnectionNode::default_server(boxed![ReachState::new(State::Confirmed)]),
+        TailDrop::dsl_downlink(),
+    ],
+);
+
+simulate!(
+    transfer_delay_drop,
+    [
+        ConnectionNode::default_client(boxed![SendData::new(TRANSFER_AMOUNT)]),
+        Delay::new(DELAY_RANGE),
+        Drop::percentage(1),
+        ConnectionNode::default_server(boxed![ReceiveData::new(TRANSFER_AMOUNT)]),
+        Delay::new(DELAY_RANGE),
+        Drop::percentage(1),
+    ],
+);
+
+simulate!(
+    transfer_taildrop,
+    [
+        ConnectionNode::default_client(boxed![SendData::new(TRANSFER_AMOUNT)]),
+        TailDrop::dsl_uplink(),
+        ConnectionNode::default_server(boxed![ReceiveData::new(TRANSFER_AMOUNT)]),
+        TailDrop::dsl_downlink(),
+    ],
+);
+
+simulate!(
+    transfer_taildrop_jitter,
+    [
+        ConnectionNode::default_client(boxed![SendData::new(TRANSFER_AMOUNT)]),
+        TailDrop::dsl_uplink(),
+        Delay::new(ZERO..JITTER),
+        ConnectionNode::default_server(boxed![ReceiveData::new(TRANSFER_AMOUNT)]),
+        TailDrop::dsl_downlink(),
+        Delay::new(ZERO..JITTER),
+    ],
+);
+
+/// This test is a nasty piece of work.  Delays are anything from 0 to 50ms and 1% of
+/// packets get dropped.
+#[test]
+fn transfer_fixed_seed() {
+    let mut sim = Simulator::new(
+        "transfer_fixed_seed",
+        boxed![
+            ConnectionNode::default_client(boxed![SendData::new(TRANSFER_AMOUNT)]),
+            Delay::new(ZERO..DELAY),
+            Drop::percentage(1),
+            ConnectionNode::default_server(boxed![ReceiveData::new(TRANSFER_AMOUNT)]),
+            Delay::new(ZERO..DELAY),
+            Drop::percentage(1),
+        ],
+    );
+    sim.seed_str("117f65d90ee5c1a7fb685f3af502c7730ba5d31866b758d98f5e3c2117cf9b86");
+    sim.run();
+}