Implement video frame acknowledgements in the chromoting protocol.

remoting/client/software_video_renderer.h

 // 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.
 
 #ifndef REMOTING_CLIENT_SOFTWARE_VIDEO_RENDERER_H_
 #define REMOTING_CLIENT_SOFTWARE_VIDEO_RENDERER_H_
 
 #include "base/memory/ref_counted.h"
 #include "base/memory/scoped_ptr.h"
 #include "remoting/client/chromoting_stats.h"
@@ skipping 27 matching lines @@
   SoftwareVideoRenderer(
       scoped_refptr<base::SingleThreadTaskRunner> main_task_runner,
       scoped_refptr<base::SingleThreadTaskRunner> decode_task_runner,
       scoped_refptr<FrameConsumerProxy> consumer);
   ~SoftwareVideoRenderer() override;
 
   // VideoRenderer implementation.
   void OnSessionConfig(const protocol::SessionConfig& config) override;
   ChromotingStats* GetStats() override;
   void ProcessVideoPacket(scoped_ptr<VideoPacket> packet,
-                          const base::Closure& done) override;
+                          const ProgressCallback& progress_callback) override;
 
   // FrameProducer implementation. These methods may be called before we are
   // Initialize()d, or we know the source screen size. These methods may be
   // called on any thread.
   //
   // TODO(sergeyu): On Android a separate display thread is used for drawing.
   // FrameConsumer calls FrameProducer on that thread. Can we avoid having a
   // separate display thread? E.g. can we do everything on the decode thread?
   void DrawBuffer(webrtc::DesktopFrame* buffer) override;
   void InvalidateRegion(const webrtc::DesktopRegion& region) override;
   void RequestReturnBuffers(const base::Closure& done) override;
   void SetOutputSizeAndClip(const webrtc::DesktopSize& view_size,
                             const webrtc::DesktopRect& clip_area) override;
 
  private:
   class Core;
 
   // Callback method when a VideoPacket is processed. |decode_start| contains
   // the timestamp when the packet will start to be processed.
-  void OnPacketDone(base::Time decode_start, const base::Closure& done);
+  void OnPacketDone(base::Time decode_start,
+                    const ProgressCallback& progress_callback);
 
   scoped_refptr<base::SingleThreadTaskRunner> decode_task_runner_;
   scoped_ptr<Core> core_;
 
   ChromotingStats stats_;
 
   // Keep track of the latest event timestamp bounced back from the host.
   int64 latest_event_timestamp_;
 
   base::WeakPtrFactory<SoftwareVideoRenderer> weak_factory_;
 
   DISALLOW_COPY_AND_ASSIGN(SoftwareVideoRenderer);
 };
 
 }  // namespace remoting
 
 #endif  // REMOTING_CLIENT_SOFTWARE_VIDEO_RENDERER_H_