123456789101112131415161718192021222324252627282930 |
- // Copyright 2014 The Chromium Authors. All rights reserved.
- // Use of this source code is governed by a BSD-style license that can be
- // found in the LICENSE file.
- #include "remoting/protocol/message_serialization.h"
- #include <stdint.h>
- #include "net/base/io_buffer.h"
- #include "third_party/webrtc/rtc_base/byte_order.h"
- namespace remoting {
- namespace protocol {
- scoped_refptr<net::IOBufferWithSize> SerializeAndFrameMessage(
- const google::protobuf::MessageLite& msg) {
- // Create a buffer with 4 extra bytes. This is used as prefix to write an
- // int32_t of the serialized message size for framing.
- const int kExtraBytes = sizeof(int32_t);
- int size = msg.ByteSize() + kExtraBytes;
- scoped_refptr<net::IOBufferWithSize> buffer =
- base::MakeRefCounted<net::IOBufferWithSize>(size);
- rtc::SetBE32(buffer->data(), msg.GetCachedSize());
- msg.SerializeWithCachedSizesToArray(
- reinterpret_cast<uint8_t*>(buffer->data()) + kExtraBytes);
- return buffer;
- }
- } // namespace protocol
- } // namespace remoting
|