1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
|
/* -*- Mode: C++; tab-width: 8; indent-tabs-mode: nil; c-basic-offset: 2 -*- */
/* vim: set ts=8 sts=2 et sw=2 tw=80: */
/* 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/. */
#include "OriginOperationBase.h"
#include "mozilla/Assertions.h"
#include "mozilla/MozPromise.h"
#include "mozilla/dom/fs/TargetPtrHolder.h"
#include "mozilla/dom/quota/QuotaManager.h"
#include "mozilla/dom/quota/ResultExtensions.h"
#include "nsError.h"
#include "nsIThread.h"
#include "nsThreadUtils.h"
namespace mozilla::dom::quota {
OriginOperationBase::OriginOperationBase(
MovingNotNull<RefPtr<QuotaManager>>&& aQuotaManager, const char* aName)
: BackgroundThreadObject(GetCurrentSerialEventTarget()),
mQuotaManager(std::move(aQuotaManager)),
mResultCode(NS_OK),
mActorDestroyed(false)
#ifdef QM_COLLECTING_OPERATION_TELEMETRY
,
mName(aName)
#endif
{
AssertIsOnOwningThread();
}
OriginOperationBase::~OriginOperationBase() {
AssertIsOnOwningThread();
MOZ_ASSERT(mActorDestroyed);
}
void OriginOperationBase::RunImmediately() {
AssertIsOnOwningThread();
[self = RefPtr(this)]() {
if (QuotaManager::IsShuttingDown()) {
return BoolPromise::CreateAndReject(NS_ERROR_ABORT, __func__);
}
QM_TRY(MOZ_TO_RESULT(self->DoInit(*self->mQuotaManager)),
CreateAndRejectBoolPromise);
return self->Open();
}()
#ifdef DEBUG
->Then(GetCurrentSerialEventTarget(), __func__,
[self = RefPtr(this)](
const BoolPromise::ResolveOrRejectValue& aValue) {
if (aValue.IsReject()) {
return BoolPromise::CreateAndReject(aValue.RejectValue(),
__func__);
}
// Give derived classes the occasion to add additional debug
// only checks after the opening was successfully finished on
// the current thread before passing the work to the IO thread.
QM_TRY(MOZ_TO_RESULT(self->DirectoryOpen()),
CreateAndRejectBoolPromise);
return BoolPromise::CreateAndResolve(true, __func__);
})
#endif
->Then(mQuotaManager->IOThread(), __func__,
[selfHolder = fs::TargetPtrHolder(this)](
const BoolPromise::ResolveOrRejectValue& aValue) {
if (aValue.IsReject()) {
return BoolPromise::CreateAndReject(aValue.RejectValue(),
__func__);
}
QM_TRY(MOZ_TO_RESULT(selfHolder->DoDirectoryWork(
*selfHolder->mQuotaManager)),
CreateAndRejectBoolPromise);
return BoolPromise::CreateAndResolve(true, __func__);
})
->Then(GetCurrentSerialEventTarget(), __func__,
[self = RefPtr(this)](
const BoolPromise::ResolveOrRejectValue& aValue) {
if (aValue.IsReject()) {
MOZ_ASSERT(NS_SUCCEEDED(self->mResultCode));
self->mResultCode = aValue.RejectValue();
}
self->UnblockOpen();
});
}
nsresult OriginOperationBase::DoInit(QuotaManager& aQuotaManager) {
AssertIsOnOwningThread();
return NS_OK;
}
#ifdef DEBUG
nsresult OriginOperationBase::DirectoryOpen() {
AssertIsOnOwningThread();
return NS_OK;
}
#endif
} // namespace mozilla::dom::quota
|
