| Index: third_party/protobuf/ruby/ext/google/protobuf_c/storage.c
|
| diff --git a/third_party/protobuf/ruby/ext/google/protobuf_c/storage.c b/third_party/protobuf/ruby/ext/google/protobuf_c/storage.c
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..b1f65f413b53d3b46047c83c46a55103d9134596
|
| --- /dev/null
|
| +++ b/third_party/protobuf/ruby/ext/google/protobuf_c/storage.c
|
| @@ -0,0 +1,863 @@
|
| +// Protocol Buffers - Google's data interchange format
|
| +// Copyright 2014 Google Inc. All rights reserved.
|
| +// https://developers.google.com/protocol-buffers/
|
| +//
|
| +// 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 Inc. 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 THE COPYRIGHT
|
| +// OWNER OR CONTRIBUTORS 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 "protobuf.h"
|
| +
|
| +#include <math.h>
|
| +
|
| +#include <ruby/encoding.h>
|
| +
|
| +// -----------------------------------------------------------------------------
|
| +// Ruby <-> native slot management.
|
| +// -----------------------------------------------------------------------------
|
| +
|
| +#define DEREF(memory, type) *(type*)(memory)
|
| +
|
| +size_t native_slot_size(upb_fieldtype_t type) {
|
| + switch (type) {
|
| + case UPB_TYPE_FLOAT: return 4;
|
| + case UPB_TYPE_DOUBLE: return 8;
|
| + case UPB_TYPE_BOOL: return 1;
|
| + case UPB_TYPE_STRING: return sizeof(VALUE);
|
| + case UPB_TYPE_BYTES: return sizeof(VALUE);
|
| + case UPB_TYPE_MESSAGE: return sizeof(VALUE);
|
| + case UPB_TYPE_ENUM: return 4;
|
| + case UPB_TYPE_INT32: return 4;
|
| + case UPB_TYPE_INT64: return 8;
|
| + case UPB_TYPE_UINT32: return 4;
|
| + case UPB_TYPE_UINT64: return 8;
|
| + default: return 0;
|
| + }
|
| +}
|
| +
|
| +static bool is_ruby_num(VALUE value) {
|
| + return (TYPE(value) == T_FLOAT ||
|
| + TYPE(value) == T_FIXNUM ||
|
| + TYPE(value) == T_BIGNUM);
|
| +}
|
| +
|
| +void native_slot_check_int_range_precision(upb_fieldtype_t type, VALUE val) {
|
| + if (!is_ruby_num(val)) {
|
| + rb_raise(rb_eTypeError, "Expected number type for integral field.");
|
| + }
|
| +
|
| + // NUM2{INT,UINT,LL,ULL} macros do the appropriate range checks on upper
|
| + // bound; we just need to do precision checks (i.e., disallow rounding) and
|
| + // check for < 0 on unsigned types.
|
| + if (TYPE(val) == T_FLOAT) {
|
| + double dbl_val = NUM2DBL(val);
|
| + if (floor(dbl_val) != dbl_val) {
|
| + rb_raise(rb_eRangeError,
|
| + "Non-integral floating point value assigned to integer field.");
|
| + }
|
| + }
|
| + if (type == UPB_TYPE_UINT32 || type == UPB_TYPE_UINT64) {
|
| + if (NUM2DBL(val) < 0) {
|
| + rb_raise(rb_eRangeError,
|
| + "Assigning negative value to unsigned integer field.");
|
| + }
|
| + }
|
| +}
|
| +
|
| +void native_slot_validate_string_encoding(upb_fieldtype_t type, VALUE value) {
|
| + bool bad_encoding = false;
|
| + rb_encoding* string_encoding = rb_enc_from_index(ENCODING_GET(value));
|
| + if (type == UPB_TYPE_STRING) {
|
| + bad_encoding =
|
| + string_encoding != kRubyStringUtf8Encoding &&
|
| + string_encoding != kRubyStringASCIIEncoding;
|
| + } else {
|
| + bad_encoding =
|
| + string_encoding != kRubyString8bitEncoding;
|
| + }
|
| + // Check that encoding is UTF-8 or ASCII (for string fields) or ASCII-8BIT
|
| + // (for bytes fields).
|
| + if (bad_encoding) {
|
| + rb_raise(rb_eTypeError, "Encoding for '%s' fields must be %s (was %s)",
|
| + (type == UPB_TYPE_STRING) ? "string" : "bytes",
|
| + (type == UPB_TYPE_STRING) ? "UTF-8 or ASCII" : "ASCII-8BIT",
|
| + rb_enc_name(string_encoding));
|
| + }
|
| +}
|
| +
|
| +void native_slot_set(upb_fieldtype_t type, VALUE type_class,
|
| + void* memory, VALUE value) {
|
| + native_slot_set_value_and_case(type, type_class, memory, value, NULL, 0);
|
| +}
|
| +
|
| +void native_slot_set_value_and_case(upb_fieldtype_t type, VALUE type_class,
|
| + void* memory, VALUE value,
|
| + uint32_t* case_memory,
|
| + uint32_t case_number) {
|
| + // Note that in order to atomically change the value in memory and the case
|
| + // value (w.r.t. Ruby VM calls), we must set the value at |memory| only after
|
| + // all Ruby VM calls are complete. The case is then set at the bottom of this
|
| + // function.
|
| + switch (type) {
|
| + case UPB_TYPE_FLOAT:
|
| + if (!is_ruby_num(value)) {
|
| + rb_raise(rb_eTypeError, "Expected number type for float field.");
|
| + }
|
| + DEREF(memory, float) = NUM2DBL(value);
|
| + break;
|
| + case UPB_TYPE_DOUBLE:
|
| + if (!is_ruby_num(value)) {
|
| + rb_raise(rb_eTypeError, "Expected number type for double field.");
|
| + }
|
| + DEREF(memory, double) = NUM2DBL(value);
|
| + break;
|
| + case UPB_TYPE_BOOL: {
|
| + int8_t val = -1;
|
| + if (value == Qtrue) {
|
| + val = 1;
|
| + } else if (value == Qfalse) {
|
| + val = 0;
|
| + } else {
|
| + rb_raise(rb_eTypeError, "Invalid argument for boolean field.");
|
| + }
|
| + DEREF(memory, int8_t) = val;
|
| + break;
|
| + }
|
| + case UPB_TYPE_STRING:
|
| + case UPB_TYPE_BYTES: {
|
| + if (CLASS_OF(value) != rb_cString) {
|
| + rb_raise(rb_eTypeError, "Invalid argument for string field.");
|
| + }
|
| + native_slot_validate_string_encoding(type, value);
|
| + DEREF(memory, VALUE) = value;
|
| + break;
|
| + }
|
| + case UPB_TYPE_MESSAGE: {
|
| + if (CLASS_OF(value) == CLASS_OF(Qnil)) {
|
| + value = Qnil;
|
| + } else if (CLASS_OF(value) != type_class) {
|
| + rb_raise(rb_eTypeError,
|
| + "Invalid type %s to assign to submessage field.",
|
| + rb_class2name(CLASS_OF(value)));
|
| + }
|
| + DEREF(memory, VALUE) = value;
|
| + break;
|
| + }
|
| + case UPB_TYPE_ENUM: {
|
| + int32_t int_val = 0;
|
| + if (!is_ruby_num(value) && TYPE(value) != T_SYMBOL) {
|
| + rb_raise(rb_eTypeError,
|
| + "Expected number or symbol type for enum field.");
|
| + }
|
| + if (TYPE(value) == T_SYMBOL) {
|
| + // Ensure that the given symbol exists in the enum module.
|
| + VALUE lookup = rb_funcall(type_class, rb_intern("resolve"), 1, value);
|
| + if (lookup == Qnil) {
|
| + rb_raise(rb_eRangeError, "Unknown symbol value for enum field.");
|
| + } else {
|
| + int_val = NUM2INT(lookup);
|
| + }
|
| + } else {
|
| + native_slot_check_int_range_precision(UPB_TYPE_INT32, value);
|
| + int_val = NUM2INT(value);
|
| + }
|
| + DEREF(memory, int32_t) = int_val;
|
| + break;
|
| + }
|
| + case UPB_TYPE_INT32:
|
| + case UPB_TYPE_INT64:
|
| + case UPB_TYPE_UINT32:
|
| + case UPB_TYPE_UINT64:
|
| + native_slot_check_int_range_precision(type, value);
|
| + switch (type) {
|
| + case UPB_TYPE_INT32:
|
| + DEREF(memory, int32_t) = NUM2INT(value);
|
| + break;
|
| + case UPB_TYPE_INT64:
|
| + DEREF(memory, int64_t) = NUM2LL(value);
|
| + break;
|
| + case UPB_TYPE_UINT32:
|
| + DEREF(memory, uint32_t) = NUM2UINT(value);
|
| + break;
|
| + case UPB_TYPE_UINT64:
|
| + DEREF(memory, uint64_t) = NUM2ULL(value);
|
| + break;
|
| + default:
|
| + break;
|
| + }
|
| + break;
|
| + default:
|
| + break;
|
| + }
|
| +
|
| + if (case_memory != NULL) {
|
| + *case_memory = case_number;
|
| + }
|
| +}
|
| +
|
| +VALUE native_slot_get(upb_fieldtype_t type,
|
| + VALUE type_class,
|
| + const void* memory) {
|
| + switch (type) {
|
| + case UPB_TYPE_FLOAT:
|
| + return DBL2NUM(DEREF(memory, float));
|
| + case UPB_TYPE_DOUBLE:
|
| + return DBL2NUM(DEREF(memory, double));
|
| + case UPB_TYPE_BOOL:
|
| + return DEREF(memory, int8_t) ? Qtrue : Qfalse;
|
| + case UPB_TYPE_STRING:
|
| + case UPB_TYPE_BYTES:
|
| + case UPB_TYPE_MESSAGE:
|
| + return DEREF(memory, VALUE);
|
| + case UPB_TYPE_ENUM: {
|
| + int32_t val = DEREF(memory, int32_t);
|
| + VALUE symbol = enum_lookup(type_class, INT2NUM(val));
|
| + if (symbol == Qnil) {
|
| + return INT2NUM(val);
|
| + } else {
|
| + return symbol;
|
| + }
|
| + }
|
| + case UPB_TYPE_INT32:
|
| + return INT2NUM(DEREF(memory, int32_t));
|
| + case UPB_TYPE_INT64:
|
| + return LL2NUM(DEREF(memory, int64_t));
|
| + case UPB_TYPE_UINT32:
|
| + return UINT2NUM(DEREF(memory, uint32_t));
|
| + case UPB_TYPE_UINT64:
|
| + return ULL2NUM(DEREF(memory, uint64_t));
|
| + default:
|
| + return Qnil;
|
| + }
|
| +}
|
| +
|
| +void native_slot_init(upb_fieldtype_t type, void* memory) {
|
| + switch (type) {
|
| + case UPB_TYPE_FLOAT:
|
| + DEREF(memory, float) = 0.0;
|
| + break;
|
| + case UPB_TYPE_DOUBLE:
|
| + DEREF(memory, double) = 0.0;
|
| + break;
|
| + case UPB_TYPE_BOOL:
|
| + DEREF(memory, int8_t) = 0;
|
| + break;
|
| + case UPB_TYPE_STRING:
|
| + case UPB_TYPE_BYTES:
|
| + DEREF(memory, VALUE) = rb_str_new2("");
|
| + rb_enc_associate(DEREF(memory, VALUE), (type == UPB_TYPE_BYTES) ?
|
| + kRubyString8bitEncoding : kRubyStringUtf8Encoding);
|
| + break;
|
| + case UPB_TYPE_MESSAGE:
|
| + DEREF(memory, VALUE) = Qnil;
|
| + break;
|
| + case UPB_TYPE_ENUM:
|
| + case UPB_TYPE_INT32:
|
| + DEREF(memory, int32_t) = 0;
|
| + break;
|
| + case UPB_TYPE_INT64:
|
| + DEREF(memory, int64_t) = 0;
|
| + break;
|
| + case UPB_TYPE_UINT32:
|
| + DEREF(memory, uint32_t) = 0;
|
| + break;
|
| + case UPB_TYPE_UINT64:
|
| + DEREF(memory, uint64_t) = 0;
|
| + break;
|
| + default:
|
| + break;
|
| + }
|
| +}
|
| +
|
| +void native_slot_mark(upb_fieldtype_t type, void* memory) {
|
| + switch (type) {
|
| + case UPB_TYPE_STRING:
|
| + case UPB_TYPE_BYTES:
|
| + case UPB_TYPE_MESSAGE:
|
| + rb_gc_mark(DEREF(memory, VALUE));
|
| + break;
|
| + default:
|
| + break;
|
| + }
|
| +}
|
| +
|
| +void native_slot_dup(upb_fieldtype_t type, void* to, void* from) {
|
| + memcpy(to, from, native_slot_size(type));
|
| +}
|
| +
|
| +void native_slot_deep_copy(upb_fieldtype_t type, void* to, void* from) {
|
| + switch (type) {
|
| + case UPB_TYPE_STRING:
|
| + case UPB_TYPE_BYTES: {
|
| + VALUE from_val = DEREF(from, VALUE);
|
| + DEREF(to, VALUE) = (from_val != Qnil) ?
|
| + rb_funcall(from_val, rb_intern("dup"), 0) : Qnil;
|
| + break;
|
| + }
|
| + case UPB_TYPE_MESSAGE: {
|
| + VALUE from_val = DEREF(from, VALUE);
|
| + DEREF(to, VALUE) = (from_val != Qnil) ?
|
| + Message_deep_copy(from_val) : Qnil;
|
| + break;
|
| + }
|
| + default:
|
| + memcpy(to, from, native_slot_size(type));
|
| + }
|
| +}
|
| +
|
| +bool native_slot_eq(upb_fieldtype_t type, void* mem1, void* mem2) {
|
| + switch (type) {
|
| + case UPB_TYPE_STRING:
|
| + case UPB_TYPE_BYTES:
|
| + case UPB_TYPE_MESSAGE: {
|
| + VALUE val1 = DEREF(mem1, VALUE);
|
| + VALUE val2 = DEREF(mem2, VALUE);
|
| + VALUE ret = rb_funcall(val1, rb_intern("=="), 1, val2);
|
| + return ret == Qtrue;
|
| + }
|
| + default:
|
| + return !memcmp(mem1, mem2, native_slot_size(type));
|
| + }
|
| +}
|
| +
|
| +// -----------------------------------------------------------------------------
|
| +// Map field utilities.
|
| +// -----------------------------------------------------------------------------
|
| +
|
| +const upb_msgdef* tryget_map_entry_msgdef(const upb_fielddef* field) {
|
| + const upb_msgdef* subdef;
|
| + if (upb_fielddef_label(field) != UPB_LABEL_REPEATED ||
|
| + upb_fielddef_type(field) != UPB_TYPE_MESSAGE) {
|
| + return NULL;
|
| + }
|
| + subdef = upb_fielddef_msgsubdef(field);
|
| + return upb_msgdef_mapentry(subdef) ? subdef : NULL;
|
| +}
|
| +
|
| +const upb_msgdef *map_entry_msgdef(const upb_fielddef* field) {
|
| + const upb_msgdef* subdef = tryget_map_entry_msgdef(field);
|
| + assert(subdef);
|
| + return subdef;
|
| +}
|
| +
|
| +bool is_map_field(const upb_fielddef *field) {
|
| + return tryget_map_entry_msgdef(field) != NULL;
|
| +}
|
| +
|
| +const upb_fielddef* map_field_key(const upb_fielddef* field) {
|
| + const upb_msgdef* subdef = map_entry_msgdef(field);
|
| + return map_entry_key(subdef);
|
| +}
|
| +
|
| +const upb_fielddef* map_field_value(const upb_fielddef* field) {
|
| + const upb_msgdef* subdef = map_entry_msgdef(field);
|
| + return map_entry_value(subdef);
|
| +}
|
| +
|
| +const upb_fielddef* map_entry_key(const upb_msgdef* msgdef) {
|
| + const upb_fielddef* key_field = upb_msgdef_itof(msgdef, MAP_KEY_FIELD);
|
| + assert(key_field != NULL);
|
| + return key_field;
|
| +}
|
| +
|
| +const upb_fielddef* map_entry_value(const upb_msgdef* msgdef) {
|
| + const upb_fielddef* value_field = upb_msgdef_itof(msgdef, MAP_VALUE_FIELD);
|
| + assert(value_field != NULL);
|
| + return value_field;
|
| +}
|
| +
|
| +// -----------------------------------------------------------------------------
|
| +// Memory layout management.
|
| +// -----------------------------------------------------------------------------
|
| +
|
| +static size_t align_up_to(size_t offset, size_t granularity) {
|
| + // Granularity must be a power of two.
|
| + return (offset + granularity - 1) & ~(granularity - 1);
|
| +}
|
| +
|
| +MessageLayout* create_layout(const upb_msgdef* msgdef) {
|
| + MessageLayout* layout = ALLOC(MessageLayout);
|
| + int nfields = upb_msgdef_numfields(msgdef);
|
| + upb_msg_field_iter it;
|
| + upb_msg_oneof_iter oit;
|
| + size_t off = 0;
|
| +
|
| + layout->fields = ALLOC_N(MessageField, nfields);
|
| +
|
| + for (upb_msg_field_begin(&it, msgdef);
|
| + !upb_msg_field_done(&it);
|
| + upb_msg_field_next(&it)) {
|
| + const upb_fielddef* field = upb_msg_iter_field(&it);
|
| + size_t field_size;
|
| +
|
| + if (upb_fielddef_containingoneof(field)) {
|
| + // Oneofs are handled separately below.
|
| + continue;
|
| + }
|
| +
|
| + // Allocate |field_size| bytes for this field in the layout.
|
| + field_size = 0;
|
| + if (upb_fielddef_label(field) == UPB_LABEL_REPEATED) {
|
| + field_size = sizeof(VALUE);
|
| + } else {
|
| + field_size = native_slot_size(upb_fielddef_type(field));
|
| + }
|
| + // Align current offset up to |size| granularity.
|
| + off = align_up_to(off, field_size);
|
| + layout->fields[upb_fielddef_index(field)].offset = off;
|
| + layout->fields[upb_fielddef_index(field)].case_offset =
|
| + MESSAGE_FIELD_NO_CASE;
|
| + off += field_size;
|
| + }
|
| +
|
| + // Handle oneofs now -- we iterate over oneofs specifically and allocate only
|
| + // one slot per oneof.
|
| + //
|
| + // We assign all value slots first, then pack the 'case' fields at the end,
|
| + // since in the common case (modern 64-bit platform) these are 8 bytes and 4
|
| + // bytes respectively and we want to avoid alignment overhead.
|
| + //
|
| + // Note that we reserve 4 bytes (a uint32) per 'case' slot because the value
|
| + // space for oneof cases is conceptually as wide as field tag numbers. In
|
| + // practice, it's unlikely that a oneof would have more than e.g. 256 or 64K
|
| + // members (8 or 16 bits respectively), so conceivably we could assign
|
| + // consecutive case numbers and then pick a smaller oneof case slot size, but
|
| + // the complexity to implement this indirection is probably not worthwhile.
|
| + for (upb_msg_oneof_begin(&oit, msgdef);
|
| + !upb_msg_oneof_done(&oit);
|
| + upb_msg_oneof_next(&oit)) {
|
| + const upb_oneofdef* oneof = upb_msg_iter_oneof(&oit);
|
| + upb_oneof_iter fit;
|
| +
|
| + // Always allocate NATIVE_SLOT_MAX_SIZE bytes, but share the slot between
|
| + // all fields.
|
| + size_t field_size = NATIVE_SLOT_MAX_SIZE;
|
| + // Align the offset.
|
| + off = align_up_to(off, field_size);
|
| + // Assign all fields in the oneof this same offset.
|
| + for (upb_oneof_begin(&fit, oneof);
|
| + !upb_oneof_done(&fit);
|
| + upb_oneof_next(&fit)) {
|
| + const upb_fielddef* field = upb_oneof_iter_field(&fit);
|
| + layout->fields[upb_fielddef_index(field)].offset = off;
|
| + }
|
| + off += field_size;
|
| + }
|
| +
|
| + // Now the case fields.
|
| + for (upb_msg_oneof_begin(&oit, msgdef);
|
| + !upb_msg_oneof_done(&oit);
|
| + upb_msg_oneof_next(&oit)) {
|
| + const upb_oneofdef* oneof = upb_msg_iter_oneof(&oit);
|
| + upb_oneof_iter fit;
|
| +
|
| + size_t field_size = sizeof(uint32_t);
|
| + // Align the offset.
|
| + off = (off + field_size - 1) & ~(field_size - 1);
|
| + // Assign all fields in the oneof this same offset.
|
| + for (upb_oneof_begin(&fit, oneof);
|
| + !upb_oneof_done(&fit);
|
| + upb_oneof_next(&fit)) {
|
| + const upb_fielddef* field = upb_oneof_iter_field(&fit);
|
| + layout->fields[upb_fielddef_index(field)].case_offset = off;
|
| + }
|
| + off += field_size;
|
| + }
|
| +
|
| + layout->size = off;
|
| +
|
| + layout->msgdef = msgdef;
|
| + upb_msgdef_ref(layout->msgdef, &layout->msgdef);
|
| +
|
| + return layout;
|
| +}
|
| +
|
| +void free_layout(MessageLayout* layout) {
|
| + xfree(layout->fields);
|
| + upb_msgdef_unref(layout->msgdef, &layout->msgdef);
|
| + xfree(layout);
|
| +}
|
| +
|
| +VALUE field_type_class(const upb_fielddef* field) {
|
| + VALUE type_class = Qnil;
|
| + if (upb_fielddef_type(field) == UPB_TYPE_MESSAGE) {
|
| + VALUE submsgdesc =
|
| + get_def_obj(upb_fielddef_subdef(field));
|
| + type_class = Descriptor_msgclass(submsgdesc);
|
| + } else if (upb_fielddef_type(field) == UPB_TYPE_ENUM) {
|
| + VALUE subenumdesc =
|
| + get_def_obj(upb_fielddef_subdef(field));
|
| + type_class = EnumDescriptor_enummodule(subenumdesc);
|
| + }
|
| + return type_class;
|
| +}
|
| +
|
| +static void* slot_memory(MessageLayout* layout,
|
| + const void* storage,
|
| + const upb_fielddef* field) {
|
| + return ((uint8_t *)storage) +
|
| + layout->fields[upb_fielddef_index(field)].offset;
|
| +}
|
| +
|
| +static uint32_t* slot_oneof_case(MessageLayout* layout,
|
| + const void* storage,
|
| + const upb_fielddef* field) {
|
| + return (uint32_t *)(((uint8_t *)storage) +
|
| + layout->fields[upb_fielddef_index(field)].case_offset);
|
| +}
|
| +
|
| +
|
| +VALUE layout_get(MessageLayout* layout,
|
| + const void* storage,
|
| + const upb_fielddef* field) {
|
| + void* memory = slot_memory(layout, storage, field);
|
| + uint32_t* oneof_case = slot_oneof_case(layout, storage, field);
|
| +
|
| + if (upb_fielddef_containingoneof(field)) {
|
| + if (*oneof_case != upb_fielddef_number(field)) {
|
| + return Qnil;
|
| + }
|
| + return native_slot_get(upb_fielddef_type(field),
|
| + field_type_class(field),
|
| + memory);
|
| + } else if (upb_fielddef_label(field) == UPB_LABEL_REPEATED) {
|
| + return *((VALUE *)memory);
|
| + } else {
|
| + return native_slot_get(upb_fielddef_type(field),
|
| + field_type_class(field),
|
| + memory);
|
| + }
|
| +}
|
| +
|
| +static void check_repeated_field_type(VALUE val, const upb_fielddef* field) {
|
| + RepeatedField* self;
|
| + assert(upb_fielddef_label(field) == UPB_LABEL_REPEATED);
|
| +
|
| + if (!RB_TYPE_P(val, T_DATA) || !RTYPEDDATA_P(val) ||
|
| + RTYPEDDATA_TYPE(val) != &RepeatedField_type) {
|
| + rb_raise(rb_eTypeError, "Expected repeated field array");
|
| + }
|
| +
|
| + self = ruby_to_RepeatedField(val);
|
| + if (self->field_type != upb_fielddef_type(field)) {
|
| + rb_raise(rb_eTypeError, "Repeated field array has wrong element type");
|
| + }
|
| +
|
| + if (self->field_type == UPB_TYPE_MESSAGE ||
|
| + self->field_type == UPB_TYPE_ENUM) {
|
| + if (self->field_type_class !=
|
| + get_def_obj(upb_fielddef_subdef(field))) {
|
| + rb_raise(rb_eTypeError,
|
| + "Repeated field array has wrong message/enum class");
|
| + }
|
| + }
|
| +}
|
| +
|
| +static void check_map_field_type(VALUE val, const upb_fielddef* field) {
|
| + const upb_fielddef* key_field = map_field_key(field);
|
| + const upb_fielddef* value_field = map_field_value(field);
|
| + Map* self;
|
| +
|
| + if (!RB_TYPE_P(val, T_DATA) || !RTYPEDDATA_P(val) ||
|
| + RTYPEDDATA_TYPE(val) != &Map_type) {
|
| + rb_raise(rb_eTypeError, "Expected Map instance");
|
| + }
|
| +
|
| + self = ruby_to_Map(val);
|
| + if (self->key_type != upb_fielddef_type(key_field)) {
|
| + rb_raise(rb_eTypeError, "Map key type does not match field's key type");
|
| + }
|
| + if (self->value_type != upb_fielddef_type(value_field)) {
|
| + rb_raise(rb_eTypeError, "Map value type does not match field's value type");
|
| + }
|
| + if (upb_fielddef_type(value_field) == UPB_TYPE_MESSAGE ||
|
| + upb_fielddef_type(value_field) == UPB_TYPE_ENUM) {
|
| + if (self->value_type_class !=
|
| + get_def_obj(upb_fielddef_subdef(value_field))) {
|
| + rb_raise(rb_eTypeError,
|
| + "Map value type has wrong message/enum class");
|
| + }
|
| + }
|
| +}
|
| +
|
| +
|
| +void layout_set(MessageLayout* layout,
|
| + void* storage,
|
| + const upb_fielddef* field,
|
| + VALUE val) {
|
| + void* memory = slot_memory(layout, storage, field);
|
| + uint32_t* oneof_case = slot_oneof_case(layout, storage, field);
|
| +
|
| + if (upb_fielddef_containingoneof(field)) {
|
| + if (val == Qnil) {
|
| + // Assigning nil to a oneof field clears the oneof completely.
|
| + *oneof_case = ONEOF_CASE_NONE;
|
| + memset(memory, 0, NATIVE_SLOT_MAX_SIZE);
|
| + } else {
|
| + // The transition between field types for a single oneof (union) slot is
|
| + // somewhat complex because we need to ensure that a GC triggered at any
|
| + // point by a call into the Ruby VM sees a valid state for this field and
|
| + // does not either go off into the weeds (following what it thinks is a
|
| + // VALUE but is actually a different field type) or miss an object (seeing
|
| + // what it thinks is a primitive field but is actually a VALUE for the new
|
| + // field type).
|
| + //
|
| + // In order for the transition to be safe, the oneof case slot must be in
|
| + // sync with the value slot whenever the Ruby VM has been called. Thus, we
|
| + // use native_slot_set_value_and_case(), which ensures that both the value
|
| + // and case number are altered atomically (w.r.t. the Ruby VM).
|
| + native_slot_set_value_and_case(
|
| + upb_fielddef_type(field), field_type_class(field),
|
| + memory, val,
|
| + oneof_case, upb_fielddef_number(field));
|
| + }
|
| + } else if (is_map_field(field)) {
|
| + check_map_field_type(val, field);
|
| + DEREF(memory, VALUE) = val;
|
| + } else if (upb_fielddef_label(field) == UPB_LABEL_REPEATED) {
|
| + check_repeated_field_type(val, field);
|
| + DEREF(memory, VALUE) = val;
|
| + } else {
|
| + native_slot_set(upb_fielddef_type(field), field_type_class(field),
|
| + memory, val);
|
| + }
|
| +}
|
| +
|
| +void layout_init(MessageLayout* layout,
|
| + void* storage) {
|
| + upb_msg_field_iter it;
|
| + for (upb_msg_field_begin(&it, layout->msgdef);
|
| + !upb_msg_field_done(&it);
|
| + upb_msg_field_next(&it)) {
|
| + const upb_fielddef* field = upb_msg_iter_field(&it);
|
| + void* memory = slot_memory(layout, storage, field);
|
| + uint32_t* oneof_case = slot_oneof_case(layout, storage, field);
|
| +
|
| + if (upb_fielddef_containingoneof(field)) {
|
| + memset(memory, 0, NATIVE_SLOT_MAX_SIZE);
|
| + *oneof_case = ONEOF_CASE_NONE;
|
| + } else if (is_map_field(field)) {
|
| + VALUE map = Qnil;
|
| +
|
| + const upb_fielddef* key_field = map_field_key(field);
|
| + const upb_fielddef* value_field = map_field_value(field);
|
| + VALUE type_class = field_type_class(value_field);
|
| +
|
| + if (type_class != Qnil) {
|
| + VALUE args[3] = {
|
| + fieldtype_to_ruby(upb_fielddef_type(key_field)),
|
| + fieldtype_to_ruby(upb_fielddef_type(value_field)),
|
| + type_class,
|
| + };
|
| + map = rb_class_new_instance(3, args, cMap);
|
| + } else {
|
| + VALUE args[2] = {
|
| + fieldtype_to_ruby(upb_fielddef_type(key_field)),
|
| + fieldtype_to_ruby(upb_fielddef_type(value_field)),
|
| + };
|
| + map = rb_class_new_instance(2, args, cMap);
|
| + }
|
| +
|
| + DEREF(memory, VALUE) = map;
|
| + } else if (upb_fielddef_label(field) == UPB_LABEL_REPEATED) {
|
| + VALUE ary = Qnil;
|
| +
|
| + VALUE type_class = field_type_class(field);
|
| +
|
| + if (type_class != Qnil) {
|
| + VALUE args[2] = {
|
| + fieldtype_to_ruby(upb_fielddef_type(field)),
|
| + type_class,
|
| + };
|
| + ary = rb_class_new_instance(2, args, cRepeatedField);
|
| + } else {
|
| + VALUE args[1] = { fieldtype_to_ruby(upb_fielddef_type(field)) };
|
| + ary = rb_class_new_instance(1, args, cRepeatedField);
|
| + }
|
| +
|
| + DEREF(memory, VALUE) = ary;
|
| + } else {
|
| + native_slot_init(upb_fielddef_type(field), memory);
|
| + }
|
| + }
|
| +}
|
| +
|
| +void layout_mark(MessageLayout* layout, void* storage) {
|
| + upb_msg_field_iter it;
|
| + for (upb_msg_field_begin(&it, layout->msgdef);
|
| + !upb_msg_field_done(&it);
|
| + upb_msg_field_next(&it)) {
|
| + const upb_fielddef* field = upb_msg_iter_field(&it);
|
| + void* memory = slot_memory(layout, storage, field);
|
| + uint32_t* oneof_case = slot_oneof_case(layout, storage, field);
|
| +
|
| + if (upb_fielddef_containingoneof(field)) {
|
| + if (*oneof_case == upb_fielddef_number(field)) {
|
| + native_slot_mark(upb_fielddef_type(field), memory);
|
| + }
|
| + } else if (upb_fielddef_label(field) == UPB_LABEL_REPEATED) {
|
| + rb_gc_mark(DEREF(memory, VALUE));
|
| + } else {
|
| + native_slot_mark(upb_fielddef_type(field), memory);
|
| + }
|
| + }
|
| +}
|
| +
|
| +void layout_dup(MessageLayout* layout, void* to, void* from) {
|
| + upb_msg_field_iter it;
|
| + for (upb_msg_field_begin(&it, layout->msgdef);
|
| + !upb_msg_field_done(&it);
|
| + upb_msg_field_next(&it)) {
|
| + const upb_fielddef* field = upb_msg_iter_field(&it);
|
| +
|
| + void* to_memory = slot_memory(layout, to, field);
|
| + uint32_t* to_oneof_case = slot_oneof_case(layout, to, field);
|
| + void* from_memory = slot_memory(layout, from, field);
|
| + uint32_t* from_oneof_case = slot_oneof_case(layout, from, field);
|
| +
|
| + if (upb_fielddef_containingoneof(field)) {
|
| + if (*from_oneof_case == upb_fielddef_number(field)) {
|
| + *to_oneof_case = *from_oneof_case;
|
| + native_slot_dup(upb_fielddef_type(field), to_memory, from_memory);
|
| + }
|
| + } else if (is_map_field(field)) {
|
| + DEREF(to_memory, VALUE) = Map_dup(DEREF(from_memory, VALUE));
|
| + } else if (upb_fielddef_label(field) == UPB_LABEL_REPEATED) {
|
| + DEREF(to_memory, VALUE) = RepeatedField_dup(DEREF(from_memory, VALUE));
|
| + } else {
|
| + native_slot_dup(upb_fielddef_type(field), to_memory, from_memory);
|
| + }
|
| + }
|
| +}
|
| +
|
| +void layout_deep_copy(MessageLayout* layout, void* to, void* from) {
|
| + upb_msg_field_iter it;
|
| + for (upb_msg_field_begin(&it, layout->msgdef);
|
| + !upb_msg_field_done(&it);
|
| + upb_msg_field_next(&it)) {
|
| + const upb_fielddef* field = upb_msg_iter_field(&it);
|
| +
|
| + void* to_memory = slot_memory(layout, to, field);
|
| + uint32_t* to_oneof_case = slot_oneof_case(layout, to, field);
|
| + void* from_memory = slot_memory(layout, from, field);
|
| + uint32_t* from_oneof_case = slot_oneof_case(layout, from, field);
|
| +
|
| + if (upb_fielddef_containingoneof(field)) {
|
| + if (*from_oneof_case == upb_fielddef_number(field)) {
|
| + *to_oneof_case = *from_oneof_case;
|
| + native_slot_deep_copy(upb_fielddef_type(field), to_memory, from_memory);
|
| + }
|
| + } else if (is_map_field(field)) {
|
| + DEREF(to_memory, VALUE) =
|
| + Map_deep_copy(DEREF(from_memory, VALUE));
|
| + } else if (upb_fielddef_label(field) == UPB_LABEL_REPEATED) {
|
| + DEREF(to_memory, VALUE) =
|
| + RepeatedField_deep_copy(DEREF(from_memory, VALUE));
|
| + } else {
|
| + native_slot_deep_copy(upb_fielddef_type(field), to_memory, from_memory);
|
| + }
|
| + }
|
| +}
|
| +
|
| +VALUE layout_eq(MessageLayout* layout, void* msg1, void* msg2) {
|
| + upb_msg_field_iter it;
|
| + for (upb_msg_field_begin(&it, layout->msgdef);
|
| + !upb_msg_field_done(&it);
|
| + upb_msg_field_next(&it)) {
|
| + const upb_fielddef* field = upb_msg_iter_field(&it);
|
| +
|
| + void* msg1_memory = slot_memory(layout, msg1, field);
|
| + uint32_t* msg1_oneof_case = slot_oneof_case(layout, msg1, field);
|
| + void* msg2_memory = slot_memory(layout, msg2, field);
|
| + uint32_t* msg2_oneof_case = slot_oneof_case(layout, msg2, field);
|
| +
|
| + if (upb_fielddef_containingoneof(field)) {
|
| + if (*msg1_oneof_case != *msg2_oneof_case ||
|
| + (*msg1_oneof_case == upb_fielddef_number(field) &&
|
| + !native_slot_eq(upb_fielddef_type(field),
|
| + msg1_memory,
|
| + msg2_memory))) {
|
| + return Qfalse;
|
| + }
|
| + } else if (is_map_field(field)) {
|
| + if (!Map_eq(DEREF(msg1_memory, VALUE),
|
| + DEREF(msg2_memory, VALUE))) {
|
| + return Qfalse;
|
| + }
|
| + } else if (upb_fielddef_label(field) == UPB_LABEL_REPEATED) {
|
| + if (!RepeatedField_eq(DEREF(msg1_memory, VALUE),
|
| + DEREF(msg2_memory, VALUE))) {
|
| + return Qfalse;
|
| + }
|
| + } else {
|
| + if (!native_slot_eq(upb_fielddef_type(field),
|
| + msg1_memory, msg2_memory)) {
|
| + return Qfalse;
|
| + }
|
| + }
|
| + }
|
| + return Qtrue;
|
| +}
|
| +
|
| +VALUE layout_hash(MessageLayout* layout, void* storage) {
|
| + upb_msg_field_iter it;
|
| + st_index_t h = rb_hash_start(0);
|
| + VALUE hash_sym = rb_intern("hash");
|
| + for (upb_msg_field_begin(&it, layout->msgdef);
|
| + !upb_msg_field_done(&it);
|
| + upb_msg_field_next(&it)) {
|
| + const upb_fielddef* field = upb_msg_iter_field(&it);
|
| + VALUE field_val = layout_get(layout, storage, field);
|
| + h = rb_hash_uint(h, NUM2LONG(rb_funcall(field_val, hash_sym, 0)));
|
| + }
|
| + h = rb_hash_end(h);
|
| +
|
| + return INT2FIX(h);
|
| +}
|
| +
|
| +VALUE layout_inspect(MessageLayout* layout, void* storage) {
|
| + VALUE str = rb_str_new2("");
|
| +
|
| + upb_msg_field_iter it;
|
| + bool first = true;
|
| + for (upb_msg_field_begin(&it, layout->msgdef);
|
| + !upb_msg_field_done(&it);
|
| + upb_msg_field_next(&it)) {
|
| + const upb_fielddef* field = upb_msg_iter_field(&it);
|
| + VALUE field_val = layout_get(layout, storage, field);
|
| +
|
| + if (!first) {
|
| + str = rb_str_cat2(str, ", ");
|
| + } else {
|
| + first = false;
|
| + }
|
| + str = rb_str_cat2(str, upb_fielddef_name(field));
|
| + str = rb_str_cat2(str, ": ");
|
| +
|
| + str = rb_str_append(str, rb_funcall(field_val, rb_intern("inspect"), 0));
|
| + }
|
| +
|
| + return str;
|
| +}
|
|
|