| /development/simulator/app/ |
| LocalBiChannel.h | 13 #include "Pipe.h"
23 * The name for the pipe should be a short filename made up of alphanumeric
39 bool listen(Pipe** ppReadPipe, Pipe** ppWritePipe);
44 bool attach(const char* name, Pipe** ppReadPipe, Pipe** ppWritePipe);
|
| Pipe.h | 30 * Simple anonymous unidirectional pipe.
38 class Pipe {
40 Pipe(void);
41 virtual ~Pipe(void);
43 /* Create the pipe */
46 /* Create a read-only pipe, using the supplied handle as read handle */
48 /* Create a write-only pipe, using the supplied handle as write handle */
55 * Read "count" bytes from the pipe. Returns the amount of data read,
62 * Write "count" bytes into the pipe. Returns number of bytes written,
|
| UserEventMessage.h | 58 void CreateExternalRuntime(android::Pipe* reader, android::Pipe* writer) {
70 android::Pipe* GetReader(void) const { return mReader; }
71 android::Pipe* GetWriter(void) const { return mWriter; }
80 android::Pipe* mReader; // for kExternalRuntime
81 android::Pipe* mWriter; // for kExternalRuntime
|
| MessageStream.h | 20 #include "Pipe.h"
99 * Read or write this message on the specified pipe.
104 bool read(Pipe* pPipe, bool wait);
105 bool write(Pipe* pPipe) const;
133 * the read pipe from multiple threads will have unpredictable behavior.
149 bool init(Pipe* readPipe, Pipe* writePipe, bool initiateHello);
171 * Get our incoming traffic pipe. This is useful on Linux systems
175 Pipe* getReadPipe(void) { return mReadPipe; }
184 Pipe* mReadPipe
[all...] |
| Pipe.cpp | 18 // Unidirectional pipe.
21 #include "Pipe.h"
45 Pipe::Pipe(void)
54 Pipe::~Pipe(void)
59 LOG(LOG_WARN, "pipe", "failed closing read handle (%ld)\n",
65 LOG(LOG_WARN, "pipe", "failed closing write handle (%ld)\n",
71 LOG(LOG_WARN, "pipe", "failed closing read fd (%d)\n",
76 LOG(LOG_WARN, "pipe", "failed closing write fd (%d)\n"
[all...] |
| SimRuntime.h | 74 bool create(Pipe* reader, Pipe* writer);
97 * Return a copy of our input pipe so the event system can monitor
100 Pipe* getReadPipe(void) { return mStream.getReadPipe(); }
|
| LocalBiChannel.cpp | 50 * the file handles into a Pipe, which uses HANDLE under Win32.
72 static const char* kBasePath = "\\\\.\\pipe\\android-";
85 * Create a named pipe, so the client has something to connect to.
96 mFileName, // unique pipe name
99 0, // pipe mode (byte, blocking)
119 * Attach to an existing named pipe.
121 bool LocalBiChannel::attach(const char* name, Pipe** ppReadPipe,
122 Pipe** ppWritePipe)
139 "CreateFile on pipe '%s' failed (err=%ld)\n", name, GetLastError());
149 *ppReadPipe = new Pipe();
[all...] |
| DeviceManager.h | 95 bool StartRuntime(android::Pipe* reader, android::Pipe* writer);
132 android::Pipe* reader, android::Pipe* writer)
175 android::Pipe* mReader;
176 android::Pipe* mWriter;
|
| ExternalRuntime.cpp | 64 Pipe* reader;
65 Pipe* writer;
70 fprintf(stderr, "Sim: failed creating named pipe '%s'\n",
|
| MainFrame.h | 80 void HandleExternalRuntime(android::Pipe* reader, android::Pipe* writer);
|
| MessageStream.cpp | 212 * Read the next event from the pipe.
216 bool Message::read(Pipe* pPipe, bool wait)
259 * Write this event to a pipe.
270 bool Message::write(Pipe* pPipe) const
331 bool MessageStream::init(Pipe* readPipe, Pipe* writePipe, bool initiateHello)
|
| Android.mk | 27 Pipe.cpp \
|
| /libcore/luni/src/test/java/libcore/java/nio/channels/ |
| PipeTest.java | 20 import java.nio.channels.Pipe;
24 Pipe p = Pipe.open();
|
| /libcore/luni/src/test/java/org/apache/harmony/nio/tests/java/nio/channels/ |
| PipeTest.java | 24 import java.nio.channels.Pipe;
25 import java.nio.channels.Pipe.SinkChannel;
26 import java.nio.channels.Pipe.SourceChannel;
30 value = Pipe.class,
34 method = "Pipe",
40 * Tests for Pipe and its default implementation
45 * @tests java.nio.channels.Pipe#open()
54 Pipe pipe = Pipe.open() local
68 Pipe pipe = Pipe.open(); local
83 Pipe pipe = Pipe.open(); local
[all...] |
| SourceChannelTest.java | 29 import java.nio.channels.Pipe;
31 import java.nio.channels.Pipe.SourceChannel;
36 value = java.nio.channels.Pipe.SourceChannel.class,
47 * Tests for java.nio.channels.Pipe.SourceChannel
55 private Pipe pipe; field in class:SourceChannelTest
57 private Pipe.SinkChannel sink;
59 private Pipe.SourceChannel source;
67 pipe = Pipe.open()
382 Pipe pipe = Pipe.open(); local
[all...] |
| SinkChannelTest.java | 32 import java.nio.channels.Pipe;
36 import java.nio.channels.Pipe.SinkChannel;
42 * Tests for Pipe.SinkChannel class
45 value = java.nio.channels.Pipe.SinkChannel.class,
67 private Pipe pipe; field in class:SinkChannelTest
69 private Pipe.SinkChannel sink;
71 private Pipe.SourceChannel source;
79 pipe = Pipe.open()
[all...] |
| /libcore/luni/src/main/java/java/nio/channels/ |
| Pipe.java | 24 * A pipe contains two channels, forming a unidirectional pipe. One is the writable sink channel,
29 public abstract class Pipe {
31 * Writable sink channel used to write to a pipe.
57 * Readable source channel used to read from a pipe.
83 * Returns a new pipe from the default {@see java.nio.channels.spi.SelectorProvider}.
88 public static Pipe open() throws IOException {
95 protected Pipe() {
100 * Returns the sink channel of the pipe.
102 * @return a writable sink channel of the pipe
[all...] |
| /frameworks/base/libs/utils/tests/ |
| TestHelpers.h | 24 class Pipe {
29 Pipe() {
31 ::pipe(fds);
37 ~Pipe() {
|
| Looper_test.cpp | 34 Pipe* mPipe;
37 DelayedWriteSignal(int delayMillis, Pipe* pipe) :
38 DelayedTask(delayMillis), mPipe(pipe) {
149 Pipe pipe; local
152 handler.setCallback(mLooper, pipe.receiveFd, ALOOPER_EVENT_INPUT);
167 Pipe pipe; local
170 ASSERT_EQ(OK, pipe.writeSignal())
190 Pipe pipe; local
208 Pipe pipe; local
233 Pipe pipe; local
259 Pipe pipe; local
281 Pipe pipe; local
323 Pipe pipe; local
350 Pipe pipe; local
358 Pipe pipe; local
366 Pipe pipe; local
382 Pipe pipe; local
400 Pipe pipe; local
[all...] |
| /libcore/luni/src/main/java/org/apache/harmony/nio/internal/ |
| SelectorProviderImpl.java | 22 import java.nio.channels.Pipe;
50 public Pipe openPipe() throws IOException {
|
| PipeImpl.java | 23 import java.nio.channels.Pipe;
29 * Implements {@link java.nio.channels.Pipe}.
31 final class PipeImpl extends Pipe {
37 IoUtils.pipe(fds);
39 // unidirectional, and indeed are only unidirectional on Linux. See IoUtils.pipe.
65 private class PipeSourceChannel extends Pipe.SourceChannel implements FileDescriptorHandler {
100 private class PipeSinkChannel extends Pipe.SinkChannel implements FileDescriptorHandler {
|
| /libcore/luni/src/main/java/java/nio/channels/spi/ |
| SelectorProvider.java | 23 import java.nio.channels.Pipe;
33 * providing instances of {@link DatagramChannel}, {@link Pipe},
109 * Creates a new {@code Pipe}.
111 * @return the new pipe.
115 public abstract Pipe openPipe() throws IOException;
|
| /system/extras/tests/sdcard/ |
| testcase.h | 45 enum Pipe {READ_FROM_CHILD = 0, WRITE_TO_PARENT, READ_FROM_PARENT, WRITE_TO_CHILD};
|
| /libcore/luni/src/test/java/org/apache/harmony/nio/tests/java/nio/channels/spi/ |
| AbstractSelectorTest.java | 26 import java.nio.channels.Pipe;
258 public Pipe openPipe() {
|
| /frameworks/base/libs/ui/tests/ |
| InputChannel_test.cpp | 28 // of a pipe and to check for EPIPE on the other end after the channel is destroyed.
29 Pipe fakeAshmem, sendPipe, receivePipe;
39 << "channel should have provided receive pipe fd";
41 << "channel should have provided send pipe fd";
48 << "channel should have closed receive pipe fd when destroyed";
50 << "channel should have closed send pipe fd when destroyed";
52 // clean up fds of Pipe endpoints that were closed so we don't try to close them again
|
