| 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 patch class RawServerSocket { | 5 patch class RawServerSocket { |
| 6 /* patch */ static Future<RawServerSocket> bind([String address = "127.0.0.1", | 6 /* patch */ static Future<RawServerSocket> bind([String address = "127.0.0.1", |
| 7 int port = 0, | 7 int port = 0, |
| 8 int backlog = 0]) { | 8 int backlog = 0]) { |
| 9 return _RawServerSocket.bind(address, port, backlog); | 9 return _RawServerSocket.bind(address, port, backlog); |
| 10 } | 10 } |
| (...skipping 453 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 464 | 464 |
| 465 void _pause() { | 465 void _pause() { |
| 466 _socket.setListening(read: false, write: false); | 466 _socket.setListening(read: false, write: false); |
| 467 } | 467 } |
| 468 | 468 |
| 469 void _resume() { | 469 void _resume() { |
| 470 _socket.setListening(read: true, write: false); | 470 _socket.setListening(read: true, write: false); |
| 471 } | 471 } |
| 472 | 472 |
| 473 void _onSubscriptionStateChange() { | 473 void _onSubscriptionStateChange() { |
| 474 if (_controller.hasSubscribers) { | 474 if (_controller.hasListener) { |
| 475 _resume(); | 475 _resume(); |
| 476 } else { | 476 } else { |
| 477 close(); | 477 close(); |
| 478 } | 478 } |
| 479 } | 479 } |
| 480 void _onPauseStateChange() { | 480 void _onPauseStateChange() { |
| 481 if (_controller.isPaused) { | 481 if (_controller.isPaused) { |
| 482 _pause(); | 482 _pause(); |
| 483 } else { | 483 } else { |
| 484 _resume(); | 484 _resume(); |
| (...skipping 106 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 591 | 591 |
| 592 void _onPauseStateChange() { | 592 void _onPauseStateChange() { |
| 593 if (_controller.isPaused) { | 593 if (_controller.isPaused) { |
| 594 _pause(); | 594 _pause(); |
| 595 } else { | 595 } else { |
| 596 _resume(); | 596 _resume(); |
| 597 } | 597 } |
| 598 } | 598 } |
| 599 | 599 |
| 600 void _onSubscriptionStateChange() { | 600 void _onSubscriptionStateChange() { |
| 601 if (_controller.hasSubscribers) { | 601 if (_controller.hasListener) { |
| 602 _resume(); | 602 _resume(); |
| 603 } else { | 603 } else { |
| 604 close(); | 604 close(); |
| 605 } | 605 } |
| 606 } | 606 } |
| 607 } | 607 } |
| 608 | 608 |
| 609 | 609 |
| 610 patch class ServerSocket { | 610 patch class ServerSocket { |
| 611 /* patch */ static Future<ServerSocket> bind([String address = "127.0.0.1", | 611 /* patch */ static Future<ServerSocket> bind([String address = "127.0.0.1", |
| (...skipping 248 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 860 } | 860 } |
| 861 | 861 |
| 862 _closeRawSocket() { | 862 _closeRawSocket() { |
| 863 var tmp = _raw; | 863 var tmp = _raw; |
| 864 _raw = null; | 864 _raw = null; |
| 865 _closed = true; | 865 _closed = true; |
| 866 tmp.close(); | 866 tmp.close(); |
| 867 } | 867 } |
| 868 | 868 |
| 869 void _onSubscriptionStateChange() { | 869 void _onSubscriptionStateChange() { |
| 870 if (_controller.hasSubscribers) { | 870 if (_controller.hasListener) { |
| 871 _ensureRawSocketSubscription(); | 871 _ensureRawSocketSubscription(); |
| 872 // Enable read events for providing data to subscription. | 872 // Enable read events for providing data to subscription. |
| 873 if (_raw != null) { | 873 if (_raw != null) { |
| 874 _raw.readEventsEnabled = true; | 874 _raw.readEventsEnabled = true; |
| 875 } | 875 } |
| 876 } else { | 876 } else { |
| 877 _controllerClosed = true; | 877 _controllerClosed = true; |
| 878 if (_raw != null) { | 878 if (_raw != null) { |
| 879 _raw.shutdown(SocketDirection.RECEIVE); | 879 _raw.shutdown(SocketDirection.RECEIVE); |
| 880 } | 880 } |
| (...skipping 92 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 973 _raw.onBadCertificate = callback; | 973 _raw.onBadCertificate = callback; |
| 974 } | 974 } |
| 975 | 975 |
| 976 X509Certificate get peerCertificate { | 976 X509Certificate get peerCertificate { |
| 977 if (_raw == null) { | 977 if (_raw == null) { |
| 978 throw new StateError("peerCertificate called on destroyed SecureSocket"); | 978 throw new StateError("peerCertificate called on destroyed SecureSocket"); |
| 979 } | 979 } |
| 980 return _raw.peerCertificate; | 980 return _raw.peerCertificate; |
| 981 } | 981 } |
| 982 } | 982 } |
| OLD | NEW |