Retry

neqo-client/src/main.rs

@@ -8,11 +8,14 @@
 use neqo_common::{matches, Datagram};
 use neqo_crypto::{init, AuthenticationStatus};
 use neqo_http3::{Header, Http3Connection, Http3Event, Http3State, Output};
-use neqo_transport::Connection;
+use neqo_transport::{Connection, FixedConnectionIdManager};
+
+use std::cell::RefCell;
 use std::collections::HashSet;
 use std::io::{self, ErrorKind};
 use std::net::{IpAddr, Ipv4Addr, Ipv6Addr, SocketAddr, ToSocketAddrs, UdpSocket};
 use std::process::exit;
+use std::rc::Rc;
 use std::time::Instant;
 use structopt::StructOpt;
 use url::Url;
@@ -241,6 +244,7 @@ fn client(args: Args, socket: UdpSocket, local_addr: SocketAddr, remote_addr: So
         Connection::new_client(
             args.url.host_str().unwrap(),
             &args.alpn,
+            Rc::new(RefCell::new(FixedConnectionIdManager::new(0))),
             local_addr,
             remote_addr,
         )
@@ -319,13 +323,17 @@ fn main() {
 }
 
 mod old {
+    use std::cell::RefCell;
     use std::collections::HashSet;
     use std::net::{SocketAddr, UdpSocket};
     use std::process::exit;
+    use std::rc::Rc;
     use std::time::Instant;
 
     use neqo_common::Datagram;
-    use neqo_transport::{Connection, ConnectionEvent, State, StreamType};
+    use neqo_transport::{
+        Connection, ConnectionEvent, FixedConnectionIdManager, State, StreamType,
+    };
 
     use super::{emit_datagram, Args};
 
@@ -443,6 +451,7 @@ mod old {
         let mut client = Connection::new_client(
             args.url.host_str().unwrap(),
             &["http/0.9"],
+            Rc::new(RefCell::new(FixedConnectionIdManager::new(0))),
             local_addr,
             remote_addr,
         )

neqo-common/Cargo.toml

@@ -8,4 +8,4 @@ edition = "2018"
 num-traits = "0.2"
 log = "0.4.0"
 env_logger = "0.6.1"
-lazy_static = "1.2.0"
+lazy_static = "1.3.0"

neqo-common/src/lib.rs

@@ -11,6 +11,7 @@ mod datagram;
 mod incrdecoder;
 pub mod log;
 pub mod once;
+pub mod timer;
 
 pub use self::codec::{Decoder, Encoder};
 pub use self::datagram::Datagram;