Added CompoundBuffer that will be used to store data in the encoding/decoding

remoting/protocol/rtp_writer.cc

 // Copyright (c) 2010 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/rtp_writer.h"
 
 #include "net/base/io_buffer.h"
 #include "net/base/net_errors.h"
+#include "remoting/base/compound_buffer.h"
 #include "remoting/protocol/rtp_utils.h"
 
 namespace remoting {
 namespace protocol {
 
 namespace {
 const int kMtu = 1200;
 const uint8 kRtpPayloadTypePrivate = 96;
 }
 
 RtpWriter::RtpWriter()
     : rtp_socket_(NULL),
       rtcp_socket_(NULL),
       last_packet_number_(0) {
 }
 
 RtpWriter::~RtpWriter() { }
 
 // Initializes the writer. Must be called on the thread the sockets belong
 // to.
 void RtpWriter::Init(net::Socket* rtp_socket, net::Socket* rtcp_socket) {
   buffered_rtp_writer_ = new BufferedDatagramWriter();
   buffered_rtp_writer_->Init(rtp_socket, NULL);
   rtp_socket_ = rtp_socket;
   rtcp_socket_ = rtcp_socket;
 }
 
-void RtpWriter::SendPacket(const char* payload, int payload_size,
-                           uint32 timestamp) {
+void RtpWriter::SendPacket(const CompoundBuffer& payload, uint32 timestamp) {
   RtpHeader header;
   header.padding = false;
   header.extension = false;
   header.sources = 0;
   header.payload_type = kRtpPayloadTypePrivate;
   header.timestamp = timestamp;
 
   // TODO(sergeyu): RTP requires that SSRC is chosen randomly by each
   // participant. There are only two participants in chromoting session,
   // so SSRC isn't useful. Implement it in future if neccessary.
   header.sync_source_id = 0;
 
   // TODO(sergeyu): Add VP8 payload header.
 
   int position = 0;
-  while (position < payload_size) {
+  while (position < payload.total_bytes()) {
     // Allocate buffer.
-    int size = std::min(kMtu, payload_size - position);
+    int size = std::min(kMtu, payload.total_bytes() - position);
     int header_size = GetRtpHeaderSize(header.sources);
     int total_size = size + header_size;
     net::IOBufferWithSize* buffer = new net::IOBufferWithSize(total_size);
 
     // Set marker if this is the last frame.
-    header.marker = (position + size) == payload_size;
+    header.marker = (position + size) == payload.total_bytes();
 
     // TODO(sergeyu): Handle sequence number wrapping.
     header.sequence_number = last_packet_number_;
     ++last_packet_number_;
 
     // Generate header.
     PackRtpHeader(reinterpret_cast<uint8*>(buffer->data()), buffer->size(),
                   header);
 
     // Copy data to the buffer.
-    memcpy(buffer->data() + header_size, payload + position, size);
+    CompoundBuffer chunk;
+    chunk.CopyFrom(payload, position, position + size);
+    chunk.CopyTo(buffer->data() + header_size, size);
 
     // Send it.
     buffered_rtp_writer_->Write(buffer);
 
     position += size;
   }
 
-  DCHECK_EQ(position, payload_size);
+  DCHECK_EQ(position, payload.total_bytes());
 }
 
 int RtpWriter::GetPendingPackets() {
   return buffered_rtp_writer_->GetBufferChunks();
 }
 
 // Stop writing and drop pending data. Must be called from the same thread as
 // Init().
 void RtpWriter::Close() {
   buffered_rtp_writer_->Close();
 }
 
 }  // namespace protocol
 }  // namespace remoting