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 |