// Copyright 2013 The Rust Project Developers. See the COPYRIGHT // file at the top-level directory of this distribution and at // http://rust-lang.org/COPYRIGHT. // // Licensed under the Apache License, Version 2.0 or the MIT license // , at your // option. This file may not be copied, modified, or distributed // except according to those terms. /*! Task-local reference counted boxes The `Rc` type provides shared ownership of an immutable value. Destruction is deterministic, and will occur as soon as the last owner is gone. It is marked as non-sendable because it avoids the overhead of atomic reference counting. */ use ptr::RawPtr; use unstable::intrinsics::transmute; use ops::Drop; use kinds::{Freeze, Send}; use clone::{Clone, DeepClone}; use mutable::Mut; struct RcBox { value: T, count: uint } /// Immutable reference counted pointer type #[unsafe_no_drop_flag] #[no_send] pub struct Rc { priv ptr: *mut RcBox } impl Rc { /// Construct a new reference-counted box from a `Freeze` value #[inline] pub fn new(value: T) -> Rc { unsafe { Rc::new_unchecked(value) } } } impl Rc { /// Construct a new reference-counted box from a `Send` value #[inline] pub fn from_send(value: T) -> Rc { unsafe { Rc::new_unchecked(value) } } } impl Rc> { /// Construct a new reference-counted box from a `Mut`-wrapped `Freeze` value #[inline] pub fn from_mut(value: Mut) -> Rc> { unsafe { Rc::new_unchecked(value) } } } impl Rc { /// Unsafety construct a new reference-counted box from any value. /// /// It is possible to create cycles, which will leak, and may interact /// poorly with managed pointers. #[inline] pub unsafe fn new_unchecked(value: T) -> Rc { Rc{ptr: transmute(~RcBox{value: value, count: 1})} } /// Borrow the value contained in the reference-counted box #[inline] pub fn borrow<'r>(&'r self) -> &'r T { unsafe { &(*self.ptr).value } } } impl Clone for Rc { #[inline] fn clone(&self) -> Rc { unsafe { (*self.ptr).count += 1; Rc{ptr: self.ptr} } } } impl DeepClone for Rc { #[inline] fn deep_clone(&self) -> Rc { unsafe { Rc::new_unchecked(self.borrow().deep_clone()) } } } #[unsafe_destructor] impl Drop for Rc { fn drop(&mut self) { unsafe { if self.ptr.is_not_null() { (*self.ptr).count -= 1; if (*self.ptr).count == 0 { let _: ~RcBox = transmute(self.ptr); } } } } } #[cfg(test)] mod test_rc { use super::*; use mutable::Mut; #[test] fn test_clone() { let x = Rc::from_send(Mut::new(5)); let y = x.clone(); do x.borrow().with_mut |inner| { *inner = 20; } assert_eq!(y.borrow().with(|v| *v), 20); } #[test] fn test_deep_clone() { let x = Rc::from_send(Mut::new(5)); let y = x.deep_clone(); do x.borrow().with_mut |inner| { *inner = 20; } assert_eq!(y.borrow().with(|v| *v), 5); } #[test] fn test_simple() { let x = Rc::new(5); assert_eq!(*x.borrow(), 5); } #[test] fn test_simple_clone() { let x = Rc::new(5); let y = x.clone(); assert_eq!(*x.borrow(), 5); assert_eq!(*y.borrow(), 5); } #[test] fn test_destructor() { let x = Rc::from_send(~5); assert_eq!(**x.borrow(), 5); } #[test] fn test_from_mut() { let a = 10; let _x = Rc::from_mut(Mut::new(&a)); } }