| OLD | NEW |
| 1 // Copyright (c) 2013, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2013, the Dart project authors. Please see the AUTHORS file |
| 2 // for details. All rights reserved. Use of this source code is governed by a | 2 // for details. All rights reserved. Use of this source code is governed by a |
| 3 // BSD-style license that can be found in the LICENSE file. | 3 // BSD-style license that can be found in the LICENSE file. |
| 4 | 4 |
| 5 part of dart.io; | 5 part of dart.io; |
| 6 | 6 |
| 7 class _HttpIncoming extends Stream<List<int>> { | 7 class _HttpIncoming extends Stream<List<int>> { |
| 8 final int _transferLength; | 8 final int _transferLength; |
| 9 final Completer _dataCompleter = new Completer(); | 9 final Completer _dataCompleter = new Completer(); |
| 10 Stream<List<int>> _stream; | 10 Stream<List<int>> _stream; |
| (...skipping 1616 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1627 bool get _isActive => _state == _ACTIVE; | 1627 bool get _isActive => _state == _ACTIVE; |
| 1628 bool get _isIdle => _state == _IDLE; | 1628 bool get _isIdle => _state == _IDLE; |
| 1629 bool get _isClosing => _state == _CLOSING; | 1629 bool get _isClosing => _state == _CLOSING; |
| 1630 bool get _isDetached => _state == _DETACHED; | 1630 bool get _isDetached => _state == _DETACHED; |
| 1631 } | 1631 } |
| 1632 | 1632 |
| 1633 | 1633 |
| 1634 // HTTP server waiting for socket connections. | 1634 // HTTP server waiting for socket connections. |
| 1635 class _HttpServer extends Stream<HttpRequest> implements HttpServer { | 1635 class _HttpServer extends Stream<HttpRequest> implements HttpServer { |
| 1636 | 1636 |
| 1637 static Future<HttpServer> bind(String host, int port, int backlog) { | 1637 static Future<HttpServer> bind(address, int port, int backlog) { |
| 1638 return ServerSocket.bind(host, port, backlog).then((socket) { | 1638 return ServerSocket.bind(address, port, backlog: backlog).then((socket) { |
| 1639 return new _HttpServer._(socket, true); | 1639 return new _HttpServer._(socket, true); |
| 1640 }); | 1640 }); |
| 1641 } | 1641 } |
| 1642 | 1642 |
| 1643 static Future<HttpServer> bindSecure(String host, | 1643 static Future<HttpServer> bindSecure(address, |
| 1644 int port, | 1644 int port, |
| 1645 int backlog, | 1645 int backlog, |
| 1646 String certificate_name, | 1646 String certificate_name, |
| 1647 bool requestClientCertificate) { | 1647 bool requestClientCertificate) { |
| 1648 return SecureServerSocket.bind( | 1648 return SecureServerSocket.bind( |
| 1649 host, | 1649 address, |
| 1650 port, | 1650 port, |
| 1651 backlog, | |
| 1652 certificate_name, | 1651 certificate_name, |
| 1652 backlog: backlog, |
| 1653 requestClientCertificate: requestClientCertificate) | 1653 requestClientCertificate: requestClientCertificate) |
| 1654 .then((socket) { | 1654 .then((socket) { |
| 1655 return new _HttpServer._(socket, true); | 1655 return new _HttpServer._(socket, true); |
| 1656 }); | 1656 }); |
| 1657 } | 1657 } |
| 1658 | 1658 |
| 1659 _HttpServer._(this._serverSocket, this._closeServer); | 1659 _HttpServer._(this._serverSocket, this._closeServer); |
| 1660 | 1660 |
| 1661 _HttpServer.listenOn(ServerSocket this._serverSocket) | 1661 _HttpServer.listenOn(ServerSocket this._serverSocket) |
| 1662 : _closeServer = false; | 1662 : _closeServer = false; |
| (...skipping 395 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 2058 | 2058 |
| 2059 | 2059 |
| 2060 class _RedirectInfo implements RedirectInfo { | 2060 class _RedirectInfo implements RedirectInfo { |
| 2061 const _RedirectInfo(int this.statusCode, | 2061 const _RedirectInfo(int this.statusCode, |
| 2062 String this.method, | 2062 String this.method, |
| 2063 Uri this.location); | 2063 Uri this.location); |
| 2064 final int statusCode; | 2064 final int statusCode; |
| 2065 final String method; | 2065 final String method; |
| 2066 final Uri location; | 2066 final Uri location; |
| 2067 } | 2067 } |
| OLD | NEW |