ppapi/proxy/ppb_network_monitor_private_proxy.cc

   1 // Copyright (c) 2012 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 #include "ppapi/proxy/ppb_network_monitor_private_proxy.h"
   6
   7 #include "ppapi/proxy/enter_proxy.h"
   8 #include "ppapi/proxy/ppapi_messages.h"
   9 #include "ppapi/shared_impl/proxy_lock.h"
  10 #include "ppapi/thunk/ppb_network_monitor_private_api.h"
  11
  12 namespace ppapi {
  13 namespace proxy {
  14
  15 class PPB_NetworkMonitor_Private_Proxy::NetworkMonitor
  16     : public Resource,
  17       public thunk::PPB_NetworkMonitor_Private_API,
  18       public base::SupportsWeakPtr<
  19           PPB_NetworkMonitor_Private_Proxy::NetworkMonitor> {
  20  public:
  21   NetworkMonitor(PP_Instance instance,
  22                  PPB_NetworkMonitor_Private_Proxy* proxy,
  23                  PPB_NetworkMonitor_Callback callback,
  24                  void* user_data)
  25       : Resource(OBJECT_IS_PROXY, instance),
  26         proxy_(proxy),
  27         callback_(callback),
  28         user_data_(user_data) {
  29   }
  30
  31   virtual ~NetworkMonitor() {
  32     proxy_->OnNetworkMonitorDeleted(this, pp_instance());
  33   }
  34
  35
  36   // Resource overrides.
  37   virtual ppapi::thunk::PPB_NetworkMonitor_Private_API*
  38   AsPPB_NetworkMonitor_Private_API() OVERRIDE {
  39     return this;
  40   }
  41
  42   // This is invoked when a network list is received for this monitor (either
  43   // initially or on a change). It acquires the ProxyLock inside because
  44   // ObserverListThreadSafe does not support Bind/Closure, otherwise we would
  45   // wrap the call with a lock using RunWhileLocked.
  46   void OnNetworkListReceivedLocks(
  47       const scoped_refptr<NetworkListStorage>& list) {
  48     ProxyAutoLock lock;
  49     PP_Resource list_resource =
  50         PPB_NetworkList_Private_Shared::Create(
  51             OBJECT_IS_PROXY, pp_instance(), list);
  52     CallWhileUnlocked(callback_, user_data_, list_resource);
  53   }
  54
  55  private:
  56   PPB_NetworkMonitor_Private_Proxy* proxy_;
  57   PPB_NetworkMonitor_Callback callback_;
  58   void* user_data_;
  59
  60   DISALLOW_COPY_AND_ASSIGN(NetworkMonitor);
  61 };
  62
  63 PPB_NetworkMonitor_Private_Proxy::PPB_NetworkMonitor_Private_Proxy(
  64     Dispatcher* dispatcher)
  65     : InterfaceProxy(dispatcher),
  66       monitors_(new ObserverListThreadSafe<NetworkMonitor>()),
  67       monitors_count_(0) {
  68 }
  69
  70 PPB_NetworkMonitor_Private_Proxy::~PPB_NetworkMonitor_Private_Proxy() {
  71   monitors_->AssertEmpty();
  72 }
  73
  74 // static
  75 PP_Resource PPB_NetworkMonitor_Private_Proxy::CreateProxyResource(
  76     PP_Instance instance,
  77     PPB_NetworkMonitor_Callback callback,
  78     void* user_data) {
  79   // TODO(dmichael): Check that this thread has a valid message loop associated
  80   //                 with it.
  81   if (!callback)
  82     return 0;
  83
  84   PluginDispatcher* dispatcher = PluginDispatcher::GetForInstance(instance);
  85   if (!dispatcher)
  86     return 0;
  87   PPB_NetworkMonitor_Private_Proxy* proxy =
  88       static_cast<PPB_NetworkMonitor_Private_Proxy*>(
  89           dispatcher->GetInterfaceProxy(kApiID));
  90   if (!proxy)
  91     return 0;
  92
  93   scoped_refptr<NetworkMonitor> result(
  94       new NetworkMonitor(instance, proxy, callback, user_data));
  95   proxy->monitors_->AddObserver(result.get());
  96
  97   proxy->monitors_count_++;
  98   if (proxy->monitors_count_ == 1) {
  99     // If that is the first network monitor then send Start message.
 100     PluginGlobals::Get()->GetBrowserSender()->Send(
 101         new PpapiHostMsg_PPBNetworkMonitor_Start(
 102             dispatcher->plugin_dispatcher_id()));
 103
 104     // We could have received network list message after sending the
 105     // previous Stop message. This list is stale now, so reset it
 106     // here.
 107     proxy->current_list_ = NULL;
 108   } else if (proxy->current_list_.get()) {
 109     base::MessageLoop::current()->PostTask(
 110         FROM_HERE,
 111         base::Bind(&NetworkMonitor::OnNetworkListReceivedLocks,
 112                    result->AsWeakPtr(),
 113                    proxy->current_list_));
 114   }
 115
 116   return result->GetReference();
 117 }
 118
 119 bool PPB_NetworkMonitor_Private_Proxy::OnMessageReceived(
 120     const IPC::Message& msg) {
 121   bool handled = true;
 122   IPC_BEGIN_MESSAGE_MAP(PPB_NetworkMonitor_Private_Proxy, msg)
 123     IPC_MESSAGE_HANDLER(PpapiMsg_PPBNetworkMonitor_NetworkList,
 124                         OnPluginMsgNetworkList)
 125     IPC_MESSAGE_UNHANDLED(handled = false)
 126   IPC_END_MESSAGE_MAP()
 127   return handled;
 128 }
 129
 130 void PPB_NetworkMonitor_Private_Proxy::OnPluginMsgNetworkList(
 131     uint32 plugin_dispatcher_id,
 132     const ppapi::NetworkList& list) {
 133   scoped_refptr<NetworkListStorage> list_storage(new NetworkListStorage(list));
 134   current_list_ = list_storage;
 135   monitors_->Notify(&NetworkMonitor::OnNetworkListReceivedLocks, list_storage);
 136 }
 137
 138 void PPB_NetworkMonitor_Private_Proxy::OnNetworkMonitorDeleted(
 139     NetworkMonitor* monitor,
 140     PP_Instance instance) {
 141   monitors_->RemoveObserver(monitor);
 142   monitors_count_--;
 143   if (monitors_count_ == 0) {
 144     // Send Stop message if that was the last NetworkMonitor.
 145     PluginDispatcher* dispatcher = PluginDispatcher::GetForInstance(instance);
 146     if (dispatcher) {
 147       PluginGlobals::Get()->GetBrowserSender()->Send(
 148           new PpapiHostMsg_PPBNetworkMonitor_Stop(
 149               dispatcher->plugin_dispatcher_id()));
 150     }
 151     current_list_ = NULL;
 152   }
 153 }
 154
 155 }  // namespace proxy
 156 }  // namespace ppapi