v4.0.16

.github/workflows/all_build.yml

@@ -4,12 +4,15 @@ on:
   push:
     branches:
       - master
+  pull_request:
+    branches:
+      - master
 
 env:
   CARGO_TERM_COLOR: always
-  
+
 jobs:
-  upgrade:
+  build:
     name: Build on ${{ matrix.os }} (${{ matrix.toolchain }})
     runs-on: ${{ matrix.os }}
 
@@ -22,8 +25,7 @@ jobs:
       - name: Checkout code
         uses: actions/checkout@v4
 
-      - id: setup
-        name: Setup Toolchain
+      - name: Setup Toolchain
         uses: dtolnay/rust-toolchain@stable
         with:
           toolchain: ${{ matrix.toolchain }}
@@ -32,4 +34,4 @@ jobs:
         run: cargo test --all-features --verbose
 
       - name: Build project
-        run: cargo build --release --verbose
+        run: cargo build --release --verbose

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "torrust-actix"
-version = "4.0.15"
+version = "4.0.16"
 edition = "2024"
 license = "AGPL-3.0"
 authors = [

README.md

@@ -51,7 +51,7 @@ Run the code using `--help` argument for using in your enironment:
 ```bash
 ./target/release/torrust-actix --help
 ```
-Before you can run the server, you need to either have persietency turned off, and when enabled, make sure your database is created and working. See the help argument above how to fix your setup as you wish.
+Before you can run the server, you need to either have persistence turned off, and when enabled, make sure your database is created and working. See the help argument above how to fix your setup as you wish.
 
 Swagger UI is introduced, and when enabled in the configuration, is accessible through the API via `/swagger-ui/`.
 
@@ -167,11 +167,25 @@ HTTP_0_TLS_CONNECTION_RATE <UINT64>
 
 UDP_0_ENABLED <true | false>
 UDP_0_BIND_ADDRESS <STRING>
-UDP_0_THREADS <UINT64>
+UDP_0_UDP_THREADS <UINT64>
+UDP_0_WORKER_THREADS <UINT64>
+UDP_0_RECEIVE_BUFFER_SIZE <UINT64>
+UDP_0_SEND_BUFFER_SIZE <UINT64>
+UDP_0_REUSE_ADDRESS <true | false>
 ```
 
 ### ChangeLog
 
+#### v4.0.16
+* Small debug and hotfixes
+* Fixed the unit test that somehow failed
+* Updated this readme file
+
+#### v4.0.15
+* More code optimizations thanks to AI scanning further
+* UDP performance tweaks (some new config options added)
+* Added an initial unit testing for checking if all functions and features work as expected
+
 #### v4.0.14
 * Code optimizations thanks to AI scanning
 * Huge memory and CPU consumption improvement for UDP, using offloading

benches/tracker_benchmarks.rs

@@ -65,7 +65,6 @@ fn bench_get_peers_with_limit(c: &mut Criterion) {
     let tracker = rt.block_on(create_tracker());
     let info_hash = random_info_hash();
 
-
     for i in 0..1000 {
         let peer_id = random_peer_id();
         let peer = create_test_peer(IpAddr::V4(Ipv4Addr::new(10, 0, (i / 256) as u8, (i % 256) as u8)), 6881, peer_id);
@@ -157,7 +156,6 @@ fn bench_peer_filtering_ipv4_vs_ipv6(c: &mut Criterion) {
     let tracker = rt.block_on(create_tracker());
     let info_hash = random_info_hash();
 
-
     for i in 0..500 {
         let peer_id = random_peer_id();
         let peer = if i % 2 == 0 {

docker/Dockerfile

@@ -2,7 +2,7 @@ FROM rust:alpine
 
 RUN apk add git musl-dev curl pkgconfig openssl-dev openssl-libs-static
 RUN git clone https://github.com/Power2All/torrust-actix.git /app/torrust-actix
-RUN cd /app/torrust-actix && git checkout tags/v4.0.15
+RUN cd /app/torrust-actix && git checkout tags/v4.0.16
 WORKDIR /app/torrust-actix
 RUN cd /app/torrust-actix
 RUN cargo build --release && rm -Rf target/release/.fingerprint target/release/build target/release/deps target/release/examples target/release/incremental

docker/build.bat

@@ -1,5 +1,5 @@
 @echo off
 
-docker build -t power2all/torrust-actix:v4.0.15 -t power2all/torrust-actix:latest .
-docker push power2all/torrust-actix:v4.0.15
+docker build -t power2all/torrust-actix:v4.0.16 -t power2all/torrust-actix:latest .
+docker push power2all/torrust-actix:v4.0.16
 docker push power2all/torrust-actix:latest

src/http/http.rs

@@ -29,6 +29,7 @@ use std::time::Duration;
 pub fn http_service_cors() -> Cors
 {
     Cors::default()
+        .allow_any_origin()
         .send_wildcard()
         .allowed_methods(vec!["GET"])
         .allowed_headers(vec![http::header::X_FORWARDED_FOR, http::header::ACCEPT])

src/udp/impls/parse_pool.rs

@@ -63,7 +63,6 @@ impl ParsePool {
             });
         }
 
-
         let runtime = self.udp_runtime.clone();
         std::mem::forget(runtime);
     }

src/udp/impls/udp_server.rs

@@ -166,10 +166,14 @@ impl UdpServer {
     #[tracing::instrument(level = "debug")]
     pub async fn get_connection_id(remote_address: &SocketAddr) -> ConnectionId {
         use std::hash::{DefaultHasher, Hasher};
-        use std::time::Instant;
+        use std::time::{SystemTime, UNIX_EPOCH};
 
         let mut hasher = DefaultHasher::new();
-        hasher.write_u64(Instant::now().elapsed().as_nanos() as u64);
+        let timestamp = SystemTime::now()
+            .duration_since(UNIX_EPOCH)
+            .unwrap_or_default()
+            .as_nanos() as u64;
+        hasher.write_u64(timestamp);
         hasher.write_u16(remote_address.port());
         if let std::net::IpAddr::V4(ipv4) = remote_address.ip() {
             hasher.write(&ipv4.octets());