diff -r 000000000000 -r 6474c204b198 toolkit/components/url-classifier/nsUrlClassifierProxies.h --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/toolkit/components/url-classifier/nsUrlClassifierProxies.h Wed Dec 31 06:09:35 2014 +0100 @@ -0,0 +1,303 @@ +/* -*- Mode: C++; tab-width: 8; indent-tabs-mode: nil; c-basic-offset: 2 -*- */ +/* This Source Code Form is subject to the terms of the Mozilla Public + * License, v. 2.0. If a copy of the MPL was not distributed with this + * file, You can obtain one at http://mozilla.org/MPL/2.0/. */ + +#ifndef nsUrlClassifierProxies_h +#define nsUrlClassifierProxies_h + +#include "nsIUrlClassifierDBService.h" +#include "nsProxyRelease.h" +#include "nsThreadUtils.h" +#include "mozilla/Attributes.h" +#include "nsIPrincipal.h" +#include "LookupCache.h" + + +/** + * Thread proxy from the main thread to the worker thread. + */ +class UrlClassifierDBServiceWorkerProxy MOZ_FINAL : + public nsIUrlClassifierDBServiceWorker +{ +public: + UrlClassifierDBServiceWorkerProxy(nsIUrlClassifierDBServiceWorker* aTarget) + : mTarget(aTarget) + { } + + NS_DECL_THREADSAFE_ISUPPORTS + NS_DECL_NSIURLCLASSIFIERDBSERVICE + NS_DECL_NSIURLCLASSIFIERDBSERVICEWORKER + + class LookupRunnable : public nsRunnable + { + public: + LookupRunnable(nsIUrlClassifierDBServiceWorker* aTarget, + nsIPrincipal* aPrincipal, + const nsACString& aTables, + nsIUrlClassifierCallback* aCB) + : mTarget(aTarget) + , mPrincipal(aPrincipal) + , mLookupTables(aTables) + , mCB(aCB) + { } + + NS_DECL_NSIRUNNABLE + + private: + nsCOMPtr mTarget; + nsCOMPtr mPrincipal; + nsCString mLookupTables; + nsCOMPtr mCB; + }; + + class GetTablesRunnable : public nsRunnable + { + public: + GetTablesRunnable(nsIUrlClassifierDBServiceWorker* aTarget, + nsIUrlClassifierCallback* aCB) + : mTarget(aTarget) + , mCB(aCB) + { } + + NS_DECL_NSIRUNNABLE + + private: + nsCOMPtr mTarget; + nsCOMPtr mCB; + }; + + class BeginUpdateRunnable : public nsRunnable + { + public: + BeginUpdateRunnable(nsIUrlClassifierDBServiceWorker* aTarget, + nsIUrlClassifierUpdateObserver* aUpdater, + const nsACString& aTables) + : mTarget(aTarget) + , mUpdater(aUpdater) + , mTables(aTables) + { } + + NS_DECL_NSIRUNNABLE + + private: + nsCOMPtr mTarget; + nsCOMPtr mUpdater; + nsCString mTables; + }; + + class BeginStreamRunnable : public nsRunnable + { + public: + BeginStreamRunnable(nsIUrlClassifierDBServiceWorker* aTarget, + const nsACString& aTable) + : mTarget(aTarget) + , mTable(aTable) + { } + + NS_DECL_NSIRUNNABLE + + private: + nsCOMPtr mTarget; + nsCString mTable; + }; + + class UpdateStreamRunnable : public nsRunnable + { + public: + UpdateStreamRunnable(nsIUrlClassifierDBServiceWorker* aTarget, + const nsACString& aUpdateChunk) + : mTarget(aTarget) + , mUpdateChunk(aUpdateChunk) + { } + + NS_DECL_NSIRUNNABLE + + private: + nsCOMPtr mTarget; + nsCString mUpdateChunk; + }; + + class CacheCompletionsRunnable : public nsRunnable + { + public: + CacheCompletionsRunnable(nsIUrlClassifierDBServiceWorker* aTarget, + mozilla::safebrowsing::CacheResultArray *aEntries) + : mTarget(aTarget) + , mEntries(aEntries) + { } + + NS_DECL_NSIRUNNABLE + + private: + nsCOMPtr mTarget; + mozilla::safebrowsing::CacheResultArray *mEntries; + }; + + class CacheMissesRunnable : public nsRunnable + { + public: + CacheMissesRunnable(nsIUrlClassifierDBServiceWorker* aTarget, + mozilla::safebrowsing::PrefixArray *aEntries) + : mTarget(aTarget) + , mEntries(aEntries) + { } + + NS_DECL_NSIRUNNABLE + + private: + nsCOMPtr mTarget; + mozilla::safebrowsing::PrefixArray *mEntries; + }; + +private: + nsCOMPtr mTarget; +}; + +// The remaining classes here are all proxies to the main thread + +class UrlClassifierLookupCallbackProxy MOZ_FINAL : + public nsIUrlClassifierLookupCallback +{ +public: + UrlClassifierLookupCallbackProxy(nsIUrlClassifierLookupCallback* aTarget) + : mTarget(new nsMainThreadPtrHolder(aTarget)) + { } + + NS_DECL_THREADSAFE_ISUPPORTS + NS_DECL_NSIURLCLASSIFIERLOOKUPCALLBACK + + class LookupCompleteRunnable : public nsRunnable + { + public: + LookupCompleteRunnable(const nsMainThreadPtrHandle& aTarget, + mozilla::safebrowsing::LookupResultArray *aResults) + : mTarget(aTarget) + , mResults(aResults) + { } + + NS_DECL_NSIRUNNABLE + + private: + nsMainThreadPtrHandle mTarget; + mozilla::safebrowsing::LookupResultArray * mResults; + }; + +private: + nsMainThreadPtrHandle mTarget; +}; + +class UrlClassifierCallbackProxy MOZ_FINAL : public nsIUrlClassifierCallback +{ +public: + UrlClassifierCallbackProxy(nsIUrlClassifierCallback* aTarget) + : mTarget(new nsMainThreadPtrHolder(aTarget)) + { } + + NS_DECL_THREADSAFE_ISUPPORTS + NS_DECL_NSIURLCLASSIFIERCALLBACK + + class HandleEventRunnable : public nsRunnable + { + public: + HandleEventRunnable(const nsMainThreadPtrHandle& aTarget, + const nsACString& aValue) + : mTarget(aTarget) + , mValue(aValue) + { } + + NS_DECL_NSIRUNNABLE + + private: + nsMainThreadPtrHandle mTarget; + nsCString mValue; + }; + +private: + nsMainThreadPtrHandle mTarget; +}; + +class UrlClassifierUpdateObserverProxy MOZ_FINAL : + public nsIUrlClassifierUpdateObserver +{ +public: + UrlClassifierUpdateObserverProxy(nsIUrlClassifierUpdateObserver* aTarget) + : mTarget(new nsMainThreadPtrHolder(aTarget)) + { } + + NS_DECL_THREADSAFE_ISUPPORTS + NS_DECL_NSIURLCLASSIFIERUPDATEOBSERVER + + class UpdateUrlRequestedRunnable : public nsRunnable + { + public: + UpdateUrlRequestedRunnable(const nsMainThreadPtrHandle& aTarget, + const nsACString& aURL, + const nsACString& aTable) + : mTarget(aTarget) + , mURL(aURL) + , mTable(aTable) + { } + + NS_DECL_NSIRUNNABLE + + private: + nsMainThreadPtrHandle mTarget; + nsCString mURL, mTable; + }; + + class StreamFinishedRunnable : public nsRunnable + { + public: + StreamFinishedRunnable(const nsMainThreadPtrHandle& aTarget, + nsresult aStatus, uint32_t aDelay) + : mTarget(aTarget) + , mStatus(aStatus) + , mDelay(aDelay) + { } + + NS_DECL_NSIRUNNABLE + + private: + nsMainThreadPtrHandle mTarget; + nsresult mStatus; + uint32_t mDelay; + }; + + class UpdateErrorRunnable : public nsRunnable + { + public: + UpdateErrorRunnable(const nsMainThreadPtrHandle& aTarget, + nsresult aError) + : mTarget(aTarget) + , mError(aError) + { } + + NS_DECL_NSIRUNNABLE + + private: + nsMainThreadPtrHandle mTarget; + nsresult mError; + }; + + class UpdateSuccessRunnable : public nsRunnable + { + public: + UpdateSuccessRunnable(const nsMainThreadPtrHandle& aTarget, + uint32_t aRequestedTimeout) + : mTarget(aTarget) + , mRequestedTimeout(aRequestedTimeout) + { } + + NS_DECL_NSIRUNNABLE + + private: + nsMainThreadPtrHandle mTarget; + uint32_t mRequestedTimeout; + }; + +private: + nsMainThreadPtrHandle mTarget; +}; + +#endif // nsUrlClassifierProxies_h