use libc::*;
use std::ffi::{CStr, CString};
use std::ptr;
use std::str;
use super::*;
pub fn error_message(ptr: *const i8) -> String {
let c_str = unsafe { CStr::from_ptr(ptr as *const _) };
let s = str::from_utf8(c_str.to_bytes()).unwrap().to_owned();
unsafe {
free(ptr as *mut c_void);
}
s
}
#[test]
fn internal() {
unsafe {
let opts = rocksdb_options_create();
assert!(!opts.is_null());
rocksdb_options_increase_parallelism(opts, 0);
rocksdb_options_optimize_level_style_compaction(opts, 0);
rocksdb_options_set_create_if_missing(opts, true as c_uchar);
let rustpath = "_rust_rocksdb_internaltest";
let cpath = CString::new(rustpath).unwrap();
let mut err: *mut c_char = ptr::null_mut();
let err_ptr: *mut *mut c_char = &mut err;
let db = rocksdb_open(opts, cpath.as_ptr() as *const _, err_ptr);
if !err.is_null() {
println!("failed to open rocksdb: {}", error_message(err));
}
assert!(err.is_null());
let writeopts = rocksdb_writeoptions_create();
assert!(!writeopts.is_null());
let key = b"name\x00";
let val = b"spacejam\x00";
rocksdb_put(
db,
writeopts.clone(),
key.as_ptr() as *const c_char,
4,
val.as_ptr() as *const c_char,
8,
err_ptr,
);
rocksdb_writeoptions_destroy(writeopts);
assert!(err.is_null());
let readopts = rocksdb_readoptions_create();
assert!(!readopts.is_null());
let mut val_len: size_t = 0;
let val_len_ptr = &mut val_len as *mut size_t;
rocksdb_get(
db,
readopts.clone(),
key.as_ptr() as *const c_char,
4,
val_len_ptr,
err_ptr,
);
rocksdb_readoptions_destroy(readopts);
assert!(err.is_null());
rocksdb_close(db);
rocksdb_destroy_db(opts, cpath.as_ptr() as *const _, err_ptr);
assert!(err.is_null());
}
}