Index: mojo/dart/packages/mojo_services/lib/mojo/flog/flog.mojom.dart |
diff --git a/mojo/dart/packages/mojo_services/lib/mojo/flog/flog.mojom.dart b/mojo/dart/packages/mojo_services/lib/mojo/flog/flog.mojom.dart |
new file mode 100644 |
index 0000000000000000000000000000000000000000..738b2fcb9b7520254b2d4831b3c99a1b815d288d |
--- /dev/null |
+++ b/mojo/dart/packages/mojo_services/lib/mojo/flog/flog.mojom.dart |
@@ -0,0 +1,2164 @@ |
+// Copyright 2014 The Chromium Authors. All rights reserved. |
+// Use of this source code is governed by a BSD-style license that can be |
+// found in the LICENSE file. |
+ |
+library flog_mojom; |
+import 'dart:async'; |
+import 'package:mojo/bindings.dart' as bindings; |
+import 'package:mojo/core.dart' as core; |
+import 'package:mojo/mojo/bindings/types/service_describer.mojom.dart' as service_describer; |
+ |
+ |
+ |
+class FlogDescription extends bindings.Struct { |
+ static const List<bindings.StructDataHeader> kVersions = const [ |
+ const bindings.StructDataHeader(48, 0) |
+ ]; |
+ String label = null; |
+ int logId = 0; |
+ int entryCount = 0; |
+ int startTimeUs = 0; |
+ int stopTimeUs = 0; |
+ bool open = false; |
+ |
+ FlogDescription() : super(kVersions.last.size); |
+ |
+ static FlogDescription deserialize(bindings.Message message) { |
+ var decoder = new bindings.Decoder(message); |
+ var result = decode(decoder); |
+ if (decoder.excessHandles != null) { |
+ decoder.excessHandles.forEach((h) => h.close()); |
+ } |
+ return result; |
+ } |
+ |
+ static FlogDescription decode(bindings.Decoder decoder0) { |
+ if (decoder0 == null) { |
+ return null; |
+ } |
+ FlogDescription result = new FlogDescription(); |
+ |
+ var mainDataHeader = decoder0.decodeStructDataHeader(); |
+ if (mainDataHeader.version <= kVersions.last.version) { |
+ // Scan in reverse order to optimize for more recent versions. |
+ for (int i = kVersions.length - 1; i >= 0; --i) { |
+ if (mainDataHeader.version >= kVersions[i].version) { |
+ if (mainDataHeader.size == kVersions[i].size) { |
+ // Found a match. |
+ break; |
+ } |
+ throw new bindings.MojoCodecError( |
+ 'Header size doesn\'t correspond to known version size.'); |
+ } |
+ } |
+ } else if (mainDataHeader.size < kVersions.last.size) { |
+ throw new bindings.MojoCodecError( |
+ 'Message newer than the last known version cannot be shorter than ' |
+ 'required by the last known version.'); |
+ } |
+ if (mainDataHeader.version >= 0) { |
+ |
+ result.label = decoder0.decodeString(8, false); |
+ } |
+ if (mainDataHeader.version >= 0) { |
+ |
+ result.logId = decoder0.decodeUint32(16); |
+ } |
+ if (mainDataHeader.version >= 0) { |
+ |
+ result.entryCount = decoder0.decodeUint32(20); |
+ } |
+ if (mainDataHeader.version >= 0) { |
+ |
+ result.startTimeUs = decoder0.decodeInt64(24); |
+ } |
+ if (mainDataHeader.version >= 0) { |
+ |
+ result.stopTimeUs = decoder0.decodeInt64(32); |
+ } |
+ if (mainDataHeader.version >= 0) { |
+ |
+ result.open = decoder0.decodeBool(40, 0); |
+ } |
+ return result; |
+ } |
+ |
+ void encode(bindings.Encoder encoder) { |
+ var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last); |
+ try { |
+ encoder0.encodeString(label, 8, false); |
+ } on bindings.MojoCodecError catch(e) { |
+ e.message = "Error encountered while encoding field " |
+ "label of struct FlogDescription: $e"; |
+ rethrow; |
+ } |
+ try { |
+ encoder0.encodeUint32(logId, 16); |
+ } on bindings.MojoCodecError catch(e) { |
+ e.message = "Error encountered while encoding field " |
+ "logId of struct FlogDescription: $e"; |
+ rethrow; |
+ } |
+ try { |
+ encoder0.encodeUint32(entryCount, 20); |
+ } on bindings.MojoCodecError catch(e) { |
+ e.message = "Error encountered while encoding field " |
+ "entryCount of struct FlogDescription: $e"; |
+ rethrow; |
+ } |
+ try { |
+ encoder0.encodeInt64(startTimeUs, 24); |
+ } on bindings.MojoCodecError catch(e) { |
+ e.message = "Error encountered while encoding field " |
+ "startTimeUs of struct FlogDescription: $e"; |
+ rethrow; |
+ } |
+ try { |
+ encoder0.encodeInt64(stopTimeUs, 32); |
+ } on bindings.MojoCodecError catch(e) { |
+ e.message = "Error encountered while encoding field " |
+ "stopTimeUs of struct FlogDescription: $e"; |
+ rethrow; |
+ } |
+ try { |
+ encoder0.encodeBool(open, 40, 0); |
+ } on bindings.MojoCodecError catch(e) { |
+ e.message = "Error encountered while encoding field " |
+ "open of struct FlogDescription: $e"; |
+ rethrow; |
+ } |
+ } |
+ |
+ String toString() { |
+ return "FlogDescription(" |
+ "label: $label" ", " |
+ "logId: $logId" ", " |
+ "entryCount: $entryCount" ", " |
+ "startTimeUs: $startTimeUs" ", " |
+ "stopTimeUs: $stopTimeUs" ", " |
+ "open: $open" ")"; |
+ } |
+ |
+ Map toJson() { |
+ Map map = new Map(); |
+ map["label"] = label; |
+ map["logId"] = logId; |
+ map["entryCount"] = entryCount; |
+ map["startTimeUs"] = startTimeUs; |
+ map["stopTimeUs"] = stopTimeUs; |
+ map["open"] = open; |
+ return map; |
+ } |
+} |
+ |
+ |
+class FlogEntry extends bindings.Struct { |
+ static const List<bindings.StructDataHeader> kVersions = const [ |
+ const bindings.StructDataHeader(40, 0) |
+ ]; |
+ int timeUs = 0; |
+ int logId = 0; |
+ int channelId = 0; |
+ FlogEntryDetails details = null; |
+ |
+ FlogEntry() : super(kVersions.last.size); |
+ |
+ static FlogEntry deserialize(bindings.Message message) { |
+ var decoder = new bindings.Decoder(message); |
+ var result = decode(decoder); |
+ if (decoder.excessHandles != null) { |
+ decoder.excessHandles.forEach((h) => h.close()); |
+ } |
+ return result; |
+ } |
+ |
+ static FlogEntry decode(bindings.Decoder decoder0) { |
+ if (decoder0 == null) { |
+ return null; |
+ } |
+ FlogEntry result = new FlogEntry(); |
+ |
+ var mainDataHeader = decoder0.decodeStructDataHeader(); |
+ if (mainDataHeader.version <= kVersions.last.version) { |
+ // Scan in reverse order to optimize for more recent versions. |
+ for (int i = kVersions.length - 1; i >= 0; --i) { |
+ if (mainDataHeader.version >= kVersions[i].version) { |
+ if (mainDataHeader.size == kVersions[i].size) { |
+ // Found a match. |
+ break; |
+ } |
+ throw new bindings.MojoCodecError( |
+ 'Header size doesn\'t correspond to known version size.'); |
+ } |
+ } |
+ } else if (mainDataHeader.size < kVersions.last.size) { |
+ throw new bindings.MojoCodecError( |
+ 'Message newer than the last known version cannot be shorter than ' |
+ 'required by the last known version.'); |
+ } |
+ if (mainDataHeader.version >= 0) { |
+ |
+ result.timeUs = decoder0.decodeInt64(8); |
+ } |
+ if (mainDataHeader.version >= 0) { |
+ |
+ result.logId = decoder0.decodeUint32(16); |
+ } |
+ if (mainDataHeader.version >= 0) { |
+ |
+ result.channelId = decoder0.decodeUint32(20); |
+ } |
+ if (mainDataHeader.version >= 0) { |
+ |
+ result.details = FlogEntryDetails.decode(decoder0, 24); |
+ } |
+ return result; |
+ } |
+ |
+ void encode(bindings.Encoder encoder) { |
+ var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last); |
+ try { |
+ encoder0.encodeInt64(timeUs, 8); |
+ } on bindings.MojoCodecError catch(e) { |
+ e.message = "Error encountered while encoding field " |
+ "timeUs of struct FlogEntry: $e"; |
+ rethrow; |
+ } |
+ try { |
+ encoder0.encodeUint32(logId, 16); |
+ } on bindings.MojoCodecError catch(e) { |
+ e.message = "Error encountered while encoding field " |
+ "logId of struct FlogEntry: $e"; |
+ rethrow; |
+ } |
+ try { |
+ encoder0.encodeUint32(channelId, 20); |
+ } on bindings.MojoCodecError catch(e) { |
+ e.message = "Error encountered while encoding field " |
+ "channelId of struct FlogEntry: $e"; |
+ rethrow; |
+ } |
+ try { |
+ encoder0.encodeUnion(details, 24, true); |
+ } on bindings.MojoCodecError catch(e) { |
+ e.message = "Error encountered while encoding field " |
+ "details of struct FlogEntry: $e"; |
+ rethrow; |
+ } |
+ } |
+ |
+ String toString() { |
+ return "FlogEntry(" |
+ "timeUs: $timeUs" ", " |
+ "logId: $logId" ", " |
+ "channelId: $channelId" ", " |
+ "details: $details" ")"; |
+ } |
+ |
+ Map toJson() { |
+ Map map = new Map(); |
+ map["timeUs"] = timeUs; |
+ map["logId"] = logId; |
+ map["channelId"] = channelId; |
+ map["details"] = details; |
+ return map; |
+ } |
+} |
+ |
+ |
+class FlogChannelCreationEntryDetails extends bindings.Struct { |
+ static const List<bindings.StructDataHeader> kVersions = const [ |
+ const bindings.StructDataHeader(16, 0) |
+ ]; |
+ String typeName = null; |
+ |
+ FlogChannelCreationEntryDetails() : super(kVersions.last.size); |
+ |
+ static FlogChannelCreationEntryDetails deserialize(bindings.Message message) { |
+ var decoder = new bindings.Decoder(message); |
+ var result = decode(decoder); |
+ if (decoder.excessHandles != null) { |
+ decoder.excessHandles.forEach((h) => h.close()); |
+ } |
+ return result; |
+ } |
+ |
+ static FlogChannelCreationEntryDetails decode(bindings.Decoder decoder0) { |
+ if (decoder0 == null) { |
+ return null; |
+ } |
+ FlogChannelCreationEntryDetails result = new FlogChannelCreationEntryDetails(); |
+ |
+ var mainDataHeader = decoder0.decodeStructDataHeader(); |
+ if (mainDataHeader.version <= kVersions.last.version) { |
+ // Scan in reverse order to optimize for more recent versions. |
+ for (int i = kVersions.length - 1; i >= 0; --i) { |
+ if (mainDataHeader.version >= kVersions[i].version) { |
+ if (mainDataHeader.size == kVersions[i].size) { |
+ // Found a match. |
+ break; |
+ } |
+ throw new bindings.MojoCodecError( |
+ 'Header size doesn\'t correspond to known version size.'); |
+ } |
+ } |
+ } else if (mainDataHeader.size < kVersions.last.size) { |
+ throw new bindings.MojoCodecError( |
+ 'Message newer than the last known version cannot be shorter than ' |
+ 'required by the last known version.'); |
+ } |
+ if (mainDataHeader.version >= 0) { |
+ |
+ result.typeName = decoder0.decodeString(8, false); |
+ } |
+ return result; |
+ } |
+ |
+ void encode(bindings.Encoder encoder) { |
+ var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last); |
+ try { |
+ encoder0.encodeString(typeName, 8, false); |
+ } on bindings.MojoCodecError catch(e) { |
+ e.message = "Error encountered while encoding field " |
+ "typeName of struct FlogChannelCreationEntryDetails: $e"; |
+ rethrow; |
+ } |
+ } |
+ |
+ String toString() { |
+ return "FlogChannelCreationEntryDetails(" |
+ "typeName: $typeName" ")"; |
+ } |
+ |
+ Map toJson() { |
+ Map map = new Map(); |
+ map["typeName"] = typeName; |
+ return map; |
+ } |
+} |
+ |
+ |
+class FlogChannelMessageEntryDetails extends bindings.Struct { |
+ static const List<bindings.StructDataHeader> kVersions = const [ |
+ const bindings.StructDataHeader(16, 0) |
+ ]; |
+ List<int> data = null; |
+ |
+ FlogChannelMessageEntryDetails() : super(kVersions.last.size); |
+ |
+ static FlogChannelMessageEntryDetails deserialize(bindings.Message message) { |
+ var decoder = new bindings.Decoder(message); |
+ var result = decode(decoder); |
+ if (decoder.excessHandles != null) { |
+ decoder.excessHandles.forEach((h) => h.close()); |
+ } |
+ return result; |
+ } |
+ |
+ static FlogChannelMessageEntryDetails decode(bindings.Decoder decoder0) { |
+ if (decoder0 == null) { |
+ return null; |
+ } |
+ FlogChannelMessageEntryDetails result = new FlogChannelMessageEntryDetails(); |
+ |
+ var mainDataHeader = decoder0.decodeStructDataHeader(); |
+ if (mainDataHeader.version <= kVersions.last.version) { |
+ // Scan in reverse order to optimize for more recent versions. |
+ for (int i = kVersions.length - 1; i >= 0; --i) { |
+ if (mainDataHeader.version >= kVersions[i].version) { |
+ if (mainDataHeader.size == kVersions[i].size) { |
+ // Found a match. |
+ break; |
+ } |
+ throw new bindings.MojoCodecError( |
+ 'Header size doesn\'t correspond to known version size.'); |
+ } |
+ } |
+ } else if (mainDataHeader.size < kVersions.last.size) { |
+ throw new bindings.MojoCodecError( |
+ 'Message newer than the last known version cannot be shorter than ' |
+ 'required by the last known version.'); |
+ } |
+ if (mainDataHeader.version >= 0) { |
+ |
+ result.data = decoder0.decodeUint8Array(8, bindings.kNothingNullable, bindings.kUnspecifiedArrayLength); |
+ } |
+ return result; |
+ } |
+ |
+ void encode(bindings.Encoder encoder) { |
+ var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last); |
+ try { |
+ encoder0.encodeUint8Array(data, 8, bindings.kNothingNullable, bindings.kUnspecifiedArrayLength); |
+ } on bindings.MojoCodecError catch(e) { |
+ e.message = "Error encountered while encoding field " |
+ "data of struct FlogChannelMessageEntryDetails: $e"; |
+ rethrow; |
+ } |
+ } |
+ |
+ String toString() { |
+ return "FlogChannelMessageEntryDetails(" |
+ "data: $data" ")"; |
+ } |
+ |
+ Map toJson() { |
+ Map map = new Map(); |
+ map["data"] = data; |
+ return map; |
+ } |
+} |
+ |
+ |
+class _FlogServiceCreateLoggerParams extends bindings.Struct { |
+ static const List<bindings.StructDataHeader> kVersions = const [ |
+ const bindings.StructDataHeader(24, 0) |
+ ]; |
+ FlogLoggerInterfaceRequest logger = null; |
+ String label = null; |
+ |
+ _FlogServiceCreateLoggerParams() : super(kVersions.last.size); |
+ |
+ static _FlogServiceCreateLoggerParams deserialize(bindings.Message message) { |
+ var decoder = new bindings.Decoder(message); |
+ var result = decode(decoder); |
+ if (decoder.excessHandles != null) { |
+ decoder.excessHandles.forEach((h) => h.close()); |
+ } |
+ return result; |
+ } |
+ |
+ static _FlogServiceCreateLoggerParams decode(bindings.Decoder decoder0) { |
+ if (decoder0 == null) { |
+ return null; |
+ } |
+ _FlogServiceCreateLoggerParams result = new _FlogServiceCreateLoggerParams(); |
+ |
+ var mainDataHeader = decoder0.decodeStructDataHeader(); |
+ if (mainDataHeader.version <= kVersions.last.version) { |
+ // Scan in reverse order to optimize for more recent versions. |
+ for (int i = kVersions.length - 1; i >= 0; --i) { |
+ if (mainDataHeader.version >= kVersions[i].version) { |
+ if (mainDataHeader.size == kVersions[i].size) { |
+ // Found a match. |
+ break; |
+ } |
+ throw new bindings.MojoCodecError( |
+ 'Header size doesn\'t correspond to known version size.'); |
+ } |
+ } |
+ } else if (mainDataHeader.size < kVersions.last.size) { |
+ throw new bindings.MojoCodecError( |
+ 'Message newer than the last known version cannot be shorter than ' |
+ 'required by the last known version.'); |
+ } |
+ if (mainDataHeader.version >= 0) { |
+ |
+ result.logger = decoder0.decodeInterfaceRequest(8, false, FlogLoggerStub.newFromEndpoint); |
+ } |
+ if (mainDataHeader.version >= 0) { |
+ |
+ result.label = decoder0.decodeString(16, false); |
+ } |
+ return result; |
+ } |
+ |
+ void encode(bindings.Encoder encoder) { |
+ var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last); |
+ try { |
+ encoder0.encodeInterfaceRequest(logger, 8, false); |
+ } on bindings.MojoCodecError catch(e) { |
+ e.message = "Error encountered while encoding field " |
+ "logger of struct _FlogServiceCreateLoggerParams: $e"; |
+ rethrow; |
+ } |
+ try { |
+ encoder0.encodeString(label, 16, false); |
+ } on bindings.MojoCodecError catch(e) { |
+ e.message = "Error encountered while encoding field " |
+ "label of struct _FlogServiceCreateLoggerParams: $e"; |
+ rethrow; |
+ } |
+ } |
+ |
+ String toString() { |
+ return "_FlogServiceCreateLoggerParams(" |
+ "logger: $logger" ", " |
+ "label: $label" ")"; |
+ } |
+ |
+ Map toJson() { |
+ throw new bindings.MojoCodecError( |
+ 'Object containing handles cannot be encoded to JSON.'); |
+ } |
+} |
+ |
+ |
+class _FlogServiceGetLogDescriptionsParams extends bindings.Struct { |
+ static const List<bindings.StructDataHeader> kVersions = const [ |
+ const bindings.StructDataHeader(8, 0) |
+ ]; |
+ |
+ _FlogServiceGetLogDescriptionsParams() : super(kVersions.last.size); |
+ |
+ static _FlogServiceGetLogDescriptionsParams deserialize(bindings.Message message) { |
+ var decoder = new bindings.Decoder(message); |
+ var result = decode(decoder); |
+ if (decoder.excessHandles != null) { |
+ decoder.excessHandles.forEach((h) => h.close()); |
+ } |
+ return result; |
+ } |
+ |
+ static _FlogServiceGetLogDescriptionsParams decode(bindings.Decoder decoder0) { |
+ if (decoder0 == null) { |
+ return null; |
+ } |
+ _FlogServiceGetLogDescriptionsParams result = new _FlogServiceGetLogDescriptionsParams(); |
+ |
+ var mainDataHeader = decoder0.decodeStructDataHeader(); |
+ if (mainDataHeader.version <= kVersions.last.version) { |
+ // Scan in reverse order to optimize for more recent versions. |
+ for (int i = kVersions.length - 1; i >= 0; --i) { |
+ if (mainDataHeader.version >= kVersions[i].version) { |
+ if (mainDataHeader.size == kVersions[i].size) { |
+ // Found a match. |
+ break; |
+ } |
+ throw new bindings.MojoCodecError( |
+ 'Header size doesn\'t correspond to known version size.'); |
+ } |
+ } |
+ } else if (mainDataHeader.size < kVersions.last.size) { |
+ throw new bindings.MojoCodecError( |
+ 'Message newer than the last known version cannot be shorter than ' |
+ 'required by the last known version.'); |
+ } |
+ return result; |
+ } |
+ |
+ void encode(bindings.Encoder encoder) { |
+ encoder.getStructEncoderAtOffset(kVersions.last); |
+ } |
+ |
+ String toString() { |
+ return "_FlogServiceGetLogDescriptionsParams("")"; |
+ } |
+ |
+ Map toJson() { |
+ Map map = new Map(); |
+ return map; |
+ } |
+} |
+ |
+ |
+class FlogServiceGetLogDescriptionsResponseParams extends bindings.Struct { |
+ static const List<bindings.StructDataHeader> kVersions = const [ |
+ const bindings.StructDataHeader(16, 0) |
+ ]; |
+ List<FlogDescription> descriptions = null; |
+ |
+ FlogServiceGetLogDescriptionsResponseParams() : super(kVersions.last.size); |
+ |
+ static FlogServiceGetLogDescriptionsResponseParams deserialize(bindings.Message message) { |
+ var decoder = new bindings.Decoder(message); |
+ var result = decode(decoder); |
+ if (decoder.excessHandles != null) { |
+ decoder.excessHandles.forEach((h) => h.close()); |
+ } |
+ return result; |
+ } |
+ |
+ static FlogServiceGetLogDescriptionsResponseParams decode(bindings.Decoder decoder0) { |
+ if (decoder0 == null) { |
+ return null; |
+ } |
+ FlogServiceGetLogDescriptionsResponseParams result = new FlogServiceGetLogDescriptionsResponseParams(); |
+ |
+ var mainDataHeader = decoder0.decodeStructDataHeader(); |
+ if (mainDataHeader.version <= kVersions.last.version) { |
+ // Scan in reverse order to optimize for more recent versions. |
+ for (int i = kVersions.length - 1; i >= 0; --i) { |
+ if (mainDataHeader.version >= kVersions[i].version) { |
+ if (mainDataHeader.size == kVersions[i].size) { |
+ // Found a match. |
+ break; |
+ } |
+ throw new bindings.MojoCodecError( |
+ 'Header size doesn\'t correspond to known version size.'); |
+ } |
+ } |
+ } else if (mainDataHeader.size < kVersions.last.size) { |
+ throw new bindings.MojoCodecError( |
+ 'Message newer than the last known version cannot be shorter than ' |
+ 'required by the last known version.'); |
+ } |
+ if (mainDataHeader.version >= 0) { |
+ |
+ var decoder1 = decoder0.decodePointer(8, false); |
+ { |
+ var si1 = decoder1.decodeDataHeaderForPointerArray(bindings.kUnspecifiedArrayLength); |
+ result.descriptions = new List<FlogDescription>(si1.numElements); |
+ for (int i1 = 0; i1 < si1.numElements; ++i1) { |
+ |
+ var decoder2 = decoder1.decodePointer(bindings.ArrayDataHeader.kHeaderSize + bindings.kPointerSize * i1, false); |
+ result.descriptions[i1] = FlogDescription.decode(decoder2); |
+ } |
+ } |
+ } |
+ return result; |
+ } |
+ |
+ void encode(bindings.Encoder encoder) { |
+ var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last); |
+ try { |
+ if (descriptions == null) { |
+ encoder0.encodeNullPointer(8, false); |
+ } else { |
+ var encoder1 = encoder0.encodePointerArray(descriptions.length, 8, bindings.kUnspecifiedArrayLength); |
+ for (int i0 = 0; i0 < descriptions.length; ++i0) { |
+ encoder1.encodeStruct(descriptions[i0], bindings.ArrayDataHeader.kHeaderSize + bindings.kPointerSize * i0, false); |
+ } |
+ } |
+ } on bindings.MojoCodecError catch(e) { |
+ e.message = "Error encountered while encoding field " |
+ "descriptions of struct FlogServiceGetLogDescriptionsResponseParams: $e"; |
+ rethrow; |
+ } |
+ } |
+ |
+ String toString() { |
+ return "FlogServiceGetLogDescriptionsResponseParams(" |
+ "descriptions: $descriptions" ")"; |
+ } |
+ |
+ Map toJson() { |
+ Map map = new Map(); |
+ map["descriptions"] = descriptions; |
+ return map; |
+ } |
+} |
+ |
+ |
+class _FlogServiceCreateReaderParams extends bindings.Struct { |
+ static const List<bindings.StructDataHeader> kVersions = const [ |
+ const bindings.StructDataHeader(16, 0) |
+ ]; |
+ FlogReaderInterfaceRequest reader = null; |
+ int logId = 0; |
+ |
+ _FlogServiceCreateReaderParams() : super(kVersions.last.size); |
+ |
+ static _FlogServiceCreateReaderParams deserialize(bindings.Message message) { |
+ var decoder = new bindings.Decoder(message); |
+ var result = decode(decoder); |
+ if (decoder.excessHandles != null) { |
+ decoder.excessHandles.forEach((h) => h.close()); |
+ } |
+ return result; |
+ } |
+ |
+ static _FlogServiceCreateReaderParams decode(bindings.Decoder decoder0) { |
+ if (decoder0 == null) { |
+ return null; |
+ } |
+ _FlogServiceCreateReaderParams result = new _FlogServiceCreateReaderParams(); |
+ |
+ var mainDataHeader = decoder0.decodeStructDataHeader(); |
+ if (mainDataHeader.version <= kVersions.last.version) { |
+ // Scan in reverse order to optimize for more recent versions. |
+ for (int i = kVersions.length - 1; i >= 0; --i) { |
+ if (mainDataHeader.version >= kVersions[i].version) { |
+ if (mainDataHeader.size == kVersions[i].size) { |
+ // Found a match. |
+ break; |
+ } |
+ throw new bindings.MojoCodecError( |
+ 'Header size doesn\'t correspond to known version size.'); |
+ } |
+ } |
+ } else if (mainDataHeader.size < kVersions.last.size) { |
+ throw new bindings.MojoCodecError( |
+ 'Message newer than the last known version cannot be shorter than ' |
+ 'required by the last known version.'); |
+ } |
+ if (mainDataHeader.version >= 0) { |
+ |
+ result.reader = decoder0.decodeInterfaceRequest(8, false, FlogReaderStub.newFromEndpoint); |
+ } |
+ if (mainDataHeader.version >= 0) { |
+ |
+ result.logId = decoder0.decodeUint32(12); |
+ } |
+ return result; |
+ } |
+ |
+ void encode(bindings.Encoder encoder) { |
+ var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last); |
+ try { |
+ encoder0.encodeInterfaceRequest(reader, 8, false); |
+ } on bindings.MojoCodecError catch(e) { |
+ e.message = "Error encountered while encoding field " |
+ "reader of struct _FlogServiceCreateReaderParams: $e"; |
+ rethrow; |
+ } |
+ try { |
+ encoder0.encodeUint32(logId, 12); |
+ } on bindings.MojoCodecError catch(e) { |
+ e.message = "Error encountered while encoding field " |
+ "logId of struct _FlogServiceCreateReaderParams: $e"; |
+ rethrow; |
+ } |
+ } |
+ |
+ String toString() { |
+ return "_FlogServiceCreateReaderParams(" |
+ "reader: $reader" ", " |
+ "logId: $logId" ")"; |
+ } |
+ |
+ Map toJson() { |
+ throw new bindings.MojoCodecError( |
+ 'Object containing handles cannot be encoded to JSON.'); |
+ } |
+} |
+ |
+ |
+class _FlogLoggerLogChannelCreationParams extends bindings.Struct { |
+ static const List<bindings.StructDataHeader> kVersions = const [ |
+ const bindings.StructDataHeader(32, 0) |
+ ]; |
+ int timeUs = 0; |
+ int channelId = 0; |
+ String typeName = null; |
+ |
+ _FlogLoggerLogChannelCreationParams() : super(kVersions.last.size); |
+ |
+ static _FlogLoggerLogChannelCreationParams deserialize(bindings.Message message) { |
+ var decoder = new bindings.Decoder(message); |
+ var result = decode(decoder); |
+ if (decoder.excessHandles != null) { |
+ decoder.excessHandles.forEach((h) => h.close()); |
+ } |
+ return result; |
+ } |
+ |
+ static _FlogLoggerLogChannelCreationParams decode(bindings.Decoder decoder0) { |
+ if (decoder0 == null) { |
+ return null; |
+ } |
+ _FlogLoggerLogChannelCreationParams result = new _FlogLoggerLogChannelCreationParams(); |
+ |
+ var mainDataHeader = decoder0.decodeStructDataHeader(); |
+ if (mainDataHeader.version <= kVersions.last.version) { |
+ // Scan in reverse order to optimize for more recent versions. |
+ for (int i = kVersions.length - 1; i >= 0; --i) { |
+ if (mainDataHeader.version >= kVersions[i].version) { |
+ if (mainDataHeader.size == kVersions[i].size) { |
+ // Found a match. |
+ break; |
+ } |
+ throw new bindings.MojoCodecError( |
+ 'Header size doesn\'t correspond to known version size.'); |
+ } |
+ } |
+ } else if (mainDataHeader.size < kVersions.last.size) { |
+ throw new bindings.MojoCodecError( |
+ 'Message newer than the last known version cannot be shorter than ' |
+ 'required by the last known version.'); |
+ } |
+ if (mainDataHeader.version >= 0) { |
+ |
+ result.timeUs = decoder0.decodeInt64(8); |
+ } |
+ if (mainDataHeader.version >= 0) { |
+ |
+ result.channelId = decoder0.decodeUint32(16); |
+ } |
+ if (mainDataHeader.version >= 0) { |
+ |
+ result.typeName = decoder0.decodeString(24, false); |
+ } |
+ return result; |
+ } |
+ |
+ void encode(bindings.Encoder encoder) { |
+ var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last); |
+ try { |
+ encoder0.encodeInt64(timeUs, 8); |
+ } on bindings.MojoCodecError catch(e) { |
+ e.message = "Error encountered while encoding field " |
+ "timeUs of struct _FlogLoggerLogChannelCreationParams: $e"; |
+ rethrow; |
+ } |
+ try { |
+ encoder0.encodeUint32(channelId, 16); |
+ } on bindings.MojoCodecError catch(e) { |
+ e.message = "Error encountered while encoding field " |
+ "channelId of struct _FlogLoggerLogChannelCreationParams: $e"; |
+ rethrow; |
+ } |
+ try { |
+ encoder0.encodeString(typeName, 24, false); |
+ } on bindings.MojoCodecError catch(e) { |
+ e.message = "Error encountered while encoding field " |
+ "typeName of struct _FlogLoggerLogChannelCreationParams: $e"; |
+ rethrow; |
+ } |
+ } |
+ |
+ String toString() { |
+ return "_FlogLoggerLogChannelCreationParams(" |
+ "timeUs: $timeUs" ", " |
+ "channelId: $channelId" ", " |
+ "typeName: $typeName" ")"; |
+ } |
+ |
+ Map toJson() { |
+ Map map = new Map(); |
+ map["timeUs"] = timeUs; |
+ map["channelId"] = channelId; |
+ map["typeName"] = typeName; |
+ return map; |
+ } |
+} |
+ |
+ |
+class _FlogLoggerLogChannelMessageParams extends bindings.Struct { |
+ static const List<bindings.StructDataHeader> kVersions = const [ |
+ const bindings.StructDataHeader(32, 0) |
+ ]; |
+ int timeUs = 0; |
+ int channelId = 0; |
+ List<int> data = null; |
+ |
+ _FlogLoggerLogChannelMessageParams() : super(kVersions.last.size); |
+ |
+ static _FlogLoggerLogChannelMessageParams deserialize(bindings.Message message) { |
+ var decoder = new bindings.Decoder(message); |
+ var result = decode(decoder); |
+ if (decoder.excessHandles != null) { |
+ decoder.excessHandles.forEach((h) => h.close()); |
+ } |
+ return result; |
+ } |
+ |
+ static _FlogLoggerLogChannelMessageParams decode(bindings.Decoder decoder0) { |
+ if (decoder0 == null) { |
+ return null; |
+ } |
+ _FlogLoggerLogChannelMessageParams result = new _FlogLoggerLogChannelMessageParams(); |
+ |
+ var mainDataHeader = decoder0.decodeStructDataHeader(); |
+ if (mainDataHeader.version <= kVersions.last.version) { |
+ // Scan in reverse order to optimize for more recent versions. |
+ for (int i = kVersions.length - 1; i >= 0; --i) { |
+ if (mainDataHeader.version >= kVersions[i].version) { |
+ if (mainDataHeader.size == kVersions[i].size) { |
+ // Found a match. |
+ break; |
+ } |
+ throw new bindings.MojoCodecError( |
+ 'Header size doesn\'t correspond to known version size.'); |
+ } |
+ } |
+ } else if (mainDataHeader.size < kVersions.last.size) { |
+ throw new bindings.MojoCodecError( |
+ 'Message newer than the last known version cannot be shorter than ' |
+ 'required by the last known version.'); |
+ } |
+ if (mainDataHeader.version >= 0) { |
+ |
+ result.timeUs = decoder0.decodeInt64(8); |
+ } |
+ if (mainDataHeader.version >= 0) { |
+ |
+ result.channelId = decoder0.decodeUint32(16); |
+ } |
+ if (mainDataHeader.version >= 0) { |
+ |
+ result.data = decoder0.decodeUint8Array(24, bindings.kNothingNullable, bindings.kUnspecifiedArrayLength); |
+ } |
+ return result; |
+ } |
+ |
+ void encode(bindings.Encoder encoder) { |
+ var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last); |
+ try { |
+ encoder0.encodeInt64(timeUs, 8); |
+ } on bindings.MojoCodecError catch(e) { |
+ e.message = "Error encountered while encoding field " |
+ "timeUs of struct _FlogLoggerLogChannelMessageParams: $e"; |
+ rethrow; |
+ } |
+ try { |
+ encoder0.encodeUint32(channelId, 16); |
+ } on bindings.MojoCodecError catch(e) { |
+ e.message = "Error encountered while encoding field " |
+ "channelId of struct _FlogLoggerLogChannelMessageParams: $e"; |
+ rethrow; |
+ } |
+ try { |
+ encoder0.encodeUint8Array(data, 24, bindings.kNothingNullable, bindings.kUnspecifiedArrayLength); |
+ } on bindings.MojoCodecError catch(e) { |
+ e.message = "Error encountered while encoding field " |
+ "data of struct _FlogLoggerLogChannelMessageParams: $e"; |
+ rethrow; |
+ } |
+ } |
+ |
+ String toString() { |
+ return "_FlogLoggerLogChannelMessageParams(" |
+ "timeUs: $timeUs" ", " |
+ "channelId: $channelId" ", " |
+ "data: $data" ")"; |
+ } |
+ |
+ Map toJson() { |
+ Map map = new Map(); |
+ map["timeUs"] = timeUs; |
+ map["channelId"] = channelId; |
+ map["data"] = data; |
+ return map; |
+ } |
+} |
+ |
+ |
+class _FlogLoggerLogChannelDeletionParams extends bindings.Struct { |
+ static const List<bindings.StructDataHeader> kVersions = const [ |
+ const bindings.StructDataHeader(24, 0) |
+ ]; |
+ int timeUs = 0; |
+ int channelId = 0; |
+ |
+ _FlogLoggerLogChannelDeletionParams() : super(kVersions.last.size); |
+ |
+ static _FlogLoggerLogChannelDeletionParams deserialize(bindings.Message message) { |
+ var decoder = new bindings.Decoder(message); |
+ var result = decode(decoder); |
+ if (decoder.excessHandles != null) { |
+ decoder.excessHandles.forEach((h) => h.close()); |
+ } |
+ return result; |
+ } |
+ |
+ static _FlogLoggerLogChannelDeletionParams decode(bindings.Decoder decoder0) { |
+ if (decoder0 == null) { |
+ return null; |
+ } |
+ _FlogLoggerLogChannelDeletionParams result = new _FlogLoggerLogChannelDeletionParams(); |
+ |
+ var mainDataHeader = decoder0.decodeStructDataHeader(); |
+ if (mainDataHeader.version <= kVersions.last.version) { |
+ // Scan in reverse order to optimize for more recent versions. |
+ for (int i = kVersions.length - 1; i >= 0; --i) { |
+ if (mainDataHeader.version >= kVersions[i].version) { |
+ if (mainDataHeader.size == kVersions[i].size) { |
+ // Found a match. |
+ break; |
+ } |
+ throw new bindings.MojoCodecError( |
+ 'Header size doesn\'t correspond to known version size.'); |
+ } |
+ } |
+ } else if (mainDataHeader.size < kVersions.last.size) { |
+ throw new bindings.MojoCodecError( |
+ 'Message newer than the last known version cannot be shorter than ' |
+ 'required by the last known version.'); |
+ } |
+ if (mainDataHeader.version >= 0) { |
+ |
+ result.timeUs = decoder0.decodeInt64(8); |
+ } |
+ if (mainDataHeader.version >= 0) { |
+ |
+ result.channelId = decoder0.decodeUint32(16); |
+ } |
+ return result; |
+ } |
+ |
+ void encode(bindings.Encoder encoder) { |
+ var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last); |
+ try { |
+ encoder0.encodeInt64(timeUs, 8); |
+ } on bindings.MojoCodecError catch(e) { |
+ e.message = "Error encountered while encoding field " |
+ "timeUs of struct _FlogLoggerLogChannelDeletionParams: $e"; |
+ rethrow; |
+ } |
+ try { |
+ encoder0.encodeUint32(channelId, 16); |
+ } on bindings.MojoCodecError catch(e) { |
+ e.message = "Error encountered while encoding field " |
+ "channelId of struct _FlogLoggerLogChannelDeletionParams: $e"; |
+ rethrow; |
+ } |
+ } |
+ |
+ String toString() { |
+ return "_FlogLoggerLogChannelDeletionParams(" |
+ "timeUs: $timeUs" ", " |
+ "channelId: $channelId" ")"; |
+ } |
+ |
+ Map toJson() { |
+ Map map = new Map(); |
+ map["timeUs"] = timeUs; |
+ map["channelId"] = channelId; |
+ return map; |
+ } |
+} |
+ |
+ |
+class _FlogReaderGetEntriesParams extends bindings.Struct { |
+ static const List<bindings.StructDataHeader> kVersions = const [ |
+ const bindings.StructDataHeader(16, 0) |
+ ]; |
+ int startIndex = 0; |
+ int maxCount = 0; |
+ |
+ _FlogReaderGetEntriesParams() : super(kVersions.last.size); |
+ |
+ static _FlogReaderGetEntriesParams deserialize(bindings.Message message) { |
+ var decoder = new bindings.Decoder(message); |
+ var result = decode(decoder); |
+ if (decoder.excessHandles != null) { |
+ decoder.excessHandles.forEach((h) => h.close()); |
+ } |
+ return result; |
+ } |
+ |
+ static _FlogReaderGetEntriesParams decode(bindings.Decoder decoder0) { |
+ if (decoder0 == null) { |
+ return null; |
+ } |
+ _FlogReaderGetEntriesParams result = new _FlogReaderGetEntriesParams(); |
+ |
+ var mainDataHeader = decoder0.decodeStructDataHeader(); |
+ if (mainDataHeader.version <= kVersions.last.version) { |
+ // Scan in reverse order to optimize for more recent versions. |
+ for (int i = kVersions.length - 1; i >= 0; --i) { |
+ if (mainDataHeader.version >= kVersions[i].version) { |
+ if (mainDataHeader.size == kVersions[i].size) { |
+ // Found a match. |
+ break; |
+ } |
+ throw new bindings.MojoCodecError( |
+ 'Header size doesn\'t correspond to known version size.'); |
+ } |
+ } |
+ } else if (mainDataHeader.size < kVersions.last.size) { |
+ throw new bindings.MojoCodecError( |
+ 'Message newer than the last known version cannot be shorter than ' |
+ 'required by the last known version.'); |
+ } |
+ if (mainDataHeader.version >= 0) { |
+ |
+ result.startIndex = decoder0.decodeUint32(8); |
+ } |
+ if (mainDataHeader.version >= 0) { |
+ |
+ result.maxCount = decoder0.decodeUint32(12); |
+ } |
+ return result; |
+ } |
+ |
+ void encode(bindings.Encoder encoder) { |
+ var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last); |
+ try { |
+ encoder0.encodeUint32(startIndex, 8); |
+ } on bindings.MojoCodecError catch(e) { |
+ e.message = "Error encountered while encoding field " |
+ "startIndex of struct _FlogReaderGetEntriesParams: $e"; |
+ rethrow; |
+ } |
+ try { |
+ encoder0.encodeUint32(maxCount, 12); |
+ } on bindings.MojoCodecError catch(e) { |
+ e.message = "Error encountered while encoding field " |
+ "maxCount of struct _FlogReaderGetEntriesParams: $e"; |
+ rethrow; |
+ } |
+ } |
+ |
+ String toString() { |
+ return "_FlogReaderGetEntriesParams(" |
+ "startIndex: $startIndex" ", " |
+ "maxCount: $maxCount" ")"; |
+ } |
+ |
+ Map toJson() { |
+ Map map = new Map(); |
+ map["startIndex"] = startIndex; |
+ map["maxCount"] = maxCount; |
+ return map; |
+ } |
+} |
+ |
+ |
+class FlogReaderGetEntriesResponseParams extends bindings.Struct { |
+ static const List<bindings.StructDataHeader> kVersions = const [ |
+ const bindings.StructDataHeader(24, 0) |
+ ]; |
+ List<FlogEntry> entries = null; |
+ int entryCount = 0; |
+ bool open = false; |
+ |
+ FlogReaderGetEntriesResponseParams() : super(kVersions.last.size); |
+ |
+ static FlogReaderGetEntriesResponseParams deserialize(bindings.Message message) { |
+ var decoder = new bindings.Decoder(message); |
+ var result = decode(decoder); |
+ if (decoder.excessHandles != null) { |
+ decoder.excessHandles.forEach((h) => h.close()); |
+ } |
+ return result; |
+ } |
+ |
+ static FlogReaderGetEntriesResponseParams decode(bindings.Decoder decoder0) { |
+ if (decoder0 == null) { |
+ return null; |
+ } |
+ FlogReaderGetEntriesResponseParams result = new FlogReaderGetEntriesResponseParams(); |
+ |
+ var mainDataHeader = decoder0.decodeStructDataHeader(); |
+ if (mainDataHeader.version <= kVersions.last.version) { |
+ // Scan in reverse order to optimize for more recent versions. |
+ for (int i = kVersions.length - 1; i >= 0; --i) { |
+ if (mainDataHeader.version >= kVersions[i].version) { |
+ if (mainDataHeader.size == kVersions[i].size) { |
+ // Found a match. |
+ break; |
+ } |
+ throw new bindings.MojoCodecError( |
+ 'Header size doesn\'t correspond to known version size.'); |
+ } |
+ } |
+ } else if (mainDataHeader.size < kVersions.last.size) { |
+ throw new bindings.MojoCodecError( |
+ 'Message newer than the last known version cannot be shorter than ' |
+ 'required by the last known version.'); |
+ } |
+ if (mainDataHeader.version >= 0) { |
+ |
+ var decoder1 = decoder0.decodePointer(8, false); |
+ { |
+ var si1 = decoder1.decodeDataHeaderForPointerArray(bindings.kUnspecifiedArrayLength); |
+ result.entries = new List<FlogEntry>(si1.numElements); |
+ for (int i1 = 0; i1 < si1.numElements; ++i1) { |
+ |
+ var decoder2 = decoder1.decodePointer(bindings.ArrayDataHeader.kHeaderSize + bindings.kPointerSize * i1, false); |
+ result.entries[i1] = FlogEntry.decode(decoder2); |
+ } |
+ } |
+ } |
+ if (mainDataHeader.version >= 0) { |
+ |
+ result.entryCount = decoder0.decodeUint32(16); |
+ } |
+ if (mainDataHeader.version >= 0) { |
+ |
+ result.open = decoder0.decodeBool(20, 0); |
+ } |
+ return result; |
+ } |
+ |
+ void encode(bindings.Encoder encoder) { |
+ var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last); |
+ try { |
+ if (entries == null) { |
+ encoder0.encodeNullPointer(8, false); |
+ } else { |
+ var encoder1 = encoder0.encodePointerArray(entries.length, 8, bindings.kUnspecifiedArrayLength); |
+ for (int i0 = 0; i0 < entries.length; ++i0) { |
+ encoder1.encodeStruct(entries[i0], bindings.ArrayDataHeader.kHeaderSize + bindings.kPointerSize * i0, false); |
+ } |
+ } |
+ } on bindings.MojoCodecError catch(e) { |
+ e.message = "Error encountered while encoding field " |
+ "entries of struct FlogReaderGetEntriesResponseParams: $e"; |
+ rethrow; |
+ } |
+ try { |
+ encoder0.encodeUint32(entryCount, 16); |
+ } on bindings.MojoCodecError catch(e) { |
+ e.message = "Error encountered while encoding field " |
+ "entryCount of struct FlogReaderGetEntriesResponseParams: $e"; |
+ rethrow; |
+ } |
+ try { |
+ encoder0.encodeBool(open, 20, 0); |
+ } on bindings.MojoCodecError catch(e) { |
+ e.message = "Error encountered while encoding field " |
+ "open of struct FlogReaderGetEntriesResponseParams: $e"; |
+ rethrow; |
+ } |
+ } |
+ |
+ String toString() { |
+ return "FlogReaderGetEntriesResponseParams(" |
+ "entries: $entries" ", " |
+ "entryCount: $entryCount" ", " |
+ "open: $open" ")"; |
+ } |
+ |
+ Map toJson() { |
+ Map map = new Map(); |
+ map["entries"] = entries; |
+ map["entryCount"] = entryCount; |
+ map["open"] = open; |
+ return map; |
+ } |
+} |
+ |
+ |
+ |
+enum FlogEntryDetailsTag { |
+ channelCreation, |
+ channelMessage, |
+ unknown |
+} |
+ |
+class FlogEntryDetails extends bindings.Union { |
+ static final _tagToInt = const { |
+ FlogEntryDetailsTag.channelCreation: 0, |
+ FlogEntryDetailsTag.channelMessage: 1, |
+ }; |
+ |
+ static final _intToTag = const { |
+ 0: FlogEntryDetailsTag.channelCreation, |
+ 1: FlogEntryDetailsTag.channelMessage, |
+ }; |
+ |
+ var _data; |
+ FlogEntryDetailsTag _tag = FlogEntryDetailsTag.unknown; |
+ |
+ FlogEntryDetailsTag get tag => _tag; |
+ FlogChannelCreationEntryDetails get channelCreation { |
+ if (_tag != FlogEntryDetailsTag.channelCreation) { |
+ throw new bindings.UnsetUnionTagError(_tag, FlogEntryDetailsTag.channelCreation); |
+ } |
+ return _data; |
+ } |
+ |
+ set channelCreation(FlogChannelCreationEntryDetails value) { |
+ _tag = FlogEntryDetailsTag.channelCreation; |
+ _data = value; |
+ } |
+ FlogChannelMessageEntryDetails get channelMessage { |
+ if (_tag != FlogEntryDetailsTag.channelMessage) { |
+ throw new bindings.UnsetUnionTagError(_tag, FlogEntryDetailsTag.channelMessage); |
+ } |
+ return _data; |
+ } |
+ |
+ set channelMessage(FlogChannelMessageEntryDetails value) { |
+ _tag = FlogEntryDetailsTag.channelMessage; |
+ _data = value; |
+ } |
+ |
+ static FlogEntryDetails decode(bindings.Decoder decoder0, int offset) { |
+ int size = decoder0.decodeUint32(offset); |
+ if (size == 0) { |
+ return null; |
+ } |
+ FlogEntryDetails result = new FlogEntryDetails(); |
+ |
+ |
+ FlogEntryDetailsTag tag = _intToTag[decoder0.decodeUint32(offset + 4)]; |
+ switch (tag) { |
+ case FlogEntryDetailsTag.channelCreation: |
+ |
+ var decoder1 = decoder0.decodePointer(offset + 8, false); |
+ result.channelCreation = FlogChannelCreationEntryDetails.decode(decoder1); |
+ break; |
+ case FlogEntryDetailsTag.channelMessage: |
+ |
+ var decoder1 = decoder0.decodePointer(offset + 8, false); |
+ result.channelMessage = FlogChannelMessageEntryDetails.decode(decoder1); |
+ break; |
+ default: |
+ throw new bindings.MojoCodecError("Bad union tag: $tag"); |
+ } |
+ |
+ return result; |
+ } |
+ |
+ void encode(bindings.Encoder encoder0, int offset) { |
+ |
+ encoder0.encodeUint32(16, offset); |
+ encoder0.encodeUint32(_tagToInt[_tag], offset + 4); |
+ switch (_tag) { |
+ case FlogEntryDetailsTag.channelCreation: |
+ encoder0.encodeStruct(channelCreation, offset + 8, false); |
+ break; |
+ case FlogEntryDetailsTag.channelMessage: |
+ encoder0.encodeStruct(channelMessage, offset + 8, false); |
+ break; |
+ default: |
+ throw new bindings.MojoCodecError("Bad union tag: $_tag"); |
+ } |
+ } |
+ |
+ String toString() { |
+ String result = "FlogEntryDetails("; |
+ switch (_tag) { |
+ case FlogEntryDetailsTag.channelCreation: |
+ result += "channelCreation"; |
+ break; |
+ case FlogEntryDetailsTag.channelMessage: |
+ result += "channelMessage"; |
+ break; |
+ default: |
+ result += "unknown"; |
+ } |
+ result += ": $_data)"; |
+ return result; |
+ } |
+} |
+const int _flogServiceMethodCreateLoggerName = 0; |
+const int _flogServiceMethodGetLogDescriptionsName = 1; |
+const int _flogServiceMethodCreateReaderName = 2; |
+ |
+class _FlogServiceServiceDescription implements service_describer.ServiceDescription { |
+ dynamic getTopLevelInterface([Function responseFactory]) => |
+ responseFactory(null); |
+ |
+ dynamic getTypeDefinition(String typeKey, [Function responseFactory]) => |
+ responseFactory(null); |
+ |
+ dynamic getAllTypeDefinitions([Function responseFactory]) => |
+ responseFactory(null); |
+} |
+ |
+abstract class FlogService { |
+ static const String serviceName = "mojo::flog::FlogService"; |
+ |
+ static service_describer.ServiceDescription _cachedServiceDescription; |
+ static service_describer.ServiceDescription get serviceDescription { |
+ if (_cachedServiceDescription == null) { |
+ _cachedServiceDescription = new _FlogServiceServiceDescription(); |
+ } |
+ return _cachedServiceDescription; |
+ } |
+ |
+ static FlogServiceProxy connectToService( |
+ bindings.ServiceConnector s, String url, [String serviceName]) { |
+ FlogServiceProxy p = new FlogServiceProxy.unbound(); |
+ String name = serviceName ?? FlogService.serviceName; |
+ if ((name == null) || name.isEmpty) { |
+ throw new core.MojoApiError( |
+ "If an interface has no ServiceName, then one must be provided."); |
+ } |
+ s.connectToService(url, p, name); |
+ return p; |
+ } |
+ void createLogger(FlogLoggerInterfaceRequest logger, String label); |
+ dynamic getLogDescriptions([Function responseFactory = null]); |
+ void createReader(FlogReaderInterfaceRequest reader, int logId); |
+} |
+ |
+abstract class FlogServiceInterface |
+ implements bindings.MojoInterface<FlogService>, |
+ FlogService { |
+ factory FlogServiceInterface([FlogService impl]) => |
+ new FlogServiceStub.unbound(impl); |
+ factory FlogServiceInterface.fromEndpoint( |
+ core.MojoMessagePipeEndpoint endpoint, |
+ [FlogService impl]) => |
+ new FlogServiceStub.fromEndpoint(endpoint, impl); |
+} |
+ |
+abstract class FlogServiceInterfaceRequest |
+ implements bindings.MojoInterface<FlogService>, |
+ FlogService { |
+ factory FlogServiceInterfaceRequest() => |
+ new FlogServiceProxy.unbound(); |
+} |
+ |
+class _FlogServiceProxyControl |
+ extends bindings.ProxyMessageHandler |
+ implements bindings.ProxyControl<FlogService> { |
+ _FlogServiceProxyControl.fromEndpoint( |
+ core.MojoMessagePipeEndpoint endpoint) : super.fromEndpoint(endpoint); |
+ |
+ _FlogServiceProxyControl.fromHandle( |
+ core.MojoHandle handle) : super.fromHandle(handle); |
+ |
+ _FlogServiceProxyControl.unbound() : super.unbound(); |
+ |
+ String get serviceName => FlogService.serviceName; |
+ |
+ void handleResponse(bindings.ServiceMessage message) { |
+ switch (message.header.type) { |
+ case _flogServiceMethodGetLogDescriptionsName: |
+ var r = FlogServiceGetLogDescriptionsResponseParams.deserialize( |
+ message.payload); |
+ if (!message.header.hasRequestId) { |
+ proxyError("Expected a message with a valid request Id."); |
+ return; |
+ } |
+ Completer c = completerMap[message.header.requestId]; |
+ if (c == null) { |
+ proxyError( |
+ "Message had unknown request Id: ${message.header.requestId}"); |
+ return; |
+ } |
+ completerMap.remove(message.header.requestId); |
+ if (c.isCompleted) { |
+ proxyError("Response completer already completed"); |
+ return; |
+ } |
+ c.complete(r); |
+ break; |
+ default: |
+ proxyError("Unexpected message type: ${message.header.type}"); |
+ close(immediate: true); |
+ break; |
+ } |
+ } |
+ |
+ FlogService get impl => null; |
+ set impl(FlogService _) { |
+ throw new core.MojoApiError("The impl of a Proxy cannot be set."); |
+ } |
+ |
+ @override |
+ String toString() { |
+ var superString = super.toString(); |
+ return "_FlogServiceProxyControl($superString)"; |
+ } |
+} |
+ |
+class FlogServiceProxy |
+ extends bindings.Proxy<FlogService> |
+ implements FlogService, |
+ FlogServiceInterface, |
+ FlogServiceInterfaceRequest { |
+ FlogServiceProxy.fromEndpoint( |
+ core.MojoMessagePipeEndpoint endpoint) |
+ : super(new _FlogServiceProxyControl.fromEndpoint(endpoint)); |
+ |
+ FlogServiceProxy.fromHandle(core.MojoHandle handle) |
+ : super(new _FlogServiceProxyControl.fromHandle(handle)); |
+ |
+ FlogServiceProxy.unbound() |
+ : super(new _FlogServiceProxyControl.unbound()); |
+ |
+ static FlogServiceProxy newFromEndpoint( |
+ core.MojoMessagePipeEndpoint endpoint) { |
+ assert(endpoint.setDescription("For FlogServiceProxy")); |
+ return new FlogServiceProxy.fromEndpoint(endpoint); |
+ } |
+ |
+ |
+ void createLogger(FlogLoggerInterfaceRequest logger, String label) { |
+ if (!ctrl.isBound) { |
+ ctrl.proxyError("The Proxy is closed."); |
+ return; |
+ } |
+ var params = new _FlogServiceCreateLoggerParams(); |
+ params.logger = logger; |
+ params.label = label; |
+ ctrl.sendMessage(params, |
+ _flogServiceMethodCreateLoggerName); |
+ } |
+ dynamic getLogDescriptions([Function responseFactory = null]) { |
+ var params = new _FlogServiceGetLogDescriptionsParams(); |
+ return ctrl.sendMessageWithRequestId( |
+ params, |
+ _flogServiceMethodGetLogDescriptionsName, |
+ -1, |
+ bindings.MessageHeader.kMessageExpectsResponse); |
+ } |
+ void createReader(FlogReaderInterfaceRequest reader, int logId) { |
+ if (!ctrl.isBound) { |
+ ctrl.proxyError("The Proxy is closed."); |
+ return; |
+ } |
+ var params = new _FlogServiceCreateReaderParams(); |
+ params.reader = reader; |
+ params.logId = logId; |
+ ctrl.sendMessage(params, |
+ _flogServiceMethodCreateReaderName); |
+ } |
+} |
+ |
+class _FlogServiceStubControl |
+ extends bindings.StubMessageHandler |
+ implements bindings.StubControl<FlogService> { |
+ FlogService _impl; |
+ |
+ _FlogServiceStubControl.fromEndpoint( |
+ core.MojoMessagePipeEndpoint endpoint, [FlogService impl]) |
+ : super.fromEndpoint(endpoint, autoBegin: impl != null) { |
+ _impl = impl; |
+ } |
+ |
+ _FlogServiceStubControl.fromHandle( |
+ core.MojoHandle handle, [FlogService impl]) |
+ : super.fromHandle(handle, autoBegin: impl != null) { |
+ _impl = impl; |
+ } |
+ |
+ _FlogServiceStubControl.unbound([this._impl]) : super.unbound(); |
+ |
+ String get serviceName => FlogService.serviceName; |
+ |
+ |
+ FlogServiceGetLogDescriptionsResponseParams _flogServiceGetLogDescriptionsResponseParamsFactory(List<FlogDescription> descriptions) { |
+ var result = new FlogServiceGetLogDescriptionsResponseParams(); |
+ result.descriptions = descriptions; |
+ return result; |
+ } |
+ |
+ dynamic handleMessage(bindings.ServiceMessage message) { |
+ if (bindings.ControlMessageHandler.isControlMessage(message)) { |
+ return bindings.ControlMessageHandler.handleMessage(this, |
+ 0, |
+ message); |
+ } |
+ if (_impl == null) { |
+ throw new core.MojoApiError("$this has no implementation set"); |
+ } |
+ switch (message.header.type) { |
+ case _flogServiceMethodCreateLoggerName: |
+ var params = _FlogServiceCreateLoggerParams.deserialize( |
+ message.payload); |
+ _impl.createLogger(params.logger, params.label); |
+ break; |
+ case _flogServiceMethodGetLogDescriptionsName: |
+ var response = _impl.getLogDescriptions(_flogServiceGetLogDescriptionsResponseParamsFactory); |
+ if (response is Future) { |
+ return response.then((response) { |
+ if (response != null) { |
+ return buildResponseWithId( |
+ response, |
+ _flogServiceMethodGetLogDescriptionsName, |
+ message.header.requestId, |
+ bindings.MessageHeader.kMessageIsResponse); |
+ } |
+ }); |
+ } else if (response != null) { |
+ return buildResponseWithId( |
+ response, |
+ _flogServiceMethodGetLogDescriptionsName, |
+ message.header.requestId, |
+ bindings.MessageHeader.kMessageIsResponse); |
+ } |
+ break; |
+ case _flogServiceMethodCreateReaderName: |
+ var params = _FlogServiceCreateReaderParams.deserialize( |
+ message.payload); |
+ _impl.createReader(params.reader, params.logId); |
+ break; |
+ default: |
+ throw new bindings.MojoCodecError("Unexpected message name"); |
+ break; |
+ } |
+ return null; |
+ } |
+ |
+ FlogService get impl => _impl; |
+ set impl(FlogService d) { |
+ if (d == null) { |
+ throw new core.MojoApiError("$this: Cannot set a null implementation"); |
+ } |
+ if (isBound && (_impl == null)) { |
+ beginHandlingEvents(); |
+ } |
+ _impl = d; |
+ } |
+ |
+ @override |
+ void bind(core.MojoMessagePipeEndpoint endpoint) { |
+ super.bind(endpoint); |
+ if (!isOpen && (_impl != null)) { |
+ beginHandlingEvents(); |
+ } |
+ } |
+ |
+ @override |
+ String toString() { |
+ var superString = super.toString(); |
+ return "_FlogServiceStubControl($superString)"; |
+ } |
+ |
+ int get version => 0; |
+} |
+ |
+class FlogServiceStub |
+ extends bindings.Stub<FlogService> |
+ implements FlogService, |
+ FlogServiceInterface, |
+ FlogServiceInterfaceRequest { |
+ FlogServiceStub.unbound([FlogService impl]) |
+ : super(new _FlogServiceStubControl.unbound(impl)); |
+ |
+ FlogServiceStub.fromEndpoint( |
+ core.MojoMessagePipeEndpoint endpoint, [FlogService impl]) |
+ : super(new _FlogServiceStubControl.fromEndpoint(endpoint, impl)); |
+ |
+ FlogServiceStub.fromHandle( |
+ core.MojoHandle handle, [FlogService impl]) |
+ : super(new _FlogServiceStubControl.fromHandle(handle, impl)); |
+ |
+ static FlogServiceStub newFromEndpoint( |
+ core.MojoMessagePipeEndpoint endpoint) { |
+ assert(endpoint.setDescription("For FlogServiceStub")); |
+ return new FlogServiceStub.fromEndpoint(endpoint); |
+ } |
+ |
+ |
+ void createLogger(FlogLoggerInterfaceRequest logger, String label) { |
+ return impl.createLogger(logger, label); |
+ } |
+ dynamic getLogDescriptions([Function responseFactory = null]) { |
+ return impl.getLogDescriptions(responseFactory); |
+ } |
+ void createReader(FlogReaderInterfaceRequest reader, int logId) { |
+ return impl.createReader(reader, logId); |
+ } |
+} |
+ |
+const int _flogLoggerMethodLogChannelCreationName = 0; |
+const int _flogLoggerMethodLogChannelMessageName = 1; |
+const int _flogLoggerMethodLogChannelDeletionName = 2; |
+ |
+class _FlogLoggerServiceDescription implements service_describer.ServiceDescription { |
+ dynamic getTopLevelInterface([Function responseFactory]) => |
+ responseFactory(null); |
+ |
+ dynamic getTypeDefinition(String typeKey, [Function responseFactory]) => |
+ responseFactory(null); |
+ |
+ dynamic getAllTypeDefinitions([Function responseFactory]) => |
+ responseFactory(null); |
+} |
+ |
+abstract class FlogLogger { |
+ static const String serviceName = null; |
+ |
+ static service_describer.ServiceDescription _cachedServiceDescription; |
+ static service_describer.ServiceDescription get serviceDescription { |
+ if (_cachedServiceDescription == null) { |
+ _cachedServiceDescription = new _FlogLoggerServiceDescription(); |
+ } |
+ return _cachedServiceDescription; |
+ } |
+ |
+ static FlogLoggerProxy connectToService( |
+ bindings.ServiceConnector s, String url, [String serviceName]) { |
+ FlogLoggerProxy p = new FlogLoggerProxy.unbound(); |
+ String name = serviceName ?? FlogLogger.serviceName; |
+ if ((name == null) || name.isEmpty) { |
+ throw new core.MojoApiError( |
+ "If an interface has no ServiceName, then one must be provided."); |
+ } |
+ s.connectToService(url, p, name); |
+ return p; |
+ } |
+ void logChannelCreation(int timeUs, int channelId, String typeName); |
+ void logChannelMessage(int timeUs, int channelId, List<int> data); |
+ void logChannelDeletion(int timeUs, int channelId); |
+} |
+ |
+abstract class FlogLoggerInterface |
+ implements bindings.MojoInterface<FlogLogger>, |
+ FlogLogger { |
+ factory FlogLoggerInterface([FlogLogger impl]) => |
+ new FlogLoggerStub.unbound(impl); |
+ factory FlogLoggerInterface.fromEndpoint( |
+ core.MojoMessagePipeEndpoint endpoint, |
+ [FlogLogger impl]) => |
+ new FlogLoggerStub.fromEndpoint(endpoint, impl); |
+} |
+ |
+abstract class FlogLoggerInterfaceRequest |
+ implements bindings.MojoInterface<FlogLogger>, |
+ FlogLogger { |
+ factory FlogLoggerInterfaceRequest() => |
+ new FlogLoggerProxy.unbound(); |
+} |
+ |
+class _FlogLoggerProxyControl |
+ extends bindings.ProxyMessageHandler |
+ implements bindings.ProxyControl<FlogLogger> { |
+ _FlogLoggerProxyControl.fromEndpoint( |
+ core.MojoMessagePipeEndpoint endpoint) : super.fromEndpoint(endpoint); |
+ |
+ _FlogLoggerProxyControl.fromHandle( |
+ core.MojoHandle handle) : super.fromHandle(handle); |
+ |
+ _FlogLoggerProxyControl.unbound() : super.unbound(); |
+ |
+ String get serviceName => FlogLogger.serviceName; |
+ |
+ void handleResponse(bindings.ServiceMessage message) { |
+ switch (message.header.type) { |
+ default: |
+ proxyError("Unexpected message type: ${message.header.type}"); |
+ close(immediate: true); |
+ break; |
+ } |
+ } |
+ |
+ FlogLogger get impl => null; |
+ set impl(FlogLogger _) { |
+ throw new core.MojoApiError("The impl of a Proxy cannot be set."); |
+ } |
+ |
+ @override |
+ String toString() { |
+ var superString = super.toString(); |
+ return "_FlogLoggerProxyControl($superString)"; |
+ } |
+} |
+ |
+class FlogLoggerProxy |
+ extends bindings.Proxy<FlogLogger> |
+ implements FlogLogger, |
+ FlogLoggerInterface, |
+ FlogLoggerInterfaceRequest { |
+ FlogLoggerProxy.fromEndpoint( |
+ core.MojoMessagePipeEndpoint endpoint) |
+ : super(new _FlogLoggerProxyControl.fromEndpoint(endpoint)); |
+ |
+ FlogLoggerProxy.fromHandle(core.MojoHandle handle) |
+ : super(new _FlogLoggerProxyControl.fromHandle(handle)); |
+ |
+ FlogLoggerProxy.unbound() |
+ : super(new _FlogLoggerProxyControl.unbound()); |
+ |
+ static FlogLoggerProxy newFromEndpoint( |
+ core.MojoMessagePipeEndpoint endpoint) { |
+ assert(endpoint.setDescription("For FlogLoggerProxy")); |
+ return new FlogLoggerProxy.fromEndpoint(endpoint); |
+ } |
+ |
+ |
+ void logChannelCreation(int timeUs, int channelId, String typeName) { |
+ if (!ctrl.isBound) { |
+ ctrl.proxyError("The Proxy is closed."); |
+ return; |
+ } |
+ var params = new _FlogLoggerLogChannelCreationParams(); |
+ params.timeUs = timeUs; |
+ params.channelId = channelId; |
+ params.typeName = typeName; |
+ ctrl.sendMessage(params, |
+ _flogLoggerMethodLogChannelCreationName); |
+ } |
+ void logChannelMessage(int timeUs, int channelId, List<int> data) { |
+ if (!ctrl.isBound) { |
+ ctrl.proxyError("The Proxy is closed."); |
+ return; |
+ } |
+ var params = new _FlogLoggerLogChannelMessageParams(); |
+ params.timeUs = timeUs; |
+ params.channelId = channelId; |
+ params.data = data; |
+ ctrl.sendMessage(params, |
+ _flogLoggerMethodLogChannelMessageName); |
+ } |
+ void logChannelDeletion(int timeUs, int channelId) { |
+ if (!ctrl.isBound) { |
+ ctrl.proxyError("The Proxy is closed."); |
+ return; |
+ } |
+ var params = new _FlogLoggerLogChannelDeletionParams(); |
+ params.timeUs = timeUs; |
+ params.channelId = channelId; |
+ ctrl.sendMessage(params, |
+ _flogLoggerMethodLogChannelDeletionName); |
+ } |
+} |
+ |
+class _FlogLoggerStubControl |
+ extends bindings.StubMessageHandler |
+ implements bindings.StubControl<FlogLogger> { |
+ FlogLogger _impl; |
+ |
+ _FlogLoggerStubControl.fromEndpoint( |
+ core.MojoMessagePipeEndpoint endpoint, [FlogLogger impl]) |
+ : super.fromEndpoint(endpoint, autoBegin: impl != null) { |
+ _impl = impl; |
+ } |
+ |
+ _FlogLoggerStubControl.fromHandle( |
+ core.MojoHandle handle, [FlogLogger impl]) |
+ : super.fromHandle(handle, autoBegin: impl != null) { |
+ _impl = impl; |
+ } |
+ |
+ _FlogLoggerStubControl.unbound([this._impl]) : super.unbound(); |
+ |
+ String get serviceName => FlogLogger.serviceName; |
+ |
+ |
+ |
+ dynamic handleMessage(bindings.ServiceMessage message) { |
+ if (bindings.ControlMessageHandler.isControlMessage(message)) { |
+ return bindings.ControlMessageHandler.handleMessage(this, |
+ 0, |
+ message); |
+ } |
+ if (_impl == null) { |
+ throw new core.MojoApiError("$this has no implementation set"); |
+ } |
+ switch (message.header.type) { |
+ case _flogLoggerMethodLogChannelCreationName: |
+ var params = _FlogLoggerLogChannelCreationParams.deserialize( |
+ message.payload); |
+ _impl.logChannelCreation(params.timeUs, params.channelId, params.typeName); |
+ break; |
+ case _flogLoggerMethodLogChannelMessageName: |
+ var params = _FlogLoggerLogChannelMessageParams.deserialize( |
+ message.payload); |
+ _impl.logChannelMessage(params.timeUs, params.channelId, params.data); |
+ break; |
+ case _flogLoggerMethodLogChannelDeletionName: |
+ var params = _FlogLoggerLogChannelDeletionParams.deserialize( |
+ message.payload); |
+ _impl.logChannelDeletion(params.timeUs, params.channelId); |
+ break; |
+ default: |
+ throw new bindings.MojoCodecError("Unexpected message name"); |
+ break; |
+ } |
+ return null; |
+ } |
+ |
+ FlogLogger get impl => _impl; |
+ set impl(FlogLogger d) { |
+ if (d == null) { |
+ throw new core.MojoApiError("$this: Cannot set a null implementation"); |
+ } |
+ if (isBound && (_impl == null)) { |
+ beginHandlingEvents(); |
+ } |
+ _impl = d; |
+ } |
+ |
+ @override |
+ void bind(core.MojoMessagePipeEndpoint endpoint) { |
+ super.bind(endpoint); |
+ if (!isOpen && (_impl != null)) { |
+ beginHandlingEvents(); |
+ } |
+ } |
+ |
+ @override |
+ String toString() { |
+ var superString = super.toString(); |
+ return "_FlogLoggerStubControl($superString)"; |
+ } |
+ |
+ int get version => 0; |
+} |
+ |
+class FlogLoggerStub |
+ extends bindings.Stub<FlogLogger> |
+ implements FlogLogger, |
+ FlogLoggerInterface, |
+ FlogLoggerInterfaceRequest { |
+ FlogLoggerStub.unbound([FlogLogger impl]) |
+ : super(new _FlogLoggerStubControl.unbound(impl)); |
+ |
+ FlogLoggerStub.fromEndpoint( |
+ core.MojoMessagePipeEndpoint endpoint, [FlogLogger impl]) |
+ : super(new _FlogLoggerStubControl.fromEndpoint(endpoint, impl)); |
+ |
+ FlogLoggerStub.fromHandle( |
+ core.MojoHandle handle, [FlogLogger impl]) |
+ : super(new _FlogLoggerStubControl.fromHandle(handle, impl)); |
+ |
+ static FlogLoggerStub newFromEndpoint( |
+ core.MojoMessagePipeEndpoint endpoint) { |
+ assert(endpoint.setDescription("For FlogLoggerStub")); |
+ return new FlogLoggerStub.fromEndpoint(endpoint); |
+ } |
+ |
+ |
+ void logChannelCreation(int timeUs, int channelId, String typeName) { |
+ return impl.logChannelCreation(timeUs, channelId, typeName); |
+ } |
+ void logChannelMessage(int timeUs, int channelId, List<int> data) { |
+ return impl.logChannelMessage(timeUs, channelId, data); |
+ } |
+ void logChannelDeletion(int timeUs, int channelId) { |
+ return impl.logChannelDeletion(timeUs, channelId); |
+ } |
+} |
+ |
+const int _flogReaderMethodGetEntriesName = 0; |
+ |
+class _FlogReaderServiceDescription implements service_describer.ServiceDescription { |
+ dynamic getTopLevelInterface([Function responseFactory]) => |
+ responseFactory(null); |
+ |
+ dynamic getTypeDefinition(String typeKey, [Function responseFactory]) => |
+ responseFactory(null); |
+ |
+ dynamic getAllTypeDefinitions([Function responseFactory]) => |
+ responseFactory(null); |
+} |
+ |
+abstract class FlogReader { |
+ static const String serviceName = null; |
+ |
+ static service_describer.ServiceDescription _cachedServiceDescription; |
+ static service_describer.ServiceDescription get serviceDescription { |
+ if (_cachedServiceDescription == null) { |
+ _cachedServiceDescription = new _FlogReaderServiceDescription(); |
+ } |
+ return _cachedServiceDescription; |
+ } |
+ |
+ static FlogReaderProxy connectToService( |
+ bindings.ServiceConnector s, String url, [String serviceName]) { |
+ FlogReaderProxy p = new FlogReaderProxy.unbound(); |
+ String name = serviceName ?? FlogReader.serviceName; |
+ if ((name == null) || name.isEmpty) { |
+ throw new core.MojoApiError( |
+ "If an interface has no ServiceName, then one must be provided."); |
+ } |
+ s.connectToService(url, p, name); |
+ return p; |
+ } |
+ dynamic getEntries(int startIndex,int maxCount,[Function responseFactory = null]); |
+} |
+ |
+abstract class FlogReaderInterface |
+ implements bindings.MojoInterface<FlogReader>, |
+ FlogReader { |
+ factory FlogReaderInterface([FlogReader impl]) => |
+ new FlogReaderStub.unbound(impl); |
+ factory FlogReaderInterface.fromEndpoint( |
+ core.MojoMessagePipeEndpoint endpoint, |
+ [FlogReader impl]) => |
+ new FlogReaderStub.fromEndpoint(endpoint, impl); |
+} |
+ |
+abstract class FlogReaderInterfaceRequest |
+ implements bindings.MojoInterface<FlogReader>, |
+ FlogReader { |
+ factory FlogReaderInterfaceRequest() => |
+ new FlogReaderProxy.unbound(); |
+} |
+ |
+class _FlogReaderProxyControl |
+ extends bindings.ProxyMessageHandler |
+ implements bindings.ProxyControl<FlogReader> { |
+ _FlogReaderProxyControl.fromEndpoint( |
+ core.MojoMessagePipeEndpoint endpoint) : super.fromEndpoint(endpoint); |
+ |
+ _FlogReaderProxyControl.fromHandle( |
+ core.MojoHandle handle) : super.fromHandle(handle); |
+ |
+ _FlogReaderProxyControl.unbound() : super.unbound(); |
+ |
+ String get serviceName => FlogReader.serviceName; |
+ |
+ void handleResponse(bindings.ServiceMessage message) { |
+ switch (message.header.type) { |
+ case _flogReaderMethodGetEntriesName: |
+ var r = FlogReaderGetEntriesResponseParams.deserialize( |
+ message.payload); |
+ if (!message.header.hasRequestId) { |
+ proxyError("Expected a message with a valid request Id."); |
+ return; |
+ } |
+ Completer c = completerMap[message.header.requestId]; |
+ if (c == null) { |
+ proxyError( |
+ "Message had unknown request Id: ${message.header.requestId}"); |
+ return; |
+ } |
+ completerMap.remove(message.header.requestId); |
+ if (c.isCompleted) { |
+ proxyError("Response completer already completed"); |
+ return; |
+ } |
+ c.complete(r); |
+ break; |
+ default: |
+ proxyError("Unexpected message type: ${message.header.type}"); |
+ close(immediate: true); |
+ break; |
+ } |
+ } |
+ |
+ FlogReader get impl => null; |
+ set impl(FlogReader _) { |
+ throw new core.MojoApiError("The impl of a Proxy cannot be set."); |
+ } |
+ |
+ @override |
+ String toString() { |
+ var superString = super.toString(); |
+ return "_FlogReaderProxyControl($superString)"; |
+ } |
+} |
+ |
+class FlogReaderProxy |
+ extends bindings.Proxy<FlogReader> |
+ implements FlogReader, |
+ FlogReaderInterface, |
+ FlogReaderInterfaceRequest { |
+ FlogReaderProxy.fromEndpoint( |
+ core.MojoMessagePipeEndpoint endpoint) |
+ : super(new _FlogReaderProxyControl.fromEndpoint(endpoint)); |
+ |
+ FlogReaderProxy.fromHandle(core.MojoHandle handle) |
+ : super(new _FlogReaderProxyControl.fromHandle(handle)); |
+ |
+ FlogReaderProxy.unbound() |
+ : super(new _FlogReaderProxyControl.unbound()); |
+ |
+ static FlogReaderProxy newFromEndpoint( |
+ core.MojoMessagePipeEndpoint endpoint) { |
+ assert(endpoint.setDescription("For FlogReaderProxy")); |
+ return new FlogReaderProxy.fromEndpoint(endpoint); |
+ } |
+ |
+ |
+ dynamic getEntries(int startIndex,int maxCount,[Function responseFactory = null]) { |
+ var params = new _FlogReaderGetEntriesParams(); |
+ params.startIndex = startIndex; |
+ params.maxCount = maxCount; |
+ return ctrl.sendMessageWithRequestId( |
+ params, |
+ _flogReaderMethodGetEntriesName, |
+ -1, |
+ bindings.MessageHeader.kMessageExpectsResponse); |
+ } |
+} |
+ |
+class _FlogReaderStubControl |
+ extends bindings.StubMessageHandler |
+ implements bindings.StubControl<FlogReader> { |
+ FlogReader _impl; |
+ |
+ _FlogReaderStubControl.fromEndpoint( |
+ core.MojoMessagePipeEndpoint endpoint, [FlogReader impl]) |
+ : super.fromEndpoint(endpoint, autoBegin: impl != null) { |
+ _impl = impl; |
+ } |
+ |
+ _FlogReaderStubControl.fromHandle( |
+ core.MojoHandle handle, [FlogReader impl]) |
+ : super.fromHandle(handle, autoBegin: impl != null) { |
+ _impl = impl; |
+ } |
+ |
+ _FlogReaderStubControl.unbound([this._impl]) : super.unbound(); |
+ |
+ String get serviceName => FlogReader.serviceName; |
+ |
+ |
+ FlogReaderGetEntriesResponseParams _flogReaderGetEntriesResponseParamsFactory(List<FlogEntry> entries, int entryCount, bool open) { |
+ var result = new FlogReaderGetEntriesResponseParams(); |
+ result.entries = entries; |
+ result.entryCount = entryCount; |
+ result.open = open; |
+ return result; |
+ } |
+ |
+ dynamic handleMessage(bindings.ServiceMessage message) { |
+ if (bindings.ControlMessageHandler.isControlMessage(message)) { |
+ return bindings.ControlMessageHandler.handleMessage(this, |
+ 0, |
+ message); |
+ } |
+ if (_impl == null) { |
+ throw new core.MojoApiError("$this has no implementation set"); |
+ } |
+ switch (message.header.type) { |
+ case _flogReaderMethodGetEntriesName: |
+ var params = _FlogReaderGetEntriesParams.deserialize( |
+ message.payload); |
+ var response = _impl.getEntries(params.startIndex,params.maxCount,_flogReaderGetEntriesResponseParamsFactory); |
+ if (response is Future) { |
+ return response.then((response) { |
+ if (response != null) { |
+ return buildResponseWithId( |
+ response, |
+ _flogReaderMethodGetEntriesName, |
+ message.header.requestId, |
+ bindings.MessageHeader.kMessageIsResponse); |
+ } |
+ }); |
+ } else if (response != null) { |
+ return buildResponseWithId( |
+ response, |
+ _flogReaderMethodGetEntriesName, |
+ message.header.requestId, |
+ bindings.MessageHeader.kMessageIsResponse); |
+ } |
+ break; |
+ default: |
+ throw new bindings.MojoCodecError("Unexpected message name"); |
+ break; |
+ } |
+ return null; |
+ } |
+ |
+ FlogReader get impl => _impl; |
+ set impl(FlogReader d) { |
+ if (d == null) { |
+ throw new core.MojoApiError("$this: Cannot set a null implementation"); |
+ } |
+ if (isBound && (_impl == null)) { |
+ beginHandlingEvents(); |
+ } |
+ _impl = d; |
+ } |
+ |
+ @override |
+ void bind(core.MojoMessagePipeEndpoint endpoint) { |
+ super.bind(endpoint); |
+ if (!isOpen && (_impl != null)) { |
+ beginHandlingEvents(); |
+ } |
+ } |
+ |
+ @override |
+ String toString() { |
+ var superString = super.toString(); |
+ return "_FlogReaderStubControl($superString)"; |
+ } |
+ |
+ int get version => 0; |
+} |
+ |
+class FlogReaderStub |
+ extends bindings.Stub<FlogReader> |
+ implements FlogReader, |
+ FlogReaderInterface, |
+ FlogReaderInterfaceRequest { |
+ FlogReaderStub.unbound([FlogReader impl]) |
+ : super(new _FlogReaderStubControl.unbound(impl)); |
+ |
+ FlogReaderStub.fromEndpoint( |
+ core.MojoMessagePipeEndpoint endpoint, [FlogReader impl]) |
+ : super(new _FlogReaderStubControl.fromEndpoint(endpoint, impl)); |
+ |
+ FlogReaderStub.fromHandle( |
+ core.MojoHandle handle, [FlogReader impl]) |
+ : super(new _FlogReaderStubControl.fromHandle(handle, impl)); |
+ |
+ static FlogReaderStub newFromEndpoint( |
+ core.MojoMessagePipeEndpoint endpoint) { |
+ assert(endpoint.setDescription("For FlogReaderStub")); |
+ return new FlogReaderStub.fromEndpoint(endpoint); |
+ } |
+ |
+ |
+ dynamic getEntries(int startIndex,int maxCount,[Function responseFactory = null]) { |
+ return impl.getEntries(startIndex,maxCount,responseFactory); |
+ } |
+} |
+ |
+ |
+ |