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
|
/* 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 mozilla_dom_fetchChild_h__
#define mozilla_dom_fetchChild_h__
#include "mozilla/dom/AbortFollower.h"
#include "mozilla/dom/AbortSignal.h"
#include "mozilla/dom/FlippedOnce.h"
#include "mozilla/dom/PFetchChild.h"
#include "mozilla/dom/SerializedStackHolder.h"
#include "nsIConsoleReportCollector.h"
#include "nsISupports.h"
#include "nsIWorkerChannelInfo.h"
namespace mozilla::dom {
class FetchObserver;
class ThreadSafeWorkerRef;
class Promise;
class WorkerPrivate;
class FetchChild final : public PFetchChild, public AbortFollower {
friend class PFetchChild;
public:
NS_DECL_THREADSAFE_ISUPPORTS
mozilla::ipc::IPCResult Recv__delete__(const nsresult&& aResult);
mozilla::ipc::IPCResult RecvOnResponseAvailableInternal(
ParentToChildInternalResponse&& aResponse);
mozilla::ipc::IPCResult RecvOnResponseEnd(ResponseEndArgs&& aArgs);
mozilla::ipc::IPCResult RecvOnDataAvailable();
mozilla::ipc::IPCResult RecvOnFlushConsoleReport(
nsTArray<net::ConsoleReportCollected>&& aReports);
mozilla::ipc::IPCResult RecvOnCSPViolationEvent(const nsAString& aJSon);
mozilla::ipc::IPCResult RecvOnReportPerformanceTiming(
ResponseTiming&& aTiming);
mozilla::ipc::IPCResult RecvOnNotifyNetworkMonitorAlternateStack(
uint64_t aChannelID);
void SetCSPEventListener(nsICSPEventListener* aListener);
// Creates the actor for worker fetch requests
static RefPtr<FetchChild> CreateForWorker(WorkerPrivate* aWorkerPrivate,
RefPtr<Promise> aPromise,
RefPtr<AbortSignalImpl> aSignalImpl,
RefPtr<FetchObserver> aObserver);
// Creates the actor for main thread fetch requests
static RefPtr<FetchChild> CreateForMainThread(
RefPtr<Promise> aPromise, RefPtr<AbortSignalImpl> aSignalImpl,
RefPtr<FetchObserver> aObserver);
FetchChild(RefPtr<Promise>&& aPromise, RefPtr<AbortSignalImpl>&& aSignalImpl,
RefPtr<FetchObserver>&& aObserver);
// AbortFollower
void RunAbortAlgorithm() override;
void DoFetchOp(const FetchOpArgs& aArgs);
void SetOriginStack(UniquePtr<SerializedStackHolder>&& aStack) {
MOZ_ASSERT(!mOriginStack);
mOriginStack = std::move(aStack);
}
private:
~FetchChild() = default;
// WorkerPrivate shutdown callback.
void Shutdown();
void ActorDestroy(ActorDestroyReason aReason) override;
RefPtr<ThreadSafeWorkerRef> mWorkerRef;
bool mIsKeepAliveRequest{false};
uint64_t mKeepaliveRequestSize{0};
RefPtr<Promise> mPromise;
RefPtr<AbortSignalImpl> mSignalImpl;
RefPtr<FetchObserver> mFetchObserver;
UniquePtr<SerializedStackHolder> mOriginStack;
nsCOMPtr<nsICSPEventListener> mCSPEventListener;
nsCOMPtr<nsIConsoleReportCollector> mReporter;
FlippedOnce<false> mIsShutdown;
nsCOMPtr<nsIWorkerChannelInfo> mWorkerChannelInfo;
};
} // namespace mozilla::dom
#endif
|
