| /device/generic/goldfish/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...] |
| /libcore/harmony-tests/src/test/java/org/apache/harmony/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...] |
| /external/drrickorang/LoopbackApp/app/src/main/java/org/drrickorang/loopback/ |
| Pipe.java | 21 * This class is a pipe that allows one writer and one reader.
24 public abstract class Pipe {
33 public Pipe(int maxSamples) {
50 /** Clear the pipe. */
|
| /libcore/luni/src/test/java/libcore/java/nio/channels/ |
| PipeTest.java | 20 import java.nio.channels.Pipe;
24 Pipe p = Pipe.open();
|
| ChannelsTest.java | 26 import java.nio.channels.Pipe;
43 Pipe.SourceChannel sourceChannel = createNonBlockingChannel("abc".getBytes("UTF-8"));
56 Pipe.SourceChannel sourceChannel = createNonBlockingChannel("abc".getBytes("UTF-8"));
64 private Pipe.SourceChannel createNonBlockingChannel(byte[] content) throws IOException {
65 Pipe pipe = Pipe.open(); local
66 WritableByteChannel sinkChannel = pipe.sink();
68 Pipe.SourceChannel sourceChannel = pipe.source()
[all...] |
| /frameworks/av/media/libnbaio/ |
| Pipe.cpp | 17 #define LOG_TAG "Pipe"
23 #include <media/nbaio/Pipe.h>
28 Pipe::Pipe(size_t maxFrames, const NBAIO_Format& format, void *buffer) :
40 Pipe::~Pipe()
48 ssize_t Pipe::write(const void *buffer, size_t count)
|
| /frameworks/av/media/libnbaio/include/media/nbaio/ |
| Pipe.h | 25 // Pipe is multi-thread safe for readers (see PipeReader), but safe for only a single writer thread.
28 class Pipe : public NBAIO_Sink {
34 // buffer is an optional parameter specifying the virtual address of the pipe buffer,
36 Pipe(size_t maxFrames, const NBAIO_Format& format, void *buffer = NULL);
39 virtual ~Pipe();
53 // The write side of a pipe permits overruns; flow control is the caller's responsibility.
65 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);
55 Pipe& pipe() const { return mPipe; }
59 Pipe& mPipe;
|
| /system/libhwbinder/vts/performance/ |
| PerfTest.h | 29 // Pipe is a object used for IPC between parent process and child process.
31 // The common usage is the main process to create the Pipe and forks.
34 class Pipe {
36 static tuple<Pipe, Pipe> createPipePair();
37 Pipe(Pipe&& rval);
38 ~Pipe();
62 Pipe(int read_fd, int write_fd) : fd_read_{read_fd}, fd_write_{write_fd} {}
63 Pipe(const Pipe&) = delete
[all...] |
| Benchmark_throughput.cpp | 47 class Pipe {
50 Pipe(int readFd, int writeFd)
53 Pipe(const Pipe &) = delete;
54 Pipe& operator=(const Pipe &) = delete;
55 Pipe& operator=(const Pipe &&) = delete;
57 Pipe(Pipe&& rval) noexcept
[all...] |
| PerfTest.cpp | 54 tuple<Pipe, Pipe> Pipe::createPipePair() {
58 int error1 = pipe(a);
59 int error2 = pipe(b);
63 return make_tuple(Pipe(a[0], b[1]), Pipe(b[0], a[1]));
66 Pipe::Pipe(Pipe&& rval) noexcept
[all...] |
| /libcore/ojluni/src/main/java/java/nio/channels/ |
| Pipe.java | 33 * A pair of channels that implements a unidirectional pipe.
35 * <p> A pipe consists of a pair of channels: A writable {@link
36 * Pipe.SinkChannel sink} channel and a readable {@link Pipe.SourceChannel source}
40 * <p> Whether or not a thread writing bytes to a pipe will block until another
41 * thread reads those bytes, or some previously-written bytes, from the pipe is
42 * system-dependent and therefore unspecified. Many pipe implementations will
52 public abstract class Pipe {
55 * A channel representing the readable end of a {@link Pipe}.
77 * <p> Pipe-source channels only support reading, so this metho
[all...] |
| /system/extras/alloc-stress/ |
| alloc-stress.cpp | 27 class Pipe {
30 Pipe(const Pipe &) = delete;
31 Pipe& operator=(const Pipe &) = delete;
32 Pipe& operator=(const Pipe &&) = delete;
34 Pipe(int readFd, int writeFd) : m_readFd{readFd}, m_writeFd{writeFd} {
38 Pipe(Pipe&& rval) noexcept
[all...] |
| /frameworks/native/libs/input/tests/ |
| TestHelpers.h | 26 class Pipe {
31 Pipe() {
33 ::pipe(fds);
39 ~Pipe() {
|
| /system/core/libutils/tests/ |
| TestHelpers.h | 24 class Pipe {
29 Pipe() {
31 ::pipe(fds);
37 ~Pipe() {
|
| /external/python/cpython2/Lib/test/ |
| mp_fork_bomb.py | 10 r, w = multiprocessing.Pipe(False)
|
| /prebuilts/gdb/darwin-x86/lib/python2.7/test/ |
| mp_fork_bomb.py | 10 r, w = multiprocessing.Pipe(False)
|
| /prebuilts/gdb/linux-x86/lib/python2.7/test/ |
| mp_fork_bomb.py | 10 r, w = multiprocessing.Pipe(False)
|
| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/test/ |
| mp_fork_bomb.py | 10 r, w = multiprocessing.Pipe(False)
|
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/test/ |
| mp_fork_bomb.py | 10 r, w = multiprocessing.Pipe(False)
|
| /prebuilts/go/darwin-x86/src/os/ |
| pipe_bsd.go | 11 // Pipe returns a connected pair of Files; reads from r return bytes written to w.
13 func Pipe() (r *File, w *File, err error) {
18 e := syscall.Pipe(p[0:])
21 return nil, nil, NewSyscallError("pipe", e)
|
| /prebuilts/go/linux-x86/src/os/ |
| pipe_bsd.go | 11 // Pipe returns a connected pair of Files; reads from r return bytes written to w.
13 func Pipe() (r *File, w *File, err error) {
18 e := syscall.Pipe(p[0:])
21 return nil, nil, NewSyscallError("pipe", e)
|
| /frameworks/native/libs/binder/tests/ |
| binderThroughputTest.cpp | 52 class Pipe {
55 Pipe(int readFd, int writeFd) : m_readFd{readFd}, m_writeFd{writeFd} {}
56 Pipe(const Pipe &) = delete;
57 Pipe& operator=(const Pipe &) = delete;
58 Pipe& operator=(const Pipe &&) = delete;
60 Pipe(Pipe&& rval) noexcept
[all...] |
| schd-dbg.cpp | 151 class Pipe {
154 Pipe(int readFd, int writeFd) : m_readFd{readFd}, m_writeFd{writeFd} {
156 Pipe(const Pipe&) = delete;
157 Pipe& operator=(const Pipe&) = delete;
158 Pipe& operator=(const Pipe&&) = delete;
161 Pipe(Pipe&& rval) noexcept
[all...] |
