| /libcore/luni/src/main/java/java/io/ |
| PipedInputStream.java | 23 * Receives information from a communications pipe. When two threads want to
68 * The size of the default pipe in bytes.
73 * Indicates if this pipe is connected.
109 throw new IllegalArgumentException("pipe size " + pipeSize + " too small");
149 * pipe and notifies all threads waiting to read or write.
182 throw new IOException("Pipe already connected");
193 * reached. If there is no data in the pipe, this method blocks until data
220 * "Pipe broken" will be thrown in receive()
231 throw new IOException("Pipe broken");
299 * "Pipe broken" will be thrown in receive(
[all...] |
| /prebuilts/gcc/linux-x86/host/i686-linux-glibc2.7-4.4.3/sysroot/usr/include/linux/ |
| limits.h | 13 #define PIPE_BUF 4096 /* # bytes in atomic write to a pipe */
|
| /prebuilts/gcc/linux-x86/host/i686-linux-glibc2.7-4.6/sysroot/usr/include/linux/ |
| limits.h | 13 #define PIPE_BUF 4096 /* # bytes in atomic write to a pipe */
|
| /prebuilts/gcc/linux-x86/host/x86_64-linux-glibc2.7-4.6/sysroot/usr/include/linux/ |
| limits.h | 13 #define PIPE_BUF 4096 /* # bytes in atomic write to a pipe */
|
| /external/qemu/docs/ |
| ANDROID-QEMU-PIPE.TXT | 42 implemented by any emulator pipe service.
44 ./android/hw-pipe-net.c contains the implementation of the network pipe
118 > 0 The number of bytes that were written to the pipe
144 wait queue until the pipe service can accept data again.
152 up when the pipe becomes writable again. How this is done is explained
165 poll() and epoll() system calls where a pipe channel is involved.
196 PIPE_WAKE_CLOSED :: the pipe service closed the connection.
|
| ANDROID-ADB-QEMU.TXT | 11 been moved to use QEMUD pipe to transfer data between the emulator, and the
19 communication over QEMUD pipe:
44 QEMUD pipe connection in the ADB client, and ADB guest is ready to receive data
|
| /external/skia/gyp/ |
| FileReaderApp.gyp | 12 '../include/pipe',
18 '../src/pipe/SkGPipeRead.cpp',
|
| /external/compiler-rt/lib/asan/scripts/ |
| asan_symbolize.py | 55 stdin=subprocess.PIPE, stdout=subprocess.PIPE)
74 stdin=subprocess.PIPE, stdout=subprocess.PIPE)
109 stdin=subprocess.PIPE, stdout=subprocess.PIPE,)
|
| /external/libnfc-nxp/src/ |
| phHciNfc_Generic.h | 189 /* HCP Header Pipe ID Offset */
191 /* HCP Header Pipe ID Length */
529 /** \internal Chaining Information and Pipe Identifier */
552 /** \internal HCI Source Gate Information for the pipe */
554 /** \internal HCI Destination Gate Information for the pipe */
556 /** \internal HCI Pipe Identifier */
562 /** \internal Structure containing the created dynamic pipe information */
563 phHciNfc_Pipe_Params_t pipe; member in struct:phHciNfc_Pipe_Info
564 /** \internal Status of the previous command sent to this pipe */
566 /** \internal previous message type Sent to this pipe */
[all...] |
| phHciNfc_SWP.h | 84 /* Pointer to SWP gate pipe information */
86 /* SWP gate pipe Identified */
139 * \brief updates SWP gate specific pipe information .
141 * This function intialises gate specific informations like pipe id,
146 * \param[in] pPipeInfo Update the pipe Information of the SWP
163 * \brief updates SWP gate specific pipe information .
165 * This function intialises gate specific informations like pipe id,
|
| phHciNfc_PollingLoop.h | 88 * polling loop pipe
112 * The phHciNfc_PollLoop_Release function closes the polling loop gate pipe
168 * loop gate management structure. This function is used by the pipe management to
169 * update the pipe id
174 * \param[in] pPipeInfo Update the pipe Information of the polling loop
|
| phHciNfc_LinkMgmt.c | 172 /* Link Mgmt pipe open sequence */
183 /* Populate the pipe information in the pipe handle */
184 ((phHciNfc_Pipe_Info_t *)p_pipe_info)->pipe.pipe_id =
265 * \brief Opens the Link Management Pipe of the Link Management Gate.
267 * This function Opens the Link Management Pipe of the Link Management
|
| /external/nist-sip/java/gov/nist/javax/sip/parser/ |
| Pipeline.java | 52 private InputStream pipe; field in class:Pipeline
122 public Pipeline(InputStream pipe, int readTimeout, Timer timer) {
123 // pipe is the Socket stream
126 this.pipe = pipe;
159 this.pipe.close();
|
| /external/wpa_supplicant_6/wpa_supplicant/src/common/ |
| wpa_ctrl.c | 66 HANDLE pipe; member in struct:wpa_ctrl
435 #define NAMED_PIPE_PREFIX TEXT("\\\\.\\pipe\\") TEXT(WPA_SUPPLICANT_NAMED_PIPE)
468 ctrl->pipe = CreateFile(name, GENERIC_READ | GENERIC_WRITE, 0,
471 * Current named pipe server side in wpa_supplicant is
472 * re-opening the pipe for new clients only after the previous
477 if (ctrl->pipe != INVALID_HANDLE_VALUE ||
482 if (ctrl->pipe == INVALID_HANDLE_VALUE) {
488 if (!SetNamedPipeHandleState(ctrl->pipe, &mode, NULL, NULL)) {
489 CloseHandle(ctrl->pipe);
500 CloseHandle(ctrl->pipe);
[all...] |
| /system/bluetooth/tools/ |
| pipetest.c | 17 /* Helper to test linux pipe's */
156 if (pipe(fd)) return -1;
256 if (pipe(fd)) {
257 printf("pipe: %s\n", strerror(errno));
274 if (pipe(fd)) return -1;
297 if (pipe(fd)) return -1;
321 if (pipe(fd)) return -1;
344 if (pipe(fd)) return -1;
362 if (pipe(fd)) return -1;
376 if (pipe(fd)) return -1
[all...] |
| /external/kernel-headers/original/linux/ |
| usb.h | 684 * @pipe: Holds endpoint number, direction, type, and more.
690 * is a different endpoint (and pipe) from "out" endpoint two.
714 * and is encoded in the pipe. When the length is zero, neither
771 * All URBs submitted must initialize the dev, pipe, transfer_flags (may be
858 unsigned int pipe; \/* (in) pipe information *\/ member in struct:urb
1078 int pipe; member in struct:usb_sg_request
[all...] |
| /external/webkit/Source/WebKit2/Platform/CoreIPC/win/ |
| ConnectionWin.cpp | 50 pipeName = String::format("\\\\.\\pipe\\com.apple.WebKit.%x", uniqueID);
57 // There was already a pipe with this name, try again.
127 // Read the rest of the message out of the pipe.
180 // Find out the size of the next message in the pipe (if there is one) so that we can read
194 // There's no message waiting in the pipe. Schedule a read of the first byte of the
208 // There was already a message waiting in the pipe, and we read it synchronously.
216 // There are no messages in the pipe currently. readEventHandler will be called again once there is a message.
262 // We connected the two ends of the pipe in createServerAndClientIdentifiers.
304 // The pipe is being closed.
|
| /external/bluetooth/glib/gio/tests/ |
| unix-streams.c | 104 /* pipe closed */
209 * read op in the main thread, which will then close the pipe to
213 g_assert (pipe (writer_pipe) == 0 && pipe (reader_pipe) == 0);
253 g_test_add_func ("/unix-streams/pipe-io-test", test_pipe_io);
|
| /external/chromium/net/test/ |
| test_server_win.cc | 83 // Unblock the ReadFile in TestServer::WaitToStart by writing to the pipe.
86 LOG(WARNING) << "Timeout reached; unblocking pipe by writing "
156 PLOG(ERROR) << "Failed to create pipe";
165 PLOG(ERROR) << "Failed to enable pipe inheritance";
180 "startup-pipe",
|
| /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/ |
| FileInputStreamTest.java | 70 FileDescriptor[] pipe = Libcore.os.pipe(); local
71 DataFeeder feeder = new DataFeeder(pipe[1]);
74 FileInputStream fis = new FileInputStream(pipe[0]);
81 IoUtils.closeQuietly(pipe[0]);
|
| InterruptedStreamTest.java | 31 import java.nio.channels.Pipe;
82 testInterruptReadableChannel(Pipe.open().source());
86 testInterruptWritableChannel(Pipe.open().sink());
|
| /dalvik/tools/ |
| deadcode.py | 103 pipe = os.popen(command)
106 data = pipe.read()
109 pipe.close()
|
| /external/chromium/base/ |
| sync_socket_win.cc | 16 // This prefix used to be appended to pipe names for pipes
18 const wchar_t kPipePrefix[] = L"\\\\.\\pipe\\chrome.sync.";
77 OPEN_EXISTING, // opens existing pipe.
|
| /frameworks/base/tests/DumpRenderTree/assets/ |
| run_layout_tests.py | 62 adb_output = subprocess.Popen(shell_cmd_str, shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE).communicate()[0]
167 adb_output = subprocess.Popen(generate_test_list_cmd_str, shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE).communicate()[0]
205 adb_output = subprocess.Popen(run_layout_test_cmd, shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE).communicate()[0]
214 shell_cmd_str, shell=True, stdout=subprocess.PIPE,
215 stderr=subprocess.PIPE).communicate()
230 adb_output = subprocess.Popen(run_layout_test_cmd, shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE).communicate()[0
[all...] |
