|
|
|
@ -6333,6 +6333,102 @@ bool UPB_PRIVATE(_upb_Array_Realloc)(upb_Array* array, size_t min_capacity, |
|
|
|
|
#include <string.h> |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// Must be last.
|
|
|
|
|
|
|
|
|
|
const upb_Message_Extension* _upb_Message_Getext( |
|
|
|
|
const upb_Message* msg, const upb_MiniTableExtension* e) { |
|
|
|
|
size_t n; |
|
|
|
|
const upb_Message_Extension* ext = _upb_Message_Getexts(msg, &n); |
|
|
|
|
|
|
|
|
|
// For now we use linear search exclusively to find extensions.
|
|
|
|
|
// If this becomes an issue due to messages with lots of extensions,
|
|
|
|
|
// we can introduce a table of some sort.
|
|
|
|
|
for (size_t i = 0; i < n; i++) { |
|
|
|
|
if (ext[i].ext == e) { |
|
|
|
|
return &ext[i]; |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
return NULL; |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
const upb_Message_Extension* _upb_Message_Getexts(const upb_Message* msg, |
|
|
|
|
size_t* count) { |
|
|
|
|
const upb_Message_Internal* in = upb_Message_Getinternal(msg); |
|
|
|
|
if (in->internal) { |
|
|
|
|
*count = (in->internal->size - in->internal->ext_begin) / |
|
|
|
|
sizeof(upb_Message_Extension); |
|
|
|
|
return UPB_PTR_AT(in->internal, in->internal->ext_begin, void); |
|
|
|
|
} else { |
|
|
|
|
*count = 0; |
|
|
|
|
return NULL; |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
upb_Message_Extension* _upb_Message_GetOrCreateExtension( |
|
|
|
|
upb_Message* msg, const upb_MiniTableExtension* e, upb_Arena* arena) { |
|
|
|
|
upb_Message_Extension* ext = |
|
|
|
|
(upb_Message_Extension*)_upb_Message_Getext(msg, e); |
|
|
|
|
if (ext) return ext; |
|
|
|
|
if (!UPB_PRIVATE(_upb_Message_Realloc)(msg, sizeof(upb_Message_Extension), arena)) return NULL; |
|
|
|
|
upb_Message_Internal* in = upb_Message_Getinternal(msg); |
|
|
|
|
in->internal->ext_begin -= sizeof(upb_Message_Extension); |
|
|
|
|
ext = UPB_PTR_AT(in->internal, in->internal->ext_begin, void); |
|
|
|
|
memset(ext, 0, sizeof(upb_Message_Extension)); |
|
|
|
|
ext->ext = e; |
|
|
|
|
return ext; |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
#include <math.h> |
|
|
|
|
#include <string.h> |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// Must be last.
|
|
|
|
|
|
|
|
|
|
const float kUpb_FltInfinity = INFINITY; |
|
|
|
|
const double kUpb_Infinity = INFINITY; |
|
|
|
|
const double kUpb_NaN = NAN; |
|
|
|
|
|
|
|
|
|
static const size_t realloc_overhead = sizeof(upb_Message_InternalData); |
|
|
|
|
|
|
|
|
|
bool UPB_PRIVATE(_upb_Message_Realloc)(upb_Message* msg, size_t need, |
|
|
|
|
upb_Arena* arena) { |
|
|
|
|
upb_Message_Internal* in = upb_Message_Getinternal(msg); |
|
|
|
|
if (!in->internal) { |
|
|
|
|
// No internal data, allocate from scratch.
|
|
|
|
|
size_t size = UPB_MAX(128, upb_Log2CeilingSize(need + realloc_overhead)); |
|
|
|
|
upb_Message_InternalData* internal = upb_Arena_Malloc(arena, size); |
|
|
|
|
if (!internal) return false; |
|
|
|
|
internal->size = size; |
|
|
|
|
internal->unknown_end = realloc_overhead; |
|
|
|
|
internal->ext_begin = size; |
|
|
|
|
in->internal = internal; |
|
|
|
|
} else if (in->internal->ext_begin - in->internal->unknown_end < need) { |
|
|
|
|
// Internal data is too small, reallocate.
|
|
|
|
|
size_t new_size = upb_Log2CeilingSize(in->internal->size + need); |
|
|
|
|
size_t ext_bytes = in->internal->size - in->internal->ext_begin; |
|
|
|
|
size_t new_ext_begin = new_size - ext_bytes; |
|
|
|
|
upb_Message_InternalData* internal = |
|
|
|
|
upb_Arena_Realloc(arena, in->internal, in->internal->size, new_size); |
|
|
|
|
if (!internal) return false; |
|
|
|
|
if (ext_bytes) { |
|
|
|
|
// Need to move extension data to the end.
|
|
|
|
|
char* ptr = (char*)internal; |
|
|
|
|
memmove(ptr + new_ext_begin, ptr + internal->ext_begin, ext_bytes); |
|
|
|
|
} |
|
|
|
|
internal->ext_begin = new_ext_begin; |
|
|
|
|
internal->size = new_size; |
|
|
|
|
in->internal = internal; |
|
|
|
|
} |
|
|
|
|
UPB_ASSERT(in->internal->ext_begin - in->internal->unknown_end >= need); |
|
|
|
|
return true; |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
#include <string.h> |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// Must be last.
|
|
|
|
|
|
|
|
|
|
// Strings/bytes are special-cased in maps.
|
|
|
|
@ -6580,57 +6676,19 @@ bool _upb_mapsorter_pushexts(_upb_mapsorter* s, |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
#include <math.h> |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// Must be last.
|
|
|
|
|
|
|
|
|
|
const float kUpb_FltInfinity = INFINITY; |
|
|
|
|
const double kUpb_Infinity = INFINITY; |
|
|
|
|
const double kUpb_NaN = NAN; |
|
|
|
|
|
|
|
|
|
static const size_t overhead = sizeof(upb_Message_InternalData); |
|
|
|
|
static const size_t message_overhead = sizeof(upb_Message_InternalData); |
|
|
|
|
|
|
|
|
|
upb_Message* upb_Message_New(const upb_MiniTable* mini_table, |
|
|
|
|
upb_Arena* arena) { |
|
|
|
|
return _upb_Message_New(mini_table, arena); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
static bool realloc_internal(upb_Message* msg, size_t need, upb_Arena* arena) { |
|
|
|
|
upb_Message_Internal* in = upb_Message_Getinternal(msg); |
|
|
|
|
if (!in->internal) { |
|
|
|
|
/* No internal data, allocate from scratch. */ |
|
|
|
|
size_t size = UPB_MAX(128, upb_Log2CeilingSize(need + overhead)); |
|
|
|
|
upb_Message_InternalData* internal = upb_Arena_Malloc(arena, size); |
|
|
|
|
if (!internal) return false; |
|
|
|
|
internal->size = size; |
|
|
|
|
internal->unknown_end = overhead; |
|
|
|
|
internal->ext_begin = size; |
|
|
|
|
in->internal = internal; |
|
|
|
|
} else if (in->internal->ext_begin - in->internal->unknown_end < need) { |
|
|
|
|
/* Internal data is too small, reallocate. */ |
|
|
|
|
size_t new_size = upb_Log2CeilingSize(in->internal->size + need); |
|
|
|
|
size_t ext_bytes = in->internal->size - in->internal->ext_begin; |
|
|
|
|
size_t new_ext_begin = new_size - ext_bytes; |
|
|
|
|
upb_Message_InternalData* internal = |
|
|
|
|
upb_Arena_Realloc(arena, in->internal, in->internal->size, new_size); |
|
|
|
|
if (!internal) return false; |
|
|
|
|
if (ext_bytes) { |
|
|
|
|
/* Need to move extension data to the end. */ |
|
|
|
|
char* ptr = (char*)internal; |
|
|
|
|
memmove(ptr + new_ext_begin, ptr + internal->ext_begin, ext_bytes); |
|
|
|
|
} |
|
|
|
|
internal->ext_begin = new_ext_begin; |
|
|
|
|
internal->size = new_size; |
|
|
|
|
in->internal = internal; |
|
|
|
|
} |
|
|
|
|
UPB_ASSERT(in->internal->ext_begin - in->internal->unknown_end >= need); |
|
|
|
|
return true; |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
bool _upb_Message_AddUnknown(upb_Message* msg, const char* data, size_t len, |
|
|
|
|
upb_Arena* arena) { |
|
|
|
|
if (!realloc_internal(msg, len, arena)) return false; |
|
|
|
|
if (!UPB_PRIVATE(_upb_Message_Realloc)(msg, len, arena)) return false; |
|
|
|
|
upb_Message_Internal* in = upb_Message_Getinternal(msg); |
|
|
|
|
memcpy(UPB_PTR_AT(in->internal, in->internal->unknown_end, char), data, len); |
|
|
|
|
in->internal->unknown_end += len; |
|
|
|
@ -6640,14 +6698,14 @@ bool _upb_Message_AddUnknown(upb_Message* msg, const char* data, size_t len, |
|
|
|
|
void _upb_Message_DiscardUnknown_shallow(upb_Message* msg) { |
|
|
|
|
upb_Message_Internal* in = upb_Message_Getinternal(msg); |
|
|
|
|
if (in->internal) { |
|
|
|
|
in->internal->unknown_end = overhead; |
|
|
|
|
in->internal->unknown_end = message_overhead; |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
const char* upb_Message_GetUnknown(const upb_Message* msg, size_t* len) { |
|
|
|
|
const upb_Message_Internal* in = upb_Message_Getinternal(msg); |
|
|
|
|
if (in->internal) { |
|
|
|
|
*len = in->internal->unknown_end - overhead; |
|
|
|
|
*len = in->internal->unknown_end - message_overhead; |
|
|
|
|
return (char*)(in->internal + 1); |
|
|
|
|
} else { |
|
|
|
|
*len = 0; |
|
|
|
@ -6673,50 +6731,6 @@ void upb_Message_DeleteUnknown(upb_Message* msg, const char* data, size_t len) { |
|
|
|
|
in->internal->unknown_end -= len; |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
const upb_Message_Extension* _upb_Message_Getexts(const upb_Message* msg, |
|
|
|
|
size_t* count) { |
|
|
|
|
const upb_Message_Internal* in = upb_Message_Getinternal(msg); |
|
|
|
|
if (in->internal) { |
|
|
|
|
*count = (in->internal->size - in->internal->ext_begin) / |
|
|
|
|
sizeof(upb_Message_Extension); |
|
|
|
|
return UPB_PTR_AT(in->internal, in->internal->ext_begin, void); |
|
|
|
|
} else { |
|
|
|
|
*count = 0; |
|
|
|
|
return NULL; |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
const upb_Message_Extension* _upb_Message_Getext( |
|
|
|
|
const upb_Message* msg, const upb_MiniTableExtension* e) { |
|
|
|
|
size_t n; |
|
|
|
|
const upb_Message_Extension* ext = _upb_Message_Getexts(msg, &n); |
|
|
|
|
|
|
|
|
|
/* For now we use linear search exclusively to find extensions. If this
|
|
|
|
|
* becomes an issue due to messages with lots of extensions, we can introduce |
|
|
|
|
* a table of some sort. */ |
|
|
|
|
for (size_t i = 0; i < n; i++) { |
|
|
|
|
if (ext[i].ext == e) { |
|
|
|
|
return &ext[i]; |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
return NULL; |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
upb_Message_Extension* _upb_Message_GetOrCreateExtension( |
|
|
|
|
upb_Message* msg, const upb_MiniTableExtension* e, upb_Arena* arena) { |
|
|
|
|
upb_Message_Extension* ext = |
|
|
|
|
(upb_Message_Extension*)_upb_Message_Getext(msg, e); |
|
|
|
|
if (ext) return ext; |
|
|
|
|
if (!realloc_internal(msg, sizeof(upb_Message_Extension), arena)) return NULL; |
|
|
|
|
upb_Message_Internal* in = upb_Message_Getinternal(msg); |
|
|
|
|
in->internal->ext_begin -= sizeof(upb_Message_Extension); |
|
|
|
|
ext = UPB_PTR_AT(in->internal, in->internal->ext_begin, void); |
|
|
|
|
memset(ext, 0, sizeof(upb_Message_Extension)); |
|
|
|
|
ext->ext = e; |
|
|
|
|
return ext; |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
size_t upb_Message_ExtensionCount(const upb_Message* msg) { |
|
|
|
|
size_t count; |
|
|
|
|
_upb_Message_Getexts(msg, &count); |
|
|
|
|