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

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 Created 4 years, 11 months 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 35dd6559aff4167bc8bb5923a5bb4f7947832368..507df9fbcadc7d01abe87979553a839207e3d92a 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,59 +764,52 @@ 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 _NamedObject_setNameName = 0;
-const int _NamedObject_getNameName = 1;
+const int _MediaProducer_connectName = 0;
+const int _MediaProducer_disconnectName = 1;
-abstract class NamedObject {
- static const String serviceName = "sample::NamedObject";
- void setName(String name);
- dynamic getName([Function responseFactory = null]);
+abstract class MediaProducer {
+ static const String serviceName = null;
+ 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);
}
void handleResponse(bindings.ServiceMessage message) {
switch (message.header.type) {
- case _NamedObject_getNameName:
- var r = NamedObjectGetNameResponseParams.deserialize(
+ case _MediaProducer_connectName:
+ var r = MediaProducerConnectResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
proxyError("Expected a message with a valid request Id.");
@@ -1036,73 +837,73 @@ 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) {
- if (!_proxyImpl.isBound) {
- _proxyImpl.proxyError("The Proxy is closed.");
- return;
- }
- var params = new _NamedObjectSetNameParams();
- params.name = name;
- _proxyImpl.sendMessage(params, _NamedObject_setNameName);
- }
- dynamic getName([Function responseFactory = null]) {
- var params = new _NamedObjectGetNameParams();
+ _MediaProducerProxyCalls(this._proxyImpl);
+ dynamic connect(Object consumer,[Function responseFactory = null]) {
+ var params = new _MediaProducerConnectParams();
+ params.consumer = consumer;
return _proxyImpl.sendMessageWithRequestId(
params,
- _NamedObject_getNameName,
+ _MediaProducer_connectName,
-1,
bindings.MessageHeader.kMessageExpectsResponse);
}
+ void disconnect() {
+ if (!_proxyImpl.isBound) {
+ _proxyImpl.proxyError("The Proxy is closed.");
+ return;
+ }
+ var params = new _MediaProducerDisconnectParams();
+ _proxyImpl.sendMessage(params, _MediaProducer_disconnectName);
+ }
}
-class NamedObjectProxy implements bindings.ProxyBase {
+class MediaProducerProxy implements bindings.ProxyBase {
final bindings.Proxy impl;
- NamedObject ptr;
+ MediaProducer ptr;
- 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(
+ factory MediaProducerProxy.connectToService(
bindings.ServiceConnector s, String url, [String serviceName]) {
- NamedObjectProxy p = new NamedObjectProxy.unbound();
+ MediaProducerProxy p = new MediaProducerProxy.unbound();
s.connectToService(url, p, serviceName);
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);
}
- String get serviceName => NamedObject.serviceName;
+ String get serviceName => MediaProducer.serviceName;
Future close({bool immediate: false}) => impl.close(immediate: immediate);
@@ -1119,33 +920,32 @@ 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);
}
- 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;
}
@@ -1157,21 +957,16 @@ class NamedObjectStub extends bindings.Stub {
}
assert(_impl != null);
switch (message.header.type) {
- case _NamedObject_setNameName:
- var params = _NamedObjectSetNameParams.deserialize(
+ case _MediaProducer_connectName:
+ var params = _MediaProducerConnectParams.deserialize(
message.payload);
- _impl.setName(params.name);
- break;
- case _NamedObject_getNameName:
- 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,
- _NamedObject_getNameName,
+ _MediaProducer_connectName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -1179,11 +974,16 @@ class NamedObjectStub extends bindings.Stub {
} else if (response != null) {
return buildResponseWithId(
response,
- _NamedObject_getNameName,
+ _MediaProducer_connectName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
+ case _MediaProducer_disconnectName:
+ var params = _MediaProducerDisconnectParams.deserialize(
+ message.payload);
+ _impl.disconnect();
+ break;
default:
throw new bindings.MojoCodecError("Unexpected message name");
break;
@@ -1191,55 +991,51 @@ 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 _Factory_doStuffName = 0;
-const int _Factory_doStuff2Name = 1;
-const int _Factory_createNamedObjectName = 2;
-const int _Factory_requestImportedInterfaceName = 3;
-const int _Factory_takeImportedInterfaceName = 4;
+const int _MediaPullModeProducer_getBufferName = 0;
+const int _MediaPullModeProducer_pullPacketName = 1;
+const int _MediaPullModeProducer_releasePacketName = 2;
-abstract class Factory {
+abstract class MediaPullModeProducer {
static const String serviceName = null;
- 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]);
+ 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);
}
void handleResponse(bindings.ServiceMessage message) {
switch (message.header.type) {
- case _Factory_doStuffName:
- var r = FactoryDoStuffResponseParams.deserialize(
+ case _MediaPullModeProducer_getBufferName:
+ var r = MediaPullModeProducerGetBufferResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
proxyError("Expected a message with a valid request Id.");
@@ -1258,48 +1054,8 @@ class _FactoryProxyImpl extends bindings.Proxy {
}
c.complete(r);
break;
- case _Factory_doStuff2Name:
- 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 _Factory_requestImportedInterfaceName:
- 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 _Factory_takeImportedInterfaceName:
- var r = FactoryTakeImportedInterfaceResponseParams.deserialize(
+ case _MediaPullModeProducer_pullPacketName:
+ var r = MediaPullModeProducerPullPacketResponseParams.deserialize(
message.payload);
if (!message.header.hasRequestId) {
proxyError("Expected a message with a valid request Id.");
@@ -1327,102 +1083,82 @@ 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,
- _Factory_doStuffName,
+ _MediaPullModeProducer_getBufferName,
-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,
- _Factory_doStuff2Name,
+ _MediaPullModeProducer_pullPacketName,
-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, _Factory_createNamedObjectName);
- }
- dynamic requestImportedInterface(Object obj,[Function responseFactory = null]) {
- var params = new _FactoryRequestImportedInterfaceParams();
- params.obj = obj;
- return _proxyImpl.sendMessageWithRequestId(
- params,
- _Factory_requestImportedInterfaceName,
- -1,
- bindings.MessageHeader.kMessageExpectsResponse);
- }
- dynamic takeImportedInterface(Object obj,[Function responseFactory = null]) {
- var params = new _FactoryTakeImportedInterfaceParams();
- params.obj = obj;
- return _proxyImpl.sendMessageWithRequestId(
- params,
- _Factory_takeImportedInterfaceName,
- -1,
- bindings.MessageHeader.kMessageExpectsResponse);
+ var params = new _MediaPullModeProducerReleasePacketParams();
+ params.toRelease = toRelease;
+ _proxyImpl.sendMessage(params, _MediaPullModeProducer_releasePacketName);
}
}
-class FactoryProxy implements bindings.ProxyBase {
+class MediaPullModeProducerProxy implements bindings.ProxyBase {
final bindings.Proxy impl;
- Factory ptr;
+ MediaPullModeProducer ptr;
- 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(
+ factory MediaPullModeProducerProxy.connectToService(
bindings.ServiceConnector s, String url, [String serviceName]) {
- FactoryProxy p = new FactoryProxy.unbound();
+ MediaPullModeProducerProxy p = new MediaPullModeProducerProxy.unbound();
s.connectToService(url, p, serviceName);
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);
}
- String get serviceName => Factory.serviceName;
+ String get serviceName => MediaPullModeProducer.serviceName;
Future close({bool immediate: false}) => impl.close(immediate: immediate);
@@ -1439,49 +1175,38 @@ 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);
}
- 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;
}
@@ -1493,16 +1218,16 @@ class FactoryStub extends bindings.Stub {
}
assert(_impl != null);
switch (message.header.type) {
- case _Factory_doStuffName:
- var params = _FactoryDoStuffParams.deserialize(
+ case _MediaPullModeProducer_getBufferName:
+ 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,
- _Factory_doStuffName,
+ _MediaPullModeProducer_getBufferName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -1510,21 +1235,21 @@ class FactoryStub extends bindings.Stub {
} else if (response != null) {
return buildResponseWithId(
response,
- _Factory_doStuffName,
+ _MediaPullModeProducer_getBufferName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case _Factory_doStuff2Name:
- var params = _FactoryDoStuff2Params.deserialize(
+ case _MediaPullModeProducer_pullPacketName:
+ 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,
- _Factory_doStuff2Name,
+ _MediaPullModeProducer_pullPacketName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -1532,26 +1257,249 @@ class FactoryStub extends bindings.Stub {
} else if (response != null) {
return buildResponseWithId(
response,
- _Factory_doStuff2Name,
+ _MediaPullModeProducer_pullPacketName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case _Factory_createNamedObjectName:
- var params = _FactoryCreateNamedObjectParams.deserialize(
+ case _MediaPullModeProducer_releasePacketName:
+ var params = _MediaPullModeProducerReleasePacketParams.deserialize(
message.payload);
- _impl.createNamedObject(params.obj);
+ _impl.releasePacket(params.toRelease);
+ break;
+ 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 _MediaConsumer_setBufferName = 0;
+const int _MediaConsumer_pushPacketName = 1;
+
+abstract class MediaConsumer {
+ static const String serviceName = null;
+ 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);
+ }
+
+ void handleResponse(bindings.ServiceMessage message) {
+ switch (message.header.type) {
+ case _MediaConsumer_setBufferName:
+ 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 _MediaConsumer_pushPacketName:
+ 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;
- case _Factory_requestImportedInterfaceName:
- var params = _FactoryRequestImportedInterfaceParams.deserialize(
+ 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,
+ _MediaConsumer_setBufferName,
+ -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,
+ _MediaConsumer_pushPacketName,
+ -1,
+ bindings.MessageHeader.kMessageExpectsResponse);
+ }
+}
+
+
+class MediaConsumerProxy implements bindings.ProxyBase {
+ final bindings.Proxy impl;
+ MediaConsumer ptr;
+
+ 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, [String serviceName]) {
+ MediaConsumerProxy p = new MediaConsumerProxy.unbound();
+ s.connectToService(url, p, serviceName);
+ return p;
+ }
+
+ static MediaConsumerProxy newFromEndpoint(
+ core.MojoMessagePipeEndpoint endpoint) {
+ assert(endpoint.setDescription("For MediaConsumerProxy"));
+ return new MediaConsumerProxy.fromEndpoint(endpoint);
+ }
+
+ String get serviceName => MediaConsumer.serviceName;
+
+ 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);
+ }
+
+
+ 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 _MediaConsumer_setBufferName:
+ 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,
- _Factory_requestImportedInterfaceName,
+ _MediaConsumer_setBufferName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -1559,21 +1507,21 @@ class FactoryStub extends bindings.Stub {
} else if (response != null) {
return buildResponseWithId(
response,
- _Factory_requestImportedInterfaceName,
+ _MediaConsumer_setBufferName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
break;
- case _Factory_takeImportedInterfaceName:
- var params = _FactoryTakeImportedInterfaceParams.deserialize(
+ case _MediaConsumer_pushPacketName:
+ 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,
- _Factory_takeImportedInterfaceName,
+ _MediaConsumer_pushPacketName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -1581,7 +1529,7 @@ class FactoryStub extends bindings.Stub {
} else if (response != null) {
return buildResponseWithId(
response,
- _Factory_takeImportedInterfaceName,
+ _MediaConsumer_pushPacketName,
message.header.requestId,
bindings.MessageHeader.kMessageIsResponse);
}
@@ -1593,15 +1541,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