Attachment #8743359 for bug #1217544

Attachment #8743359: Part 2: ServiceWorkerRegistration for bug #1217544

View | Details | Raw Unified | Return to bug 1217544
Collapse All | Expand All





  }

  RefPtr<SyncManager> ref = new SyncManager(aGlobal, principalInfo);
  return ref.forget();
}

// static
already_AddRefed<SyncManager>
SyncManager::CreateOnWorker(nsIGlobalObject* aGlobal,
                            WorkerPrivate* aWorkerPrivate)
{
  MOZ_ASSERT(aWorkerPrivate);
  aWorkerPrivate->AssertIsOnWorkerThread();

  const PrincipalInfo& principalInfo = aWorkerPrivate->GetPrincipalInfo();

  RefPtr<SyncManager> ref = new SyncManager(aGlobal, principalInfo);
  return ref.forget();
}

SyncManager::SyncManager(nsIGlobalObject* aGlobal,
                         const PrincipalInfo& aPrincipalInfo)
  : mGlobal(aGlobal)
  , mPrincipalInfo(new PrincipalInfo(aPrincipalInfo))
{}

SyncManager::PrefEnabled(JSContext* aCx, JSObject* aObj)
{
  using mozilla::dom::workers::WorkerPrivate;
  using mozilla::dom::workers::GetWorkerPrivateFromContext;

  // If we are on the main thread, then check the pref directly.
  if (NS_IsMainThread()) {
    bool enabled = false;
    Preferences::GetBool("dom.backgroundSync.enabled", &enabled);
    return enabled;
  }

  // Otherwise check the pref via the worker private helper.
  WorkerPrivate* workerPrivate = GetWorkerPrivateFromContext(aCx);
  if (!workerPrivate) {
    return false;
  }





  NS_DECL_CYCLE_COLLECTION_SCRIPT_HOLDER_CLASS(SyncManager)

  static already_AddRefed<SyncManager>
  CreateOnMainThread(nsIGlobalObject* aGlobal,
                     nsIPrincipal* aPrincipal,
                     ErrorResult& aRv);

  static already_AddRefed<SyncManager>
  CreateOnWorker(nsIGlobalObject* aGlobal,
                 workers::WorkerPrivate* aWorkerPrivate);

  // Binding methods.

  nsIGlobalObject*
  GetParentObject() const
  {
    // Can be nullptr on workers.
    return mGlobal;
  }

  JSObject*
  WrapObject(JSContext* aCx, JS::Handle<JSObject*> aGivenProto) override;

  static bool PrefEnabled(JSContext* aCx, JSObject* aObj);


(-)a/dom/webidl/ServiceWorkerRegistration.webidl (+2 lines)

Line	Link Here

Lines 27-35 interface ServiceWorkerRegistration : Ev	Link Here

  attribute EventHandler onupdatefound;

  attribute EventHandler onupdatefound;

};

};

partial interface ServiceWorkerRegistration {

partial interface ServiceWorkerRegistration {

#ifndef MOZ_SIMPLEPUSH

#ifndef MOZ_SIMPLEPUSH

  [Throws, Exposed=(Window,Worker), Func="nsContentUtils::PushEnabled"]

  [Throws, Exposed=(Window,Worker), Func="nsContentUtils::PushEnabled"]

  readonly attribute PushManager pushManager;

  readonly attribute PushManager pushManager;

#endif

#endif

  [Throws, Exposed=(Window,Worker), Func="SyncManager::PrefEnabled"]

  readonly attribute SyncManager sync;

};

};





#include "Workers.h"
#include "WorkerScope.h"

#ifndef MOZ_SIMPLEPUSH
#include "mozilla/dom/PushManagerBinding.h"
#include "mozilla/dom/PushManager.h"
#endif

#include "mozilla/dom/SyncManagerBinding.h"
#include "mozilla/dom/SyncManager.h"

using namespace mozilla::dom::workers;

