// Copyright (c) 2017-present PyO3 Project and Contributors use std; use std::rc::Rc; use std::marker::PhantomData; use ffi; use err::{PyResult, PyErr, PyDowncastError}; use pointer::PyObject; use objects::PyInstance; use objectprotocol::ObjectProtocol; use conversion::{ToPyObject, IntoPyObject, FromPyObject}; use python::{Python, IntoPyPointer, ToPyPointer, PyDowncastInto, PyDowncastFrom}; use typeob::{PyTypeInfo, PyObjectAlloc}; pub struct PyToken(PhantomData>); impl PyToken { pub fn py<'p>(&'p self) -> Python<'p> { unsafe { Python::assume_gil_acquired() } } } pub trait PyObjectWithToken: Sized { fn token(&self) -> Python; } pub trait PyNativeType: PyObjectWithToken {} pub trait AsPyRef: Sized { fn as_ref(&self, py: Python) -> &T; fn as_mut(&self, py: Python) -> &mut T; 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)) } fn with_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.release(self); result } fn into_mut_py(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.release(self); result } } /// Wrapper around unsafe `*mut ffi::PyObject` pointer. Decrement ref counter on `Drop` #[derive(Debug)] pub struct Py(pub *mut ffi::PyObject, 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(ptr, std::marker::PhantomData) } /// Cast from ffi::PyObject ptr to a concrete object. #[inline] pub fn from_owned_ptr_or_panic(ptr: *mut ffi::PyObject) -> Py { if ptr.is_null() { ::err::panic_after_error(); } else { unsafe{ Py::from_owned_ptr(ptr) } } } /// 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 fn from_owned_ptr_or_err(py: Python, ptr: *mut ffi::PyObject) -> PyResult> { if ptr.is_null() { Err(PyErr::fetch(py)) } else { Ok(unsafe{ Py::from_owned_ptr(ptr) }) } } /// 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::from_owned_ptr(ptr) } /// Gets the reference count of the ffi::PyObject pointer. #[inline] pub fn get_refcnt(&self) -> isize { unsafe { ffi::Py_REFCNT(self.0) } } /// Clone self, Calls Py_INCREF() on the ptr. #[inline] pub fn clone_ref(&self, _py: Python) -> Py { unsafe { Py::from_borrowed_ptr(self.0) } } /// Casts the `Py` imstance to a concrete Python object type. /// Fails with `PyDowncastError` if the object is not of the expected type. #[inline] pub fn cast_into(self, py: Python) -> Result where D: PyDowncastInto { ::downcast_into(py, self) } /// Calls `ffi::Py_DECREF` and sets ptr to null value. #[inline] pub unsafe fn drop_ref(&mut self) { ffi::Py_DECREF(self.0); self.0 = std::ptr::null_mut(); } } impl Py where T: PyTypeInfo, { /// Create new instance of T and move under python management /// Returns `Py`. pub fn new(py: Python, f: F) -> PyResult> where F: FnOnce(::PyToken) -> T, T: PyObjectAlloc { let ob = f(PyToken(PhantomData)); let ob = unsafe { let ob = try!(>::alloc(py, ob)); Py::from_owned_ptr(ob) }; Ok(ob) } /// Create new instance of `T` and move under python management. /// Returns references to `T` pub fn new_ref<'p, F>(py: Python<'p>, f: F) -> PyResult<&'p T> where F: FnOnce(::PyToken) -> T, T: PyObjectAlloc + PyDowncastFrom { let ob = f(PyToken(PhantomData)); unsafe { let ob = try!(>::alloc(py, ob)); Ok(py.cast_from_ptr(ob)) } } /// Create new instance of `T` and move under python management. /// Returns mutable references to `T` pub fn new_mut<'p, F>(py: Python<'p>, f: F) -> PyResult<&'p mut T> where F: FnOnce(::PyToken) -> T, T: PyObjectAlloc + PyDowncastFrom { let ob = f(PyToken(PhantomData)); unsafe { let ob = try!(>::alloc(py, ob)); Ok(py.mut_cast_from_ptr(ob)) } } } impl AsPyRef for Py where T: PyTypeInfo { #[inline] default fn as_ref(&self, _py: Python) -> &T { let offset = ::offset(); unsafe { let ptr = (self.as_ptr() as *mut u8).offset(offset) as *mut T; ptr.as_ref().unwrap() } } #[inline] default fn as_mut(&self, _py: Python) -> &mut T { let offset = ::offset(); unsafe { let ptr = (self.as_ptr() as *mut u8).offset(offset) as *mut T; ptr.as_mut().unwrap() } } } impl AsPyRef for Py where T: PyTypeInfo + PyNativeType { #[inline] fn as_ref(&self, _py: Python) -> &T { unsafe {std::mem::transmute(self)} } #[inline] fn as_mut(&self, _py: Python) -> &mut T { unsafe {std::mem::transmute(self as *const _ as *mut T)} } } impl ToPyObject for Py { 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 } } 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; 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) { if !self.0.is_null() { let _gil_guard = Python::acquire_gil(); unsafe { ffi::Py_DECREF(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 PyDowncastInto for Py where T: PyTypeInfo { fn downcast_into<'p, I>(py: Python<'p>, ob: I) -> Result> where I: IntoPyPointer { unsafe{ let ptr = ob.into_ptr(); if T::is_instance(ptr) { Ok(Py::from_owned_ptr(ptr)) } else { ffi::Py_DECREF(ptr); Err(PyDowncastError(py, None)) } } } fn downcast_into_from_ptr<'p>(py: Python<'p>, ptr: *mut ffi::PyObject) -> Result> { unsafe{ if T::is_instance(ptr) { Ok(Py::from_owned_ptr(ptr)) } else { ffi::Py_DECREF(ptr); Err(PyDowncastError(py, None)) } } } fn unchecked_downcast_into<'p, I>(ob: I) -> Self where I: IntoPyPointer { unsafe{ Py::from_owned_ptr(ob.into_ptr()) } } } impl<'a, T> FromPyObject<'a> for Py where T: ToPyPointer + FromPyObject<'a> { /// Extracts `Self` from the source `PyObject`. fn extract(ob: &'a PyInstance) -> PyResult { unsafe { ob.extract::().map(|val| Py::from_borrowed_ptr(val.as_ptr())) } } }