| /external/chromium_org/mojo/public/java/system/src/org/chromium/mojo/system/ |
| InvalidHandle.java | 8 import org.chromium.mojo.system.DataPipe.ConsumerHandle;
9 import org.chromium.mojo.system.DataPipe.ProducerHandle;
144 * @see DataPipe.ProducerHandle#writeData(java.nio.ByteBuffer, DataPipe.WriteFlags)
147 public int writeData(ByteBuffer elements, DataPipe.WriteFlags flags) {
152 * @see DataPipe.ProducerHandle#beginWriteData(int, DataPipe.WriteFlags)
156 DataPipe.WriteFlags flags) {
161 * @see DataPipe.ProducerHandle#endWriteData(int)
169 * @see DataPipe.ConsumerHandle#discardData(int, DataPipe.ReadFlags
[all...] |
| UntypedHandle.java | 7 import org.chromium.mojo.system.DataPipe.ConsumerHandle;
8 import org.chromium.mojo.system.DataPipe.ProducerHandle;
|
| Core.java | 162 * the size given in |options|. See |DataPipe.CreateOptions| for a description of the different
169 public Pair<DataPipe.ProducerHandle, DataPipe.ConsumerHandle> createDataPipe(
170 DataPipe.CreateOptions options);
|
| /external/chromium_org/mojo/public/cpp/system/ |
| data_pipe.h | 111 class DataPipe {
113 DataPipe();
114 explicit DataPipe(const MojoCreateDataPipeOptions& options);
115 ~DataPipe();
121 inline DataPipe::DataPipe() {
127 inline DataPipe::DataPipe(const MojoCreateDataPipeOptions& options) {
133 inline DataPipe::~DataPipe() {
[all...] |
| /external/chromium_org/mojo/android/javatests/src/org/chromium/mojo/ |
| HandleMock.java | 8 import org.chromium.mojo.system.DataPipe;
9 import org.chromium.mojo.system.DataPipe.ConsumerHandle;
10 import org.chromium.mojo.system.DataPipe.ProducerHandle;
85 * @see ConsumerHandle#discardData(int, DataPipe.ReadFlags)
88 public int discardData(int numBytes, DataPipe.ReadFlags flags) {
94 * @see ConsumerHandle#readData(java.nio.ByteBuffer, DataPipe.ReadFlags)
98 DataPipe.ReadFlags flags) {
104 * @see ConsumerHandle#beginReadData(int, DataPipe.ReadFlags)
108 DataPipe.ReadFlags flags) {
122 * @see ProducerHandle#writeData(java.nio.ByteBuffer, DataPipe.WriteFlags
[all...] |
| /external/chromium_org/mojo/system/ |
| data_pipe.cc | 23 const MojoCreateDataPipeOptions DataPipe::kDefaultCreateOptions = {
29 MojoResult DataPipe::ValidateCreateOptions(
79 void DataPipe::ProducerCancelAllWaiters() {
85 void DataPipe::ProducerClose() {
100 MojoResult DataPipe::ProducerWriteData(UserPointer<const void> elements,
132 MojoResult DataPipe::ProducerBeginWriteData(
163 MojoResult DataPipe::ProducerEndWriteData(uint32_t num_bytes_written) {
197 HandleSignalsState DataPipe::ProducerGetHandleSignalsState() {
203 MojoResult DataPipe::ProducerAddWaiter(Waiter* waiter,
226 void DataPipe::ProducerRemoveWaiter(Waiter* waiter
[all...] |
| data_pipe_unittest.cc | 37 DataPipe::ValidateCreateOptions(MakeUserPointer(&validated_options),
64 DataPipe::ValidateCreateOptions(NullUserPointer(), &validated_options));
76 DataPipe::ValidateCreateOptions(MakeUserPointer(&options),
98 DataPipe::ValidateCreateOptions(MakeUserPointer(&options),
115 DataPipe::ValidateCreateOptions(MakeUserPointer(&options),
137 DataPipe::ValidateCreateOptions(MakeUserPointer(&options),
158 DataPipe::ValidateCreateOptions(MakeUserPointer(&options),
178 DataPipe::ValidateCreateOptions(MakeUserPointer(&options),
201 DataPipe::ValidateCreateOptions(MakeUserPointer(&options),
222 DataPipe::ValidateCreateOptions(MakeUserPointer(&options)
[all...] |
| local_data_pipe.h | 18 // |LocalDataPipe| is a subclass that "implements" |DataPipe| for data pipes
20 // protection provided by |DataPipe|'s |lock_|.
21 class MOJO_SYSTEM_IMPL_EXPORT LocalDataPipe : public DataPipe {
23 // |validated_options| should be the output of |DataPipe::ValidateOptions()|.
32 // |DataPipe| implementation:
80 // The members below are protected by |DataPipe|'s |lock_|:
|
| data_pipe_consumer_dispatcher.h | 16 class DataPipe;
26 void Init(scoped_refptr<DataPipe> data_pipe);
59 scoped_refptr<DataPipe> data_pipe_; // This will be null if closed.
|
| data_pipe_producer_dispatcher.h | 16 class DataPipe;
26 void Init(scoped_refptr<DataPipe> data_pipe);
60 scoped_refptr<DataPipe> data_pipe_; // This will be null if closed.
|
| data_pipe.h | 26 // |DataPipe| is a base class for secondary objects implementing data pipes,
32 class MOJO_SYSTEM_IMPL_EXPORT DataPipe
33 : public base::RefCountedThreadSafe<DataPipe> {
93 DataPipe(bool has_local_producer,
97 friend class base::RefCountedThreadSafe<DataPipe>;
98 virtual ~DataPipe();
210 DISALLOW_COPY_AND_ASSIGN(DataPipe);
|
| /external/chromium_org/mojo/android/system/src/org/chromium/mojo/system/impl/ |
| DataPipeProducerHandleImpl.java | 7 import org.chromium.mojo.system.DataPipe.ProducerHandle;
8 import org.chromium.mojo.system.DataPipe.WriteFlags;
32 * @see org.chromium.mojo.system.DataPipe.ProducerHandle#pass()
|
| DataPipeConsumerHandleImpl.java | 7 import org.chromium.mojo.system.DataPipe.ConsumerHandle;
8 import org.chromium.mojo.system.DataPipe.ReadFlags;
|
| UntypedHandleImpl.java | 7 import org.chromium.mojo.system.DataPipe.ConsumerHandle;
8 import org.chromium.mojo.system.DataPipe.ProducerHandle;
|
| CoreImpl.java | 11 import org.chromium.mojo.system.DataPipe;
12 import org.chromium.mojo.system.DataPipe.ConsumerHandle;
13 import org.chromium.mojo.system.DataPipe.ProducerHandle;
132 * @see Core#createDataPipe(DataPipe.CreateOptions)
135 public Pair<ProducerHandle, ConsumerHandle> createDataPipe(DataPipe.CreateOptions options) {
274 * @see ConsumerHandle#discardData(int, DataPipe.ReadFlags)
277 DataPipe.ReadFlags flags) {
287 * @see ConsumerHandle#readData(ByteBuffer, DataPipe.ReadFlags)
290 DataPipe.ReadFlags flags) {
304 * @see ConsumerHandle#beginReadData(int, DataPipe.ReadFlags
[all...] |
| /external/chromium_org/mojo/apps/js/test/ |
| js_to_cpp_unittest.js | 89 var dataPipe;
110 dataPipe = core.createDataPipe(DATA_PIPE_PARAMS);
112 writeDataPipe(dataPipe, sampleData);
114 arg.data_handle = dataPipe.consumerHandle;
119 core.close(dataPipe.producerHandle);
131 var dataPipe;
150 dataPipe = core.createDataPipe(DATA_PIPE_PARAMS);
152 writeDataPipe(dataPipe, sampleData);
154 arg.data_handle = dataPipe.consumerHandle;
159 core.close(dataPipe.producerHandle)
[all...] |
| /external/chromium_org/mojo/android/javatests/src/org/chromium/mojo/bindings/ |
| ReadAndDispatchMessageTest.java | 12 import org.chromium.mojo.system.DataPipe;
48 Pair<DataPipe.ProducerHandle, DataPipe.ConsumerHandle> datapipe = core.createDataPipe(null); local
49 mHandlesToSend.addAll(Arrays.asList(datapipe.first, datapipe.second));
|
| /external/chromium_org/media/mojo/interfaces/ |
| demuxer_stream.mojom | 34 // DataPipe that we can serialize [|status| | response|]* over directly.
44 // payloads from the DataPipe directly. If |pipe| is NULL, it means the
50 // in a Read() callback or over the DataPipe).
|
| /external/chromium_org/mojo/android/javatests/src/org/chromium/mojo/system/impl/ |
| CoreImplTest.java | 15 import org.chromium.mojo.system.DataPipe;
124 private static void checkSendingData(DataPipe.ProducerHandle in, DataPipe.ConsumerHandle out) {
132 int result = in.writeData(buffer, DataPipe.WriteFlags.NONE);
136 result = out.readData(null, DataPipe.ReadFlags.none().query(true));
141 result = out.readData(receiveBuffer, DataPipe.ReadFlags.NONE);
348 private static void createAndCloseDataPipe(DataPipe.CreateOptions options) {
350 Pair<DataPipe.ProducerHandle, DataPipe.ConsumerHandle> handles = core.createDataPipe(
357 * Testing {@link DataPipe}
[all...] |
| /external/chromium_org/components/devtools_bridge/test/android/javatests/src/org/chromium/components/devtools_bridge/ |
| DataPipe.java | 13 public class DataPipe {
76 // Ignore. Will dispose in DataPipe.dispose.
|
| /external/chromium_org/mojo/python/tests/ |
| system_unittest.py | 194 self._TestDataHandleCreation(system.DataPipe())
197 self._TestDataHandleCreation(system.DataPipe(None))
201 system.DataPipe(system.CreateDataPipeOptions()))
206 self._TestDataHandleCreation(system.DataPipe(options))
211 self._TestDataHandleCreation(system.DataPipe(options))
216 self._TestDataHandleCreation(system.DataPipe(options))
223 self._TestDataHandleCreation(system.DataPipe(options))
227 pipes = system.DataPipe()
233 pipes = system.DataPipe()
241 pipes = system.DataPipe()
[all...] |
| /external/chromium_org/media/mojo/services/ |
| mojo_demuxer_stream_impl.cc | 42 // TODO(tim): Once using DataPipe, fill via the producer handle and then
55 // TODO(tim): Create a DataPipe, hold the producer handle, and pass the
|
| /hardware/ti/omap3/omx/audio/src/openmax_il/g711_dec/src/ |
| OMX_G711Dec_ComponentThread.c | 80 if (pComponentPrivate->dataPipe[0] > fdmax) {
81 fdmax = pComponentPrivate->dataPipe[0];
87 FD_SET (pComponentPrivate->dataPipe[0], &rfds);
125 } else if (FD_ISSET(pComponentPrivate->dataPipe[0], &rfds)){
127 ret = read(pComponentPrivate->dataPipe[0], &pBufHeader, sizeof(pBufHeader));
|
| /external/chromium_org/mojo/services/public/cpp/network/ |
| web_socket_read_queue.h | 15 // This class simplifies the handling of multiple Reads on a DataPipe. It reads
|
| web_socket_write_queue.h | 15 // This class simplifies the handling of multiple Writes on a DataPipe. It
|
