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
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
|
/* -*- Mode: C++; tab-width: 8; indent-tabs-mode: nil; c-basic-offset: 2 -*- */
/* vim: set sw=2 ts=8 et 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 "Capsule.h"
#include "CapsuleEncoder.h"
// For Http2Session::LogIO.
#include "Http2Session.h"
namespace mozilla::net {
// static
void Capsule::LogBuffer(const uint8_t* aBuffer, uint32_t aLength) {
#ifdef DEBUG
Http2Session::LogIO(nullptr, nullptr, "Capsule",
reinterpret_cast<const char*>(aBuffer), aLength);
#endif
}
// static
Capsule Capsule::CloseWebTransportSession(uint32_t aStatus,
const nsACString& aReason) {
CloseWebTransportSessionCapsule capsule;
capsule.mStatus = aStatus;
capsule.mReason = aReason;
return Capsule(std::move(capsule));
}
// static
Capsule Capsule::WebTransportMaxData(uint64_t aValue) {
WebTransportMaxDataCapsule capsule;
capsule.mMaxDataSize = aValue;
return Capsule(std::move(capsule));
}
// static
Capsule Capsule::WebTransportStreamData(uint64_t aID, bool aFin,
nsTArray<uint8_t>&& aData) {
WebTransportStreamDataCapsule capsule;
capsule.mID = aID;
capsule.mFin = aFin;
capsule.mData.AppendElements(std::move(aData));
return Capsule(std::move(capsule));
}
// static
Capsule Capsule::WebTransportStreamsBlocked(uint64_t aLimit, bool aBidi) {
WebTransportStreamsBlockedCapsule capsule;
capsule.mLimit = aLimit;
capsule.mBidi = aBidi;
return Capsule(std::move(capsule));
}
// static
Capsule Capsule::WebTransportMaxStreams(uint64_t aLimit, bool aBidi) {
WebTransportMaxStreamsCapsule capsule;
capsule.mLimit = aLimit;
capsule.mBidi = aBidi;
return Capsule(std::move(capsule));
}
// static
Capsule Capsule::WebTransportStreamDataBlocked(uint64_t aLimit, uint64_t aID) {
WebTransportStreamDataBlockedCapsule capsule;
capsule.mLimit = aLimit;
capsule.mID = aID;
return Capsule(std::move(capsule));
}
// static
Capsule Capsule::WebTransportMaxStreamData(uint64_t aLimit, uint64_t aID) {
WebTransportMaxStreamDataCapsule capsule;
capsule.mLimit = aLimit;
capsule.mID = aID;
return Capsule(std::move(capsule));
}
// static
Capsule Capsule::WebTransportDataBlocked(uint64_t aLimit) {
WebTransportDataBlockedCapsule capsule;
capsule.mLimit = aLimit;
return Capsule(std::move(capsule));
}
// static
Capsule Capsule::WebTransportStopSending(uint64_t aError, uint64_t aID) {
WebTransportStopSendingCapsule capsule;
capsule.mErrorCode = aError;
capsule.mID = aID;
return Capsule(std::move(capsule));
}
// static
Capsule Capsule::WebTransportResetStream(uint64_t aError, uint64_t aSize,
uint64_t aID) {
WebTransportResetStreamCapsule capsule;
capsule.mErrorCode = aError;
capsule.mReliableSize = aSize;
capsule.mID = aID;
return Capsule(std::move(capsule));
}
// static
Capsule Capsule::WebTransportDatagram(nsTArray<uint8_t>&& aPayload) {
Capsule capsule;
capsule.mCapsule = AsVariant(WebTransportDatagramCapsule());
capsule.mCapsule.as<WebTransportDatagramCapsule>().mPayload.AppendElements(
std::move(aPayload));
return capsule;
}
// static
Capsule Capsule::Unknown(uint64_t aType, nsTArray<uint8_t>&& aData) {
UnknownCapsule capsule;
capsule.mType = aType;
capsule.mData = std::move(aData);
return Capsule(std::move(capsule));
}
CapsuleType Capsule::Type() const {
return mCapsule.match(
[](const UnknownCapsule& aCapsule) { return aCapsule.Type(); },
[](const CloseWebTransportSessionCapsule& aCapsule) {
return aCapsule.Type();
},
[](const WebTransportMaxDataCapsule& aCapsule) {
return aCapsule.Type();
},
[](const WebTransportStreamDataCapsule& aCapsule) {
return aCapsule.Type();
},
[](const WebTransportStreamsBlockedCapsule& aCapsule) {
return aCapsule.Type();
},
[](const WebTransportMaxStreamsCapsule& aCapsule) {
return aCapsule.Type();
},
[](const WebTransportStreamDataBlockedCapsule& aCapsule) {
return aCapsule.Type();
},
[](const WebTransportMaxStreamDataCapsule& aCapsule) {
return aCapsule.Type();
},
[](const WebTransportDataBlockedCapsule& aCapsule) {
return aCapsule.Type();
},
[](const WebTransportStopSendingCapsule& aCapsule) {
return aCapsule.Type();
},
[](const WebTransportResetStreamCapsule& aCapsule) {
return aCapsule.Type();
},
[](const WebTransportDatagramCapsule& aCapsule) {
return aCapsule.Type();
});
}
} // namespace mozilla::net
|
