| /external/valgrind/main/memcheck/tests/ |
| pipe.vgtest | 1 prog: pipe
|
| pipe.c | 2 // behaved as if pipe() took an array of 64-bit ints, when it really takes
13 pipe(filedes);
|
| /external/dbus/dbus/ |
| dbus-pipe.c | 2 /* dbus-pipe.c pipe implementation (internal to D-Bus implementation)
26 #include "dbus-pipe.h"
29 * init a pipe instance.
31 * @param pipe the pipe
35 _dbus_pipe_init (DBusPipe *pipe,
38 pipe->fd_or_handle = fd;
42 * init a pipe with stdout
44 * @param pipe the pip
[all...] |
| dbus-pipe-win.c | 2 /* dbus-pipe-win.c windows related pipe implementation
29 #include "dbus-pipe.h"
34 * write data to a pipe.
36 * @param pipe the pipe instance
44 _dbus_pipe_write (DBusPipe *pipe,
55 res = WriteFile ((HANDLE) pipe->fd_or_handle, buffer_c + start, len, &written, NULL);
59 "Writing to pipe: %s\n",
66 * close a pipe
[all...] |
| dbus-pipe-unix.c | 2 /* dbus-pipe-unix.c unix related pipe implementation
29 #include "dbus-pipe.h"
35 * write data to a pipe.
37 * @param pipe the pipe instance
45 _dbus_pipe_write (DBusPipe *pipe,
53 written = _dbus_write (pipe->fd_or_handle, buffer, start, len);
57 "Writing to pipe: %s\n",
64 * close a pipe
[all...] |
| dbus-pipe.h | 45 void _dbus_pipe_init (DBusPipe *pipe,
47 void _dbus_pipe_init_stdout (DBusPipe *pipe);
48 int _dbus_pipe_write (DBusPipe *pipe,
53 int _dbus_pipe_close (DBusPipe *pipe,
55 dbus_bool_t _dbus_pipe_is_valid (DBusPipe *pipe);
56 void _dbus_pipe_invalidate (DBusPipe *pipe);
57 dbus_bool_t _dbus_pipe_is_stdout_or_stderr (DBusPipe *pipe);
|
| /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...] |
| /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...] |
| goldfish_pipe.h | 20 * A goldfish pipe is a very fast communication channel between the guest
23 * To open a new pipe to the emulator, a guest client will do the following:
37 * This header provides the interface used by pipe services in the emulator
41 * 1/ Call goldfish_pipe_add_type() to register a new pipe service by name.
43 * during normal pipe operations.
49 * 3/ Call goldfish_pipe_close() to force the closure of a given pipe.
51 * 4/ Call goldfish_pipe_signal() to signal a change of state to the pipe.
61 /* Pipe handler funcs */
66 * to goldfish_pipe_add_type() when registering a given pipe service.
70 /* Called when the guest kernel has finally closed a pipe connection
[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...] |
| /external/clang/test/CodeGen/ |
| 2008-07-31-asm-labels.c | 2 // RUN: grep "@pipe()" %t | count 0
7 // RUN: grep "@pipe()" %t | count 0
11 void pipe() asm("_thisIsNotAPipe");
14 pipe();
17 void pipe(int);
20 pipe(1);
24 void pipe(int arg) { function
|
| /external/qemu/android/ |
| hw-pipe-net.c | 17 /* This file implements the 'tcp:' goldfish pipe type which allows
30 /* Implement the OpenGL fast-pipe */
75 netPipe_free( NetPipe* pipe )
80 fd = pipe->io->fd;
81 loopIo_done(pipe->io);
84 /* Release the pipe object */
85 AFREE(pipe);
90 netPipe_resetState( NetPipe* pipe )
92 if ((pipe->wakeWanted & PIPE_WAKE_WRITE) != 0) {
93 loopIo_wantWrite(pipe->io)
112 NetPipe* pipe = opaque; local
140 NetPipe* pipe = opaque; local
189 NetPipe* pipe; local
233 NetPipe* pipe = opaque; local
241 NetPipe* pipe = opaque; local
295 NetPipe* pipe = opaque; local
348 NetPipe* pipe = opaque; local
363 NetPipe* pipe = opaque; local
472 NetPipe *pipe; local
[all...] |
| /bionic/libc/arch-x86/syscalls/ |
| pipe.S | 5 .type pipe, @function
6 .globl pipe
9 pipe: label
|
| /external/valgrind/main/none/tests/ |
| fdleak_pipe.c | 10 DO( pipe(fds) );
|
| /bionic/libc/arch-arm/syscalls/ |
| pipe.S | 5 ENTRY(pipe) function
14 END(pipe)
|
| /frameworks/av/services/audioflinger/ |
| 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)
|
| /libcore/luni/src/test/java/libcore/java/nio/channels/ |
| 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...] |
| /external/openssh/regress/ |
| broken-pipe.sh | 1 # $OpenBSD: broken-pipe.sh,v 1.4 2002/03/15 13:08:56 markus Exp $
4 tid="broken pipe test"
12 fail "broken pipe returns $r for protocol $p"
|
| /external/valgrind/main/coregrind/m_scheduler/ |
| sema.c | 41 pipe-based token passing scheme.
44 /* Cycle the char passed through the pipe through 'A' .. 'Z' to make
55 r = VG_(pipe)(sema->pipe);
58 vg_assert(sema->pipe[0] != sema->pipe[1]);
60 sema->pipe[0] = VG_(safe_fd)(sema->pipe[0]);
61 sema->pipe[1] = VG_(safe_fd)(sema->pipe[1])
[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...] |
| /sdk/emulator/opengl/shared/OpenglCodecCommon/ |
| Win32PipeStream.cpp | 30 * pipe cannot be more than 256 characters long.
40 Win32PipeStream::Win32PipeStream(HANDLE pipe, size_t bufSize) :
42 m_pipe(pipe)
54 /* Initialize the pipe name corresponding to a given port
59 snprintf(path, pathlen, "\\\\.\\pipe\\qemu-gles-%d", port_number);
64 * One does not create/bind a pipe, and collect a new handle each
67 * Instead, the server creates a new pipe instance each time it wants
71 * So listen() is a no-op, and accept() really creates the pipe handle.
73 * Also, connect() must create a pipe handle with CreateFile() and
87 HANDLE pipe; local
126 HANDLE pipe; local
[all...] |
| /external/oprofile/daemon/ |
| opd_pipe.h | 18 * Creates the Oprofile daemon fifo pipe to enable communication between
19 * the daemon and the 'opcontrol --dump' command. Failure to create the pipe
32 * Closes the Oprofile daemon fifo pipe.
39 * Checks the Oprofile daemon fifo pipe for do_jitconv request.
|
| /frameworks/compile/libbcc/tests/ |
| bccarm | 11 proc = subprocess.Popen(["bcc"] + args, stderr=subprocess.PIPE, stdout=subprocess.PIPE)
16 proc = subprocess.Popen(args, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
58 proc = subprocess.Popen(remoteCmdLine, stdout=subprocess.PIPE)
|
