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