Protocol Buffers - Google's data interchange format (grpc依赖)
https://developers.google.com/protocol-buffers/
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
526 lines
20 KiB
526 lines
20 KiB
/* |
|
* Copyright (c) 2009-2021, Google LLC |
|
* All rights reserved. |
|
* |
|
* Redistribution and use in source and binary forms, with or without |
|
* modification, are permitted provided that the following conditions are met: |
|
* * Redistributions of source code must retain the above copyright |
|
* notice, this list of conditions and the following disclaimer. |
|
* * Redistributions in binary form must reproduce the above copyright |
|
* notice, this list of conditions and the following disclaimer in the |
|
* documentation and/or other materials provided with the distribution. |
|
* * Neither the name of Google LLC nor the |
|
* names of its contributors may be used to endorse or promote products |
|
* derived from this software without specific prior written permission. |
|
* |
|
* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" |
|
* AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE |
|
* IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE |
|
* ARE DISCLAIMED. IN NO EVENT SHALL Google LLC BE LIABLE FOR ANY DIRECT, |
|
* INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES |
|
* (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; |
|
* LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND |
|
* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
|
* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS |
|
* SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
|
*/ |
|
|
|
#include "python/map.h" |
|
|
|
#include "python/convert.h" |
|
#include "python/message.h" |
|
#include "python/protobuf.h" |
|
#include "upb/collections/map.h" |
|
#include "upb/reflection/def.h" |
|
|
|
// ----------------------------------------------------------------------------- |
|
// MapContainer |
|
// ----------------------------------------------------------------------------- |
|
|
|
typedef struct { |
|
PyObject_HEAD; |
|
PyObject* arena; |
|
// The field descriptor (upb_FieldDef*). |
|
// The low bit indicates whether the container is reified (see ptr below). |
|
// - low bit set: repeated field is a stub (empty map, no underlying data). |
|
// - low bit clear: repeated field is reified (points to upb_Array). |
|
uintptr_t field; |
|
union { |
|
PyObject* parent; // stub: owning pointer to parent message. |
|
upb_Map* map; // reified: the data for this array. |
|
} ptr; |
|
int version; |
|
} PyUpb_MapContainer; |
|
|
|
static PyObject* PyUpb_MapIterator_New(PyUpb_MapContainer* map); |
|
|
|
static bool PyUpb_MapContainer_IsStub(PyUpb_MapContainer* self) { |
|
return self->field & 1; |
|
} |
|
|
|
// If the map is reified, returns it. Otherwise, returns NULL. |
|
// If NULL is returned, the object is empty and has no underlying data. |
|
static upb_Map* PyUpb_MapContainer_GetIfReified(PyUpb_MapContainer* self) { |
|
return PyUpb_MapContainer_IsStub(self) ? NULL : self->ptr.map; |
|
} |
|
|
|
static const upb_FieldDef* PyUpb_MapContainer_GetField( |
|
PyUpb_MapContainer* self) { |
|
return (const upb_FieldDef*)(self->field & ~(uintptr_t)1); |
|
} |
|
|
|
static void PyUpb_MapContainer_Dealloc(void* _self) { |
|
PyUpb_MapContainer* self = _self; |
|
Py_DECREF(self->arena); |
|
if (PyUpb_MapContainer_IsStub(self)) { |
|
PyUpb_Message_CacheDelete(self->ptr.parent, |
|
PyUpb_MapContainer_GetField(self)); |
|
Py_DECREF(self->ptr.parent); |
|
} else { |
|
PyUpb_ObjCache_Delete(self->ptr.map); |
|
} |
|
PyUpb_Dealloc(_self); |
|
} |
|
|
|
PyTypeObject* PyUpb_MapContainer_GetClass(const upb_FieldDef* f) { |
|
assert(upb_FieldDef_IsMap(f)); |
|
PyUpb_ModuleState* state = PyUpb_ModuleState_Get(); |
|
const upb_FieldDef* val = |
|
upb_MessageDef_Field(upb_FieldDef_MessageSubDef(f), 1); |
|
assert(upb_FieldDef_Number(val) == 2); |
|
return upb_FieldDef_IsSubMessage(val) ? state->message_map_container_type |
|
: state->scalar_map_container_type; |
|
} |
|
|
|
PyObject* PyUpb_MapContainer_NewStub(PyObject* parent, const upb_FieldDef* f, |
|
PyObject* arena) { |
|
// We only create stubs when the parent is reified, by convention. However |
|
// this is not an invariant: the parent could become reified at any time. |
|
assert(PyUpb_Message_GetIfReified(parent) == NULL); |
|
PyTypeObject* cls = PyUpb_MapContainer_GetClass(f); |
|
PyUpb_MapContainer* map = (void*)PyType_GenericAlloc(cls, 0); |
|
map->arena = arena; |
|
map->field = (uintptr_t)f | 1; |
|
map->ptr.parent = parent; |
|
map->version = 0; |
|
Py_INCREF(arena); |
|
Py_INCREF(parent); |
|
return &map->ob_base; |
|
} |
|
|
|
void PyUpb_MapContainer_Reify(PyObject* _self, upb_Map* map) { |
|
PyUpb_MapContainer* self = (PyUpb_MapContainer*)_self; |
|
if (!map) { |
|
const upb_FieldDef* f = PyUpb_MapContainer_GetField(self); |
|
upb_Arena* arena = PyUpb_Arena_Get(self->arena); |
|
const upb_MessageDef* entry_m = upb_FieldDef_MessageSubDef(f); |
|
const upb_FieldDef* key_f = upb_MessageDef_Field(entry_m, 0); |
|
const upb_FieldDef* val_f = upb_MessageDef_Field(entry_m, 1); |
|
map = upb_Map_New(arena, upb_FieldDef_CType(key_f), |
|
upb_FieldDef_CType(val_f)); |
|
} |
|
PyUpb_ObjCache_Add(map, &self->ob_base); |
|
Py_DECREF(self->ptr.parent); |
|
self->ptr.map = map; // Overwrites self->ptr.parent. |
|
self->field &= ~(uintptr_t)1; |
|
assert(!PyUpb_MapContainer_IsStub(self)); |
|
} |
|
|
|
void PyUpb_MapContainer_Invalidate(PyObject* obj) { |
|
PyUpb_MapContainer* self = (PyUpb_MapContainer*)obj; |
|
self->version++; |
|
} |
|
|
|
upb_Map* PyUpb_MapContainer_EnsureReified(PyObject* _self) { |
|
PyUpb_MapContainer* self = (PyUpb_MapContainer*)_self; |
|
self->version++; |
|
upb_Map* map = PyUpb_MapContainer_GetIfReified(self); |
|
if (map) return map; // Already writable. |
|
|
|
const upb_FieldDef* f = PyUpb_MapContainer_GetField(self); |
|
upb_Arena* arena = PyUpb_Arena_Get(self->arena); |
|
const upb_MessageDef* entry_m = upb_FieldDef_MessageSubDef(f); |
|
const upb_FieldDef* key_f = upb_MessageDef_Field(entry_m, 0); |
|
const upb_FieldDef* val_f = upb_MessageDef_Field(entry_m, 1); |
|
map = |
|
upb_Map_New(arena, upb_FieldDef_CType(key_f), upb_FieldDef_CType(val_f)); |
|
upb_MessageValue msgval = {.map_val = map}; |
|
PyUpb_Message_SetConcreteSubobj(self->ptr.parent, f, msgval); |
|
PyUpb_MapContainer_Reify((PyObject*)self, map); |
|
return map; |
|
} |
|
|
|
bool PyUpb_MapContainer_Set(PyUpb_MapContainer* self, upb_Map* map, |
|
upb_MessageValue key, upb_MessageValue val, |
|
upb_Arena* arena) { |
|
switch (upb_Map_Insert(map, key, val, arena)) { |
|
case kUpb_MapInsertStatus_Inserted: |
|
return true; |
|
case kUpb_MapInsertStatus_Replaced: |
|
// We did not insert a new key, undo the previous invalidate. |
|
self->version--; |
|
return true; |
|
case kUpb_MapInsertStatus_OutOfMemory: |
|
return false; |
|
} |
|
return false; // Unreachable, silence compiler warning. |
|
} |
|
|
|
int PyUpb_MapContainer_AssignSubscript(PyObject* _self, PyObject* key, |
|
PyObject* val) { |
|
PyUpb_MapContainer* self = (PyUpb_MapContainer*)_self; |
|
upb_Map* map = PyUpb_MapContainer_EnsureReified(_self); |
|
const upb_FieldDef* f = PyUpb_MapContainer_GetField(self); |
|
const upb_MessageDef* entry_m = upb_FieldDef_MessageSubDef(f); |
|
const upb_FieldDef* key_f = upb_MessageDef_Field(entry_m, 0); |
|
const upb_FieldDef* val_f = upb_MessageDef_Field(entry_m, 1); |
|
upb_Arena* arena = PyUpb_Arena_Get(self->arena); |
|
upb_MessageValue u_key, u_val; |
|
if (!PyUpb_PyToUpb(key, key_f, &u_key, arena)) return -1; |
|
|
|
if (val) { |
|
if (!PyUpb_PyToUpb(val, val_f, &u_val, arena)) return -1; |
|
if (!PyUpb_MapContainer_Set(self, map, u_key, u_val, arena)) return -1; |
|
} else { |
|
if (!upb_Map_Delete(map, u_key, NULL)) { |
|
PyErr_Format(PyExc_KeyError, "Key not present in map"); |
|
return -1; |
|
} |
|
} |
|
return 0; |
|
} |
|
|
|
PyObject* PyUpb_MapContainer_Subscript(PyObject* _self, PyObject* key) { |
|
PyUpb_MapContainer* self = (PyUpb_MapContainer*)_self; |
|
upb_Map* map = PyUpb_MapContainer_GetIfReified(self); |
|
const upb_FieldDef* f = PyUpb_MapContainer_GetField(self); |
|
const upb_MessageDef* entry_m = upb_FieldDef_MessageSubDef(f); |
|
const upb_FieldDef* key_f = upb_MessageDef_Field(entry_m, 0); |
|
const upb_FieldDef* val_f = upb_MessageDef_Field(entry_m, 1); |
|
upb_Arena* arena = PyUpb_Arena_Get(self->arena); |
|
upb_MessageValue u_key, u_val; |
|
if (!PyUpb_PyToUpb(key, key_f, &u_key, arena)) return NULL; |
|
if (!map || !upb_Map_Get(map, u_key, &u_val)) { |
|
map = PyUpb_MapContainer_EnsureReified(_self); |
|
upb_Arena* arena = PyUpb_Arena_Get(self->arena); |
|
if (upb_FieldDef_IsSubMessage(val_f)) { |
|
const upb_Message* m = upb_FieldDef_MessageSubDef(val_f); |
|
const upb_MiniTable* layout = upb_MessageDef_MiniTable(m); |
|
u_val.msg_val = upb_Message_New(layout, arena); |
|
} else { |
|
memset(&u_val, 0, sizeof(u_val)); |
|
} |
|
if (!PyUpb_MapContainer_Set(self, map, u_key, u_val, arena)) return false; |
|
} |
|
return PyUpb_UpbToPy(u_val, val_f, self->arena); |
|
} |
|
|
|
PyObject* PyUpb_MapContainer_Contains(PyObject* _self, PyObject* key) { |
|
PyUpb_MapContainer* self = (PyUpb_MapContainer*)_self; |
|
upb_Map* map = PyUpb_MapContainer_GetIfReified(self); |
|
if (!map) Py_RETURN_FALSE; |
|
const upb_FieldDef* f = PyUpb_MapContainer_GetField(self); |
|
const upb_MessageDef* entry_m = upb_FieldDef_MessageSubDef(f); |
|
const upb_FieldDef* key_f = upb_MessageDef_Field(entry_m, 0); |
|
upb_MessageValue u_key; |
|
if (!PyUpb_PyToUpb(key, key_f, &u_key, NULL)) return NULL; |
|
if (upb_Map_Get(map, u_key, NULL)) { |
|
Py_RETURN_TRUE; |
|
} else { |
|
Py_RETURN_FALSE; |
|
} |
|
} |
|
|
|
PyObject* PyUpb_MapContainer_Clear(PyObject* _self, PyObject* key) { |
|
upb_Map* map = PyUpb_MapContainer_EnsureReified(_self); |
|
upb_Map_Clear(map); |
|
Py_RETURN_NONE; |
|
} |
|
|
|
static PyObject* PyUpb_MapContainer_Get(PyObject* _self, PyObject* args, |
|
PyObject* kwargs) { |
|
PyUpb_MapContainer* self = (PyUpb_MapContainer*)_self; |
|
static const char* kwlist[] = {"key", "default", NULL}; |
|
PyObject* key; |
|
PyObject* default_value = NULL; |
|
upb_Map* map = PyUpb_MapContainer_GetIfReified(self); |
|
if (!PyArg_ParseTupleAndKeywords(args, kwargs, "O|O", (char**)kwlist, &key, |
|
&default_value)) { |
|
return NULL; |
|
} |
|
|
|
const upb_FieldDef* f = PyUpb_MapContainer_GetField(self); |
|
const upb_MessageDef* entry_m = upb_FieldDef_MessageSubDef(f); |
|
const upb_FieldDef* key_f = upb_MessageDef_Field(entry_m, 0); |
|
const upb_FieldDef* val_f = upb_MessageDef_Field(entry_m, 1); |
|
upb_Arena* arena = PyUpb_Arena_Get(self->arena); |
|
upb_MessageValue u_key, u_val; |
|
if (!PyUpb_PyToUpb(key, key_f, &u_key, arena)) return NULL; |
|
if (map && upb_Map_Get(map, u_key, &u_val)) { |
|
return PyUpb_UpbToPy(u_val, val_f, self->arena); |
|
} |
|
if (default_value) { |
|
Py_INCREF(default_value); |
|
return default_value; |
|
} |
|
Py_RETURN_NONE; |
|
} |
|
|
|
static PyObject* PyUpb_MapContainer_GetEntryClass(PyObject* _self, |
|
PyObject* arg) { |
|
PyUpb_MapContainer* self = (PyUpb_MapContainer*)_self; |
|
const upb_FieldDef* f = PyUpb_MapContainer_GetField(self); |
|
const upb_MessageDef* entry_m = upb_FieldDef_MessageSubDef(f); |
|
return PyUpb_Descriptor_GetClass(entry_m); |
|
} |
|
|
|
Py_ssize_t PyUpb_MapContainer_Length(PyObject* _self) { |
|
PyUpb_MapContainer* self = (PyUpb_MapContainer*)_self; |
|
upb_Map* map = PyUpb_MapContainer_GetIfReified(self); |
|
return map ? upb_Map_Size(map) : 0; |
|
} |
|
|
|
PyUpb_MapContainer* PyUpb_MapContainer_Check(PyObject* _self) { |
|
PyUpb_ModuleState* state = PyUpb_ModuleState_Get(); |
|
if (!PyObject_TypeCheck(_self, state->message_map_container_type) && |
|
!PyObject_TypeCheck(_self, state->scalar_map_container_type)) { |
|
PyErr_Format(PyExc_TypeError, "Expected protobuf map, but got %R", _self); |
|
return NULL; |
|
} |
|
return (PyUpb_MapContainer*)_self; |
|
} |
|
|
|
int PyUpb_Message_InitMapAttributes(PyObject* map, PyObject* value, |
|
const upb_FieldDef* f); |
|
|
|
static PyObject* PyUpb_MapContainer_MergeFrom(PyObject* _self, PyObject* _arg) { |
|
PyUpb_MapContainer* self = (PyUpb_MapContainer*)_self; |
|
const upb_FieldDef* f = PyUpb_MapContainer_GetField(self); |
|
|
|
if (PyDict_Check(_arg)) { |
|
return PyErr_Format(PyExc_AttributeError, "Merging of dict is not allowed"); |
|
} |
|
|
|
if (PyUpb_Message_InitMapAttributes(_self, _arg, f) < 0) { |
|
return NULL; |
|
} |
|
|
|
Py_RETURN_NONE; |
|
} |
|
|
|
static PyObject* PyUpb_MapContainer_Repr(PyObject* _self) { |
|
PyUpb_MapContainer* self = (PyUpb_MapContainer*)_self; |
|
upb_Map* map = PyUpb_MapContainer_GetIfReified(self); |
|
PyObject* dict = PyDict_New(); |
|
if (map) { |
|
const upb_FieldDef* f = PyUpb_MapContainer_GetField(self); |
|
const upb_MessageDef* entry_m = upb_FieldDef_MessageSubDef(f); |
|
const upb_FieldDef* key_f = upb_MessageDef_Field(entry_m, 0); |
|
const upb_FieldDef* val_f = upb_MessageDef_Field(entry_m, 1); |
|
size_t iter = kUpb_Map_Begin; |
|
upb_MessageValue map_key, map_val; |
|
while (upb_Map_Next(map, &map_key, &map_val, &iter)) { |
|
PyObject* key = PyUpb_UpbToPy(map_key, key_f, self->arena); |
|
PyObject* val = PyUpb_UpbToPy(map_val, val_f, self->arena); |
|
if (!key || !val) { |
|
Py_XDECREF(key); |
|
Py_XDECREF(val); |
|
Py_DECREF(dict); |
|
return NULL; |
|
} |
|
PyDict_SetItem(dict, key, val); |
|
Py_DECREF(key); |
|
Py_DECREF(val); |
|
} |
|
} |
|
PyObject* repr = PyObject_Repr(dict); |
|
Py_DECREF(dict); |
|
return repr; |
|
} |
|
|
|
PyObject* PyUpb_MapContainer_GetOrCreateWrapper(upb_Map* map, |
|
const upb_FieldDef* f, |
|
PyObject* arena) { |
|
PyUpb_MapContainer* ret = (void*)PyUpb_ObjCache_Get(map); |
|
if (ret) return &ret->ob_base; |
|
|
|
PyTypeObject* cls = PyUpb_MapContainer_GetClass(f); |
|
ret = (void*)PyType_GenericAlloc(cls, 0); |
|
ret->arena = arena; |
|
ret->field = (uintptr_t)f; |
|
ret->ptr.map = map; |
|
ret->version = 0; |
|
Py_INCREF(arena); |
|
PyUpb_ObjCache_Add(map, &ret->ob_base); |
|
return &ret->ob_base; |
|
} |
|
|
|
// ----------------------------------------------------------------------------- |
|
// ScalarMapContainer |
|
// ----------------------------------------------------------------------------- |
|
|
|
static PyMethodDef PyUpb_ScalarMapContainer_Methods[] = { |
|
{"__contains__", PyUpb_MapContainer_Contains, METH_O, |
|
"Tests whether a key is a member of the map."}, |
|
{"clear", PyUpb_MapContainer_Clear, METH_NOARGS, |
|
"Removes all elements from the map."}, |
|
{"get", (PyCFunction)PyUpb_MapContainer_Get, METH_VARARGS | METH_KEYWORDS, |
|
"Gets the value for the given key if present, or otherwise a default"}, |
|
{"GetEntryClass", PyUpb_MapContainer_GetEntryClass, METH_NOARGS, |
|
"Return the class used to build Entries of (key, value) pairs."}, |
|
{"MergeFrom", PyUpb_MapContainer_MergeFrom, METH_O, |
|
"Merges a map into the current map."}, |
|
/* |
|
{ "__deepcopy__", (PyCFunction)DeepCopy, METH_VARARGS, |
|
"Makes a deep copy of the class." }, |
|
{ "__reduce__", (PyCFunction)Reduce, METH_NOARGS, |
|
"Outputs picklable representation of the repeated field." }, |
|
*/ |
|
{NULL, NULL}, |
|
}; |
|
|
|
static PyType_Slot PyUpb_ScalarMapContainer_Slots[] = { |
|
{Py_tp_dealloc, PyUpb_MapContainer_Dealloc}, |
|
{Py_mp_length, PyUpb_MapContainer_Length}, |
|
{Py_mp_subscript, PyUpb_MapContainer_Subscript}, |
|
{Py_mp_ass_subscript, PyUpb_MapContainer_AssignSubscript}, |
|
{Py_tp_methods, PyUpb_ScalarMapContainer_Methods}, |
|
{Py_tp_iter, PyUpb_MapIterator_New}, |
|
{Py_tp_repr, PyUpb_MapContainer_Repr}, |
|
{0, NULL}, |
|
}; |
|
|
|
static PyType_Spec PyUpb_ScalarMapContainer_Spec = { |
|
PYUPB_MODULE_NAME ".ScalarMapContainer", |
|
sizeof(PyUpb_MapContainer), |
|
0, |
|
Py_TPFLAGS_DEFAULT, |
|
PyUpb_ScalarMapContainer_Slots, |
|
}; |
|
|
|
// ----------------------------------------------------------------------------- |
|
// MessageMapContainer |
|
// ----------------------------------------------------------------------------- |
|
|
|
static PyMethodDef PyUpb_MessageMapContainer_Methods[] = { |
|
{"__contains__", PyUpb_MapContainer_Contains, METH_O, |
|
"Tests whether the map contains this element."}, |
|
{"clear", PyUpb_MapContainer_Clear, METH_NOARGS, |
|
"Removes all elements from the map."}, |
|
{"get", (PyCFunction)PyUpb_MapContainer_Get, METH_VARARGS | METH_KEYWORDS, |
|
"Gets the value for the given key if present, or otherwise a default"}, |
|
{"get_or_create", PyUpb_MapContainer_Subscript, METH_O, |
|
"Alias for getitem, useful to make explicit that the map is mutated."}, |
|
{"GetEntryClass", PyUpb_MapContainer_GetEntryClass, METH_NOARGS, |
|
"Return the class used to build Entries of (key, value) pairs."}, |
|
{"MergeFrom", PyUpb_MapContainer_MergeFrom, METH_O, |
|
"Merges a map into the current map."}, |
|
/* |
|
{ "__deepcopy__", (PyCFunction)DeepCopy, METH_VARARGS, |
|
"Makes a deep copy of the class." }, |
|
{ "__reduce__", (PyCFunction)Reduce, METH_NOARGS, |
|
"Outputs picklable representation of the repeated field." }, |
|
*/ |
|
{NULL, NULL}, |
|
}; |
|
|
|
static PyType_Slot PyUpb_MessageMapContainer_Slots[] = { |
|
{Py_tp_dealloc, PyUpb_MapContainer_Dealloc}, |
|
{Py_mp_length, PyUpb_MapContainer_Length}, |
|
{Py_mp_subscript, PyUpb_MapContainer_Subscript}, |
|
{Py_mp_ass_subscript, PyUpb_MapContainer_AssignSubscript}, |
|
{Py_tp_methods, PyUpb_MessageMapContainer_Methods}, |
|
{Py_tp_iter, PyUpb_MapIterator_New}, |
|
{Py_tp_repr, PyUpb_MapContainer_Repr}, |
|
{0, NULL}}; |
|
|
|
static PyType_Spec PyUpb_MessageMapContainer_Spec = { |
|
PYUPB_MODULE_NAME ".MessageMapContainer", sizeof(PyUpb_MapContainer), 0, |
|
Py_TPFLAGS_DEFAULT, PyUpb_MessageMapContainer_Slots}; |
|
|
|
// ----------------------------------------------------------------------------- |
|
// MapIterator |
|
// ----------------------------------------------------------------------------- |
|
|
|
typedef struct { |
|
PyObject_HEAD; |
|
PyUpb_MapContainer* map; // We own a reference. |
|
size_t iter; |
|
int version; |
|
} PyUpb_MapIterator; |
|
|
|
static PyObject* PyUpb_MapIterator_New(PyUpb_MapContainer* map) { |
|
PyUpb_ModuleState* state = PyUpb_ModuleState_Get(); |
|
PyUpb_MapIterator* iter = |
|
(void*)PyType_GenericAlloc(state->map_iterator_type, 0); |
|
iter->map = map; |
|
iter->iter = kUpb_Map_Begin; |
|
iter->version = map->version; |
|
Py_INCREF(map); |
|
return &iter->ob_base; |
|
} |
|
|
|
static void PyUpb_MapIterator_Dealloc(void* _self) { |
|
PyUpb_MapIterator* self = (PyUpb_MapIterator*)_self; |
|
Py_DECREF(&self->map->ob_base); |
|
PyUpb_Dealloc(_self); |
|
} |
|
|
|
PyObject* PyUpb_MapIterator_IterNext(PyObject* _self) { |
|
PyUpb_MapIterator* self = (PyUpb_MapIterator*)_self; |
|
if (self->version != self->map->version) { |
|
return PyErr_Format(PyExc_RuntimeError, "Map modified during iteration."); |
|
} |
|
upb_Map* map = PyUpb_MapContainer_GetIfReified(self->map); |
|
if (!map) return NULL; |
|
upb_MessageValue key, val; |
|
if (!upb_Map_Next(map, &key, &val, &self->iter)) return NULL; |
|
const upb_FieldDef* f = PyUpb_MapContainer_GetField(self->map); |
|
const upb_MessageDef* entry_m = upb_FieldDef_MessageSubDef(f); |
|
const upb_FieldDef* key_f = upb_MessageDef_Field(entry_m, 0); |
|
return PyUpb_UpbToPy(key, key_f, self->map->arena); |
|
} |
|
|
|
static PyType_Slot PyUpb_MapIterator_Slots[] = { |
|
{Py_tp_dealloc, PyUpb_MapIterator_Dealloc}, |
|
{Py_tp_iter, PyObject_SelfIter}, |
|
{Py_tp_iternext, PyUpb_MapIterator_IterNext}, |
|
{0, NULL}}; |
|
|
|
static PyType_Spec PyUpb_MapIterator_Spec = { |
|
PYUPB_MODULE_NAME ".MapIterator", sizeof(PyUpb_MapIterator), 0, |
|
Py_TPFLAGS_DEFAULT, PyUpb_MapIterator_Slots}; |
|
|
|
// ----------------------------------------------------------------------------- |
|
// Top Level |
|
// ----------------------------------------------------------------------------- |
|
|
|
static PyObject* GetMutableMappingBase(void) { |
|
PyObject* collections = NULL; |
|
PyObject* mapping = NULL; |
|
PyObject* bases = NULL; |
|
if ((collections = PyImport_ImportModule("collections.abc")) && |
|
(mapping = PyObject_GetAttrString(collections, "MutableMapping"))) { |
|
bases = Py_BuildValue("(O)", mapping); |
|
} |
|
Py_XDECREF(collections); |
|
Py_XDECREF(mapping); |
|
return bases; |
|
} |
|
|
|
bool PyUpb_Map_Init(PyObject* m) { |
|
PyUpb_ModuleState* state = PyUpb_ModuleState_GetFromModule(m); |
|
PyObject* bases = GetMutableMappingBase(); |
|
if (!bases) return false; |
|
|
|
state->message_map_container_type = |
|
PyUpb_AddClassWithBases(m, &PyUpb_MessageMapContainer_Spec, bases); |
|
state->scalar_map_container_type = |
|
PyUpb_AddClassWithBases(m, &PyUpb_ScalarMapContainer_Spec, bases); |
|
state->map_iterator_type = PyUpb_AddClass(m, &PyUpb_MapIterator_Spec); |
|
|
|
Py_DECREF(bases); |
|
|
|
return state->message_map_container_type && |
|
state->scalar_map_container_type && state->map_iterator_type; |
|
}
|
|
|