| OLD | NEW |
| 1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 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 // | 5 // |
| 6 // Implementation of ServerSocket and RawServerSocket for Mojo. | 6 // Implementation of ServerSocket and RawServerSocket for Mojo. |
| 7 // | 7 // |
| 8 | 8 |
| 9 patch class RawServerSocket { | 9 patch class RawServerSocket { |
| 10 /* patch */ static Future<RawServerSocket> bind(address, | 10 /* patch */ static Future<RawServerSocket> bind(address, |
| (...skipping 27 matching lines...) Expand all Loading... |
| 38 Future _scheduledAccept; | 38 Future _scheduledAccept; |
| 39 bool _paused = false; | 39 bool _paused = false; |
| 40 bool _closed = false; | 40 bool _closed = false; |
| 41 var _owner; | 41 var _owner; |
| 42 | 42 |
| 43 static Future<_MojoRawServerSocket> _bind(NetAddress bindAddress, | 43 static Future<_MojoRawServerSocket> _bind(NetAddress bindAddress, |
| 44 int backlog, | 44 int backlog, |
| 45 bool v6Only, | 45 bool v6Only, |
| 46 bool shared) async { | 46 bool shared) async { |
| 47 final rawServerSocket = new _MojoRawServerSocket(v6Only); | 47 final rawServerSocket = new _MojoRawServerSocket(v6Only); |
| 48 final networkService = _getNetworkService().ptr; | 48 final networkService = _getNetworkService(); |
| 49 assert(networkService != null); | 49 assert(networkService != null); |
| 50 var response = | 50 var response = |
| 51 await networkService.createTcpBoundSocket( | 51 await networkService.createTcpBoundSocket( |
| 52 bindAddress, | 52 bindAddress, |
| 53 rawServerSocket._tcpBoundSocket); | 53 rawServerSocket._tcpBoundSocket); |
| 54 if (!_NetworkService._okay(response.result)) { | 54 if (!_NetworkService._okay(response.result)) { |
| 55 rawServerSocket.close(); | 55 rawServerSocket.close(); |
| 56 _NetworkService._throwOnError(response.result); | 56 _NetworkService._throwOnError(response.result); |
| 57 } | 57 } |
| 58 rawServerSocket._boundAddress = | 58 rawServerSocket._boundAddress = |
| 59 _NetworkServiceCodec._fromNetAddress(response.boundTo); | 59 _NetworkServiceCodec._fromNetAddress(response.boundTo); |
| 60 rawServerSocket._boundPort = | 60 rawServerSocket._boundPort = |
| 61 _NetworkServiceCodec._portFromNetAddress(response.boundTo); | 61 _NetworkServiceCodec._portFromNetAddress(response.boundTo); |
| 62 final boundSocket = rawServerSocket._tcpBoundSocket.ptr; | 62 final boundSocket = rawServerSocket._tcpBoundSocket; |
| 63 response = | 63 response = |
| 64 await boundSocket.startListening(rawServerSocket._tcpServerSocket); | 64 await boundSocket.startListening(rawServerSocket._tcpServerSocket); |
| 65 if (!_NetworkService._okay(response.result)) { | 65 if (!_NetworkService._okay(response.result)) { |
| 66 rawServerSocket.close(); | 66 rawServerSocket.close(); |
| 67 _NetworkService._throwOnError(response.result); | 67 _NetworkService._throwOnError(response.result); |
| 68 } | 68 } |
| 69 return rawServerSocket; | 69 return rawServerSocket; |
| 70 } | 70 } |
| 71 | 71 |
| 72 static Future<_MojoRawServerSocket> bind(address, | 72 static Future<_MojoRawServerSocket> bind(address, |
| (...skipping 23 matching lines...) Expand all Loading... |
| 96 var rawSocket = new _MojoRawSocket(); | 96 var rawSocket = new _MojoRawSocket(); |
| 97 rawSocket._localAddress = _boundAddress; | 97 rawSocket._localAddress = _boundAddress; |
| 98 rawSocket._localPort = _boundPort; | 98 rawSocket._localPort = _boundPort; |
| 99 rawSocket._setupIn(); | 99 rawSocket._setupIn(); |
| 100 rawSocket._setupOut(); | 100 rawSocket._setupOut(); |
| 101 rawSocket._tracePipeIn(); | 101 rawSocket._tracePipeIn(); |
| 102 rawSocket._tracePipeOut(); | 102 rawSocket._tracePipeOut(); |
| 103 var response; | 103 var response; |
| 104 try { | 104 try { |
| 105 response = await _tcpServerSocket.responseOrError( | 105 response = await _tcpServerSocket.responseOrError( |
| 106 _tcpServerSocket.ptr.accept(rawSocket._pipeOut.consumer, | 106 _tcpServerSocket.accept(rawSocket._pipeOut.consumer, |
| 107 rawSocket._pipeIn.producer, | 107 rawSocket._pipeIn.producer, |
| 108 rawSocket._tcpConnectedSocket)); | 108 rawSocket._tcpConnectedSocket)); |
| 109 } on ProxyError catch (e) { | 109 } on ProxyError catch (e) { |
| 110 rawSocket.destroy(); | 110 rawSocket.destroy(); |
| 111 await _destroy(); | 111 await _destroy(); |
| 112 return; | 112 return; |
| 113 } catch (e) { | 113 } catch (e) { |
| 114 _controller.addError(e); | 114 _controller.addError(e); |
| 115 rawSocket.destroy(); | 115 rawSocket.destroy(); |
| 116 await _destroy(); | 116 await _destroy(); |
| 117 return; | 117 return; |
| 118 } | 118 } |
| (...skipping 161 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 280 int get port => _socket.port; | 280 int get port => _socket.port; |
| 281 | 281 |
| 282 InternetAddress get address => _socket.address; | 282 InternetAddress get address => _socket.address; |
| 283 | 283 |
| 284 Future close() => _socket.close().then((_) => this); | 284 Future close() => _socket.close().then((_) => this); |
| 285 | 285 |
| 286 Map _toJSON(bool ref) => _socket._toJSON(ref); | 286 Map _toJSON(bool ref) => _socket._toJSON(ref); |
| 287 | 287 |
| 288 void set _owner(owner) { _socket._owner = owner; } | 288 void set _owner(owner) { _socket._owner = owner; } |
| 289 } | 289 } |
| OLD | NEW |