| 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 | 5 |
| 6 class _SocketBase { | 6 class _SocketBase { |
| 7 // Bit flags used when communicating between the eventhandler and | 7 // Bit flags used when communicating between the eventhandler and |
| 8 // dart code. The EVENT flags are used to indicate events of | 8 // dart code. The EVENT flags are used to indicate events of |
| 9 // interest when sending a message from dart code to the | 9 // interest when sending a message from dart code to the |
| 10 // eventhandler. When receiving a message from the eventhandler the | 10 // eventhandler. When receiving a message from the eventhandler the |
| (...skipping 288 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 299 } | 299 } |
| 300 if (offset < 0) { | 300 if (offset < 0) { |
| 301 throw new IndexOutOfRangeException(offset); | 301 throw new IndexOutOfRangeException(offset); |
| 302 } | 302 } |
| 303 if (bytes < 0) { | 303 if (bytes < 0) { |
| 304 throw new IndexOutOfRangeException(bytes); | 304 throw new IndexOutOfRangeException(bytes); |
| 305 } | 305 } |
| 306 if ((offset + bytes) > buffer.length) { | 306 if ((offset + bytes) > buffer.length) { |
| 307 throw new IndexOutOfRangeException(offset + bytes); | 307 throw new IndexOutOfRangeException(offset + bytes); |
| 308 } | 308 } |
| 309 // When using the Dart C API access to ObjectArray by index is | 309 // When using the Dart C API to access raw data, using a ByteArray is |
| 310 // currently much faster. This function will make a copy of the | 310 // currently much faster. This function will make a copy of the |
| 311 // supplied List to an ObjectArray if it isn't already. | 311 // supplied List to a ByteArray if it isn't already. |
| 312 ObjectArray outBuffer; | 312 List outBuffer; |
| 313 int outOffset = offset; | 313 int outOffset = offset; |
| 314 if (buffer is ObjectArray) { | 314 if (buffer is ByteArray || buffer is ObjectArray) { |
| 315 outBuffer = buffer; | 315 outBuffer = buffer; |
| 316 } else { | 316 } else { |
| 317 outBuffer = new ObjectArray(bytes); | 317 outBuffer = new ByteArray(bytes); |
| 318 outOffset = 0; | 318 outOffset = 0; |
| 319 int j = offset; | 319 int j = offset; |
| 320 for (int i = 0; i < bytes; i++) { | 320 for (int i = 0; i < bytes; i++) { |
| 321 outBuffer[i] = buffer[j]; | 321 int value = buffer[j]; |
| 322 if (value is! int) { |
| 323 throw new FileIOException( |
| 324 "List element is not an integer at index $j"); |
| 325 } |
| 326 outBuffer[i] = value; |
| 322 j++; | 327 j++; |
| 323 } | 328 } |
| 324 } | 329 } |
| 325 var bytes_written = _writeList(outBuffer, outOffset, bytes); | 330 var bytes_written = _writeList(outBuffer, outOffset, bytes); |
| 326 if (bytes_written < 0) { | 331 if (bytes_written < 0) { |
| 327 // If writing fails we return 0 as the number of bytes and | 332 // If writing fails we return 0 as the number of bytes and |
| 328 // report the error on the error handler. | 333 // report the error on the error handler. |
| 329 bytes_written = 0; | 334 bytes_written = 0; |
| 330 _reportError(); | 335 _reportError(); |
| 331 } | 336 } |
| (...skipping 123 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 455 bool _seenFirstOutEvent = false; | 460 bool _seenFirstOutEvent = false; |
| 456 bool _closedRead = false; | 461 bool _closedRead = false; |
| 457 bool _closedWrite = false; | 462 bool _closedWrite = false; |
| 458 bool _pipe = false; | 463 bool _pipe = false; |
| 459 Function _clientConnectHandler; | 464 Function _clientConnectHandler; |
| 460 Function _clientWriteHandler; | 465 Function _clientWriteHandler; |
| 461 SocketInputStream _inputStream; | 466 SocketInputStream _inputStream; |
| 462 SocketOutputStream _outputStream; | 467 SocketOutputStream _outputStream; |
| 463 } | 468 } |
| 464 | 469 |
| OLD | NEW |