| OLD | NEW |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 Loading... |
| 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 |
| OLD | NEW |