| 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 tcp_bound_socket_mojom; | 5 library tcp_bound_socket_mojom; |
| 6 | 6 |
| 7 import 'dart:async'; | 7 import 'dart:async'; |
| 8 | 8 |
| 9 import 'package:mojo/bindings.dart' as bindings; | 9 import 'package:mojo/bindings.dart' as bindings; |
| 10 import 'package:mojo/core.dart' as core; | 10 import 'package:mojo/core.dart' as core; |
| 11 import 'package:mojo/mojo/bindings/types/mojom_types.mojom.dart' as mojom_types; |
| 12 import 'package:mojo/mojo/bindings/types/service_describer.mojom.dart' as servic
e_describer; |
| 11 import 'package:mojo/mojo/network_error.mojom.dart' as network_error_mojom; | 13 import 'package:mojo/mojo/network_error.mojom.dart' as network_error_mojom; |
| 12 import 'package:mojo_services/mojo/net_address.mojom.dart' as net_address_mojom; | 14 import 'package:mojo_services/mojo/net_address.mojom.dart' as net_address_mojom; |
| 13 import 'package:mojo_services/mojo/tcp_connected_socket.mojom.dart' as tcp_conne
cted_socket_mojom; | 15 import 'package:mojo_services/mojo/tcp_connected_socket.mojom.dart' as tcp_conne
cted_socket_mojom; |
| 14 import 'package:mojo_services/mojo/tcp_server_socket.mojom.dart' as tcp_server_s
ocket_mojom; | 16 import 'package:mojo_services/mojo/tcp_server_socket.mojom.dart' as tcp_server_s
ocket_mojom; |
| 15 | 17 |
| 16 | 18 |
| 17 | 19 |
| 18 class _TcpBoundSocketStartListeningParams extends bindings.Struct { | 20 class _TcpBoundSocketStartListeningParams extends bindings.Struct { |
| 19 static const List<bindings.StructDataHeader> kVersions = const [ | 21 static const List<bindings.StructDataHeader> kVersions = const [ |
| 20 const bindings.StructDataHeader(16, 0) | 22 const bindings.StructDataHeader(16, 0) |
| (...skipping 53 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 74 "server: $server" ")"; | 76 "server: $server" ")"; |
| 75 } | 77 } |
| 76 | 78 |
| 77 Map toJson() { | 79 Map toJson() { |
| 78 throw new bindings.MojoCodecError( | 80 throw new bindings.MojoCodecError( |
| 79 'Object containing handles cannot be encoded to JSON.'); | 81 'Object containing handles cannot be encoded to JSON.'); |
| 80 } | 82 } |
| 81 } | 83 } |
| 82 | 84 |
| 83 | 85 |
| 86 |
| 87 |
| 84 class TcpBoundSocketStartListeningResponseParams extends bindings.Struct { | 88 class TcpBoundSocketStartListeningResponseParams extends bindings.Struct { |
| 85 static const List<bindings.StructDataHeader> kVersions = const [ | 89 static const List<bindings.StructDataHeader> kVersions = const [ |
| 86 const bindings.StructDataHeader(16, 0) | 90 const bindings.StructDataHeader(16, 0) |
| 87 ]; | 91 ]; |
| 88 network_error_mojom.NetworkError result = null; | 92 network_error_mojom.NetworkError result = null; |
| 89 | 93 |
| 90 TcpBoundSocketStartListeningResponseParams() : super(kVersions.last.size); | 94 TcpBoundSocketStartListeningResponseParams() : super(kVersions.last.size); |
| 91 | 95 |
| 92 static TcpBoundSocketStartListeningResponseParams deserialize(bindings.Message
message) { | 96 static TcpBoundSocketStartListeningResponseParams deserialize(bindings.Message
message) { |
| 93 var decoder = new bindings.Decoder(message); | 97 var decoder = new bindings.Decoder(message); |
| (...skipping 48 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 142 } | 146 } |
| 143 | 147 |
| 144 Map toJson() { | 148 Map toJson() { |
| 145 Map map = new Map(); | 149 Map map = new Map(); |
| 146 map["result"] = result; | 150 map["result"] = result; |
| 147 return map; | 151 return map; |
| 148 } | 152 } |
| 149 } | 153 } |
| 150 | 154 |
| 151 | 155 |
| 156 |
| 157 |
| 152 class _TcpBoundSocketConnectParams extends bindings.Struct { | 158 class _TcpBoundSocketConnectParams extends bindings.Struct { |
| 153 static const List<bindings.StructDataHeader> kVersions = const [ | 159 static const List<bindings.StructDataHeader> kVersions = const [ |
| 154 const bindings.StructDataHeader(32, 0) | 160 const bindings.StructDataHeader(32, 0) |
| 155 ]; | 161 ]; |
| 156 net_address_mojom.NetAddress remoteAddress = null; | 162 net_address_mojom.NetAddress remoteAddress = null; |
| 157 core.MojoDataPipeConsumer sendStream = null; | 163 core.MojoDataPipeConsumer sendStream = null; |
| 158 core.MojoDataPipeProducer receiveStream = null; | 164 core.MojoDataPipeProducer receiveStream = null; |
| 159 Object clientSocket = null; | 165 Object clientSocket = null; |
| 160 | 166 |
| 161 _TcpBoundSocketConnectParams() : super(kVersions.last.size); | 167 _TcpBoundSocketConnectParams() : super(kVersions.last.size); |
| (...skipping 71 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 233 "clientSocket: $clientSocket" ")"; | 239 "clientSocket: $clientSocket" ")"; |
| 234 } | 240 } |
| 235 | 241 |
| 236 Map toJson() { | 242 Map toJson() { |
| 237 throw new bindings.MojoCodecError( | 243 throw new bindings.MojoCodecError( |
| 238 'Object containing handles cannot be encoded to JSON.'); | 244 'Object containing handles cannot be encoded to JSON.'); |
| 239 } | 245 } |
| 240 } | 246 } |
| 241 | 247 |
| 242 | 248 |
| 249 |
| 250 |
| 243 class TcpBoundSocketConnectResponseParams extends bindings.Struct { | 251 class TcpBoundSocketConnectResponseParams extends bindings.Struct { |
| 244 static const List<bindings.StructDataHeader> kVersions = const [ | 252 static const List<bindings.StructDataHeader> kVersions = const [ |
| 245 const bindings.StructDataHeader(16, 0) | 253 const bindings.StructDataHeader(16, 0) |
| 246 ]; | 254 ]; |
| 247 network_error_mojom.NetworkError result = null; | 255 network_error_mojom.NetworkError result = null; |
| 248 | 256 |
| 249 TcpBoundSocketConnectResponseParams() : super(kVersions.last.size); | 257 TcpBoundSocketConnectResponseParams() : super(kVersions.last.size); |
| 250 | 258 |
| 251 static TcpBoundSocketConnectResponseParams deserialize(bindings.Message messag
e) { | 259 static TcpBoundSocketConnectResponseParams deserialize(bindings.Message messag
e) { |
| 252 var decoder = new bindings.Decoder(message); | 260 var decoder = new bindings.Decoder(message); |
| (...skipping 47 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 300 "result: $result" ")"; | 308 "result: $result" ")"; |
| 301 } | 309 } |
| 302 | 310 |
| 303 Map toJson() { | 311 Map toJson() { |
| 304 Map map = new Map(); | 312 Map map = new Map(); |
| 305 map["result"] = result; | 313 map["result"] = result; |
| 306 return map; | 314 return map; |
| 307 } | 315 } |
| 308 } | 316 } |
| 309 | 317 |
| 318 |
| 319 |
| 320 |
| 310 const int _TcpBoundSocket_startListeningName = 0; | 321 const int _TcpBoundSocket_startListeningName = 0; |
| 311 const int _TcpBoundSocket_connectName = 1; | 322 const int _TcpBoundSocket_connectName = 1; |
| 312 | 323 |
| 324 |
| 325 |
| 326 class _TcpBoundSocketServiceDescription implements service_describer.ServiceDesc
ription { |
| 327 dynamic getTopLevelInterface([Function responseFactory]) => null; |
| 328 |
| 329 dynamic getTypeDefinition(String typeKey, [Function responseFactory]) => null; |
| 330 |
| 331 dynamic getAllTypeDefinitions([Function responseFactory]) => null; |
| 332 } |
| 333 |
| 313 abstract class TcpBoundSocket { | 334 abstract class TcpBoundSocket { |
| 314 static const String serviceName = null; | 335 static const String serviceName = null; |
| 315 dynamic startListening(Object server,[Function responseFactory = null]); | 336 dynamic startListening(Object server,[Function responseFactory = null]); |
| 316 dynamic connect(net_address_mojom.NetAddress remoteAddress,core.MojoDataPipeCo
nsumer sendStream,core.MojoDataPipeProducer receiveStream,Object clientSocket,[F
unction responseFactory = null]); | 337 dynamic connect(net_address_mojom.NetAddress remoteAddress,core.MojoDataPipeCo
nsumer sendStream,core.MojoDataPipeProducer receiveStream,Object clientSocket,[F
unction responseFactory = null]); |
| 317 } | 338 } |
| 318 | 339 |
| 319 | 340 |
| 320 class _TcpBoundSocketProxyImpl extends bindings.Proxy { | 341 class _TcpBoundSocketProxyImpl extends bindings.Proxy { |
| 321 _TcpBoundSocketProxyImpl.fromEndpoint( | 342 _TcpBoundSocketProxyImpl.fromEndpoint( |
| 322 core.MojoMessagePipeEndpoint endpoint) : super.fromEndpoint(endpoint); | 343 core.MojoMessagePipeEndpoint endpoint) : super.fromEndpoint(endpoint); |
| 323 | 344 |
| 324 _TcpBoundSocketProxyImpl.fromHandle(core.MojoHandle handle) : | 345 _TcpBoundSocketProxyImpl.fromHandle(core.MojoHandle handle) : |
| 325 super.fromHandle(handle); | 346 super.fromHandle(handle); |
| 326 | 347 |
| 327 _TcpBoundSocketProxyImpl.unbound() : super.unbound(); | 348 _TcpBoundSocketProxyImpl.unbound() : super.unbound(); |
| 328 | 349 |
| 329 static _TcpBoundSocketProxyImpl newFromEndpoint( | 350 static _TcpBoundSocketProxyImpl newFromEndpoint( |
| 330 core.MojoMessagePipeEndpoint endpoint) { | 351 core.MojoMessagePipeEndpoint endpoint) { |
| 331 assert(endpoint.setDescription("For _TcpBoundSocketProxyImpl")); | 352 assert(endpoint.setDescription("For _TcpBoundSocketProxyImpl")); |
| 332 return new _TcpBoundSocketProxyImpl.fromEndpoint(endpoint); | 353 return new _TcpBoundSocketProxyImpl.fromEndpoint(endpoint); |
| 333 } | 354 } |
| 334 | 355 |
| 356 service_describer.ServiceDescription get serviceDescription => |
| 357 new _TcpBoundSocketServiceDescription(); |
| 358 |
| 335 void handleResponse(bindings.ServiceMessage message) { | 359 void handleResponse(bindings.ServiceMessage message) { |
| 336 switch (message.header.type) { | 360 switch (message.header.type) { |
| 337 case _TcpBoundSocket_startListeningName: | 361 case _TcpBoundSocket_startListeningName: |
| 338 var r = TcpBoundSocketStartListeningResponseParams.deserialize( | 362 var r = TcpBoundSocketStartListeningResponseParams.deserialize( |
| 339 message.payload); | 363 message.payload); |
| 340 if (!message.header.hasRequestId) { | 364 if (!message.header.hasRequestId) { |
| 341 proxyError("Expected a message with a valid request Id."); | 365 proxyError("Expected a message with a valid request Id."); |
| 342 return; | 366 return; |
| 343 } | 367 } |
| 344 Completer c = completerMap[message.header.requestId]; | 368 Completer c = completerMap[message.header.requestId]; |
| (...skipping 224 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 569 assert(_impl == null); | 593 assert(_impl == null); |
| 570 _impl = d; | 594 _impl = d; |
| 571 } | 595 } |
| 572 | 596 |
| 573 String toString() { | 597 String toString() { |
| 574 var superString = super.toString(); | 598 var superString = super.toString(); |
| 575 return "TcpBoundSocketStub($superString)"; | 599 return "TcpBoundSocketStub($superString)"; |
| 576 } | 600 } |
| 577 | 601 |
| 578 int get version => 0; | 602 int get version => 0; |
| 603 |
| 604 service_describer.ServiceDescription get serviceDescription => |
| 605 new _TcpBoundSocketServiceDescription(); |
| 579 } | 606 } |
| 580 | 607 |
| 581 | 608 |
| 609 |
| OLD | NEW |