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_server_socket_mojom; | 5 library tcp_server_socket_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/mojo/network_error.mojom.dart' as network_error_mojom; | 10 import 'package:mojo/mojo/network_error.mojom.dart' as network_error_mojom; |
(...skipping 197 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
208 | 208 |
209 dynamic getAllTypeDefinitions([Function responseFactory]) => | 209 dynamic getAllTypeDefinitions([Function responseFactory]) => |
210 responseFactory(null); | 210 responseFactory(null); |
211 } | 211 } |
212 | 212 |
213 abstract class TcpServerSocket { | 213 abstract class TcpServerSocket { |
214 static const String serviceName = null; | 214 static const String serviceName = null; |
215 dynamic accept(core.MojoDataPipeConsumer sendStream,core.MojoDataPipeProducer
receiveStream,Object clientSocket,[Function responseFactory = null]); | 215 dynamic accept(core.MojoDataPipeConsumer sendStream,core.MojoDataPipeProducer
receiveStream,Object clientSocket,[Function responseFactory = null]); |
216 } | 216 } |
217 | 217 |
218 | 218 class _TcpServerSocketProxyControl |
219 class _TcpServerSocketProxyControl extends bindings.ProxyMessageHandler | 219 extends bindings.ProxyMessageHandler |
220 implements bindings.ProxyControl { | 220 implements bindings.ProxyControl { |
221 _TcpServerSocketProxyControl.fromEndpoint( | 221 _TcpServerSocketProxyControl.fromEndpoint( |
222 core.MojoMessagePipeEndpoint endpoint) : super.fromEndpoint(endpoint); | 222 core.MojoMessagePipeEndpoint endpoint) : super.fromEndpoint(endpoint); |
223 | 223 |
224 _TcpServerSocketProxyControl.fromHandle( | 224 _TcpServerSocketProxyControl.fromHandle( |
225 core.MojoHandle handle) : super.fromHandle(handle); | 225 core.MojoHandle handle) : super.fromHandle(handle); |
226 | 226 |
227 _TcpServerSocketProxyControl.unbound() : super.unbound(); | 227 _TcpServerSocketProxyControl.unbound() : super.unbound(); |
228 | 228 |
229 service_describer.ServiceDescription get serviceDescription => | 229 service_describer.ServiceDescription get serviceDescription => |
230 new _TcpServerSocketServiceDescription(); | 230 new _TcpServerSocketServiceDescription(); |
231 | 231 |
232 String get serviceName => TcpServerSocket.serviceName; | 232 String get serviceName => TcpServerSocket.serviceName; |
233 | 233 |
234 @override | |
235 void handleResponse(bindings.ServiceMessage message) { | 234 void handleResponse(bindings.ServiceMessage message) { |
236 switch (message.header.type) { | 235 switch (message.header.type) { |
237 case _tcpServerSocketMethodAcceptName: | 236 case _tcpServerSocketMethodAcceptName: |
238 var r = TcpServerSocketAcceptResponseParams.deserialize( | 237 var r = TcpServerSocketAcceptResponseParams.deserialize( |
239 message.payload); | 238 message.payload); |
240 if (!message.header.hasRequestId) { | 239 if (!message.header.hasRequestId) { |
241 proxyError("Expected a message with a valid request Id."); | 240 proxyError("Expected a message with a valid request Id."); |
242 return; | 241 return; |
243 } | 242 } |
244 Completer c = completerMap[message.header.requestId]; | 243 Completer c = completerMap[message.header.requestId]; |
(...skipping 16 matching lines...) Expand all Loading... |
261 } | 260 } |
262 } | 261 } |
263 | 262 |
264 @override | 263 @override |
265 String toString() { | 264 String toString() { |
266 var superString = super.toString(); | 265 var superString = super.toString(); |
267 return "_TcpServerSocketProxyControl($superString)"; | 266 return "_TcpServerSocketProxyControl($superString)"; |
268 } | 267 } |
269 } | 268 } |
270 | 269 |
271 | 270 class TcpServerSocketProxy |
272 class TcpServerSocketProxy extends bindings.Proxy | 271 extends bindings.Proxy |
273 implements TcpServerSocket { | 272 implements TcpServerSocket { |
274 TcpServerSocketProxy.fromEndpoint( | 273 TcpServerSocketProxy.fromEndpoint( |
275 core.MojoMessagePipeEndpoint endpoint) | 274 core.MojoMessagePipeEndpoint endpoint) |
276 : super(new _TcpServerSocketProxyControl.fromEndpoint(endpoint)); | 275 : super(new _TcpServerSocketProxyControl.fromEndpoint(endpoint)); |
277 | 276 |
278 TcpServerSocketProxy.fromHandle(core.MojoHandle handle) | 277 TcpServerSocketProxy.fromHandle(core.MojoHandle handle) |
279 : super(new _TcpServerSocketProxyControl.fromHandle(handle)); | 278 : super(new _TcpServerSocketProxyControl.fromHandle(handle)); |
280 | 279 |
281 TcpServerSocketProxy.unbound() | 280 TcpServerSocketProxy.unbound() |
282 : super(new _TcpServerSocketProxyControl.unbound()); | 281 : super(new _TcpServerSocketProxyControl.unbound()); |
283 | 282 |
(...skipping 17 matching lines...) Expand all Loading... |
301 params.receiveStream = receiveStream; | 300 params.receiveStream = receiveStream; |
302 params.clientSocket = clientSocket; | 301 params.clientSocket = clientSocket; |
303 return ctrl.sendMessageWithRequestId( | 302 return ctrl.sendMessageWithRequestId( |
304 params, | 303 params, |
305 _tcpServerSocketMethodAcceptName, | 304 _tcpServerSocketMethodAcceptName, |
306 -1, | 305 -1, |
307 bindings.MessageHeader.kMessageExpectsResponse); | 306 bindings.MessageHeader.kMessageExpectsResponse); |
308 } | 307 } |
309 } | 308 } |
310 | 309 |
311 | 310 class _TcpServerSocketStubControl |
312 class TcpServerSocketStub extends bindings.Stub { | 311 extends bindings.StubMessageHandler |
| 312 implements bindings.StubControl<TcpServerSocket> { |
313 TcpServerSocket _impl; | 313 TcpServerSocket _impl; |
314 | 314 |
315 TcpServerSocketStub.fromEndpoint( | 315 _TcpServerSocketStubControl.fromEndpoint( |
316 core.MojoMessagePipeEndpoint endpoint, [TcpServerSocket impl]) | 316 core.MojoMessagePipeEndpoint endpoint, [TcpServerSocket impl]) |
317 : super.fromEndpoint(endpoint, autoBegin: impl != null) { | 317 : super.fromEndpoint(endpoint, autoBegin: impl != null) { |
318 _impl = impl; | 318 _impl = impl; |
319 } | 319 } |
320 | 320 |
321 TcpServerSocketStub.fromHandle( | 321 _TcpServerSocketStubControl.fromHandle( |
322 core.MojoHandle handle, [TcpServerSocket impl]) | 322 core.MojoHandle handle, [TcpServerSocket impl]) |
323 : super.fromHandle(handle, autoBegin: impl != null) { | 323 : super.fromHandle(handle, autoBegin: impl != null) { |
324 _impl = impl; | 324 _impl = impl; |
325 } | 325 } |
326 | 326 |
327 TcpServerSocketStub.unbound([this._impl]) : super.unbound(); | 327 _TcpServerSocketStubControl.unbound([this._impl]) : super.unbound(); |
328 | |
329 static TcpServerSocketStub newFromEndpoint( | |
330 core.MojoMessagePipeEndpoint endpoint) { | |
331 assert(endpoint.setDescription("For TcpServerSocketStub")); | |
332 return new TcpServerSocketStub.fromEndpoint(endpoint); | |
333 } | |
334 | 328 |
335 | 329 |
336 TcpServerSocketAcceptResponseParams _tcpServerSocketAcceptResponseParamsFactor
y(network_error_mojom.NetworkError result, net_address_mojom.NetAddress remoteAd
dress) { | 330 TcpServerSocketAcceptResponseParams _tcpServerSocketAcceptResponseParamsFactor
y(network_error_mojom.NetworkError result, net_address_mojom.NetAddress remoteAd
dress) { |
337 var result = new TcpServerSocketAcceptResponseParams(); | 331 var result = new TcpServerSocketAcceptResponseParams(); |
338 result.result = result; | 332 result.result = result; |
339 result.remoteAddress = remoteAddress; | 333 result.remoteAddress = remoteAddress; |
340 return result; | 334 return result; |
341 } | 335 } |
342 | 336 |
343 dynamic handleMessage(bindings.ServiceMessage message) { | 337 dynamic handleMessage(bindings.ServiceMessage message) { |
(...skipping 47 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
391 } | 385 } |
392 | 386 |
393 @override | 387 @override |
394 void bind(core.MojoMessagePipeEndpoint endpoint) { | 388 void bind(core.MojoMessagePipeEndpoint endpoint) { |
395 super.bind(endpoint); | 389 super.bind(endpoint); |
396 if (!isOpen && (_impl != null)) { | 390 if (!isOpen && (_impl != null)) { |
397 beginHandlingEvents(); | 391 beginHandlingEvents(); |
398 } | 392 } |
399 } | 393 } |
400 | 394 |
| 395 @override |
401 String toString() { | 396 String toString() { |
402 var superString = super.toString(); | 397 var superString = super.toString(); |
403 return "TcpServerSocketStub($superString)"; | 398 return "_TcpServerSocketStubControl($superString)"; |
404 } | 399 } |
405 | 400 |
406 int get version => 0; | 401 int get version => 0; |
407 | 402 |
408 static service_describer.ServiceDescription _cachedServiceDescription; | 403 static service_describer.ServiceDescription _cachedServiceDescription; |
409 static service_describer.ServiceDescription get serviceDescription { | 404 static service_describer.ServiceDescription get serviceDescription { |
410 if (_cachedServiceDescription == null) { | 405 if (_cachedServiceDescription == null) { |
411 _cachedServiceDescription = new _TcpServerSocketServiceDescription(); | 406 _cachedServiceDescription = new _TcpServerSocketServiceDescription(); |
412 } | 407 } |
413 return _cachedServiceDescription; | 408 return _cachedServiceDescription; |
414 } | 409 } |
415 } | 410 } |
416 | 411 |
| 412 class TcpServerSocketStub |
| 413 extends bindings.Stub<TcpServerSocket> |
| 414 implements TcpServerSocket { |
| 415 TcpServerSocketStub.fromEndpoint( |
| 416 core.MojoMessagePipeEndpoint endpoint, [TcpServerSocket impl]) |
| 417 : super(new _TcpServerSocketStubControl.fromEndpoint(endpoint, impl)); |
| 418 |
| 419 TcpServerSocketStub.fromHandle( |
| 420 core.MojoHandle handle, [TcpServerSocket impl]) |
| 421 : super(new _TcpServerSocketStubControl.fromHandle(handle, impl)); |
| 422 |
| 423 TcpServerSocketStub.unbound([TcpServerSocket impl]) |
| 424 : super(new _TcpServerSocketStubControl.unbound(impl)); |
| 425 |
| 426 static TcpServerSocketStub newFromEndpoint( |
| 427 core.MojoMessagePipeEndpoint endpoint) { |
| 428 assert(endpoint.setDescription("For TcpServerSocketStub")); |
| 429 return new TcpServerSocketStub.fromEndpoint(endpoint); |
| 430 } |
| 431 |
| 432 static service_describer.ServiceDescription get serviceDescription => |
| 433 _TcpServerSocketStubControl.serviceDescription; |
| 434 |
| 435 |
| 436 dynamic accept(core.MojoDataPipeConsumer sendStream,core.MojoDataPipeProducer
receiveStream,Object clientSocket,[Function responseFactory = null]) { |
| 437 return impl.accept(sendStream,receiveStream,clientSocket,responseFactory); |
| 438 } |
| 439 } |
| 440 |
417 | 441 |
418 | 442 |
OLD | NEW |