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

Unified Diff: mojo/dart/packages/mojo_services/lib/mojo/media/media_transport.mojom.dart

Issue 1509323002: Mojom updates for Motown. (Closed) Base URL: https://github.com/domokit/mojo.git@master
Patch Set: sync with master Created 5 years ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: mojo/dart/packages/mojo_services/lib/mojo/media/media_transport.mojom.dart
diff --git a/mojo/dart/packages/_mojo_for_test_only/lib/sample/sample_factory.mojom.dart b/mojo/dart/packages/mojo_services/lib/mojo/media/media_transport.mojom.dart
similarity index 55%
copy from mojo/dart/packages/_mojo_for_test_only/lib/sample/sample_factory.mojom.dart
copy to mojo/dart/packages/mojo_services/lib/mojo/media/media_transport.mojom.dart
index c7d49217afde884dda298435cadc08c5de1da9ae..ebb8ad09a627e72a2ac38b1882470d20c8f994bc 100644
--- a/mojo/dart/packages/_mojo_for_test_only/lib/sample/sample_factory.mojom.dart
+++ b/mojo/dart/packages/mojo_services/lib/mojo/media/media_transport.mojom.dart
@@ -2,116 +2,27 @@
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
-library sample_factory_mojom;
+library media_transport_mojom;
import 'dart:async';
import 'package:mojo/bindings.dart' as bindings;
import 'package:mojo/core.dart' as core;
-import 'package:_mojo_for_test_only/imported/sample_import.mojom.dart' as sample_import_mojom;
+import 'package:mojo_services/mojo/media/media_common.mojom.dart' as media_common_mojom;
+import 'package:mojo_services/mojo/media/media_pipe.mojom.dart' as media_pipe_mojom;
+import 'package:mojo_services/mojo/media/media_types.mojom.dart' as media_types_mojom;
-class Request extends bindings.Struct {
- static const List<bindings.StructDataHeader> kVersions = const [
- const bindings.StructDataHeader(32, 0)
- ];
- int x = 0;
- core.MojoMessagePipeEndpoint pipe = null;
- List<core.MojoMessagePipeEndpoint> morePipes = null;
- Object obj = null;
-
- Request() : super(kVersions.last.size);
-
- static Request 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 Request decode(bindings.Decoder decoder0) {
- if (decoder0 == null) {
- return null;
- }
- Request result = new Request();
-
- 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.x = decoder0.decodeInt32(8);
- }
- if (mainDataHeader.version >= 0) {
-
- result.pipe = decoder0.decodeMessagePipeHandle(12, true);
- }
- if (mainDataHeader.version >= 0) {
-
- result.morePipes = decoder0.decodeMessagePipeHandleArray(16, bindings.kArrayNullable, bindings.kUnspecifiedArrayLength);
- }
- if (mainDataHeader.version >= 0) {
-
- result.obj = decoder0.decodeServiceInterface(24, true, sample_import_mojom.ImportedInterfaceProxy.newFromEndpoint);
- }
- return result;
- }
-
- void encode(bindings.Encoder encoder) {
- var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last);
-
- encoder0.encodeInt32(x, 8);
-
- encoder0.encodeMessagePipeHandle(pipe, 12, true);
-
- encoder0.encodeMessagePipeHandleArray(morePipes, 16, bindings.kArrayNullable, bindings.kUnspecifiedArrayLength);
-
- encoder0.encodeInterface(obj, 24, true);
- }
-
- String toString() {
- return "Request("
- "x: $x" ", "
- "pipe: $pipe" ", "
- "morePipes: $morePipes" ", "
- "obj: $obj" ")";
- }
-
- Map toJson() {
- throw new bindings.MojoCodecError(
- 'Object containing handles cannot be encoded to JSON.');
- }
-}
-
-
-class Response extends bindings.Struct {
+class MediaProducerConnectParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(16, 0)
];
- int x = 0;
- core.MojoMessagePipeEndpoint pipe = null;
+ Object consumer = null;
- Response() : super(kVersions.last.size);
+ MediaProducerConnectParams() : super(kVersions.last.size);
- static Response deserialize(bindings.Message message) {
+ static MediaProducerConnectParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -120,11 +31,11 @@ class Response extends bindings.Struct {
return result;
}
- static Response decode(bindings.Decoder decoder0) {
+ static MediaProducerConnectParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- Response result = new Response();
+ MediaProducerConnectParams result = new MediaProducerConnectParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -146,11 +57,7 @@ class Response extends bindings.Struct {
}
if (mainDataHeader.version >= 0) {
- result.x = decoder0.decodeInt32(8);
- }
- if (mainDataHeader.version >= 0) {
-
- result.pipe = decoder0.decodeMessagePipeHandle(12, true);
+ result.consumer = decoder0.decodeServiceInterface(8, false, MediaConsumerProxy.newFromEndpoint);
}
return result;
}
@@ -158,15 +65,12 @@ class Response extends bindings.Struct {
void encode(bindings.Encoder encoder) {
var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last);
- encoder0.encodeInt32(x, 8);
-
- encoder0.encodeMessagePipeHandle(pipe, 12, true);
+ encoder0.encodeInterface(consumer, 8, false);
}
String toString() {
- return "Response("
- "x: $x" ", "
- "pipe: $pipe" ")";
+ return "MediaProducerConnectParams("
+ "consumer: $consumer" ")";
}
Map toJson() {
@@ -176,15 +80,14 @@ class Response extends bindings.Struct {
}
-class NamedObjectSetNameParams extends bindings.Struct {
+class MediaProducerConnectResponseParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
- const bindings.StructDataHeader(16, 0)
+ const bindings.StructDataHeader(8, 0)
];
- String name = null;
- NamedObjectSetNameParams() : super(kVersions.last.size);
+ MediaProducerConnectResponseParams() : super(kVersions.last.size);
- static NamedObjectSetNameParams deserialize(bindings.Message message) {
+ static MediaProducerConnectResponseParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -193,11 +96,11 @@ class NamedObjectSetNameParams extends bindings.Struct {
return result;
}
- static NamedObjectSetNameParams decode(bindings.Decoder decoder0) {
+ static MediaProducerConnectResponseParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- NamedObjectSetNameParams result = new NamedObjectSetNameParams();
+ MediaProducerConnectResponseParams result = new MediaProducerConnectResponseParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -217,40 +120,32 @@ class NamedObjectSetNameParams extends bindings.Struct {
'Message newer than the last known version cannot be shorter than '
'required by the last known version.');
}
- if (mainDataHeader.version >= 0) {
-
- result.name = decoder0.decodeString(8, false);
- }
return result;
}
void encode(bindings.Encoder encoder) {
- var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last);
-
- encoder0.encodeString(name, 8, false);
+ encoder.getStructEncoderAtOffset(kVersions.last);
}
String toString() {
- return "NamedObjectSetNameParams("
- "name: $name" ")";
+ return "MediaProducerConnectResponseParams("")";
}
Map toJson() {
Map map = new Map();
- map["name"] = name;
return map;
}
}
-class NamedObjectGetNameParams extends bindings.Struct {
+class MediaProducerDisconnectParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(8, 0)
];
- NamedObjectGetNameParams() : super(kVersions.last.size);
+ MediaProducerDisconnectParams() : super(kVersions.last.size);
- static NamedObjectGetNameParams deserialize(bindings.Message message) {
+ static MediaProducerDisconnectParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -259,11 +154,11 @@ class NamedObjectGetNameParams extends bindings.Struct {
return result;
}
- static NamedObjectGetNameParams decode(bindings.Decoder decoder0) {
+ static MediaProducerDisconnectParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- NamedObjectGetNameParams result = new NamedObjectGetNameParams();
+ MediaProducerDisconnectParams result = new MediaProducerDisconnectParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -291,7 +186,7 @@ class NamedObjectGetNameParams extends bindings.Struct {
}
String toString() {
- return "NamedObjectGetNameParams("")";
+ return "MediaProducerDisconnectParams("")";
}
Map toJson() {
@@ -301,15 +196,14 @@ class NamedObjectGetNameParams extends bindings.Struct {
}
-class NamedObjectGetNameResponseParams extends bindings.Struct {
+class MediaPullModeProducerGetBufferParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
- const bindings.StructDataHeader(16, 0)
+ const bindings.StructDataHeader(8, 0)
];
- String name = null;
- NamedObjectGetNameResponseParams() : super(kVersions.last.size);
+ MediaPullModeProducerGetBufferParams() : super(kVersions.last.size);
- static NamedObjectGetNameResponseParams deserialize(bindings.Message message) {
+ static MediaPullModeProducerGetBufferParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -318,11 +212,11 @@ class NamedObjectGetNameResponseParams extends bindings.Struct {
return result;
}
- static NamedObjectGetNameResponseParams decode(bindings.Decoder decoder0) {
+ static MediaPullModeProducerGetBufferParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- NamedObjectGetNameResponseParams result = new NamedObjectGetNameResponseParams();
+ MediaPullModeProducerGetBufferParams result = new MediaPullModeProducerGetBufferParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -342,42 +236,33 @@ class NamedObjectGetNameResponseParams extends bindings.Struct {
'Message newer than the last known version cannot be shorter than '
'required by the last known version.');
}
- if (mainDataHeader.version >= 0) {
-
- result.name = decoder0.decodeString(8, false);
- }
return result;
}
void encode(bindings.Encoder encoder) {
- var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last);
-
- encoder0.encodeString(name, 8, false);
+ encoder.getStructEncoderAtOffset(kVersions.last);
}
String toString() {
- return "NamedObjectGetNameResponseParams("
- "name: $name" ")";
+ return "MediaPullModeProducerGetBufferParams("")";
}
Map toJson() {
Map map = new Map();
- map["name"] = name;
return map;
}
}
-class FactoryDoStuffParams extends bindings.Struct {
+class MediaPullModeProducerGetBufferResponseParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
- const bindings.StructDataHeader(24, 0)
+ const bindings.StructDataHeader(16, 0)
];
- Request request = null;
- core.MojoMessagePipeEndpoint pipe = null;
+ core.MojoSharedBuffer buffer = null;
- FactoryDoStuffParams() : super(kVersions.last.size);
+ MediaPullModeProducerGetBufferResponseParams() : super(kVersions.last.size);
- static FactoryDoStuffParams deserialize(bindings.Message message) {
+ static MediaPullModeProducerGetBufferResponseParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -386,11 +271,11 @@ class FactoryDoStuffParams extends bindings.Struct {
return result;
}
- static FactoryDoStuffParams decode(bindings.Decoder decoder0) {
+ static MediaPullModeProducerGetBufferResponseParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- FactoryDoStuffParams result = new FactoryDoStuffParams();
+ MediaPullModeProducerGetBufferResponseParams result = new MediaPullModeProducerGetBufferResponseParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -412,12 +297,7 @@ class FactoryDoStuffParams extends bindings.Struct {
}
if (mainDataHeader.version >= 0) {
- var decoder1 = decoder0.decodePointer(8, false);
- result.request = Request.decode(decoder1);
- }
- if (mainDataHeader.version >= 0) {
-
- result.pipe = decoder0.decodeMessagePipeHandle(16, true);
+ result.buffer = decoder0.decodeSharedBufferHandle(8, false);
}
return result;
}
@@ -425,15 +305,12 @@ class FactoryDoStuffParams extends bindings.Struct {
void encode(bindings.Encoder encoder) {
var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last);
- encoder0.encodeStruct(request, 8, false);
-
- encoder0.encodeMessagePipeHandle(pipe, 16, true);
+ encoder0.encodeSharedBufferHandle(buffer, 8, false);
}
String toString() {
- return "FactoryDoStuffParams("
- "request: $request" ", "
- "pipe: $pipe" ")";
+ return "MediaPullModeProducerGetBufferResponseParams("
+ "buffer: $buffer" ")";
}
Map toJson() {
@@ -443,16 +320,15 @@ class FactoryDoStuffParams extends bindings.Struct {
}
-class FactoryDoStuffResponseParams extends bindings.Struct {
+class MediaPullModeProducerPullPacketParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
- const bindings.StructDataHeader(24, 0)
+ const bindings.StructDataHeader(16, 0)
];
- Response response = null;
- String text = null;
+ media_pipe_mojom.MediaPacket toRelease = null;
- FactoryDoStuffResponseParams() : super(kVersions.last.size);
+ MediaPullModeProducerPullPacketParams() : super(kVersions.last.size);
- static FactoryDoStuffResponseParams deserialize(bindings.Message message) {
+ static MediaPullModeProducerPullPacketParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -461,11 +337,11 @@ class FactoryDoStuffResponseParams extends bindings.Struct {
return result;
}
- static FactoryDoStuffResponseParams decode(bindings.Decoder decoder0) {
+ static MediaPullModeProducerPullPacketParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- FactoryDoStuffResponseParams result = new FactoryDoStuffResponseParams();
+ MediaPullModeProducerPullPacketParams result = new MediaPullModeProducerPullPacketParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -487,12 +363,8 @@ class FactoryDoStuffResponseParams extends bindings.Struct {
}
if (mainDataHeader.version >= 0) {
- var decoder1 = decoder0.decodePointer(8, false);
- result.response = Response.decode(decoder1);
- }
- if (mainDataHeader.version >= 0) {
-
- result.text = decoder0.decodeString(16, false);
+ var decoder1 = decoder0.decodePointer(8, true);
+ result.toRelease = media_pipe_mojom.MediaPacket.decode(decoder1);
}
return result;
}
@@ -500,33 +372,31 @@ class FactoryDoStuffResponseParams extends bindings.Struct {
void encode(bindings.Encoder encoder) {
var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last);
- encoder0.encodeStruct(response, 8, false);
-
- encoder0.encodeString(text, 16, false);
+ encoder0.encodeStruct(toRelease, 8, true);
}
String toString() {
- return "FactoryDoStuffResponseParams("
- "response: $response" ", "
- "text: $text" ")";
+ return "MediaPullModeProducerPullPacketParams("
+ "toRelease: $toRelease" ")";
}
Map toJson() {
- throw new bindings.MojoCodecError(
- 'Object containing handles cannot be encoded to JSON.');
+ Map map = new Map();
+ map["toRelease"] = toRelease;
+ return map;
}
}
-class FactoryDoStuff2Params extends bindings.Struct {
+class MediaPullModeProducerPullPacketResponseParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(16, 0)
];
- core.MojoDataPipeConsumer pipe = null;
+ media_pipe_mojom.MediaPacket packet = null;
- FactoryDoStuff2Params() : super(kVersions.last.size);
+ MediaPullModeProducerPullPacketResponseParams() : super(kVersions.last.size);
- static FactoryDoStuff2Params deserialize(bindings.Message message) {
+ static MediaPullModeProducerPullPacketResponseParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -535,11 +405,11 @@ class FactoryDoStuff2Params extends bindings.Struct {
return result;
}
- static FactoryDoStuff2Params decode(bindings.Decoder decoder0) {
+ static MediaPullModeProducerPullPacketResponseParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- FactoryDoStuff2Params result = new FactoryDoStuff2Params();
+ MediaPullModeProducerPullPacketResponseParams result = new MediaPullModeProducerPullPacketResponseParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -561,7 +431,8 @@ class FactoryDoStuff2Params extends bindings.Struct {
}
if (mainDataHeader.version >= 0) {
- result.pipe = decoder0.decodeConsumerHandle(8, false);
+ var decoder1 = decoder0.decodePointer(8, false);
+ result.packet = media_pipe_mojom.MediaPacket.decode(decoder1);
}
return result;
}
@@ -569,30 +440,31 @@ class FactoryDoStuff2Params extends bindings.Struct {
void encode(bindings.Encoder encoder) {
var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last);
- encoder0.encodeConsumerHandle(pipe, 8, false);
+ encoder0.encodeStruct(packet, 8, false);
}
String toString() {
- return "FactoryDoStuff2Params("
- "pipe: $pipe" ")";
+ return "MediaPullModeProducerPullPacketResponseParams("
+ "packet: $packet" ")";
}
Map toJson() {
- throw new bindings.MojoCodecError(
- 'Object containing handles cannot be encoded to JSON.');
+ Map map = new Map();
+ map["packet"] = packet;
+ return map;
}
}
-class FactoryDoStuff2ResponseParams extends bindings.Struct {
+class MediaPullModeProducerReleasePacketParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(16, 0)
];
- String text = null;
+ media_pipe_mojom.MediaPacket toRelease = null;
- FactoryDoStuff2ResponseParams() : super(kVersions.last.size);
+ MediaPullModeProducerReleasePacketParams() : super(kVersions.last.size);
- static FactoryDoStuff2ResponseParams deserialize(bindings.Message message) {
+ static MediaPullModeProducerReleasePacketParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -601,11 +473,11 @@ class FactoryDoStuff2ResponseParams extends bindings.Struct {
return result;
}
- static FactoryDoStuff2ResponseParams decode(bindings.Decoder decoder0) {
+ static MediaPullModeProducerReleasePacketParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- FactoryDoStuff2ResponseParams result = new FactoryDoStuff2ResponseParams();
+ MediaPullModeProducerReleasePacketParams result = new MediaPullModeProducerReleasePacketParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -627,7 +499,8 @@ class FactoryDoStuff2ResponseParams extends bindings.Struct {
}
if (mainDataHeader.version >= 0) {
- result.text = decoder0.decodeString(8, false);
+ var decoder1 = decoder0.decodePointer(8, false);
+ result.toRelease = media_pipe_mojom.MediaPacket.decode(decoder1);
}
return result;
}
@@ -635,31 +508,32 @@ class FactoryDoStuff2ResponseParams extends bindings.Struct {
void encode(bindings.Encoder encoder) {
var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last);
- encoder0.encodeString(text, 8, false);
+ encoder0.encodeStruct(toRelease, 8, false);
}
String toString() {
- return "FactoryDoStuff2ResponseParams("
- "text: $text" ")";
+ return "MediaPullModeProducerReleasePacketParams("
+ "toRelease: $toRelease" ")";
}
Map toJson() {
Map map = new Map();
- map["text"] = text;
+ map["toRelease"] = toRelease;
return map;
}
}
-class FactoryCreateNamedObjectParams extends bindings.Struct {
+class MediaConsumerSetBufferParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
- const bindings.StructDataHeader(16, 0)
+ const bindings.StructDataHeader(24, 0)
];
- Object obj = null;
+ core.MojoSharedBuffer buffer = null;
+ int size = 0;
- FactoryCreateNamedObjectParams() : super(kVersions.last.size);
+ MediaConsumerSetBufferParams() : super(kVersions.last.size);
- static FactoryCreateNamedObjectParams deserialize(bindings.Message message) {
+ static MediaConsumerSetBufferParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -668,11 +542,11 @@ class FactoryCreateNamedObjectParams extends bindings.Struct {
return result;
}
- static FactoryCreateNamedObjectParams decode(bindings.Decoder decoder0) {
+ static MediaConsumerSetBufferParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- FactoryCreateNamedObjectParams result = new FactoryCreateNamedObjectParams();
+ MediaConsumerSetBufferParams result = new MediaConsumerSetBufferParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -694,73 +568,11 @@ class FactoryCreateNamedObjectParams extends bindings.Struct {
}
if (mainDataHeader.version >= 0) {
- result.obj = decoder0.decodeInterfaceRequest(8, false, NamedObjectStub.newFromEndpoint);
- }
- return result;
- }
-
- void encode(bindings.Encoder encoder) {
- var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last);
-
- encoder0.encodeInterfaceRequest(obj, 8, false);
- }
-
- String toString() {
- return "FactoryCreateNamedObjectParams("
- "obj: $obj" ")";
- }
-
- Map toJson() {
- throw new bindings.MojoCodecError(
- 'Object containing handles cannot be encoded to JSON.');
- }
-}
-
-
-class FactoryRequestImportedInterfaceParams extends bindings.Struct {
- static const List<bindings.StructDataHeader> kVersions = const [
- const bindings.StructDataHeader(16, 0)
- ];
- Object obj = null;
-
- FactoryRequestImportedInterfaceParams() : super(kVersions.last.size);
-
- static FactoryRequestImportedInterfaceParams 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 FactoryRequestImportedInterfaceParams decode(bindings.Decoder decoder0) {
- if (decoder0 == null) {
- return null;
- }
- FactoryRequestImportedInterfaceParams result = new FactoryRequestImportedInterfaceParams();
-
- 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.');
+ result.buffer = decoder0.decodeSharedBufferHandle(8, false);
}
if (mainDataHeader.version >= 0) {
- result.obj = decoder0.decodeInterfaceRequest(8, false, sample_import_mojom.ImportedInterfaceStub.newFromEndpoint);
+ result.size = decoder0.decodeUint64(16);
}
return result;
}
@@ -768,12 +580,15 @@ class FactoryRequestImportedInterfaceParams extends bindings.Struct {
void encode(bindings.Encoder encoder) {
var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last);
- encoder0.encodeInterfaceRequest(obj, 8, false);
+ encoder0.encodeSharedBufferHandle(buffer, 8, false);
+
+ encoder0.encodeUint64(size, 16);
}
String toString() {
- return "FactoryRequestImportedInterfaceParams("
- "obj: $obj" ")";
+ return "MediaConsumerSetBufferParams("
+ "buffer: $buffer" ", "
+ "size: $size" ")";
}
Map toJson() {
@@ -783,15 +598,14 @@ class FactoryRequestImportedInterfaceParams extends bindings.Struct {
}
-class FactoryRequestImportedInterfaceResponseParams extends bindings.Struct {
+class MediaConsumerSetBufferResponseParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
- const bindings.StructDataHeader(16, 0)
+ const bindings.StructDataHeader(8, 0)
];
- Object obj = null;
- FactoryRequestImportedInterfaceResponseParams() : super(kVersions.last.size);
+ MediaConsumerSetBufferResponseParams() : super(kVersions.last.size);
- static FactoryRequestImportedInterfaceResponseParams deserialize(bindings.Message message) {
+ static MediaConsumerSetBufferResponseParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -800,11 +614,11 @@ class FactoryRequestImportedInterfaceResponseParams extends bindings.Struct {
return result;
}
- static FactoryRequestImportedInterfaceResponseParams decode(bindings.Decoder decoder0) {
+ static MediaConsumerSetBufferResponseParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- FactoryRequestImportedInterfaceResponseParams result = new FactoryRequestImportedInterfaceResponseParams();
+ MediaConsumerSetBufferResponseParams result = new MediaConsumerSetBufferResponseParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -824,40 +638,33 @@ class FactoryRequestImportedInterfaceResponseParams extends bindings.Struct {
'Message newer than the last known version cannot be shorter than '
'required by the last known version.');
}
- if (mainDataHeader.version >= 0) {
-
- result.obj = decoder0.decodeInterfaceRequest(8, false, sample_import_mojom.ImportedInterfaceStub.newFromEndpoint);
- }
return result;
}
void encode(bindings.Encoder encoder) {
- var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last);
-
- encoder0.encodeInterfaceRequest(obj, 8, false);
+ encoder.getStructEncoderAtOffset(kVersions.last);
}
String toString() {
- return "FactoryRequestImportedInterfaceResponseParams("
- "obj: $obj" ")";
+ return "MediaConsumerSetBufferResponseParams("")";
}
Map toJson() {
- throw new bindings.MojoCodecError(
- 'Object containing handles cannot be encoded to JSON.');
+ Map map = new Map();
+ return map;
}
}
-class FactoryTakeImportedInterfaceParams extends bindings.Struct {
+class MediaConsumerPushPacketParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
const bindings.StructDataHeader(16, 0)
];
- Object obj = null;
+ media_pipe_mojom.MediaPacket packet = null;
- FactoryTakeImportedInterfaceParams() : super(kVersions.last.size);
+ MediaConsumerPushPacketParams() : super(kVersions.last.size);
- static FactoryTakeImportedInterfaceParams deserialize(bindings.Message message) {
+ static MediaConsumerPushPacketParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -866,11 +673,11 @@ class FactoryTakeImportedInterfaceParams extends bindings.Struct {
return result;
}
- static FactoryTakeImportedInterfaceParams decode(bindings.Decoder decoder0) {
+ static MediaConsumerPushPacketParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- FactoryTakeImportedInterfaceParams result = new FactoryTakeImportedInterfaceParams();
+ MediaConsumerPushPacketParams result = new MediaConsumerPushPacketParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -892,7 +699,8 @@ class FactoryTakeImportedInterfaceParams extends bindings.Struct {
}
if (mainDataHeader.version >= 0) {
- result.obj = decoder0.decodeServiceInterface(8, false, sample_import_mojom.ImportedInterfaceProxy.newFromEndpoint);
+ var decoder1 = decoder0.decodePointer(8, false);
+ result.packet = media_pipe_mojom.MediaPacket.decode(decoder1);
}
return result;
}
@@ -900,30 +708,30 @@ class FactoryTakeImportedInterfaceParams extends bindings.Struct {
void encode(bindings.Encoder encoder) {
var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last);
- encoder0.encodeInterface(obj, 8, false);
+ encoder0.encodeStruct(packet, 8, false);
}
String toString() {
- return "FactoryTakeImportedInterfaceParams("
- "obj: $obj" ")";
+ return "MediaConsumerPushPacketParams("
+ "packet: $packet" ")";
}
Map toJson() {
- throw new bindings.MojoCodecError(
- 'Object containing handles cannot be encoded to JSON.');
+ Map map = new Map();
+ map["packet"] = packet;
+ return map;
}
}
-class FactoryTakeImportedInterfaceResponseParams extends bindings.Struct {
+class MediaConsumerPushPacketResponseParams extends bindings.Struct {
static const List<bindings.StructDataHeader> kVersions = const [
- const bindings.StructDataHeader(16, 0)
+ const bindings.StructDataHeader(8, 0)
];
- Object obj = null;
- FactoryTakeImportedInterfaceResponseParams() : super(kVersions.last.size);
+ MediaConsumerPushPacketResponseParams() : super(kVersions.last.size);
- static FactoryTakeImportedInterfaceResponseParams deserialize(bindings.Message message) {
+ static MediaConsumerPushPacketResponseParams deserialize(bindings.Message message) {
var decoder = new bindings.Decoder(message);
var result = decode(decoder);
if (decoder.excessHandles != null) {
@@ -932,11 +740,11 @@ class FactoryTakeImportedInterfaceResponseParams extends bindings.Struct {
return result;
}
- static FactoryTakeImportedInterfaceResponseParams decode(bindings.Decoder decoder0) {
+ static MediaConsumerPushPacketResponseParams decode(bindings.Decoder decoder0) {
if (decoder0 == null) {
return null;
}
- FactoryTakeImportedInterfaceResponseParams result = new FactoryTakeImportedInterfaceResponseParams();
+ MediaConsumerPushPacketResponseParams result = new MediaConsumerPushPacketResponseParams();
var mainDataHeader = decoder0.decodeStructDataHeader();
if (mainDataHeader.version <= kVersions.last.version) {
@@ -956,62 +764,55 @@ class FactoryTakeImportedInterfaceResponseParams extends bindings.Struct {
'Message newer than the last known version cannot be shorter than '
'required by the last known version.');
}
- if (mainDataHeader.version >= 0) {
-
- result.obj = decoder0.decodeServiceInterface(8, false, sample_import_mojom.ImportedInterfaceProxy.newFromEndpoint);
- }
return result;
}
void encode(bindings.Encoder encoder) {
- var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last);
-
- encoder0.encodeInterface(obj, 8, false);
+ encoder.getStructEncoderAtOffset(kVersions.last);
}
String toString() {
- return "FactoryTakeImportedInterfaceResponseParams("
- "obj: $obj" ")";
+ return "MediaConsumerPushPacketResponseParams("")";
}
Map toJson() {
- throw new bindings.MojoCodecError(
- 'Object containing handles cannot be encoded to JSON.');
+ Map map = new Map();
+ return map;
}
}
-const int kNamedObject_setName_name = 0;
-const int kNamedObject_getName_name = 1;
-const String NamedObjectName = "sample::NamedObject";
+const int kMediaProducer_connect_name = 0;
+const int kMediaProducer_disconnect_name = 1;
+const String MediaProducerName = null;
-abstract class NamedObject {
- void setName(String name);
- dynamic getName([Function responseFactory = null]);
+abstract class MediaProducer {
+ dynamic connect(Object consumer,[Function responseFactory = null]);
+ void disconnect();
}
-class NamedObjectProxyImpl extends bindings.Proxy {
- NamedObjectProxyImpl.fromEndpoint(
+class MediaProducerProxyImpl extends bindings.Proxy {
+ MediaProducerProxyImpl.fromEndpoint(
core.MojoMessagePipeEndpoint endpoint) : super.fromEndpoint(endpoint);
- NamedObjectProxyImpl.fromHandle(core.MojoHandle handle) :
+ MediaProducerProxyImpl.fromHandle(core.MojoHandle handle) :
super.fromHandle(handle);
- NamedObjectProxyImpl.unbound() : super.unbound();
+ MediaProducerProxyImpl.unbound() : super.unbound();
- static NamedObjectProxyImpl newFromEndpoint(
+ static MediaProducerProxyImpl newFromEndpoint(
core.MojoMessagePipeEndpoint endpoint) {
- assert(endpoint.setDescription("For NamedObjectProxyImpl"));
- return new NamedObjectProxyImpl.fromEndpoint(endpoint);
+ assert(endpoint.setDescription("For MediaProducerProxyImpl"));
+ return new MediaProducerProxyImpl.fromEndpoint(endpoint);
}
- String get name => NamedObjectName;
+ String get name => MediaProducerName;
void handleResponse(bindings.ServiceMessage message) {
switch (message.header.type) {
- case kNamedObject_getName_name:
- var r = NamedObjectGetNameResponseParams.deserialize(
+ case kMediaProducer_connect_name:
+ var r = MediaProducerConnectResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
proxyError("Expected a message with a valid request Id.");
@@ -1039,72 +840,72 @@ class NamedObjectProxyImpl extends bindings.Proxy {
String toString() {
var superString = super.toString();
- return "NamedObjectProxyImpl($superString)";
+ return "MediaProducerProxyImpl($superString)";
}
}
-class _NamedObjectProxyCalls implements NamedObject {
- NamedObjectProxyImpl _proxyImpl;
+class _MediaProducerProxyCalls implements MediaProducer {
+ MediaProducerProxyImpl _proxyImpl;
- _NamedObjectProxyCalls(this._proxyImpl);
- void setName(String name) {
+ _MediaProducerProxyCalls(this._proxyImpl);
+ dynamic connect(Object consumer,[Function responseFactory = null]) {
+ var params = new MediaProducerConnectParams();
+ params.consumer = consumer;
+ return _proxyImpl.sendMessageWithRequestId(
+ params,
+ kMediaProducer_connect_name,
+ -1,
+ bindings.MessageHeader.kMessageExpectsResponse);
+ }
+ void disconnect() {
if (!_proxyImpl.isBound) {
_proxyImpl.proxyError("The Proxy is closed.");
return;
}
- var params = new NamedObjectSetNameParams();
- params.name = name;
- _proxyImpl.sendMessage(params, kNamedObject_setName_name);
+ var params = new MediaProducerDisconnectParams();
+ _proxyImpl.sendMessage(params, kMediaProducer_disconnect_name);
}
- dynamic getName([Function responseFactory = null]) {
- var params = new NamedObjectGetNameParams();
- return _proxyImpl.sendMessageWithRequestId(
- params,
- kNamedObject_getName_name,
- -1,
- bindings.MessageHeader.kMessageExpectsResponse);
- }
}
-class NamedObjectProxy implements bindings.ProxyBase {
+class MediaProducerProxy implements bindings.ProxyBase {
final bindings.Proxy impl;
- NamedObject ptr;
- final String name = NamedObjectName;
+ MediaProducer ptr;
+ final String name = MediaProducerName;
- NamedObjectProxy(NamedObjectProxyImpl proxyImpl) :
+ MediaProducerProxy(MediaProducerProxyImpl proxyImpl) :
impl = proxyImpl,
- ptr = new _NamedObjectProxyCalls(proxyImpl);
+ ptr = new _MediaProducerProxyCalls(proxyImpl);
- NamedObjectProxy.fromEndpoint(
+ MediaProducerProxy.fromEndpoint(
core.MojoMessagePipeEndpoint endpoint) :
- impl = new NamedObjectProxyImpl.fromEndpoint(endpoint) {
- ptr = new _NamedObjectProxyCalls(impl);
+ impl = new MediaProducerProxyImpl.fromEndpoint(endpoint) {
+ ptr = new _MediaProducerProxyCalls(impl);
}
- NamedObjectProxy.fromHandle(core.MojoHandle handle) :
- impl = new NamedObjectProxyImpl.fromHandle(handle) {
- ptr = new _NamedObjectProxyCalls(impl);
+ MediaProducerProxy.fromHandle(core.MojoHandle handle) :
+ impl = new MediaProducerProxyImpl.fromHandle(handle) {
+ ptr = new _MediaProducerProxyCalls(impl);
}
- NamedObjectProxy.unbound() :
- impl = new NamedObjectProxyImpl.unbound() {
- ptr = new _NamedObjectProxyCalls(impl);
+ MediaProducerProxy.unbound() :
+ impl = new MediaProducerProxyImpl.unbound() {
+ ptr = new _MediaProducerProxyCalls(impl);
}
- factory NamedObjectProxy.connectToService(
- bindings.ServiceConnector s, String url, [String serviceName]) {
- NamedObjectProxy p = new NamedObjectProxy.unbound();
- s.connectToService(url, p, serviceName);
+ factory MediaProducerProxy.connectToService(
+ bindings.ServiceConnector s, String url) {
+ MediaProducerProxy p = new MediaProducerProxy.unbound();
+ s.connectToService(url, p);
return p;
}
- static NamedObjectProxy newFromEndpoint(
+ static MediaProducerProxy newFromEndpoint(
core.MojoMessagePipeEndpoint endpoint) {
- assert(endpoint.setDescription("For NamedObjectProxy"));
- return new NamedObjectProxy.fromEndpoint(endpoint);
+ assert(endpoint.setDescription("For MediaProducerProxy"));
+ return new MediaProducerProxy.fromEndpoint(endpoint);
}
Future close({bool immediate: false}) => impl.close(immediate: immediate);
@@ -1122,35 +923,34 @@ class NamedObjectProxy implements bindings.ProxyBase {
}
String toString() {
- return "NamedObjectProxy($impl)";
+ return "MediaProducerProxy($impl)";
}
}
-class NamedObjectStub extends bindings.Stub {
- NamedObject _impl = null;
+class MediaProducerStub extends bindings.Stub {
+ MediaProducer _impl = null;
- NamedObjectStub.fromEndpoint(
+ MediaProducerStub.fromEndpoint(
core.MojoMessagePipeEndpoint endpoint, [this._impl])
: super.fromEndpoint(endpoint);
- NamedObjectStub.fromHandle(core.MojoHandle handle, [this._impl])
+ MediaProducerStub.fromHandle(core.MojoHandle handle, [this._impl])
: super.fromHandle(handle);
- NamedObjectStub.unbound() : super.unbound();
+ MediaProducerStub.unbound() : super.unbound();
- static NamedObjectStub newFromEndpoint(
+ static MediaProducerStub newFromEndpoint(
core.MojoMessagePipeEndpoint endpoint) {
- assert(endpoint.setDescription("For NamedObjectStub"));
- return new NamedObjectStub.fromEndpoint(endpoint);
+ assert(endpoint.setDescription("For MediaProducerStub"));
+ return new MediaProducerStub.fromEndpoint(endpoint);
}
- static const String name = NamedObjectName;
+ static const String name = MediaProducerName;
- NamedObjectGetNameResponseParams _NamedObjectGetNameResponseParamsFactory(String name) {
- var mojo_factory_result = new NamedObjectGetNameResponseParams();
- mojo_factory_result.name = name;
+ MediaProducerConnectResponseParams _MediaProducerConnectResponseParamsFactory() {
+ var mojo_factory_result = new MediaProducerConnectResponseParams();
return mojo_factory_result;
}
@@ -1162,21 +962,16 @@ class NamedObjectStub extends bindings.Stub {
}
assert(_impl != null);
switch (message.header.type) {
- case kNamedObject_setName_name:
- var params = NamedObjectSetNameParams.deserialize(
+ case kMediaProducer_connect_name:
+ var params = MediaProducerConnectParams.deserialize(
message.payload);
- _impl.setName(params.name);
- break;
- case kNamedObject_getName_name:
- var params = NamedObjectGetNameParams.deserialize(
- message.payload);
- var response = _impl.getName(_NamedObjectGetNameResponseParamsFactory);
+ var response = _impl.connect(params.consumer,_MediaProducerConnectResponseParamsFactory);
if (response is Future) {
return response.then((response) {
if (response != null) {
return buildResponseWithId(
response,
- kNamedObject_getName_name,
+ kMediaProducer_connect_name,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -1184,11 +979,16 @@ class NamedObjectStub extends bindings.Stub {
} else if (response != null) {
return buildResponseWithId(
response,
- kNamedObject_getName_name,
+ kMediaProducer_connect_name,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
+ case kMediaProducer_disconnect_name:
+ var params = MediaProducerDisconnectParams.deserialize(
+ message.payload);
+ _impl.disconnect();
+ break;
default:
throw new bindings.MojoCodecError("Unexpected message name");
break;
@@ -1196,58 +996,54 @@ class NamedObjectStub extends bindings.Stub {
return null;
}
- NamedObject get impl => _impl;
- set impl(NamedObject d) {
+ MediaProducer get impl => _impl;
+ set impl(MediaProducer d) {
assert(_impl == null);
_impl = d;
}
String toString() {
var superString = super.toString();
- return "NamedObjectStub($superString)";
+ return "MediaProducerStub($superString)";
}
int get version => 0;
}
-const int kFactory_doStuff_name = 0;
-const int kFactory_doStuff2_name = 1;
-const int kFactory_createNamedObject_name = 2;
-const int kFactory_requestImportedInterface_name = 3;
-const int kFactory_takeImportedInterface_name = 4;
-const String FactoryName = null;
+const int kMediaPullModeProducer_getBuffer_name = 0;
+const int kMediaPullModeProducer_pullPacket_name = 1;
+const int kMediaPullModeProducer_releasePacket_name = 2;
+const String MediaPullModeProducerName = null;
-abstract class Factory {
- dynamic doStuff(Request request,core.MojoMessagePipeEndpoint pipe,[Function responseFactory = null]);
- dynamic doStuff2(core.MojoDataPipeConsumer pipe,[Function responseFactory = null]);
- void createNamedObject(Object obj);
- dynamic requestImportedInterface(Object obj,[Function responseFactory = null]);
- dynamic takeImportedInterface(Object obj,[Function responseFactory = null]);
+abstract class MediaPullModeProducer {
+ dynamic getBuffer([Function responseFactory = null]);
+ dynamic pullPacket(media_pipe_mojom.MediaPacket toRelease,[Function responseFactory = null]);
+ void releasePacket(media_pipe_mojom.MediaPacket toRelease);
}
-class FactoryProxyImpl extends bindings.Proxy {
- FactoryProxyImpl.fromEndpoint(
+class MediaPullModeProducerProxyImpl extends bindings.Proxy {
+ MediaPullModeProducerProxyImpl.fromEndpoint(
core.MojoMessagePipeEndpoint endpoint) : super.fromEndpoint(endpoint);
- FactoryProxyImpl.fromHandle(core.MojoHandle handle) :
+ MediaPullModeProducerProxyImpl.fromHandle(core.MojoHandle handle) :
super.fromHandle(handle);
- FactoryProxyImpl.unbound() : super.unbound();
+ MediaPullModeProducerProxyImpl.unbound() : super.unbound();
- static FactoryProxyImpl newFromEndpoint(
+ static MediaPullModeProducerProxyImpl newFromEndpoint(
core.MojoMessagePipeEndpoint endpoint) {
- assert(endpoint.setDescription("For FactoryProxyImpl"));
- return new FactoryProxyImpl.fromEndpoint(endpoint);
+ assert(endpoint.setDescription("For MediaPullModeProducerProxyImpl"));
+ return new MediaPullModeProducerProxyImpl.fromEndpoint(endpoint);
}
- String get name => FactoryName;
+ String get name => MediaPullModeProducerName;
void handleResponse(bindings.ServiceMessage message) {
switch (message.header.type) {
- case kFactory_doStuff_name:
- var r = FactoryDoStuffResponseParams.deserialize(
+ case kMediaPullModeProducer_getBuffer_name:
+ var r = MediaPullModeProducerGetBufferResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
proxyError("Expected a message with a valid request Id.");
@@ -1266,48 +1062,8 @@ class FactoryProxyImpl extends bindings.Proxy {
}
c.complete(r);
break;
- case kFactory_doStuff2_name:
- var r = FactoryDoStuff2ResponseParams.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;
- case kFactory_requestImportedInterface_name:
- var r = FactoryRequestImportedInterfaceResponseParams.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;
- case kFactory_takeImportedInterface_name:
- var r = FactoryTakeImportedInterfaceResponseParams.deserialize(
+ case kMediaPullModeProducer_pullPacket_name:
+ var r = MediaPullModeProducerPullPacketResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
proxyError("Expected a message with a valid request Id.");
@@ -1335,101 +1091,81 @@ class FactoryProxyImpl extends bindings.Proxy {
String toString() {
var superString = super.toString();
- return "FactoryProxyImpl($superString)";
+ return "MediaPullModeProducerProxyImpl($superString)";
}
}
-class _FactoryProxyCalls implements Factory {
- FactoryProxyImpl _proxyImpl;
+class _MediaPullModeProducerProxyCalls implements MediaPullModeProducer {
+ MediaPullModeProducerProxyImpl _proxyImpl;
- _FactoryProxyCalls(this._proxyImpl);
- dynamic doStuff(Request request,core.MojoMessagePipeEndpoint pipe,[Function responseFactory = null]) {
- var params = new FactoryDoStuffParams();
- params.request = request;
- params.pipe = pipe;
+ _MediaPullModeProducerProxyCalls(this._proxyImpl);
+ dynamic getBuffer([Function responseFactory = null]) {
+ var params = new MediaPullModeProducerGetBufferParams();
return _proxyImpl.sendMessageWithRequestId(
params,
- kFactory_doStuff_name,
+ kMediaPullModeProducer_getBuffer_name,
-1,
bindings.MessageHeader.kMessageExpectsResponse);
}
- dynamic doStuff2(core.MojoDataPipeConsumer pipe,[Function responseFactory = null]) {
- var params = new FactoryDoStuff2Params();
- params.pipe = pipe;
+ dynamic pullPacket(media_pipe_mojom.MediaPacket toRelease,[Function responseFactory = null]) {
+ var params = new MediaPullModeProducerPullPacketParams();
+ params.toRelease = toRelease;
return _proxyImpl.sendMessageWithRequestId(
params,
- kFactory_doStuff2_name,
+ kMediaPullModeProducer_pullPacket_name,
-1,
bindings.MessageHeader.kMessageExpectsResponse);
}
- void createNamedObject(Object obj) {
+ void releasePacket(media_pipe_mojom.MediaPacket toRelease) {
if (!_proxyImpl.isBound) {
_proxyImpl.proxyError("The Proxy is closed.");
return;
}
- var params = new FactoryCreateNamedObjectParams();
- params.obj = obj;
- _proxyImpl.sendMessage(params, kFactory_createNamedObject_name);
+ var params = new MediaPullModeProducerReleasePacketParams();
+ params.toRelease = toRelease;
+ _proxyImpl.sendMessage(params, kMediaPullModeProducer_releasePacket_name);
}
- dynamic requestImportedInterface(Object obj,[Function responseFactory = null]) {
- var params = new FactoryRequestImportedInterfaceParams();
- params.obj = obj;
- return _proxyImpl.sendMessageWithRequestId(
- params,
- kFactory_requestImportedInterface_name,
- -1,
- bindings.MessageHeader.kMessageExpectsResponse);
- }
- dynamic takeImportedInterface(Object obj,[Function responseFactory = null]) {
- var params = new FactoryTakeImportedInterfaceParams();
- params.obj = obj;
- return _proxyImpl.sendMessageWithRequestId(
- params,
- kFactory_takeImportedInterface_name,
- -1,
- bindings.MessageHeader.kMessageExpectsResponse);
- }
}
-class FactoryProxy implements bindings.ProxyBase {
+class MediaPullModeProducerProxy implements bindings.ProxyBase {
final bindings.Proxy impl;
- Factory ptr;
- final String name = FactoryName;
+ MediaPullModeProducer ptr;
+ final String name = MediaPullModeProducerName;
- FactoryProxy(FactoryProxyImpl proxyImpl) :
+ MediaPullModeProducerProxy(MediaPullModeProducerProxyImpl proxyImpl) :
impl = proxyImpl,
- ptr = new _FactoryProxyCalls(proxyImpl);
+ ptr = new _MediaPullModeProducerProxyCalls(proxyImpl);
- FactoryProxy.fromEndpoint(
+ MediaPullModeProducerProxy.fromEndpoint(
core.MojoMessagePipeEndpoint endpoint) :
- impl = new FactoryProxyImpl.fromEndpoint(endpoint) {
- ptr = new _FactoryProxyCalls(impl);
+ impl = new MediaPullModeProducerProxyImpl.fromEndpoint(endpoint) {
+ ptr = new _MediaPullModeProducerProxyCalls(impl);
}
- FactoryProxy.fromHandle(core.MojoHandle handle) :
- impl = new FactoryProxyImpl.fromHandle(handle) {
- ptr = new _FactoryProxyCalls(impl);
+ MediaPullModeProducerProxy.fromHandle(core.MojoHandle handle) :
+ impl = new MediaPullModeProducerProxyImpl.fromHandle(handle) {
+ ptr = new _MediaPullModeProducerProxyCalls(impl);
}
- FactoryProxy.unbound() :
- impl = new FactoryProxyImpl.unbound() {
- ptr = new _FactoryProxyCalls(impl);
+ MediaPullModeProducerProxy.unbound() :
+ impl = new MediaPullModeProducerProxyImpl.unbound() {
+ ptr = new _MediaPullModeProducerProxyCalls(impl);
}
- factory FactoryProxy.connectToService(
- bindings.ServiceConnector s, String url, [String serviceName]) {
- FactoryProxy p = new FactoryProxy.unbound();
- s.connectToService(url, p, serviceName);
+ factory MediaPullModeProducerProxy.connectToService(
+ bindings.ServiceConnector s, String url) {
+ MediaPullModeProducerProxy p = new MediaPullModeProducerProxy.unbound();
+ s.connectToService(url, p);
return p;
}
- static FactoryProxy newFromEndpoint(
+ static MediaPullModeProducerProxy newFromEndpoint(
core.MojoMessagePipeEndpoint endpoint) {
- assert(endpoint.setDescription("For FactoryProxy"));
- return new FactoryProxy.fromEndpoint(endpoint);
+ assert(endpoint.setDescription("For MediaPullModeProducerProxy"));
+ return new MediaPullModeProducerProxy.fromEndpoint(endpoint);
}
Future close({bool immediate: false}) => impl.close(immediate: immediate);
@@ -1447,51 +1183,40 @@ class FactoryProxy implements bindings.ProxyBase {
}
String toString() {
- return "FactoryProxy($impl)";
+ return "MediaPullModeProducerProxy($impl)";
}
}
-class FactoryStub extends bindings.Stub {
- Factory _impl = null;
+class MediaPullModeProducerStub extends bindings.Stub {
+ MediaPullModeProducer _impl = null;
- FactoryStub.fromEndpoint(
+ MediaPullModeProducerStub.fromEndpoint(
core.MojoMessagePipeEndpoint endpoint, [this._impl])
: super.fromEndpoint(endpoint);
- FactoryStub.fromHandle(core.MojoHandle handle, [this._impl])
+ MediaPullModeProducerStub.fromHandle(core.MojoHandle handle, [this._impl])
: super.fromHandle(handle);
- FactoryStub.unbound() : super.unbound();
+ MediaPullModeProducerStub.unbound() : super.unbound();
- static FactoryStub newFromEndpoint(
+ static MediaPullModeProducerStub newFromEndpoint(
core.MojoMessagePipeEndpoint endpoint) {
- assert(endpoint.setDescription("For FactoryStub"));
- return new FactoryStub.fromEndpoint(endpoint);
+ assert(endpoint.setDescription("For MediaPullModeProducerStub"));
+ return new MediaPullModeProducerStub.fromEndpoint(endpoint);
}
- static const String name = FactoryName;
+ static const String name = MediaPullModeProducerName;
- FactoryDoStuffResponseParams _FactoryDoStuffResponseParamsFactory(Response response, String text) {
- var mojo_factory_result = new FactoryDoStuffResponseParams();
- mojo_factory_result.response = response;
- mojo_factory_result.text = text;
+ MediaPullModeProducerGetBufferResponseParams _MediaPullModeProducerGetBufferResponseParamsFactory(core.MojoSharedBuffer buffer) {
+ var mojo_factory_result = new MediaPullModeProducerGetBufferResponseParams();
+ mojo_factory_result.buffer = buffer;
return mojo_factory_result;
}
- FactoryDoStuff2ResponseParams _FactoryDoStuff2ResponseParamsFactory(String text) {
- var mojo_factory_result = new FactoryDoStuff2ResponseParams();
- mojo_factory_result.text = text;
- return mojo_factory_result;
- }
- FactoryRequestImportedInterfaceResponseParams _FactoryRequestImportedInterfaceResponseParamsFactory(Object obj) {
- var mojo_factory_result = new FactoryRequestImportedInterfaceResponseParams();
- mojo_factory_result.obj = obj;
- return mojo_factory_result;
- }
- FactoryTakeImportedInterfaceResponseParams _FactoryTakeImportedInterfaceResponseParamsFactory(Object obj) {
- var mojo_factory_result = new FactoryTakeImportedInterfaceResponseParams();
- mojo_factory_result.obj = obj;
+ MediaPullModeProducerPullPacketResponseParams _MediaPullModeProducerPullPacketResponseParamsFactory(media_pipe_mojom.MediaPacket packet) {
+ var mojo_factory_result = new MediaPullModeProducerPullPacketResponseParams();
+ mojo_factory_result.packet = packet;
return mojo_factory_result;
}
@@ -1503,16 +1228,16 @@ class FactoryStub extends bindings.Stub {
}
assert(_impl != null);
switch (message.header.type) {
- case kFactory_doStuff_name:
- var params = FactoryDoStuffParams.deserialize(
+ case kMediaPullModeProducer_getBuffer_name:
+ var params = MediaPullModeProducerGetBufferParams.deserialize(
message.payload);
- var response = _impl.doStuff(params.request,params.pipe,_FactoryDoStuffResponseParamsFactory);
+ var response = _impl.getBuffer(_MediaPullModeProducerGetBufferResponseParamsFactory);
if (response is Future) {
return response.then((response) {
if (response != null) {
return buildResponseWithId(
response,
- kFactory_doStuff_name,
+ kMediaPullModeProducer_getBuffer_name,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -1520,21 +1245,21 @@ class FactoryStub extends bindings.Stub {
} else if (response != null) {
return buildResponseWithId(
response,
- kFactory_doStuff_name,
+ kMediaPullModeProducer_getBuffer_name,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case kFactory_doStuff2_name:
- var params = FactoryDoStuff2Params.deserialize(
+ case kMediaPullModeProducer_pullPacket_name:
+ var params = MediaPullModeProducerPullPacketParams.deserialize(
message.payload);
- var response = _impl.doStuff2(params.pipe,_FactoryDoStuff2ResponseParamsFactory);
+ var response = _impl.pullPacket(params.toRelease,_MediaPullModeProducerPullPacketResponseParamsFactory);
if (response is Future) {
return response.then((response) {
if (response != null) {
return buildResponseWithId(
response,
- kFactory_doStuff2_name,
+ kMediaPullModeProducer_pullPacket_name,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -1542,26 +1267,253 @@ class FactoryStub extends bindings.Stub {
} else if (response != null) {
return buildResponseWithId(
response,
- kFactory_doStuff2_name,
+ kMediaPullModeProducer_pullPacket_name,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case kFactory_createNamedObject_name:
- var params = FactoryCreateNamedObjectParams.deserialize(
+ case kMediaPullModeProducer_releasePacket_name:
+ var params = MediaPullModeProducerReleasePacketParams.deserialize(
message.payload);
- _impl.createNamedObject(params.obj);
+ _impl.releasePacket(params.toRelease);
break;
- case kFactory_requestImportedInterface_name:
- var params = FactoryRequestImportedInterfaceParams.deserialize(
+ default:
+ throw new bindings.MojoCodecError("Unexpected message name");
+ break;
+ }
+ return null;
+ }
+
+ MediaPullModeProducer get impl => _impl;
+ set impl(MediaPullModeProducer d) {
+ assert(_impl == null);
+ _impl = d;
+ }
+
+ String toString() {
+ var superString = super.toString();
+ return "MediaPullModeProducerStub($superString)";
+ }
+
+ int get version => 0;
+}
+
+const int kMediaConsumer_setBuffer_name = 0;
+const int kMediaConsumer_pushPacket_name = 1;
+const String MediaConsumerName = null;
+
+abstract class MediaConsumer {
+ dynamic setBuffer(core.MojoSharedBuffer buffer,int size,[Function responseFactory = null]);
+ dynamic pushPacket(media_pipe_mojom.MediaPacket packet,[Function responseFactory = null]);
+
+}
+
+
+class MediaConsumerProxyImpl extends bindings.Proxy {
+ MediaConsumerProxyImpl.fromEndpoint(
+ core.MojoMessagePipeEndpoint endpoint) : super.fromEndpoint(endpoint);
+
+ MediaConsumerProxyImpl.fromHandle(core.MojoHandle handle) :
+ super.fromHandle(handle);
+
+ MediaConsumerProxyImpl.unbound() : super.unbound();
+
+ static MediaConsumerProxyImpl newFromEndpoint(
+ core.MojoMessagePipeEndpoint endpoint) {
+ assert(endpoint.setDescription("For MediaConsumerProxyImpl"));
+ return new MediaConsumerProxyImpl.fromEndpoint(endpoint);
+ }
+
+ String get name => MediaConsumerName;
+
+ void handleResponse(bindings.ServiceMessage message) {
+ switch (message.header.type) {
+ case kMediaConsumer_setBuffer_name:
+ var r = MediaConsumerSetBufferResponseParams.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;
+ case kMediaConsumer_pushPacket_name:
+ var r = MediaConsumerPushPacketResponseParams.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;
+ }
+ }
+
+ String toString() {
+ var superString = super.toString();
+ return "MediaConsumerProxyImpl($superString)";
+ }
+}
+
+
+class _MediaConsumerProxyCalls implements MediaConsumer {
+ MediaConsumerProxyImpl _proxyImpl;
+
+ _MediaConsumerProxyCalls(this._proxyImpl);
+ dynamic setBuffer(core.MojoSharedBuffer buffer,int size,[Function responseFactory = null]) {
+ var params = new MediaConsumerSetBufferParams();
+ params.buffer = buffer;
+ params.size = size;
+ return _proxyImpl.sendMessageWithRequestId(
+ params,
+ kMediaConsumer_setBuffer_name,
+ -1,
+ bindings.MessageHeader.kMessageExpectsResponse);
+ }
+ dynamic pushPacket(media_pipe_mojom.MediaPacket packet,[Function responseFactory = null]) {
+ var params = new MediaConsumerPushPacketParams();
+ params.packet = packet;
+ return _proxyImpl.sendMessageWithRequestId(
+ params,
+ kMediaConsumer_pushPacket_name,
+ -1,
+ bindings.MessageHeader.kMessageExpectsResponse);
+ }
+}
+
+
+class MediaConsumerProxy implements bindings.ProxyBase {
+ final bindings.Proxy impl;
+ MediaConsumer ptr;
+ final String name = MediaConsumerName;
+
+ MediaConsumerProxy(MediaConsumerProxyImpl proxyImpl) :
+ impl = proxyImpl,
+ ptr = new _MediaConsumerProxyCalls(proxyImpl);
+
+ MediaConsumerProxy.fromEndpoint(
+ core.MojoMessagePipeEndpoint endpoint) :
+ impl = new MediaConsumerProxyImpl.fromEndpoint(endpoint) {
+ ptr = new _MediaConsumerProxyCalls(impl);
+ }
+
+ MediaConsumerProxy.fromHandle(core.MojoHandle handle) :
+ impl = new MediaConsumerProxyImpl.fromHandle(handle) {
+ ptr = new _MediaConsumerProxyCalls(impl);
+ }
+
+ MediaConsumerProxy.unbound() :
+ impl = new MediaConsumerProxyImpl.unbound() {
+ ptr = new _MediaConsumerProxyCalls(impl);
+ }
+
+ factory MediaConsumerProxy.connectToService(
+ bindings.ServiceConnector s, String url) {
+ MediaConsumerProxy p = new MediaConsumerProxy.unbound();
+ s.connectToService(url, p);
+ return p;
+ }
+
+ static MediaConsumerProxy newFromEndpoint(
+ core.MojoMessagePipeEndpoint endpoint) {
+ assert(endpoint.setDescription("For MediaConsumerProxy"));
+ return new MediaConsumerProxy.fromEndpoint(endpoint);
+ }
+
+ Future close({bool immediate: false}) => impl.close(immediate: immediate);
+
+ Future responseOrError(Future f) => impl.responseOrError(f);
+
+ Future get errorFuture => impl.errorFuture;
+
+ int get version => impl.version;
+
+ Future<int> queryVersion() => impl.queryVersion();
+
+ void requireVersion(int requiredVersion) {
+ impl.requireVersion(requiredVersion);
+ }
+
+ String toString() {
+ return "MediaConsumerProxy($impl)";
+ }
+}
+
+
+class MediaConsumerStub extends bindings.Stub {
+ MediaConsumer _impl = null;
+
+ MediaConsumerStub.fromEndpoint(
+ core.MojoMessagePipeEndpoint endpoint, [this._impl])
+ : super.fromEndpoint(endpoint);
+
+ MediaConsumerStub.fromHandle(core.MojoHandle handle, [this._impl])
+ : super.fromHandle(handle);
+
+ MediaConsumerStub.unbound() : super.unbound();
+
+ static MediaConsumerStub newFromEndpoint(
+ core.MojoMessagePipeEndpoint endpoint) {
+ assert(endpoint.setDescription("For MediaConsumerStub"));
+ return new MediaConsumerStub.fromEndpoint(endpoint);
+ }
+
+ static const String name = MediaConsumerName;
+
+
+ MediaConsumerSetBufferResponseParams _MediaConsumerSetBufferResponseParamsFactory() {
+ var mojo_factory_result = new MediaConsumerSetBufferResponseParams();
+ return mojo_factory_result;
+ }
+ MediaConsumerPushPacketResponseParams _MediaConsumerPushPacketResponseParamsFactory() {
+ var mojo_factory_result = new MediaConsumerPushPacketResponseParams();
+ return mojo_factory_result;
+ }
+
+ dynamic handleMessage(bindings.ServiceMessage message) {
+ if (bindings.ControlMessageHandler.isControlMessage(message)) {
+ return bindings.ControlMessageHandler.handleMessage(this,
+ 0,
+ message);
+ }
+ assert(_impl != null);
+ switch (message.header.type) {
+ case kMediaConsumer_setBuffer_name:
+ var params = MediaConsumerSetBufferParams.deserialize(
message.payload);
- var response = _impl.requestImportedInterface(params.obj,_FactoryRequestImportedInterfaceResponseParamsFactory);
+ var response = _impl.setBuffer(params.buffer,params.size,_MediaConsumerSetBufferResponseParamsFactory);
if (response is Future) {
return response.then((response) {
if (response != null) {
return buildResponseWithId(
response,
- kFactory_requestImportedInterface_name,
+ kMediaConsumer_setBuffer_name,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -1569,21 +1521,21 @@ class FactoryStub extends bindings.Stub {
} else if (response != null) {
return buildResponseWithId(
response,
- kFactory_requestImportedInterface_name,
+ kMediaConsumer_setBuffer_name,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case kFactory_takeImportedInterface_name:
- var params = FactoryTakeImportedInterfaceParams.deserialize(
+ case kMediaConsumer_pushPacket_name:
+ var params = MediaConsumerPushPacketParams.deserialize(
message.payload);
- var response = _impl.takeImportedInterface(params.obj,_FactoryTakeImportedInterfaceResponseParamsFactory);
+ var response = _impl.pushPacket(params.packet,_MediaConsumerPushPacketResponseParamsFactory);
if (response is Future) {
return response.then((response) {
if (response != null) {
return buildResponseWithId(
response,
- kFactory_takeImportedInterface_name,
+ kMediaConsumer_pushPacket_name,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -1591,7 +1543,7 @@ class FactoryStub extends bindings.Stub {
} else if (response != null) {
return buildResponseWithId(
response,
- kFactory_takeImportedInterface_name,
+ kMediaConsumer_pushPacket_name,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -1603,15 +1555,15 @@ class FactoryStub extends bindings.Stub {
return null;
}
- Factory get impl => _impl;
- set impl(Factory d) {
+ MediaConsumer get impl => _impl;
+ set impl(MediaConsumer d) {
assert(_impl == null);
_impl = d;
}
String toString() {
var superString = super.toString();
- return "FactoryStub($superString)";
+ return "MediaConsumerStub($superString)";
}
int get version => 0;

Powered by Google App Engine
This is Rietveld 408576698