Gather history of capture and encode time determine next recoring delay

remoting/host/screen_recorder.h

 // 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.
 
 #ifndef REMOTING_HOST_SCREEN_RECORDER_H_
 #define REMOTING_HOST_SCREEN_RECORDER_H_
 
 #include <vector>
 
 #include "base/basictypes.h"
 #include "base/callback.h"
 #include "base/memory/ref_counted.h"
 #include "base/memory/scoped_ptr.h"
 #include "base/message_loop.h"
 #include "base/time.h"
 #include "base/timer.h"
 #include "remoting/base/encoder.h"
 #include "remoting/host/capturer.h"
+#include "remoting/host/recording_rate_regulator.h"
 #include "remoting/proto/video.pb.h"
 
 namespace base {
 class MessageLoopProxy;
 }  // namespace base
 
 namespace remoting {
 
 namespace protocol {
 class ConnectionToClient;
@@ skipping 56 matching lines @@
 
   virtual ~ScreenRecorder();
 
   // Start recording.
   void Start();
 
   // Stop the recording session. |done_task| is executed when recording is fully
   // stopped. This object cannot be used again after |task| is executed.
   void Stop(const base::Closure& done_task);
 
-  // Set the maximum capture rate. This is denoted by number of updates
-  // in one second. The actual system may run in a slower rate than the maximum
-  // rate due to various factors, e.g. capture speed, encode speed and network
-  // conditions.
-  // This method should be called before Start() is called.
-  void SetMaxRate(double rate);
-
   // Add a connection to this recording session.
   void AddConnection(scoped_refptr<protocol::ConnectionToClient> connection);
 
   // Remove a connection from receiving screen updates.
   void RemoveConnection(scoped_refptr<protocol::ConnectionToClient> connection);
 
   // Remove all connections.
   void RemoveAllConnections();
 
   // Update the sequence number for tracing performance.
@@ skipping 70 matching lines @@
   // Flag that indicates recording has been started. This variable should only
   // be used on the capture thread.
   bool is_recording_;
 
   // Per-thread flags that are set when the ScreenRecorder is
   // stopped. They must be used on the corresponding threads only.
   bool network_stopped_;
   bool encoder_stopped_;
 
   // Timer that calls DoCapture.
-  base::RepeatingTimer<ScreenRecorder> capture_timer_;
+  base::OneShotTimer<ScreenRecorder> capture_timer_;
+
+  // Maximum simutaneous recordings allowed. Note that this number

[Wez, 2011/10/20 00:52:15]

typo: "simutaneous"

[Alpha Left Google, 2011/10/31 18:47:24]

Done.

+  // cannot exceed 2 at any time.
+  int max_recordings_;
 
   // Count the number of recordings (i.e. capture or encode) happening.
   int recordings_;
 
   // Set to true if we've skipped last capture because there are too
   // many pending frames.
   int frame_skipped_;
 
-  // Number of captures to perform every second. Written on the capture thread.
-  double max_rate_;
-
   // Time when capture is started.
   base::Time capture_start_time_;
 
   // Time when encode is started.
   base::Time encode_start_time_;
 
   // This is a number updated by client to trace performance.
   int64 sequence_number_;
 
+  // An object to help throttle recording rate.
+  RecordingRateRegulator regulator_;
+
   DISALLOW_COPY_AND_ASSIGN(ScreenRecorder);
 };
 
 }  // namespace remoting
 
 #endif  // REMOTING_HOST_SCREEN_RECORDER_H_