GCP2.0 Device: XMPP pings.

cloud_print/gcp20/prototype/printer.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.
 
 #include "cloud_print/gcp20/prototype/printer.h"
 
 #include <stdio.h>
 #include <string>
 #include <vector>
 
 #include "base/bind.h"
 #include "base/command_line.h"
 #include "base/file_util.h"
 #include "base/guid.h"
 #include "base/json/json_reader.h"
 #include "base/json/json_writer.h"
 #include "base/strings/string_number_conversions.h"
 #include "base/strings/stringprintf.h"
 #include "cloud_print/gcp20/prototype/command_line_reader.h"
 #include "cloud_print/gcp20/prototype/service_parameters.h"
 #include "cloud_print/gcp20/prototype/special_io.h"
 #include "net/base/net_util.h"
 #include "net/base/url_util.h"
 
 const char kPrinterStatePathDefault[] = "printer_state.json";
 
 namespace {
 
 const uint16 kHttpPortDefault = 10101;
-const uint32 kTtlDefault = 60*60;
+const uint32 kTtlDefault = 60*60;  // in seconds
+const int kXmppPingIntervalDefault = 5*60;  // in seconds
 
 const char kServiceType[] = "_privet._tcp.local";
 const char kServiceNamePrefixDefault[] = "first_gcp20_device";
 const char kServiceDomainNameDefault[] = "my-privet-device.local";
 
 const char kPrinterName[] = "Google GCP2.0 Prototype";
 const char kPrinterDescription[] = "Printer emulator";
 
 const char kUserConfirmationTitle[] = "Confirm registration: type 'y' if you "
                                       "agree and any other to discard\n";
@@ skipping 134 matching lines @@
 
 void Printer::Stop() {
   dns_server_.Shutdown();
   http_server_.Shutdown();
   requester_.reset();
   print_job_handler_.reset();
   xmpp_listener_.reset();
 }
 
 void Printer::OnAuthError() {
+  LOG(ERROR) << "Auth error occurred";
   access_token_update_ = base::Time::Now();
   ChangeState(OFFLINE);
   // TODO(maksymb): Implement *instant* updating of access_token.
 }
 
 std::string Printer::GetAccessToken() {
   return access_token_;
 }
 
 PrivetHttpServer::RegistrationErrorStatus Printer::RegistrationStart(
@@ skipping 274 matching lines @@
       ConnectXmpp();
     }
   } else {
     // TODO(maksymb): Ping google.com to check connection state.
     ChangeState(ONLINE);
   }
 }
 
 void Printer::ConnectXmpp() {
   xmpp_listener_.reset(
-      new CloudPrintXmppListener(reg_info_.xmpp_jid, GetTaskRunner(), this));
+      new CloudPrintXmppListener(reg_info_.xmpp_jid, kXmppPingIntervalDefault,
+                                 GetTaskRunner(), this));
   xmpp_listener_->Connect(access_token_);
 }
 
 void Printer::OnIdle() {
   DCHECK(IsRegistered());
   DCHECK(on_idle_posted_) << "Instant call is not allowed";
   on_idle_posted_ = false;
 
   if (connection_state_ != ONLINE)
     return;
@@ skipping 296 matching lines @@
     case NOT_CONFIGURED:
       break;
 
     default:
       NOTREACHED();
   }
 
   return true;
 }