mirror of
https://github.com/RGBCube/serenity
synced 2025-07-27 03:47:35 +00:00
parent
df14d11a11
commit
b2a849935b
1 changed files with 1 additions and 1 deletions
|
@ -216,7 +216,7 @@ protected:
|
||||||
if (message_size == 0 || bytes.size() - index - sizeof(uint32_t) < message_size)
|
if (message_size == 0 || bytes.size() - index - sizeof(uint32_t) < message_size)
|
||||||
break;
|
break;
|
||||||
index += sizeof(message_size);
|
index += sizeof(message_size);
|
||||||
auto remaining_bytes = ReadonlyBytes { bytes.data() + index, bytes.size() - index };
|
auto remaining_bytes = ReadonlyBytes { bytes.data() + index, message_size };
|
||||||
if (auto message = LocalEndpoint::decode_message(remaining_bytes, m_socket->fd())) {
|
if (auto message = LocalEndpoint::decode_message(remaining_bytes, m_socket->fd())) {
|
||||||
m_unprocessed_messages.append(message.release_nonnull());
|
m_unprocessed_messages.append(message.release_nonnull());
|
||||||
} else if (auto message = PeerEndpoint::decode_message(remaining_bytes, m_socket->fd())) {
|
} else if (auto message = PeerEndpoint::decode_message(remaining_bytes, m_socket->fd())) {
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue