| /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)
|
| queues.py | 47 from multiprocessing import Pipe
53 # Queue type using a pipe, buffer and thread
62 self._reader, self._writer = Pipe(duplex=False)
180 # Start thread which transfers data from buffer to pipe
194 # On process exit we will wait for data to be flushed to pipe.
231 debug('starting thread to feed data to pipe')
345 # Simplified Queue type -- really just a locked pipe
351 self._reader, self._writer = Pipe(duplex=False)
382 # writes to a message oriented win32 pipe are atomic
|
| /libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/nio/channels/ |
| 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...] |
| /device/generic/goldfish/libqemu/ |
| 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...] |
| test_guest_2.c | 17 /* This program benchmarks a QEMUD pipe to exchange data with a test
40 " -pipe <name> Use pipe name (default: " PIPE_NAME ")\n"
50 Pipe pipe[1]; local
77 } else if (!strcmp(arg, "-pipe")) {
79 fprintf(stderr, "-pipe option needs an argument! See --help for details.\n");
111 fprintf(stderr, "You can't use both -pipe and -tcp at the same time\n");
122 /* Use default pipe name */
135 /* Open the pipe */
[all...] |
| /external/clang/lib/Driver/ |
| InputInfo.h | 33 Pipe
|
| /prebuilts/gdb/darwin-x86/lib/python2.7/multiprocessing/dummy/ |
| connection.py | 35 __all__ = [ 'Client', 'Listener', 'Pipe' ]
63 def Pipe(duplex=True):
|
| /prebuilts/gdb/linux-x86/lib/python2.7/multiprocessing/dummy/ |
| connection.py | 35 __all__ = [ 'Client', 'Listener', 'Pipe' ]
63 def Pipe(duplex=True):
|
| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/multiprocessing/dummy/ |
| connection.py | 35 __all__ = [ 'Client', 'Listener', 'Pipe' ]
63 def Pipe(duplex=True):
|
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/multiprocessing/dummy/ |
| connection.py | 35 __all__ = [ 'Client', 'Listener', 'Pipe' ]
63 def Pipe(duplex=True):
|
| /system/core/libutils/tests/ |
| 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, Looper::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...] |
| /frameworks/av/media/libnbaio/ |
| 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);
57 // Discard 1/16 of the most recent data in pipe to avoid another overrun immediately
|
| /libcore/ojluni/src/main/java/java/nio/channels/spi/ |
| SelectorProvider.java | 51 * DatagramChannel}, {@link java.nio.channels.Pipe#open Pipe}, {@link
209 * Opens a pipe. </p>
211 * @return The new pipe
213 public abstract Pipe openPipe()
|
| /external/okhttp/okio/okio/src/test/java/okio/ |
| BufferedSourceTest.java | 41 @Override public Pipe pipe() {
43 Pipe result = new Pipe();
55 @Override public Pipe pipe() {
57 Pipe result = new Pipe();
69 @Override public Pipe pipe() {
87 Pipe pipe(); method in interface:BufferedSourceTest.Factory
117 Pipe pipe = factory.pipe(); local
[all...] |
| /system/extras/tests/sdcard/ |
| testcase.h | 45 enum Pipe {READ_FROM_CHILD = 0, WRITE_TO_PARENT, READ_FROM_PARENT, WRITE_TO_CHILD};
|
| /external/clang/lib/Basic/ |
| Diagnostic.cpp | 742 const char *Pipe = ScanFormat(Argument, Argument + ArgumentLen, '|');
743 const char *FirstDollar = ScanFormat(Argument, Pipe, '$');
744 const char *SecondDollar = ScanFormat(FirstDollar + 1, Pipe, '$');
751 FormatDiagnostic(SecondDollar + 1, Pipe, OutStr);
873 const char *Pipe = ScanFormat(Argument, ArgumentEnd, '|');
887 FormatDiagnostic(Pipe + 1, ArgumentEnd, OutStr);
[all...] |
| /libcore/harmony-tests/src/test/java/org/apache/harmony/tests/javax/net/ssl/ |
| SSLEngineTest.java | 23 import java.nio.channels.Pipe;
24 import java.nio.channels.Pipe.SinkChannel;
25 import java.nio.channels.Pipe.SourceChannel;
[all...] |
| /prebuilts/gdb/darwin-x86/lib/python2.7/multiprocessing/ |
| queues.py | 47 from multiprocessing import Pipe
53 # Queue type using a pipe, buffer and thread
62 self._reader, self._writer = Pipe(duplex=False)
180 # Start thread which transfers data from buffer to pipe
194 # On process exit we will wait for data to be flushed to pipe.
231 debug('starting thread to feed data to pipe')
345 # Simplified Queue type -- really just a locked pipe
351 self._reader, self._writer = Pipe(duplex=False)
382 # writes to a message oriented win32 pipe are atomic
|
| /prebuilts/gdb/linux-x86/lib/python2.7/multiprocessing/ |
| queues.py | 47 from multiprocessing import Pipe
53 # Queue type using a pipe, buffer and thread
62 self._reader, self._writer = Pipe(duplex=False)
180 # Start thread which transfers data from buffer to pipe
194 # On process exit we will wait for data to be flushed to pipe.
231 debug('starting thread to feed data to pipe')
345 # Simplified Queue type -- really just a locked pipe
351 self._reader, self._writer = Pipe(duplex=False)
382 # writes to a message oriented win32 pipe are atomic
|
| /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/multiprocessing/ |
| queues.py | 47 from multiprocessing import Pipe
53 # Queue type using a pipe, buffer and thread
62 self._reader, self._writer = Pipe(duplex=False)
180 # Start thread which transfers data from buffer to pipe
194 # On process exit we will wait for data to be flushed to pipe.
231 debug('starting thread to feed data to pipe')
345 # Simplified Queue type -- really just a locked pipe
351 self._reader, self._writer = Pipe(duplex=False)
382 # writes to a message oriented win32 pipe are atomic
|
| /external/autotest/site_utils/tester_feedback/ |
| request_multiplexer.py | 108 # Pop and handle selected request, then close pipe.
164 reply_pipe_send, reply_pipe_recv = multiprocessing.Pipe()
|
| /external/llvm/include/llvm/MC/MCParser/ |
| MCAsmLexer.h | 49 Pipe, PipePipe, Caret,
|
| /frameworks/native/libs/input/tests/ |
| InputChannel_test.cpp | 41 // of a pipe and to check for EPIPE on the other end after the channel is destroyed.
42 Pipe pipe; local
44 sp<InputChannel> inputChannel = new InputChannel(String8("channel name"), pipe.sendFd);
48 EXPECT_EQ(pipe.sendFd, inputChannel->getFd())
53 EXPECT_EQ(-EPIPE, pipe.readSignal())
56 // clean up fds of Pipe endpoints that were closed so we don't try to close them again
57 pipe.sendFd = -1;
|
| /libcore/ojluni/src/main/java/sun/nio/ch/ |
| SinkChannelImpl.java | 35 extends Pipe.SinkChannel
|
