| OLD | NEW |
| 1 // Copyright (c) 2012, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2012, 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 ServerSocket { | 5 patch class ServerSocket { |
| 6 /* patch */ factory ServerSocket(String bindAddress, int port, int backlog) { | 6 /* patch */ factory ServerSocket(String bindAddress, int port, int backlog) { |
| 7 return new _ServerSocket(bindAddress, port, backlog); | 7 return new _ServerSocket(bindAddress, port, backlog); |
| 8 } | 8 } |
| 9 } | 9 } |
| 10 | 10 |
| (...skipping 27 matching lines...) Expand all Loading... |
| 38 static const int _LISTENING_SOCKET = 16; | 38 static const int _LISTENING_SOCKET = 16; |
| 39 static const int _PIPE = 17; | 39 static const int _PIPE = 17; |
| 40 | 40 |
| 41 static const int _FIRST_EVENT = _IN_EVENT; | 41 static const int _FIRST_EVENT = _IN_EVENT; |
| 42 static const int _LAST_EVENT = _CLOSE_EVENT; | 42 static const int _LAST_EVENT = _CLOSE_EVENT; |
| 43 | 43 |
| 44 static const int _FIRST_COMMAND = _CLOSE_COMMAND; | 44 static const int _FIRST_COMMAND = _CLOSE_COMMAND; |
| 45 static const int _LAST_COMMAND = _SHUTDOWN_WRITE_COMMAND; | 45 static const int _LAST_COMMAND = _SHUTDOWN_WRITE_COMMAND; |
| 46 | 46 |
| 47 _SocketBase () { | 47 _SocketBase () { |
| 48 _handlerMap = new List(_LAST_EVENT + 1); | 48 _handlerMap = new List.fixedLength(_LAST_EVENT + 1); |
| 49 _handlerMask = 0; | 49 _handlerMask = 0; |
| 50 _canActivateHandlers = true; | 50 _canActivateHandlers = true; |
| 51 _closed = true; | 51 _closed = true; |
| 52 _EventHandler._start(); | 52 _EventHandler._start(); |
| 53 _hashCode = _nextHashCode; | 53 _hashCode = _nextHashCode; |
| 54 _nextHashCode = (_nextHashCode + 1) & 0xFFFFFFF; | 54 _nextHashCode = (_nextHashCode + 1) & 0xFFFFFFF; |
| 55 } | 55 } |
| 56 | 56 |
| 57 // Multiplexes socket events to the socket handlers. | 57 // Multiplexes socket events to the socket handlers. |
| 58 void _multiplex(int event_mask) { | 58 void _multiplex(int event_mask) { |
| (...skipping 273 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 332 | 332 |
| 333 class _Socket extends _SocketBase implements Socket { | 333 class _Socket extends _SocketBase implements Socket { |
| 334 static const HOST_NAME_LOOKUP = 0; | 334 static const HOST_NAME_LOOKUP = 0; |
| 335 | 335 |
| 336 // Constructs a new socket. During the construction an asynchronous | 336 // Constructs a new socket. During the construction an asynchronous |
| 337 // host name lookup is initiated. The returned socket is not yet | 337 // host name lookup is initiated. The returned socket is not yet |
| 338 // connected but ready for registration of callbacks. | 338 // connected but ready for registration of callbacks. |
| 339 factory _Socket(String host, int port) { | 339 factory _Socket(String host, int port) { |
| 340 Socket socket = new _Socket._internal(); | 340 Socket socket = new _Socket._internal(); |
| 341 _ensureSocketService(); | 341 _ensureSocketService(); |
| 342 List request = new List(2); | 342 List request = new List.fixedLength(2); |
| 343 request[0] = HOST_NAME_LOOKUP; | 343 request[0] = HOST_NAME_LOOKUP; |
| 344 request[1] = host; | 344 request[1] = host; |
| 345 _socketService.call(request).then((response) { | 345 _socketService.call(request).then((response) { |
| 346 if (socket._isErrorResponse(response)) { | 346 if (socket._isErrorResponse(response)) { |
| 347 socket._reportError(response, "Failed host name lookup"); | 347 socket._reportError(response, "Failed host name lookup"); |
| 348 } else{ | 348 } else{ |
| 349 var result = socket._createConnect(response, port); | 349 var result = socket._createConnect(response, port); |
| 350 if (result is OSError) { | 350 if (result is OSError) { |
| 351 socket.close(); | 351 socket.close(); |
| 352 socket._reportError(result, "Connection failed"); | 352 socket._reportError(result, "Connection failed"); |
| (...skipping 245 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 598 bool _seenFirstOutEvent = false; | 598 bool _seenFirstOutEvent = false; |
| 599 bool _pipe = false; | 599 bool _pipe = false; |
| 600 Function _clientConnectHandler; | 600 Function _clientConnectHandler; |
| 601 Function _clientWriteHandler; | 601 Function _clientWriteHandler; |
| 602 _SocketInputStream _inputStream; | 602 _SocketInputStream _inputStream; |
| 603 _SocketOutputStream _outputStream; | 603 _SocketOutputStream _outputStream; |
| 604 String _remoteHost; | 604 String _remoteHost; |
| 605 int _remotePort; | 605 int _remotePort; |
| 606 static SendPort _socketService; | 606 static SendPort _socketService; |
| 607 } | 607 } |
| OLD | NEW |