diff --git a/dtls/examples/listen/psk/listen_psk.rs b/dtls/examples/listen/psk/listen_psk.rs index fc536bb6e..12e1555be 100644 --- a/dtls/examples/listen/psk/listen_psk.rs +++ b/dtls/examples/listen/psk/listen_psk.rs @@ -77,7 +77,7 @@ async fn main() -> Result<(), Error> { let listener2 = Arc::clone(&listener); let h2 = Arc::clone(&h); tokio::spawn(async move { - while let Ok((dtls_conn, _remote_addr)) = listener2.accept().await { + while let Ok((dtls_conn, _ctx, _remote_addr)) = listener2.accept().await { // Register the connection with the chat hub h2.register(dtls_conn).await; } diff --git a/dtls/examples/listen/selfsign/listen_selfsign.rs b/dtls/examples/listen/selfsign/listen_selfsign.rs index 19a54fdc9..4ef5d417d 100644 --- a/dtls/examples/listen/selfsign/listen_selfsign.rs +++ b/dtls/examples/listen/selfsign/listen_selfsign.rs @@ -75,7 +75,7 @@ async fn main() -> Result<(), Error> { let listener2 = Arc::clone(&listener); let h2 = Arc::clone(&h); tokio::spawn(async move { - while let Ok((dtls_conn, _remote_addr)) = listener2.accept().await { + while let Ok((dtls_conn, _ctx, _remote_addr)) = listener2.accept().await { // Register the connection with the chat hub h2.register(dtls_conn).await; } diff --git a/dtls/examples/listen/verify/listen_verify.rs b/dtls/examples/listen/verify/listen_verify.rs index a9aeef980..2e75ff8e6 100644 --- a/dtls/examples/listen/verify/listen_verify.rs +++ b/dtls/examples/listen/verify/listen_verify.rs @@ -96,7 +96,7 @@ async fn main() -> Result<(), Error> { } result = listener2.accept() => { match result{ - Ok((dtls_conn, _)) => { + Ok((dtls_conn, _ctx, _)) => { // Register the connection with the chat hub h2.register(dtls_conn).await; } diff --git a/util/src/conn/conn_udp_listener_test.rs b/util/src/conn/conn_udp_listener_test.rs index 3ac0a93c0..4661a258c 100644 --- a/util/src/conn/conn_udp_listener_test.rs +++ b/util/src/conn/conn_udp_listener_test.rs @@ -27,7 +27,7 @@ async fn pipe() -> Result<( let daddr = d_conn.local_addr()?; // Accept the connection - let (l_conn, raddr) = listener.accept().await?; + let (l_conn, _ctx, raddr) = listener.accept().await?; assert_eq!(daddr, raddr, "remote address should be match"); let raddr = l_conn.remote_addr(); @@ -119,7 +119,7 @@ async fn test_listener_accept_filter() -> Result<()> { let listener2 = Arc::clone(&listener); tokio::spawn(async move { let (c, _raddr) = match listener2.accept().await { - Ok((c, raddr)) => (c, raddr), + Ok((c, _ctx, raddr)) => (c, raddr), Err(err) => { assert_eq!(Error::ErrClosedListener, err); return Result::<()>::Ok(()); @@ -179,7 +179,7 @@ async fn test_listener_concurrent() -> Result<()> { let mut b = vec![0u8; 1]; for i in 0..BACKLOG as u8 { - let (conn, _raddr) = listener.accept().await?; + let (conn, _ctx, _raddr) = listener.accept().await?; let n = conn.recv(&mut b).await?; assert_eq!( &b[..n], @@ -197,7 +197,7 @@ async fn test_listener_concurrent() -> Result<()> { let listener2 = Arc::clone(&listener); tokio::spawn(async move { match listener2.accept().await { - Ok((conn, _raddr)) => { + Ok((conn, _ctx, _raddr)) => { conn.close().await?; } Err(err) => {