| /development/tools/emulator/system/libqemu/ |
| test_util.h | 27 } Pipe;
29 int pipe_openSocket( Pipe* pipe, int port );
30 int pipe_openQemuPipe( Pipe* pipe, const char* pipename );
31 int pipe_send( Pipe* pipe, const void* buff, size_t bufflen );
32 int pipe_recv( Pipe* pipe, void* buff, size_t bufflen );
33 void pipe_close( Pipe* pipe )
[all...] |
| test_util.c | 45 pipe_openSocket( Pipe* pipe, int port )
50 pipe->socket = -1;
70 pipe->socket = fd;
75 pipe_openQemuPipe( Pipe* pipe, const char* pipename )
77 pipe->socket = qemu_pipe_open(pipename);
78 if (pipe->socket < 0) {
79 fprintf(stderr, "%s: Could not open '%s' pipe: %s\n", __FUNCTION__, pipename, strerror(errno));
86 pipe_send( Pipe* pipe, const void* buff, size_t bufflen
[all...] |
| test_guest_1.c | 17 /* This program uses a QEMUD pipe to exchange data with a test
42 Pipe pipe[1]; local
47 if (pipe_openSocket(pipe, port) < 0) {
53 if (pipe_openQemuPipe(pipe, PIPE_NAME) < 0) {
54 fprintf(stderr, "Could not open '%s' pipe: %s\n", PIPE_NAME, strerror(errno));
57 printf("Connected to '%s' pipe\n", PIPE_NAME);
70 int ret = pipe_send(pipe, buff, len);
79 ret = pipe_recv(pipe, buff2, len);
98 printf("Closing pipe\n")
[all...] |
| /external/apache-harmony/nio/src/test/java/common/org/apache/harmony/nio/tests/java/nio/channels/ |
| PipeTest.java | 21 import java.nio.channels.Pipe;
22 import java.nio.channels.Pipe.SinkChannel;
23 import java.nio.channels.Pipe.SourceChannel;
29 * Tests for Pipe and its default implementation
34 * @tests java.nio.channels.Pipe#open()
37 Pipe pipe = Pipe.open(); local
38 assertNotNull(pipe);
42 * @tests java.nio.channels.Pipe#sink(
45 Pipe pipe = Pipe.open(); local
54 Pipe pipe = Pipe.open(); local
[all...] |
| SourceChannelTest.java | 22 import java.nio.channels.Pipe;
28 * Tests for java.nio.channels.Pipe.SourceChannel
36 private Pipe pipe; field in class:SourceChannelTest
38 private Pipe.SinkChannel sink;
40 private Pipe.SourceChannel source;
48 pipe = Pipe.open();
49 sink = pipe.sink();
50 source = pipe.source()
301 Pipe pipe = Pipe.open(); local
[all...] |
| SinkChannelTest.java | 24 import java.nio.channels.Pipe;
32 * Tests for Pipe.SinkChannel class
40 private Pipe pipe; field in class:SinkChannelTest
42 private Pipe.SinkChannel sink;
44 private Pipe.SourceChannel source;
52 pipe = Pipe.open();
53 sink = pipe.sink();
54 source = pipe.source()
[all...] |
| /frameworks/av/services/audioflinger/ |
| Pipe.h | 24 // Pipe is multi-thread safe for readers (see PipeReader), but safe for only a single writer thread.
27 class Pipe : public NBAIO_Sink {
33 Pipe(size_t maxFrames, NBAIO_Format format);
34 virtual ~Pipe();
48 // The write side of a pipe permits overruns; flow control is the caller's responsibility.
59 volatile int32_t mReaders; // number of PipeReader clients currently attached to this Pipe
|
| PipeReader.h | 20 #include "Pipe.h"
29 // Construct a PipeReader and associate it with a Pipe
30 // FIXME make this constructor a factory method of Pipe.
31 PipeReader(Pipe& pipe);
53 Pipe& pipe() const { return mPipe; }
57 Pipe& mPipe;
|
| Pipe.cpp | 17 #define LOG_TAG "Pipe"
23 #include "Pipe.h"
28 Pipe::Pipe(size_t maxFrames, NBAIO_Format format) :
37 Pipe::~Pipe()
43 ssize_t Pipe::write(const void *buffer, size_t count)
|
| PipeReader.cpp | 26 PipeReader::PipeReader(Pipe& pipe) :
27 NBAIO_Source(pipe.mFormat),
28 mPipe(pipe),
29 // any data already in the pipe is not visible to this PipeReader
30 mFront(android_atomic_acquire_load(&pipe.mRear)),
34 android_atomic_inc(&pipe.mReaders);
52 // Discard 1/16 of the most recent data in pipe to avoid another overrun immediately
|
| Android.mk | 23 Pipe.cpp \
|
| /libcore/luni/src/test/java/libcore/java/nio/channels/ |
| PipeTest.java | 20 import java.nio.channels.Pipe;
24 Pipe p = Pipe.open();
|
| ChannelsTest.java | 23 import java.nio.channels.Pipe;
30 Pipe.SourceChannel sourceChannel = createNonBlockingChannel("abc".getBytes("UTF-8"));
43 Pipe.SourceChannel sourceChannel = createNonBlockingChannel("abc".getBytes("UTF-8"));
51 private Pipe.SourceChannel createNonBlockingChannel(byte[] content) throws IOException {
52 Pipe pipe = Pipe.open(); local
53 WritableByteChannel sinkChannel = pipe.sink();
55 Pipe.SourceChannel sourceChannel = pipe.source()
[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() {
99 * Returns the sink channel of the pipe.
101 * @return a writable sink channel of the pipe
[all...] |
| /frameworks/base/libs/androidfw/tests/ |
| TestHelpers.h | 24 class Pipe {
29 Pipe() {
31 ::pipe(fds);
37 ~Pipe() {
|
| /frameworks/native/libs/utils/tests/ |
| TestHelpers.h | 24 class Pipe {
29 Pipe() {
31 ::pipe(fds);
37 ~Pipe() {
|
| Looper_test.cpp | 41 Pipe* mPipe;
44 DelayedWriteSignal(int delayMillis, Pipe* pipe) :
45 DelayedTask(delayMillis), mPipe(pipe) {
165 Pipe pipe; local
168 handler.setCallback(mLooper, pipe.receiveFd, ALOOPER_EVENT_INPUT);
183 Pipe pipe; local
186 ASSERT_EQ(OK, pipe.writeSignal())
206 Pipe pipe; local
224 Pipe pipe; local
249 Pipe pipe; local
275 Pipe pipe; local
297 Pipe pipe; local
339 Pipe pipe; local
366 Pipe pipe; local
374 Pipe pipe; local
382 Pipe pipe; local
398 Pipe pipe; local
416 Pipe pipe; local
[all...] |
| /libcore/luni/src/main/java/java/nio/ |
| SelectorProviderImpl.java | 22 import java.nio.channels.Pipe;
36 public Pipe openPipe() throws IOException {
|
| PipeImpl.java | 23 import java.nio.channels.Pipe;
31 * Implements {@link java.nio.channels.Pipe}.
33 final class PipeImpl extends Pipe {
39 FileDescriptor[] fds = Libcore.os.pipe();
70 private class PipeSourceChannel extends Pipe.SourceChannel implements FileDescriptorChannel {
105 private class PipeSinkChannel extends Pipe.SinkChannel implements FileDescriptorChannel {
|
| /external/qemu/hw/ |
| goldfish_pipe.c | 46 /* Set to 1 to enable the 'zero' pipe type, useful for debugging */
49 /* Set to 1 to enable the 'pingpong' pipe type, useful for debugging */
52 /* Set to 1 to enable the 'throttle' pipe type, useful for debugging */
55 /* Maximum length of pipe service name, in characters (excluding final 0) */
90 APANIC("Too many goldfish pipe services (%d)", count);
94 APANIC("Pipe service name too long: '%s'", pipeName);
129 typedef struct Pipe {
130 struct Pipe* next;
131 struct Pipe* next_waked;
140 } Pipe;
148 Pipe* pipe; local
157 Pipe* pipe = pipe_new0(dev); local
254 Pipe* pipe; local
323 Pipe* pipe; member in struct:__anon11184
409 Pipe* pipe = pcon->pipe; local
632 PingPongPipe* pipe = opaque; local
696 PingPongPipe* pipe = opaque; local
740 PingPongPipe* pipe = opaque; local
755 PingPongPipe* pipe = opaque; local
798 ThrottlePipe* pipe; local
812 ThrottlePipe* pipe = opaque; local
845 ThrottlePipe* pipe = opaque; local
874 ThrottlePipe* pipe = opaque; local
893 ThrottlePipe* pipe = opaque; local
911 ThrottlePipe* pipe = opaque; local
926 ThrottlePipe* pipe = opaque; local
970 Pipe* pipe = *lookup; local
1119 Pipe* pipe = dev->signaled_pipes; local
1161 Pipe* pipe; local
1186 Pipe* pipe; local
1253 Pipe* pipe = hwpipe; local
1275 Pipe* pipe = hwpipe; local
[all...] |
| /libcore/luni/src/main/java/java/nio/channels/spi/ |
| SelectorProvider.java | 24 import java.nio.channels.Pipe;
31 * providing instances of {@link DatagramChannel}, {@link Pipe},
95 * Creates a new {@code Pipe}.
97 * @return the new pipe.
101 public abstract Pipe openPipe() throws IOException;
|
| /libcore/luni/src/test/java/libcore/java/io/ |
| InterruptedStreamTest.java | 31 import java.nio.channels.Pipe;
82 testInterruptReadableChannel(Pipe.open().source());
86 testInterruptWritableChannel(Pipe.open().sink());
|
| /external/clang/lib/Driver/ |
| InputInfo.h | 33 Pipe
|
| /external/llvm/include/llvm/MC/MCParser/ |
| MCAsmLexer.h | 48 Pipe, PipePipe, Caret,
|
| /system/extras/tests/sdcard/ |
| testcase.h | 45 enum Pipe {READ_FROM_CHILD = 0, WRITE_TO_PARENT, READ_FROM_PARENT, WRITE_TO_CHILD};
|
