about summary refs log tree commit diff
path: root/third_party/immer/extra/python/src/immer-raw.cpp
//
// immer: immutable data structures for C++
// Copyright (C) 2016, 2017, 2018 Juan Pedro Bolivar Puente
//
// This software is distributed under the Boost Software License, Version 1.0.
// See accompanying file LICENSE or copy at http://boost.org/LICENSE_1_0.txt
//

extern "C" {
#include <Python.h>
#include <structmember.h>
}

#include <immer/vector.hpp>
#include <immer/algorithm.hpp>
#include <immer/refcount/unsafe_refcount_policy.hpp>

#include <iostream>

namespace {

struct heap_t
{
    template <typename ...Tags>
    static void* allocate(std::size_t size, Tags...)
    {
        return PyMem_Malloc(size);
    }

    template <typename ...Tags>
    static void deallocate(std::size_t, void* obj, Tags...)
    {
        PyMem_Free(obj);
    }
};

struct object_t
{
    struct wrap_t {};
    struct adopt_t {};

    PyObject* ptr_ = nullptr;

    object_t() = delete;
    ~object_t() { Py_XDECREF(ptr_); }

    explicit object_t(PyObject* p, wrap_t)  : ptr_{p} {}
    explicit object_t(PyObject* p, adopt_t) : ptr_{p}
    {
        assert(p);
        Py_INCREF(p);
    }

    static object_t wrap(PyObject* p)  { return object_t{p, wrap_t{}}; }
    static object_t adopt(PyObject* p) { return object_t{p, adopt_t{}}; }

    object_t(const object_t& o) : ptr_(o.ptr_) { Py_INCREF(ptr_); }
    object_t(object_t&& o) { std::swap(ptr_, o.ptr_); }

    object_t& operator=(const object_t& o)
    {
        Py_XINCREF(o.ptr_);
        Py_XDECREF(ptr_);
        ptr_ = o.ptr_;
        return *this;
    }
    object_t& operator=(object_t&& o)
    {
        std::swap(ptr_, o.ptr_);
        return *this;
    }

    PyObject* release()
    {
        auto p = ptr_;
        ptr_ = nullptr;
        return p;
    }

    PyObject* get() const { return ptr_; }
};

using memory_t = immer::memory_policy<
    immer::unsafe_free_list_heap_policy<heap_t>,
    immer::unsafe_refcount_policy>;

using vector_impl_t = immer::vector<object_t, memory_t>;

struct vector_t
{
    PyObject_HEAD
    vector_impl_t impl;
    PyObject*     in_weakreflist;

