[NetInfo] Add Blink support for connection.change, connection.downlinkMax, and wimax

Source/core/page/NetworkStateNotifier.cpp

 /*
  * Copyright (C) 2008 Apple Inc. All Rights Reserved.
  *
  * Redistribution and use in source and binary forms, with or without
  * modification, are permitted provided that the following conditions
  * are met:
  * 1. Redistributions of source code must retain the above copyright
  *    notice, this list of conditions and the following disclaimer.
  * 2. Redistributions in binary form must reproduce the above copyright
  *    notice, this list of conditions and the following disclaimer in the
@@ skipping 40 matching lines @@
         MutexLocker locker(m_mutex);
         if (m_isOnLine == onLine)
             return;
 
         m_isOnLine = onLine;
     }
 
     Page::networkStateChanged(onLine);
 }
 
-void NetworkStateNotifier::setWebConnectionType(WebConnectionType type)
+void NetworkStateNotifier::setWebConnection(WebConnectionType type, double maxBandwidthMbps)
 {
     ASSERT(isMainThread());
     if (m_testUpdatesOnly)
         return;
 
-    setWebConnectionTypeImpl(type);
-}
-
-void NetworkStateNotifier::setWebConnectionTypeImpl(WebConnectionType type)
-{
-    ASSERT(isMainThread());
-
-    MutexLocker locker(m_mutex);
-    if (m_type == type)
-        return;
-    m_type = type;
-
-    for (const auto& entry : m_observers) {
-        ExecutionContext* context = entry.key;
-        context->postTask(FROM_HERE, createCrossThreadTask(&NetworkStateNotifier::notifyObserversOnContext, this, type));
-    }
+    setWebConnectionImpl(type, maxBandwidthMbps);
 }
 
 void NetworkStateNotifier::addObserver(NetworkStateObserver* observer, ExecutionContext* context)
 {
     ASSERT(context->isContextThread());
     ASSERT(observer);
 
     MutexLocker locker(m_mutex);
     ObserverListMap::AddResult result = m_observers.add(context, nullptr);
     if (result.isNewEntry)
@@ skipping 22 matching lines @@
     if (!observerList->iterating && !observerList->zeroedObservers.isEmpty())
         collectZeroedObservers(observerList, context);
 }
 
 void NetworkStateNotifier::setTestUpdatesOnly(bool updatesOnly)
 {
     ASSERT(isMainThread());
     m_testUpdatesOnly = updatesOnly;
 }
 
-void NetworkStateNotifier::setWebConnectionTypeForTest(WebConnectionType type)
+void NetworkStateNotifier::setWebConnectionForTest(WebConnectionType type, double maxBandwidthMbps)
 {
     ASSERT(isMainThread());
     ASSERT(m_testUpdatesOnly);
-    setWebConnectionTypeImpl(type);
+    setWebConnectionImpl(type, maxBandwidthMbps);
 }
 
-void NetworkStateNotifier::notifyObserversOnContext(WebConnectionType type, ExecutionContext* context)
+void NetworkStateNotifier::setWebConnectionImpl(WebConnectionType type, double maxBandwidthMbps)
+{
+    ASSERT(isMainThread());
+
+    MutexLocker locker(m_mutex);
+    if (m_type == type && m_maxBandwidthMbps == maxBandwidthMbps)
+        return;
+    m_type = type;
+    m_maxBandwidthMbps = maxBandwidthMbps;
+
+    for (const auto& entry : m_observers) {
+        ExecutionContext* context = entry.key;
+        context->postTask(FROM_HERE, createCrossThreadTask(&NetworkStateNotifier::notifyObserversOfConnectionChangeOnContext, this, type, maxBandwidthMbps));
+    }
+}
+
+void NetworkStateNotifier::notifyObserversOfConnectionChangeOnContext(WebConnectionType type, double maxBandwidthMbps, ExecutionContext* context)
 {
     ObserverList* observerList = lockAndFindObserverList(context);
 
     // The context could have been removed before the notification task got to run.
     if (!observerList)
         return;
 
     ASSERT(context->isContextThread());
 
     observerList->iterating = true;
 
     for (size_t i = 0; i < observerList->observers.size(); ++i) {
         // Observers removed during iteration are zeroed out, skip them.
         if (observerList->observers[i])
-            observerList->observers[i]->connectionTypeChange(type);
+            observerList->observers[i]->connectionChange(type, maxBandwidthMbps);
     }
 
     observerList->iterating = false;
 
     if (!observerList->zeroedObservers.isEmpty())
         collectZeroedObservers(observerList, context);
 }
 
 NetworkStateNotifier::ObserverList* NetworkStateNotifier::lockAndFindObserverList(ExecutionContext* context)
 {
@@ skipping 14 matching lines @@
 
     list->zeroedObservers.clear();
 
     if (list->observers.isEmpty()) {
         MutexLocker locker(m_mutex);
         m_observers.remove(context); // deletes list
     }
 }
 
 } // namespace blink