namespace mozilla {
namespace dom {

bool
ServiceWorkerRegistrationVisible(JSContext* aCx, JSObject* aObj)
{

NS_IMPL_ADDREF_INHERITED(ServiceWorkerRegistrationMainThread, ServiceWorkerRegistrationBase)
NS_IMPL_RELEASE_INHERITED(ServiceWorkerRegistrationMainThread, ServiceWorkerRegistrationBase)

NS_INTERFACE_MAP_BEGIN_CYCLE_COLLECTION_INHERITED(ServiceWorkerRegistrationMainThread)
NS_INTERFACE_MAP_END_INHERITING(ServiceWorkerRegistrationBase)

#ifndef MOZ_SIMPLEPUSH
NS_IMPL_CYCLE_COLLECTION_INHERITED(ServiceWorkerRegistrationMainThread, ServiceWorkerRegistrationBase,
                                   mPushManager, mSyncManager,
                                   mInstallingWorker, mWaitingWorker, mActiveWorker);
#else
NS_IMPL_CYCLE_COLLECTION_INHERITED(ServiceWorkerRegistrationMainThread, ServiceWorkerRegistrationBase,
                                   mSyncManager,
                                   mInstallingWorker, mWaitingWorker, mActiveWorker);
#endif

ServiceWorkerRegistrationMainThread::ServiceWorkerRegistrationMainThread(nsPIDOMWindowInner* aWindow,
                                                                         const nsAString& aScope)
  : ServiceWorkerRegistrationBase(aWindow, aScope)
  , mListeningForEvents(false)
{

  }

  RefPtr<PushManager> ret = mPushManager;
  return ret.forget();

#endif /* ! MOZ_SIMPLEPUSH */
}

SyncManager*
ServiceWorkerRegistrationMainThread::GetSync(ErrorResult& aRv)
{
  AssertIsOnMainThread();

  if (!mSyncManager) {
    nsCOMPtr<nsIGlobalObject> globalObject = do_QueryInterface(GetOwner());

    if (!globalObject) {
      aRv.Throw(NS_ERROR_FAILURE);
      return nullptr;
    }

    nsCOMPtr<nsIDocument> document = GetOwner()->GetExtantDoc();
    if (!document) {
      aRv.Throw(NS_ERROR_FAILURE);
      return nullptr;
    }

    nsCOMPtr<nsIPrincipal> principal = document->NodePrincipal();
    if (!principal) {
      aRv.Throw(NS_ERROR_FAILURE);
      return nullptr;
    }

    mSyncManager = SyncManager::CreateOnMainThread(globalObject, principal,
                                                   aRv);
  }

  return mSyncManager;
}

////////////////////////////////////////////////////
// Worker Thread implementation
class WorkerListener final : public ServiceWorkerRegistrationListener
{
  // Accessed on the main thread.
  WorkerPrivate* mWorkerPrivate;
  nsString mScope;
  bool mListeningForEvents;

// Expanded macros since we need special behaviour to release the proxy.
NS_IMPL_CYCLE_COLLECTION_CLASS(ServiceWorkerRegistrationWorkerThread)

NS_IMPL_CYCLE_COLLECTION_TRAVERSE_BEGIN_INHERITED(ServiceWorkerRegistrationWorkerThread,
                                                  ServiceWorkerRegistrationBase)
#ifndef MOZ_SIMPLEPUSH
  NS_IMPL_CYCLE_COLLECTION_TRAVERSE(mPushManager)
#endif
  NS_IMPL_CYCLE_COLLECTION_TRAVERSE(mSyncManager)
NS_IMPL_CYCLE_COLLECTION_TRAVERSE_END

NS_IMPL_CYCLE_COLLECTION_UNLINK_BEGIN_INHERITED(ServiceWorkerRegistrationWorkerThread,
                                                ServiceWorkerRegistrationBase)
#ifndef MOZ_SIMPLEPUSH
  NS_IMPL_CYCLE_COLLECTION_UNLINK(mPushManager)
#endif
  NS_IMPL_CYCLE_COLLECTION_UNLINK(mSyncManager)
  tmp->ReleaseListener(RegistrationIsGoingAway);
NS_IMPL_CYCLE_COLLECTION_UNLINK_END

ServiceWorkerRegistrationWorkerThread::ServiceWorkerRegistrationWorkerThread(WorkerPrivate* aWorkerPrivate,
                                                                             const nsAString& aScope)
  : ServiceWorkerRegistrationBase(nullptr, aScope)
  , mWorkerPrivate(aWorkerPrivate)
{

  }

  RefPtr<PushManager> ret = mPushManager;
  return ret.forget();

#endif /* ! MOZ_SIMPLEPUSH */
}

SyncManager*
ServiceWorkerRegistrationWorkerThread::GetSync(ErrorResult& aRv)
{
  if (!mSyncManager) {
    mSyncManager = SyncManager::CreateOnWorker(mWorkerPrivate->GlobalScope(),
                                               mWorkerPrivate);
  }

  return mSyncManager;
}

} // dom namespace
} // mozilla namespace






class nsPIDOMWindowInner;

