Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(985)

Unified Diff: runtime/bin/socket_patch.dart

Issue 1072783003: Remove server socket references (Closed) Base URL: https://dart.googlecode.com/svn/branches/bleeding_edge/dart
Patch Set: Rebased Created 5 years, 2 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « runtime/bin/socket.cc ('k') | sdk/lib/io/socket.dart » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: runtime/bin/socket_patch.dart
diff --git a/runtime/bin/socket_patch.dart b/runtime/bin/socket_patch.dart
index 47e5f444f16026cc20c4929491e7b05054fc9854..7de16a988220aabbdf9a312d67c6494acc59479e 100644
--- a/runtime/bin/socket_patch.dart
+++ b/runtime/bin/socket_patch.dart
@@ -1083,8 +1083,6 @@ class _NativeSocket extends _NativeSocketNativeWrapper with _ServiceObject {
bool nativeLeaveMulticast(
List<int> addr, List<int> interfaceAddr, int interfaceIndex)
native "Socket_LeaveMulticast";
- bool _nativeMarkSocketAsSharedHack()
- native "Socket_MarkSocketAsSharedHack";
}
@@ -1187,50 +1185,10 @@ class _RawServerSocket extends Stream<RawSocket>
}
}
- RawServerSocketReference get reference {
- if (_referencePort == null) {
- bool successfull = _socket._nativeMarkSocketAsSharedHack();
- _referencePort = new ReceivePort();
- _referencePort.listen((sendPort) {
- sendPort.send(
- [_socket.address,
- _socket.port,
- _v6Only]);
- });
- }
- return new _RawServerSocketReference(_referencePort.sendPort);
- }
-
void set _owner(owner) { _socket.owner = owner; }
}
-class _RawServerSocketReference implements RawServerSocketReference {
- final SendPort _sendPort;
-
- _RawServerSocketReference(this._sendPort);
-
- Future<RawServerSocket> create() {
- var port = new ReceivePort();
- _sendPort.send(port.sendPort);
- return port.first.then((List args) {
- port.close();
-
- InternetAddress address = args[0];
- int tcpPort = args[1];
- bool v6Only = args[2];
- return
- RawServerSocket.bind(address, tcpPort, v6Only: v6Only, shared: true);
- });
- }
-
- int get hashCode => _sendPort.hashCode;
-
- bool operator==(Object other)
- => other is _RawServerSocketReference && _sendPort == other._sendPort;
-}
-
-
class _RawSocket extends Stream<RawSocketEvent>
implements RawSocket {
final _NativeSocket _socket;
@@ -1393,17 +1351,6 @@ patch class ServerSocket {
}
-class _ServerSocketReference implements ServerSocketReference {
- final RawServerSocketReference _rawReference;
-
- _ServerSocketReference(this._rawReference);
-
- Future<ServerSocket> create() {
- return _rawReference.create().then((raw) => new _ServerSocket(raw));
- }
-}
-
-
class _ServerSocket extends Stream<Socket>
implements ServerSocket {
final _socket;
@@ -1436,10 +1383,6 @@ class _ServerSocket extends Stream<Socket>
Future close() => _socket.close().then((_) => this);
- ServerSocketReference get reference {
- return new _ServerSocketReference(_socket.reference);
- }
-
void set _owner(owner) { _socket._owner = owner; }
}
« no previous file with comments | « runtime/bin/socket.cc ('k') | sdk/lib/io/socket.dart » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698