Index: third_party/mojo/src/mojo/public/go/system/message_pipe.go |
diff --git a/third_party/mojo/src/mojo/public/go/system/message_pipe.go b/third_party/mojo/src/mojo/public/go/system/message_pipe.go |
deleted file mode 100644 |
index 149b5becc1761a2f092043d23671e5e57ede2314..0000000000000000000000000000000000000000 |
--- a/third_party/mojo/src/mojo/public/go/system/message_pipe.go |
+++ /dev/null |
@@ -1,59 +0,0 @@ |
-// Copyright 2015 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. |
- |
-package system |
- |
-// MessagePipeHandle is a handle for a bidirectional communication channel for |
-// framed data (i.e., messages). Messages can contain plain data and/or Mojo |
-// handles. |
-type MessagePipeHandle interface { |
- Handle |
- |
- // ReadMessage reads a message from the message pipe endpoint with the |
- // specified flags. Returns the message data and attached handles that were |
- // received in the "next" message. |
- ReadMessage(flags MojoReadMessageFlags) (MojoResult, []byte, []UntypedHandle) |
- |
- // WriteMessage writes message data and optional attached handles to |
- // the message pipe endpoint given by handle. On success the attached |
- // handles will no longer be valid (i.e.: the receiver will receive |
- // equivalent but logically different handles). |
- WriteMessage(bytes []byte, handles []UntypedHandle, flags MojoWriteMessageFlags) MojoResult |
-} |
- |
-type messagePipe struct { |
- // baseHandle should always be the first component of this struct, |
- // see |finalizeHandle()| for more details. |
- baseHandle |
-} |
- |
-func (h *messagePipe) ReadMessage(flags MojoReadMessageFlags) (MojoResult, []byte, []UntypedHandle) { |
- h.core.mu.Lock() |
- r, buf, rawHandles := sysImpl.ReadMessage(uint32(h.mojoHandle), uint32(flags)) |
- h.core.mu.Unlock() |
- if r != 0 { |
- return MojoResult(r), nil, nil |
- } |
- |
- handles := make([]UntypedHandle, len(rawHandles)) |
- for i := 0; i < len(handles); i++ { |
- handles[i] = h.core.AcquireNativeHandle(MojoHandle(rawHandles[i])) |
- } |
- return MojoResult(r), buf, handles |
-} |
- |
-func (h *messagePipe) WriteMessage(bytes []byte, handles []UntypedHandle, flags MojoWriteMessageFlags) MojoResult { |
- |
- var rawHandles []uint32 |
- if len(handles) != 0 { |
- rawHandles = make([]uint32, len(handles)) |
- for i := 0; i < len(handles); i++ { |
- rawHandles[i] = uint32(handles[i].ReleaseNativeHandle()) |
- } |
- } |
- h.core.mu.Lock() |
- r := sysImpl.WriteMessage(uint32(h.mojoHandle), bytes, rawHandles, uint32(flags)) |
- h.core.mu.Unlock() |
- return MojoResult(r) |
-} |