//! Misc low level stuff export type_desc; export get_type_desc; export size_of; export min_align_of; export pref_align_of; export refcount; export log_str; export lock_and_signal, condition, methods; export shape_eq, shape_lt, shape_le; import task::atomically; enum type_desc = { size: uint, align: uint // Remaining fields not listed }; type rust_cond_lock = *libc::c_void; #[abi = "cdecl"] extern mod rustrt { pure fn shape_log_str(t: *sys::type_desc, data: *()) -> ~str; fn rust_create_cond_lock() -> rust_cond_lock; fn rust_destroy_cond_lock(lock: rust_cond_lock); fn rust_lock_cond_lock(lock: rust_cond_lock); fn rust_unlock_cond_lock(lock: rust_cond_lock); fn rust_wait_cond_lock(lock: rust_cond_lock); fn rust_signal_cond_lock(lock: rust_cond_lock) -> bool; } #[abi = "rust-intrinsic"] extern mod rusti { fn get_tydesc() -> *(); fn size_of() -> uint; fn pref_align_of() -> uint; fn min_align_of() -> uint; } /// Compares contents of two pointers using the default method. /// Equivalent to `*x1 == *x2`. Useful for hashtables. pure fn shape_eq(x1: &T, x2: &T) -> bool { *x1 == *x2 } pure fn shape_lt(x1: &T, x2: &T) -> bool { *x1 < *x2 } pure fn shape_le(x1: &T, x2: &T) -> bool { *x1 < *x2 } /** * Returns a pointer to a type descriptor. * * Useful for calling certain function in the Rust runtime or otherwise * performing dark magick. */ pure fn get_type_desc() -> *type_desc { unchecked { rusti::get_tydesc::() as *type_desc } } /// Returns the size of a type #[inline(always)] pure fn size_of() -> uint { unchecked { rusti::size_of::() } } /** * Returns the ABI-required minimum alignment of a type * * This is the alignment used for struct fields. It may be smaller * than the preferred alignment. */ pure fn min_align_of() -> uint { unchecked { rusti::min_align_of::() } } /// Returns the preferred alignment of a type pure fn pref_align_of() -> uint { unchecked { rusti::pref_align_of::() } } /// Returns the refcount of a shared box (as just before calling this) pure fn refcount(+t: @T) -> uint { unsafe { let ref_ptr: *uint = unsafe::reinterpret_cast(t); *ref_ptr - 1 } } pure fn log_str(t: T) -> ~str { unsafe { let data_ptr: *() = unsafe::reinterpret_cast(ptr::addr_of(t)); rustrt::shape_log_str(get_type_desc::(), data_ptr) } } class lock_and_signal { let lock: rust_cond_lock; new() { self.lock = rustrt::rust_create_cond_lock(); } drop { rustrt::rust_destroy_cond_lock(self.lock); } } enum condition { condition_(rust_cond_lock) } class unlock { let lock: rust_cond_lock; new(lock: rust_cond_lock) { self.lock = lock; } drop { rustrt::rust_unlock_cond_lock(self.lock); } } impl methods for lock_and_signal { unsafe fn lock(f: fn() -> T) -> T { do atomically { rustrt::rust_lock_cond_lock(self.lock); let _r = unlock(self.lock); f() } } unsafe fn lock_cond(f: fn(condition) -> T) -> T { do atomically { rustrt::rust_lock_cond_lock(self.lock); let _r = unlock(self.lock); f(condition_(self.lock)) } } } impl methods for condition { fn wait() { rustrt::rust_wait_cond_lock(*self); } fn signal() -> bool { rustrt::rust_signal_cond_lock(*self) } } #[cfg(test)] mod tests { #[test] fn size_of_basic() { assert size_of::() == 1u; assert size_of::() == 2u; assert size_of::() == 4u; assert size_of::() == 8u; } #[test] #[cfg(target_arch = "x86")] #[cfg(target_arch = "arm")] fn size_of_32() { assert size_of::() == 4u; assert size_of::<*uint>() == 4u; } #[test] #[cfg(target_arch = "x86_64")] fn size_of_64() { assert size_of::() == 8u; assert size_of::<*uint>() == 8u; } #[test] fn align_of_basic() { assert pref_align_of::() == 1u; assert pref_align_of::() == 2u; assert pref_align_of::() == 4u; } #[test] #[cfg(target_arch = "x86")] #[cfg(target_arch = "arm")] fn align_of_32() { assert pref_align_of::() == 4u; assert pref_align_of::<*uint>() == 4u; } #[test] #[cfg(target_arch = "x86_64")] fn align_of_64() { assert pref_align_of::() == 8u; assert pref_align_of::<*uint>() == 8u; } #[test] #[ignore] // this can go into infinite loops fn condition_variable() { let lock = arc::arc(lock_and_signal()); let lock2 = arc::clone(&lock); do task::spawn |move lock2| { let lock = arc::get(&lock2); do (*lock).lock_cond |c| { c.wait(); } } let mut signaled = false; while !signaled { do (*arc::get(&lock)).lock_cond |c| { signaled = c.signal() } } } } // Local Variables: // mode: rust; // fill-column: 78; // indent-tabs-mode: nil // c-basic-offset: 4 // buffer-file-coding-system: utf-8-unix // End: