Refactor VideoStub interface to accept ownership of video packets.

remoting/protocol/message_reader.cc

 // Copyright (c) 2011 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_reader.h"
 
 #include "base/bind.h"
 #include "base/callback.h"
 #include "base/location.h"
 #include "net/base/io_buffer.h"
@@ skipping 77 matching lines @@
       break;
     new_messages.push_back(buffer);
   }
 
   pending_messages_ += new_messages.size();
 
   // TODO(lambroslambrou): MessageLoopProxy::current() will not work from the
   // plugin thread if this code is compiled into a separate binary.  Fix this.
   for (std::vector<CompoundBuffer*>::iterator it = new_messages.begin();
        it != new_messages.end(); ++it) {
-    message_received_callback_.Run(*it, base::Bind(
-        &MessageReader::OnMessageDone, this,
-        *it, base::MessageLoopProxy::current()));
+    message_received_callback_.Run(
+        scoped_ptr<CompoundBuffer>(*it),
+        base::Bind(&MessageReader::OnMessageDone, this,
+                   base::MessageLoopProxy::current()));
   }
 }
 
 void MessageReader::OnMessageDone(
-    CompoundBuffer* message,
     scoped_refptr<base::MessageLoopProxy> message_loop) {
   if (!message_loop->BelongsToCurrentThread()) {
     message_loop->PostTask(
         FROM_HERE,
-        base::Bind(&MessageReader::OnMessageDone, this, message, message_loop));
+        base::Bind(&MessageReader::OnMessageDone, this, message_loop));
     return;
   }
-  delete message;
   ProcessDoneEvent();
 }
 
 void MessageReader::ProcessDoneEvent() {
   pending_messages_--;
   DCHECK_GE(pending_messages_, 0);
 
   DoRead(); // Start next read if neccessary.
 }
 
 }  // namespace protocol
 }  // namespace remoting