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

Unified Diff: third_party/mojo/src/mojo/public/dart/src/data_pipe.dart

Issue 1142043005: Update mojo sdk to rev 1dc8a9a5db73d3718d99917fadf31f5fb2ebad4f (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: fix type conversion errors on win64 for some msvs Created 5 years, 7 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: third_party/mojo/src/mojo/public/dart/src/data_pipe.dart
diff --git a/third_party/mojo/src/mojo/public/dart/src/data_pipe.dart b/third_party/mojo/src/mojo/public/dart/src/data_pipe.dart
deleted file mode 100644
index 884bbcba8f9d9379ddd2ad7b4853ba2181937526..0000000000000000000000000000000000000000
--- a/third_party/mojo/src/mojo/public/dart/src/data_pipe.dart
+++ /dev/null
@@ -1,167 +0,0 @@
-// Copyright 2014 The Chromium Authors. 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 core;
-
-class MojoDataPipeProducer {
- static const int FLAG_NONE = 0;
- static const int FLAG_ALL_OR_NONE = 1 << 0;
-
- MojoHandle handle;
- MojoResult status;
- final int elementBytes;
-
- MojoDataPipeProducer(this.handle,
- [this.status = MojoResult.OK, this.elementBytes = 1]);
-
- int write(ByteData data, [int numBytes = -1, int flags = 0]) {
- if (handle == null) {
- status = MojoResult.INVALID_ARGUMENT;
- return 0;
- }
-
- int data_numBytes = (numBytes == -1) ? data.lengthInBytes : numBytes;
- List result =
- MojoDataPipeNatives.MojoWriteData(handle.h, data, data_numBytes, flags);
- if (result == null) {
- status = MojoResult.INVALID_ARGUMENT;
- return 0;
- }
-
- assert((result is List) && (result.length == 2));
- status = new MojoResult(result[0]);
- return result[1];
- }
-
- ByteData beginWrite(int bufferBytes, [int flags = 0]) {
- if (handle == null) {
- status = MojoResult.INVALID_ARGUMENT;
- return null;
- }
-
- List result =
- MojoDataPipeNatives.MojoBeginWriteData(handle.h, bufferBytes, flags);
- if (result == null) {
- status = MojoResult.INVALID_ARGUMENT;
- return null;
- }
-
- assert((result is List) && (result.length == 2));
- status = new MojoResult(result[0]);
- return result[1];
- }
-
- MojoResult endWrite(int bytesWritten) {
- if (handle == null) {
- status = MojoResult.INVALID_ARGUMENT;
- return status;
- }
- int result = MojoDataPipeNatives.MojoEndWriteData(handle.h, bytesWritten);
- status = new MojoResult(result);
- return status;
- }
-
- String toString() => "MojoDataPipeProducer(handle: $handle, status: $status)";
-}
-
-class MojoDataPipeConsumer {
- static const int FLAG_NONE = 0;
- static const int FLAG_ALL_OR_NONE = 1 << 0;
- static const int FLAG_DISCARD = 1 << 1;
- static const int FLAG_QUERY = 1 << 2;
- static const int FLAG_PEEK = 1 << 3;
-
- MojoHandle handle;
- MojoResult status;
- final int elementBytes;
-
- MojoDataPipeConsumer(this.handle,
- [this.status = MojoResult.OK, this.elementBytes = 1]);
-
- int read(ByteData data, [int numBytes = -1, int flags = 0]) {
- if (handle == null) {
- status = MojoResult.INVALID_ARGUMENT;
- return 0;
- }
-
- int data_numBytes = (numBytes == -1) ? data.lengthInBytes : numBytes;
- List result =
- MojoDataPipeNatives.MojoReadData(handle.h, data, data_numBytes, flags);
- if (result == null) {
- status = MojoResult.INVALID_ARGUMENT;
- return 0;
- }
- assert((result is List) && (result.length == 2));
- status = new MojoResult(result[0]);
- return result[1];
- }
-
- ByteData beginRead([int bufferBytes = 0, int flags = 0]) {
- if (handle == null) {
- status = MojoResult.INVALID_ARGUMENT;
- return null;
- }
-
- List result =
- MojoDataPipeNatives.MojoBeginReadData(handle.h, bufferBytes, flags);
- if (result == null) {
- status = MojoResult.INVALID_ARGUMENT;
- return null;
- }
-
- assert((result is List) && (result.length == 2));
- status = new MojoResult(result[0]);
- return result[1];
- }
-
- MojoResult endRead(int bytesRead) {
- if (handle == null) {
- status = MojoResult.INVALID_ARGUMENT;
- return status;
- }
- int result = MojoDataPipeNatives.MojoEndReadData(handle.h, bytesRead);
- status = new MojoResult(result);
- return status;
- }
-
- int query() => read(null, 0, FLAG_QUERY);
-
- String toString() => "MojoDataPipeConsumer("
- "handle: $handle, status: $status, available: ${query()})";
-}
-
-class MojoDataPipe {
- static const int FLAG_NONE = 0;
- static const int DEFAULT_ELEMENT_SIZE = 1;
- static const int DEFAULT_CAPACITY = 0;
-
- MojoDataPipeProducer producer;
- MojoDataPipeConsumer consumer;
- MojoResult status;
-
- MojoDataPipe._internal() {
- producer = null;
- consumer = null;
- status = MojoResult.OK;
- }
-
- factory MojoDataPipe([int elementBytes = DEFAULT_ELEMENT_SIZE,
- int capacityBytes = DEFAULT_CAPACITY, int flags = FLAG_NONE]) {
- List result = MojoDataPipeNatives.MojoCreateDataPipe(
- elementBytes, capacityBytes, flags);
- if (result == null) {
- return null;
- }
- assert((result is List) && (result.length == 3));
- MojoHandle producerHandle = new MojoHandle(result[1]);
- MojoHandle consumerHandle = new MojoHandle(result[2]);
- MojoDataPipe pipe = new MojoDataPipe._internal();
- pipe.producer = new MojoDataPipeProducer(
- producerHandle, new MojoResult(result[0]), elementBytes);
- pipe.consumer = new MojoDataPipeConsumer(
- consumerHandle, new MojoResult(result[0]), elementBytes);
- pipe.status = new MojoResult(result[0]);
- return pipe;
- }
-}
« no previous file with comments | « third_party/mojo/src/mojo/public/dart/src/codec.dart ('k') | third_party/mojo/src/mojo/public/dart/src/drain_data.dart » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698