Ipv4 only network - listen on windows

massa-bootstrap/Cargo.toml

@@ -24,6 +24,7 @@ parking_lot = { version = "0.12", features = ["deadlock_detection"] }
 tokio = { version = "1.23", features = ["full"] }
 tracing = "0.1"
 substruct = { git = "https://github.com/sydhds/substruct" }
+socket2 = "0.4.7"
 
 # custom modules
 massa_async_pool = { path = "../massa-async-pool" }

massa-bootstrap/src/establisher.rs

@@ -77,7 +77,17 @@ pub mod types {
         /// # Argument
         /// * `addr`: `SocketAddr` we want to bind to.
         pub async fn get_listener(&mut self, addr: SocketAddr) -> io::Result<DefaultListener> {
-            Ok(DefaultListener(TcpListener::bind(addr).await?))
+            // Create a socket2 TCP listener to manually set the IPV6_V6ONLY flag
+            let socket = socket2::Socket::new(socket2::Domain::IPV6, socket2::Type::STREAM, None)?;
+
+            socket.set_only_v6(false)?;
+            socket.set_nonblocking(true)?;
+            socket.bind(&addr.into())?;
+
+            // Number of connections to queue, set to the hardcoded value used by tokio
+            socket.listen(1024)?;
+
+            Ok(DefaultListener(TcpListener::from_std(socket.into())?))
         }
 
         /// Get the connector with associated timeout

massa-bootstrap/src/tests/mock_establisher.rs

@@ -2,6 +2,7 @@
 
 use massa_models::config::{CHANNEL_SIZE, MAX_DUPLEX_BUFFER_SIZE};
 use massa_time::MassaTime;
+use socket2 as _;
 use std::io;
 use std::net::SocketAddr;
 use tokio::io::DuplexStream;

massa-network-exports/Cargo.toml

@@ -12,6 +12,7 @@ serde = { version = "1.0", features = ["derive"] }
 thiserror = "1.0"
 tokio = { version = "1.23", features = ["full"] }
 enum-map = { version = "2.4", features = ["serde"] }
+socket2 = "0.4.7"
 # custom modules
 massa_hash = { path = "../massa-hash" }
 massa_models = { path = "../massa-models" }

massa-network-exports/src/establisher.rs

@@ -83,7 +83,17 @@ mod types {
         /// # Argument
         /// * `addr`: `SocketAddr` we want to bind to.
         pub async fn get_listener(&mut self, addr: SocketAddr) -> io::Result<DefaultListener> {
-            Ok(DefaultListener(TcpListener::bind(addr).await?))
+            // Create a socket2 TCP listener to manually set the IPV6_V6ONLY flag
+            let socket = socket2::Socket::new(socket2::Domain::IPV6, socket2::Type::STREAM, None)?;
+
+            socket.set_only_v6(false)?;
+            socket.set_nonblocking(true)?;
+            socket.bind(&addr.into())?;
+
+            // Number of connections to queue, set to the hardcoded value used by tokio
+            socket.listen(1024)?;
+
+            Ok(DefaultListener(TcpListener::from_std(socket.into())?))
         }
 
         /// Get the connector with associated timeout

massa-network-exports/src/test_exports/mock_establisher.rs

@@ -1,6 +1,7 @@
 // Copyright (c) 2022 MASSA LABS <[email protected]>
 
 use massa_time::MassaTime;
+use socket2 as _;
 use std::io;
 use std::net::SocketAddr;
 use tokio::io::DuplexStream;