drew
/
acadia
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 1 Wiki Activity

Fix repeated message serialization in cpp yunq.

This commit is contained in:
Drew Galbraith 2025-02-01 14:08:35 -08:00
parent c4dfa624fa
commit 00f2424987
2 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
lib/yunq/serialize.cpp
View File

@ -3,7 +3,7 @@
namespace yunq { namespace yunq {
namespace { namespace {
const uint64_t kIdentByte = 0x33441122; const uint32_t kIdentByte = 0x33441122;
} // namespace } // namespace

5
lib/yunq/serialize.h
View File

@ -100,7 +100,7 @@ template <typename T>
void Serializer::WriteRepeatedMessage(uint64_t field_index, void Serializer::WriteRepeatedMessage(uint64_t field_index,
const glcr::Vector<T>& value) { const glcr::Vector<T>& value) {
uint64_t next_offset = next_extension_; uint64_t next_offset = next_extension_;
uint64_t length = 0; uint64_t length = value.size();
for (T& message : value) { for (T& message : value) {
uint64_t msg_length = 0; uint64_t msg_length = 0;
@ -110,7 +110,6 @@ void Serializer::WriteRepeatedMessage(uint64_t field_index,
} else { } else {
msg_length = message.SerializeToBytes(buffer_, offset_ + next_offset); msg_length = message.SerializeToBytes(buffer_, offset_ + next_offset);
} }
length += msg_length;
next_offset += msg_length; next_offset += msg_length;
} }
@ -119,7 +118,7 @@ void Serializer::WriteRepeatedMessage(uint64_t field_index,
.length = (uint32_t)length, .length = (uint32_t)length,
}; };
next_extension_ += length; next_extension_ = next_offset;
buffer_.WriteAt<ExtensionPointer>(field_offset(field_index), ptr); buffer_.WriteAt<ExtensionPointer>(field_offset(field_index), ptr);
} }