    static PyTypeObject type;
};

vector_t* empty_vector = nullptr;

vector_t* make_vector()
{
    auto* v = PyObject_GC_New(vector_t, &vector_t::type);
    new (&v->impl) vector_impl_t{};
    v->in_weakreflist = nullptr;
    PyObject_GC_Track((PyObject*)v);
    return v;
}

vector_t* make_vector(vector_impl_t&& impl)
{
    auto v = PyObject_GC_New(vector_t, &vector_t::type);
    new (&v->impl) vector_impl_t{std::move(impl)};
    v->in_weakreflist = nullptr;
    PyObject_GC_Track((PyObject*)v);
    return v;
}

auto todo()
{
    PyErr_SetString(PyExc_RuntimeError, "immer: todo!");
    return nullptr;
}

void vector_dealloc(vector_t* self)
{
    if (self->in_weakreflist != nullptr)
        PyObject_ClearWeakRefs((PyObject*)self);

    PyObject_GC_UnTrack((PyObject*)self);
    Py_TRASHCAN_SAFE_BEGIN(self);

    self->impl.~vector_impl_t();

    PyObject_GC_Del(self);
    Py_TRASHCAN_SAFE_END(self);
}

PyObject* vector_to_list(vector_t* self)
{
    auto list = PyList_New(self->impl.size());
    auto idx  = 0;
    immer::for_each(self->impl, [&] (auto&& obj) {
            auto o = obj.get();
            Py_INCREF(o);
            PyList_SET_ITEM(list, idx, o);
            ++idx;
        });
    return list;
}

PyObject* vector_repr(vector_t *self)
{
    auto list = vector_to_list(self);
    auto list_repr = PyObject_Repr(list);
    Py_DECREF(list);

    if (!list_repr) return nullptr;

#if PY_MAJOR_VERSION >= 3
    auto s = PyUnicode_FromFormat("%s%U%s", "immer.vector(", list_repr, ")");
    Py_DECREF(list_repr);
#else
    auto s = PyString_FromString("immer.vector(");
    PyString_ConcatAndDel(&s, list_repr);
    PyString_ConcatAndDel(&s, PyString_FromString(")"));
#endif
    return s;
}

Py_ssize_t vector_len(vector_t* self)
{
    return self->impl.size();
}

PyObject* vector_extend(vector_t* self, PyObject* iterable)
{
    return todo();
}

vector_t* vector_append(vector_t* self, PyObject *obj)
{
    assert(obj != nullptr);
    return make_vector(self->impl.push_back(object_t::adopt(obj)));
}

vector_t* vector_set(vector_t* self, PyObject* args)
{
    PyObject* obj = nullptr;
    Py_ssize_t pos;
    // the n parses for size, the O parses for a Python object
    if(!PyArg_ParseTuple(args, "nO", &pos, &obj)) {
        return nullptr;
    }
    if (pos < 0)
        pos += self->impl.size();
    if (pos < 0 || pos > (Py_ssize_t)self->impl.size()) {
        PyErr_Format(PyExc_IndexError, "Index out of range: %zi", pos);
        return nullptr;
    }
    return make_vector(self->impl.set(pos, object_t::adopt(obj)));
}

PyObject* vector_new(PyTypeObject* subtype, PyObject *args, PyObject *kwds)
{
    Py_INCREF(empty_vector);
    return (PyObject*)empty_vector;
}

long vector_hash(vector_t* self)
{
    todo();
    return 0;
}

PyObject* vector_get_item(vector_t* self, Py_ssize_t pos)
{
    if (pos < 0)
        pos += self->impl.size();
    if (pos < 0 || pos >= (Py_ssize_t)self->impl.size()) {
        PyErr_Format(PyExc_IndexError, "Index out of range: %zi", pos);
        return nullptr;
    }
    auto r = self->impl[pos];
    return r.release();
}

PyObject* vector_subscript(vector_t* self, PyObject* item)
{
    if (PyIndex_Check(item)) {
        auto i = PyNumber_AsSsize_t(item, PyExc_IndexError);
        if (i == -1 && PyErr_Occurred())
            return nullptr;
        return vector_get_item(self, i);
    } else if (PySlice_Check(item)) {
        return todo();
    } else {
        PyErr_Format(PyExc_TypeError,
                     "vector indices must be integers, not %.200s",
                     Py_TYPE(item)->tp_name);
        return nullptr;
    }
}

PyObject* vector_repeat(vector_t* self, Py_ssize_t n)
{
    return todo();
}

int vector_traverse(vector_t* self, visitproc visit, void* arg)
{
    auto result = 0;
    immer::all_of(self->impl, [&] (auto&& o) {
            return 0 == (result = [&] {
                Py_VISIT(o.get());
                return 0;
            }());
        });
    return result;
}

PyObject* vector_richcompare(PyObject* v, PyObject* w, int op)
{
    return todo();
}

PyObject* vector_iter(PyObject* self)
{
    return todo();
}

PyMethodDef vector_methods[] =
{
    {"append",      (PyCFunction)vector_append, METH_O, "Appends an element"},
    {"set",         (PyCFunction)vector_set, METH_VARARGS, "Inserts an element at the specified position"},
    {"extend",      (PyCFunction)vector_extend, METH_O|METH_COEXIST, "Extend"},
    {"tolist",      (PyCFunction)vector_to_list, METH_NOARGS, "Convert to list"},
    {0}
};

PyMemberDef vector_members[] =
{
    {0}  /* sentinel */
};

PySequenceMethods vector_sequence_methods =
{
    (lenfunc)vector_len,             /* sq_length */
    (binaryfunc)vector_extend,       /* sq_concat */
    (ssizeargfunc)vector_repeat,     /* sq_repeat */
    (ssizeargfunc)vector_get_item,   /* sq_item */
    0,                               /* sq_slice */
    0,                               /* sq_ass_item */
    0,                               /* sq_ass_slice */
    0,                               /* sq_contains */
    0,                               /* sq_inplace_concat */
    0,                               /* sq_inplace_repeat */
};

PyMappingMethods vector_mapping_methods =
{
    (lenfunc)vector_len,
    (binaryfunc)vector_subscript,
    0
};

PyTypeObject vector_t::type =
{
    PyVarObject_HEAD_INIT(NULL, 0)
    "immer.Vector",                             /* tp_name        */
    sizeof(vector_t),                           /* tp_basicsize   */
    0,		                                /* tp_itemsize    */
    (destructor)vector_dealloc,                 /* tp_dealloc     */
    0,                                          /* tp_print       */
    0,                                          /* tp_getattr     */
    0,                                          /* tp_setattr     */
    0,                                          /* tp_compare     */
    (reprfunc)vector_repr,                      /* tp_repr        */
    0,                                          /* tp_as_number   */
    &vector_sequence_methods,                   /* tp_as_sequence */
    &vector_mapping_methods,                    /* tp_as_mapping  */
    (hashfunc)vector_hash,                      /* tp_hash        */
    0,                                          /* tp_call        */
    0,                                          /* tp_str         */
    0,                                          /* tp_getattro    */
    0,                                          /* tp_setattro    */
    0,                                          /* tp_as_buffer   */
    Py_TPFLAGS_DEFAULT | Py_TPFLAGS_HAVE_GC,    /* tp_flags       */
    "",                                         /* tp_doc         */
    (traverseproc)vector_traverse,              /* tp_traverse       */
    0,                                          /* tp_clear          */
    vector_richcompare,                         /* tp_richcompare    */
    offsetof(vector_t, in_weakreflist),         /* tp_weaklistoffset */
    vector_iter,                                /* tp_iter           */
    0,                                          /* tp_iternext       */
    vector_methods,                             /* tp_methods        */
    vector_members,                             /* tp_members        */
    0,                                          /* tp_getset         */
    0,                                          /* tp_base           */
    0,                                          /* tp_dict           */
    0,                                          /* tp_descr_get      */
    0,                                          /* tp_descr_set      */
    0,                                          /* tp_dictoffset     */
    0,                                          /* tp_init           */
    0,                                          /* tp_alloc */
    vector_new,                                 /* tp_new   */
};

#if PY_MAJOR_VERSION >= 3
struct PyModuleDef module_def =
{
    PyModuleDef_HEAD_INIT,
    "immer_python_module", /* m_name */
    "",                  /* m_doc */
    -1,                  /* m_size */
    /module_methods,     /* m_methods */
    0,                   /* m_reload */
    0,                   /* m_traverse */
    0,                   /* m_clear */
    0,                   /* m_free */
};
#endif

PyMethodDef module_methods[] = {
    {0, 0, 0, 0}
};

PyObject* module_init()
{
    if (PyType_Ready(&vector_t::type) < 0)
        return nullptr;

#if PY_MAJOR_VERSION >= 3
    auto m = PyModule_Create(&module_def);
#else
    auto m = Py_InitModule3("immer_python_module", module_methods, "");
#endif
    if (!m)
        return nullptr;

    if (!empty_vector)
        empty_vector = make_vector();

    Py_INCREF(&vector_t::type);
    PyModule_AddObject(m, "Vector", (PyObject*) &vector_t::type);
    return m;
}

} // anonymous namespace

extern "C" {
#if PY_MAJOR_VERSION >= 3
PyMODINIT_FUNC PyInit_immer_python_module()
{
    return module_init();
}
#else
PyMODINIT_FUNC initimmer_python_module()
{
    module_init();
}
#endif
}