Refactor VideoStub interface to accept ownership of video packets.

remoting/protocol/rtp_video_writer.cc

 // Copyright (c) 2012 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_video_writer.h"
 
 #include "base/bind.h"
 #include "base/callback.h"
 #include "net/base/io_buffer.h"
 #include "remoting/base/compound_buffer.h"
@@ skipping 67 matching lines @@
     session_->CancelChannelCreation(kVideoRtpChannelName);
     session_->CancelChannelCreation(kVideoRtcpChannelName);
     session_ = NULL;
   }
 }
 
 bool RtpVideoWriter::is_connected() {
   return rtp_channel_.get() && rtcp_channel_.get();
 }
 
-void RtpVideoWriter::ProcessVideoPacket(const VideoPacket* packet,
+void RtpVideoWriter::ProcessVideoPacket(const scoped_ptr<VideoPacket> packet,
                                         const base::Closure& done) {
   CHECK(packet->format().encoding() == VideoPacketFormat::ENCODING_VP8)
       << "Only VP8 is supported in RTP.";
 
   CompoundBuffer payload;
   // TODO(sergeyu): This copy would not be necessary CompoundBuffer was used
   // inside of VideoPacket.
   payload.AppendCopyOf(packet->data().data(), packet->data().size());
 
   Vp8Descriptor vp8_desriptor;
@@ skipping 34 matching lines @@
     CompoundBuffer chunk;
     chunk.CopyFrom(payload, position, position + size);
 
     // And send it.
     rtp_writer_.SendPacket(packet->timestamp(), marker, vp8_desriptor, chunk);
 
     position += size;
   }
   DCHECK_EQ(position, payload.total_bytes());
 
-  done.Run();
+  if (!done.is_null())
+    done.Run();
 }
 
 int RtpVideoWriter::GetPendingPackets() {
   return rtp_writer_.GetPendingPackets();
 }
 
 }  // namespace protocol
 }  // namespace remoting