1 files changed, 155 insertions, 0 deletions
diff --git a/mojo/public/dart/src/message_pipe.dart b/mojo/public/dart/src/message_pipe.dart
new file mode 100644
index 0000000..81d9f28
--- /dev/null
+++ b/mojo/public/dart/src/message_pipe.dart
@@ -0,0 +1,155 @@
+// 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 _MojoMessagePipeNatives {
+  static List MojoCreateMessagePipe(int flags)
+      native "MojoMessagePipe_Create";
+
+  static int MojoWriteMessage(
+      int handle, ByteData data, int num_bytes, List<int> handles, int flags)
+      native "MojoMessagePipe_Write";
+
+  static List MojoReadMessage(
+      int handle, ByteData data, int num_bytes, List<int> handles, int flags)
+      native "MojoMessagePipe_Read";
+}
+
+
+class MojoMessagePipeReadResult {
+  final MojoResult status;
+  final int bytesRead;
+  final int handlesRead;
+
+  MojoMessagePipeReadResult(this.status, this.bytesRead, this.handlesRead);
+  MojoMessagePipeReadResult.fromList(List<int> resultList)
+      : this(new MojoResult(resultList[0]), resultList[1], resultList[2]);
+}
+
+
+class MojoMessagePipeEndpoint {
+  static const int WRITE_FLAG_NONE = 0;
+  static const int READ_FLAG_NONE = 0;
+  static const int READ_FLAG_MAY_DISCARD = 0;
+
+  RawMojoHandle handle;
+  MojoResult status;
+
+  MojoMessagePipeEndpoint(this.handle);
+
+  MojoResult write(ByteData data,
+                   [int num_bytes = -1,
+                    List<RawMojoHandle> handles = null,
+                    int flags = 0]) {
+    if (handle == null) {
+      status = MojoResult.INVALID_ARGUMENT;
+      return status;
+    }
+
+    // If num_bytes has the default value, use the full length of the data.
+    int data_num_bytes = (num_bytes == -1) ? data.lengthInBytes : num_bytes;
+    if (data_num_bytes > data.lengthInBytes) {
+      status = MojoResult.INVALID_ARGUMENT;
+      return status;
+    }
+
+    // handles may be null, otherwise convert to ints.
+    List<int> mojo_handles =
+        (handles != null) ? handles.map((h) => h.h).toList() : null;
+
+    // Do the call.
+    int result = _MojoMessagePipeNatives.MojoWriteMessage(
+        handle.h, data, data_num_bytes, mojo_handles, flags);
+
+    status = new MojoResult(result);
+    return status;
+  }
+
+
+  MojoMessagePipeReadResult read(ByteData data,
+                                 [int num_bytes = -1,
+                                  List<RawMojoHandle> handles = null,
+                                  int flags = 0]) {
+    if (handle == null) {
+      status = MojoResult.INVALID_ARGUMENT;
+      return null;
+    }
+
+    // If num_bytes has the default value, use the full length of the data.
+    int data_num_bytes;
+    if (data == null) {
+      data_num_bytes = 0;
+    } else {
+      data_num_bytes = (num_bytes == -1) ? data.lengthInBytes : num_bytes;
+    }
+    if (data_num_bytes > data.lengthInBytes) {
+      status = MojoResult.INVALID_ARGUMENT;
+      return status;
+    }
+
+    // handles may be null, otherwise make an int list for the handles.
+    List<int> mojo_handles;
+    if (handles == null) {
+      mojo_handles = null;
+    } else {
+      mojo_handles = new List<int>(handles.length);
+    }
+
+    // Do the call.
+    List result = _MojoMessagePipeNatives.MojoReadMessage(
+        handle.h, data, data_num_bytes, mojo_handles, flags);
+
+    if (result == null) {
+      status = MojoResult.INVALID_ARGUMENT;
+      return null;
+    }
+
+    assert((result is List) && (result.length == 3));
+    var readResult = new MojoMessagePipeReadResult.fromList(result);
+
+    // Copy out the handles that were read.
+    if (handles != null) {
+      for (var i = 0; i < readResult.handlesRead; i++) {
+        handles[i].h = mojo_handles[i];
+      }
+    }
+
+    status = readResult.status;
+    return readResult;
+  }
+
+  MojoMessagePipeReadResult query() => read(null);
+}
+
+
+class MojoMessagePipe {
+  static const int FLAG_NONE = 0;
+
+  List<MojoMessagePipeEndpoint> endpoints;
+  MojoResult status;
+
+  MojoMessagePipe._() {
+    endpoints = null;
+    status = MojoResult.OK;
+  }
+
+  factory MojoMessagePipe([int flags = FLAG_NONE]) {
+    List result = _MojoMessagePipeNatives.MojoCreateMessagePipe(flags);
+    if (result == null) {
+      return null;
+    }
+    assert((result is List) && (result.length == 3));
+
+    RawMojoHandle end1 = new RawMojoHandle(result[1]);
+    RawMojoHandle end2 = new RawMojoHandle(result[2]);
+    MojoMessagePipe pipe = new MojoMessagePipe._();
+    pipe.endpoints = new List(2);
+    pipe.endpoints[0] = new MojoMessagePipeEndpoint(end1);
+    pipe.endpoints[1] = new MojoMessagePipeEndpoint(end2);
+    pipe.status = new MojoResult(result[0]);
+    return pipe;
+  }
+}