OLD | NEW |
1 // WARNING: DO NOT EDIT. This file was generated by a program. | 1 // WARNING: DO NOT EDIT. This file was generated by a program. |
2 // See $MOJO_SDK/tools/bindings/mojom_bindings_generator.py. | 2 // See $MOJO_SDK/tools/bindings/mojom_bindings_generator.py. |
3 | 3 |
4 library flog_mojom; | 4 library flog_mojom; |
5 import 'dart:async'; | 5 import 'dart:async'; |
6 import 'package:mojo/bindings.dart' as bindings; | 6 import 'package:mojo/bindings.dart' as bindings; |
7 import 'package:mojo/core.dart' as core; | 7 import 'package:mojo/core.dart' as core; |
8 import 'package:mojo/mojo/bindings/types/service_describer.mojom.dart' as servic
e_describer; | 8 import 'package:mojo/mojo/bindings/types/service_describer.mojom.dart' as servic
e_describer; |
9 | 9 |
10 | 10 |
11 | 11 |
12 class FlogDescription extends bindings.Struct { | 12 class FlogDescription extends bindings.Struct { |
13 static const List<bindings.StructDataHeader> kVersions = const [ | 13 static const List<bindings.StructDataHeader> kVersions = const [ |
14 const bindings.StructDataHeader(48, 0) | 14 const bindings.StructDataHeader(48, 0) |
15 ]; | 15 ]; |
16 String label = null; | 16 String label = null; |
17 int logId = 0; | 17 int logId = 0; |
18 int entryCount = 0; | 18 int entryCount = 0; |
19 int startTimeUs = 0; | 19 int startTimeUs = 0; |
20 int stopTimeUs = 0; | 20 int stopTimeUs = 0; |
21 bool open = false; | 21 bool open = false; |
22 | 22 |
23 FlogDescription() : super(kVersions.last.size); | 23 FlogDescription() : super(kVersions.last.size); |
24 | 24 |
| 25 FlogDescription.init( |
| 26 String this.label, |
| 27 int this.logId, |
| 28 int this.entryCount, |
| 29 int this.startTimeUs, |
| 30 int this.stopTimeUs, |
| 31 bool this.open |
| 32 ) : super(kVersions.last.size); |
| 33 |
25 static FlogDescription deserialize(bindings.Message message) { | 34 static FlogDescription deserialize(bindings.Message message) { |
26 var decoder = new bindings.Decoder(message); | 35 var decoder = new bindings.Decoder(message); |
27 var result = decode(decoder); | 36 var result = decode(decoder); |
28 if (decoder.excessHandles != null) { | 37 if (decoder.excessHandles != null) { |
29 decoder.excessHandles.forEach((h) => h.close()); | 38 decoder.excessHandles.forEach((h) => h.close()); |
30 } | 39 } |
31 return result; | 40 return result; |
32 } | 41 } |
33 | 42 |
34 static FlogDescription decode(bindings.Decoder decoder0) { | 43 static FlogDescription decode(bindings.Decoder decoder0) { |
(...skipping 120 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
155 static const List<bindings.StructDataHeader> kVersions = const [ | 164 static const List<bindings.StructDataHeader> kVersions = const [ |
156 const bindings.StructDataHeader(40, 0) | 165 const bindings.StructDataHeader(40, 0) |
157 ]; | 166 ]; |
158 int timeUs = 0; | 167 int timeUs = 0; |
159 int logId = 0; | 168 int logId = 0; |
160 int channelId = 0; | 169 int channelId = 0; |
161 FlogEntryDetails details = null; | 170 FlogEntryDetails details = null; |
162 | 171 |
163 FlogEntry() : super(kVersions.last.size); | 172 FlogEntry() : super(kVersions.last.size); |
164 | 173 |
| 174 FlogEntry.init( |
| 175 int this.timeUs, |
| 176 int this.logId, |
| 177 int this.channelId, |
| 178 FlogEntryDetails this.details |
| 179 ) : super(kVersions.last.size); |
| 180 |
165 static FlogEntry deserialize(bindings.Message message) { | 181 static FlogEntry deserialize(bindings.Message message) { |
166 var decoder = new bindings.Decoder(message); | 182 var decoder = new bindings.Decoder(message); |
167 var result = decode(decoder); | 183 var result = decode(decoder); |
168 if (decoder.excessHandles != null) { | 184 if (decoder.excessHandles != null) { |
169 decoder.excessHandles.forEach((h) => h.close()); | 185 decoder.excessHandles.forEach((h) => h.close()); |
170 } | 186 } |
171 return result; | 187 return result; |
172 } | 188 } |
173 | 189 |
174 static FlogEntry decode(bindings.Decoder decoder0) { | 190 static FlogEntry decode(bindings.Decoder decoder0) { |
(...skipping 91 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
266 | 282 |
267 | 283 |
268 class FlogChannelCreationEntryDetails extends bindings.Struct { | 284 class FlogChannelCreationEntryDetails extends bindings.Struct { |
269 static const List<bindings.StructDataHeader> kVersions = const [ | 285 static const List<bindings.StructDataHeader> kVersions = const [ |
270 const bindings.StructDataHeader(16, 0) | 286 const bindings.StructDataHeader(16, 0) |
271 ]; | 287 ]; |
272 String typeName = null; | 288 String typeName = null; |
273 | 289 |
274 FlogChannelCreationEntryDetails() : super(kVersions.last.size); | 290 FlogChannelCreationEntryDetails() : super(kVersions.last.size); |
275 | 291 |
| 292 FlogChannelCreationEntryDetails.init( |
| 293 String this.typeName |
| 294 ) : super(kVersions.last.size); |
| 295 |
276 static FlogChannelCreationEntryDetails deserialize(bindings.Message message) { | 296 static FlogChannelCreationEntryDetails deserialize(bindings.Message message) { |
277 var decoder = new bindings.Decoder(message); | 297 var decoder = new bindings.Decoder(message); |
278 var result = decode(decoder); | 298 var result = decode(decoder); |
279 if (decoder.excessHandles != null) { | 299 if (decoder.excessHandles != null) { |
280 decoder.excessHandles.forEach((h) => h.close()); | 300 decoder.excessHandles.forEach((h) => h.close()); |
281 } | 301 } |
282 return result; | 302 return result; |
283 } | 303 } |
284 | 304 |
285 static FlogChannelCreationEntryDetails decode(bindings.Decoder decoder0) { | 305 static FlogChannelCreationEntryDetails decode(bindings.Decoder decoder0) { |
(...skipping 52 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
338 | 358 |
339 | 359 |
340 class FlogChannelMessageEntryDetails extends bindings.Struct { | 360 class FlogChannelMessageEntryDetails extends bindings.Struct { |
341 static const List<bindings.StructDataHeader> kVersions = const [ | 361 static const List<bindings.StructDataHeader> kVersions = const [ |
342 const bindings.StructDataHeader(16, 0) | 362 const bindings.StructDataHeader(16, 0) |
343 ]; | 363 ]; |
344 List<int> data = null; | 364 List<int> data = null; |
345 | 365 |
346 FlogChannelMessageEntryDetails() : super(kVersions.last.size); | 366 FlogChannelMessageEntryDetails() : super(kVersions.last.size); |
347 | 367 |
| 368 FlogChannelMessageEntryDetails.init( |
| 369 List<int> this.data |
| 370 ) : super(kVersions.last.size); |
| 371 |
348 static FlogChannelMessageEntryDetails deserialize(bindings.Message message) { | 372 static FlogChannelMessageEntryDetails deserialize(bindings.Message message) { |
349 var decoder = new bindings.Decoder(message); | 373 var decoder = new bindings.Decoder(message); |
350 var result = decode(decoder); | 374 var result = decode(decoder); |
351 if (decoder.excessHandles != null) { | 375 if (decoder.excessHandles != null) { |
352 decoder.excessHandles.forEach((h) => h.close()); | 376 decoder.excessHandles.forEach((h) => h.close()); |
353 } | 377 } |
354 return result; | 378 return result; |
355 } | 379 } |
356 | 380 |
357 static FlogChannelMessageEntryDetails decode(bindings.Decoder decoder0) { | 381 static FlogChannelMessageEntryDetails decode(bindings.Decoder decoder0) { |
(...skipping 53 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
411 | 435 |
412 class _FlogServiceCreateLoggerParams extends bindings.Struct { | 436 class _FlogServiceCreateLoggerParams extends bindings.Struct { |
413 static const List<bindings.StructDataHeader> kVersions = const [ | 437 static const List<bindings.StructDataHeader> kVersions = const [ |
414 const bindings.StructDataHeader(24, 0) | 438 const bindings.StructDataHeader(24, 0) |
415 ]; | 439 ]; |
416 FlogLoggerInterfaceRequest logger = null; | 440 FlogLoggerInterfaceRequest logger = null; |
417 String label = null; | 441 String label = null; |
418 | 442 |
419 _FlogServiceCreateLoggerParams() : super(kVersions.last.size); | 443 _FlogServiceCreateLoggerParams() : super(kVersions.last.size); |
420 | 444 |
| 445 _FlogServiceCreateLoggerParams.init( |
| 446 FlogLoggerInterfaceRequest this.logger, |
| 447 String this.label |
| 448 ) : super(kVersions.last.size); |
| 449 |
421 static _FlogServiceCreateLoggerParams deserialize(bindings.Message message) { | 450 static _FlogServiceCreateLoggerParams deserialize(bindings.Message message) { |
422 var decoder = new bindings.Decoder(message); | 451 var decoder = new bindings.Decoder(message); |
423 var result = decode(decoder); | 452 var result = decode(decoder); |
424 if (decoder.excessHandles != null) { | 453 if (decoder.excessHandles != null) { |
425 decoder.excessHandles.forEach((h) => h.close()); | 454 decoder.excessHandles.forEach((h) => h.close()); |
426 } | 455 } |
427 return result; | 456 return result; |
428 } | 457 } |
429 | 458 |
430 static _FlogServiceCreateLoggerParams decode(bindings.Decoder decoder0) { | 459 static _FlogServiceCreateLoggerParams decode(bindings.Decoder decoder0) { |
(...skipping 62 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
493 } | 522 } |
494 | 523 |
495 | 524 |
496 class _FlogServiceGetLogDescriptionsParams extends bindings.Struct { | 525 class _FlogServiceGetLogDescriptionsParams extends bindings.Struct { |
497 static const List<bindings.StructDataHeader> kVersions = const [ | 526 static const List<bindings.StructDataHeader> kVersions = const [ |
498 const bindings.StructDataHeader(8, 0) | 527 const bindings.StructDataHeader(8, 0) |
499 ]; | 528 ]; |
500 | 529 |
501 _FlogServiceGetLogDescriptionsParams() : super(kVersions.last.size); | 530 _FlogServiceGetLogDescriptionsParams() : super(kVersions.last.size); |
502 | 531 |
| 532 _FlogServiceGetLogDescriptionsParams.init( |
| 533 ) : super(kVersions.last.size); |
| 534 |
503 static _FlogServiceGetLogDescriptionsParams deserialize(bindings.Message messa
ge) { | 535 static _FlogServiceGetLogDescriptionsParams deserialize(bindings.Message messa
ge) { |
504 var decoder = new bindings.Decoder(message); | 536 var decoder = new bindings.Decoder(message); |
505 var result = decode(decoder); | 537 var result = decode(decoder); |
506 if (decoder.excessHandles != null) { | 538 if (decoder.excessHandles != null) { |
507 decoder.excessHandles.forEach((h) => h.close()); | 539 decoder.excessHandles.forEach((h) => h.close()); |
508 } | 540 } |
509 return result; | 541 return result; |
510 } | 542 } |
511 | 543 |
512 static _FlogServiceGetLogDescriptionsParams decode(bindings.Decoder decoder0)
{ | 544 static _FlogServiceGetLogDescriptionsParams decode(bindings.Decoder decoder0)
{ |
(...skipping 39 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
552 | 584 |
553 | 585 |
554 class FlogServiceGetLogDescriptionsResponseParams extends bindings.Struct { | 586 class FlogServiceGetLogDescriptionsResponseParams extends bindings.Struct { |
555 static const List<bindings.StructDataHeader> kVersions = const [ | 587 static const List<bindings.StructDataHeader> kVersions = const [ |
556 const bindings.StructDataHeader(16, 0) | 588 const bindings.StructDataHeader(16, 0) |
557 ]; | 589 ]; |
558 List<FlogDescription> descriptions = null; | 590 List<FlogDescription> descriptions = null; |
559 | 591 |
560 FlogServiceGetLogDescriptionsResponseParams() : super(kVersions.last.size); | 592 FlogServiceGetLogDescriptionsResponseParams() : super(kVersions.last.size); |
561 | 593 |
| 594 FlogServiceGetLogDescriptionsResponseParams.init( |
| 595 List<FlogDescription> this.descriptions |
| 596 ) : super(kVersions.last.size); |
| 597 |
562 static FlogServiceGetLogDescriptionsResponseParams deserialize(bindings.Messag
e message) { | 598 static FlogServiceGetLogDescriptionsResponseParams deserialize(bindings.Messag
e message) { |
563 var decoder = new bindings.Decoder(message); | 599 var decoder = new bindings.Decoder(message); |
564 var result = decode(decoder); | 600 var result = decode(decoder); |
565 if (decoder.excessHandles != null) { | 601 if (decoder.excessHandles != null) { |
566 decoder.excessHandles.forEach((h) => h.close()); | 602 decoder.excessHandles.forEach((h) => h.close()); |
567 } | 603 } |
568 return result; | 604 return result; |
569 } | 605 } |
570 | 606 |
571 static FlogServiceGetLogDescriptionsResponseParams decode(bindings.Decoder dec
oder0) { | 607 static FlogServiceGetLogDescriptionsResponseParams decode(bindings.Decoder dec
oder0) { |
(...skipping 69 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
641 | 677 |
642 class _FlogServiceCreateReaderParams extends bindings.Struct { | 678 class _FlogServiceCreateReaderParams extends bindings.Struct { |
643 static const List<bindings.StructDataHeader> kVersions = const [ | 679 static const List<bindings.StructDataHeader> kVersions = const [ |
644 const bindings.StructDataHeader(16, 0) | 680 const bindings.StructDataHeader(16, 0) |
645 ]; | 681 ]; |
646 FlogReaderInterfaceRequest reader = null; | 682 FlogReaderInterfaceRequest reader = null; |
647 int logId = 0; | 683 int logId = 0; |
648 | 684 |
649 _FlogServiceCreateReaderParams() : super(kVersions.last.size); | 685 _FlogServiceCreateReaderParams() : super(kVersions.last.size); |
650 | 686 |
| 687 _FlogServiceCreateReaderParams.init( |
| 688 FlogReaderInterfaceRequest this.reader, |
| 689 int this.logId |
| 690 ) : super(kVersions.last.size); |
| 691 |
651 static _FlogServiceCreateReaderParams deserialize(bindings.Message message) { | 692 static _FlogServiceCreateReaderParams deserialize(bindings.Message message) { |
652 var decoder = new bindings.Decoder(message); | 693 var decoder = new bindings.Decoder(message); |
653 var result = decode(decoder); | 694 var result = decode(decoder); |
654 if (decoder.excessHandles != null) { | 695 if (decoder.excessHandles != null) { |
655 decoder.excessHandles.forEach((h) => h.close()); | 696 decoder.excessHandles.forEach((h) => h.close()); |
656 } | 697 } |
657 return result; | 698 return result; |
658 } | 699 } |
659 | 700 |
660 static _FlogServiceCreateReaderParams decode(bindings.Decoder decoder0) { | 701 static _FlogServiceCreateReaderParams decode(bindings.Decoder decoder0) { |
(...skipping 65 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
726 class _FlogLoggerLogChannelCreationParams extends bindings.Struct { | 767 class _FlogLoggerLogChannelCreationParams extends bindings.Struct { |
727 static const List<bindings.StructDataHeader> kVersions = const [ | 768 static const List<bindings.StructDataHeader> kVersions = const [ |
728 const bindings.StructDataHeader(32, 0) | 769 const bindings.StructDataHeader(32, 0) |
729 ]; | 770 ]; |
730 int timeUs = 0; | 771 int timeUs = 0; |
731 int channelId = 0; | 772 int channelId = 0; |
732 String typeName = null; | 773 String typeName = null; |
733 | 774 |
734 _FlogLoggerLogChannelCreationParams() : super(kVersions.last.size); | 775 _FlogLoggerLogChannelCreationParams() : super(kVersions.last.size); |
735 | 776 |
| 777 _FlogLoggerLogChannelCreationParams.init( |
| 778 int this.timeUs, |
| 779 int this.channelId, |
| 780 String this.typeName |
| 781 ) : super(kVersions.last.size); |
| 782 |
736 static _FlogLoggerLogChannelCreationParams deserialize(bindings.Message messag
e) { | 783 static _FlogLoggerLogChannelCreationParams deserialize(bindings.Message messag
e) { |
737 var decoder = new bindings.Decoder(message); | 784 var decoder = new bindings.Decoder(message); |
738 var result = decode(decoder); | 785 var result = decode(decoder); |
739 if (decoder.excessHandles != null) { | 786 if (decoder.excessHandles != null) { |
740 decoder.excessHandles.forEach((h) => h.close()); | 787 decoder.excessHandles.forEach((h) => h.close()); |
741 } | 788 } |
742 return result; | 789 return result; |
743 } | 790 } |
744 | 791 |
745 static _FlogLoggerLogChannelCreationParams decode(bindings.Decoder decoder0) { | 792 static _FlogLoggerLogChannelCreationParams decode(bindings.Decoder decoder0) { |
(...skipping 80 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
826 class _FlogLoggerLogChannelMessageParams extends bindings.Struct { | 873 class _FlogLoggerLogChannelMessageParams extends bindings.Struct { |
827 static const List<bindings.StructDataHeader> kVersions = const [ | 874 static const List<bindings.StructDataHeader> kVersions = const [ |
828 const bindings.StructDataHeader(32, 0) | 875 const bindings.StructDataHeader(32, 0) |
829 ]; | 876 ]; |
830 int timeUs = 0; | 877 int timeUs = 0; |
831 int channelId = 0; | 878 int channelId = 0; |
832 List<int> data = null; | 879 List<int> data = null; |
833 | 880 |
834 _FlogLoggerLogChannelMessageParams() : super(kVersions.last.size); | 881 _FlogLoggerLogChannelMessageParams() : super(kVersions.last.size); |
835 | 882 |
| 883 _FlogLoggerLogChannelMessageParams.init( |
| 884 int this.timeUs, |
| 885 int this.channelId, |
| 886 List<int> this.data |
| 887 ) : super(kVersions.last.size); |
| 888 |
836 static _FlogLoggerLogChannelMessageParams deserialize(bindings.Message message
) { | 889 static _FlogLoggerLogChannelMessageParams deserialize(bindings.Message message
) { |
837 var decoder = new bindings.Decoder(message); | 890 var decoder = new bindings.Decoder(message); |
838 var result = decode(decoder); | 891 var result = decode(decoder); |
839 if (decoder.excessHandles != null) { | 892 if (decoder.excessHandles != null) { |
840 decoder.excessHandles.forEach((h) => h.close()); | 893 decoder.excessHandles.forEach((h) => h.close()); |
841 } | 894 } |
842 return result; | 895 return result; |
843 } | 896 } |
844 | 897 |
845 static _FlogLoggerLogChannelMessageParams decode(bindings.Decoder decoder0) { | 898 static _FlogLoggerLogChannelMessageParams decode(bindings.Decoder decoder0) { |
(...skipping 79 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
925 | 978 |
926 class _FlogLoggerLogChannelDeletionParams extends bindings.Struct { | 979 class _FlogLoggerLogChannelDeletionParams extends bindings.Struct { |
927 static const List<bindings.StructDataHeader> kVersions = const [ | 980 static const List<bindings.StructDataHeader> kVersions = const [ |
928 const bindings.StructDataHeader(24, 0) | 981 const bindings.StructDataHeader(24, 0) |
929 ]; | 982 ]; |
930 int timeUs = 0; | 983 int timeUs = 0; |
931 int channelId = 0; | 984 int channelId = 0; |
932 | 985 |
933 _FlogLoggerLogChannelDeletionParams() : super(kVersions.last.size); | 986 _FlogLoggerLogChannelDeletionParams() : super(kVersions.last.size); |
934 | 987 |
| 988 _FlogLoggerLogChannelDeletionParams.init( |
| 989 int this.timeUs, |
| 990 int this.channelId |
| 991 ) : super(kVersions.last.size); |
| 992 |
935 static _FlogLoggerLogChannelDeletionParams deserialize(bindings.Message messag
e) { | 993 static _FlogLoggerLogChannelDeletionParams deserialize(bindings.Message messag
e) { |
936 var decoder = new bindings.Decoder(message); | 994 var decoder = new bindings.Decoder(message); |
937 var result = decode(decoder); | 995 var result = decode(decoder); |
938 if (decoder.excessHandles != null) { | 996 if (decoder.excessHandles != null) { |
939 decoder.excessHandles.forEach((h) => h.close()); | 997 decoder.excessHandles.forEach((h) => h.close()); |
940 } | 998 } |
941 return result; | 999 return result; |
942 } | 1000 } |
943 | 1001 |
944 static _FlogLoggerLogChannelDeletionParams decode(bindings.Decoder decoder0) { | 1002 static _FlogLoggerLogChannelDeletionParams decode(bindings.Decoder decoder0) { |
(...skipping 66 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1011 | 1069 |
1012 class _FlogReaderGetEntriesParams extends bindings.Struct { | 1070 class _FlogReaderGetEntriesParams extends bindings.Struct { |
1013 static const List<bindings.StructDataHeader> kVersions = const [ | 1071 static const List<bindings.StructDataHeader> kVersions = const [ |
1014 const bindings.StructDataHeader(16, 0) | 1072 const bindings.StructDataHeader(16, 0) |
1015 ]; | 1073 ]; |
1016 int startIndex = 0; | 1074 int startIndex = 0; |
1017 int maxCount = 0; | 1075 int maxCount = 0; |
1018 | 1076 |
1019 _FlogReaderGetEntriesParams() : super(kVersions.last.size); | 1077 _FlogReaderGetEntriesParams() : super(kVersions.last.size); |
1020 | 1078 |
| 1079 _FlogReaderGetEntriesParams.init( |
| 1080 int this.startIndex, |
| 1081 int this.maxCount |
| 1082 ) : super(kVersions.last.size); |
| 1083 |
1021 static _FlogReaderGetEntriesParams deserialize(bindings.Message message) { | 1084 static _FlogReaderGetEntriesParams deserialize(bindings.Message message) { |
1022 var decoder = new bindings.Decoder(message); | 1085 var decoder = new bindings.Decoder(message); |
1023 var result = decode(decoder); | 1086 var result = decode(decoder); |
1024 if (decoder.excessHandles != null) { | 1087 if (decoder.excessHandles != null) { |
1025 decoder.excessHandles.forEach((h) => h.close()); | 1088 decoder.excessHandles.forEach((h) => h.close()); |
1026 } | 1089 } |
1027 return result; | 1090 return result; |
1028 } | 1091 } |
1029 | 1092 |
1030 static _FlogReaderGetEntriesParams decode(bindings.Decoder decoder0) { | 1093 static _FlogReaderGetEntriesParams decode(bindings.Decoder decoder0) { |
(...skipping 67 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1098 class FlogReaderGetEntriesResponseParams extends bindings.Struct { | 1161 class FlogReaderGetEntriesResponseParams extends bindings.Struct { |
1099 static const List<bindings.StructDataHeader> kVersions = const [ | 1162 static const List<bindings.StructDataHeader> kVersions = const [ |
1100 const bindings.StructDataHeader(24, 0) | 1163 const bindings.StructDataHeader(24, 0) |
1101 ]; | 1164 ]; |
1102 List<FlogEntry> entries = null; | 1165 List<FlogEntry> entries = null; |
1103 int entryCount = 0; | 1166 int entryCount = 0; |
1104 bool open = false; | 1167 bool open = false; |
1105 | 1168 |
1106 FlogReaderGetEntriesResponseParams() : super(kVersions.last.size); | 1169 FlogReaderGetEntriesResponseParams() : super(kVersions.last.size); |
1107 | 1170 |
| 1171 FlogReaderGetEntriesResponseParams.init( |
| 1172 List<FlogEntry> this.entries, |
| 1173 int this.entryCount, |
| 1174 bool this.open |
| 1175 ) : super(kVersions.last.size); |
| 1176 |
1108 static FlogReaderGetEntriesResponseParams deserialize(bindings.Message message
) { | 1177 static FlogReaderGetEntriesResponseParams deserialize(bindings.Message message
) { |
1109 var decoder = new bindings.Decoder(message); | 1178 var decoder = new bindings.Decoder(message); |
1110 var result = decode(decoder); | 1179 var result = decode(decoder); |
1111 if (decoder.excessHandles != null) { | 1180 if (decoder.excessHandles != null) { |
1112 decoder.excessHandles.forEach((h) => h.close()); | 1181 decoder.excessHandles.forEach((h) => h.close()); |
1113 } | 1182 } |
1114 return result; | 1183 return result; |
1115 } | 1184 } |
1116 | 1185 |
1117 static FlogReaderGetEntriesResponseParams decode(bindings.Decoder decoder0) { | 1186 static FlogReaderGetEntriesResponseParams decode(bindings.Decoder decoder0) { |
(...skipping 195 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1313 } | 1382 } |
1314 result += ": $_data)"; | 1383 result += ": $_data)"; |
1315 return result; | 1384 return result; |
1316 } | 1385 } |
1317 } | 1386 } |
1318 const int _flogServiceMethodCreateLoggerName = 0; | 1387 const int _flogServiceMethodCreateLoggerName = 0; |
1319 const int _flogServiceMethodGetLogDescriptionsName = 1; | 1388 const int _flogServiceMethodGetLogDescriptionsName = 1; |
1320 const int _flogServiceMethodCreateReaderName = 2; | 1389 const int _flogServiceMethodCreateReaderName = 2; |
1321 | 1390 |
1322 class _FlogServiceServiceDescription implements service_describer.ServiceDescrip
tion { | 1391 class _FlogServiceServiceDescription implements service_describer.ServiceDescrip
tion { |
1323 dynamic getTopLevelInterface([Function responseFactory]) => | 1392 void getTopLevelInterface(Function responder) { |
1324 responseFactory(null); | 1393 responder(null); |
| 1394 } |
1325 | 1395 |
1326 dynamic getTypeDefinition(String typeKey, [Function responseFactory]) => | 1396 void getTypeDefinition(String typeKey, Function responder) { |
1327 responseFactory(null); | 1397 responder(null); |
| 1398 } |
1328 | 1399 |
1329 dynamic getAllTypeDefinitions([Function responseFactory]) => | 1400 void getAllTypeDefinitions(Function responder) { |
1330 responseFactory(null); | 1401 responder(null); |
| 1402 } |
1331 } | 1403 } |
1332 | 1404 |
1333 abstract class FlogService { | 1405 abstract class FlogService { |
1334 static const String serviceName = "mojo::flog::FlogService"; | 1406 static const String serviceName = "mojo::flog::FlogService"; |
1335 | 1407 |
1336 static service_describer.ServiceDescription _cachedServiceDescription; | 1408 static service_describer.ServiceDescription _cachedServiceDescription; |
1337 static service_describer.ServiceDescription get serviceDescription { | 1409 static service_describer.ServiceDescription get serviceDescription { |
1338 if (_cachedServiceDescription == null) { | 1410 if (_cachedServiceDescription == null) { |
1339 _cachedServiceDescription = new _FlogServiceServiceDescription(); | 1411 _cachedServiceDescription = new _FlogServiceServiceDescription(); |
1340 } | 1412 } |
1341 return _cachedServiceDescription; | 1413 return _cachedServiceDescription; |
1342 } | 1414 } |
1343 | 1415 |
1344 static FlogServiceProxy connectToService( | 1416 static FlogServiceProxy connectToService( |
1345 bindings.ServiceConnector s, String url, [String serviceName]) { | 1417 bindings.ServiceConnector s, String url, [String serviceName]) { |
1346 FlogServiceProxy p = new FlogServiceProxy.unbound(); | 1418 FlogServiceProxy p = new FlogServiceProxy.unbound(); |
1347 String name = serviceName ?? FlogService.serviceName; | 1419 String name = serviceName ?? FlogService.serviceName; |
1348 if ((name == null) || name.isEmpty) { | 1420 if ((name == null) || name.isEmpty) { |
1349 throw new core.MojoApiError( | 1421 throw new core.MojoApiError( |
1350 "If an interface has no ServiceName, then one must be provided."); | 1422 "If an interface has no ServiceName, then one must be provided."); |
1351 } | 1423 } |
1352 s.connectToService(url, p, name); | 1424 s.connectToService(url, p, name); |
1353 return p; | 1425 return p; |
1354 } | 1426 } |
1355 void createLogger(FlogLoggerInterfaceRequest logger, String label); | 1427 void createLogger(FlogLoggerInterfaceRequest logger, String label); |
1356 dynamic getLogDescriptions([Function responseFactory = null]); | 1428 void getLogDescriptions(void callback(List<FlogDescription> descriptions)); |
1357 void createReader(FlogReaderInterfaceRequest reader, int logId); | 1429 void createReader(FlogReaderInterfaceRequest reader, int logId); |
1358 } | 1430 } |
1359 | 1431 |
1360 abstract class FlogServiceInterface | 1432 abstract class FlogServiceInterface |
1361 implements bindings.MojoInterface<FlogService>, | 1433 implements bindings.MojoInterface<FlogService>, |
1362 FlogService { | 1434 FlogService { |
1363 factory FlogServiceInterface([FlogService impl]) => | 1435 factory FlogServiceInterface([FlogService impl]) => |
1364 new FlogServiceStub.unbound(impl); | 1436 new FlogServiceStub.unbound(impl); |
1365 | 1437 |
1366 factory FlogServiceInterface.fromEndpoint( | 1438 factory FlogServiceInterface.fromEndpoint( |
(...skipping 30 matching lines...) Expand all Loading... |
1397 | 1469 |
1398 void handleResponse(bindings.ServiceMessage message) { | 1470 void handleResponse(bindings.ServiceMessage message) { |
1399 switch (message.header.type) { | 1471 switch (message.header.type) { |
1400 case _flogServiceMethodGetLogDescriptionsName: | 1472 case _flogServiceMethodGetLogDescriptionsName: |
1401 var r = FlogServiceGetLogDescriptionsResponseParams.deserialize( | 1473 var r = FlogServiceGetLogDescriptionsResponseParams.deserialize( |
1402 message.payload); | 1474 message.payload); |
1403 if (!message.header.hasRequestId) { | 1475 if (!message.header.hasRequestId) { |
1404 proxyError("Expected a message with a valid request Id."); | 1476 proxyError("Expected a message with a valid request Id."); |
1405 return; | 1477 return; |
1406 } | 1478 } |
1407 Completer c = completerMap[message.header.requestId]; | 1479 Function callback = callbackMap[message.header.requestId]; |
1408 if (c == null) { | 1480 if (callback == null) { |
1409 proxyError( | 1481 proxyError( |
1410 "Message had unknown request Id: ${message.header.requestId}"); | 1482 "Message had unknown request Id: ${message.header.requestId}"); |
1411 return; | 1483 return; |
1412 } | 1484 } |
1413 completerMap.remove(message.header.requestId); | 1485 callbackMap.remove(message.header.requestId); |
1414 if (c.isCompleted) { | 1486 callback(r.descriptions ); |
1415 proxyError("Response completer already completed"); | |
1416 return; | |
1417 } | |
1418 c.complete(r); | |
1419 break; | 1487 break; |
1420 default: | 1488 default: |
1421 proxyError("Unexpected message type: ${message.header.type}"); | 1489 proxyError("Unexpected message type: ${message.header.type}"); |
1422 close(immediate: true); | 1490 close(immediate: true); |
1423 break; | 1491 break; |
1424 } | 1492 } |
1425 } | 1493 } |
1426 | 1494 |
1427 @override | 1495 @override |
1428 String toString() { | 1496 String toString() { |
(...skipping 39 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1468 if (!ctrl.isBound) { | 1536 if (!ctrl.isBound) { |
1469 ctrl.proxyError("The Proxy is closed."); | 1537 ctrl.proxyError("The Proxy is closed."); |
1470 return; | 1538 return; |
1471 } | 1539 } |
1472 var params = new _FlogServiceCreateLoggerParams(); | 1540 var params = new _FlogServiceCreateLoggerParams(); |
1473 params.logger = logger; | 1541 params.logger = logger; |
1474 params.label = label; | 1542 params.label = label; |
1475 ctrl.sendMessage(params, | 1543 ctrl.sendMessage(params, |
1476 _flogServiceMethodCreateLoggerName); | 1544 _flogServiceMethodCreateLoggerName); |
1477 } | 1545 } |
1478 dynamic getLogDescriptions([Function responseFactory = null]) { | 1546 void getLogDescriptions(void callback(List<FlogDescription> descriptions)) { |
1479 if (impl != null) { | 1547 if (impl != null) { |
1480 return new Future(() => impl.getLogDescriptions(_FlogServiceStubControl._f
logServiceGetLogDescriptionsResponseParamsFactory)); | 1548 impl.getLogDescriptions(callback); |
| 1549 return; |
1481 } | 1550 } |
1482 var params = new _FlogServiceGetLogDescriptionsParams(); | 1551 var params = new _FlogServiceGetLogDescriptionsParams(); |
1483 return ctrl.sendMessageWithRequestId( | 1552 ctrl.sendMessageWithRequestId( |
1484 params, | 1553 params, |
1485 _flogServiceMethodGetLogDescriptionsName, | 1554 _flogServiceMethodGetLogDescriptionsName, |
1486 -1, | 1555 -1, |
1487 bindings.MessageHeader.kMessageExpectsResponse); | 1556 bindings.MessageHeader.kMessageExpectsResponse, |
| 1557 callback); |
1488 } | 1558 } |
1489 void createReader(FlogReaderInterfaceRequest reader, int logId) { | 1559 void createReader(FlogReaderInterfaceRequest reader, int logId) { |
1490 if (impl != null) { | 1560 if (impl != null) { |
1491 impl.createReader(reader, logId); | 1561 impl.createReader(reader, logId); |
1492 return; | 1562 return; |
1493 } | 1563 } |
1494 if (!ctrl.isBound) { | 1564 if (!ctrl.isBound) { |
1495 ctrl.proxyError("The Proxy is closed."); | 1565 ctrl.proxyError("The Proxy is closed."); |
1496 return; | 1566 return; |
1497 } | 1567 } |
(...skipping 20 matching lines...) Expand all Loading... |
1518 core.MojoHandle handle, [FlogService impl]) | 1588 core.MojoHandle handle, [FlogService impl]) |
1519 : super.fromHandle(handle, autoBegin: impl != null) { | 1589 : super.fromHandle(handle, autoBegin: impl != null) { |
1520 _impl = impl; | 1590 _impl = impl; |
1521 } | 1591 } |
1522 | 1592 |
1523 _FlogServiceStubControl.unbound([this._impl]) : super.unbound(); | 1593 _FlogServiceStubControl.unbound([this._impl]) : super.unbound(); |
1524 | 1594 |
1525 String get serviceName => FlogService.serviceName; | 1595 String get serviceName => FlogService.serviceName; |
1526 | 1596 |
1527 | 1597 |
1528 static FlogServiceGetLogDescriptionsResponseParams _flogServiceGetLogDescripti
onsResponseParamsFactory(List<FlogDescription> descriptions) { | 1598 Function _flogServiceGetLogDescriptionsResponseParamsResponder( |
1529 var result = new FlogServiceGetLogDescriptionsResponseParams(); | 1599 int requestId) { |
1530 result.descriptions = descriptions; | 1600 return (List<FlogDescription> descriptions) { |
1531 return result; | 1601 var result = new FlogServiceGetLogDescriptionsResponseParams(); |
| 1602 result.descriptions = descriptions; |
| 1603 sendResponse(buildResponseWithId( |
| 1604 result, |
| 1605 _flogServiceMethodGetLogDescriptionsName, |
| 1606 requestId, |
| 1607 bindings.MessageHeader.kMessageIsResponse)); |
| 1608 }; |
1532 } | 1609 } |
1533 | 1610 |
1534 dynamic handleMessage(bindings.ServiceMessage message) { | 1611 void handleMessage(bindings.ServiceMessage message) { |
1535 if (bindings.ControlMessageHandler.isControlMessage(message)) { | 1612 if (bindings.ControlMessageHandler.isControlMessage(message)) { |
1536 return bindings.ControlMessageHandler.handleMessage(this, | 1613 bindings.ControlMessageHandler.handleMessage( |
1537 0, | 1614 this, 0, message); |
1538 message); | 1615 return; |
1539 } | 1616 } |
1540 if (_impl == null) { | 1617 if (_impl == null) { |
1541 throw new core.MojoApiError("$this has no implementation set"); | 1618 throw new core.MojoApiError("$this has no implementation set"); |
1542 } | 1619 } |
1543 switch (message.header.type) { | 1620 switch (message.header.type) { |
1544 case _flogServiceMethodCreateLoggerName: | 1621 case _flogServiceMethodCreateLoggerName: |
1545 var params = _FlogServiceCreateLoggerParams.deserialize( | 1622 var params = _FlogServiceCreateLoggerParams.deserialize( |
1546 message.payload); | 1623 message.payload); |
1547 _impl.createLogger(params.logger, params.label); | 1624 _impl.createLogger(params.logger, params.label); |
1548 break; | 1625 break; |
1549 case _flogServiceMethodGetLogDescriptionsName: | 1626 case _flogServiceMethodGetLogDescriptionsName: |
1550 var response = _impl.getLogDescriptions(_flogServiceGetLogDescriptionsRe
sponseParamsFactory); | 1627 _impl.getLogDescriptions(_flogServiceGetLogDescriptionsResponseParamsRes
ponder(message.header.requestId)); |
1551 if (response is Future) { | |
1552 return response.then((response) { | |
1553 if (response != null) { | |
1554 return buildResponseWithId( | |
1555 response, | |
1556 _flogServiceMethodGetLogDescriptionsName, | |
1557 message.header.requestId, | |
1558 bindings.MessageHeader.kMessageIsResponse); | |
1559 } | |
1560 }); | |
1561 } else if (response != null) { | |
1562 return buildResponseWithId( | |
1563 response, | |
1564 _flogServiceMethodGetLogDescriptionsName, | |
1565 message.header.requestId, | |
1566 bindings.MessageHeader.kMessageIsResponse); | |
1567 } | |
1568 break; | 1628 break; |
1569 case _flogServiceMethodCreateReaderName: | 1629 case _flogServiceMethodCreateReaderName: |
1570 var params = _FlogServiceCreateReaderParams.deserialize( | 1630 var params = _FlogServiceCreateReaderParams.deserialize( |
1571 message.payload); | 1631 message.payload); |
1572 _impl.createReader(params.reader, params.logId); | 1632 _impl.createReader(params.reader, params.logId); |
1573 break; | 1633 break; |
1574 default: | 1634 default: |
1575 throw new bindings.MojoCodecError("Unexpected message name"); | 1635 throw new bindings.MojoCodecError("Unexpected message name"); |
1576 break; | 1636 break; |
1577 } | 1637 } |
1578 return null; | |
1579 } | 1638 } |
1580 | 1639 |
1581 FlogService get impl => _impl; | 1640 FlogService get impl => _impl; |
1582 set impl(FlogService d) { | 1641 set impl(FlogService d) { |
1583 if (d == null) { | 1642 if (d == null) { |
1584 throw new core.MojoApiError("$this: Cannot set a null implementation"); | 1643 throw new core.MojoApiError("$this: Cannot set a null implementation"); |
1585 } | 1644 } |
1586 if (isBound && (_impl == null)) { | 1645 if (isBound && (_impl == null)) { |
1587 beginHandlingEvents(); | 1646 beginHandlingEvents(); |
1588 } | 1647 } |
(...skipping 36 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1625 static FlogServiceStub newFromEndpoint( | 1684 static FlogServiceStub newFromEndpoint( |
1626 core.MojoMessagePipeEndpoint endpoint) { | 1685 core.MojoMessagePipeEndpoint endpoint) { |
1627 assert(endpoint.setDescription("For FlogServiceStub")); | 1686 assert(endpoint.setDescription("For FlogServiceStub")); |
1628 return new FlogServiceStub.fromEndpoint(endpoint); | 1687 return new FlogServiceStub.fromEndpoint(endpoint); |
1629 } | 1688 } |
1630 | 1689 |
1631 | 1690 |
1632 void createLogger(FlogLoggerInterfaceRequest logger, String label) { | 1691 void createLogger(FlogLoggerInterfaceRequest logger, String label) { |
1633 return impl.createLogger(logger, label); | 1692 return impl.createLogger(logger, label); |
1634 } | 1693 } |
1635 dynamic getLogDescriptions([Function responseFactory = null]) { | 1694 void getLogDescriptions(void callback(List<FlogDescription> descriptions)) { |
1636 return impl.getLogDescriptions(responseFactory); | 1695 return impl.getLogDescriptions(callback); |
1637 } | 1696 } |
1638 void createReader(FlogReaderInterfaceRequest reader, int logId) { | 1697 void createReader(FlogReaderInterfaceRequest reader, int logId) { |
1639 return impl.createReader(reader, logId); | 1698 return impl.createReader(reader, logId); |
1640 } | 1699 } |
1641 } | 1700 } |
1642 | 1701 |
1643 const int _flogLoggerMethodLogChannelCreationName = 0; | 1702 const int _flogLoggerMethodLogChannelCreationName = 0; |
1644 const int _flogLoggerMethodLogChannelMessageName = 1; | 1703 const int _flogLoggerMethodLogChannelMessageName = 1; |
1645 const int _flogLoggerMethodLogChannelDeletionName = 2; | 1704 const int _flogLoggerMethodLogChannelDeletionName = 2; |
1646 | 1705 |
1647 class _FlogLoggerServiceDescription implements service_describer.ServiceDescript
ion { | 1706 class _FlogLoggerServiceDescription implements service_describer.ServiceDescript
ion { |
1648 dynamic getTopLevelInterface([Function responseFactory]) => | 1707 void getTopLevelInterface(Function responder) { |
1649 responseFactory(null); | 1708 responder(null); |
| 1709 } |
1650 | 1710 |
1651 dynamic getTypeDefinition(String typeKey, [Function responseFactory]) => | 1711 void getTypeDefinition(String typeKey, Function responder) { |
1652 responseFactory(null); | 1712 responder(null); |
| 1713 } |
1653 | 1714 |
1654 dynamic getAllTypeDefinitions([Function responseFactory]) => | 1715 void getAllTypeDefinitions(Function responder) { |
1655 responseFactory(null); | 1716 responder(null); |
| 1717 } |
1656 } | 1718 } |
1657 | 1719 |
1658 abstract class FlogLogger { | 1720 abstract class FlogLogger { |
1659 static const String serviceName = null; | 1721 static const String serviceName = null; |
1660 | 1722 |
1661 static service_describer.ServiceDescription _cachedServiceDescription; | 1723 static service_describer.ServiceDescription _cachedServiceDescription; |
1662 static service_describer.ServiceDescription get serviceDescription { | 1724 static service_describer.ServiceDescription get serviceDescription { |
1663 if (_cachedServiceDescription == null) { | 1725 if (_cachedServiceDescription == null) { |
1664 _cachedServiceDescription = new _FlogLoggerServiceDescription(); | 1726 _cachedServiceDescription = new _FlogLoggerServiceDescription(); |
1665 } | 1727 } |
(...skipping 164 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1830 : super.fromHandle(handle, autoBegin: impl != null) { | 1892 : super.fromHandle(handle, autoBegin: impl != null) { |
1831 _impl = impl; | 1893 _impl = impl; |
1832 } | 1894 } |
1833 | 1895 |
1834 _FlogLoggerStubControl.unbound([this._impl]) : super.unbound(); | 1896 _FlogLoggerStubControl.unbound([this._impl]) : super.unbound(); |
1835 | 1897 |
1836 String get serviceName => FlogLogger.serviceName; | 1898 String get serviceName => FlogLogger.serviceName; |
1837 | 1899 |
1838 | 1900 |
1839 | 1901 |
1840 dynamic handleMessage(bindings.ServiceMessage message) { | 1902 void handleMessage(bindings.ServiceMessage message) { |
1841 if (bindings.ControlMessageHandler.isControlMessage(message)) { | 1903 if (bindings.ControlMessageHandler.isControlMessage(message)) { |
1842 return bindings.ControlMessageHandler.handleMessage(this, | 1904 bindings.ControlMessageHandler.handleMessage( |
1843 0, | 1905 this, 0, message); |
1844 message); | 1906 return; |
1845 } | 1907 } |
1846 if (_impl == null) { | 1908 if (_impl == null) { |
1847 throw new core.MojoApiError("$this has no implementation set"); | 1909 throw new core.MojoApiError("$this has no implementation set"); |
1848 } | 1910 } |
1849 switch (message.header.type) { | 1911 switch (message.header.type) { |
1850 case _flogLoggerMethodLogChannelCreationName: | 1912 case _flogLoggerMethodLogChannelCreationName: |
1851 var params = _FlogLoggerLogChannelCreationParams.deserialize( | 1913 var params = _FlogLoggerLogChannelCreationParams.deserialize( |
1852 message.payload); | 1914 message.payload); |
1853 _impl.logChannelCreation(params.timeUs, params.channelId, params.typeNam
e); | 1915 _impl.logChannelCreation(params.timeUs, params.channelId, params.typeNam
e); |
1854 break; | 1916 break; |
1855 case _flogLoggerMethodLogChannelMessageName: | 1917 case _flogLoggerMethodLogChannelMessageName: |
1856 var params = _FlogLoggerLogChannelMessageParams.deserialize( | 1918 var params = _FlogLoggerLogChannelMessageParams.deserialize( |
1857 message.payload); | 1919 message.payload); |
1858 _impl.logChannelMessage(params.timeUs, params.channelId, params.data); | 1920 _impl.logChannelMessage(params.timeUs, params.channelId, params.data); |
1859 break; | 1921 break; |
1860 case _flogLoggerMethodLogChannelDeletionName: | 1922 case _flogLoggerMethodLogChannelDeletionName: |
1861 var params = _FlogLoggerLogChannelDeletionParams.deserialize( | 1923 var params = _FlogLoggerLogChannelDeletionParams.deserialize( |
1862 message.payload); | 1924 message.payload); |
1863 _impl.logChannelDeletion(params.timeUs, params.channelId); | 1925 _impl.logChannelDeletion(params.timeUs, params.channelId); |
1864 break; | 1926 break; |
1865 default: | 1927 default: |
1866 throw new bindings.MojoCodecError("Unexpected message name"); | 1928 throw new bindings.MojoCodecError("Unexpected message name"); |
1867 break; | 1929 break; |
1868 } | 1930 } |
1869 return null; | |
1870 } | 1931 } |
1871 | 1932 |
1872 FlogLogger get impl => _impl; | 1933 FlogLogger get impl => _impl; |
1873 set impl(FlogLogger d) { | 1934 set impl(FlogLogger d) { |
1874 if (d == null) { | 1935 if (d == null) { |
1875 throw new core.MojoApiError("$this: Cannot set a null implementation"); | 1936 throw new core.MojoApiError("$this: Cannot set a null implementation"); |
1876 } | 1937 } |
1877 if (isBound && (_impl == null)) { | 1938 if (isBound && (_impl == null)) { |
1878 beginHandlingEvents(); | 1939 beginHandlingEvents(); |
1879 } | 1940 } |
(...skipping 47 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1927 return impl.logChannelMessage(timeUs, channelId, data); | 1988 return impl.logChannelMessage(timeUs, channelId, data); |
1928 } | 1989 } |
1929 void logChannelDeletion(int timeUs, int channelId) { | 1990 void logChannelDeletion(int timeUs, int channelId) { |
1930 return impl.logChannelDeletion(timeUs, channelId); | 1991 return impl.logChannelDeletion(timeUs, channelId); |
1931 } | 1992 } |
1932 } | 1993 } |
1933 | 1994 |
1934 const int _flogReaderMethodGetEntriesName = 0; | 1995 const int _flogReaderMethodGetEntriesName = 0; |
1935 | 1996 |
1936 class _FlogReaderServiceDescription implements service_describer.ServiceDescript
ion { | 1997 class _FlogReaderServiceDescription implements service_describer.ServiceDescript
ion { |
1937 dynamic getTopLevelInterface([Function responseFactory]) => | 1998 void getTopLevelInterface(Function responder) { |
1938 responseFactory(null); | 1999 responder(null); |
| 2000 } |
1939 | 2001 |
1940 dynamic getTypeDefinition(String typeKey, [Function responseFactory]) => | 2002 void getTypeDefinition(String typeKey, Function responder) { |
1941 responseFactory(null); | 2003 responder(null); |
| 2004 } |
1942 | 2005 |
1943 dynamic getAllTypeDefinitions([Function responseFactory]) => | 2006 void getAllTypeDefinitions(Function responder) { |
1944 responseFactory(null); | 2007 responder(null); |
| 2008 } |
1945 } | 2009 } |
1946 | 2010 |
1947 abstract class FlogReader { | 2011 abstract class FlogReader { |
1948 static const String serviceName = null; | 2012 static const String serviceName = null; |
1949 | 2013 |
1950 static service_describer.ServiceDescription _cachedServiceDescription; | 2014 static service_describer.ServiceDescription _cachedServiceDescription; |
1951 static service_describer.ServiceDescription get serviceDescription { | 2015 static service_describer.ServiceDescription get serviceDescription { |
1952 if (_cachedServiceDescription == null) { | 2016 if (_cachedServiceDescription == null) { |
1953 _cachedServiceDescription = new _FlogReaderServiceDescription(); | 2017 _cachedServiceDescription = new _FlogReaderServiceDescription(); |
1954 } | 2018 } |
1955 return _cachedServiceDescription; | 2019 return _cachedServiceDescription; |
1956 } | 2020 } |
1957 | 2021 |
1958 static FlogReaderProxy connectToService( | 2022 static FlogReaderProxy connectToService( |
1959 bindings.ServiceConnector s, String url, [String serviceName]) { | 2023 bindings.ServiceConnector s, String url, [String serviceName]) { |
1960 FlogReaderProxy p = new FlogReaderProxy.unbound(); | 2024 FlogReaderProxy p = new FlogReaderProxy.unbound(); |
1961 String name = serviceName ?? FlogReader.serviceName; | 2025 String name = serviceName ?? FlogReader.serviceName; |
1962 if ((name == null) || name.isEmpty) { | 2026 if ((name == null) || name.isEmpty) { |
1963 throw new core.MojoApiError( | 2027 throw new core.MojoApiError( |
1964 "If an interface has no ServiceName, then one must be provided."); | 2028 "If an interface has no ServiceName, then one must be provided."); |
1965 } | 2029 } |
1966 s.connectToService(url, p, name); | 2030 s.connectToService(url, p, name); |
1967 return p; | 2031 return p; |
1968 } | 2032 } |
1969 dynamic getEntries(int startIndex,int maxCount,[Function responseFactory = nul
l]); | 2033 void getEntries(int startIndex,int maxCount,void callback(List<FlogEntry> entr
ies, int entryCount, bool open)); |
1970 } | 2034 } |
1971 | 2035 |
1972 abstract class FlogReaderInterface | 2036 abstract class FlogReaderInterface |
1973 implements bindings.MojoInterface<FlogReader>, | 2037 implements bindings.MojoInterface<FlogReader>, |
1974 FlogReader { | 2038 FlogReader { |
1975 factory FlogReaderInterface([FlogReader impl]) => | 2039 factory FlogReaderInterface([FlogReader impl]) => |
1976 new FlogReaderStub.unbound(impl); | 2040 new FlogReaderStub.unbound(impl); |
1977 | 2041 |
1978 factory FlogReaderInterface.fromEndpoint( | 2042 factory FlogReaderInterface.fromEndpoint( |
1979 core.MojoMessagePipeEndpoint endpoint, | 2043 core.MojoMessagePipeEndpoint endpoint, |
(...skipping 29 matching lines...) Expand all Loading... |
2009 | 2073 |
2010 void handleResponse(bindings.ServiceMessage message) { | 2074 void handleResponse(bindings.ServiceMessage message) { |
2011 switch (message.header.type) { | 2075 switch (message.header.type) { |
2012 case _flogReaderMethodGetEntriesName: | 2076 case _flogReaderMethodGetEntriesName: |
2013 var r = FlogReaderGetEntriesResponseParams.deserialize( | 2077 var r = FlogReaderGetEntriesResponseParams.deserialize( |
2014 message.payload); | 2078 message.payload); |
2015 if (!message.header.hasRequestId) { | 2079 if (!message.header.hasRequestId) { |
2016 proxyError("Expected a message with a valid request Id."); | 2080 proxyError("Expected a message with a valid request Id."); |
2017 return; | 2081 return; |
2018 } | 2082 } |
2019 Completer c = completerMap[message.header.requestId]; | 2083 Function callback = callbackMap[message.header.requestId]; |
2020 if (c == null) { | 2084 if (callback == null) { |
2021 proxyError( | 2085 proxyError( |
2022 "Message had unknown request Id: ${message.header.requestId}"); | 2086 "Message had unknown request Id: ${message.header.requestId}"); |
2023 return; | 2087 return; |
2024 } | 2088 } |
2025 completerMap.remove(message.header.requestId); | 2089 callbackMap.remove(message.header.requestId); |
2026 if (c.isCompleted) { | 2090 callback(r.entries , r.entryCount , r.open ); |
2027 proxyError("Response completer already completed"); | |
2028 return; | |
2029 } | |
2030 c.complete(r); | |
2031 break; | 2091 break; |
2032 default: | 2092 default: |
2033 proxyError("Unexpected message type: ${message.header.type}"); | 2093 proxyError("Unexpected message type: ${message.header.type}"); |
2034 close(immediate: true); | 2094 close(immediate: true); |
2035 break; | 2095 break; |
2036 } | 2096 } |
2037 } | 2097 } |
2038 | 2098 |
2039 @override | 2099 @override |
2040 String toString() { | 2100 String toString() { |
(...skipping 24 matching lines...) Expand all Loading... |
2065 return newMockedProxy; | 2125 return newMockedProxy; |
2066 } | 2126 } |
2067 | 2127 |
2068 static FlogReaderProxy newFromEndpoint( | 2128 static FlogReaderProxy newFromEndpoint( |
2069 core.MojoMessagePipeEndpoint endpoint) { | 2129 core.MojoMessagePipeEndpoint endpoint) { |
2070 assert(endpoint.setDescription("For FlogReaderProxy")); | 2130 assert(endpoint.setDescription("For FlogReaderProxy")); |
2071 return new FlogReaderProxy.fromEndpoint(endpoint); | 2131 return new FlogReaderProxy.fromEndpoint(endpoint); |
2072 } | 2132 } |
2073 | 2133 |
2074 | 2134 |
2075 dynamic getEntries(int startIndex,int maxCount,[Function responseFactory = nul
l]) { | 2135 void getEntries(int startIndex,int maxCount,void callback(List<FlogEntry> entr
ies, int entryCount, bool open)) { |
2076 if (impl != null) { | 2136 if (impl != null) { |
2077 return new Future(() => impl.getEntries(startIndex,maxCount,_FlogReaderStu
bControl._flogReaderGetEntriesResponseParamsFactory)); | 2137 impl.getEntries(startIndex,maxCount,callback); |
| 2138 return; |
2078 } | 2139 } |
2079 var params = new _FlogReaderGetEntriesParams(); | 2140 var params = new _FlogReaderGetEntriesParams(); |
2080 params.startIndex = startIndex; | 2141 params.startIndex = startIndex; |
2081 params.maxCount = maxCount; | 2142 params.maxCount = maxCount; |
2082 return ctrl.sendMessageWithRequestId( | 2143 ctrl.sendMessageWithRequestId( |
2083 params, | 2144 params, |
2084 _flogReaderMethodGetEntriesName, | 2145 _flogReaderMethodGetEntriesName, |
2085 -1, | 2146 -1, |
2086 bindings.MessageHeader.kMessageExpectsResponse); | 2147 bindings.MessageHeader.kMessageExpectsResponse, |
| 2148 callback); |
2087 } | 2149 } |
2088 } | 2150 } |
2089 | 2151 |
2090 class _FlogReaderStubControl | 2152 class _FlogReaderStubControl |
2091 extends bindings.StubMessageHandler | 2153 extends bindings.StubMessageHandler |
2092 implements bindings.StubControl<FlogReader> { | 2154 implements bindings.StubControl<FlogReader> { |
2093 FlogReader _impl; | 2155 FlogReader _impl; |
2094 | 2156 |
2095 _FlogReaderStubControl.fromEndpoint( | 2157 _FlogReaderStubControl.fromEndpoint( |
2096 core.MojoMessagePipeEndpoint endpoint, [FlogReader impl]) | 2158 core.MojoMessagePipeEndpoint endpoint, [FlogReader impl]) |
2097 : super.fromEndpoint(endpoint, autoBegin: impl != null) { | 2159 : super.fromEndpoint(endpoint, autoBegin: impl != null) { |
2098 _impl = impl; | 2160 _impl = impl; |
2099 } | 2161 } |
2100 | 2162 |
2101 _FlogReaderStubControl.fromHandle( | 2163 _FlogReaderStubControl.fromHandle( |
2102 core.MojoHandle handle, [FlogReader impl]) | 2164 core.MojoHandle handle, [FlogReader impl]) |
2103 : super.fromHandle(handle, autoBegin: impl != null) { | 2165 : super.fromHandle(handle, autoBegin: impl != null) { |
2104 _impl = impl; | 2166 _impl = impl; |
2105 } | 2167 } |
2106 | 2168 |
2107 _FlogReaderStubControl.unbound([this._impl]) : super.unbound(); | 2169 _FlogReaderStubControl.unbound([this._impl]) : super.unbound(); |
2108 | 2170 |
2109 String get serviceName => FlogReader.serviceName; | 2171 String get serviceName => FlogReader.serviceName; |
2110 | 2172 |
2111 | 2173 |
2112 static FlogReaderGetEntriesResponseParams _flogReaderGetEntriesResponseParamsF
actory(List<FlogEntry> entries, int entryCount, bool open) { | 2174 Function _flogReaderGetEntriesResponseParamsResponder( |
2113 var result = new FlogReaderGetEntriesResponseParams(); | 2175 int requestId) { |
2114 result.entries = entries; | 2176 return (List<FlogEntry> entries, int entryCount, bool open) { |
2115 result.entryCount = entryCount; | 2177 var result = new FlogReaderGetEntriesResponseParams(); |
2116 result.open = open; | 2178 result.entries = entries; |
2117 return result; | 2179 result.entryCount = entryCount; |
| 2180 result.open = open; |
| 2181 sendResponse(buildResponseWithId( |
| 2182 result, |
| 2183 _flogReaderMethodGetEntriesName, |
| 2184 requestId, |
| 2185 bindings.MessageHeader.kMessageIsResponse)); |
| 2186 }; |
2118 } | 2187 } |
2119 | 2188 |
2120 dynamic handleMessage(bindings.ServiceMessage message) { | 2189 void handleMessage(bindings.ServiceMessage message) { |
2121 if (bindings.ControlMessageHandler.isControlMessage(message)) { | 2190 if (bindings.ControlMessageHandler.isControlMessage(message)) { |
2122 return bindings.ControlMessageHandler.handleMessage(this, | 2191 bindings.ControlMessageHandler.handleMessage( |
2123 0, | 2192 this, 0, message); |
2124 message); | 2193 return; |
2125 } | 2194 } |
2126 if (_impl == null) { | 2195 if (_impl == null) { |
2127 throw new core.MojoApiError("$this has no implementation set"); | 2196 throw new core.MojoApiError("$this has no implementation set"); |
2128 } | 2197 } |
2129 switch (message.header.type) { | 2198 switch (message.header.type) { |
2130 case _flogReaderMethodGetEntriesName: | 2199 case _flogReaderMethodGetEntriesName: |
2131 var params = _FlogReaderGetEntriesParams.deserialize( | 2200 var params = _FlogReaderGetEntriesParams.deserialize( |
2132 message.payload); | 2201 message.payload); |
2133 var response = _impl.getEntries(params.startIndex,params.maxCount,_flogR
eaderGetEntriesResponseParamsFactory); | 2202 _impl.getEntries(params.startIndex, params.maxCount, _flogReaderGetEntri
esResponseParamsResponder(message.header.requestId)); |
2134 if (response is Future) { | |
2135 return response.then((response) { | |
2136 if (response != null) { | |
2137 return buildResponseWithId( | |
2138 response, | |
2139 _flogReaderMethodGetEntriesName, | |
2140 message.header.requestId, | |
2141 bindings.MessageHeader.kMessageIsResponse); | |
2142 } | |
2143 }); | |
2144 } else if (response != null) { | |
2145 return buildResponseWithId( | |
2146 response, | |
2147 _flogReaderMethodGetEntriesName, | |
2148 message.header.requestId, | |
2149 bindings.MessageHeader.kMessageIsResponse); | |
2150 } | |
2151 break; | 2203 break; |
2152 default: | 2204 default: |
2153 throw new bindings.MojoCodecError("Unexpected message name"); | 2205 throw new bindings.MojoCodecError("Unexpected message name"); |
2154 break; | 2206 break; |
2155 } | 2207 } |
2156 return null; | |
2157 } | 2208 } |
2158 | 2209 |
2159 FlogReader get impl => _impl; | 2210 FlogReader get impl => _impl; |
2160 set impl(FlogReader d) { | 2211 set impl(FlogReader d) { |
2161 if (d == null) { | 2212 if (d == null) { |
2162 throw new core.MojoApiError("$this: Cannot set a null implementation"); | 2213 throw new core.MojoApiError("$this: Cannot set a null implementation"); |
2163 } | 2214 } |
2164 if (isBound && (_impl == null)) { | 2215 if (isBound && (_impl == null)) { |
2165 beginHandlingEvents(); | 2216 beginHandlingEvents(); |
2166 } | 2217 } |
(...skipping 33 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2200 core.MojoHandle handle, [FlogReader impl]) | 2251 core.MojoHandle handle, [FlogReader impl]) |
2201 : super(new _FlogReaderStubControl.fromHandle(handle, impl)); | 2252 : super(new _FlogReaderStubControl.fromHandle(handle, impl)); |
2202 | 2253 |
2203 static FlogReaderStub newFromEndpoint( | 2254 static FlogReaderStub newFromEndpoint( |
2204 core.MojoMessagePipeEndpoint endpoint) { | 2255 core.MojoMessagePipeEndpoint endpoint) { |
2205 assert(endpoint.setDescription("For FlogReaderStub")); | 2256 assert(endpoint.setDescription("For FlogReaderStub")); |
2206 return new FlogReaderStub.fromEndpoint(endpoint); | 2257 return new FlogReaderStub.fromEndpoint(endpoint); |
2207 } | 2258 } |
2208 | 2259 |
2209 | 2260 |
2210 dynamic getEntries(int startIndex,int maxCount,[Function responseFactory = nul
l]) { | 2261 void getEntries(int startIndex,int maxCount,void callback(List<FlogEntry> entr
ies, int entryCount, bool open)) { |
2211 return impl.getEntries(startIndex,maxCount,responseFactory); | 2262 return impl.getEntries(startIndex,maxCount,callback); |
2212 } | 2263 } |
2213 } | 2264 } |
2214 | 2265 |
2215 | 2266 |
2216 | 2267 |
OLD | NEW |