Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(197)

Side by Side Diff: mojo/dart/packages/mojo_services/lib/mojo/udp_socket.mojom.dart

Issue 1449203002: Check in generated Dart bindings and add presubmit script (Closed) Base URL: git@github.com:domokit/mojo.git@master
Patch Set: Created 5 years, 1 month ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
(Empty)
1 // Copyright 2014 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file.
4
5 library udp_socket_mojom;
6
7 import 'dart:async';
8
9 import 'package:mojo/bindings.dart' as bindings;
10 import 'package:mojo/core.dart' as core;
11 import 'package:mojo/mojo/network_error.mojom.dart' as network_error_mojom;
12 import 'package:mojo_services/mojo/net_address.mojom.dart' as net_address_mojom;
13
14
15
16 class UdpSocketAllowAddressReuseParams extends bindings.Struct {
17 static const List<bindings.StructDataHeader> kVersions = const [
18 const bindings.StructDataHeader(8, 0)
19 ];
20
21 UdpSocketAllowAddressReuseParams() : super(kVersions.last.size);
22
23 static UdpSocketAllowAddressReuseParams deserialize(bindings.Message message) {
24 var decoder = new bindings.Decoder(message);
25 var result = decode(decoder);
26 if (decoder.excessHandles != null) {
27 decoder.excessHandles.forEach((h) => h.close());
28 }
29 return result;
30 }
31
32 static UdpSocketAllowAddressReuseParams decode(bindings.Decoder decoder0) {
33 if (decoder0 == null) {
34 return null;
35 }
36 UdpSocketAllowAddressReuseParams result = new UdpSocketAllowAddressReusePara ms();
37
38 var mainDataHeader = decoder0.decodeStructDataHeader();
39 if (mainDataHeader.version <= kVersions.last.version) {
40 // Scan in reverse order to optimize for more recent versions.
41 for (int i = kVersions.length - 1; i >= 0; --i) {
42 if (mainDataHeader.version >= kVersions[i].version) {
43 if (mainDataHeader.size == kVersions[i].size) {
44 // Found a match.
45 break;
46 }
47 throw new bindings.MojoCodecError(
48 'Header size doesn\'t correspond to known version size.');
49 }
50 }
51 } else if (mainDataHeader.size < kVersions.last.size) {
52 throw new bindings.MojoCodecError(
53 'Message newer than the last known version cannot be shorter than '
54 'required by the last known version.');
55 }
56 return result;
57 }
58
59 void encode(bindings.Encoder encoder) {
60 encoder.getStructEncoderAtOffset(kVersions.last);
61 }
62
63 String toString() {
64 return "UdpSocketAllowAddressReuseParams("")";
65 }
66
67 Map toJson() {
68 Map map = new Map();
69 return map;
70 }
71 }
72
73
74 class UdpSocketAllowAddressReuseResponseParams extends bindings.Struct {
75 static const List<bindings.StructDataHeader> kVersions = const [
76 const bindings.StructDataHeader(16, 0)
77 ];
78 network_error_mojom.NetworkError result = null;
79
80 UdpSocketAllowAddressReuseResponseParams() : super(kVersions.last.size);
81
82 static UdpSocketAllowAddressReuseResponseParams deserialize(bindings.Message m essage) {
83 var decoder = new bindings.Decoder(message);
84 var result = decode(decoder);
85 if (decoder.excessHandles != null) {
86 decoder.excessHandles.forEach((h) => h.close());
87 }
88 return result;
89 }
90
91 static UdpSocketAllowAddressReuseResponseParams decode(bindings.Decoder decode r0) {
92 if (decoder0 == null) {
93 return null;
94 }
95 UdpSocketAllowAddressReuseResponseParams result = new UdpSocketAllowAddressR euseResponseParams();
96
97 var mainDataHeader = decoder0.decodeStructDataHeader();
98 if (mainDataHeader.version <= kVersions.last.version) {
99 // Scan in reverse order to optimize for more recent versions.
100 for (int i = kVersions.length - 1; i >= 0; --i) {
101 if (mainDataHeader.version >= kVersions[i].version) {
102 if (mainDataHeader.size == kVersions[i].size) {
103 // Found a match.
104 break;
105 }
106 throw new bindings.MojoCodecError(
107 'Header size doesn\'t correspond to known version size.');
108 }
109 }
110 } else if (mainDataHeader.size < kVersions.last.size) {
111 throw new bindings.MojoCodecError(
112 'Message newer than the last known version cannot be shorter than '
113 'required by the last known version.');
114 }
115 if (mainDataHeader.version >= 0) {
116
117 var decoder1 = decoder0.decodePointer(8, false);
118 result.result = network_error_mojom.NetworkError.decode(decoder1);
119 }
120 return result;
121 }
122
123 void encode(bindings.Encoder encoder) {
124 var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last);
125
126 encoder0.encodeStruct(result, 8, false);
127 }
128
129 String toString() {
130 return "UdpSocketAllowAddressReuseResponseParams("
131 "result: $result" ")";
132 }
133
134 Map toJson() {
135 Map map = new Map();
136 map["result"] = result;
137 return map;
138 }
139 }
140
141
142 class UdpSocketBindParams extends bindings.Struct {
143 static const List<bindings.StructDataHeader> kVersions = const [
144 const bindings.StructDataHeader(16, 0)
145 ];
146 net_address_mojom.NetAddress addr = null;
147
148 UdpSocketBindParams() : super(kVersions.last.size);
149
150 static UdpSocketBindParams deserialize(bindings.Message message) {
151 var decoder = new bindings.Decoder(message);
152 var result = decode(decoder);
153 if (decoder.excessHandles != null) {
154 decoder.excessHandles.forEach((h) => h.close());
155 }
156 return result;
157 }
158
159 static UdpSocketBindParams decode(bindings.Decoder decoder0) {
160 if (decoder0 == null) {
161 return null;
162 }
163 UdpSocketBindParams result = new UdpSocketBindParams();
164
165 var mainDataHeader = decoder0.decodeStructDataHeader();
166 if (mainDataHeader.version <= kVersions.last.version) {
167 // Scan in reverse order to optimize for more recent versions.
168 for (int i = kVersions.length - 1; i >= 0; --i) {
169 if (mainDataHeader.version >= kVersions[i].version) {
170 if (mainDataHeader.size == kVersions[i].size) {
171 // Found a match.
172 break;
173 }
174 throw new bindings.MojoCodecError(
175 'Header size doesn\'t correspond to known version size.');
176 }
177 }
178 } else if (mainDataHeader.size < kVersions.last.size) {
179 throw new bindings.MojoCodecError(
180 'Message newer than the last known version cannot be shorter than '
181 'required by the last known version.');
182 }
183 if (mainDataHeader.version >= 0) {
184
185 var decoder1 = decoder0.decodePointer(8, false);
186 result.addr = net_address_mojom.NetAddress.decode(decoder1);
187 }
188 return result;
189 }
190
191 void encode(bindings.Encoder encoder) {
192 var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last);
193
194 encoder0.encodeStruct(addr, 8, false);
195 }
196
197 String toString() {
198 return "UdpSocketBindParams("
199 "addr: $addr" ")";
200 }
201
202 Map toJson() {
203 Map map = new Map();
204 map["addr"] = addr;
205 return map;
206 }
207 }
208
209
210 class UdpSocketBindResponseParams extends bindings.Struct {
211 static const List<bindings.StructDataHeader> kVersions = const [
212 const bindings.StructDataHeader(32, 0)
213 ];
214 network_error_mojom.NetworkError result = null;
215 net_address_mojom.NetAddress boundAddr = null;
216 Object receiver = null;
217
218 UdpSocketBindResponseParams() : super(kVersions.last.size);
219
220 static UdpSocketBindResponseParams deserialize(bindings.Message message) {
221 var decoder = new bindings.Decoder(message);
222 var result = decode(decoder);
223 if (decoder.excessHandles != null) {
224 decoder.excessHandles.forEach((h) => h.close());
225 }
226 return result;
227 }
228
229 static UdpSocketBindResponseParams decode(bindings.Decoder decoder0) {
230 if (decoder0 == null) {
231 return null;
232 }
233 UdpSocketBindResponseParams result = new UdpSocketBindResponseParams();
234
235 var mainDataHeader = decoder0.decodeStructDataHeader();
236 if (mainDataHeader.version <= kVersions.last.version) {
237 // Scan in reverse order to optimize for more recent versions.
238 for (int i = kVersions.length - 1; i >= 0; --i) {
239 if (mainDataHeader.version >= kVersions[i].version) {
240 if (mainDataHeader.size == kVersions[i].size) {
241 // Found a match.
242 break;
243 }
244 throw new bindings.MojoCodecError(
245 'Header size doesn\'t correspond to known version size.');
246 }
247 }
248 } else if (mainDataHeader.size < kVersions.last.size) {
249 throw new bindings.MojoCodecError(
250 'Message newer than the last known version cannot be shorter than '
251 'required by the last known version.');
252 }
253 if (mainDataHeader.version >= 0) {
254
255 var decoder1 = decoder0.decodePointer(8, false);
256 result.result = network_error_mojom.NetworkError.decode(decoder1);
257 }
258 if (mainDataHeader.version >= 0) {
259
260 var decoder1 = decoder0.decodePointer(16, true);
261 result.boundAddr = net_address_mojom.NetAddress.decode(decoder1);
262 }
263 if (mainDataHeader.version >= 0) {
264
265 result.receiver = decoder0.decodeInterfaceRequest(24, true, UdpSocketRecei verStub.newFromEndpoint);
266 }
267 return result;
268 }
269
270 void encode(bindings.Encoder encoder) {
271 var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last);
272
273 encoder0.encodeStruct(result, 8, false);
274
275 encoder0.encodeStruct(boundAddr, 16, true);
276
277 encoder0.encodeInterfaceRequest(receiver, 24, true);
278 }
279
280 String toString() {
281 return "UdpSocketBindResponseParams("
282 "result: $result" ", "
283 "boundAddr: $boundAddr" ", "
284 "receiver: $receiver" ")";
285 }
286
287 Map toJson() {
288 throw new bindings.MojoCodecError(
289 'Object containing handles cannot be encoded to JSON.');
290 }
291 }
292
293
294 class UdpSocketConnectParams extends bindings.Struct {
295 static const List<bindings.StructDataHeader> kVersions = const [
296 const bindings.StructDataHeader(16, 0)
297 ];
298 net_address_mojom.NetAddress remoteAddr = null;
299
300 UdpSocketConnectParams() : super(kVersions.last.size);
301
302 static UdpSocketConnectParams deserialize(bindings.Message message) {
303 var decoder = new bindings.Decoder(message);
304 var result = decode(decoder);
305 if (decoder.excessHandles != null) {
306 decoder.excessHandles.forEach((h) => h.close());
307 }
308 return result;
309 }
310
311 static UdpSocketConnectParams decode(bindings.Decoder decoder0) {
312 if (decoder0 == null) {
313 return null;
314 }
315 UdpSocketConnectParams result = new UdpSocketConnectParams();
316
317 var mainDataHeader = decoder0.decodeStructDataHeader();
318 if (mainDataHeader.version <= kVersions.last.version) {
319 // Scan in reverse order to optimize for more recent versions.
320 for (int i = kVersions.length - 1; i >= 0; --i) {
321 if (mainDataHeader.version >= kVersions[i].version) {
322 if (mainDataHeader.size == kVersions[i].size) {
323 // Found a match.
324 break;
325 }
326 throw new bindings.MojoCodecError(
327 'Header size doesn\'t correspond to known version size.');
328 }
329 }
330 } else if (mainDataHeader.size < kVersions.last.size) {
331 throw new bindings.MojoCodecError(
332 'Message newer than the last known version cannot be shorter than '
333 'required by the last known version.');
334 }
335 if (mainDataHeader.version >= 0) {
336
337 var decoder1 = decoder0.decodePointer(8, false);
338 result.remoteAddr = net_address_mojom.NetAddress.decode(decoder1);
339 }
340 return result;
341 }
342
343 void encode(bindings.Encoder encoder) {
344 var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last);
345
346 encoder0.encodeStruct(remoteAddr, 8, false);
347 }
348
349 String toString() {
350 return "UdpSocketConnectParams("
351 "remoteAddr: $remoteAddr" ")";
352 }
353
354 Map toJson() {
355 Map map = new Map();
356 map["remoteAddr"] = remoteAddr;
357 return map;
358 }
359 }
360
361
362 class UdpSocketConnectResponseParams extends bindings.Struct {
363 static const List<bindings.StructDataHeader> kVersions = const [
364 const bindings.StructDataHeader(32, 0)
365 ];
366 network_error_mojom.NetworkError result = null;
367 net_address_mojom.NetAddress localAddr = null;
368 Object receiver = null;
369
370 UdpSocketConnectResponseParams() : super(kVersions.last.size);
371
372 static UdpSocketConnectResponseParams deserialize(bindings.Message message) {
373 var decoder = new bindings.Decoder(message);
374 var result = decode(decoder);
375 if (decoder.excessHandles != null) {
376 decoder.excessHandles.forEach((h) => h.close());
377 }
378 return result;
379 }
380
381 static UdpSocketConnectResponseParams decode(bindings.Decoder decoder0) {
382 if (decoder0 == null) {
383 return null;
384 }
385 UdpSocketConnectResponseParams result = new UdpSocketConnectResponseParams() ;
386
387 var mainDataHeader = decoder0.decodeStructDataHeader();
388 if (mainDataHeader.version <= kVersions.last.version) {
389 // Scan in reverse order to optimize for more recent versions.
390 for (int i = kVersions.length - 1; i >= 0; --i) {
391 if (mainDataHeader.version >= kVersions[i].version) {
392 if (mainDataHeader.size == kVersions[i].size) {
393 // Found a match.
394 break;
395 }
396 throw new bindings.MojoCodecError(
397 'Header size doesn\'t correspond to known version size.');
398 }
399 }
400 } else if (mainDataHeader.size < kVersions.last.size) {
401 throw new bindings.MojoCodecError(
402 'Message newer than the last known version cannot be shorter than '
403 'required by the last known version.');
404 }
405 if (mainDataHeader.version >= 0) {
406
407 var decoder1 = decoder0.decodePointer(8, false);
408 result.result = network_error_mojom.NetworkError.decode(decoder1);
409 }
410 if (mainDataHeader.version >= 0) {
411
412 var decoder1 = decoder0.decodePointer(16, true);
413 result.localAddr = net_address_mojom.NetAddress.decode(decoder1);
414 }
415 if (mainDataHeader.version >= 0) {
416
417 result.receiver = decoder0.decodeInterfaceRequest(24, true, UdpSocketRecei verStub.newFromEndpoint);
418 }
419 return result;
420 }
421
422 void encode(bindings.Encoder encoder) {
423 var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last);
424
425 encoder0.encodeStruct(result, 8, false);
426
427 encoder0.encodeStruct(localAddr, 16, true);
428
429 encoder0.encodeInterfaceRequest(receiver, 24, true);
430 }
431
432 String toString() {
433 return "UdpSocketConnectResponseParams("
434 "result: $result" ", "
435 "localAddr: $localAddr" ", "
436 "receiver: $receiver" ")";
437 }
438
439 Map toJson() {
440 throw new bindings.MojoCodecError(
441 'Object containing handles cannot be encoded to JSON.');
442 }
443 }
444
445
446 class UdpSocketSetSendBufferSizeParams extends bindings.Struct {
447 static const List<bindings.StructDataHeader> kVersions = const [
448 const bindings.StructDataHeader(16, 0)
449 ];
450 int size = 0;
451
452 UdpSocketSetSendBufferSizeParams() : super(kVersions.last.size);
453
454 static UdpSocketSetSendBufferSizeParams deserialize(bindings.Message message) {
455 var decoder = new bindings.Decoder(message);
456 var result = decode(decoder);
457 if (decoder.excessHandles != null) {
458 decoder.excessHandles.forEach((h) => h.close());
459 }
460 return result;
461 }
462
463 static UdpSocketSetSendBufferSizeParams decode(bindings.Decoder decoder0) {
464 if (decoder0 == null) {
465 return null;
466 }
467 UdpSocketSetSendBufferSizeParams result = new UdpSocketSetSendBufferSizePara ms();
468
469 var mainDataHeader = decoder0.decodeStructDataHeader();
470 if (mainDataHeader.version <= kVersions.last.version) {
471 // Scan in reverse order to optimize for more recent versions.
472 for (int i = kVersions.length - 1; i >= 0; --i) {
473 if (mainDataHeader.version >= kVersions[i].version) {
474 if (mainDataHeader.size == kVersions[i].size) {
475 // Found a match.
476 break;
477 }
478 throw new bindings.MojoCodecError(
479 'Header size doesn\'t correspond to known version size.');
480 }
481 }
482 } else if (mainDataHeader.size < kVersions.last.size) {
483 throw new bindings.MojoCodecError(
484 'Message newer than the last known version cannot be shorter than '
485 'required by the last known version.');
486 }
487 if (mainDataHeader.version >= 0) {
488
489 result.size = decoder0.decodeUint32(8);
490 }
491 return result;
492 }
493
494 void encode(bindings.Encoder encoder) {
495 var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last);
496
497 encoder0.encodeUint32(size, 8);
498 }
499
500 String toString() {
501 return "UdpSocketSetSendBufferSizeParams("
502 "size: $size" ")";
503 }
504
505 Map toJson() {
506 Map map = new Map();
507 map["size"] = size;
508 return map;
509 }
510 }
511
512
513 class UdpSocketSetSendBufferSizeResponseParams extends bindings.Struct {
514 static const List<bindings.StructDataHeader> kVersions = const [
515 const bindings.StructDataHeader(16, 0)
516 ];
517 network_error_mojom.NetworkError result = null;
518
519 UdpSocketSetSendBufferSizeResponseParams() : super(kVersions.last.size);
520
521 static UdpSocketSetSendBufferSizeResponseParams deserialize(bindings.Message m essage) {
522 var decoder = new bindings.Decoder(message);
523 var result = decode(decoder);
524 if (decoder.excessHandles != null) {
525 decoder.excessHandles.forEach((h) => h.close());
526 }
527 return result;
528 }
529
530 static UdpSocketSetSendBufferSizeResponseParams decode(bindings.Decoder decode r0) {
531 if (decoder0 == null) {
532 return null;
533 }
534 UdpSocketSetSendBufferSizeResponseParams result = new UdpSocketSetSendBuffer SizeResponseParams();
535
536 var mainDataHeader = decoder0.decodeStructDataHeader();
537 if (mainDataHeader.version <= kVersions.last.version) {
538 // Scan in reverse order to optimize for more recent versions.
539 for (int i = kVersions.length - 1; i >= 0; --i) {
540 if (mainDataHeader.version >= kVersions[i].version) {
541 if (mainDataHeader.size == kVersions[i].size) {
542 // Found a match.
543 break;
544 }
545 throw new bindings.MojoCodecError(
546 'Header size doesn\'t correspond to known version size.');
547 }
548 }
549 } else if (mainDataHeader.size < kVersions.last.size) {
550 throw new bindings.MojoCodecError(
551 'Message newer than the last known version cannot be shorter than '
552 'required by the last known version.');
553 }
554 if (mainDataHeader.version >= 0) {
555
556 var decoder1 = decoder0.decodePointer(8, false);
557 result.result = network_error_mojom.NetworkError.decode(decoder1);
558 }
559 return result;
560 }
561
562 void encode(bindings.Encoder encoder) {
563 var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last);
564
565 encoder0.encodeStruct(result, 8, false);
566 }
567
568 String toString() {
569 return "UdpSocketSetSendBufferSizeResponseParams("
570 "result: $result" ")";
571 }
572
573 Map toJson() {
574 Map map = new Map();
575 map["result"] = result;
576 return map;
577 }
578 }
579
580
581 class UdpSocketSetReceiveBufferSizeParams extends bindings.Struct {
582 static const List<bindings.StructDataHeader> kVersions = const [
583 const bindings.StructDataHeader(16, 0)
584 ];
585 int size = 0;
586
587 UdpSocketSetReceiveBufferSizeParams() : super(kVersions.last.size);
588
589 static UdpSocketSetReceiveBufferSizeParams deserialize(bindings.Message messag e) {
590 var decoder = new bindings.Decoder(message);
591 var result = decode(decoder);
592 if (decoder.excessHandles != null) {
593 decoder.excessHandles.forEach((h) => h.close());
594 }
595 return result;
596 }
597
598 static UdpSocketSetReceiveBufferSizeParams decode(bindings.Decoder decoder0) {
599 if (decoder0 == null) {
600 return null;
601 }
602 UdpSocketSetReceiveBufferSizeParams result = new UdpSocketSetReceiveBufferSi zeParams();
603
604 var mainDataHeader = decoder0.decodeStructDataHeader();
605 if (mainDataHeader.version <= kVersions.last.version) {
606 // Scan in reverse order to optimize for more recent versions.
607 for (int i = kVersions.length - 1; i >= 0; --i) {
608 if (mainDataHeader.version >= kVersions[i].version) {
609 if (mainDataHeader.size == kVersions[i].size) {
610 // Found a match.
611 break;
612 }
613 throw new bindings.MojoCodecError(
614 'Header size doesn\'t correspond to known version size.');
615 }
616 }
617 } else if (mainDataHeader.size < kVersions.last.size) {
618 throw new bindings.MojoCodecError(
619 'Message newer than the last known version cannot be shorter than '
620 'required by the last known version.');
621 }
622 if (mainDataHeader.version >= 0) {
623
624 result.size = decoder0.decodeUint32(8);
625 }
626 return result;
627 }
628
629 void encode(bindings.Encoder encoder) {
630 var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last);
631
632 encoder0.encodeUint32(size, 8);
633 }
634
635 String toString() {
636 return "UdpSocketSetReceiveBufferSizeParams("
637 "size: $size" ")";
638 }
639
640 Map toJson() {
641 Map map = new Map();
642 map["size"] = size;
643 return map;
644 }
645 }
646
647
648 class UdpSocketSetReceiveBufferSizeResponseParams extends bindings.Struct {
649 static const List<bindings.StructDataHeader> kVersions = const [
650 const bindings.StructDataHeader(16, 0)
651 ];
652 network_error_mojom.NetworkError result = null;
653
654 UdpSocketSetReceiveBufferSizeResponseParams() : super(kVersions.last.size);
655
656 static UdpSocketSetReceiveBufferSizeResponseParams deserialize(bindings.Messag e message) {
657 var decoder = new bindings.Decoder(message);
658 var result = decode(decoder);
659 if (decoder.excessHandles != null) {
660 decoder.excessHandles.forEach((h) => h.close());
661 }
662 return result;
663 }
664
665 static UdpSocketSetReceiveBufferSizeResponseParams decode(bindings.Decoder dec oder0) {
666 if (decoder0 == null) {
667 return null;
668 }
669 UdpSocketSetReceiveBufferSizeResponseParams result = new UdpSocketSetReceive BufferSizeResponseParams();
670
671 var mainDataHeader = decoder0.decodeStructDataHeader();
672 if (mainDataHeader.version <= kVersions.last.version) {
673 // Scan in reverse order to optimize for more recent versions.
674 for (int i = kVersions.length - 1; i >= 0; --i) {
675 if (mainDataHeader.version >= kVersions[i].version) {
676 if (mainDataHeader.size == kVersions[i].size) {
677 // Found a match.
678 break;
679 }
680 throw new bindings.MojoCodecError(
681 'Header size doesn\'t correspond to known version size.');
682 }
683 }
684 } else if (mainDataHeader.size < kVersions.last.size) {
685 throw new bindings.MojoCodecError(
686 'Message newer than the last known version cannot be shorter than '
687 'required by the last known version.');
688 }
689 if (mainDataHeader.version >= 0) {
690
691 var decoder1 = decoder0.decodePointer(8, false);
692 result.result = network_error_mojom.NetworkError.decode(decoder1);
693 }
694 return result;
695 }
696
697 void encode(bindings.Encoder encoder) {
698 var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last);
699
700 encoder0.encodeStruct(result, 8, false);
701 }
702
703 String toString() {
704 return "UdpSocketSetReceiveBufferSizeResponseParams("
705 "result: $result" ")";
706 }
707
708 Map toJson() {
709 Map map = new Map();
710 map["result"] = result;
711 return map;
712 }
713 }
714
715
716 class UdpSocketNegotiateMaxPendingSendRequestsParams extends bindings.Struct {
717 static const List<bindings.StructDataHeader> kVersions = const [
718 const bindings.StructDataHeader(16, 0)
719 ];
720 int requestedSize = 0;
721
722 UdpSocketNegotiateMaxPendingSendRequestsParams() : super(kVersions.last.size);
723
724 static UdpSocketNegotiateMaxPendingSendRequestsParams deserialize(bindings.Mes sage message) {
725 var decoder = new bindings.Decoder(message);
726 var result = decode(decoder);
727 if (decoder.excessHandles != null) {
728 decoder.excessHandles.forEach((h) => h.close());
729 }
730 return result;
731 }
732
733 static UdpSocketNegotiateMaxPendingSendRequestsParams decode(bindings.Decoder decoder0) {
734 if (decoder0 == null) {
735 return null;
736 }
737 UdpSocketNegotiateMaxPendingSendRequestsParams result = new UdpSocketNegotia teMaxPendingSendRequestsParams();
738
739 var mainDataHeader = decoder0.decodeStructDataHeader();
740 if (mainDataHeader.version <= kVersions.last.version) {
741 // Scan in reverse order to optimize for more recent versions.
742 for (int i = kVersions.length - 1; i >= 0; --i) {
743 if (mainDataHeader.version >= kVersions[i].version) {
744 if (mainDataHeader.size == kVersions[i].size) {
745 // Found a match.
746 break;
747 }
748 throw new bindings.MojoCodecError(
749 'Header size doesn\'t correspond to known version size.');
750 }
751 }
752 } else if (mainDataHeader.size < kVersions.last.size) {
753 throw new bindings.MojoCodecError(
754 'Message newer than the last known version cannot be shorter than '
755 'required by the last known version.');
756 }
757 if (mainDataHeader.version >= 0) {
758
759 result.requestedSize = decoder0.decodeUint32(8);
760 }
761 return result;
762 }
763
764 void encode(bindings.Encoder encoder) {
765 var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last);
766
767 encoder0.encodeUint32(requestedSize, 8);
768 }
769
770 String toString() {
771 return "UdpSocketNegotiateMaxPendingSendRequestsParams("
772 "requestedSize: $requestedSize" ")";
773 }
774
775 Map toJson() {
776 Map map = new Map();
777 map["requestedSize"] = requestedSize;
778 return map;
779 }
780 }
781
782
783 class UdpSocketNegotiateMaxPendingSendRequestsResponseParams extends bindings.St ruct {
784 static const List<bindings.StructDataHeader> kVersions = const [
785 const bindings.StructDataHeader(16, 0)
786 ];
787 int actualSize = 0;
788
789 UdpSocketNegotiateMaxPendingSendRequestsResponseParams() : super(kVersions.las t.size);
790
791 static UdpSocketNegotiateMaxPendingSendRequestsResponseParams deserialize(bind ings.Message message) {
792 var decoder = new bindings.Decoder(message);
793 var result = decode(decoder);
794 if (decoder.excessHandles != null) {
795 decoder.excessHandles.forEach((h) => h.close());
796 }
797 return result;
798 }
799
800 static UdpSocketNegotiateMaxPendingSendRequestsResponseParams decode(bindings. Decoder decoder0) {
801 if (decoder0 == null) {
802 return null;
803 }
804 UdpSocketNegotiateMaxPendingSendRequestsResponseParams result = new UdpSocke tNegotiateMaxPendingSendRequestsResponseParams();
805
806 var mainDataHeader = decoder0.decodeStructDataHeader();
807 if (mainDataHeader.version <= kVersions.last.version) {
808 // Scan in reverse order to optimize for more recent versions.
809 for (int i = kVersions.length - 1; i >= 0; --i) {
810 if (mainDataHeader.version >= kVersions[i].version) {
811 if (mainDataHeader.size == kVersions[i].size) {
812 // Found a match.
813 break;
814 }
815 throw new bindings.MojoCodecError(
816 'Header size doesn\'t correspond to known version size.');
817 }
818 }
819 } else if (mainDataHeader.size < kVersions.last.size) {
820 throw new bindings.MojoCodecError(
821 'Message newer than the last known version cannot be shorter than '
822 'required by the last known version.');
823 }
824 if (mainDataHeader.version >= 0) {
825
826 result.actualSize = decoder0.decodeUint32(8);
827 }
828 return result;
829 }
830
831 void encode(bindings.Encoder encoder) {
832 var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last);
833
834 encoder0.encodeUint32(actualSize, 8);
835 }
836
837 String toString() {
838 return "UdpSocketNegotiateMaxPendingSendRequestsResponseParams("
839 "actualSize: $actualSize" ")";
840 }
841
842 Map toJson() {
843 Map map = new Map();
844 map["actualSize"] = actualSize;
845 return map;
846 }
847 }
848
849
850 class UdpSocketReceiveMoreParams extends bindings.Struct {
851 static const List<bindings.StructDataHeader> kVersions = const [
852 const bindings.StructDataHeader(16, 0)
853 ];
854 int datagramNumber = 0;
855
856 UdpSocketReceiveMoreParams() : super(kVersions.last.size);
857
858 static UdpSocketReceiveMoreParams deserialize(bindings.Message message) {
859 var decoder = new bindings.Decoder(message);
860 var result = decode(decoder);
861 if (decoder.excessHandles != null) {
862 decoder.excessHandles.forEach((h) => h.close());
863 }
864 return result;
865 }
866
867 static UdpSocketReceiveMoreParams decode(bindings.Decoder decoder0) {
868 if (decoder0 == null) {
869 return null;
870 }
871 UdpSocketReceiveMoreParams result = new UdpSocketReceiveMoreParams();
872
873 var mainDataHeader = decoder0.decodeStructDataHeader();
874 if (mainDataHeader.version <= kVersions.last.version) {
875 // Scan in reverse order to optimize for more recent versions.
876 for (int i = kVersions.length - 1; i >= 0; --i) {
877 if (mainDataHeader.version >= kVersions[i].version) {
878 if (mainDataHeader.size == kVersions[i].size) {
879 // Found a match.
880 break;
881 }
882 throw new bindings.MojoCodecError(
883 'Header size doesn\'t correspond to known version size.');
884 }
885 }
886 } else if (mainDataHeader.size < kVersions.last.size) {
887 throw new bindings.MojoCodecError(
888 'Message newer than the last known version cannot be shorter than '
889 'required by the last known version.');
890 }
891 if (mainDataHeader.version >= 0) {
892
893 result.datagramNumber = decoder0.decodeUint32(8);
894 }
895 return result;
896 }
897
898 void encode(bindings.Encoder encoder) {
899 var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last);
900
901 encoder0.encodeUint32(datagramNumber, 8);
902 }
903
904 String toString() {
905 return "UdpSocketReceiveMoreParams("
906 "datagramNumber: $datagramNumber" ")";
907 }
908
909 Map toJson() {
910 Map map = new Map();
911 map["datagramNumber"] = datagramNumber;
912 return map;
913 }
914 }
915
916
917 class UdpSocketSendToParams extends bindings.Struct {
918 static const List<bindings.StructDataHeader> kVersions = const [
919 const bindings.StructDataHeader(24, 0)
920 ];
921 net_address_mojom.NetAddress destAddr = null;
922 List<int> data = null;
923
924 UdpSocketSendToParams() : super(kVersions.last.size);
925
926 static UdpSocketSendToParams deserialize(bindings.Message message) {
927 var decoder = new bindings.Decoder(message);
928 var result = decode(decoder);
929 if (decoder.excessHandles != null) {
930 decoder.excessHandles.forEach((h) => h.close());
931 }
932 return result;
933 }
934
935 static UdpSocketSendToParams decode(bindings.Decoder decoder0) {
936 if (decoder0 == null) {
937 return null;
938 }
939 UdpSocketSendToParams result = new UdpSocketSendToParams();
940
941 var mainDataHeader = decoder0.decodeStructDataHeader();
942 if (mainDataHeader.version <= kVersions.last.version) {
943 // Scan in reverse order to optimize for more recent versions.
944 for (int i = kVersions.length - 1; i >= 0; --i) {
945 if (mainDataHeader.version >= kVersions[i].version) {
946 if (mainDataHeader.size == kVersions[i].size) {
947 // Found a match.
948 break;
949 }
950 throw new bindings.MojoCodecError(
951 'Header size doesn\'t correspond to known version size.');
952 }
953 }
954 } else if (mainDataHeader.size < kVersions.last.size) {
955 throw new bindings.MojoCodecError(
956 'Message newer than the last known version cannot be shorter than '
957 'required by the last known version.');
958 }
959 if (mainDataHeader.version >= 0) {
960
961 var decoder1 = decoder0.decodePointer(8, true);
962 result.destAddr = net_address_mojom.NetAddress.decode(decoder1);
963 }
964 if (mainDataHeader.version >= 0) {
965
966 result.data = decoder0.decodeUint8Array(16, bindings.kNothingNullable, bin dings.kUnspecifiedArrayLength);
967 }
968 return result;
969 }
970
971 void encode(bindings.Encoder encoder) {
972 var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last);
973
974 encoder0.encodeStruct(destAddr, 8, true);
975
976 encoder0.encodeUint8Array(data, 16, bindings.kNothingNullable, bindings.kUns pecifiedArrayLength);
977 }
978
979 String toString() {
980 return "UdpSocketSendToParams("
981 "destAddr: $destAddr" ", "
982 "data: $data" ")";
983 }
984
985 Map toJson() {
986 Map map = new Map();
987 map["destAddr"] = destAddr;
988 map["data"] = data;
989 return map;
990 }
991 }
992
993
994 class UdpSocketSendToResponseParams extends bindings.Struct {
995 static const List<bindings.StructDataHeader> kVersions = const [
996 const bindings.StructDataHeader(16, 0)
997 ];
998 network_error_mojom.NetworkError result = null;
999
1000 UdpSocketSendToResponseParams() : super(kVersions.last.size);
1001
1002 static UdpSocketSendToResponseParams deserialize(bindings.Message message) {
1003 var decoder = new bindings.Decoder(message);
1004 var result = decode(decoder);
1005 if (decoder.excessHandles != null) {
1006 decoder.excessHandles.forEach((h) => h.close());
1007 }
1008 return result;
1009 }
1010
1011 static UdpSocketSendToResponseParams decode(bindings.Decoder decoder0) {
1012 if (decoder0 == null) {
1013 return null;
1014 }
1015 UdpSocketSendToResponseParams result = new UdpSocketSendToResponseParams();
1016
1017 var mainDataHeader = decoder0.decodeStructDataHeader();
1018 if (mainDataHeader.version <= kVersions.last.version) {
1019 // Scan in reverse order to optimize for more recent versions.
1020 for (int i = kVersions.length - 1; i >= 0; --i) {
1021 if (mainDataHeader.version >= kVersions[i].version) {
1022 if (mainDataHeader.size == kVersions[i].size) {
1023 // Found a match.
1024 break;
1025 }
1026 throw new bindings.MojoCodecError(
1027 'Header size doesn\'t correspond to known version size.');
1028 }
1029 }
1030 } else if (mainDataHeader.size < kVersions.last.size) {
1031 throw new bindings.MojoCodecError(
1032 'Message newer than the last known version cannot be shorter than '
1033 'required by the last known version.');
1034 }
1035 if (mainDataHeader.version >= 0) {
1036
1037 var decoder1 = decoder0.decodePointer(8, false);
1038 result.result = network_error_mojom.NetworkError.decode(decoder1);
1039 }
1040 return result;
1041 }
1042
1043 void encode(bindings.Encoder encoder) {
1044 var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last);
1045
1046 encoder0.encodeStruct(result, 8, false);
1047 }
1048
1049 String toString() {
1050 return "UdpSocketSendToResponseParams("
1051 "result: $result" ")";
1052 }
1053
1054 Map toJson() {
1055 Map map = new Map();
1056 map["result"] = result;
1057 return map;
1058 }
1059 }
1060
1061
1062 class UdpSocketReceiverOnReceivedParams extends bindings.Struct {
1063 static const List<bindings.StructDataHeader> kVersions = const [
1064 const bindings.StructDataHeader(32, 0)
1065 ];
1066 network_error_mojom.NetworkError result = null;
1067 net_address_mojom.NetAddress srcAddr = null;
1068 List<int> data = null;
1069
1070 UdpSocketReceiverOnReceivedParams() : super(kVersions.last.size);
1071
1072 static UdpSocketReceiverOnReceivedParams deserialize(bindings.Message message) {
1073 var decoder = new bindings.Decoder(message);
1074 var result = decode(decoder);
1075 if (decoder.excessHandles != null) {
1076 decoder.excessHandles.forEach((h) => h.close());
1077 }
1078 return result;
1079 }
1080
1081 static UdpSocketReceiverOnReceivedParams decode(bindings.Decoder decoder0) {
1082 if (decoder0 == null) {
1083 return null;
1084 }
1085 UdpSocketReceiverOnReceivedParams result = new UdpSocketReceiverOnReceivedPa rams();
1086
1087 var mainDataHeader = decoder0.decodeStructDataHeader();
1088 if (mainDataHeader.version <= kVersions.last.version) {
1089 // Scan in reverse order to optimize for more recent versions.
1090 for (int i = kVersions.length - 1; i >= 0; --i) {
1091 if (mainDataHeader.version >= kVersions[i].version) {
1092 if (mainDataHeader.size == kVersions[i].size) {
1093 // Found a match.
1094 break;
1095 }
1096 throw new bindings.MojoCodecError(
1097 'Header size doesn\'t correspond to known version size.');
1098 }
1099 }
1100 } else if (mainDataHeader.size < kVersions.last.size) {
1101 throw new bindings.MojoCodecError(
1102 'Message newer than the last known version cannot be shorter than '
1103 'required by the last known version.');
1104 }
1105 if (mainDataHeader.version >= 0) {
1106
1107 var decoder1 = decoder0.decodePointer(8, false);
1108 result.result = network_error_mojom.NetworkError.decode(decoder1);
1109 }
1110 if (mainDataHeader.version >= 0) {
1111
1112 var decoder1 = decoder0.decodePointer(16, true);
1113 result.srcAddr = net_address_mojom.NetAddress.decode(decoder1);
1114 }
1115 if (mainDataHeader.version >= 0) {
1116
1117 result.data = decoder0.decodeUint8Array(24, bindings.kArrayNullable, bindi ngs.kUnspecifiedArrayLength);
1118 }
1119 return result;
1120 }
1121
1122 void encode(bindings.Encoder encoder) {
1123 var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last);
1124
1125 encoder0.encodeStruct(result, 8, false);
1126
1127 encoder0.encodeStruct(srcAddr, 16, true);
1128
1129 encoder0.encodeUint8Array(data, 24, bindings.kArrayNullable, bindings.kUnspe cifiedArrayLength);
1130 }
1131
1132 String toString() {
1133 return "UdpSocketReceiverOnReceivedParams("
1134 "result: $result" ", "
1135 "srcAddr: $srcAddr" ", "
1136 "data: $data" ")";
1137 }
1138
1139 Map toJson() {
1140 Map map = new Map();
1141 map["result"] = result;
1142 map["srcAddr"] = srcAddr;
1143 map["data"] = data;
1144 return map;
1145 }
1146 }
1147
1148 const int kUdpSocket_allowAddressReuse_name = 0;
1149 const int kUdpSocket_bind_name = 1;
1150 const int kUdpSocket_connect_name = 2;
1151 const int kUdpSocket_setSendBufferSize_name = 3;
1152 const int kUdpSocket_setReceiveBufferSize_name = 4;
1153 const int kUdpSocket_negotiateMaxPendingSendRequests_name = 5;
1154 const int kUdpSocket_receiveMore_name = 6;
1155 const int kUdpSocket_sendTo_name = 7;
1156
1157 const String UdpSocketName =
1158 'mojo::UDPSocket';
1159
1160 abstract class UdpSocket {
1161 dynamic allowAddressReuse([Function responseFactory = null]);
1162 dynamic bind(net_address_mojom.NetAddress addr,[Function responseFactory = nul l]);
1163 dynamic connect(net_address_mojom.NetAddress remoteAddr,[Function responseFact ory = null]);
1164 dynamic setSendBufferSize(int size,[Function responseFactory = null]);
1165 dynamic setReceiveBufferSize(int size,[Function responseFactory = null]);
1166 dynamic negotiateMaxPendingSendRequests(int requestedSize,[Function responseFa ctory = null]);
1167 void receiveMore(int datagramNumber);
1168 dynamic sendTo(net_address_mojom.NetAddress destAddr,List<int> data,[Function responseFactory = null]);
1169
1170 }
1171
1172
1173 class UdpSocketProxyImpl extends bindings.Proxy {
1174 UdpSocketProxyImpl.fromEndpoint(
1175 core.MojoMessagePipeEndpoint endpoint) : super.fromEndpoint(endpoint);
1176
1177 UdpSocketProxyImpl.fromHandle(core.MojoHandle handle) :
1178 super.fromHandle(handle);
1179
1180 UdpSocketProxyImpl.unbound() : super.unbound();
1181
1182 static UdpSocketProxyImpl newFromEndpoint(
1183 core.MojoMessagePipeEndpoint endpoint) {
1184 assert(endpoint.setDescription("For UdpSocketProxyImpl"));
1185 return new UdpSocketProxyImpl.fromEndpoint(endpoint);
1186 }
1187
1188 String get name => UdpSocketName;
1189
1190 void handleResponse(bindings.ServiceMessage message) {
1191 switch (message.header.type) {
1192 case kUdpSocket_allowAddressReuse_name:
1193 var r = UdpSocketAllowAddressReuseResponseParams.deserialize(
1194 message.payload);
1195 if (!message.header.hasRequestId) {
1196 proxyError("Expected a message with a valid request Id.");
1197 return;
1198 }
1199 Completer c = completerMap[message.header.requestId];
1200 if (c == null) {
1201 proxyError(
1202 "Message had unknown request Id: ${message.header.requestId}");
1203 return;
1204 }
1205 completerMap.remove(message.header.requestId);
1206 if (c.isCompleted) {
1207 proxyError("Response completer already completed");
1208 return;
1209 }
1210 c.complete(r);
1211 break;
1212 case kUdpSocket_bind_name:
1213 var r = UdpSocketBindResponseParams.deserialize(
1214 message.payload);
1215 if (!message.header.hasRequestId) {
1216 proxyError("Expected a message with a valid request Id.");
1217 return;
1218 }
1219 Completer c = completerMap[message.header.requestId];
1220 if (c == null) {
1221 proxyError(
1222 "Message had unknown request Id: ${message.header.requestId}");
1223 return;
1224 }
1225 completerMap.remove(message.header.requestId);
1226 if (c.isCompleted) {
1227 proxyError("Response completer already completed");
1228 return;
1229 }
1230 c.complete(r);
1231 break;
1232 case kUdpSocket_connect_name:
1233 var r = UdpSocketConnectResponseParams.deserialize(
1234 message.payload);
1235 if (!message.header.hasRequestId) {
1236 proxyError("Expected a message with a valid request Id.");
1237 return;
1238 }
1239 Completer c = completerMap[message.header.requestId];
1240 if (c == null) {
1241 proxyError(
1242 "Message had unknown request Id: ${message.header.requestId}");
1243 return;
1244 }
1245 completerMap.remove(message.header.requestId);
1246 if (c.isCompleted) {
1247 proxyError("Response completer already completed");
1248 return;
1249 }
1250 c.complete(r);
1251 break;
1252 case kUdpSocket_setSendBufferSize_name:
1253 var r = UdpSocketSetSendBufferSizeResponseParams.deserialize(
1254 message.payload);
1255 if (!message.header.hasRequestId) {
1256 proxyError("Expected a message with a valid request Id.");
1257 return;
1258 }
1259 Completer c = completerMap[message.header.requestId];
1260 if (c == null) {
1261 proxyError(
1262 "Message had unknown request Id: ${message.header.requestId}");
1263 return;
1264 }
1265 completerMap.remove(message.header.requestId);
1266 if (c.isCompleted) {
1267 proxyError("Response completer already completed");
1268 return;
1269 }
1270 c.complete(r);
1271 break;
1272 case kUdpSocket_setReceiveBufferSize_name:
1273 var r = UdpSocketSetReceiveBufferSizeResponseParams.deserialize(
1274 message.payload);
1275 if (!message.header.hasRequestId) {
1276 proxyError("Expected a message with a valid request Id.");
1277 return;
1278 }
1279 Completer c = completerMap[message.header.requestId];
1280 if (c == null) {
1281 proxyError(
1282 "Message had unknown request Id: ${message.header.requestId}");
1283 return;
1284 }
1285 completerMap.remove(message.header.requestId);
1286 if (c.isCompleted) {
1287 proxyError("Response completer already completed");
1288 return;
1289 }
1290 c.complete(r);
1291 break;
1292 case kUdpSocket_negotiateMaxPendingSendRequests_name:
1293 var r = UdpSocketNegotiateMaxPendingSendRequestsResponseParams.deseriali ze(
1294 message.payload);
1295 if (!message.header.hasRequestId) {
1296 proxyError("Expected a message with a valid request Id.");
1297 return;
1298 }
1299 Completer c = completerMap[message.header.requestId];
1300 if (c == null) {
1301 proxyError(
1302 "Message had unknown request Id: ${message.header.requestId}");
1303 return;
1304 }
1305 completerMap.remove(message.header.requestId);
1306 if (c.isCompleted) {
1307 proxyError("Response completer already completed");
1308 return;
1309 }
1310 c.complete(r);
1311 break;
1312 case kUdpSocket_sendTo_name:
1313 var r = UdpSocketSendToResponseParams.deserialize(
1314 message.payload);
1315 if (!message.header.hasRequestId) {
1316 proxyError("Expected a message with a valid request Id.");
1317 return;
1318 }
1319 Completer c = completerMap[message.header.requestId];
1320 if (c == null) {
1321 proxyError(
1322 "Message had unknown request Id: ${message.header.requestId}");
1323 return;
1324 }
1325 completerMap.remove(message.header.requestId);
1326 if (c.isCompleted) {
1327 proxyError("Response completer already completed");
1328 return;
1329 }
1330 c.complete(r);
1331 break;
1332 default:
1333 proxyError("Unexpected message type: ${message.header.type}");
1334 close(immediate: true);
1335 break;
1336 }
1337 }
1338
1339 String toString() {
1340 var superString = super.toString();
1341 return "UdpSocketProxyImpl($superString)";
1342 }
1343 }
1344
1345
1346 class _UdpSocketProxyCalls implements UdpSocket {
1347 UdpSocketProxyImpl _proxyImpl;
1348
1349 _UdpSocketProxyCalls(this._proxyImpl);
1350 dynamic allowAddressReuse([Function responseFactory = null]) {
1351 var params = new UdpSocketAllowAddressReuseParams();
1352 return _proxyImpl.sendMessageWithRequestId(
1353 params,
1354 kUdpSocket_allowAddressReuse_name,
1355 -1,
1356 bindings.MessageHeader.kMessageExpectsResponse);
1357 }
1358 dynamic bind(net_address_mojom.NetAddress addr,[Function responseFactory = n ull]) {
1359 var params = new UdpSocketBindParams();
1360 params.addr = addr;
1361 return _proxyImpl.sendMessageWithRequestId(
1362 params,
1363 kUdpSocket_bind_name,
1364 -1,
1365 bindings.MessageHeader.kMessageExpectsResponse);
1366 }
1367 dynamic connect(net_address_mojom.NetAddress remoteAddr,[Function responseFa ctory = null]) {
1368 var params = new UdpSocketConnectParams();
1369 params.remoteAddr = remoteAddr;
1370 return _proxyImpl.sendMessageWithRequestId(
1371 params,
1372 kUdpSocket_connect_name,
1373 -1,
1374 bindings.MessageHeader.kMessageExpectsResponse);
1375 }
1376 dynamic setSendBufferSize(int size,[Function responseFactory = null]) {
1377 var params = new UdpSocketSetSendBufferSizeParams();
1378 params.size = size;
1379 return _proxyImpl.sendMessageWithRequestId(
1380 params,
1381 kUdpSocket_setSendBufferSize_name,
1382 -1,
1383 bindings.MessageHeader.kMessageExpectsResponse);
1384 }
1385 dynamic setReceiveBufferSize(int size,[Function responseFactory = null]) {
1386 var params = new UdpSocketSetReceiveBufferSizeParams();
1387 params.size = size;
1388 return _proxyImpl.sendMessageWithRequestId(
1389 params,
1390 kUdpSocket_setReceiveBufferSize_name,
1391 -1,
1392 bindings.MessageHeader.kMessageExpectsResponse);
1393 }
1394 dynamic negotiateMaxPendingSendRequests(int requestedSize,[Function response Factory = null]) {
1395 var params = new UdpSocketNegotiateMaxPendingSendRequestsParams();
1396 params.requestedSize = requestedSize;
1397 return _proxyImpl.sendMessageWithRequestId(
1398 params,
1399 kUdpSocket_negotiateMaxPendingSendRequests_name,
1400 -1,
1401 bindings.MessageHeader.kMessageExpectsResponse);
1402 }
1403 void receiveMore(int datagramNumber) {
1404 if (!_proxyImpl.isBound) {
1405 _proxyImpl.proxyError("The Proxy is closed.");
1406 return;
1407 }
1408 var params = new UdpSocketReceiveMoreParams();
1409 params.datagramNumber = datagramNumber;
1410 _proxyImpl.sendMessage(params, kUdpSocket_receiveMore_name);
1411 }
1412
1413 dynamic sendTo(net_address_mojom.NetAddress destAddr,List<int> data,[Functio n responseFactory = null]) {
1414 var params = new UdpSocketSendToParams();
1415 params.destAddr = destAddr;
1416 params.data = data;
1417 return _proxyImpl.sendMessageWithRequestId(
1418 params,
1419 kUdpSocket_sendTo_name,
1420 -1,
1421 bindings.MessageHeader.kMessageExpectsResponse);
1422 }
1423 }
1424
1425
1426 class UdpSocketProxy implements bindings.ProxyBase {
1427 final bindings.Proxy impl;
1428 UdpSocket ptr;
1429 final String name = UdpSocketName;
1430
1431 UdpSocketProxy(UdpSocketProxyImpl proxyImpl) :
1432 impl = proxyImpl,
1433 ptr = new _UdpSocketProxyCalls(proxyImpl);
1434
1435 UdpSocketProxy.fromEndpoint(
1436 core.MojoMessagePipeEndpoint endpoint) :
1437 impl = new UdpSocketProxyImpl.fromEndpoint(endpoint) {
1438 ptr = new _UdpSocketProxyCalls(impl);
1439 }
1440
1441 UdpSocketProxy.fromHandle(core.MojoHandle handle) :
1442 impl = new UdpSocketProxyImpl.fromHandle(handle) {
1443 ptr = new _UdpSocketProxyCalls(impl);
1444 }
1445
1446 UdpSocketProxy.unbound() :
1447 impl = new UdpSocketProxyImpl.unbound() {
1448 ptr = new _UdpSocketProxyCalls(impl);
1449 }
1450
1451 factory UdpSocketProxy.connectToService(
1452 bindings.ServiceConnector s, String url) {
1453 UdpSocketProxy p = new UdpSocketProxy.unbound();
1454 s.connectToService(url, p);
1455 return p;
1456 }
1457
1458 static UdpSocketProxy newFromEndpoint(
1459 core.MojoMessagePipeEndpoint endpoint) {
1460 assert(endpoint.setDescription("For UdpSocketProxy"));
1461 return new UdpSocketProxy.fromEndpoint(endpoint);
1462 }
1463
1464 Future close({bool immediate: false}) => impl.close(immediate: immediate);
1465
1466 Future responseOrError(Future f) => impl.responseOrError(f);
1467
1468 Future get errorFuture => impl.errorFuture;
1469
1470 int get version => impl.version;
1471
1472 Future<int> queryVersion() => impl.queryVersion();
1473
1474 void requireVersion(int requiredVersion) {
1475 impl.requireVersion(requiredVersion);
1476 }
1477
1478 String toString() {
1479 return "UdpSocketProxy($impl)";
1480 }
1481 }
1482
1483
1484 class UdpSocketStub extends bindings.Stub {
1485 UdpSocket _impl = null;
1486
1487 UdpSocketStub.fromEndpoint(
1488 core.MojoMessagePipeEndpoint endpoint, [this._impl])
1489 : super.fromEndpoint(endpoint);
1490
1491 UdpSocketStub.fromHandle(core.MojoHandle handle, [this._impl])
1492 : super.fromHandle(handle);
1493
1494 UdpSocketStub.unbound() : super.unbound();
1495
1496 static UdpSocketStub newFromEndpoint(
1497 core.MojoMessagePipeEndpoint endpoint) {
1498 assert(endpoint.setDescription("For UdpSocketStub"));
1499 return new UdpSocketStub.fromEndpoint(endpoint);
1500 }
1501
1502 static const String name = UdpSocketName;
1503
1504
1505 UdpSocketAllowAddressReuseResponseParams _UdpSocketAllowAddressReuseResponsePa ramsFactory(network_error_mojom.NetworkError result) {
1506 var result = new UdpSocketAllowAddressReuseResponseParams();
1507 result.result = result;
1508 return result;
1509 }
1510 UdpSocketBindResponseParams _UdpSocketBindResponseParamsFactory(network_error_ mojom.NetworkError result, net_address_mojom.NetAddress boundAddr, Object receiv er) {
1511 var result = new UdpSocketBindResponseParams();
1512 result.result = result;
1513 result.boundAddr = boundAddr;
1514 result.receiver = receiver;
1515 return result;
1516 }
1517 UdpSocketConnectResponseParams _UdpSocketConnectResponseParamsFactory(network_ error_mojom.NetworkError result, net_address_mojom.NetAddress localAddr, Object receiver) {
1518 var result = new UdpSocketConnectResponseParams();
1519 result.result = result;
1520 result.localAddr = localAddr;
1521 result.receiver = receiver;
1522 return result;
1523 }
1524 UdpSocketSetSendBufferSizeResponseParams _UdpSocketSetSendBufferSizeResponsePa ramsFactory(network_error_mojom.NetworkError result) {
1525 var result = new UdpSocketSetSendBufferSizeResponseParams();
1526 result.result = result;
1527 return result;
1528 }
1529 UdpSocketSetReceiveBufferSizeResponseParams _UdpSocketSetReceiveBufferSizeResp onseParamsFactory(network_error_mojom.NetworkError result) {
1530 var result = new UdpSocketSetReceiveBufferSizeResponseParams();
1531 result.result = result;
1532 return result;
1533 }
1534 UdpSocketNegotiateMaxPendingSendRequestsResponseParams _UdpSocketNegotiateMaxP endingSendRequestsResponseParamsFactory(int actualSize) {
1535 var result = new UdpSocketNegotiateMaxPendingSendRequestsResponseParams();
1536 result.actualSize = actualSize;
1537 return result;
1538 }
1539 UdpSocketSendToResponseParams _UdpSocketSendToResponseParamsFactory(network_er ror_mojom.NetworkError result) {
1540 var result = new UdpSocketSendToResponseParams();
1541 result.result = result;
1542 return result;
1543 }
1544
1545 dynamic handleMessage(bindings.ServiceMessage message) {
1546 if (bindings.ControlMessageHandler.isControlMessage(message)) {
1547 return bindings.ControlMessageHandler.handleMessage(this,
1548 0,
1549 message);
1550 }
1551 assert(_impl != null);
1552 switch (message.header.type) {
1553 case kUdpSocket_allowAddressReuse_name:
1554 var params = UdpSocketAllowAddressReuseParams.deserialize(
1555 message.payload);
1556 var response = _impl.allowAddressReuse(_UdpSocketAllowAddressReuseRespon seParamsFactory);
1557 if (response is Future) {
1558 return response.then((response) {
1559 if (response != null) {
1560 return buildResponseWithId(
1561 response,
1562 kUdpSocket_allowAddressReuse_name,
1563 message.header.requestId,
1564 bindings.MessageHeader.kMessageIsResponse);
1565 }
1566 });
1567 } else if (response != null) {
1568 return buildResponseWithId(
1569 response,
1570 kUdpSocket_allowAddressReuse_name,
1571 message.header.requestId,
1572 bindings.MessageHeader.kMessageIsResponse);
1573 }
1574 break;
1575 case kUdpSocket_bind_name:
1576 var params = UdpSocketBindParams.deserialize(
1577 message.payload);
1578 var response = _impl.bind(params.addr,_UdpSocketBindResponseParamsFactor y);
1579 if (response is Future) {
1580 return response.then((response) {
1581 if (response != null) {
1582 return buildResponseWithId(
1583 response,
1584 kUdpSocket_bind_name,
1585 message.header.requestId,
1586 bindings.MessageHeader.kMessageIsResponse);
1587 }
1588 });
1589 } else if (response != null) {
1590 return buildResponseWithId(
1591 response,
1592 kUdpSocket_bind_name,
1593 message.header.requestId,
1594 bindings.MessageHeader.kMessageIsResponse);
1595 }
1596 break;
1597 case kUdpSocket_connect_name:
1598 var params = UdpSocketConnectParams.deserialize(
1599 message.payload);
1600 var response = _impl.connect(params.remoteAddr,_UdpSocketConnectResponse ParamsFactory);
1601 if (response is Future) {
1602 return response.then((response) {
1603 if (response != null) {
1604 return buildResponseWithId(
1605 response,
1606 kUdpSocket_connect_name,
1607 message.header.requestId,
1608 bindings.MessageHeader.kMessageIsResponse);
1609 }
1610 });
1611 } else if (response != null) {
1612 return buildResponseWithId(
1613 response,
1614 kUdpSocket_connect_name,
1615 message.header.requestId,
1616 bindings.MessageHeader.kMessageIsResponse);
1617 }
1618 break;
1619 case kUdpSocket_setSendBufferSize_name:
1620 var params = UdpSocketSetSendBufferSizeParams.deserialize(
1621 message.payload);
1622 var response = _impl.setSendBufferSize(params.size,_UdpSocketSetSendBuff erSizeResponseParamsFactory);
1623 if (response is Future) {
1624 return response.then((response) {
1625 if (response != null) {
1626 return buildResponseWithId(
1627 response,
1628 kUdpSocket_setSendBufferSize_name,
1629 message.header.requestId,
1630 bindings.MessageHeader.kMessageIsResponse);
1631 }
1632 });
1633 } else if (response != null) {
1634 return buildResponseWithId(
1635 response,
1636 kUdpSocket_setSendBufferSize_name,
1637 message.header.requestId,
1638 bindings.MessageHeader.kMessageIsResponse);
1639 }
1640 break;
1641 case kUdpSocket_setReceiveBufferSize_name:
1642 var params = UdpSocketSetReceiveBufferSizeParams.deserialize(
1643 message.payload);
1644 var response = _impl.setReceiveBufferSize(params.size,_UdpSocketSetRecei veBufferSizeResponseParamsFactory);
1645 if (response is Future) {
1646 return response.then((response) {
1647 if (response != null) {
1648 return buildResponseWithId(
1649 response,
1650 kUdpSocket_setReceiveBufferSize_name,
1651 message.header.requestId,
1652 bindings.MessageHeader.kMessageIsResponse);
1653 }
1654 });
1655 } else if (response != null) {
1656 return buildResponseWithId(
1657 response,
1658 kUdpSocket_setReceiveBufferSize_name,
1659 message.header.requestId,
1660 bindings.MessageHeader.kMessageIsResponse);
1661 }
1662 break;
1663 case kUdpSocket_negotiateMaxPendingSendRequests_name:
1664 var params = UdpSocketNegotiateMaxPendingSendRequestsParams.deserialize(
1665 message.payload);
1666 var response = _impl.negotiateMaxPendingSendRequests(params.requestedSiz e,_UdpSocketNegotiateMaxPendingSendRequestsResponseParamsFactory);
1667 if (response is Future) {
1668 return response.then((response) {
1669 if (response != null) {
1670 return buildResponseWithId(
1671 response,
1672 kUdpSocket_negotiateMaxPendingSendRequests_name,
1673 message.header.requestId,
1674 bindings.MessageHeader.kMessageIsResponse);
1675 }
1676 });
1677 } else if (response != null) {
1678 return buildResponseWithId(
1679 response,
1680 kUdpSocket_negotiateMaxPendingSendRequests_name,
1681 message.header.requestId,
1682 bindings.MessageHeader.kMessageIsResponse);
1683 }
1684 break;
1685 case kUdpSocket_receiveMore_name:
1686 var params = UdpSocketReceiveMoreParams.deserialize(
1687 message.payload);
1688 _impl.receiveMore(params.datagramNumber);
1689 break;
1690 case kUdpSocket_sendTo_name:
1691 var params = UdpSocketSendToParams.deserialize(
1692 message.payload);
1693 var response = _impl.sendTo(params.destAddr,params.data,_UdpSocketSendTo ResponseParamsFactory);
1694 if (response is Future) {
1695 return response.then((response) {
1696 if (response != null) {
1697 return buildResponseWithId(
1698 response,
1699 kUdpSocket_sendTo_name,
1700 message.header.requestId,
1701 bindings.MessageHeader.kMessageIsResponse);
1702 }
1703 });
1704 } else if (response != null) {
1705 return buildResponseWithId(
1706 response,
1707 kUdpSocket_sendTo_name,
1708 message.header.requestId,
1709 bindings.MessageHeader.kMessageIsResponse);
1710 }
1711 break;
1712 default:
1713 throw new bindings.MojoCodecError("Unexpected message name");
1714 break;
1715 }
1716 return null;
1717 }
1718
1719 UdpSocket get impl => _impl;
1720 set impl(UdpSocket d) {
1721 assert(_impl == null);
1722 _impl = d;
1723 }
1724
1725 String toString() {
1726 var superString = super.toString();
1727 return "UdpSocketStub($superString)";
1728 }
1729
1730 int get version => 0;
1731 }
1732
1733 const int kUdpSocketReceiver_onReceived_name = 0;
1734
1735 const String UdpSocketReceiverName =
1736 'mojo::UDPSocketReceiver';
1737
1738 abstract class UdpSocketReceiver {
1739 void onReceived(network_error_mojom.NetworkError result, net_address_mojom.Net Address srcAddr, List<int> data);
1740
1741 }
1742
1743
1744 class UdpSocketReceiverProxyImpl extends bindings.Proxy {
1745 UdpSocketReceiverProxyImpl.fromEndpoint(
1746 core.MojoMessagePipeEndpoint endpoint) : super.fromEndpoint(endpoint);
1747
1748 UdpSocketReceiverProxyImpl.fromHandle(core.MojoHandle handle) :
1749 super.fromHandle(handle);
1750
1751 UdpSocketReceiverProxyImpl.unbound() : super.unbound();
1752
1753 static UdpSocketReceiverProxyImpl newFromEndpoint(
1754 core.MojoMessagePipeEndpoint endpoint) {
1755 assert(endpoint.setDescription("For UdpSocketReceiverProxyImpl"));
1756 return new UdpSocketReceiverProxyImpl.fromEndpoint(endpoint);
1757 }
1758
1759 String get name => UdpSocketReceiverName;
1760
1761 void handleResponse(bindings.ServiceMessage message) {
1762 switch (message.header.type) {
1763 default:
1764 proxyError("Unexpected message type: ${message.header.type}");
1765 close(immediate: true);
1766 break;
1767 }
1768 }
1769
1770 String toString() {
1771 var superString = super.toString();
1772 return "UdpSocketReceiverProxyImpl($superString)";
1773 }
1774 }
1775
1776
1777 class _UdpSocketReceiverProxyCalls implements UdpSocketReceiver {
1778 UdpSocketReceiverProxyImpl _proxyImpl;
1779
1780 _UdpSocketReceiverProxyCalls(this._proxyImpl);
1781 void onReceived(network_error_mojom.NetworkError result, net_address_mojom.N etAddress srcAddr, List<int> data) {
1782 if (!_proxyImpl.isBound) {
1783 _proxyImpl.proxyError("The Proxy is closed.");
1784 return;
1785 }
1786 var params = new UdpSocketReceiverOnReceivedParams();
1787 params.result = result;
1788 params.srcAddr = srcAddr;
1789 params.data = data;
1790 _proxyImpl.sendMessage(params, kUdpSocketReceiver_onReceived_name);
1791 }
1792
1793 }
1794
1795
1796 class UdpSocketReceiverProxy implements bindings.ProxyBase {
1797 final bindings.Proxy impl;
1798 UdpSocketReceiver ptr;
1799 final String name = UdpSocketReceiverName;
1800
1801 UdpSocketReceiverProxy(UdpSocketReceiverProxyImpl proxyImpl) :
1802 impl = proxyImpl,
1803 ptr = new _UdpSocketReceiverProxyCalls(proxyImpl);
1804
1805 UdpSocketReceiverProxy.fromEndpoint(
1806 core.MojoMessagePipeEndpoint endpoint) :
1807 impl = new UdpSocketReceiverProxyImpl.fromEndpoint(endpoint) {
1808 ptr = new _UdpSocketReceiverProxyCalls(impl);
1809 }
1810
1811 UdpSocketReceiverProxy.fromHandle(core.MojoHandle handle) :
1812 impl = new UdpSocketReceiverProxyImpl.fromHandle(handle) {
1813 ptr = new _UdpSocketReceiverProxyCalls(impl);
1814 }
1815
1816 UdpSocketReceiverProxy.unbound() :
1817 impl = new UdpSocketReceiverProxyImpl.unbound() {
1818 ptr = new _UdpSocketReceiverProxyCalls(impl);
1819 }
1820
1821 factory UdpSocketReceiverProxy.connectToService(
1822 bindings.ServiceConnector s, String url) {
1823 UdpSocketReceiverProxy p = new UdpSocketReceiverProxy.unbound();
1824 s.connectToService(url, p);
1825 return p;
1826 }
1827
1828 static UdpSocketReceiverProxy newFromEndpoint(
1829 core.MojoMessagePipeEndpoint endpoint) {
1830 assert(endpoint.setDescription("For UdpSocketReceiverProxy"));
1831 return new UdpSocketReceiverProxy.fromEndpoint(endpoint);
1832 }
1833
1834 Future close({bool immediate: false}) => impl.close(immediate: immediate);
1835
1836 Future responseOrError(Future f) => impl.responseOrError(f);
1837
1838 Future get errorFuture => impl.errorFuture;
1839
1840 int get version => impl.version;
1841
1842 Future<int> queryVersion() => impl.queryVersion();
1843
1844 void requireVersion(int requiredVersion) {
1845 impl.requireVersion(requiredVersion);
1846 }
1847
1848 String toString() {
1849 return "UdpSocketReceiverProxy($impl)";
1850 }
1851 }
1852
1853
1854 class UdpSocketReceiverStub extends bindings.Stub {
1855 UdpSocketReceiver _impl = null;
1856
1857 UdpSocketReceiverStub.fromEndpoint(
1858 core.MojoMessagePipeEndpoint endpoint, [this._impl])
1859 : super.fromEndpoint(endpoint);
1860
1861 UdpSocketReceiverStub.fromHandle(core.MojoHandle handle, [this._impl])
1862 : super.fromHandle(handle);
1863
1864 UdpSocketReceiverStub.unbound() : super.unbound();
1865
1866 static UdpSocketReceiverStub newFromEndpoint(
1867 core.MojoMessagePipeEndpoint endpoint) {
1868 assert(endpoint.setDescription("For UdpSocketReceiverStub"));
1869 return new UdpSocketReceiverStub.fromEndpoint(endpoint);
1870 }
1871
1872 static const String name = UdpSocketReceiverName;
1873
1874
1875
1876 dynamic handleMessage(bindings.ServiceMessage message) {
1877 if (bindings.ControlMessageHandler.isControlMessage(message)) {
1878 return bindings.ControlMessageHandler.handleMessage(this,
1879 0,
1880 message);
1881 }
1882 assert(_impl != null);
1883 switch (message.header.type) {
1884 case kUdpSocketReceiver_onReceived_name:
1885 var params = UdpSocketReceiverOnReceivedParams.deserialize(
1886 message.payload);
1887 _impl.onReceived(params.result, params.srcAddr, params.data);
1888 break;
1889 default:
1890 throw new bindings.MojoCodecError("Unexpected message name");
1891 break;
1892 }
1893 return null;
1894 }
1895
1896 UdpSocketReceiver get impl => _impl;
1897 set impl(UdpSocketReceiver d) {
1898 assert(_impl == null);
1899 _impl = d;
1900 }
1901
1902 String toString() {
1903 var superString = super.toString();
1904 return "UdpSocketReceiverStub($superString)";
1905 }
1906
1907 int get version => 0;
1908 }
1909
1910
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698