Simplify message parsing.

remoting/protocol/client_video_dispatcher.cc

 // 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/client_video_dispatcher.h"
 
 #include <utility>
 
 #include "base/bind.h"
 #include "base/callback_helpers.h"
@@ skipping 10 matching lines @@
   PendingFrame(int frame_id)
       : frame_id(frame_id),
         done(false) {}
   int frame_id;
   bool done;
 };
 
 ClientVideoDispatcher::ClientVideoDispatcher(VideoStub* video_stub)
     : ChannelDispatcherBase(kVideoChannelName),
       video_stub_(video_stub),
-      parser_(base::Bind(&ClientVideoDispatcher::ProcessVideoPacket,
-                         base::Unretained(this)),
-              reader()),
       weak_factory_(this) {}
-
 ClientVideoDispatcher::~ClientVideoDispatcher() {}
 
-void ClientVideoDispatcher::ProcessVideoPacket(
-    scoped_ptr<VideoPacket> video_packet) {
+void ClientVideoDispatcher::OnIncomingMessage(
+    scoped_ptr<CompoundBuffer> message) {
+  scoped_ptr<VideoPacket> video_packet =
+      ParseMessage<VideoPacket>(message.get());
+  if (!video_packet)
+    return;
+
   int frame_id = video_packet->frame_id();
 
   if (!video_packet->has_frame_id()) {
     video_stub_->ProcessVideoPacket(std::move(video_packet),
                                     base::Bind(&base::DoNothing));
     return;
   }
 
   PendingFramesList::iterator pending_frame =
       pending_frames_.insert(pending_frames_.end(), PendingFrame(frame_id));
@@ skipping 15 matching lines @@
   while (!pending_frames_.empty() && pending_frames_.front().done) {
     VideoAck ack_message;
     ack_message.set_frame_id(pending_frames_.front().frame_id);
     writer()->Write(SerializeAndFrameMessage(ack_message), base::Closure());
     pending_frames_.pop_front();
   }
 }
 
 }  // namespace protocol
 }  // namespace remoting