// Copyright (c) 2017-present PyO3 Project and Contributors use crate::err::{PyErr, PyResult}; use crate::ffi; use crate::gil; use crate::instance; use crate::object::PyObject; use crate::objectprotocol::ObjectProtocol; use crate::type_object::PyTypeCreate; use crate::type_object::{PyTypeInfo, PyTypeObject}; use crate::types::PyAny; use crate::AsPyPointer; use crate::IntoPyPointer; use crate::Python; use crate::{FromPyObject, IntoPyObject, ToPyObject}; use std::marker::PhantomData; use std::mem; use std::ops::{Deref, DerefMut}; use std::ptr::NonNull; use std::rc::Rc; /// Types that are built into the python interpreter. /// /// pyo3 is designed in a way that that all references to those types are bound to the GIL, /// which is why you can get a token from all references of those types. pub unsafe trait PyNativeType: Sized { fn py(&self) -> Python { unsafe { Python::assume_gil_acquired() } } } /// A special reference of type `T`. `PyRef` refers a instance of T, which exists in the Python /// heap as a part of a Python object. /// /// We can't implement `AsPyPointer` or `ToPyObject` for `pyclass`es, because they're not Python /// objects until copied to the Python heap. So, instead of treating `&pyclass`es as Python objects, /// we need to use special reference types `PyRef` and `PyRefMut`. /// /// # Example /// /// ``` /// use pyo3::prelude::*; /// use pyo3::types::IntoPyDict; /// #[pyclass] /// struct Point { /// x: i32, /// y: i32, /// } /// #[pymethods] /// impl Point { /// fn length(&self) -> i32 { /// self.x * self.y /// } /// } /// let gil = Python::acquire_gil(); /// let py = gil.python(); /// let obj = PyRef::new(gil.python(), Point { x: 3, y: 4 }).unwrap(); /// let d = [("p", obj)].into_py_dict(py); /// py.run("assert p.length() == 12", None, Some(d)).unwrap(); /// ``` #[derive(Debug)] pub struct PyRef<'a, T: PyTypeInfo>(&'a T, PhantomData>); fn ref_to_ptr(t: &T) -> *mut ffi::PyObject where T: PyTypeInfo, { unsafe { (t as *const _ as *mut u8).offset(-T::OFFSET) as *mut _ } } impl<'a, T: PyTypeInfo> PyRef<'a, T> { pub(crate) fn from_ref(r: &'a T) -> Self { PyRef(r, PhantomData) } } impl<'a, T> PyRef<'a, T> where T: PyTypeInfo + PyTypeObject + PyTypeCreate, { pub fn new(py: Python, value: T) -> PyResult> { let obj = T::create(py)?; obj.init(value); let ref_ = unsafe { py.from_owned_ptr(obj.into_ptr()) }; Ok(PyRef::from_ref(ref_)) } } impl<'a, T: PyTypeInfo> AsPyPointer for PyRef<'a, T> { fn as_ptr(&self) -> *mut ffi::PyObject { ref_to_ptr(self.0) } } impl<'a, T: PyTypeInfo> ToPyObject for PyRef<'a, T> { fn to_object(&self, py: Python) -> PyObject { unsafe { PyObject::from_borrowed_ptr(py, self.as_ptr()) } } } impl<'a, T: PyTypeInfo> Deref for PyRef<'a, T> { type Target = T; fn deref(&self) -> &T { self.0 } } /// Mutable version of [`PyRef`](struct.PyRef.html). /// # Example /// ``` /// use pyo3::prelude::*; /// use pyo3::types::IntoPyDict; /// #[pyclass] /// struct Point { /// x: i32, /// y: i32, /// } /// #[pymethods] /// impl Point { /// fn length(&self) -> i32 { /// self.x * self.y /// } /// } /// let gil = Python::acquire_gil(); /// let py = gil.python(); /// let mut obj = PyRefMut::new(gil.python(), Point { x: 3, y: 4 }).unwrap(); /// let d = vec![("p", obj.to_object(py))].into_py_dict(py); /// obj.x = 5; obj.y = 20; /// py.run("assert p.length() == 100", None, Some(d)).unwrap(); /// ``` #[derive(Debug)] pub struct PyRefMut<'a, T: PyTypeInfo>(&'a mut T, PhantomData>); impl<'a, T: PyTypeInfo> PyRefMut<'a, T> { pub(crate) fn from_mut(t: &'a mut T) -> Self { PyRefMut(t, PhantomData) } } impl<'a, T> PyRefMut<'a, T> where T: PyTypeInfo + PyTypeObject + PyTypeCreate, { pub fn new(py: Python, value: T) -> PyResult> { let obj = T::create(py)?; obj.init(value); let ref_ = unsafe { py.mut_from_owned_ptr(obj.into_ptr()) }; Ok(PyRefMut::from_mut(ref_)) } } impl<'a, T: PyTypeInfo> AsPyPointer for PyRefMut<'a, T> { fn as_ptr(&self) -> *mut ffi::PyObject { ref_to_ptr(self.0) } } impl<'a, T: PyTypeInfo> ToPyObject for PyRefMut<'a, T> { fn to_object(&self, py: Python) -> PyObject { unsafe { PyObject::from_borrowed_ptr(py, self.as_ptr()) } } } impl<'a, T: PyTypeInfo> Deref for PyRefMut<'a, T> { type Target = T; fn deref(&self) -> &T { self.0 } } impl<'a, T: PyTypeInfo> DerefMut for PyRefMut<'a, T> { fn deref_mut(&mut self) -> &mut T { self.0 } } impl<'a, T> From> for &'a PyAny where T: PyTypeInfo, { fn from(pref: PyRef<'a, T>) -> &'a PyAny { unsafe { &*(pref.as_ptr() as *const PyAny) } } } impl<'a, T> From> for &'a PyAny where T: PyTypeInfo, { fn from(pref: PyRefMut<'a, T>) -> &'a PyAny { unsafe { &*(pref.as_ptr() as *const PyAny) } } } /// Trait implements object reference extraction from python managed pointer. pub trait AsPyRef: Sized { /// Return reference to object. fn as_ref(&self, py: Python) -> PyRef; /// Return mutable reference to object. fn as_mut(&mut self, py: Python) -> PyRefMut; /// Acquire python gil and call closure with object reference. fn with(&self, f: F) -> R where F: FnOnce(Python, PyRef) -> R, { let gil = Python::acquire_gil(); let py = gil.python(); f(py, self.as_ref(py)) } /// Acquire python gil and call closure with mutable object reference. fn with_mut(&mut self, f: F) -> R where F: FnOnce(Python, PyRefMut) -> R, { let gil = Python::acquire_gil(); let py = gil.python(); f(py, self.as_mut(py)) } fn into_py(self, f: F) -> R where Self: IntoPyPointer, F: FnOnce(Python, PyRef) -> R, { let gil = Python::acquire_gil(); let py = gil.python(); let result = f(py, self.as_ref(py)); py.xdecref(self); result } fn into_mut_py(mut self, f: F) -> R where Self: IntoPyPointer, F: FnOnce(Python, PyRefMut) -> R, { let gil = Python::acquire_gil(); let py = gil.python(); let result = f(py, self.as_mut(py)); py.xdecref(self); result } } /// Safe wrapper around unsafe `*mut ffi::PyObject` pointer with specified type information. /// /// `Py` is thread-safe, because any python related operations require a Python<'p> token. #[derive(Debug)] #[repr(transparent)] pub struct Py(NonNull, std::marker::PhantomData); unsafe impl Send for Py {} unsafe impl Sync for Py {} impl Py { /// Create new instance of T and move it under python management pub fn new(py: Python, value: T) -> PyResult> where T: PyTypeCreate, { let ob = T::create(py)?; ob.init(value); let ob = unsafe { Py::from_owned_ptr(ob.into_ptr()) }; Ok(ob) } /// Creates a `Py` instance for the given FFI pointer. /// This moves ownership over the pointer into the `Py`. /// Undefined behavior if the pointer is NULL or invalid. #[inline] pub unsafe fn from_owned_ptr(ptr: *mut ffi::PyObject) -> Py { debug_assert!( !ptr.is_null() && ffi::Py_REFCNT(ptr) > 0, format!("REFCNT: {:?} - {:?}", ptr, ffi::Py_REFCNT(ptr)) ); Py(NonNull::new_unchecked(ptr), std::marker::PhantomData) } /// Creates a `Py` instance for the given FFI pointer. /// Panics if the pointer is `null`. /// Undefined behavior if the pointer is invalid. #[inline] pub unsafe fn from_owned_ptr_or_panic(ptr: *mut ffi::PyObject) -> Py { match NonNull::new(ptr) { Some(nonnull_ptr) => Py(nonnull_ptr, std::marker::PhantomData), None => { crate::err::panic_after_error(); } } } /// Construct `Py` from the result of a Python FFI call that /// returns a new reference (owned pointer). /// Returns `Err(PyErr)` if the pointer is `null`. /// Unsafe because the pointer might be invalid. pub unsafe fn from_owned_ptr_or_err(py: Python, ptr: *mut ffi::PyObject) -> PyResult> { match NonNull::new(ptr) { Some(nonnull_ptr) => Ok(Py(nonnull_ptr, std::marker::PhantomData)), None => Err(PyErr::fetch(py)), } } /// Creates a `Py` instance for the given Python FFI pointer. /// Calls Py_INCREF() on the ptr. /// Undefined behavior if the pointer is NULL or invalid. #[inline] pub unsafe fn from_borrowed_ptr(ptr: *mut ffi::PyObject) -> Py { debug_assert!( !ptr.is_null() && ffi::Py_REFCNT(ptr) > 0, format!("REFCNT: {:?} - {:?}", ptr, ffi::Py_REFCNT(ptr)) ); ffi::Py_INCREF(ptr); Py(NonNull::new_unchecked(ptr), std::marker::PhantomData) } /// Gets the reference count of the ffi::PyObject pointer. #[inline] pub fn get_refcnt(&self) -> isize { unsafe { ffi::Py_REFCNT(self.0.as_ptr()) } } /// Clone self, Calls Py_INCREF() on the ptr. #[inline] pub fn clone_ref(&self, _py: Python) -> Py { unsafe { Py::from_borrowed_ptr(self.0.as_ptr()) } } /// Returns the inner pointer without decreasing the refcount /// /// This will eventually move into its own trait pub(crate) fn into_non_null(self) -> NonNull { let pointer = self.0; mem::forget(self); pointer } } /// Specialization workaround trait AsPyRefDispatch: AsPyPointer { fn as_ref_dispatch(&self, _py: Python) -> &T { unsafe { let ptr = (self.as_ptr() as *mut u8).offset(T::OFFSET) as *mut T; ptr.as_ref().expect("Py has a null pointer") } } fn as_mut_dispatch(&mut self, _py: Python) -> &mut T { unsafe { let ptr = (self.as_ptr() as *mut u8).offset(T::OFFSET) as *mut T; ptr.as_mut().expect("Py has a null pointer") } } } impl AsPyRefDispatch for Py {} impl AsPyRefDispatch for Py { fn as_ref_dispatch(&self, _py: Python) -> &T { unsafe { &*(self as *const instance::Py as *const T) } } fn as_mut_dispatch(&mut self, _py: Python) -> &mut T { unsafe { &mut *(self as *mut _ as *mut T) } } } impl AsPyRef for Py where T: PyTypeInfo, { #[inline] fn as_ref(&self, py: Python) -> PyRef { PyRef::from_ref(self.as_ref_dispatch(py)) } #[inline] fn as_mut(&mut self, py: Python) -> PyRefMut { PyRefMut::from_mut(self.as_mut_dispatch(py)) } } impl ToPyObject for Py { /// Converts `Py` instance -> PyObject. fn to_object(&self, py: Python) -> PyObject { unsafe { PyObject::from_borrowed_ptr(py, self.as_ptr()) } } } impl IntoPyObject for Py { /// Converts `Py` instance -> PyObject. /// Consumes `self` without calling `Py_DECREF()` #[inline] fn into_object(self, py: Python) -> PyObject { unsafe { PyObject::from_owned_ptr(py, self.into_ptr()) } } } impl AsPyPointer for Py { /// Gets the underlying FFI pointer, returns a borrowed pointer. #[inline] fn as_ptr(&self) -> *mut ffi::PyObject { self.0.as_ptr() } } impl IntoPyPointer for Py { /// Gets the underlying FFI pointer, returns a owned pointer. #[inline] #[must_use] fn into_ptr(self) -> *mut ffi::PyObject { let ptr = self.0.as_ptr(); std::mem::forget(self); ptr } } impl PartialEq for Py { #[inline] fn eq(&self, o: &Py) -> bool { self.0 == o.0 } } /// Dropping a `Py` instance decrements the reference count on the object by 1. impl Drop for Py { fn drop(&mut self) { unsafe { gil::register_pointer(self.0); } } } impl std::convert::From> for PyObject { #[inline] fn from(ob: Py) -> Self { unsafe { PyObject::from_not_null(ob.into_non_null()) } } } impl<'a, T> std::convert::From> for Py where T: PyTypeInfo, { fn from(ob: PyRef<'a, T>) -> Self { unsafe { Py::from_borrowed_ptr(ob.as_ptr()) } } } impl<'a, T> std::convert::From> for Py where T: PyTypeInfo, { fn from(ob: PyRefMut<'a, T>) -> Self { unsafe { Py::from_borrowed_ptr(ob.as_ptr()) } } } impl<'a, T> std::convert::From<&'a T> for PyObject where T: AsPyPointer, { fn from(ob: &'a T) -> Self { unsafe { Py::::from_borrowed_ptr(ob.as_ptr()) }.into() } } impl<'a, T> std::convert::From<&'a mut T> for PyObject where T: AsPyPointer, { fn from(ob: &'a mut T) -> Self { unsafe { Py::::from_borrowed_ptr(ob.as_ptr()) }.into() } } impl<'a, T> FromPyObject<'a> for Py where T: AsPyPointer, &'a T: 'a + FromPyObject<'a>, { /// Extracts `Self` from the source `PyObject`. fn extract(ob: &'a PyAny) -> PyResult { unsafe { ob.extract::<&T>() .map(|val| Py::from_borrowed_ptr(val.as_ptr())) } } } /// Reference to a converted [ToPyObject]. /// /// Many methods want to take anything that can be converted into a python object. This type /// takes care of both types types that are already python object (i.e. implement /// [AsPyPointer]) and those that don't (i.e. [ToPyObject] types). /// For the [AsPyPointer] types, we just use the borrowed pointer, which is a lot faster /// and simpler than creating a new extra object. The remaning [ToPyObject] types are /// converted to python objects, the owned pointer is stored and decref'd on drop. /// /// # Example /// /// ``` /// use pyo3::ffi; /// use pyo3::{ToPyObject, AsPyPointer, PyNativeType, ManagedPyRef}; /// use pyo3::types::{PyDict, PyAny}; /// /// pub fn get_dict_item<'p>(dict: &'p PyDict, key: &impl ToPyObject) -> Option<&'p PyAny> { /// let key = ManagedPyRef::from_to_pyobject(dict.py(), key); /// unsafe { /// dict.py().from_borrowed_ptr_or_opt(ffi::PyDict_GetItem(dict.as_ptr(), key.as_ptr())) /// } /// } /// ``` #[repr(transparent)] pub struct ManagedPyRef<'p, T: ToPyObject + ?Sized> { data: *mut ffi::PyObject, data_type: PhantomData, _py: Python<'p>, } /// This should eventually be replaced with a generic `IntoPy` trait impl by figuring /// out the correct lifetime annotation to make the compiler happy impl<'p, T: ToPyObject> ManagedPyRef<'p, T> { pub fn from_to_pyobject(py: Python<'p>, to_pyobject: &T) -> Self { to_pyobject.to_managed_py_ref(py) } } impl<'p, T: ToPyObject> AsPyPointer for ManagedPyRef<'p, T> { fn as_ptr(&self) -> *mut ffi::PyObject { self.data } } /// Helper trait to choose the right implementation for [BorrowedPyRef] pub trait ManagedPyRefDispatch: ToPyObject { /// Optionally converts into a python object and stores the pointer to the python heap. /// /// Contains the case 1 impl (with to_object) to avoid a specialization error fn to_managed_py_ref<'p>(&self, py: Python<'p>) -> ManagedPyRef<'p, Self> { ManagedPyRef { data: self.to_object(py).into_ptr(), data_type: PhantomData, _py: py, } } /// Dispatch over a xdecref and a noop drop impl /// /// Contains the case 1 impl (decref) to avoid a specialization error fn drop_impl(borrowed: &mut ManagedPyRef) { unsafe { ffi::Py_DECREF(borrowed.data) }; } } /// Case 1: It's a rust object which still needs to be converted to a python object. /// This means we're storing the owned pointer that into_ptr() has given us /// and therefore need to xdecref when we're done. /// /// Note that the actual implementations are part of the trait declaration to avoid /// a specialization error impl ManagedPyRefDispatch for T {} /// Case 2: It's an object on the python heap, we're just storing a borrowed pointer. /// The object we're getting is an owned pointer, it might have it's own drop impl. impl ManagedPyRefDispatch for T { /// Use AsPyPointer to copy the pointer and store it as borrowed pointer fn to_managed_py_ref<'p>(&self, py: Python<'p>) -> ManagedPyRef<'p, Self> { ManagedPyRef { data: self.as_ptr(), data_type: PhantomData, _py: py, } } /// We have a borrowed pointer, so nothing to do here fn drop_impl(_: &mut ManagedPyRef) {} } impl<'p, T: ToPyObject + ?Sized> Drop for ManagedPyRef<'p, T> { /// Uses the internal [ManagedPyRefDispatch] trait to get the right drop impl without causing /// a specialization error fn drop(&mut self) { ManagedPyRefDispatch::drop_impl(self); } } #[cfg(test)] mod test { use crate::ffi; use crate::types::PyDict; use crate::{AsPyPointer, ManagedPyRef, Python}; #[test] fn borrowed_py_ref_with_to_pointer() { let gil = Python::acquire_gil(); let py = gil.python(); let native = PyDict::new(py); let ref_count = unsafe { ffi::Py_REFCNT(native.as_ptr()) }; let borrowed = ManagedPyRef::from_to_pyobject(py, native); assert_eq!(native.as_ptr(), borrowed.data); assert_eq!(ref_count, unsafe { ffi::Py_REFCNT(borrowed.data) }); drop(borrowed); assert_eq!(ref_count, unsafe { ffi::Py_REFCNT(native.as_ptr()) }); } #[test] fn borrowed_py_ref_with_to_object() { let gil = Python::acquire_gil(); let py = gil.python(); let convertible = (1, 2, 3); let borrowed = ManagedPyRef::from_to_pyobject(py, &convertible); let ptr = borrowed.data; // The refcountwould become 0 after dropping, which means the gc can free the pointer // and getting the refcount would be UB. This incref ensures that it remains 1 unsafe { ffi::Py_INCREF(ptr); } assert_eq!(2, unsafe { ffi::Py_REFCNT(ptr) }); drop(borrowed); assert_eq!(1, unsafe { ffi::Py_REFCNT(ptr) }); unsafe { ffi::Py_DECREF(ptr); } } }