namespace mozilla {
namespace dom {

class Promise;
class PushManager;
class SyncManager;
class WorkerListener;

namespace workers {
class ServiceWorker;
class WorkerPrivate;
} // namespace workers

bool

  GetWaiting() override;

  already_AddRefed<workers::ServiceWorker>
  GetActive() override;

  already_AddRefed<PushManager>
  GetPushManager(JSContext* aCx, ErrorResult& aRv);

  SyncManager*
  GetSync(ErrorResult& aRv);

  // DOMEventTargethelper
  void DisconnectFromOwner() override
  {
    StopListeningForEvents();
    ServiceWorkerRegistrationBase::DisconnectFromOwner();
  }

  // ServiceWorkerRegistrationListener

  // These three may change to a new worker at any time.
  RefPtr<workers::ServiceWorker> mInstallingWorker;
  RefPtr<workers::ServiceWorker> mWaitingWorker;
  RefPtr<workers::ServiceWorker> mActiveWorker;

#ifndef MOZ_SIMPLEPUSH
  RefPtr<PushManager> mPushManager;
#endif

  RefPtr<SyncManager> mSyncManager;
};

class ServiceWorkerRegistrationWorkerThread final : public ServiceWorkerRegistrationBase
                                                  , public workers::WorkerFeature
{
public:
  NS_DECL_ISUPPORTS_INHERITED
  NS_DECL_CYCLE_COLLECTION_CLASS_INHERITED(ServiceWorkerRegistrationWorkerThread,

  }

  bool
  Notify(workers::Status aStatus) override;

  already_AddRefed<PushManager>
  GetPushManager(ErrorResult& aRv);

  SyncManager*
  GetSync(ErrorResult& aRv);

private:
  enum Reason
  {
    RegistrationIsGoingAway = 0,
    WorkerIsGoingAway,
  };

  ~ServiceWorkerRegistrationWorkerThread();

  ReleaseListener(Reason aReason);

  workers::WorkerPrivate* mWorkerPrivate;
  RefPtr<WorkerListener> mListener;

#ifndef MOZ_SIMPLEPUSH
  RefPtr<PushManager> mPushManager;
#endif

  RefPtr<SyncManager> mSyncManager;
};

} // namespace dom
} // namespace mozilla

#endif /* mozilla_dom_ServiceWorkerRegistration_h */





WORKER_SIMPLE_PREF("dom.caches.testing.enabled", DOMCachesTestingEnabled, DOM_CACHES_TESTING)
WORKER_SIMPLE_PREF("dom.performance.enable_user_timing_logging", PerformanceLoggingEnabled, PERFORMANCE_LOGGING_ENABLED)
WORKER_SIMPLE_PREF("dom.webnotifications.enabled", DOMWorkerNotificationEnabled, DOM_WORKERNOTIFICATION)
WORKER_SIMPLE_PREF("dom.webnotifications.serviceworker.enabled", DOMServiceWorkerNotificationEnabled, DOM_SERVICEWORKERNOTIFICATION)
WORKER_SIMPLE_PREF("dom.serviceWorkers.enabled", ServiceWorkersEnabled, SERVICEWORKERS_ENABLED)
WORKER_SIMPLE_PREF("dom.serviceWorkers.testing.enabled", ServiceWorkersTestingEnabled, SERVICEWORKERS_TESTING_ENABLED)
WORKER_SIMPLE_PREF("dom.serviceWorkers.openWindow.enabled", OpenWindowEnabled, OPEN_WINDOW_ENABLED)
WORKER_SIMPLE_PREF("dom.push.enabled", PushEnabled, PUSH_ENABLED)
WORKER_SIMPLE_PREF("dom.backgroundSync.enabled", BackgroundSyncEnabled, BACKGROUND_SYNC_ENABLED)
WORKER_SIMPLE_PREF("dom.requestcontext.enabled", RequestContextEnabled, REQUESTCONTEXT_ENABLED)
WORKER_SIMPLE_PREF("gfx.offscreencanvas.enabled", OffscreenCanvasEnabled, OFFSCREENCANVAS_ENABLED)
WORKER_PREF("dom.workers.latestJSVersion", JSVersionChanged)
WORKER_PREF("intl.accept_languages", PrefLanguagesChanged)
WORKER_PREF("general.appname.override", AppNameOverrideChanged)
WORKER_PREF("general.appversion.override", AppVersionOverrideChanged)
WORKER_PREF("general.platform.override", PlatformOverrideChanged)
#ifdef JS_GC_ZEAL

Return to bug 1217544