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

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

Issue 1874003002: Motown: Get rid of speculative clock definition (Closed) Base URL: https://github.com/domokit/mojo.git@master
Patch Set: Created 4 years, 8 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 unified diff | Download patch
OLDNEW
1 // Copyright 2014 The Chromium Authors. All rights reserved. 1 // Copyright 2014 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 library media_sink_mojom; 5 library media_sink_mojom;
6 import 'dart:async'; 6 import 'dart:async';
7 import 'package:mojo/bindings.dart' as bindings; 7 import 'package:mojo/bindings.dart' as bindings;
8 import 'package:mojo/core.dart' as core; 8 import 'package:mojo/core.dart' as core;
9 import 'package:mojo/mojo/bindings/types/service_describer.mojom.dart' as servic e_describer; 9 import 'package:mojo/mojo/bindings/types/service_describer.mojom.dart' as servic e_describer;
10 import 'package:mojo_services/mojo/media/media_clock.mojom.dart' as media_clock_ mojom;
11 import 'package:mojo_services/mojo/media/media_state.mojom.dart' as media_state_ mojom; 10 import 'package:mojo_services/mojo/media/media_state.mojom.dart' as media_state_ mojom;
12 import 'package:mojo_services/mojo/media/media_transport.mojom.dart' as media_tr ansport_mojom; 11 import 'package:mojo_services/mojo/media/media_transport.mojom.dart' as media_tr ansport_mojom;
13 import 'package:mojo_services/mojo/media/rate_control.mojom.dart' as rate_contro l_mojom; 12 import 'package:mojo_services/mojo/media/rate_control.mojom.dart' as rate_contro l_mojom;
14 13
15 14
16 15
17 class MediaSinkStatus extends bindings.Struct { 16 class MediaSinkStatus extends bindings.Struct {
18 static const List<bindings.StructDataHeader> kVersions = const [ 17 static const List<bindings.StructDataHeader> kVersions = const [
19 const bindings.StructDataHeader(24, 0) 18 const bindings.StructDataHeader(24, 0)
20 ]; 19 ];
(...skipping 77 matching lines...) Expand 10 before | Expand all | Expand 10 after
98 97
99 Map toJson() { 98 Map toJson() {
100 Map map = new Map(); 99 Map map = new Map();
101 map["state"] = state; 100 map["state"] = state;
102 map["timelineTransform"] = timelineTransform; 101 map["timelineTransform"] = timelineTransform;
103 return map; 102 return map;
104 } 103 }
105 } 104 }
106 105
107 106
108 class _MediaSinkGetClockDispositionParams extends bindings.Struct {
109 static const List<bindings.StructDataHeader> kVersions = const [
110 const bindings.StructDataHeader(8, 0)
111 ];
112
113 _MediaSinkGetClockDispositionParams() : super(kVersions.last.size);
114
115 static _MediaSinkGetClockDispositionParams deserialize(bindings.Message messag e) {
116 var decoder = new bindings.Decoder(message);
117 var result = decode(decoder);
118 if (decoder.excessHandles != null) {
119 decoder.excessHandles.forEach((h) => h.close());
120 }
121 return result;
122 }
123
124 static _MediaSinkGetClockDispositionParams decode(bindings.Decoder decoder0) {
125 if (decoder0 == null) {
126 return null;
127 }
128 _MediaSinkGetClockDispositionParams result = new _MediaSinkGetClockDispositi onParams();
129
130 var mainDataHeader = decoder0.decodeStructDataHeader();
131 if (mainDataHeader.version <= kVersions.last.version) {
132 // Scan in reverse order to optimize for more recent versions.
133 for (int i = kVersions.length - 1; i >= 0; --i) {
134 if (mainDataHeader.version >= kVersions[i].version) {
135 if (mainDataHeader.size == kVersions[i].size) {
136 // Found a match.
137 break;
138 }
139 throw new bindings.MojoCodecError(
140 'Header size doesn\'t correspond to known version size.');
141 }
142 }
143 } else if (mainDataHeader.size < kVersions.last.size) {
144 throw new bindings.MojoCodecError(
145 'Message newer than the last known version cannot be shorter than '
146 'required by the last known version.');
147 }
148 return result;
149 }
150
151 void encode(bindings.Encoder encoder) {
152 encoder.getStructEncoderAtOffset(kVersions.last);
153 }
154
155 String toString() {
156 return "_MediaSinkGetClockDispositionParams("")";
157 }
158
159 Map toJson() {
160 Map map = new Map();
161 return map;
162 }
163 }
164
165
166 class MediaSinkGetClockDispositionResponseParams extends bindings.Struct {
167 static const List<bindings.StructDataHeader> kVersions = const [
168 const bindings.StructDataHeader(16, 0)
169 ];
170 media_clock_mojom.ClockDisposition clockDisposition = null;
171
172 MediaSinkGetClockDispositionResponseParams() : super(kVersions.last.size);
173
174 static MediaSinkGetClockDispositionResponseParams deserialize(bindings.Message message) {
175 var decoder = new bindings.Decoder(message);
176 var result = decode(decoder);
177 if (decoder.excessHandles != null) {
178 decoder.excessHandles.forEach((h) => h.close());
179 }
180 return result;
181 }
182
183 static MediaSinkGetClockDispositionResponseParams decode(bindings.Decoder deco der0) {
184 if (decoder0 == null) {
185 return null;
186 }
187 MediaSinkGetClockDispositionResponseParams result = new MediaSinkGetClockDis positionResponseParams();
188
189 var mainDataHeader = decoder0.decodeStructDataHeader();
190 if (mainDataHeader.version <= kVersions.last.version) {
191 // Scan in reverse order to optimize for more recent versions.
192 for (int i = kVersions.length - 1; i >= 0; --i) {
193 if (mainDataHeader.version >= kVersions[i].version) {
194 if (mainDataHeader.size == kVersions[i].size) {
195 // Found a match.
196 break;
197 }
198 throw new bindings.MojoCodecError(
199 'Header size doesn\'t correspond to known version size.');
200 }
201 }
202 } else if (mainDataHeader.size < kVersions.last.size) {
203 throw new bindings.MojoCodecError(
204 'Message newer than the last known version cannot be shorter than '
205 'required by the last known version.');
206 }
207 if (mainDataHeader.version >= 0) {
208
209 result.clockDisposition = media_clock_mojom.ClockDisposition.decode(deco der0, 8);
210 if (result.clockDisposition == null) {
211 throw new bindings.MojoCodecError(
212 'Trying to decode null union for non-nullable media_clock_mojom.Cloc kDisposition.');
213 }
214 }
215 return result;
216 }
217
218 void encode(bindings.Encoder encoder) {
219 var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last);
220 try {
221 encoder0.encodeEnum(clockDisposition, 8);
222 } on bindings.MojoCodecError catch(e) {
223 e.message = "Error encountered while encoding field "
224 "clockDisposition of struct MediaSinkGetClockDispositionResponseParams : $e";
225 rethrow;
226 }
227 }
228
229 String toString() {
230 return "MediaSinkGetClockDispositionResponseParams("
231 "clockDisposition: $clockDisposition" ")";
232 }
233
234 Map toJson() {
235 Map map = new Map();
236 map["clockDisposition"] = clockDisposition;
237 return map;
238 }
239 }
240
241
242 class _MediaSinkGetMasterClockParams extends bindings.Struct {
243 static const List<bindings.StructDataHeader> kVersions = const [
244 const bindings.StructDataHeader(16, 0)
245 ];
246 Object masterClock = null;
247
248 _MediaSinkGetMasterClockParams() : super(kVersions.last.size);
249
250 static _MediaSinkGetMasterClockParams deserialize(bindings.Message message) {
251 var decoder = new bindings.Decoder(message);
252 var result = decode(decoder);
253 if (decoder.excessHandles != null) {
254 decoder.excessHandles.forEach((h) => h.close());
255 }
256 return result;
257 }
258
259 static _MediaSinkGetMasterClockParams decode(bindings.Decoder decoder0) {
260 if (decoder0 == null) {
261 return null;
262 }
263 _MediaSinkGetMasterClockParams result = new _MediaSinkGetMasterClockParams() ;
264
265 var mainDataHeader = decoder0.decodeStructDataHeader();
266 if (mainDataHeader.version <= kVersions.last.version) {
267 // Scan in reverse order to optimize for more recent versions.
268 for (int i = kVersions.length - 1; i >= 0; --i) {
269 if (mainDataHeader.version >= kVersions[i].version) {
270 if (mainDataHeader.size == kVersions[i].size) {
271 // Found a match.
272 break;
273 }
274 throw new bindings.MojoCodecError(
275 'Header size doesn\'t correspond to known version size.');
276 }
277 }
278 } else if (mainDataHeader.size < kVersions.last.size) {
279 throw new bindings.MojoCodecError(
280 'Message newer than the last known version cannot be shorter than '
281 'required by the last known version.');
282 }
283 if (mainDataHeader.version >= 0) {
284
285 result.masterClock = decoder0.decodeInterfaceRequest(8, false, media_clock _mojom.ClockStub.newFromEndpoint);
286 }
287 return result;
288 }
289
290 void encode(bindings.Encoder encoder) {
291 var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last);
292 try {
293 encoder0.encodeInterfaceRequest(masterClock, 8, false);
294 } on bindings.MojoCodecError catch(e) {
295 e.message = "Error encountered while encoding field "
296 "masterClock of struct _MediaSinkGetMasterClockParams: $e";
297 rethrow;
298 }
299 }
300
301 String toString() {
302 return "_MediaSinkGetMasterClockParams("
303 "masterClock: $masterClock" ")";
304 }
305
306 Map toJson() {
307 throw new bindings.MojoCodecError(
308 'Object containing handles cannot be encoded to JSON.');
309 }
310 }
311
312
313 class _MediaSinkSetMasterClockParams extends bindings.Struct {
314 static const List<bindings.StructDataHeader> kVersions = const [
315 const bindings.StructDataHeader(16, 0)
316 ];
317 Object masterClock = null;
318
319 _MediaSinkSetMasterClockParams() : super(kVersions.last.size);
320
321 static _MediaSinkSetMasterClockParams deserialize(bindings.Message message) {
322 var decoder = new bindings.Decoder(message);
323 var result = decode(decoder);
324 if (decoder.excessHandles != null) {
325 decoder.excessHandles.forEach((h) => h.close());
326 }
327 return result;
328 }
329
330 static _MediaSinkSetMasterClockParams decode(bindings.Decoder decoder0) {
331 if (decoder0 == null) {
332 return null;
333 }
334 _MediaSinkSetMasterClockParams result = new _MediaSinkSetMasterClockParams() ;
335
336 var mainDataHeader = decoder0.decodeStructDataHeader();
337 if (mainDataHeader.version <= kVersions.last.version) {
338 // Scan in reverse order to optimize for more recent versions.
339 for (int i = kVersions.length - 1; i >= 0; --i) {
340 if (mainDataHeader.version >= kVersions[i].version) {
341 if (mainDataHeader.size == kVersions[i].size) {
342 // Found a match.
343 break;
344 }
345 throw new bindings.MojoCodecError(
346 'Header size doesn\'t correspond to known version size.');
347 }
348 }
349 } else if (mainDataHeader.size < kVersions.last.size) {
350 throw new bindings.MojoCodecError(
351 'Message newer than the last known version cannot be shorter than '
352 'required by the last known version.');
353 }
354 if (mainDataHeader.version >= 0) {
355
356 result.masterClock = decoder0.decodeServiceInterface(8, true, media_clock_ mojom.ClockProxy.newFromEndpoint);
357 }
358 return result;
359 }
360
361 void encode(bindings.Encoder encoder) {
362 var encoder0 = encoder.getStructEncoderAtOffset(kVersions.last);
363 try {
364 encoder0.encodeInterface(masterClock, 8, true);
365 } on bindings.MojoCodecError catch(e) {
366 e.message = "Error encountered while encoding field "
367 "masterClock of struct _MediaSinkSetMasterClockParams: $e";
368 rethrow;
369 }
370 }
371
372 String toString() {
373 return "_MediaSinkSetMasterClockParams("
374 "masterClock: $masterClock" ")";
375 }
376
377 Map toJson() {
378 throw new bindings.MojoCodecError(
379 'Object containing handles cannot be encoded to JSON.');
380 }
381 }
382
383
384 class _MediaSinkGetConsumerParams extends bindings.Struct { 107 class _MediaSinkGetConsumerParams extends bindings.Struct {
385 static const List<bindings.StructDataHeader> kVersions = const [ 108 static const List<bindings.StructDataHeader> kVersions = const [
386 const bindings.StructDataHeader(16, 0) 109 const bindings.StructDataHeader(16, 0)
387 ]; 110 ];
388 Object consumer = null; 111 Object consumer = null;
389 112
390 _MediaSinkGetConsumerParams() : super(kVersions.last.size); 113 _MediaSinkGetConsumerParams() : super(kVersions.last.size);
391 114
392 static _MediaSinkGetConsumerParams deserialize(bindings.Message message) { 115 static _MediaSinkGetConsumerParams deserialize(bindings.Message message) {
393 var decoder = new bindings.Decoder(message); 116 var decoder = new bindings.Decoder(message);
(...skipping 325 matching lines...) Expand 10 before | Expand all | Expand 10 after
719 String toString() { 442 String toString() {
720 return "_MediaSinkPauseParams("")"; 443 return "_MediaSinkPauseParams("")";
721 } 444 }
722 445
723 Map toJson() { 446 Map toJson() {
724 Map map = new Map(); 447 Map map = new Map();
725 return map; 448 return map;
726 } 449 }
727 } 450 }
728 451
729 const int _mediaSinkMethodGetClockDispositionName = 0; 452 const int _mediaSinkMethodGetConsumerName = 0;
730 const int _mediaSinkMethodGetMasterClockName = 1; 453 const int _mediaSinkMethodGetStatusName = 1;
731 const int _mediaSinkMethodSetMasterClockName = 2; 454 const int _mediaSinkMethodPlayName = 2;
732 const int _mediaSinkMethodGetConsumerName = 3; 455 const int _mediaSinkMethodPauseName = 3;
733 const int _mediaSinkMethodGetStatusName = 4;
734 const int _mediaSinkMethodPlayName = 5;
735 const int _mediaSinkMethodPauseName = 6;
736 456
737 class _MediaSinkServiceDescription implements service_describer.ServiceDescripti on { 457 class _MediaSinkServiceDescription implements service_describer.ServiceDescripti on {
738 dynamic getTopLevelInterface([Function responseFactory]) => 458 dynamic getTopLevelInterface([Function responseFactory]) =>
739 responseFactory(null); 459 responseFactory(null);
740 460
741 dynamic getTypeDefinition(String typeKey, [Function responseFactory]) => 461 dynamic getTypeDefinition(String typeKey, [Function responseFactory]) =>
742 responseFactory(null); 462 responseFactory(null);
743 463
744 dynamic getAllTypeDefinitions([Function responseFactory]) => 464 dynamic getAllTypeDefinitions([Function responseFactory]) =>
745 responseFactory(null); 465 responseFactory(null);
746 } 466 }
747 467
748 abstract class MediaSink { 468 abstract class MediaSink {
749 static const String serviceName = null; 469 static const String serviceName = null;
750 dynamic getClockDisposition([Function responseFactory = null]);
751 void getMasterClock(Object masterClock);
752 void setMasterClock(Object masterClock);
753 void getConsumer(Object consumer); 470 void getConsumer(Object consumer);
754 dynamic getStatus(int versionLastSeen,[Function responseFactory = null]); 471 dynamic getStatus(int versionLastSeen,[Function responseFactory = null]);
755 void play(); 472 void play();
756 void pause(); 473 void pause();
757 static const int kInitialStatus = 0; 474 static const int kInitialStatus = 0;
758 } 475 }
759 476
760 477
761 class _MediaSinkProxyImpl extends bindings.Proxy { 478 class _MediaSinkProxyImpl extends bindings.Proxy {
762 _MediaSinkProxyImpl.fromEndpoint( 479 _MediaSinkProxyImpl.fromEndpoint(
763 core.MojoMessagePipeEndpoint endpoint) : super.fromEndpoint(endpoint); 480 core.MojoMessagePipeEndpoint endpoint) : super.fromEndpoint(endpoint);
764 481
765 _MediaSinkProxyImpl.fromHandle(core.MojoHandle handle) : 482 _MediaSinkProxyImpl.fromHandle(core.MojoHandle handle) :
766 super.fromHandle(handle); 483 super.fromHandle(handle);
767 484
768 _MediaSinkProxyImpl.unbound() : super.unbound(); 485 _MediaSinkProxyImpl.unbound() : super.unbound();
769 486
770 static _MediaSinkProxyImpl newFromEndpoint( 487 static _MediaSinkProxyImpl newFromEndpoint(
771 core.MojoMessagePipeEndpoint endpoint) { 488 core.MojoMessagePipeEndpoint endpoint) {
772 assert(endpoint.setDescription("For _MediaSinkProxyImpl")); 489 assert(endpoint.setDescription("For _MediaSinkProxyImpl"));
773 return new _MediaSinkProxyImpl.fromEndpoint(endpoint); 490 return new _MediaSinkProxyImpl.fromEndpoint(endpoint);
774 } 491 }
775 492
776 service_describer.ServiceDescription get serviceDescription => 493 service_describer.ServiceDescription get serviceDescription =>
777 new _MediaSinkServiceDescription(); 494 new _MediaSinkServiceDescription();
778 495
779 void handleResponse(bindings.ServiceMessage message) { 496 void handleResponse(bindings.ServiceMessage message) {
780 switch (message.header.type) { 497 switch (message.header.type) {
781 case _mediaSinkMethodGetClockDispositionName:
782 var r = MediaSinkGetClockDispositionResponseParams.deserialize(
783 message.payload);
784 if (!message.header.hasRequestId) {
785 proxyError("Expected a message with a valid request Id.");
786 return;
787 }
788 Completer c = completerMap[message.header.requestId];
789 if (c == null) {
790 proxyError(
791 "Message had unknown request Id: ${message.header.requestId}");
792 return;
793 }
794 completerMap.remove(message.header.requestId);
795 if (c.isCompleted) {
796 proxyError("Response completer already completed");
797 return;
798 }
799 c.complete(r);
800 break;
801 case _mediaSinkMethodGetStatusName: 498 case _mediaSinkMethodGetStatusName:
802 var r = MediaSinkGetStatusResponseParams.deserialize( 499 var r = MediaSinkGetStatusResponseParams.deserialize(
803 message.payload); 500 message.payload);
804 if (!message.header.hasRequestId) { 501 if (!message.header.hasRequestId) {
805 proxyError("Expected a message with a valid request Id."); 502 proxyError("Expected a message with a valid request Id.");
806 return; 503 return;
807 } 504 }
808 Completer c = completerMap[message.header.requestId]; 505 Completer c = completerMap[message.header.requestId];
809 if (c == null) { 506 if (c == null) {
810 proxyError( 507 proxyError(
(...skipping 18 matching lines...) Expand all
829 var superString = super.toString(); 526 var superString = super.toString();
830 return "_MediaSinkProxyImpl($superString)"; 527 return "_MediaSinkProxyImpl($superString)";
831 } 528 }
832 } 529 }
833 530
834 531
835 class _MediaSinkProxyCalls implements MediaSink { 532 class _MediaSinkProxyCalls implements MediaSink {
836 _MediaSinkProxyImpl _proxyImpl; 533 _MediaSinkProxyImpl _proxyImpl;
837 534
838 _MediaSinkProxyCalls(this._proxyImpl); 535 _MediaSinkProxyCalls(this._proxyImpl);
839 dynamic getClockDisposition([Function responseFactory = null]) {
840 var params = new _MediaSinkGetClockDispositionParams();
841 return _proxyImpl.sendMessageWithRequestId(
842 params,
843 _mediaSinkMethodGetClockDispositionName,
844 -1,
845 bindings.MessageHeader.kMessageExpectsResponse);
846 }
847 void getMasterClock(Object masterClock) {
848 if (!_proxyImpl.isBound) {
849 _proxyImpl.proxyError("The Proxy is closed.");
850 return;
851 }
852 var params = new _MediaSinkGetMasterClockParams();
853 params.masterClock = masterClock;
854 _proxyImpl.sendMessage(params, _mediaSinkMethodGetMasterClockName);
855 }
856 void setMasterClock(Object masterClock) {
857 if (!_proxyImpl.isBound) {
858 _proxyImpl.proxyError("The Proxy is closed.");
859 return;
860 }
861 var params = new _MediaSinkSetMasterClockParams();
862 params.masterClock = masterClock;
863 _proxyImpl.sendMessage(params, _mediaSinkMethodSetMasterClockName);
864 }
865 void getConsumer(Object consumer) { 536 void getConsumer(Object consumer) {
866 if (!_proxyImpl.isBound) { 537 if (!_proxyImpl.isBound) {
867 _proxyImpl.proxyError("The Proxy is closed."); 538 _proxyImpl.proxyError("The Proxy is closed.");
868 return; 539 return;
869 } 540 }
870 var params = new _MediaSinkGetConsumerParams(); 541 var params = new _MediaSinkGetConsumerParams();
871 params.consumer = consumer; 542 params.consumer = consumer;
872 _proxyImpl.sendMessage(params, _mediaSinkMethodGetConsumerName); 543 _proxyImpl.sendMessage(params, _mediaSinkMethodGetConsumerName);
873 } 544 }
874 dynamic getStatus(int versionLastSeen,[Function responseFactory = null]) { 545 dynamic getStatus(int versionLastSeen,[Function responseFactory = null]) {
(...skipping 95 matching lines...) Expand 10 before | Expand all | Expand 10 after
970 641
971 MediaSinkStub.unbound() : super.unbound(); 642 MediaSinkStub.unbound() : super.unbound();
972 643
973 static MediaSinkStub newFromEndpoint( 644 static MediaSinkStub newFromEndpoint(
974 core.MojoMessagePipeEndpoint endpoint) { 645 core.MojoMessagePipeEndpoint endpoint) {
975 assert(endpoint.setDescription("For MediaSinkStub")); 646 assert(endpoint.setDescription("For MediaSinkStub"));
976 return new MediaSinkStub.fromEndpoint(endpoint); 647 return new MediaSinkStub.fromEndpoint(endpoint);
977 } 648 }
978 649
979 650
980 MediaSinkGetClockDispositionResponseParams _mediaSinkGetClockDispositionRespon seParamsFactory(media_clock_mojom.ClockDisposition clockDisposition) {
981 var result = new MediaSinkGetClockDispositionResponseParams();
982 result.clockDisposition = clockDisposition;
983 return result;
984 }
985 MediaSinkGetStatusResponseParams _mediaSinkGetStatusResponseParamsFactory(int version, MediaSinkStatus status) { 651 MediaSinkGetStatusResponseParams _mediaSinkGetStatusResponseParamsFactory(int version, MediaSinkStatus status) {
986 var result = new MediaSinkGetStatusResponseParams(); 652 var result = new MediaSinkGetStatusResponseParams();
987 result.version = version; 653 result.version = version;
988 result.status = status; 654 result.status = status;
989 return result; 655 return result;
990 } 656 }
991 657
992 dynamic handleMessage(bindings.ServiceMessage message) { 658 dynamic handleMessage(bindings.ServiceMessage message) {
993 if (bindings.ControlMessageHandler.isControlMessage(message)) { 659 if (bindings.ControlMessageHandler.isControlMessage(message)) {
994 return bindings.ControlMessageHandler.handleMessage(this, 660 return bindings.ControlMessageHandler.handleMessage(this,
995 0, 661 0,
996 message); 662 message);
997 } 663 }
998 assert(_impl != null); 664 assert(_impl != null);
999 switch (message.header.type) { 665 switch (message.header.type) {
1000 case _mediaSinkMethodGetClockDispositionName:
1001 var response = _impl.getClockDisposition(_mediaSinkGetClockDispositionRe sponseParamsFactory);
1002 if (response is Future) {
1003 return response.then((response) {
1004 if (response != null) {
1005 return buildResponseWithId(
1006 response,
1007 _mediaSinkMethodGetClockDispositionName,
1008 message.header.requestId,
1009 bindings.MessageHeader.kMessageIsResponse);
1010 }
1011 });
1012 } else if (response != null) {
1013 return buildResponseWithId(
1014 response,
1015 _mediaSinkMethodGetClockDispositionName,
1016 message.header.requestId,
1017 bindings.MessageHeader.kMessageIsResponse);
1018 }
1019 break;
1020 case _mediaSinkMethodGetMasterClockName:
1021 var params = _MediaSinkGetMasterClockParams.deserialize(
1022 message.payload);
1023 _impl.getMasterClock(params.masterClock);
1024 break;
1025 case _mediaSinkMethodSetMasterClockName:
1026 var params = _MediaSinkSetMasterClockParams.deserialize(
1027 message.payload);
1028 _impl.setMasterClock(params.masterClock);
1029 break;
1030 case _mediaSinkMethodGetConsumerName: 666 case _mediaSinkMethodGetConsumerName:
1031 var params = _MediaSinkGetConsumerParams.deserialize( 667 var params = _MediaSinkGetConsumerParams.deserialize(
1032 message.payload); 668 message.payload);
1033 _impl.getConsumer(params.consumer); 669 _impl.getConsumer(params.consumer);
1034 break; 670 break;
1035 case _mediaSinkMethodGetStatusName: 671 case _mediaSinkMethodGetStatusName:
1036 var params = _MediaSinkGetStatusParams.deserialize( 672 var params = _MediaSinkGetStatusParams.deserialize(
1037 message.payload); 673 message.payload);
1038 var response = _impl.getStatus(params.versionLastSeen,_mediaSinkGetStatu sResponseParamsFactory); 674 var response = _impl.getStatus(params.versionLastSeen,_mediaSinkGetStatu sResponseParamsFactory);
1039 if (response is Future) { 675 if (response is Future) {
(...skipping 44 matching lines...) Expand 10 before | Expand all | Expand 10 after
1084 static service_describer.ServiceDescription get serviceDescription { 720 static service_describer.ServiceDescription get serviceDescription {
1085 if (_cachedServiceDescription == null) { 721 if (_cachedServiceDescription == null) {
1086 _cachedServiceDescription = new _MediaSinkServiceDescription(); 722 _cachedServiceDescription = new _MediaSinkServiceDescription();
1087 } 723 }
1088 return _cachedServiceDescription; 724 return _cachedServiceDescription;
1089 } 725 }
1090 } 726 }
1091 727
1092 728
1093 729
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698