Index: mojo/dart/embedder/io/socket_patch.dart |
diff --git a/mojo/dart/embedder/io/socket_patch.dart b/mojo/dart/embedder/io/socket_patch.dart |
index f771f648273a41b100ffe8d7ee2ece2ea29d678f..273f59310a4b71b142f0aa34aa5beb5b242303fb 100644 |
--- a/mojo/dart/embedder/io/socket_patch.dart |
+++ b/mojo/dart/embedder/io/socket_patch.dart |
@@ -22,7 +22,7 @@ patch class RawSocket { |
class _MojoRawSocket extends Stream<RawSocketEvent> implements RawSocket { |
StreamController<RawSocketEvent> _controller; |
- final _tcpBoundSocket = new TcpBoundSocketProxy.unbound(); |
+ final _tcpBoundSocket = new _TcpBoundSocketProxy.unbound(); |
final _tcpConnectedSocket = new TcpConnectedSocketProxy.unbound(); |
// Constructing a new MojoDataPipe allocates two handles. All failure paths |
// must be sure that these handles are closed so we do not leak any handles. |
@@ -54,8 +54,10 @@ class _MojoRawSocket extends Stream<RawSocketEvent> implements RawSocket { |
if (!_trace) { |
return; |
} |
- _tracePrint('_tcpBoundSocket handle = ${_tcpBoundSocket.handle}'); |
- _tracePrint('_tcpConnectedSocket handle = ${_tcpConnectedSocket.handle}'); |
+ _tracePrint( |
+ '_tcpBoundSocket handle = ${_tcpBoundSocket.proxy.handle}'); |
+ _tracePrint( |
+ '_tcpConnectedSocket handle = ${_tcpConnectedSocket.handle}'); |
} |
_tracePipeIn() { |
@@ -124,7 +126,7 @@ class _MojoRawSocket extends Stream<RawSocketEvent> implements RawSocket { |
if (!_trace) { |
return; |
} |
- _tracePrint(_tcpBoundSocket.toString()); |
+ _tracePrint(_tcpBoundSocket.proxy.toString()); |
} |
static int _traceIdGenerator = 0; |
@@ -152,9 +154,8 @@ class _MojoRawSocket extends Stream<RawSocketEvent> implements RawSocket { |
var rawSocket = new _MojoRawSocket(); |
var networkService = _getNetworkService(); |
assert(networkService != null); |
- var response = |
- await networkService.createTcpBoundSocket(source, |
- rawSocket._tcpBoundSocket); |
+ var response = await networkService.createTcpBoundSocket( |
+ source, rawSocket._tcpBoundSocket.proxy); |
if (!_NetworkService._okay(response.result)) { |
rawSocket.close(); |
_NetworkService._throwOnError(response.result); |