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
58
59
60
61
62
63
64
65
66
67
68
69
70

use crate::helpers;
use crate::types::{Attribs, Attrl};
use linked_list_c::{ConstList, CustomList};
use log::{debug, trace};
use pbs_sys::attrl;
use std::ffi::CStr;
use std::ptr;

use pbs_sys as ffi;

pub mod stat {
    pub use super::ffi::{
        pbs_selstat, pbs_statfree, pbs_stathost, pbs_statque, pbs_statresv, pbs_statrsc,
        pbs_statsched, pbs_statserver, pbs_statvnode,
    };
}

pub fn is_err() -> bool {
    unsafe { *ffi::__pbs_errno_location() != 0 }
}

pub fn get_err() -> String {
    unsafe {
        CStr::from_ptr(ffi::pbse_to_txt(*ffi::__pbs_errno_location()))
            .to_str()
            .unwrap()
            .to_string()
    }
}

impl From<Attribs> for ConstList<'_, attrl> {
    fn from(attribs: Attribs) -> ConstList<'static, attrl> {
        debug!("Converting Attribs to ConstList<attrl>");
        let mut list: CustomList<attrl> = unsafe {
            CustomList::from(ptr::null_mut(), |x| {
                _ = Box::from_raw(x);
            })
        };
        for (name, val) in attribs.attribs().iter() {
            match val {
                Attrl::Value(v) => {
                    trace!("Adding {name} {val:?}");
                    let at = Box::into_raw(Box::new(attrl {
                        name: helpers::str_to_cstr(name),
                        value: helpers::str_to_cstr(&v.val()),
                        resource: ptr::null_mut(),
                        op: v.op(),
                        next: ptr::null_mut(),
                    }));
                    list.add(at);
                }

                Attrl::Resource(map) => {
                    for (r, v) in map.iter() {
                        trace!("Adding {name}.{r} {v:?}");
                        list.add(Box::into_raw(Box::new(attrl {
                            name: helpers::str_to_cstr(name),
                            value: helpers::str_to_cstr(&v.val()),
                            resource: helpers::str_to_cstr(r),
                            op: v.op(),
                            next: ptr::null_mut(),
                        })));
                    }
                }
            };
        }
        trace!("Converted Attribs to ConstList<attrl>");
        list.into()
    }
}