cannam@147
|
1 // Copyright (c) 2013-2014 Sandstorm Development Group, Inc. and contributors
|
cannam@147
|
2 // Licensed under the MIT License:
|
cannam@147
|
3 //
|
cannam@147
|
4 // Permission is hereby granted, free of charge, to any person obtaining a copy
|
cannam@147
|
5 // of this software and associated documentation files (the "Software"), to deal
|
cannam@147
|
6 // in the Software without restriction, including without limitation the rights
|
cannam@147
|
7 // to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
|
cannam@147
|
8 // copies of the Software, and to permit persons to whom the Software is
|
cannam@147
|
9 // furnished to do so, subject to the following conditions:
|
cannam@147
|
10 //
|
cannam@147
|
11 // The above copyright notice and this permission notice shall be included in
|
cannam@147
|
12 // all copies or substantial portions of the Software.
|
cannam@147
|
13 //
|
cannam@147
|
14 // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
cannam@147
|
15 // IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
cannam@147
|
16 // FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
|
cannam@147
|
17 // AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
|
cannam@147
|
18 // LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
|
cannam@147
|
19 // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
|
cannam@147
|
20 // THE SOFTWARE.
|
cannam@147
|
21
|
cannam@147
|
22 #ifndef CAPNP_ANY_H_
|
cannam@147
|
23 #define CAPNP_ANY_H_
|
cannam@147
|
24
|
cannam@147
|
25 #if defined(__GNUC__) && !defined(CAPNP_HEADER_WARNINGS)
|
cannam@147
|
26 #pragma GCC system_header
|
cannam@147
|
27 #endif
|
cannam@147
|
28
|
cannam@147
|
29 #include "layout.h"
|
cannam@147
|
30 #include "pointer-helpers.h"
|
cannam@147
|
31 #include "orphan.h"
|
cannam@147
|
32 #include "list.h"
|
cannam@147
|
33
|
cannam@147
|
34 namespace capnp {
|
cannam@147
|
35
|
cannam@147
|
36 class StructSchema;
|
cannam@147
|
37 class ListSchema;
|
cannam@147
|
38 class InterfaceSchema;
|
cannam@147
|
39 class Orphanage;
|
cannam@147
|
40 class ClientHook;
|
cannam@147
|
41 class PipelineHook;
|
cannam@147
|
42 struct PipelineOp;
|
cannam@147
|
43 struct AnyPointer;
|
cannam@147
|
44
|
cannam@147
|
45 struct AnyList {
|
cannam@147
|
46 AnyList() = delete;
|
cannam@147
|
47
|
cannam@147
|
48 class Reader;
|
cannam@147
|
49 class Builder;
|
cannam@147
|
50 };
|
cannam@147
|
51
|
cannam@147
|
52 struct AnyStruct {
|
cannam@147
|
53 AnyStruct() = delete;
|
cannam@147
|
54
|
cannam@147
|
55 class Reader;
|
cannam@147
|
56 class Builder;
|
cannam@147
|
57 class Pipeline;
|
cannam@147
|
58 };
|
cannam@147
|
59
|
cannam@147
|
60 template<>
|
cannam@147
|
61 struct List<AnyStruct, Kind::OTHER> {
|
cannam@147
|
62 List() = delete;
|
cannam@147
|
63
|
cannam@147
|
64 class Reader;
|
cannam@147
|
65 class Builder;
|
cannam@147
|
66 };
|
cannam@147
|
67
|
cannam@147
|
68 namespace _ { // private
|
cannam@147
|
69 template <> struct Kind_<AnyPointer> { static constexpr Kind kind = Kind::OTHER; };
|
cannam@147
|
70 template <> struct Kind_<AnyStruct> { static constexpr Kind kind = Kind::OTHER; };
|
cannam@147
|
71 template <> struct Kind_<AnyList> { static constexpr Kind kind = Kind::OTHER; };
|
cannam@147
|
72 } // namespace _ (private)
|
cannam@147
|
73
|
cannam@147
|
74 // =======================================================================================
|
cannam@147
|
75 // AnyPointer!
|
cannam@147
|
76
|
cannam@147
|
77 enum class Equality {
|
cannam@147
|
78 NOT_EQUAL,
|
cannam@147
|
79 EQUAL,
|
cannam@147
|
80 UNKNOWN_CONTAINS_CAPS
|
cannam@147
|
81 };
|
cannam@147
|
82
|
cannam@147
|
83 kj::StringPtr KJ_STRINGIFY(Equality res);
|
cannam@147
|
84
|
cannam@147
|
85 struct AnyPointer {
|
cannam@147
|
86 // Reader/Builder for the `AnyPointer` field type, i.e. a pointer that can point to an arbitrary
|
cannam@147
|
87 // object.
|
cannam@147
|
88
|
cannam@147
|
89 AnyPointer() = delete;
|
cannam@147
|
90
|
cannam@147
|
91 class Reader {
|
cannam@147
|
92 public:
|
cannam@147
|
93 typedef AnyPointer Reads;
|
cannam@147
|
94
|
cannam@147
|
95 Reader() = default;
|
cannam@147
|
96 inline Reader(_::PointerReader reader): reader(reader) {}
|
cannam@147
|
97
|
cannam@147
|
98 inline MessageSize targetSize() const;
|
cannam@147
|
99 // Get the total size of the target object and all its children.
|
cannam@147
|
100
|
cannam@147
|
101 inline PointerType getPointerType() const;
|
cannam@147
|
102
|
cannam@147
|
103 inline bool isNull() const { return getPointerType() == PointerType::NULL_; }
|
cannam@147
|
104 inline bool isStruct() const { return getPointerType() == PointerType::STRUCT; }
|
cannam@147
|
105 inline bool isList() const { return getPointerType() == PointerType::LIST; }
|
cannam@147
|
106 inline bool isCapability() const { return getPointerType() == PointerType::CAPABILITY; }
|
cannam@147
|
107
|
cannam@147
|
108 Equality equals(AnyPointer::Reader right);
|
cannam@147
|
109 bool operator==(AnyPointer::Reader right);
|
cannam@147
|
110 inline bool operator!=(AnyPointer::Reader right) {
|
cannam@147
|
111 return !(*this == right);
|
cannam@147
|
112 }
|
cannam@147
|
113
|
cannam@147
|
114 template <typename T>
|
cannam@147
|
115 inline ReaderFor<T> getAs() const;
|
cannam@147
|
116 // Valid for T = any generated struct type, interface type, List<U>, Text, or Data.
|
cannam@147
|
117
|
cannam@147
|
118 template <typename T>
|
cannam@147
|
119 inline ReaderFor<T> getAs(StructSchema schema) const;
|
cannam@147
|
120 // Only valid for T = DynamicStruct. Requires `#include <capnp/dynamic.h>`.
|
cannam@147
|
121
|
cannam@147
|
122 template <typename T>
|
cannam@147
|
123 inline ReaderFor<T> getAs(ListSchema schema) const;
|
cannam@147
|
124 // Only valid for T = DynamicList. Requires `#include <capnp/dynamic.h>`.
|
cannam@147
|
125
|
cannam@147
|
126 template <typename T>
|
cannam@147
|
127 inline ReaderFor<T> getAs(InterfaceSchema schema) const;
|
cannam@147
|
128 // Only valid for T = DynamicCapability. Requires `#include <capnp/dynamic.h>`.
|
cannam@147
|
129
|
cannam@147
|
130 #if !CAPNP_LITE
|
cannam@147
|
131 kj::Own<ClientHook> getPipelinedCap(kj::ArrayPtr<const PipelineOp> ops) const;
|
cannam@147
|
132 // Used by RPC system to implement pipelining. Applications generally shouldn't use this
|
cannam@147
|
133 // directly.
|
cannam@147
|
134 #endif // !CAPNP_LITE
|
cannam@147
|
135
|
cannam@147
|
136 private:
|
cannam@147
|
137 _::PointerReader reader;
|
cannam@147
|
138 friend struct AnyPointer;
|
cannam@147
|
139 friend class Orphanage;
|
cannam@147
|
140 friend class CapReaderContext;
|
cannam@147
|
141 friend struct _::PointerHelpers<AnyPointer>;
|
cannam@147
|
142 };
|
cannam@147
|
143
|
cannam@147
|
144 class Builder {
|
cannam@147
|
145 public:
|
cannam@147
|
146 typedef AnyPointer Builds;
|
cannam@147
|
147
|
cannam@147
|
148 Builder() = delete;
|
cannam@147
|
149 inline Builder(decltype(nullptr)) {}
|
cannam@147
|
150 inline Builder(_::PointerBuilder builder): builder(builder) {}
|
cannam@147
|
151
|
cannam@147
|
152 inline MessageSize targetSize() const;
|
cannam@147
|
153 // Get the total size of the target object and all its children.
|
cannam@147
|
154
|
cannam@147
|
155 inline PointerType getPointerType();
|
cannam@147
|
156
|
cannam@147
|
157 inline bool isNull() { return getPointerType() == PointerType::NULL_; }
|
cannam@147
|
158 inline bool isStruct() { return getPointerType() == PointerType::STRUCT; }
|
cannam@147
|
159 inline bool isList() { return getPointerType() == PointerType::LIST; }
|
cannam@147
|
160 inline bool isCapability() { return getPointerType() == PointerType::CAPABILITY; }
|
cannam@147
|
161
|
cannam@147
|
162 inline Equality equals(AnyPointer::Reader right) {
|
cannam@147
|
163 return asReader().equals(right);
|
cannam@147
|
164 }
|
cannam@147
|
165 inline bool operator==(AnyPointer::Reader right) {
|
cannam@147
|
166 return asReader() == right;
|
cannam@147
|
167 }
|
cannam@147
|
168 inline bool operator!=(AnyPointer::Reader right) {
|
cannam@147
|
169 return !(*this == right);
|
cannam@147
|
170 }
|
cannam@147
|
171
|
cannam@147
|
172 inline void clear();
|
cannam@147
|
173 // Set to null.
|
cannam@147
|
174
|
cannam@147
|
175 template <typename T>
|
cannam@147
|
176 inline BuilderFor<T> getAs();
|
cannam@147
|
177 // Valid for T = any generated struct type, List<U>, Text, or Data.
|
cannam@147
|
178
|
cannam@147
|
179 template <typename T>
|
cannam@147
|
180 inline BuilderFor<T> getAs(StructSchema schema);
|
cannam@147
|
181 // Only valid for T = DynamicStruct. Requires `#include <capnp/dynamic.h>`.
|
cannam@147
|
182
|
cannam@147
|
183 template <typename T>
|
cannam@147
|
184 inline BuilderFor<T> getAs(ListSchema schema);
|
cannam@147
|
185 // Only valid for T = DynamicList. Requires `#include <capnp/dynamic.h>`.
|
cannam@147
|
186
|
cannam@147
|
187 template <typename T>
|
cannam@147
|
188 inline BuilderFor<T> getAs(InterfaceSchema schema);
|
cannam@147
|
189 // Only valid for T = DynamicCapability. Requires `#include <capnp/dynamic.h>`.
|
cannam@147
|
190
|
cannam@147
|
191 template <typename T>
|
cannam@147
|
192 inline BuilderFor<T> initAs();
|
cannam@147
|
193 // Valid for T = any generated struct type.
|
cannam@147
|
194
|
cannam@147
|
195 template <typename T>
|
cannam@147
|
196 inline BuilderFor<T> initAs(uint elementCount);
|
cannam@147
|
197 // Valid for T = List<U>, Text, or Data.
|
cannam@147
|
198
|
cannam@147
|
199 template <typename T>
|
cannam@147
|
200 inline BuilderFor<T> initAs(StructSchema schema);
|
cannam@147
|
201 // Only valid for T = DynamicStruct. Requires `#include <capnp/dynamic.h>`.
|
cannam@147
|
202
|
cannam@147
|
203 template <typename T>
|
cannam@147
|
204 inline BuilderFor<T> initAs(ListSchema schema, uint elementCount);
|
cannam@147
|
205 // Only valid for T = DynamicList. Requires `#include <capnp/dynamic.h>`.
|
cannam@147
|
206
|
cannam@147
|
207 inline AnyList::Builder initAsAnyList(ElementSize elementSize, uint elementCount);
|
cannam@147
|
208 // Note: Does not accept INLINE_COMPOSITE for elementSize.
|
cannam@147
|
209
|
cannam@147
|
210 inline List<AnyStruct>::Builder initAsListOfAnyStruct(
|
cannam@147
|
211 uint16_t dataWordCount, uint16_t pointerCount, uint elementCount);
|
cannam@147
|
212
|
cannam@147
|
213 inline AnyStruct::Builder initAsAnyStruct(uint16_t dataWordCount, uint16_t pointerCount);
|
cannam@147
|
214
|
cannam@147
|
215 template <typename T>
|
cannam@147
|
216 inline void setAs(ReaderFor<T> value);
|
cannam@147
|
217 // Valid for ReaderType = T::Reader for T = any generated struct type, List<U>, Text, Data,
|
cannam@147
|
218 // DynamicStruct, or DynamicList (the dynamic types require `#include <capnp/dynamic.h>`).
|
cannam@147
|
219
|
cannam@147
|
220 template <typename T>
|
cannam@147
|
221 inline void setAs(std::initializer_list<ReaderFor<ListElementType<T>>> list);
|
cannam@147
|
222 // Valid for T = List<?>.
|
cannam@147
|
223
|
cannam@147
|
224 template <typename T>
|
cannam@147
|
225 inline void setCanonicalAs(ReaderFor<T> value);
|
cannam@147
|
226
|
cannam@147
|
227 inline void set(Reader value) { builder.copyFrom(value.reader); }
|
cannam@147
|
228 // Set to a copy of another AnyPointer.
|
cannam@147
|
229
|
cannam@147
|
230 inline void setCanonical(Reader value) { builder.copyFrom(value.reader, true); }
|
cannam@147
|
231
|
cannam@147
|
232 template <typename T>
|
cannam@147
|
233 inline void adopt(Orphan<T>&& orphan);
|
cannam@147
|
234 // Valid for T = any generated struct type, List<U>, Text, Data, DynamicList, DynamicStruct,
|
cannam@147
|
235 // or DynamicValue (the dynamic types require `#include <capnp/dynamic.h>`).
|
cannam@147
|
236
|
cannam@147
|
237 template <typename T>
|
cannam@147
|
238 inline Orphan<T> disownAs();
|
cannam@147
|
239 // Valid for T = any generated struct type, List<U>, Text, Data.
|
cannam@147
|
240
|
cannam@147
|
241 template <typename T>
|
cannam@147
|
242 inline Orphan<T> disownAs(StructSchema schema);
|
cannam@147
|
243 // Only valid for T = DynamicStruct. Requires `#include <capnp/dynamic.h>`.
|
cannam@147
|
244
|
cannam@147
|
245 template <typename T>
|
cannam@147
|
246 inline Orphan<T> disownAs(ListSchema schema);
|
cannam@147
|
247 // Only valid for T = DynamicList. Requires `#include <capnp/dynamic.h>`.
|
cannam@147
|
248
|
cannam@147
|
249 template <typename T>
|
cannam@147
|
250 inline Orphan<T> disownAs(InterfaceSchema schema);
|
cannam@147
|
251 // Only valid for T = DynamicCapability. Requires `#include <capnp/dynamic.h>`.
|
cannam@147
|
252
|
cannam@147
|
253 inline Orphan<AnyPointer> disown();
|
cannam@147
|
254 // Disown without a type.
|
cannam@147
|
255
|
cannam@147
|
256 inline Reader asReader() const { return Reader(builder.asReader()); }
|
cannam@147
|
257 inline operator Reader() const { return Reader(builder.asReader()); }
|
cannam@147
|
258
|
cannam@147
|
259 private:
|
cannam@147
|
260 _::PointerBuilder builder;
|
cannam@147
|
261 friend class Orphanage;
|
cannam@147
|
262 friend class CapBuilderContext;
|
cannam@147
|
263 friend struct _::PointerHelpers<AnyPointer>;
|
cannam@147
|
264 };
|
cannam@147
|
265
|
cannam@147
|
266 #if !CAPNP_LITE
|
cannam@147
|
267 class Pipeline {
|
cannam@147
|
268 public:
|
cannam@147
|
269 typedef AnyPointer Pipelines;
|
cannam@147
|
270
|
cannam@147
|
271 inline Pipeline(decltype(nullptr)) {}
|
cannam@147
|
272 inline explicit Pipeline(kj::Own<PipelineHook>&& hook): hook(kj::mv(hook)) {}
|
cannam@147
|
273
|
cannam@147
|
274 Pipeline noop();
|
cannam@147
|
275 // Just make a copy.
|
cannam@147
|
276
|
cannam@147
|
277 Pipeline getPointerField(uint16_t pointerIndex);
|
cannam@147
|
278 // Deprecated. In the future, we should use .asAnyStruct.getPointerField.
|
cannam@147
|
279
|
cannam@147
|
280 inline AnyStruct::Pipeline asAnyStruct();
|
cannam@147
|
281
|
cannam@147
|
282 kj::Own<ClientHook> asCap();
|
cannam@147
|
283 // Expect that the result is a capability and construct a pipelined version of it now.
|
cannam@147
|
284
|
cannam@147
|
285 inline kj::Own<PipelineHook> releasePipelineHook() { return kj::mv(hook); }
|
cannam@147
|
286 // For use by RPC implementations.
|
cannam@147
|
287
|
cannam@147
|
288 template <typename T, typename = kj::EnableIf<CAPNP_KIND(FromClient<T>) == Kind::INTERFACE>>
|
cannam@147
|
289 inline operator T() { return T(asCap()); }
|
cannam@147
|
290
|
cannam@147
|
291 private:
|
cannam@147
|
292 kj::Own<PipelineHook> hook;
|
cannam@147
|
293 kj::Array<PipelineOp> ops;
|
cannam@147
|
294
|
cannam@147
|
295 inline Pipeline(kj::Own<PipelineHook>&& hook, kj::Array<PipelineOp>&& ops)
|
cannam@147
|
296 : hook(kj::mv(hook)), ops(kj::mv(ops)) {}
|
cannam@147
|
297
|
cannam@147
|
298 friend class LocalClient;
|
cannam@147
|
299 friend class PipelineHook;
|
cannam@147
|
300 friend class AnyStruct::Pipeline;
|
cannam@147
|
301 };
|
cannam@147
|
302 #endif // !CAPNP_LITE
|
cannam@147
|
303 };
|
cannam@147
|
304
|
cannam@147
|
305 template <>
|
cannam@147
|
306 class Orphan<AnyPointer> {
|
cannam@147
|
307 // An orphaned object of unknown type.
|
cannam@147
|
308
|
cannam@147
|
309 public:
|
cannam@147
|
310 Orphan() = default;
|
cannam@147
|
311 KJ_DISALLOW_COPY(Orphan);
|
cannam@147
|
312 Orphan(Orphan&&) = default;
|
cannam@147
|
313 inline Orphan(_::OrphanBuilder&& builder)
|
cannam@147
|
314 : builder(kj::mv(builder)) {}
|
cannam@147
|
315
|
cannam@147
|
316 Orphan& operator=(Orphan&&) = default;
|
cannam@147
|
317
|
cannam@147
|
318 template <typename T>
|
cannam@147
|
319 inline Orphan(Orphan<T>&& other): builder(kj::mv(other.builder)) {}
|
cannam@147
|
320 template <typename T>
|
cannam@147
|
321 inline Orphan& operator=(Orphan<T>&& other) { builder = kj::mv(other.builder); return *this; }
|
cannam@147
|
322 // Cast from typed orphan.
|
cannam@147
|
323
|
cannam@147
|
324 // It's not possible to get an AnyPointer::{Reader,Builder} directly since there is no
|
cannam@147
|
325 // underlying pointer (the pointer would normally live in the parent, but this object is
|
cannam@147
|
326 // orphaned). It is possible, however, to request typed readers/builders.
|
cannam@147
|
327
|
cannam@147
|
328 template <typename T>
|
cannam@147
|
329 inline BuilderFor<T> getAs();
|
cannam@147
|
330 template <typename T>
|
cannam@147
|
331 inline BuilderFor<T> getAs(StructSchema schema);
|
cannam@147
|
332 template <typename T>
|
cannam@147
|
333 inline BuilderFor<T> getAs(ListSchema schema);
|
cannam@147
|
334 template <typename T>
|
cannam@147
|
335 inline typename T::Client getAs(InterfaceSchema schema);
|
cannam@147
|
336 template <typename T>
|
cannam@147
|
337 inline ReaderFor<T> getAsReader() const;
|
cannam@147
|
338 template <typename T>
|
cannam@147
|
339 inline ReaderFor<T> getAsReader(StructSchema schema) const;
|
cannam@147
|
340 template <typename T>
|
cannam@147
|
341 inline ReaderFor<T> getAsReader(ListSchema schema) const;
|
cannam@147
|
342 template <typename T>
|
cannam@147
|
343 inline typename T::Client getAsReader(InterfaceSchema schema) const;
|
cannam@147
|
344
|
cannam@147
|
345 template <typename T>
|
cannam@147
|
346 inline Orphan<T> releaseAs();
|
cannam@147
|
347 template <typename T>
|
cannam@147
|
348 inline Orphan<T> releaseAs(StructSchema schema);
|
cannam@147
|
349 template <typename T>
|
cannam@147
|
350 inline Orphan<T> releaseAs(ListSchema schema);
|
cannam@147
|
351 template <typename T>
|
cannam@147
|
352 inline Orphan<T> releaseAs(InterfaceSchema schema);
|
cannam@147
|
353 // Down-cast the orphan to a specific type.
|
cannam@147
|
354
|
cannam@147
|
355 inline bool operator==(decltype(nullptr)) const { return builder == nullptr; }
|
cannam@147
|
356 inline bool operator!=(decltype(nullptr)) const { return builder != nullptr; }
|
cannam@147
|
357
|
cannam@147
|
358 private:
|
cannam@147
|
359 _::OrphanBuilder builder;
|
cannam@147
|
360
|
cannam@147
|
361 template <typename, Kind>
|
cannam@147
|
362 friend struct _::PointerHelpers;
|
cannam@147
|
363 friend class Orphanage;
|
cannam@147
|
364 template <typename U>
|
cannam@147
|
365 friend class Orphan;
|
cannam@147
|
366 friend class AnyPointer::Builder;
|
cannam@147
|
367 };
|
cannam@147
|
368
|
cannam@147
|
369 template <Kind k> struct AnyTypeFor_;
|
cannam@147
|
370 template <> struct AnyTypeFor_<Kind::STRUCT> { typedef AnyStruct Type; };
|
cannam@147
|
371 template <> struct AnyTypeFor_<Kind::LIST> { typedef AnyList Type; };
|
cannam@147
|
372
|
cannam@147
|
373 template <typename T>
|
cannam@147
|
374 using AnyTypeFor = typename AnyTypeFor_<CAPNP_KIND(T)>::Type;
|
cannam@147
|
375
|
cannam@147
|
376 template <typename T>
|
cannam@147
|
377 inline ReaderFor<AnyTypeFor<FromReader<T>>> toAny(T&& value) {
|
cannam@147
|
378 return ReaderFor<AnyTypeFor<FromReader<T>>>(
|
cannam@147
|
379 _::PointerHelpers<FromReader<T>>::getInternalReader(value));
|
cannam@147
|
380 }
|
cannam@147
|
381 template <typename T>
|
cannam@147
|
382 inline BuilderFor<AnyTypeFor<FromBuilder<T>>> toAny(T&& value) {
|
cannam@147
|
383 return BuilderFor<AnyTypeFor<FromBuilder<T>>>(
|
cannam@147
|
384 _::PointerHelpers<FromBuilder<T>>::getInternalBuilder(kj::mv(value)));
|
cannam@147
|
385 }
|
cannam@147
|
386
|
cannam@147
|
387 template <>
|
cannam@147
|
388 struct List<AnyPointer, Kind::OTHER> {
|
cannam@147
|
389 // Note: This cannot be used for a list of structs, since such lists are not encoded as pointer
|
cannam@147
|
390 // lists! Use List<AnyStruct>.
|
cannam@147
|
391
|
cannam@147
|
392 List() = delete;
|
cannam@147
|
393
|
cannam@147
|
394 class Reader {
|
cannam@147
|
395 public:
|
cannam@147
|
396 typedef List<AnyPointer> Reads;
|
cannam@147
|
397
|
cannam@147
|
398 inline Reader(): reader(ElementSize::POINTER) {}
|
cannam@147
|
399 inline explicit Reader(_::ListReader reader): reader(reader) {}
|
cannam@147
|
400
|
cannam@147
|
401 inline uint size() const { return unbound(reader.size() / ELEMENTS); }
|
cannam@147
|
402 inline AnyPointer::Reader operator[](uint index) const {
|
cannam@147
|
403 KJ_IREQUIRE(index < size());
|
cannam@147
|
404 return AnyPointer::Reader(reader.getPointerElement(bounded(index) * ELEMENTS));
|
cannam@147
|
405 }
|
cannam@147
|
406
|
cannam@147
|
407 typedef _::IndexingIterator<const Reader, typename AnyPointer::Reader> Iterator;
|
cannam@147
|
408 inline Iterator begin() const { return Iterator(this, 0); }
|
cannam@147
|
409 inline Iterator end() const { return Iterator(this, size()); }
|
cannam@147
|
410
|
cannam@147
|
411 private:
|
cannam@147
|
412 _::ListReader reader;
|
cannam@147
|
413 template <typename U, Kind K>
|
cannam@147
|
414 friend struct _::PointerHelpers;
|
cannam@147
|
415 template <typename U, Kind K>
|
cannam@147
|
416 friend struct List;
|
cannam@147
|
417 friend class Orphanage;
|
cannam@147
|
418 template <typename U, Kind K>
|
cannam@147
|
419 friend struct ToDynamic_;
|
cannam@147
|
420 };
|
cannam@147
|
421
|
cannam@147
|
422 class Builder {
|
cannam@147
|
423 public:
|
cannam@147
|
424 typedef List<AnyPointer> Builds;
|
cannam@147
|
425
|
cannam@147
|
426 Builder() = delete;
|
cannam@147
|
427 inline Builder(decltype(nullptr)): builder(ElementSize::POINTER) {}
|
cannam@147
|
428 inline explicit Builder(_::ListBuilder builder): builder(builder) {}
|
cannam@147
|
429
|
cannam@147
|
430 inline operator Reader() const { return Reader(builder.asReader()); }
|
cannam@147
|
431 inline Reader asReader() const { return Reader(builder.asReader()); }
|
cannam@147
|
432
|
cannam@147
|
433 inline uint size() const { return unbound(builder.size() / ELEMENTS); }
|
cannam@147
|
434 inline AnyPointer::Builder operator[](uint index) {
|
cannam@147
|
435 KJ_IREQUIRE(index < size());
|
cannam@147
|
436 return AnyPointer::Builder(builder.getPointerElement(bounded(index) * ELEMENTS));
|
cannam@147
|
437 }
|
cannam@147
|
438
|
cannam@147
|
439 typedef _::IndexingIterator<Builder, typename AnyPointer::Builder> Iterator;
|
cannam@147
|
440 inline Iterator begin() { return Iterator(this, 0); }
|
cannam@147
|
441 inline Iterator end() { return Iterator(this, size()); }
|
cannam@147
|
442
|
cannam@147
|
443 private:
|
cannam@147
|
444 _::ListBuilder builder;
|
cannam@147
|
445 template <typename, Kind>
|
cannam@147
|
446 friend struct _::PointerHelpers;
|
cannam@147
|
447 friend class Orphanage;
|
cannam@147
|
448 template <typename, Kind>
|
cannam@147
|
449 friend struct ToDynamic_;
|
cannam@147
|
450 };
|
cannam@147
|
451 };
|
cannam@147
|
452
|
cannam@147
|
453 class AnyStruct::Reader {
|
cannam@147
|
454 public:
|
cannam@147
|
455 typedef AnyStruct Reads;
|
cannam@147
|
456
|
cannam@147
|
457 Reader() = default;
|
cannam@147
|
458 inline Reader(_::StructReader reader): _reader(reader) {}
|
cannam@147
|
459
|
cannam@147
|
460 template <typename T, typename = kj::EnableIf<CAPNP_KIND(FromReader<T>) == Kind::STRUCT>>
|
cannam@147
|
461 inline Reader(T&& value)
|
cannam@147
|
462 : _reader(_::PointerHelpers<FromReader<T>>::getInternalReader(kj::fwd<T>(value))) {}
|
cannam@147
|
463
|
cannam@147
|
464 kj::ArrayPtr<const byte> getDataSection() {
|
cannam@147
|
465 return _reader.getDataSectionAsBlob();
|
cannam@147
|
466 }
|
cannam@147
|
467 List<AnyPointer>::Reader getPointerSection() {
|
cannam@147
|
468 return List<AnyPointer>::Reader(_reader.getPointerSectionAsList());
|
cannam@147
|
469 }
|
cannam@147
|
470
|
cannam@147
|
471 kj::Array<word> canonicalize() {
|
cannam@147
|
472 return _reader.canonicalize();
|
cannam@147
|
473 }
|
cannam@147
|
474
|
cannam@147
|
475 Equality equals(AnyStruct::Reader right);
|
cannam@147
|
476 bool operator==(AnyStruct::Reader right);
|
cannam@147
|
477 inline bool operator!=(AnyStruct::Reader right) {
|
cannam@147
|
478 return !(*this == right);
|
cannam@147
|
479 }
|
cannam@147
|
480
|
cannam@147
|
481 template <typename T>
|
cannam@147
|
482 ReaderFor<T> as() const {
|
cannam@147
|
483 // T must be a struct type.
|
cannam@147
|
484 return typename T::Reader(_reader);
|
cannam@147
|
485 }
|
cannam@147
|
486 private:
|
cannam@147
|
487 _::StructReader _reader;
|
cannam@147
|
488
|
cannam@147
|
489 template <typename, Kind>
|
cannam@147
|
490 friend struct _::PointerHelpers;
|
cannam@147
|
491 friend class Orphanage;
|
cannam@147
|
492 };
|
cannam@147
|
493
|
cannam@147
|
494 class AnyStruct::Builder {
|
cannam@147
|
495 public:
|
cannam@147
|
496 typedef AnyStruct Builds;
|
cannam@147
|
497
|
cannam@147
|
498 inline Builder(decltype(nullptr)) {}
|
cannam@147
|
499 inline Builder(_::StructBuilder builder): _builder(builder) {}
|
cannam@147
|
500
|
cannam@147
|
501 #if !_MSC_VER // TODO(msvc): MSVC ICEs on this. Try restoring when compiler improves.
|
cannam@147
|
502 template <typename T, typename = kj::EnableIf<CAPNP_KIND(FromBuilder<T>) == Kind::STRUCT>>
|
cannam@147
|
503 inline Builder(T&& value)
|
cannam@147
|
504 : _builder(_::PointerHelpers<FromBuilder<T>>::getInternalBuilder(kj::fwd<T>(value))) {}
|
cannam@147
|
505 #endif
|
cannam@147
|
506
|
cannam@147
|
507 inline kj::ArrayPtr<byte> getDataSection() {
|
cannam@147
|
508 return _builder.getDataSectionAsBlob();
|
cannam@147
|
509 }
|
cannam@147
|
510 List<AnyPointer>::Builder getPointerSection() {
|
cannam@147
|
511 return List<AnyPointer>::Builder(_builder.getPointerSectionAsList());
|
cannam@147
|
512 }
|
cannam@147
|
513
|
cannam@147
|
514 inline Equality equals(AnyStruct::Reader right) {
|
cannam@147
|
515 return asReader().equals(right);
|
cannam@147
|
516 }
|
cannam@147
|
517 inline bool operator==(AnyStruct::Reader right) {
|
cannam@147
|
518 return asReader() == right;
|
cannam@147
|
519 }
|
cannam@147
|
520 inline bool operator!=(AnyStruct::Reader right) {
|
cannam@147
|
521 return !(*this == right);
|
cannam@147
|
522 }
|
cannam@147
|
523
|
cannam@147
|
524 inline operator Reader() const { return Reader(_builder.asReader()); }
|
cannam@147
|
525 inline Reader asReader() const { return Reader(_builder.asReader()); }
|
cannam@147
|
526
|
cannam@147
|
527 template <typename T>
|
cannam@147
|
528 BuilderFor<T> as() {
|
cannam@147
|
529 // T must be a struct type.
|
cannam@147
|
530 return typename T::Builder(_builder);
|
cannam@147
|
531 }
|
cannam@147
|
532 private:
|
cannam@147
|
533 _::StructBuilder _builder;
|
cannam@147
|
534 friend class Orphanage;
|
cannam@147
|
535 friend class CapBuilderContext;
|
cannam@147
|
536 };
|
cannam@147
|
537
|
cannam@147
|
538 #if !CAPNP_LITE
|
cannam@147
|
539 class AnyStruct::Pipeline {
|
cannam@147
|
540 public:
|
cannam@147
|
541 inline Pipeline(decltype(nullptr)): typeless(nullptr) {}
|
cannam@147
|
542 inline explicit Pipeline(AnyPointer::Pipeline&& typeless)
|
cannam@147
|
543 : typeless(kj::mv(typeless)) {}
|
cannam@147
|
544
|
cannam@147
|
545 inline AnyPointer::Pipeline getPointerField(uint16_t pointerIndex) {
|
cannam@147
|
546 // Return a new Promise representing a sub-object of the result. `pointerIndex` is the index
|
cannam@147
|
547 // of the sub-object within the pointer section of the result (the result must be a struct).
|
cannam@147
|
548 //
|
cannam@147
|
549 // TODO(perf): On GCC 4.8 / Clang 3.3, use rvalue qualifiers to avoid the need for copies.
|
cannam@147
|
550 // Also make `ops` into a Vector to optimize this.
|
cannam@147
|
551 return typeless.getPointerField(pointerIndex);
|
cannam@147
|
552 }
|
cannam@147
|
553
|
cannam@147
|
554 private:
|
cannam@147
|
555 AnyPointer::Pipeline typeless;
|
cannam@147
|
556 };
|
cannam@147
|
557 #endif // !CAPNP_LITE
|
cannam@147
|
558
|
cannam@147
|
559 class List<AnyStruct, Kind::OTHER>::Reader {
|
cannam@147
|
560 public:
|
cannam@147
|
561 typedef List<AnyStruct> Reads;
|
cannam@147
|
562
|
cannam@147
|
563 inline Reader(): reader(ElementSize::INLINE_COMPOSITE) {}
|
cannam@147
|
564 inline explicit Reader(_::ListReader reader): reader(reader) {}
|
cannam@147
|
565
|
cannam@147
|
566 inline uint size() const { return unbound(reader.size() / ELEMENTS); }
|
cannam@147
|
567 inline AnyStruct::Reader operator[](uint index) const {
|
cannam@147
|
568 KJ_IREQUIRE(index < size());
|
cannam@147
|
569 return AnyStruct::Reader(reader.getStructElement(bounded(index) * ELEMENTS));
|
cannam@147
|
570 }
|
cannam@147
|
571
|
cannam@147
|
572 typedef _::IndexingIterator<const Reader, typename AnyStruct::Reader> Iterator;
|
cannam@147
|
573 inline Iterator begin() const { return Iterator(this, 0); }
|
cannam@147
|
574 inline Iterator end() const { return Iterator(this, size()); }
|
cannam@147
|
575
|
cannam@147
|
576 private:
|
cannam@147
|
577 _::ListReader reader;
|
cannam@147
|
578 template <typename U, Kind K>
|
cannam@147
|
579 friend struct _::PointerHelpers;
|
cannam@147
|
580 template <typename U, Kind K>
|
cannam@147
|
581 friend struct List;
|
cannam@147
|
582 friend class Orphanage;
|
cannam@147
|
583 template <typename U, Kind K>
|
cannam@147
|
584 friend struct ToDynamic_;
|
cannam@147
|
585 };
|
cannam@147
|
586
|
cannam@147
|
587 class List<AnyStruct, Kind::OTHER>::Builder {
|
cannam@147
|
588 public:
|
cannam@147
|
589 typedef List<AnyStruct> Builds;
|
cannam@147
|
590
|
cannam@147
|
591 Builder() = delete;
|
cannam@147
|
592 inline Builder(decltype(nullptr)): builder(ElementSize::INLINE_COMPOSITE) {}
|
cannam@147
|
593 inline explicit Builder(_::ListBuilder builder): builder(builder) {}
|
cannam@147
|
594
|
cannam@147
|
595 inline operator Reader() const { return Reader(builder.asReader()); }
|
cannam@147
|
596 inline Reader asReader() const { return Reader(builder.asReader()); }
|
cannam@147
|
597
|
cannam@147
|
598 inline uint size() const { return unbound(builder.size() / ELEMENTS); }
|
cannam@147
|
599 inline AnyStruct::Builder operator[](uint index) {
|
cannam@147
|
600 KJ_IREQUIRE(index < size());
|
cannam@147
|
601 return AnyStruct::Builder(builder.getStructElement(bounded(index) * ELEMENTS));
|
cannam@147
|
602 }
|
cannam@147
|
603
|
cannam@147
|
604 typedef _::IndexingIterator<Builder, typename AnyStruct::Builder> Iterator;
|
cannam@147
|
605 inline Iterator begin() { return Iterator(this, 0); }
|
cannam@147
|
606 inline Iterator end() { return Iterator(this, size()); }
|
cannam@147
|
607
|
cannam@147
|
608 private:
|
cannam@147
|
609 _::ListBuilder builder;
|
cannam@147
|
610 template <typename U, Kind K>
|
cannam@147
|
611 friend struct _::PointerHelpers;
|
cannam@147
|
612 friend class Orphanage;
|
cannam@147
|
613 template <typename U, Kind K>
|
cannam@147
|
614 friend struct ToDynamic_;
|
cannam@147
|
615 };
|
cannam@147
|
616
|
cannam@147
|
617 class AnyList::Reader {
|
cannam@147
|
618 public:
|
cannam@147
|
619 typedef AnyList Reads;
|
cannam@147
|
620
|
cannam@147
|
621 inline Reader(): _reader(ElementSize::VOID) {}
|
cannam@147
|
622 inline Reader(_::ListReader reader): _reader(reader) {}
|
cannam@147
|
623
|
cannam@147
|
624 #if !_MSC_VER // TODO(msvc): MSVC ICEs on this. Try restoring when compiler improves.
|
cannam@147
|
625 template <typename T, typename = kj::EnableIf<CAPNP_KIND(FromReader<T>) == Kind::LIST>>
|
cannam@147
|
626 inline Reader(T&& value)
|
cannam@147
|
627 : _reader(_::PointerHelpers<FromReader<T>>::getInternalReader(kj::fwd<T>(value))) {}
|
cannam@147
|
628 #endif
|
cannam@147
|
629
|
cannam@147
|
630 inline ElementSize getElementSize() { return _reader.getElementSize(); }
|
cannam@147
|
631 inline uint size() { return unbound(_reader.size() / ELEMENTS); }
|
cannam@147
|
632
|
cannam@147
|
633 inline kj::ArrayPtr<const byte> getRawBytes() { return _reader.asRawBytes(); }
|
cannam@147
|
634
|
cannam@147
|
635 Equality equals(AnyList::Reader right);
|
cannam@147
|
636 bool operator==(AnyList::Reader right);
|
cannam@147
|
637 inline bool operator!=(AnyList::Reader right) {
|
cannam@147
|
638 return !(*this == right);
|
cannam@147
|
639 }
|
cannam@147
|
640
|
cannam@147
|
641 template <typename T> ReaderFor<T> as() {
|
cannam@147
|
642 // T must be List<U>.
|
cannam@147
|
643 return ReaderFor<T>(_reader);
|
cannam@147
|
644 }
|
cannam@147
|
645 private:
|
cannam@147
|
646 _::ListReader _reader;
|
cannam@147
|
647
|
cannam@147
|
648 template <typename, Kind>
|
cannam@147
|
649 friend struct _::PointerHelpers;
|
cannam@147
|
650 friend class Orphanage;
|
cannam@147
|
651 };
|
cannam@147
|
652
|
cannam@147
|
653 class AnyList::Builder {
|
cannam@147
|
654 public:
|
cannam@147
|
655 typedef AnyList Builds;
|
cannam@147
|
656
|
cannam@147
|
657 inline Builder(decltype(nullptr)): _builder(ElementSize::VOID) {}
|
cannam@147
|
658 inline Builder(_::ListBuilder builder): _builder(builder) {}
|
cannam@147
|
659
|
cannam@147
|
660 #if !_MSC_VER // TODO(msvc): MSVC ICEs on this. Try restoring when compiler improves.
|
cannam@147
|
661 template <typename T, typename = kj::EnableIf<CAPNP_KIND(FromBuilder<T>) == Kind::LIST>>
|
cannam@147
|
662 inline Builder(T&& value)
|
cannam@147
|
663 : _builder(_::PointerHelpers<FromBuilder<T>>::getInternalBuilder(kj::fwd<T>(value))) {}
|
cannam@147
|
664 #endif
|
cannam@147
|
665
|
cannam@147
|
666 inline ElementSize getElementSize() { return _builder.getElementSize(); }
|
cannam@147
|
667 inline uint size() { return unbound(_builder.size() / ELEMENTS); }
|
cannam@147
|
668
|
cannam@147
|
669 Equality equals(AnyList::Reader right);
|
cannam@147
|
670 inline bool operator==(AnyList::Reader right) {
|
cannam@147
|
671 return asReader() == right;
|
cannam@147
|
672 }
|
cannam@147
|
673 inline bool operator!=(AnyList::Reader right) {
|
cannam@147
|
674 return !(*this == right);
|
cannam@147
|
675 }
|
cannam@147
|
676
|
cannam@147
|
677 template <typename T> BuilderFor<T> as() {
|
cannam@147
|
678 // T must be List<U>.
|
cannam@147
|
679 return BuilderFor<T>(_builder);
|
cannam@147
|
680 }
|
cannam@147
|
681
|
cannam@147
|
682 inline operator Reader() const { return Reader(_builder.asReader()); }
|
cannam@147
|
683 inline Reader asReader() const { return Reader(_builder.asReader()); }
|
cannam@147
|
684
|
cannam@147
|
685 private:
|
cannam@147
|
686 _::ListBuilder _builder;
|
cannam@147
|
687
|
cannam@147
|
688 friend class Orphanage;
|
cannam@147
|
689 };
|
cannam@147
|
690
|
cannam@147
|
691 // =======================================================================================
|
cannam@147
|
692 // Pipeline helpers
|
cannam@147
|
693 //
|
cannam@147
|
694 // These relate to capabilities, but we don't declare them in capability.h because generated code
|
cannam@147
|
695 // for structs needs to know about these, even in files that contain no interfaces.
|
cannam@147
|
696
|
cannam@147
|
697 #if !CAPNP_LITE
|
cannam@147
|
698
|
cannam@147
|
699 struct PipelineOp {
|
cannam@147
|
700 // Corresponds to rpc.capnp's PromisedAnswer.Op.
|
cannam@147
|
701
|
cannam@147
|
702 enum Type {
|
cannam@147
|
703 NOOP, // for convenience
|
cannam@147
|
704
|
cannam@147
|
705 GET_POINTER_FIELD
|
cannam@147
|
706
|
cannam@147
|
707 // There may be other types in the future...
|
cannam@147
|
708 };
|
cannam@147
|
709
|
cannam@147
|
710 Type type;
|
cannam@147
|
711 union {
|
cannam@147
|
712 uint16_t pointerIndex; // for GET_POINTER_FIELD
|
cannam@147
|
713 };
|
cannam@147
|
714 };
|
cannam@147
|
715
|
cannam@147
|
716 class PipelineHook {
|
cannam@147
|
717 // Represents a currently-running call, and implements pipelined requests on its result.
|
cannam@147
|
718
|
cannam@147
|
719 public:
|
cannam@147
|
720 virtual kj::Own<PipelineHook> addRef() = 0;
|
cannam@147
|
721 // Increment this object's reference count.
|
cannam@147
|
722
|
cannam@147
|
723 virtual kj::Own<ClientHook> getPipelinedCap(kj::ArrayPtr<const PipelineOp> ops) = 0;
|
cannam@147
|
724 // Extract a promised Capability from the results.
|
cannam@147
|
725
|
cannam@147
|
726 virtual kj::Own<ClientHook> getPipelinedCap(kj::Array<PipelineOp>&& ops);
|
cannam@147
|
727 // Version of getPipelinedCap() passing the array by move. May avoid a copy in some cases.
|
cannam@147
|
728 // Default implementation just calls the other version.
|
cannam@147
|
729
|
cannam@147
|
730 template <typename Pipeline, typename = FromPipeline<Pipeline>>
|
cannam@147
|
731 static inline kj::Own<PipelineHook> from(Pipeline&& pipeline);
|
cannam@147
|
732
|
cannam@147
|
733 private:
|
cannam@147
|
734 template <typename T> struct FromImpl;
|
cannam@147
|
735 };
|
cannam@147
|
736
|
cannam@147
|
737 #endif // !CAPNP_LITE
|
cannam@147
|
738
|
cannam@147
|
739 // =======================================================================================
|
cannam@147
|
740 // Inline implementation details
|
cannam@147
|
741
|
cannam@147
|
742 inline MessageSize AnyPointer::Reader::targetSize() const {
|
cannam@147
|
743 return reader.targetSize().asPublic();
|
cannam@147
|
744 }
|
cannam@147
|
745
|
cannam@147
|
746 inline PointerType AnyPointer::Reader::getPointerType() const {
|
cannam@147
|
747 return reader.getPointerType();
|
cannam@147
|
748 }
|
cannam@147
|
749
|
cannam@147
|
750 template <typename T>
|
cannam@147
|
751 inline ReaderFor<T> AnyPointer::Reader::getAs() const {
|
cannam@147
|
752 return _::PointerHelpers<T>::get(reader);
|
cannam@147
|
753 }
|
cannam@147
|
754
|
cannam@147
|
755 inline MessageSize AnyPointer::Builder::targetSize() const {
|
cannam@147
|
756 return asReader().targetSize();
|
cannam@147
|
757 }
|
cannam@147
|
758
|
cannam@147
|
759 inline PointerType AnyPointer::Builder::getPointerType() {
|
cannam@147
|
760 return builder.getPointerType();
|
cannam@147
|
761 }
|
cannam@147
|
762
|
cannam@147
|
763 inline void AnyPointer::Builder::clear() {
|
cannam@147
|
764 return builder.clear();
|
cannam@147
|
765 }
|
cannam@147
|
766
|
cannam@147
|
767 template <typename T>
|
cannam@147
|
768 inline BuilderFor<T> AnyPointer::Builder::getAs() {
|
cannam@147
|
769 return _::PointerHelpers<T>::get(builder);
|
cannam@147
|
770 }
|
cannam@147
|
771
|
cannam@147
|
772 template <typename T>
|
cannam@147
|
773 inline BuilderFor<T> AnyPointer::Builder::initAs() {
|
cannam@147
|
774 return _::PointerHelpers<T>::init(builder);
|
cannam@147
|
775 }
|
cannam@147
|
776
|
cannam@147
|
777 template <typename T>
|
cannam@147
|
778 inline BuilderFor<T> AnyPointer::Builder::initAs(uint elementCount) {
|
cannam@147
|
779 return _::PointerHelpers<T>::init(builder, elementCount);
|
cannam@147
|
780 }
|
cannam@147
|
781
|
cannam@147
|
782 inline AnyList::Builder AnyPointer::Builder::initAsAnyList(
|
cannam@147
|
783 ElementSize elementSize, uint elementCount) {
|
cannam@147
|
784 return AnyList::Builder(builder.initList(elementSize, bounded(elementCount) * ELEMENTS));
|
cannam@147
|
785 }
|
cannam@147
|
786
|
cannam@147
|
787 inline List<AnyStruct>::Builder AnyPointer::Builder::initAsListOfAnyStruct(
|
cannam@147
|
788 uint16_t dataWordCount, uint16_t pointerCount, uint elementCount) {
|
cannam@147
|
789 return List<AnyStruct>::Builder(builder.initStructList(bounded(elementCount) * ELEMENTS,
|
cannam@147
|
790 _::StructSize(bounded(dataWordCount) * WORDS,
|
cannam@147
|
791 bounded(pointerCount) * POINTERS)));
|
cannam@147
|
792 }
|
cannam@147
|
793
|
cannam@147
|
794 inline AnyStruct::Builder AnyPointer::Builder::initAsAnyStruct(
|
cannam@147
|
795 uint16_t dataWordCount, uint16_t pointerCount) {
|
cannam@147
|
796 return AnyStruct::Builder(builder.initStruct(
|
cannam@147
|
797 _::StructSize(bounded(dataWordCount) * WORDS,
|
cannam@147
|
798 bounded(pointerCount) * POINTERS)));
|
cannam@147
|
799 }
|
cannam@147
|
800
|
cannam@147
|
801 template <typename T>
|
cannam@147
|
802 inline void AnyPointer::Builder::setAs(ReaderFor<T> value) {
|
cannam@147
|
803 return _::PointerHelpers<T>::set(builder, value);
|
cannam@147
|
804 }
|
cannam@147
|
805
|
cannam@147
|
806 template <typename T>
|
cannam@147
|
807 inline void AnyPointer::Builder::setCanonicalAs(ReaderFor<T> value) {
|
cannam@147
|
808 return _::PointerHelpers<T>::setCanonical(builder, value);
|
cannam@147
|
809 }
|
cannam@147
|
810
|
cannam@147
|
811 template <typename T>
|
cannam@147
|
812 inline void AnyPointer::Builder::setAs(
|
cannam@147
|
813 std::initializer_list<ReaderFor<ListElementType<T>>> list) {
|
cannam@147
|
814 return _::PointerHelpers<T>::set(builder, list);
|
cannam@147
|
815 }
|
cannam@147
|
816
|
cannam@147
|
817 template <typename T>
|
cannam@147
|
818 inline void AnyPointer::Builder::adopt(Orphan<T>&& orphan) {
|
cannam@147
|
819 _::PointerHelpers<T>::adopt(builder, kj::mv(orphan));
|
cannam@147
|
820 }
|
cannam@147
|
821
|
cannam@147
|
822 template <typename T>
|
cannam@147
|
823 inline Orphan<T> AnyPointer::Builder::disownAs() {
|
cannam@147
|
824 return _::PointerHelpers<T>::disown(builder);
|
cannam@147
|
825 }
|
cannam@147
|
826
|
cannam@147
|
827 inline Orphan<AnyPointer> AnyPointer::Builder::disown() {
|
cannam@147
|
828 return Orphan<AnyPointer>(builder.disown());
|
cannam@147
|
829 }
|
cannam@147
|
830
|
cannam@147
|
831 template <> struct ReaderFor_ <AnyPointer, Kind::OTHER> { typedef AnyPointer::Reader Type; };
|
cannam@147
|
832 template <> struct BuilderFor_<AnyPointer, Kind::OTHER> { typedef AnyPointer::Builder Type; };
|
cannam@147
|
833 template <> struct ReaderFor_ <AnyStruct, Kind::OTHER> { typedef AnyStruct::Reader Type; };
|
cannam@147
|
834 template <> struct BuilderFor_<AnyStruct, Kind::OTHER> { typedef AnyStruct::Builder Type; };
|
cannam@147
|
835
|
cannam@147
|
836 template <>
|
cannam@147
|
837 struct Orphanage::GetInnerReader<AnyPointer, Kind::OTHER> {
|
cannam@147
|
838 static inline _::PointerReader apply(const AnyPointer::Reader& t) {
|
cannam@147
|
839 return t.reader;
|
cannam@147
|
840 }
|
cannam@147
|
841 };
|
cannam@147
|
842
|
cannam@147
|
843 template <>
|
cannam@147
|
844 struct Orphanage::GetInnerBuilder<AnyPointer, Kind::OTHER> {
|
cannam@147
|
845 static inline _::PointerBuilder apply(AnyPointer::Builder& t) {
|
cannam@147
|
846 return t.builder;
|
cannam@147
|
847 }
|
cannam@147
|
848 };
|
cannam@147
|
849
|
cannam@147
|
850 template <>
|
cannam@147
|
851 struct Orphanage::GetInnerReader<AnyStruct, Kind::OTHER> {
|
cannam@147
|
852 static inline _::StructReader apply(const AnyStruct::Reader& t) {
|
cannam@147
|
853 return t._reader;
|
cannam@147
|
854 }
|
cannam@147
|
855 };
|
cannam@147
|
856
|
cannam@147
|
857 template <>
|
cannam@147
|
858 struct Orphanage::GetInnerBuilder<AnyStruct, Kind::OTHER> {
|
cannam@147
|
859 static inline _::StructBuilder apply(AnyStruct::Builder& t) {
|
cannam@147
|
860 return t._builder;
|
cannam@147
|
861 }
|
cannam@147
|
862 };
|
cannam@147
|
863
|
cannam@147
|
864 template <>
|
cannam@147
|
865 struct Orphanage::GetInnerReader<AnyList, Kind::OTHER> {
|
cannam@147
|
866 static inline _::ListReader apply(const AnyList::Reader& t) {
|
cannam@147
|
867 return t._reader;
|
cannam@147
|
868 }
|
cannam@147
|
869 };
|
cannam@147
|
870
|
cannam@147
|
871 template <>
|
cannam@147
|
872 struct Orphanage::GetInnerBuilder<AnyList, Kind::OTHER> {
|
cannam@147
|
873 static inline _::ListBuilder apply(AnyList::Builder& t) {
|
cannam@147
|
874 return t._builder;
|
cannam@147
|
875 }
|
cannam@147
|
876 };
|
cannam@147
|
877
|
cannam@147
|
878 template <typename T>
|
cannam@147
|
879 inline BuilderFor<T> Orphan<AnyPointer>::getAs() {
|
cannam@147
|
880 return _::OrphanGetImpl<T>::apply(builder);
|
cannam@147
|
881 }
|
cannam@147
|
882 template <typename T>
|
cannam@147
|
883 inline ReaderFor<T> Orphan<AnyPointer>::getAsReader() const {
|
cannam@147
|
884 return _::OrphanGetImpl<T>::applyReader(builder);
|
cannam@147
|
885 }
|
cannam@147
|
886 template <typename T>
|
cannam@147
|
887 inline Orphan<T> Orphan<AnyPointer>::releaseAs() {
|
cannam@147
|
888 return Orphan<T>(kj::mv(builder));
|
cannam@147
|
889 }
|
cannam@147
|
890
|
cannam@147
|
891 // Using AnyPointer as the template type should work...
|
cannam@147
|
892
|
cannam@147
|
893 template <>
|
cannam@147
|
894 inline typename AnyPointer::Reader AnyPointer::Reader::getAs<AnyPointer>() const {
|
cannam@147
|
895 return *this;
|
cannam@147
|
896 }
|
cannam@147
|
897 template <>
|
cannam@147
|
898 inline typename AnyPointer::Builder AnyPointer::Builder::getAs<AnyPointer>() {
|
cannam@147
|
899 return *this;
|
cannam@147
|
900 }
|
cannam@147
|
901 template <>
|
cannam@147
|
902 inline typename AnyPointer::Builder AnyPointer::Builder::initAs<AnyPointer>() {
|
cannam@147
|
903 clear();
|
cannam@147
|
904 return *this;
|
cannam@147
|
905 }
|
cannam@147
|
906 template <>
|
cannam@147
|
907 inline void AnyPointer::Builder::setAs<AnyPointer>(AnyPointer::Reader value) {
|
cannam@147
|
908 return builder.copyFrom(value.reader);
|
cannam@147
|
909 }
|
cannam@147
|
910 template <>
|
cannam@147
|
911 inline void AnyPointer::Builder::adopt<AnyPointer>(Orphan<AnyPointer>&& orphan) {
|
cannam@147
|
912 builder.adopt(kj::mv(orphan.builder));
|
cannam@147
|
913 }
|
cannam@147
|
914 template <>
|
cannam@147
|
915 inline Orphan<AnyPointer> AnyPointer::Builder::disownAs<AnyPointer>() {
|
cannam@147
|
916 return Orphan<AnyPointer>(builder.disown());
|
cannam@147
|
917 }
|
cannam@147
|
918 template <>
|
cannam@147
|
919 inline Orphan<AnyPointer> Orphan<AnyPointer>::releaseAs() {
|
cannam@147
|
920 return kj::mv(*this);
|
cannam@147
|
921 }
|
cannam@147
|
922
|
cannam@147
|
923 namespace _ { // private
|
cannam@147
|
924
|
cannam@147
|
925 // Specialize PointerHelpers for AnyPointer.
|
cannam@147
|
926
|
cannam@147
|
927 template <>
|
cannam@147
|
928 struct PointerHelpers<AnyPointer, Kind::OTHER> {
|
cannam@147
|
929 static inline AnyPointer::Reader get(PointerReader reader,
|
cannam@147
|
930 const void* defaultValue = nullptr,
|
cannam@147
|
931 uint defaultBytes = 0) {
|
cannam@147
|
932 return AnyPointer::Reader(reader);
|
cannam@147
|
933 }
|
cannam@147
|
934 static inline AnyPointer::Builder get(PointerBuilder builder,
|
cannam@147
|
935 const void* defaultValue = nullptr,
|
cannam@147
|
936 uint defaultBytes = 0) {
|
cannam@147
|
937 return AnyPointer::Builder(builder);
|
cannam@147
|
938 }
|
cannam@147
|
939 static inline void set(PointerBuilder builder, AnyPointer::Reader value) {
|
cannam@147
|
940 AnyPointer::Builder(builder).set(value);
|
cannam@147
|
941 }
|
cannam@147
|
942 static inline void adopt(PointerBuilder builder, Orphan<AnyPointer>&& value) {
|
cannam@147
|
943 builder.adopt(kj::mv(value.builder));
|
cannam@147
|
944 }
|
cannam@147
|
945 static inline Orphan<AnyPointer> disown(PointerBuilder builder) {
|
cannam@147
|
946 return Orphan<AnyPointer>(builder.disown());
|
cannam@147
|
947 }
|
cannam@147
|
948 static inline _::PointerReader getInternalReader(const AnyPointer::Reader& reader) {
|
cannam@147
|
949 return reader.reader;
|
cannam@147
|
950 }
|
cannam@147
|
951 static inline _::PointerBuilder getInternalBuilder(AnyPointer::Builder&& builder) {
|
cannam@147
|
952 return builder.builder;
|
cannam@147
|
953 }
|
cannam@147
|
954 };
|
cannam@147
|
955
|
cannam@147
|
956 template <>
|
cannam@147
|
957 struct PointerHelpers<AnyStruct, Kind::OTHER> {
|
cannam@147
|
958 static inline AnyStruct::Reader get(
|
cannam@147
|
959 PointerReader reader, const word* defaultValue = nullptr) {
|
cannam@147
|
960 return AnyStruct::Reader(reader.getStruct(defaultValue));
|
cannam@147
|
961 }
|
cannam@147
|
962 static inline AnyStruct::Builder get(
|
cannam@147
|
963 PointerBuilder builder, const word* defaultValue = nullptr) {
|
cannam@147
|
964 // TODO(someday): Allow specifying the size somehow?
|
cannam@147
|
965 return AnyStruct::Builder(builder.getStruct(
|
cannam@147
|
966 _::StructSize(ZERO * WORDS, ZERO * POINTERS), defaultValue));
|
cannam@147
|
967 }
|
cannam@147
|
968 static inline void set(PointerBuilder builder, AnyStruct::Reader value) {
|
cannam@147
|
969 builder.setStruct(value._reader);
|
cannam@147
|
970 }
|
cannam@147
|
971 static inline AnyStruct::Builder init(
|
cannam@147
|
972 PointerBuilder builder, uint16_t dataWordCount, uint16_t pointerCount) {
|
cannam@147
|
973 return AnyStruct::Builder(builder.initStruct(
|
cannam@147
|
974 StructSize(bounded(dataWordCount) * WORDS,
|
cannam@147
|
975 bounded(pointerCount) * POINTERS)));
|
cannam@147
|
976 }
|
cannam@147
|
977
|
cannam@147
|
978 static void adopt(PointerBuilder builder, Orphan<AnyStruct>&& value) {
|
cannam@147
|
979 builder.adopt(kj::mv(value.builder));
|
cannam@147
|
980 }
|
cannam@147
|
981 static Orphan<AnyStruct> disown(PointerBuilder builder) {
|
cannam@147
|
982 return Orphan<AnyStruct>(builder.disown());
|
cannam@147
|
983 }
|
cannam@147
|
984 };
|
cannam@147
|
985
|
cannam@147
|
986 template <>
|
cannam@147
|
987 struct PointerHelpers<AnyList, Kind::OTHER> {
|
cannam@147
|
988 static inline AnyList::Reader get(
|
cannam@147
|
989 PointerReader reader, const word* defaultValue = nullptr) {
|
cannam@147
|
990 return AnyList::Reader(reader.getListAnySize(defaultValue));
|
cannam@147
|
991 }
|
cannam@147
|
992 static inline AnyList::Builder get(
|
cannam@147
|
993 PointerBuilder builder, const word* defaultValue = nullptr) {
|
cannam@147
|
994 return AnyList::Builder(builder.getListAnySize(defaultValue));
|
cannam@147
|
995 }
|
cannam@147
|
996 static inline void set(PointerBuilder builder, AnyList::Reader value) {
|
cannam@147
|
997 builder.setList(value._reader);
|
cannam@147
|
998 }
|
cannam@147
|
999 static inline AnyList::Builder init(
|
cannam@147
|
1000 PointerBuilder builder, ElementSize elementSize, uint elementCount) {
|
cannam@147
|
1001 return AnyList::Builder(builder.initList(
|
cannam@147
|
1002 elementSize, bounded(elementCount) * ELEMENTS));
|
cannam@147
|
1003 }
|
cannam@147
|
1004 static inline AnyList::Builder init(
|
cannam@147
|
1005 PointerBuilder builder, uint16_t dataWordCount, uint16_t pointerCount, uint elementCount) {
|
cannam@147
|
1006 return AnyList::Builder(builder.initStructList(
|
cannam@147
|
1007 bounded(elementCount) * ELEMENTS,
|
cannam@147
|
1008 StructSize(bounded(dataWordCount) * WORDS,
|
cannam@147
|
1009 bounded(pointerCount) * POINTERS)));
|
cannam@147
|
1010 }
|
cannam@147
|
1011
|
cannam@147
|
1012 static void adopt(PointerBuilder builder, Orphan<AnyList>&& value) {
|
cannam@147
|
1013 builder.adopt(kj::mv(value.builder));
|
cannam@147
|
1014 }
|
cannam@147
|
1015 static Orphan<AnyList> disown(PointerBuilder builder) {
|
cannam@147
|
1016 return Orphan<AnyList>(builder.disown());
|
cannam@147
|
1017 }
|
cannam@147
|
1018 };
|
cannam@147
|
1019
|
cannam@147
|
1020 template <>
|
cannam@147
|
1021 struct OrphanGetImpl<AnyStruct, Kind::OTHER> {
|
cannam@147
|
1022 static inline AnyStruct::Builder apply(_::OrphanBuilder& builder) {
|
cannam@147
|
1023 return AnyStruct::Builder(builder.asStruct(_::StructSize(ZERO * WORDS, ZERO * POINTERS)));
|
cannam@147
|
1024 }
|
cannam@147
|
1025 static inline AnyStruct::Reader applyReader(const _::OrphanBuilder& builder) {
|
cannam@147
|
1026 return AnyStruct::Reader(builder.asStructReader(_::StructSize(ZERO * WORDS, ZERO * POINTERS)));
|
cannam@147
|
1027 }
|
cannam@147
|
1028 static inline void truncateListOf(_::OrphanBuilder& builder, ElementCount size) {
|
cannam@147
|
1029 builder.truncate(size, _::StructSize(ZERO * WORDS, ZERO * POINTERS));
|
cannam@147
|
1030 }
|
cannam@147
|
1031 };
|
cannam@147
|
1032
|
cannam@147
|
1033 template <>
|
cannam@147
|
1034 struct OrphanGetImpl<AnyList, Kind::OTHER> {
|
cannam@147
|
1035 static inline AnyList::Builder apply(_::OrphanBuilder& builder) {
|
cannam@147
|
1036 return AnyList::Builder(builder.asListAnySize());
|
cannam@147
|
1037 }
|
cannam@147
|
1038 static inline AnyList::Reader applyReader(const _::OrphanBuilder& builder) {
|
cannam@147
|
1039 return AnyList::Reader(builder.asListReaderAnySize());
|
cannam@147
|
1040 }
|
cannam@147
|
1041 static inline void truncateListOf(_::OrphanBuilder& builder, ElementCount size) {
|
cannam@147
|
1042 builder.truncate(size, ElementSize::POINTER);
|
cannam@147
|
1043 }
|
cannam@147
|
1044 };
|
cannam@147
|
1045
|
cannam@147
|
1046 } // namespace _ (private)
|
cannam@147
|
1047
|
cannam@147
|
1048 #if !CAPNP_LITE
|
cannam@147
|
1049
|
cannam@147
|
1050 template <typename T>
|
cannam@147
|
1051 struct PipelineHook::FromImpl {
|
cannam@147
|
1052 static inline kj::Own<PipelineHook> apply(typename T::Pipeline&& pipeline) {
|
cannam@147
|
1053 return from(kj::mv(pipeline._typeless));
|
cannam@147
|
1054 }
|
cannam@147
|
1055 };
|
cannam@147
|
1056
|
cannam@147
|
1057 template <>
|
cannam@147
|
1058 struct PipelineHook::FromImpl<AnyPointer> {
|
cannam@147
|
1059 static inline kj::Own<PipelineHook> apply(AnyPointer::Pipeline&& pipeline) {
|
cannam@147
|
1060 return kj::mv(pipeline.hook);
|
cannam@147
|
1061 }
|
cannam@147
|
1062 };
|
cannam@147
|
1063
|
cannam@147
|
1064 template <typename Pipeline, typename T>
|
cannam@147
|
1065 inline kj::Own<PipelineHook> PipelineHook::from(Pipeline&& pipeline) {
|
cannam@147
|
1066 return FromImpl<T>::apply(kj::fwd<Pipeline>(pipeline));
|
cannam@147
|
1067 }
|
cannam@147
|
1068
|
cannam@147
|
1069 #endif // !CAPNP_LITE
|
cannam@147
|
1070
|
cannam@147
|
1071 } // namespace capnp
|
cannam@147
|
1072
|
cannam@147
|
1073 #endif // CAPNP_ANY_H_
|