// Copyright (c) 2017-present PyO3 Project and Contributors use std; use std::ptr::NonNull; use crate::conversion::{FromPyObject, IntoPyObject, ToPyObject}; use crate::err::{PyErr, PyResult}; use crate::ffi; use crate::instance; use crate::object::PyObject; use crate::objectprotocol::ObjectProtocol; use crate::python::{IntoPyPointer, NonNullPyObject, Python, ToPyPointer}; use crate::pythonrun; use crate::typeob::PyTypeCreate; use crate::typeob::{PyTypeInfo, PyTypeObject}; use crate::types::PyObjectRef; /// Any instance that is managed Python can have access to `gil`. /// /// Originally, this was given to all classes with a `PyToken` field, but since `PyToken` was /// removed this is only given to native types. pub trait PyObjectWithGIL: Sized { fn py(&self) -> Python; } #[doc(hidden)] pub trait PyNativeType: PyObjectWithGIL {} /// Trait implements object reference extraction from python managed pointer. pub trait AsPyRef: Sized { /// Return reference to object. fn as_ref(&self, py: Python) -> &T; /// Return mutable reference to object. fn as_mut(&mut self, py: Python) -> &mut T; /// Acquire python gil and call closure with object reference. fn with(&self, f: F) -> R where F: FnOnce(Python, &T) -> 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, &mut T) -> 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, &T) -> 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, &mut T) -> 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. #[derive(Debug)] pub struct Py(NonNullPyObject, std::marker::PhantomData); // `Py` is thread-safe, because any python related operations require a Python<'p> token. unsafe impl Send for Py {} unsafe impl Sync for Py {} impl Py { /// 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()) } } } impl Py where T: PyTypeInfo, { /// Create new instance of T and move it under python management /// Returns `Py`. pub fn new(py: Python, f: F) -> PyResult> where F: FnOnce() -> T, T: PyTypeObject + PyTypeInfo, { let ob = ::create(py)?; ob.init(f)?; let ob = unsafe { Py::from_owned_ptr(ob.into_ptr()) }; Ok(ob) } /// Create new instance of `T` and move it under python management. /// Returns references to `T` pub fn new_ref(py: Python, f: F) -> PyResult<&T> where F: FnOnce() -> T, T: PyTypeObject + PyTypeInfo, { let ob = ::create(py)?; ob.init(f)?; unsafe { Ok(py.from_owned_ptr(ob.into_ptr())) } } /// Create new instance of `T` and move it under python management. /// Returns mutable references to `T` pub fn new_mut(py: Python, f: F) -> PyResult<&mut T> where F: FnOnce() -> T, T: PyTypeObject + PyTypeInfo, { let ob = ::create(py)?; ob.init(f)?; unsafe { Ok(py.mut_from_owned_ptr(ob.into_ptr())) } } } /// Specialization workaround trait AsPyRefDispatch: ToPyPointer { 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().unwrap() } } 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().unwrap() } } } 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 *const _ as *mut T) } } } impl AsPyRef for Py where T: PyTypeInfo, { #[inline] fn as_ref(&self, py: Python) -> &T { self.as_ref_dispatch(py) } #[inline] fn as_mut(&mut self, py: Python) -> &mut T { 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 { std::mem::transmute(self) } } } impl ToPyPointer 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 { pythonrun::register_pointer(self.0); } } } impl std::convert::From> for PyObject { #[inline] fn from(ob: Py) -> Self { unsafe { std::mem::transmute(ob) } } } impl<'a, T> std::convert::From<&'a T> for Py where T: ToPyPointer, { fn from(ob: &'a T) -> Self { unsafe { Py::from_borrowed_ptr(ob.as_ptr()) } } } impl<'a, T> std::convert::From<&'a mut T> for Py where T: ToPyPointer, { fn from(ob: &'a mut T) -> Self { unsafe { Py::from_borrowed_ptr(ob.as_ptr()) } } } impl<'a, T> std::convert::From<&'a T> for PyObject where T: ToPyPointer, { 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: ToPyPointer, { 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: ToPyPointer, &'a T: 'a + FromPyObject<'a>, { /// Extracts `Self` from the source `PyObject`. fn extract(ob: &'a PyObjectRef) -> PyResult { unsafe { ob.extract::<&T>() .map(|val| Py::from_borrowed_ptr(val.as_ptr())) } } }