1.1 --- /dev/null Thu Jan 01 00:00:00 1970 +0000
1.2 +++ b/dom/devicestorage/DeviceStorageRequestParent.h Wed Dec 31 06:09:35 2014 +0100
1.3 @@ -0,0 +1,316 @@
1.4 +/* -*- Mode: C++; tab-width: 2; indent-tabs-mode: nil; c-basic-offset: 2 -*- */
1.5 +/* This Source Code Form is subject to the terms of the Mozilla Public
1.6 + * License, v. 2.0. If a copy of the MPL was not distributed with this file,
1.7 + * You can obtain one at http://mozilla.org/MPL/2.0/. */
1.8 +
1.9 +#ifndef mozilla_dom_devicestorage_DeviceStorageRequestParent_h
1.10 +#define mozilla_dom_devicestorage_DeviceStorageRequestParent_h
1.11 +
1.12 +#include "mozilla/Attributes.h"
1.13 +#include "mozilla/dom/devicestorage/PDeviceStorageRequestParent.h"
1.14 +#include "mozilla/dom/ContentChild.h"
1.15 +#include "mozilla/dom/ContentParent.h"
1.16 +
1.17 +#include "nsThreadUtils.h"
1.18 +#include "nsDeviceStorage.h"
1.19 +#include "nsTArray.h"
1.20 +
1.21 +namespace mozilla {
1.22 +namespace dom {
1.23 +namespace devicestorage {
1.24 +
1.25 +class DeviceStorageRequestParent : public PDeviceStorageRequestParent
1.26 +{
1.27 +public:
1.28 + DeviceStorageRequestParent(const DeviceStorageParams& aParams);
1.29 +
1.30 + NS_IMETHOD_(MozExternalRefCountType) AddRef();
1.31 + NS_IMETHOD_(MozExternalRefCountType) Release();
1.32 +
1.33 + bool EnsureRequiredPermissions(mozilla::dom::ContentParent* aParent);
1.34 + void Dispatch();
1.35 +
1.36 + virtual void ActorDestroy(ActorDestroyReason);
1.37 +
1.38 +protected:
1.39 + ~DeviceStorageRequestParent();
1.40 +
1.41 +private:
1.42 + ThreadSafeAutoRefCnt mRefCnt;
1.43 + NS_DECL_OWNINGTHREAD
1.44 + DeviceStorageParams mParams;
1.45 +
1.46 + class CancelableRunnable : public nsRunnable
1.47 + {
1.48 + public:
1.49 + CancelableRunnable(DeviceStorageRequestParent* aParent)
1.50 + : mParent(aParent)
1.51 + {
1.52 + mCanceled = !(mParent->AddRunnable(this));
1.53 + }
1.54 +
1.55 + virtual ~CancelableRunnable() {
1.56 + }
1.57 +
1.58 + NS_IMETHOD Run() MOZ_OVERRIDE {
1.59 + nsresult rv = NS_OK;
1.60 + if (!mCanceled) {
1.61 + rv = CancelableRun();
1.62 + mParent->RemoveRunnable(this);
1.63 + }
1.64 + return rv;
1.65 + }
1.66 +
1.67 + void Cancel() {
1.68 + mCanceled = true;
1.69 + }
1.70 +
1.71 + virtual nsresult CancelableRun() = 0;
1.72 +
1.73 + protected:
1.74 + nsRefPtr<DeviceStorageRequestParent> mParent;
1.75 + private:
1.76 + bool mCanceled;
1.77 + };
1.78 +
1.79 + class PostErrorEvent : public CancelableRunnable
1.80 + {
1.81 + public:
1.82 + PostErrorEvent(DeviceStorageRequestParent* aParent, const char* aError);
1.83 + virtual ~PostErrorEvent();
1.84 + virtual nsresult CancelableRun();
1.85 + private:
1.86 + nsString mError;
1.87 + };
1.88 +
1.89 + class PostSuccessEvent : public CancelableRunnable
1.90 + {
1.91 + public:
1.92 + PostSuccessEvent(DeviceStorageRequestParent* aParent);
1.93 + virtual ~PostSuccessEvent();
1.94 + virtual nsresult CancelableRun();
1.95 + };
1.96 +
1.97 + class PostBlobSuccessEvent : public CancelableRunnable
1.98 + {
1.99 + public:
1.100 + PostBlobSuccessEvent(DeviceStorageRequestParent* aParent, DeviceStorageFile* aFile, uint32_t aLength, nsACString& aMimeType, uint64_t aLastModifiedDate);
1.101 + virtual ~PostBlobSuccessEvent();
1.102 + virtual nsresult CancelableRun();
1.103 + private:
1.104 + uint32_t mLength;
1.105 + uint64_t mLastModificationDate;
1.106 + nsRefPtr<DeviceStorageFile> mFile;
1.107 + nsCString mMimeType;
1.108 + };
1.109 +
1.110 + class PostEnumerationSuccessEvent : public CancelableRunnable
1.111 + {
1.112 + public:
1.113 + PostEnumerationSuccessEvent(DeviceStorageRequestParent* aParent,
1.114 + const nsAString& aStorageType,
1.115 + const nsAString& aRelPath,
1.116 + InfallibleTArray<DeviceStorageFileValue>& aPaths);
1.117 + virtual ~PostEnumerationSuccessEvent();
1.118 + virtual nsresult CancelableRun();
1.119 + private:
1.120 + const nsString mStorageType;
1.121 + const nsString mRelPath;
1.122 + InfallibleTArray<DeviceStorageFileValue> mPaths;
1.123 + };
1.124 +
1.125 + class CreateFdEvent : public CancelableRunnable
1.126 + {
1.127 + public:
1.128 + CreateFdEvent(DeviceStorageRequestParent* aParent, DeviceStorageFile* aFile);
1.129 + virtual ~CreateFdEvent();
1.130 + virtual nsresult CancelableRun();
1.131 + private:
1.132 + nsRefPtr<DeviceStorageFile> mFile;
1.133 + };
1.134 +
1.135 + class WriteFileEvent : public CancelableRunnable
1.136 + {
1.137 + public:
1.138 + WriteFileEvent(DeviceStorageRequestParent* aParent, DeviceStorageFile* aFile, nsIInputStream* aInputStream);
1.139 + virtual ~WriteFileEvent();
1.140 + virtual nsresult CancelableRun();
1.141 + private:
1.142 + nsRefPtr<DeviceStorageFile> mFile;
1.143 + nsCOMPtr<nsIInputStream> mInputStream;
1.144 + };
1.145 +
1.146 + class DeleteFileEvent : public CancelableRunnable
1.147 + {
1.148 + public:
1.149 + DeleteFileEvent(DeviceStorageRequestParent* aParent, DeviceStorageFile* aFile);
1.150 + virtual ~DeleteFileEvent();
1.151 + virtual nsresult CancelableRun();
1.152 + private:
1.153 + nsRefPtr<DeviceStorageFile> mFile;
1.154 + };
1.155 +
1.156 + class FreeSpaceFileEvent : public CancelableRunnable
1.157 + {
1.158 + public:
1.159 + FreeSpaceFileEvent(DeviceStorageRequestParent* aParent, DeviceStorageFile* aFile);
1.160 + virtual ~FreeSpaceFileEvent();
1.161 + virtual nsresult CancelableRun();
1.162 + private:
1.163 + nsRefPtr<DeviceStorageFile> mFile;
1.164 + };
1.165 +
1.166 + class UsedSpaceFileEvent : public CancelableRunnable
1.167 + {
1.168 + public:
1.169 + UsedSpaceFileEvent(DeviceStorageRequestParent* aParent, DeviceStorageFile* aFile);
1.170 + virtual ~UsedSpaceFileEvent();
1.171 + virtual nsresult CancelableRun();
1.172 + private:
1.173 + nsRefPtr<DeviceStorageFile> mFile;
1.174 + };
1.175 +
1.176 + class ReadFileEvent : public CancelableRunnable
1.177 + {
1.178 + public:
1.179 + ReadFileEvent(DeviceStorageRequestParent* aParent, DeviceStorageFile* aFile);
1.180 + virtual ~ReadFileEvent();
1.181 + virtual nsresult CancelableRun();
1.182 + private:
1.183 + nsRefPtr<DeviceStorageFile> mFile;
1.184 + nsCString mMimeType;
1.185 + };
1.186 +
1.187 + class EnumerateFileEvent : public CancelableRunnable
1.188 + {
1.189 + public:
1.190 + EnumerateFileEvent(DeviceStorageRequestParent* aParent, DeviceStorageFile* aFile, uint64_t aSince);
1.191 + virtual ~EnumerateFileEvent();
1.192 + virtual nsresult CancelableRun();
1.193 + private:
1.194 + nsRefPtr<DeviceStorageFile> mFile;
1.195 + uint64_t mSince;
1.196 + };
1.197 +
1.198 + class PostPathResultEvent : public CancelableRunnable
1.199 + {
1.200 + public:
1.201 + PostPathResultEvent(DeviceStorageRequestParent* aParent, const nsAString& aPath);
1.202 + virtual ~PostPathResultEvent();
1.203 + virtual nsresult CancelableRun();
1.204 + private:
1.205 + nsRefPtr<DeviceStorageFile> mFile;
1.206 + nsString mPath;
1.207 + };
1.208 +
1.209 + class PostFileDescriptorResultEvent : public CancelableRunnable
1.210 + {
1.211 + public:
1.212 + PostFileDescriptorResultEvent(DeviceStorageRequestParent* aParent,
1.213 + const FileDescriptor& aFileDescriptor);
1.214 + virtual ~PostFileDescriptorResultEvent();
1.215 + virtual nsresult CancelableRun();
1.216 + private:
1.217 + nsRefPtr<DeviceStorageFile> mFile;
1.218 + FileDescriptor mFileDescriptor;
1.219 + };
1.220 +
1.221 + class PostFreeSpaceResultEvent : public CancelableRunnable
1.222 + {
1.223 + public:
1.224 + PostFreeSpaceResultEvent(DeviceStorageRequestParent* aParent,
1.225 + uint64_t aFreeSpace);
1.226 + virtual ~PostFreeSpaceResultEvent();
1.227 + virtual nsresult CancelableRun();
1.228 + private:
1.229 + uint64_t mFreeSpace;
1.230 + };
1.231 +
1.232 + class PostUsedSpaceResultEvent : public CancelableRunnable
1.233 + {
1.234 + public:
1.235 + PostUsedSpaceResultEvent(DeviceStorageRequestParent* aParent,
1.236 + const nsAString& aType,
1.237 + uint64_t aUsedSpace);
1.238 + virtual ~PostUsedSpaceResultEvent();
1.239 + virtual nsresult CancelableRun();
1.240 + private:
1.241 + nsString mType;
1.242 + uint64_t mUsedSpace;
1.243 + };
1.244 +
1.245 + class PostAvailableResultEvent : public CancelableRunnable
1.246 + {
1.247 + public:
1.248 + PostAvailableResultEvent(DeviceStorageRequestParent* aParent, DeviceStorageFile* aFile);
1.249 + virtual ~PostAvailableResultEvent();
1.250 + virtual nsresult CancelableRun();
1.251 + private:
1.252 + nsRefPtr<DeviceStorageFile> mFile;
1.253 + };
1.254 +
1.255 + class PostStatusResultEvent : public CancelableRunnable
1.256 + {
1.257 + public:
1.258 + PostStatusResultEvent(DeviceStorageRequestParent* aParent, DeviceStorageFile* aFile);
1.259 + virtual ~PostStatusResultEvent();
1.260 + virtual nsresult CancelableRun();
1.261 + private:
1.262 + nsRefPtr<DeviceStorageFile> mFile;
1.263 + };
1.264 +
1.265 + class PostFormatResultEvent : public CancelableRunnable
1.266 + {
1.267 + public:
1.268 + PostFormatResultEvent(DeviceStorageRequestParent* aParent, DeviceStorageFile* aFile);
1.269 + virtual ~PostFormatResultEvent();
1.270 + virtual nsresult CancelableRun();
1.271 + private:
1.272 + nsRefPtr<DeviceStorageFile> mFile;
1.273 + };
1.274 +
1.275 + class PostMountResultEvent : public CancelableRunnable
1.276 + {
1.277 + public:
1.278 + PostMountResultEvent(DeviceStorageRequestParent* aParent, DeviceStorageFile* aFile);
1.279 + virtual ~PostMountResultEvent();
1.280 + virtual nsresult CancelableRun();
1.281 + private:
1.282 + nsRefPtr<DeviceStorageFile> mFile;
1.283 + };
1.284 +
1.285 + class PostUnmountResultEvent : public CancelableRunnable
1.286 + {
1.287 + public:
1.288 + PostUnmountResultEvent(DeviceStorageRequestParent* aParent, DeviceStorageFile* aFile);
1.289 + virtual ~PostUnmountResultEvent();
1.290 + virtual nsresult CancelableRun();
1.291 + private:
1.292 + nsRefPtr<DeviceStorageFile> mFile;
1.293 + };
1.294 +
1.295 +protected:
1.296 + bool AddRunnable(CancelableRunnable* aRunnable) {
1.297 + MutexAutoLock lock(mMutex);
1.298 + if (mActorDestoryed)
1.299 + return false;
1.300 +
1.301 + mRunnables.AppendElement(aRunnable);
1.302 + return true;
1.303 + }
1.304 +
1.305 + void RemoveRunnable(CancelableRunnable* aRunnable) {
1.306 + MutexAutoLock lock(mMutex);
1.307 + mRunnables.RemoveElement(aRunnable);
1.308 + }
1.309 +
1.310 + Mutex mMutex;
1.311 + bool mActorDestoryed;
1.312 + nsTArray<nsRefPtr<CancelableRunnable> > mRunnables;
1.313 +};
1.314 +
1.315 +} // namespace devicestorage
1.316 +} // namespace dom
1.317 +} // namespace mozilla
1.318 +
1.319 +#endif
