picologger 0.9.4

Logger for HPC
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
51
52
53
54
55
56
57
58
59
60
61

use std::fs::{File, OpenOptions};
use std::path;

pub fn get_blksize(path: &path::PathBuf) -> u64 {
    #[cfg(target_os = "linux")]
    {
        if let Ok(metadata) = std::fs::metadata(path) {
            use std::os::linux::fs::MetadataExt;
            return metadata.st_blksize();
        } else {
            return 4096; // Default fallback
        }
    }

    #[cfg(target_os = "windows")]
    {
        //TODO: Implement Windows procedure
        panic!("Windows block size detection not implemented");
    }

    #[cfg(target_os = "macos")]
    {
        //TODO: Implement mac procedure
        panic!("MacOS block size detection not implemented");
    }
}

pub fn get_file_handler(path: &path::PathBuf, pre_alloc_size: u64) -> Result<File, std::io::Error> {
    #[cfg(target_os = "linux")]
    {
        use std::os::unix::fs::OpenOptionsExt;
        let file = OpenOptions::new()
            .read(true)
            .write(true)
            .create(true)
            .custom_flags(libc::O_DIRECT)
            .open(path)
            .expect("CRITICAL: Failed to open file with O_DIRECT. Verify FS supports it.");

        
        if let Ok(metadata) = file.metadata() {
            if metadata.len() < pre_alloc_size {
                 println!("Pre-allocating disk space...");
                 file.set_len(pre_alloc_size)?; 
                 // Force metadata sync to disk
                 file.sync_all()?; 
            }
        }
        Ok(file)
    }
    #[cfg(target_os = "windows")]
    {
        //TODO: Implement Windows equivalent of IO-uring
        panic!("Windows file handler with direct IO not implemented");
    }
    #[cfg(target_os = "macos")]
    {
        //TODO: Implement MacOS equivalent of IO-uring
        panic!("MacOS file handler with direct IO not implemented");
    }
}