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
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89

// Copyright 2016 LambdaStack All rights reserved.
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

#![allow(unused_imports)]

extern crate ceph_rust;
extern crate lsio;
extern crate libc;

use std::iter::FromIterator;
use std::ptr;
use std::str;
use std::slice;
use std::ffi::{CStr, CString};

use libc::*;
#[cfg(target_os = "linux")]
use ceph_rust::rados as ceph;
#[cfg(target_os = "linux")]
use ceph_rust::ceph as ceph_helpers;

macro_rules! zeroed_c_char_buf {
	($n:expr) => {
		repeat(0).take($n).collect::<Vec<c_char>>();
	}
}

#[cfg(not(target_os = "linux"))]
fn main(){}

#[cfg(target_os = "linux")]
fn main() {
  let mut major: i32 = 0;
  let mut minor: i32 = 0;
  let mut extra: i32 = 0;

  let config_file = CString::new("/etc/ceph/ceph.conf").unwrap();
  let pool_name = CString::new("lsio").unwrap();
  let mut cluster: ceph::rados_t = std::ptr::null_mut();
  let mut ret_code: i32;

  unsafe {
    ceph::rados_version(&mut major, &mut minor, &mut extra);
    ret_code = ceph::rados_create(&mut cluster, std::ptr::null());
    println!("Return code: {} - {:?}", ret_code, cluster);

    ret_code = ceph::rados_conf_read_file(cluster, config_file.as_ptr());
    println!("Return code: {} - {:?}", ret_code, cluster);

    ret_code = ceph::rados_connect(cluster);
    println!("Return code: {} - {:?}", ret_code, cluster);

    ret_code = ceph::rados_pool_create(cluster, pool_name.as_ptr());
    println!("Return code: {}", ret_code);

    let pools_list = ceph_helpers::rados_pools(cluster).unwrap();
    println!("{:?}", pools_list);

    ret_code = ceph::rados_pool_delete(cluster, pool_name.as_ptr());
    println!("Return code: {}", ret_code);

    let instance_id = ceph::rados_get_instance_id(cluster);
    println!("Instance ID: {}", instance_id);

    let buf_size: usize = 37; // 36 is the constant size +1 for null.
    let mut fs_id: Vec<u8> = Vec::with_capacity(buf_size);

    let len = ceph::rados_cluster_fsid(cluster, fs_id.as_mut_ptr() as *mut i8, buf_size);
    let slice = slice::from_raw_parts(fs_id.as_mut_ptr(), buf_size-1);
    let s: &str = str::from_utf8(slice).unwrap();
    println!("rados_cluster_fsid len: {} - {}", len, s);

    ceph::rados_shutdown(cluster);
  }

  println!("v{}.{}.{}", major, minor, extra);

}