Implement video frame acknowledgements in the chromoting protocol.

remoting/protocol/message_reader.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/message_reader.h"
 
 #include "base/bind.h"
 #include "base/callback.h"
 #include "base/compiler_specific.h"
 #include "base/location.h"
@@ skipping 72 matching lines @@
     if (result != net::ERR_CONNECTION_CLOSED) {
       LOG(ERROR) << "Read() returned error " << result;
     }
     // Stop reading after any error.
     closed_ = true;
   }
 }
 
 void MessageReader::OnDataReceived(net::IOBuffer* data, int data_size) {
   DCHECK(CalledOnValidThread());
+
+  base::TimeTicks now = base::TimeTicks::Now();
+
+  if (message_decoder_.is_buffer_empty())
+    last_message_started_time_ = now;
   message_decoder_.AddData(data, data_size);
 
   // Get list of all new messages first, and then call the callback
   // for all of them.
   while (true) {
     CompoundBuffer* buffer = message_decoder_.GetNextMessage();
     if (!buffer)
       break;
     pending_messages_++;
+    base::TimeDelta read_duration = now - last_message_started_time_;
     base::ThreadTaskRunnerHandle::Get()->PostTask(
         FROM_HERE,
-        base::Bind(&MessageReader::RunCallback,
-                   weak_factory_.GetWeakPtr(),
-                   base::Passed(make_scoped_ptr(buffer))));
+        base::Bind(&MessageReader::RunCallback, weak_factory_.GetWeakPtr(),
+                   base::Passed(make_scoped_ptr(buffer)), read_duration));
+    last_message_started_time_ = now;
   }
 }
 
-void MessageReader::RunCallback(scoped_ptr<CompoundBuffer> message) {
-  if (!message_received_callback_.is_null()){
+void MessageReader::RunCallback(scoped_ptr<CompoundBuffer> message,
+                                base::TimeDelta read_duration) {
+  last_message_read_duration_ = read_duration;
+  if (!message_received_callback_.is_null()) {
     message_received_callback_.Run(
         message.Pass(),
         base::Bind(&MessageReader::OnMessageDone, weak_factory_.GetWeakPtr()));
   }
 }
 
 void MessageReader::OnMessageDone() {
   DCHECK(CalledOnValidThread());
   pending_messages_--;
   DCHECK_GE(pending_messages_, 0);
 
   // Start next read if necessary.
   DoRead();
 }
 
 }  // namespace protocol
 }  // namespace remoting