Implement video frame acknowledgements in the chromoting protocol.

remoting/protocol/monitored_video_stub_unittest.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/monitored_video_stub.h"
 
 #include "base/message_loop/message_loop.h"
 #include "base/message_loop/message_loop_proxy.h"
 #include "base/run_loop.h"
 #include "base/test/test_timeouts.h"
@@ skipping 33 matching lines @@
   scoped_ptr<VideoPacket> packet_;
   base::OneShotTimer<MonitoredVideoStubTest> timer_end_test_;
 };
 
 TEST_F(MonitoredVideoStubTest, OnChannelConnected) {
   EXPECT_CALL(*this, OnVideoChannelStatus(true));
   // On slow machines, the connectivity check timer may fire before the test
   // finishes, so we expect to see at most one transition to not ready.
   EXPECT_CALL(*this, OnVideoChannelStatus(false)).Times(AtMost(1));
 
-  monitor_->ProcessVideoPacket(packet_.Pass(), base::Closure());
+  monitor_->ProcessVideoPacket(packet_.Pass(), VideoStub::ProgressCallback());
   base::RunLoop().RunUntilIdle();
 }
 
 TEST_F(MonitoredVideoStubTest, OnChannelDisconnected) {
   EXPECT_CALL(*this, OnVideoChannelStatus(true));
-  monitor_->ProcessVideoPacket(packet_.Pass(), base::Closure());
+  monitor_->ProcessVideoPacket(packet_.Pass(), VideoStub::ProgressCallback());
 
   EXPECT_CALL(*this, OnVideoChannelStatus(false)).WillOnce(
     InvokeWithoutArgs(
       &message_loop_,
       &base::MessageLoop::Quit));
   message_loop_.Run();
 }
 
 TEST_F(MonitoredVideoStubTest, OnChannelStayConnected) {
   // Verify no extra connected events are fired when packets are received
   // frequently
   EXPECT_CALL(*this, OnVideoChannelStatus(true));
   // On slow machines, the connectivity check timer may fire before the test
   // finishes, so we expect to see at most one transition to not ready.
   EXPECT_CALL(*this, OnVideoChannelStatus(false)).Times(AtMost(1));
 
-  monitor_->ProcessVideoPacket(packet_.Pass(), base::Closure());
-  monitor_->ProcessVideoPacket(packet_.Pass(), base::Closure());
+  monitor_->ProcessVideoPacket(packet_.Pass(), VideoStub::ProgressCallback());
+  monitor_->ProcessVideoPacket(packet_.Pass(), VideoStub::ProgressCallback());
   base::RunLoop().RunUntilIdle();
 }
 
 TEST_F(MonitoredVideoStubTest, OnChannelStayDisconnected) {
   // Verify no extra disconnected events are fired.
   EXPECT_CALL(*this, OnVideoChannelStatus(true)).Times(1);
   EXPECT_CALL(*this, OnVideoChannelStatus(false)).Times(1);
 
-  monitor_->ProcessVideoPacket(packet_.Pass(), base::Closure());
+  monitor_->ProcessVideoPacket(packet_.Pass(), VideoStub::ProgressCallback());
 
   message_loop_.PostDelayedTask(
       FROM_HERE,
       base::MessageLoop::QuitClosure(),
       // The delay should be much greater than |kTestOverrideDelayMilliseconds|.
       TestTimeouts::tiny_timeout());
   message_loop_.Run();
 }
 
 }  // namespace protocol
 }  // namespace remoting