infrarust 1.6.1

A Rust universal Minecraft proxy
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50

#[cfg(target_os = "linux")]
mod linux;

pub mod types;

use std::sync::Arc;
use std::sync::atomic::AtomicBool;

use tokio::net::TcpStream;
use tokio::task::JoinHandle;
#[cfg(not(target_os = "linux"))]
use tracing::error;
#[cfg(target_os = "linux")]
use tracing::{debug, info};

pub use types::ZeroCopyMessage;

pub fn spawn_splice_task(
    client: TcpStream,
    server: TcpStream,
    shutdown: Arc<AtomicBool>,
) -> JoinHandle<(u64, u64)> {
    #[cfg(target_os = "linux")]
    {
        info!("Using Linux splice() for zero-copy transfer");
        tokio::spawn(async move {
            match linux::copy_bidirectional(client, server, shutdown).await {
                Ok(result) => result,
                Err(e) => {
                    debug!("Splice transfer error: {}", e);
                    (0, 0)
                }
            }
        })
    }

    #[cfg(not(target_os = "linux"))]
    {
        let _ = (client, server);

        tokio::spawn(async move {
            error!(
                "ZeroCopy mode is not available: requires Linux with splice() syscall support. \
                 This platform does not support zero-copy networking."
            );
            shutdown.store(true, std::sync::atomic::Ordering::SeqCst);
            (0, 0)
        })
    }
}