/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...] |
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...] |
/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...] |
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...] |
/frameworks/av/include/media/nbaio/ |
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 // buffer is an optional parameter specifying the virtual address of the pipe buffer, 35 Pipe(size_t maxFrames, const NBAIO_Format& format, void *buffer = NULL); 38 virtual ~Pipe(); 52 // The write side of a pipe permits overruns; flow control is the caller's responsibility. 63 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;
|
/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/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) : 38 Pipe::~Pipe() 46 ssize_t Pipe::write(const void *buffer, size_t count)
|
Android.mk | 12 Pipe.cpp \
|
/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() {
|
/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 { 60 private class PipeSourceChannel extends Pipe.SourceChannel implements FileDescriptorChannel { 95 private class PipeSinkChannel extends Pipe.SinkChannel implements FileDescriptorChannel {
|
/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)
|
/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 | 32 import java.nio.channels.Pipe; 90 testInterruptReadableChannel(Pipe.open().source()); 94 testInterruptWritableChannel(Pipe.open().sink());
|
/prebuilts/python/darwin-x86/2.7.5/lib/python2.7/multiprocessing/ |
__init__.py | 48 'Manager', 'Pipe', 'cpu_count', 'log_to_stderr', 'get_logger', 102 def Pipe(duplex=True): 104 Returns two connection object connected by a pipe 106 from multiprocessing.connection import Pipe 107 return Pipe(duplex)
|
/prebuilts/python/linux-x86/2.7.5/lib/python2.7/multiprocessing/ |
__init__.py | 48 'Manager', 'Pipe', 'cpu_count', 'log_to_stderr', 'get_logger', 102 def Pipe(duplex=True): 104 Returns two connection object connected by a pipe 106 from multiprocessing.connection import Pipe 107 return Pipe(duplex)
|
/external/clang/lib/Driver/ |
InputInfo.h | 33 Pipe
|
/external/skia/tests/ |
PipeTest.cpp | 16 // Ensures that the pipe gracefully handles drawing an invalid bitmap. 23 // Ensure that pipe gracefully handles attempting to draw after endRecording is called on the 44 DEF_TEST(Pipe, reporter) {
|
/prebuilts/python/darwin-x86/2.7.5/lib/python2.7/multiprocessing/dummy/ |
connection.py | 35 __all__ = [ 'Client', 'Listener', 'Pipe' ] 63 def Pipe(duplex=True):
|