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 network_service_mojom; | 5 library network_service_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 1007 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1018 void getCookieStore(Object cookieStore); | 1018 void getCookieStore(Object cookieStore); |
1019 void createWebSocket(Object socket); | 1019 void createWebSocket(Object socket); |
1020 dynamic createTcpBoundSocket(net_address_mojom.NetAddress localAddress,Object
boundSocket,[Function responseFactory = null]); | 1020 dynamic createTcpBoundSocket(net_address_mojom.NetAddress localAddress,Object
boundSocket,[Function responseFactory = null]); |
1021 dynamic createTcpConnectedSocket(net_address_mojom.NetAddress remoteAddress,co
re.MojoDataPipeConsumer sendStream,core.MojoDataPipeProducer receiveStream,Objec
t clientSocket,[Function responseFactory = null]); | 1021 dynamic createTcpConnectedSocket(net_address_mojom.NetAddress remoteAddress,co
re.MojoDataPipeConsumer sendStream,core.MojoDataPipeProducer receiveStream,Objec
t clientSocket,[Function responseFactory = null]); |
1022 void createUdpSocket(Object socket); | 1022 void createUdpSocket(Object socket); |
1023 dynamic createHttpServer(net_address_mojom.NetAddress localAddress,Object dele
gate,[Function responseFactory = null]); | 1023 dynamic createHttpServer(net_address_mojom.NetAddress localAddress,Object dele
gate,[Function responseFactory = null]); |
1024 void registerUrlLoaderInterceptor(Object factory); | 1024 void registerUrlLoaderInterceptor(Object factory); |
1025 void createHostResolver(Object hostResolver); | 1025 void createHostResolver(Object hostResolver); |
1026 } | 1026 } |
1027 | 1027 |
1028 | 1028 class _NetworkServiceProxyControl |
1029 class _NetworkServiceProxyControl extends bindings.ProxyMessageHandler | 1029 extends bindings.ProxyMessageHandler |
1030 implements bindings.ProxyControl { | 1030 implements bindings.ProxyControl { |
1031 _NetworkServiceProxyControl.fromEndpoint( | 1031 _NetworkServiceProxyControl.fromEndpoint( |
1032 core.MojoMessagePipeEndpoint endpoint) : super.fromEndpoint(endpoint); | 1032 core.MojoMessagePipeEndpoint endpoint) : super.fromEndpoint(endpoint); |
1033 | 1033 |
1034 _NetworkServiceProxyControl.fromHandle( | 1034 _NetworkServiceProxyControl.fromHandle( |
1035 core.MojoHandle handle) : super.fromHandle(handle); | 1035 core.MojoHandle handle) : super.fromHandle(handle); |
1036 | 1036 |
1037 _NetworkServiceProxyControl.unbound() : super.unbound(); | 1037 _NetworkServiceProxyControl.unbound() : super.unbound(); |
1038 | 1038 |
1039 service_describer.ServiceDescription get serviceDescription => | 1039 service_describer.ServiceDescription get serviceDescription => |
1040 new _NetworkServiceServiceDescription(); | 1040 new _NetworkServiceServiceDescription(); |
1041 | 1041 |
1042 String get serviceName => NetworkService.serviceName; | 1042 String get serviceName => NetworkService.serviceName; |
1043 | 1043 |
1044 @override | |
1045 void handleResponse(bindings.ServiceMessage message) { | 1044 void handleResponse(bindings.ServiceMessage message) { |
1046 switch (message.header.type) { | 1045 switch (message.header.type) { |
1047 case _networkServiceMethodCreateTcpBoundSocketName: | 1046 case _networkServiceMethodCreateTcpBoundSocketName: |
1048 var r = NetworkServiceCreateTcpBoundSocketResponseParams.deserialize( | 1047 var r = NetworkServiceCreateTcpBoundSocketResponseParams.deserialize( |
1049 message.payload); | 1048 message.payload); |
1050 if (!message.header.hasRequestId) { | 1049 if (!message.header.hasRequestId) { |
1051 proxyError("Expected a message with a valid request Id."); | 1050 proxyError("Expected a message with a valid request Id."); |
1052 return; | 1051 return; |
1053 } | 1052 } |
1054 Completer c = completerMap[message.header.requestId]; | 1053 Completer c = completerMap[message.header.requestId]; |
(...skipping 56 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1111 } | 1110 } |
1112 } | 1111 } |
1113 | 1112 |
1114 @override | 1113 @override |
1115 String toString() { | 1114 String toString() { |
1116 var superString = super.toString(); | 1115 var superString = super.toString(); |
1117 return "_NetworkServiceProxyControl($superString)"; | 1116 return "_NetworkServiceProxyControl($superString)"; |
1118 } | 1117 } |
1119 } | 1118 } |
1120 | 1119 |
1121 | 1120 class NetworkServiceProxy |
1122 class NetworkServiceProxy extends bindings.Proxy | 1121 extends bindings.Proxy |
1123 implements NetworkService { | 1122 implements NetworkService { |
1124 NetworkServiceProxy.fromEndpoint( | 1123 NetworkServiceProxy.fromEndpoint( |
1125 core.MojoMessagePipeEndpoint endpoint) | 1124 core.MojoMessagePipeEndpoint endpoint) |
1126 : super(new _NetworkServiceProxyControl.fromEndpoint(endpoint)); | 1125 : super(new _NetworkServiceProxyControl.fromEndpoint(endpoint)); |
1127 | 1126 |
1128 NetworkServiceProxy.fromHandle(core.MojoHandle handle) | 1127 NetworkServiceProxy.fromHandle(core.MojoHandle handle) |
1129 : super(new _NetworkServiceProxyControl.fromHandle(handle)); | 1128 : super(new _NetworkServiceProxyControl.fromHandle(handle)); |
1130 | 1129 |
1131 NetworkServiceProxy.unbound() | 1130 NetworkServiceProxy.unbound() |
1132 : super(new _NetworkServiceProxyControl.unbound()); | 1131 : super(new _NetworkServiceProxyControl.unbound()); |
1133 | 1132 |
(...skipping 98 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1232 ctrl.proxyError("The Proxy is closed."); | 1231 ctrl.proxyError("The Proxy is closed."); |
1233 return; | 1232 return; |
1234 } | 1233 } |
1235 var params = new _NetworkServiceCreateHostResolverParams(); | 1234 var params = new _NetworkServiceCreateHostResolverParams(); |
1236 params.hostResolver = hostResolver; | 1235 params.hostResolver = hostResolver; |
1237 ctrl.sendMessage(params, | 1236 ctrl.sendMessage(params, |
1238 _networkServiceMethodCreateHostResolverName); | 1237 _networkServiceMethodCreateHostResolverName); |
1239 } | 1238 } |
1240 } | 1239 } |
1241 | 1240 |
1242 | 1241 class _NetworkServiceStubControl |
1243 class NetworkServiceStub extends bindings.Stub { | 1242 extends bindings.StubMessageHandler |
| 1243 implements bindings.StubControl<NetworkService> { |
1244 NetworkService _impl; | 1244 NetworkService _impl; |
1245 | 1245 |
1246 NetworkServiceStub.fromEndpoint( | 1246 _NetworkServiceStubControl.fromEndpoint( |
1247 core.MojoMessagePipeEndpoint endpoint, [NetworkService impl]) | 1247 core.MojoMessagePipeEndpoint endpoint, [NetworkService impl]) |
1248 : super.fromEndpoint(endpoint, autoBegin: impl != null) { | 1248 : super.fromEndpoint(endpoint, autoBegin: impl != null) { |
1249 _impl = impl; | 1249 _impl = impl; |
1250 } | 1250 } |
1251 | 1251 |
1252 NetworkServiceStub.fromHandle( | 1252 _NetworkServiceStubControl.fromHandle( |
1253 core.MojoHandle handle, [NetworkService impl]) | 1253 core.MojoHandle handle, [NetworkService impl]) |
1254 : super.fromHandle(handle, autoBegin: impl != null) { | 1254 : super.fromHandle(handle, autoBegin: impl != null) { |
1255 _impl = impl; | 1255 _impl = impl; |
1256 } | 1256 } |
1257 | 1257 |
1258 NetworkServiceStub.unbound([this._impl]) : super.unbound(); | 1258 _NetworkServiceStubControl.unbound([this._impl]) : super.unbound(); |
1259 | |
1260 static NetworkServiceStub newFromEndpoint( | |
1261 core.MojoMessagePipeEndpoint endpoint) { | |
1262 assert(endpoint.setDescription("For NetworkServiceStub")); | |
1263 return new NetworkServiceStub.fromEndpoint(endpoint); | |
1264 } | |
1265 | 1259 |
1266 | 1260 |
1267 NetworkServiceCreateTcpBoundSocketResponseParams _networkServiceCreateTcpBound
SocketResponseParamsFactory(network_error_mojom.NetworkError result, net_address
_mojom.NetAddress boundTo) { | 1261 NetworkServiceCreateTcpBoundSocketResponseParams _networkServiceCreateTcpBound
SocketResponseParamsFactory(network_error_mojom.NetworkError result, net_address
_mojom.NetAddress boundTo) { |
1268 var result = new NetworkServiceCreateTcpBoundSocketResponseParams(); | 1262 var result = new NetworkServiceCreateTcpBoundSocketResponseParams(); |
1269 result.result = result; | 1263 result.result = result; |
1270 result.boundTo = boundTo; | 1264 result.boundTo = boundTo; |
1271 return result; | 1265 return result; |
1272 } | 1266 } |
1273 NetworkServiceCreateTcpConnectedSocketResponseParams _networkServiceCreateTcpC
onnectedSocketResponseParamsFactory(network_error_mojom.NetworkError result, net
_address_mojom.NetAddress localAddress) { | 1267 NetworkServiceCreateTcpConnectedSocketResponseParams _networkServiceCreateTcpC
onnectedSocketResponseParamsFactory(network_error_mojom.NetworkError result, net
_address_mojom.NetAddress localAddress) { |
1274 var result = new NetworkServiceCreateTcpConnectedSocketResponseParams(); | 1268 var result = new NetworkServiceCreateTcpConnectedSocketResponseParams(); |
(...skipping 133 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1408 } | 1402 } |
1409 | 1403 |
1410 @override | 1404 @override |
1411 void bind(core.MojoMessagePipeEndpoint endpoint) { | 1405 void bind(core.MojoMessagePipeEndpoint endpoint) { |
1412 super.bind(endpoint); | 1406 super.bind(endpoint); |
1413 if (!isOpen && (_impl != null)) { | 1407 if (!isOpen && (_impl != null)) { |
1414 beginHandlingEvents(); | 1408 beginHandlingEvents(); |
1415 } | 1409 } |
1416 } | 1410 } |
1417 | 1411 |
| 1412 @override |
1418 String toString() { | 1413 String toString() { |
1419 var superString = super.toString(); | 1414 var superString = super.toString(); |
1420 return "NetworkServiceStub($superString)"; | 1415 return "_NetworkServiceStubControl($superString)"; |
1421 } | 1416 } |
1422 | 1417 |
1423 int get version => 0; | 1418 int get version => 0; |
1424 | 1419 |
1425 static service_describer.ServiceDescription _cachedServiceDescription; | 1420 static service_describer.ServiceDescription _cachedServiceDescription; |
1426 static service_describer.ServiceDescription get serviceDescription { | 1421 static service_describer.ServiceDescription get serviceDescription { |
1427 if (_cachedServiceDescription == null) { | 1422 if (_cachedServiceDescription == null) { |
1428 _cachedServiceDescription = new _NetworkServiceServiceDescription(); | 1423 _cachedServiceDescription = new _NetworkServiceServiceDescription(); |
1429 } | 1424 } |
1430 return _cachedServiceDescription; | 1425 return _cachedServiceDescription; |
1431 } | 1426 } |
1432 } | 1427 } |
1433 | 1428 |
| 1429 class NetworkServiceStub |
| 1430 extends bindings.Stub<NetworkService> |
| 1431 implements NetworkService { |
| 1432 NetworkServiceStub.fromEndpoint( |
| 1433 core.MojoMessagePipeEndpoint endpoint, [NetworkService impl]) |
| 1434 : super(new _NetworkServiceStubControl.fromEndpoint(endpoint, impl)); |
| 1435 |
| 1436 NetworkServiceStub.fromHandle( |
| 1437 core.MojoHandle handle, [NetworkService impl]) |
| 1438 : super(new _NetworkServiceStubControl.fromHandle(handle, impl)); |
| 1439 |
| 1440 NetworkServiceStub.unbound([NetworkService impl]) |
| 1441 : super(new _NetworkServiceStubControl.unbound(impl)); |
| 1442 |
| 1443 static NetworkServiceStub newFromEndpoint( |
| 1444 core.MojoMessagePipeEndpoint endpoint) { |
| 1445 assert(endpoint.setDescription("For NetworkServiceStub")); |
| 1446 return new NetworkServiceStub.fromEndpoint(endpoint); |
| 1447 } |
| 1448 |
| 1449 static service_describer.ServiceDescription get serviceDescription => |
| 1450 _NetworkServiceStubControl.serviceDescription; |
| 1451 |
| 1452 |
| 1453 void createUrlLoader(Object loader) { |
| 1454 return impl.createUrlLoader(loader); |
| 1455 } |
| 1456 void getCookieStore(Object cookieStore) { |
| 1457 return impl.getCookieStore(cookieStore); |
| 1458 } |
| 1459 void createWebSocket(Object socket) { |
| 1460 return impl.createWebSocket(socket); |
| 1461 } |
| 1462 dynamic createTcpBoundSocket(net_address_mojom.NetAddress localAddress,Object
boundSocket,[Function responseFactory = null]) { |
| 1463 return impl.createTcpBoundSocket(localAddress,boundSocket,responseFactory); |
| 1464 } |
| 1465 dynamic createTcpConnectedSocket(net_address_mojom.NetAddress remoteAddress,co
re.MojoDataPipeConsumer sendStream,core.MojoDataPipeProducer receiveStream,Objec
t clientSocket,[Function responseFactory = null]) { |
| 1466 return impl.createTcpConnectedSocket(remoteAddress,sendStream,receiveStream,
clientSocket,responseFactory); |
| 1467 } |
| 1468 void createUdpSocket(Object socket) { |
| 1469 return impl.createUdpSocket(socket); |
| 1470 } |
| 1471 dynamic createHttpServer(net_address_mojom.NetAddress localAddress,Object dele
gate,[Function responseFactory = null]) { |
| 1472 return impl.createHttpServer(localAddress,delegate,responseFactory); |
| 1473 } |
| 1474 void registerUrlLoaderInterceptor(Object factory) { |
| 1475 return impl.registerUrlLoaderInterceptor(factory); |
| 1476 } |
| 1477 void createHostResolver(Object hostResolver) { |
| 1478 return impl.createHostResolver(hostResolver); |
| 1479 } |
| 1480 } |
| 1481 |
1434 | 1482 |
1435 | 1483 |
OLD | NEW |