Index: pkg/dev_compiler/tool/input_sdk/lib/io/stdio.dart |
diff --git a/pkg/dev_compiler/tool/input_sdk/lib/io/stdio.dart b/pkg/dev_compiler/tool/input_sdk/lib/io/stdio.dart |
deleted file mode 100644 |
index 03721e9864bc3b18df90a3c3a214d21bc86239ef..0000000000000000000000000000000000000000 |
--- a/pkg/dev_compiler/tool/input_sdk/lib/io/stdio.dart |
+++ /dev/null |
@@ -1,361 +0,0 @@ |
-// Copyright (c) 2013, the Dart project authors. Please see the AUTHORS file |
-// for details. All rights reserved. Use of this source code is governed by a |
-// BSD-style license that can be found in the LICENSE file. |
- |
-part of dart.io; |
- |
-const int _STDIO_HANDLE_TYPE_TERMINAL = 0; |
-const int _STDIO_HANDLE_TYPE_PIPE = 1; |
-const int _STDIO_HANDLE_TYPE_FILE = 2; |
-const int _STDIO_HANDLE_TYPE_SOCKET = 3; |
-const int _STDIO_HANDLE_TYPE_OTHER = 4; |
- |
- |
-class _StdStream extends Stream<List<int>> { |
- final Stream<List<int>> _stream; |
- |
- _StdStream(this._stream); |
- |
- StreamSubscription<List<int>> listen(void onData(List<int> event), |
- {Function onError, |
- void onDone(), |
- bool cancelOnError}) { |
- return _stream.listen( |
- onData, |
- onError: onError, |
- onDone: onDone, |
- cancelOnError: cancelOnError); |
- } |
-} |
- |
- |
-/** |
- * [Stdin] allows both synchronous and asynchronous reads from the standard |
- * input stream. |
- * |
- * Mixing synchronous and asynchronous reads is undefined. |
- */ |
-class Stdin extends _StdStream implements Stream<List<int>> { |
- Stdin._(Stream<List<int>> stream) : super(stream); |
- |
- /** |
- * Synchronously read a line from stdin. This call will block until a full |
- * line is available. |
- * |
- * The argument [encoding] can be used to changed how the input should be |
- * decoded. Default is [SYSTEM_ENCODING]. |
- * |
- * If [retainNewlines] is `false`, the returned String will not contain the |
- * final newline. If `true`, the returned String will contain the line |
- * terminator. Default is `false`. |
- * |
- * If end-of-file is reached after any bytes have been read from stdin, |
- * that data is returned. |
- * Returns `null` if no bytes preceeded the end of input. |
- */ |
- String readLineSync({Encoding encoding: SYSTEM_ENCODING, |
- bool retainNewlines: false}) { |
- const CR = 13; |
- const LF = 10; |
- final List line = []; |
- // On Windows, if lineMode is disabled, only CR is received. |
- bool crIsNewline = Platform.isWindows && |
- (stdioType(stdin) == StdioType.TERMINAL) && |
- !lineMode; |
- if (retainNewlines) { |
- int byte; |
- do { |
- byte = readByteSync(); |
- if (byte < 0) { |
- break; |
- } |
- line.add(byte); |
- } while (byte != LF && !(byte == CR && crIsNewline)); |
- if (line.isEmpty) { |
- return null; |
- } |
- } else if (crIsNewline) { |
- // CR and LF are both line terminators, neither is retained. |
- while (true) { |
- int byte = readByteSync(); |
- if (byte < 0) { |
- if (line.isEmpty) return null; |
- break; |
- } |
- if (byte == LF || byte == CR) break; |
- line.add(byte); |
- } |
- } else { |
- // Case having to hande CR LF as a single unretained line terminator. |
- outer: while (true) { |
- int byte = readByteSync(); |
- if (byte == LF) break; |
- if (byte == CR) { |
- do { |
- byte = readByteSync(); |
- if (byte == LF) break outer; |
- |
- line.add(CR); |
- } while (byte == CR); |
- // Fall through and handle non-CR character. |
- } |
- if (byte < 0) { |
- if (line.isEmpty) return null; |
- break; |
- } |
- line.add(byte); |
- } |
- } |
- return encoding.decode(line); |
- } |
- |
- /** |
- * Check if echo mode is enabled on [stdin]. |
- */ |
- external bool get echoMode; |
- |
- /** |
- * Enable or disable echo mode on [stdin]. |
- * |
- * If disabled, input from to console will not be echoed. |
- * |
- * Default depends on the parent process, but usually enabled. |
- */ |
- external void set echoMode(bool enabled); |
- |
- /** |
- * Check if line mode is enabled on [stdin]. |
- */ |
- external bool get lineMode; |
- |
- /** |
- * Enable or disable line mode on [stdin]. |
- * |
- * If enabled, characters are delayed until a new-line character is entered. |
- * If disabled, characters will be available as typed. |
- * |
- * Default depends on the parent process, but usually enabled. |
- */ |
- external void set lineMode(bool enabled); |
- |
- /** |
- * Synchronously read a byte from stdin. This call will block until a byte is |
- * available. |
- * |
- * If at end of file, -1 is returned. |
- */ |
- external int readByteSync(); |
-} |
- |
- |
-/** |
- * [Stdout] represents the [IOSink] for either `stdout` or `stderr`. |
- * |
- * It provides a *blocking* `IOSink`, so using this to write will block until |
- * the output is written. |
- * |
- * In some situations this blocking behavior is undesirable as it does not |
- * provide the same non-blocking behavior as dart:io in general exposes. |
- * Use the property [nonBlocking] to get an `IOSink` which has the non-blocking |
- * behavior. |
- * |
- * This class can also be used to check whether `stdout` or `stderr` is |
- * connected to a terminal and query some terminal properties. |
- */ |
-class Stdout extends _StdSink implements IOSink { |
- final int _fd; |
- IOSink _nonBlocking; |
- |
- Stdout._(IOSink sink, this._fd) : super(sink); |
- |
- /** |
- * Returns true if there is a terminal attached to stdout. |
- */ |
- bool get hasTerminal => _hasTerminal(_fd); |
- |
- /** |
- * Get the number of columns of the terminal. |
- * |
- * If no terminal is attached to stdout, a [StdoutException] is thrown. See |
- * [hasTerminal] for more info. |
- */ |
- int get terminalColumns => _terminalColumns(_fd); |
- |
- /** |
- * Get the number of lines of the terminal. |
- * |
- * If no terminal is attached to stdout, a [StdoutException] is thrown. See |
- * [hasTerminal] for more info. |
- */ |
- int get terminalLines => _terminalLines(_fd); |
- |
- external bool _hasTerminal(int fd); |
- external int _terminalColumns(int fd); |
- external int _terminalLines(int fd); |
- |
- /** |
- * Get a non-blocking `IOSink`. |
- */ |
- IOSink get nonBlocking { |
- if (_nonBlocking == null) { |
- _nonBlocking = new IOSink(new _FileStreamConsumer.fromStdio(_fd)); |
- } |
- return _nonBlocking; |
- } |
-} |
- |
- |
-class StdoutException implements IOException { |
- final String message; |
- final OSError osError; |
- |
- const StdoutException(this.message, [this.osError]); |
- |
- String toString() { |
- return "StdoutException: $message${osError == null ? "" : ", $osError"}"; |
- } |
-} |
- |
-class _StdConsumer implements StreamConsumer<List<int>> { |
- final _file; |
- |
- _StdConsumer(int fd) : _file = _File._openStdioSync(fd); |
- |
- Future addStream(Stream<List<int>> stream) { |
- var completer = new Completer(); |
- var sub; |
- sub = stream.listen( |
- (data) { |
- try { |
- _file.writeFromSync(data); |
- } catch (e, s) { |
- sub.cancel(); |
- completer.completeError(e, s); |
- } |
- }, |
- onError: completer.completeError, |
- onDone: completer.complete, |
- cancelOnError: true); |
- return completer.future; |
- } |
- |
- Future close() { |
- _file.closeSync(); |
- return new Future.value(); |
- } |
-} |
- |
-class _StdSink implements IOSink { |
- final IOSink _sink; |
- |
- _StdSink(this._sink); |
- |
- Encoding get encoding => _sink.encoding; |
- void set encoding(Encoding encoding) { |
- _sink.encoding = encoding; |
- } |
- void write(object) { _sink.write(object); } |
- void writeln([object = "" ]) { _sink.writeln(object); } |
- void writeAll(objects, [sep = ""]) { _sink.writeAll(objects, sep); } |
- void add(List<int> data) { _sink.add(data); } |
- void addError(error, [StackTrace stackTrace]) { |
- _sink.addError(error, stackTrace); |
- } |
- void writeCharCode(int charCode) { _sink.writeCharCode(charCode); } |
- Future addStream(Stream<List<int>> stream) => _sink.addStream(stream); |
- Future flush() => _sink.flush(); |
- Future close() => _sink.close(); |
- Future get done => _sink.done; |
-} |
- |
-/// The type of object a standard IO stream is attached to. |
-class StdioType { |
- static const StdioType TERMINAL = const StdioType._("terminal"); |
- static const StdioType PIPE = const StdioType._("pipe"); |
- static const StdioType FILE = const StdioType._("file"); |
- static const StdioType OTHER = const StdioType._("other"); |
- final String name; |
- const StdioType._(this.name); |
- String toString() => "StdioType: $name"; |
-} |
- |
- |
-Stdin _stdin; |
-Stdout _stdout; |
-Stdout _stderr; |
- |
- |
-/// The standard input stream of data read by this program. |
-Stdin get stdin { |
- if (_stdin == null) { |
- _stdin = _StdIOUtils._getStdioInputStream(); |
- } |
- return _stdin; |
-} |
- |
- |
-/// The standard output stream of data written by this program. |
-Stdout get stdout { |
- if (_stdout == null) { |
- _stdout = _StdIOUtils._getStdioOutputStream(1); |
- } |
- return _stdout; |
-} |
- |
- |
-/// The standard output stream of errors written by this program. |
-Stdout get stderr { |
- if (_stderr == null) { |
- _stderr = _StdIOUtils._getStdioOutputStream(2); |
- } |
- return _stderr; |
-} |
- |
- |
-/// For a stream, returns whether it is attached to a file, pipe, terminal, or |
-/// something else. |
-StdioType stdioType(object) { |
- if (object is _StdStream) { |
- object = object._stream; |
- } else if (object == stdout || object == stderr) { |
- switch (_StdIOUtils._getStdioHandleType(object == stdout ? 1 : 2)) { |
- case _STDIO_HANDLE_TYPE_TERMINAL: return StdioType.TERMINAL; |
- case _STDIO_HANDLE_TYPE_PIPE: return StdioType.PIPE; |
- case _STDIO_HANDLE_TYPE_FILE: return StdioType.FILE; |
- } |
- } |
- if (object is _FileStream) { |
- return StdioType.FILE; |
- } |
- if (object is Socket) { |
- int socketType = _StdIOUtils._socketType(object); |
- if (socketType == null) return StdioType.OTHER; |
- switch (socketType) { |
- case _STDIO_HANDLE_TYPE_TERMINAL: |
- return StdioType.TERMINAL; |
- case _STDIO_HANDLE_TYPE_PIPE: |
- return StdioType.PIPE; |
- case _STDIO_HANDLE_TYPE_FILE: |
- return StdioType.FILE; |
- } |
- } |
- if (object is _IOSinkImpl) { |
- try { |
- if (object._target is _FileStreamConsumer) { |
- return StdioType.FILE; |
- } |
- } catch (e) { |
- // Only the interface implemented, _sink not available. |
- } |
- } |
- return StdioType.OTHER; |
-} |
- |
- |
-class _StdIOUtils { |
- external static _getStdioOutputStream(int fd); |
- external static Stdin _getStdioInputStream(); |
- /// Returns the socket type or `null` if [socket] is not a builtin socket. |
- external static int _socketType(Socket socket); |
- external static _getStdioHandleType(int fd); |
-} |