[GCM] Add TTL support

google_apis/gcm/tools/mcs_probe.cc

 // Copyright 2013 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.
 //
 // A standalone tool for testing MCS connections and the MCS client on their
 // own.
 
 #include <cstddef>
 #include <cstdio>
 #include <string>
 
 #include "base/at_exit.h"
 #include "base/command_line.h"
 #include "base/compiler_specific.h"
 #include "base/logging.h"
 #include "base/memory/ref_counted.h"
 #include "base/memory/scoped_ptr.h"
 #include "base/message_loop/message_loop.h"
 #include "base/run_loop.h"
 #include "base/strings/string_number_conversions.h"
 #include "base/threading/thread.h"
 #include "base/threading/worker_pool.h"
+#include "base/time/default_clock.h"
 #include "base/values.h"
 #include "google_apis/gcm/base/mcs_message.h"
 #include "google_apis/gcm/base/mcs_util.h"
 #include "google_apis/gcm/engine/connection_factory_impl.h"
 #include "google_apis/gcm/engine/mcs_client.h"
 #include "net/base/host_mapping_rules.h"
 #include "net/base/net_log_logger.h"
 #include "net/cert/cert_verifier.h"
 #include "net/dns/host_resolver.h"
 #include "net/http/http_auth_handler_factory.h"
@@ skipping 131 matching lines @@
   uint64 secret() const { return secret_; }
 
  private:
   void InitializeNetworkState();
   void BuildNetworkSession();
 
   void InitializationCallback(bool success,
                               uint64 restored_android_id,
                               uint64 restored_security_token);
 
+  base::DefaultClock clock_;
+
   CommandLine command_line_;
 
   base::FilePath rmq_path_;
   uint64 android_id_;
   uint64 secret_;
   std::string server_host_;
   int server_port_;
 
   // Network state.
   scoped_refptr<net::URLRequestContextGetter> url_request_context_getter_;
@@ skipping 60 matching lines @@
 void MCSProbe::Start() {
   file_thread_.Start();
   InitializeNetworkState();
   BuildNetworkSession();
   connection_factory_.reset(
       new ConnectionFactoryImpl(GURL("https://" + net::HostPortPair(
                                     server_host_, server_port_).ToString()),
                                 network_session_,
                                 &net_log_));
   rmq_store_.reset(new RMQStore(rmq_path_, file_thread_.message_loop_proxy()));
-  mcs_client_.reset(new MCSClient(connection_factory_.get(),
+  mcs_client_.reset(new MCSClient(&clock_,
+                                  connection_factory_.get(),
                                   rmq_store_.get()));
   run_loop_.reset(new base::RunLoop());
   rmq_store_->Load(base::Bind(&MCSClient::Initialize,
                               base::Unretained(mcs_client_.get()),
                               base::Bind(&MCSProbe::InitializationCallback,
                                          base::Unretained(this)),
                               base::Bind(&MessageReceivedCallback),
                               base::Bind(&MessageSentCallback)));
   run_loop_->Run();
 }
@@ skipping 101 matching lines @@
 
   return 0;
 }
 
 }  // namespace
 }  // namespace gcm
 
 int main(int argc, char* argv[]) {
   return gcm::MCSProbeMain(argc, argv);
 }