pbs 0.0.6

Safe FFI for OpenPBS and PBSPro HPC job scheduler
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

use serde_json::Value;
use std::ffi::{CStr, CString};
use std::ptr::null_mut;

//Helper function to convert cstr into a str
//TODO FIXME not really static
pub(crate) fn cstr_to_str(instr: *mut i8) -> &'static str {
    if instr.is_null() {
        return "";
    };
    unsafe { CStr::from_ptr(instr) }.to_str().unwrap()
}

//Helper function to convert str to a cstr
pub(crate) fn str_to_cstr(instr: &str) -> *mut i8 {
    CString::new(instr).unwrap().into_raw()
}

//Helper function to convert a Option<str> to a cstr
pub(crate) fn optstr_to_cstr(instr: Option<&str>) -> *mut i8 {
    if let Some(s) = instr {
        str_to_cstr(s)
    } else {
        null_mut()
    }
}

pub(crate) fn json_val(val: String) -> Value {
    if let Ok(num) = val.parse() {
        return Value::Number(num);
    } else if val.ends_with("tb") {
        if let Ok(num) = val[..val.len() - 2].parse::<isize>() {
            return Value::Number((num * 1000000).into());
        }
    } else if val.ends_with("gb") {
        if let Ok(num) = val[..val.len() - 2].parse::<isize>() {
            return Value::Number((num * 1000).into());
        }
    } else if val.ends_with("mb") {
        if let Ok(num) = val[..val.len() - 2].parse::<isize>() {
            return Value::Number(num.into());
        }
    } else if val.ends_with("kb") {
        if let Ok(num) = val[..val.len() - 2].parse::<isize>() {
            return Value::Number((num / 1000).into());
        }
    } else if val.ends_with('b') {
        if let Ok(num) = val[..val.len() - 1].parse::<isize>() {
            return Value::Number((num / 1000000).into());
        }
    } else if val.to_lowercase() == "true" {
        return Value::Bool(true);
    } else if val.to_lowercase() == "false" {
        return Value::Bool(false);
    }
    Value::String(val)
}