Index: mojo/public/go/system/data_pipe.go |
diff --git a/mojo/public/go/system/data_pipe.go b/mojo/public/go/system/data_pipe.go |
deleted file mode 100644 |
index 3f331b2cb427d8816c0fdc7d7d26f9f3497b0a5b..0000000000000000000000000000000000000000 |
--- a/mojo/public/go/system/data_pipe.go |
+++ /dev/null |
@@ -1,126 +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 |
- |
-// ConsumerHandle is a handle for the consumer part of a data pipe. |
-type ConsumerHandle interface { |
- Handle |
- |
- // ReadData reads data from the data pipe consumer handle with the |
- // given flags. On success, returns the data that was read. |
- ReadData(flags MojoReadDataFlags) (MojoResult, []byte) |
- |
- // BeginReadData begins a two-phase read from the data pipe consumer. |
- // On success, returns a slice from which the caller can read up to its |
- // length bytes of data. The slice length will always be a multiple of |
- // the element size. |
- // |
- // During a two-phase read, this handle is *not* readable. E.g., read |
- // from this handle will return |MOJO_RESULT_BUSY|. |
- // |
- // Once the caller has finished reading data from the slice, it should |
- // call |EndReadData()| to specify the amount read and to complete the |
- // two-phase read. |
- BeginReadData(flags MojoReadDataFlags) (MojoResult, []byte) |
- |
- // EndReadData ends a two-phase read from the data pipe consumer that |
- // was begun by a call to |BeginReadData()| on the same handle. |
- // |numBytesRead| should indicate the amount of data actually read; it |
- // must be less than or equal to the length of the slice returned by |
- // |BeginReadData()| and must be a multiple of the element size. |
- // |
- // On failure, the two-phase read (if any) is ended (so the handle may |
- // become readable again) but no data is "removed" from the data pipe. |
- EndReadData(numBytesRead int) MojoResult |
-} |
- |
-// ProducerHandle is a handle for the producer part of a data pipe. |
-type ProducerHandle interface { |
- Handle |
- |
- // WriteData writes data to the data pipe producer handle with the |
- // given flags. On success, returns the number of bytes that were |
- // actually written. |
- WriteData(data []byte, flags MojoWriteDataFlags) (MojoResult, int) |
- |
- // BeginWriteData begins a two-phase write to the data pipe producer. |
- // On success, returns a slice to which the caller can write. The slice |
- // length will always be a multiple of the element size. |
- // |
- // During a two-phase write, this handle is *not* writable. E.g., write |
- // to this handle will return |MOJO_RESULT_BUSY|. |
- // |
- // Once the caller has finished writing data to the buffer, it should |
- // call |EndWriteData()| to specify the amount written and to complete |
- // the two-phase write. |
- BeginWriteData(flags MojoWriteDataFlags) (MojoResult, []byte) |
- |
- // EndWriteData ends a two-phase write to the data pipe producer that |
- // was begun by a call to |BeginWriteData()| on the same handle. |
- // |numBytesWritten| should indicate the amount of data actually |
- // written; it must be less than or equal to the length of the slice |
- // returned by |BeginWriteData()| and must be a multiple of the element |
- // size. The slice returned from |BeginWriteData()| must have been |
- // filled with exactly |numBytesWritten| bytes of data. |
- // |
- // On failure, the two-phase write (if any) is ended (so the handle may |
- // become writable again, if there's space available) but no data |
- // written to the slice is "put into" the data pipe. |
- EndWriteData(numBytesWritten int) MojoResult |
-} |
- |
-type dataPipeConsumer struct { |
- // baseHandle should always be the first component of this struct, |
- // see |finalizeHandle()| for more details. |
- baseHandle |
-} |
- |
-func (h *dataPipeConsumer) ReadData(flags MojoReadDataFlags) (MojoResult, []byte) { |
- h.core.mu.Lock() |
- r, buf := sysImpl.ReadData(uint32(h.mojoHandle), uint32(flags)) |
- h.core.mu.Unlock() |
- return MojoResult(r), buf |
-} |
- |
-func (h *dataPipeConsumer) BeginReadData(flags MojoReadDataFlags) (MojoResult, []byte) { |
- h.core.mu.Lock() |
- r, buf := sysImpl.BeginReadData(uint32(h.mojoHandle), uint32(flags)) |
- h.core.mu.Unlock() |
- return MojoResult(r), buf |
-} |
- |
-func (h *dataPipeConsumer) EndReadData(numBytesRead int) MojoResult { |
- h.core.mu.Lock() |
- r := sysImpl.EndReadData(uint32(h.mojoHandle), uint32(numBytesRead)) |
- h.core.mu.Unlock() |
- return MojoResult(r) |
-} |
- |
-type dataPipeProducer struct { |
- // baseHandle should always be the first component of this struct, |
- // see |finalizeHandle()| for more details. |
- baseHandle |
-} |
- |
-func (h *dataPipeProducer) WriteData(data []byte, flags MojoWriteDataFlags) (MojoResult, int) { |
- h.core.mu.Lock() |
- r, bytesWritten := sysImpl.WriteData(uint32(h.mojoHandle), data, uint32(flags)) |
- h.core.mu.Unlock() |
- return MojoResult(r), int(bytesWritten) |
-} |
- |
-func (h *dataPipeProducer) BeginWriteData(flags MojoWriteDataFlags) (MojoResult, []byte) { |
- h.core.mu.Lock() |
- r, buf := sysImpl.BeginWriteData(uint32(h.mojoHandle), uint32(flags)) |
- h.core.mu.Unlock() |
- return MojoResult(r), buf |
-} |
- |
-func (h *dataPipeProducer) EndWriteData(numBytesWritten int) MojoResult { |
- h.core.mu.Lock() |
- r := sysImpl.EndWriteData(uint32(h.mojoHandle), uint32(numBytesWritten)) |
- h.core.mu.Unlock() |
- return MojoResult(r) |
-} |