Provide a mechanism for the GCM driver to send message receipts to GCM.

components/gcm_driver/gcm_driver_desktop.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 "components/gcm_driver/gcm_driver_desktop.h"
 
 #include <utility>
 
 #include "base/bind.h"
 #include "base/bind_helpers.h"
@@ skipping 37 matching lines @@
                           const std::string& registration_id,
                           GCMClient::Result result) override;
   void OnUnregisterFinished(
       const linked_ptr<RegistrationInfo>& registration_info,
       GCMClient::Result result) override;
   void OnSendFinished(const std::string& app_id,
                       const std::string& message_id,
                       GCMClient::Result result) override;
   void OnMessageReceived(const std::string& app_id,
                          const IncomingMessage& message) override;
+  void OnMessageReceivedError(const std::string& app_id,
+                              const std::string& message_id,
+                              int status) override;
   void OnMessagesDeleted(const std::string& app_id) override;
   void OnMessageSendError(
       const std::string& app_id,
       const GCMClient::SendErrorDetails& send_error_details) override;
   void OnSendAcknowledged(const std::string& app_id,
                           const std::string& message_id) override;
   void OnGCMReady(const std::vector<AccountMapping>& account_mappings,
                   const base::Time& last_token_fetch_time) override;
   void OnActivityRecorded() override;
   void OnConnected(const net::IPEndPoint& ip_endpoint) override;
@@ skipping 169 matching lines @@
   DCHECK(io_thread_->RunsTasksOnCurrentThread());
 
   ui_thread_->PostTask(
       FROM_HERE,
       base::Bind(&GCMDriverDesktop::MessageReceived,
                  service_,
                  app_id,
                  message));
 }
 
+void GCMDriverDesktop::IOWorker::OnMessageReceivedError(
+    const std::string& app_id,
+    const std::string& message_id,
+    int status) {
+  DCHECK(io_thread_->RunsTasksOnCurrentThread());
+
+  ui_thread_->PostTask(
+      FROM_HERE, base::Bind(&GCMDriverDesktop::MessageReceivedError, service_,
+                            app_id, message_id, status));
+}
+
 void GCMDriverDesktop::IOWorker::OnMessagesDeleted(const std::string& app_id) {
   DCHECK(io_thread_->RunsTasksOnCurrentThread());
 
   ui_thread_->PostTask(
       FROM_HERE,
       base::Bind(&GCMDriverDesktop::MessagesDeleted, service_, app_id));
 }
 
 void GCMDriverDesktop::IOWorker::OnMessageSendError(
     const std::string& app_id,
@@ skipping 962 matching lines @@
                                        const IncomingMessage& message) {
   DCHECK(ui_thread_->RunsTasksOnCurrentThread());
 
   // Drop the event if the service has been stopped.
   if (!gcm_started_)
     return;
 
   DispatchMessage(app_id, message);
 }
 
+void GCMDriverDesktop::MessageReceivedError(const std::string& app_id,
+                                            const std::string& message_id,
+                                            int status) {
+  DCHECK(ui_thread_->RunsTasksOnCurrentThread());
+
+  // Drop the event if the service has been stopped.
+  if (!gcm_started_)
+    return;
+
+  SendMessageReceipt(app_id, message_id, status);
+}
+
 void GCMDriverDesktop::MessagesDeleted(const std::string& app_id) {
   DCHECK(ui_thread_->RunsTasksOnCurrentThread());
 
   // Drop the event if the service has been stopped.
   if (!gcm_started_)
     return;
 
   GetAppHandler(app_id)->OnMessagesDeleted(app_id);
 }
 
@@ skipping 97 matching lines @@
 
   if (std::get<1>(a) < std::get<1>(b))
     return true;
   if (std::get<1>(a) > std::get<1>(b))
     return false;
 
   return std::get<2>(a) < std::get<2>(b);
 }
 
 }  // namespace gcm