components/copresence/copresence_manager_impl.h

   1 // Copyright 2014 The Chromium Authors. All rights reserved.
   2 // Use of this source code is governed by a BSD-style license that can be
   3 // found in the LICENSE file.
   4
   5 #ifndef COMPONENTS_COPRESENCE_COPRESENCE_MANAGER_IMPL_H_
   6 #define COMPONENTS_COPRESENCE_COPRESENCE_MANAGER_IMPL_H_
   7
   8 #include <string>
   9 #include <vector>
  10
  11 #include "base/callback.h"
  12 #include "base/macros.h"
  13 #include "base/memory/scoped_ptr.h"
  14 #include "base/memory/weak_ptr.h"
  15 #include "components/copresence/proto/rpcs.pb.h"
  16 #include "components/copresence/public/copresence_manager.h"
  17
  18 namespace net {
  19 class URLContextGetter;
  20 }
  21
  22 namespace copresence {
  23
  24 class RpcHandler;
  25
  26 struct PendingRequest {
  27   PendingRequest(const ReportRequest& report,
  28                  const std::string app_id,
  29                  const StatusCallback& callback);
  30   ~PendingRequest();
  31
  32   ReportRequest report;
  33   std::string app_id;
  34   StatusCallback callback;
  35 };
  36
  37 // The implementation for CopresenceManager.
  38 class CopresenceManagerImpl : public CopresenceManager,
  39     public base::SupportsWeakPtr<CopresenceManagerImpl> {
  40  public:
  41   virtual ~CopresenceManagerImpl();
  42   virtual void ExecuteReportRequest(ReportRequest request,
  43                                     const std::string& app_id,
  44                                     const StatusCallback& callback) OVERRIDE;
  45
  46  private:
  47   // Create managers with the CopresenceManager::Create() method.
  48   friend class CopresenceManager;
  49   CopresenceManagerImpl(CopresenceDelegate* delegate);
  50
  51   void CompleteInitialization();
  52   void InitStepComplete(const std::string& step, bool success);
  53
  54   bool init_failed_;
  55   std::vector<PendingRequest> pending_requests_queue_;
  56
  57   // TODO(rkc): This code is almost identical to what we use in feedback to
  58   // perform multiple blocking tasks and then run a post process method. Look
  59   // into refactoring it all out to a common construct, like maybe a
  60   // PostMultipleTasksAndReply?
  61   size_t pending_init_operations_;
  62
  63   CopresenceDelegate* const delegate_;
  64   scoped_ptr<RpcHandler> rpc_handler_;
  65
  66   DISALLOW_COPY_AND_ASSIGN(CopresenceManagerImpl);
  67 };
  68
  69 }  // namespace copresence
  70
  71 #endif  // COMPONENTS_COPRESENCE_COPRESENCE_MANAGER_IMPL_H_