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

Unified Diff: pkg/dev_compiler/tool/input_sdk/lib/io/stdio.dart

Issue 2698353003: unfork DDC's copy of most SDK libraries (Closed)
Patch Set: revert core_patch Created 3 years, 10 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
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);
-}
« no previous file with comments | « pkg/dev_compiler/tool/input_sdk/lib/io/socket.dart ('k') | pkg/dev_compiler/tool/input_sdk/lib/io/string_transformer.dart » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698