| /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...] |
| /packages/apps/DocumentsUI/src/com/android/documentsui/archives/ |
| WriteableArchive.java | 222 ParcelFileDescriptor[] pipe; local
224 pipe = ParcelFileDescriptor.createReliablePipe();
230 final ParcelFileDescriptor inputPipe = pipe[0];
257 // the pipe with close() instead of closeWithError().
262 Log.e(TAG, "Failed to close the pipe after an error.", e2);
273 IoUtils.closeQuietly(pipe[0]);
274 IoUtils.closeQuietly(pipe[1]);
275 throw new IllegalStateException("Failed to initialize pipe.");
278 return pipe[1];
286 // Waits until all enqueued pipe requests are completed
[all...] |
| /packages/apps/Gallery2/src/com/android/gallery3d/provider/ |
| GalleryProvider.java | 209 final ParcelFileDescriptor[] pipe = ParcelFileDescriptor.createPipe(); local
214 func.writeDataToPipe(pipe[1], args);
217 Utils.closeSilently(pipe[1]);
222 return pipe[0];
224 throw new FileNotFoundException("failure making pipe");
|
| /platform_testing/libraries/aupt-lib/src/android/support/test/aupt/ |
| FilesystemUtil.java | 57 pipe(new ParcelFileDescriptor.AutoCloseInputStream(pfd), out); method
62 pipe(process.getInputStream(), out);
129 /** Pipe an inputstream to an outputstream. This matches Apache's IOUtils::copy */
130 private static void pipe(InputStream in, OutputStream out) throws IOException { method in class:FilesystemUtil
|
| /prebuilts/go/darwin-x86/src/syscall/ |
| syscall_solaris.go | 57 func pipe() (r uintptr, w uintptr, err uintptr) func
59 func Pipe(p []int) (err error) {
63 r0, w0, e1 := pipe()
|
| /prebuilts/go/linux-x86/src/syscall/ |
| syscall_solaris.go | 57 func pipe() (r uintptr, w uintptr, err uintptr) func
59 func Pipe(p []int) (err error) {
63 r0, w0, e1 := pipe()
|
| /system/core/libmemunreachable/ |
| MemUnreachable.cpp | 279 LeakPipe pipe; local
334 if (!pipe.OpenSender()) {
352 ok = ok && pipe.Sender().Send(num_allocations);
353 ok = ok && pipe.Sender().Send(allocation_bytes);
354 ok = ok && pipe.Sender().Send(num_leaks);
355 ok = ok && pipe.Sender().Send(leak_bytes);
356 ok = ok && pipe.Sender().SendVector(leaks);
395 // Get a pipe from the heap walker process. Transferring a new pipe fd
397 // walker process dies the remote side of the pipe will close
[all...] |
| /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...] |
| /system/nfc/src/nfa/hci/ |
| nfa_hci_main.cc | 68 static void nfa_hci_set_receive_buf(uint8_t pipe);
302 /* No two gates can own a same pipe */
312 /* Every bit set in pipe increment mask indicates a valid pipe */
314 /* Check if the pipe is valid one */
325 /* Check if pipe id is valid */
329 /* Check if pipe state is valid */
334 /* Check if local gate on which the pipe is created is valid */
344 /* Check if the peer gate on which the pipe is created is valid */
354 /* Check if the same pipe is present more than once in the control bloc
701 uint8_t pipe; local
[all...] |
| /toolchain/binutils/binutils-2.27/opcodes/ |
| tilegx-opc.c | 8069 int pipe; local
[all...] |
| tilepro-opc.c | 10188 int pipe; local
[all...] |
| /frameworks/base/services/backup/java/com/android/server/backup/restore/ |
| PerformAdbRestoreTask.java | 225 Slog.w(TAG, "Close of restore data pipe threw", e);
577 // If the policy is satisfied, go ahead and set up to pipe the
648 // restore data as well as a pipe for sending data to
650 // pipe.
717 FileOutputStream pipe = new FileOutputStream( local
[all...] |
| /cts/tests/tests/os/src/android/os/cts/ |
| SeccompTest.java | 415 // Create a pipe onto which we will write the composite Seccomp policy.
416 ParcelFileDescriptor[] pipe = ParcelFileDescriptor.createPipe(); local
418 new ParcelFileDescriptor.AutoCloseOutputStream(pipe[1]);
430 // Concatenate all the policyFiles together on the pipe.
456 return nativeInstallTestFilter(pipe[0].detachFd());
|
| /development/samples/Vault/tests/src/com/example/android/vault/ |
| EncryptedDocumentTest.java | 85 final ParcelFileDescriptor[] pipe = ParcelFileDescriptor.createReliablePipe(); local
86 doc.readContent(pipe[1]);
170 final ParcelFileDescriptor[] pipe = ParcelFileDescriptor.createReliablePipe(); local
172 doc.readContent(pipe[1]);
223 // try writing with a pipe that reports failure
225 final ParcelFileDescriptor[] pipe = ParcelFileDescriptor.createReliablePipe(); local
229 final FileOutputStream os = new FileOutputStream(pipe[1].getFileDescriptor());
232 pipe[1].closeWithError("ZOMG");
242 doc.writeMetadataAndContent(second, pipe[0]);
|
| /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.10/Lib/ |
| platform.py | 373 Writing to the pipe is currently not supported.
377 pipe = None
variable in class:_popen
388 self.pipe = open(tmpfile,'rb')
394 return self.pipe.read()
399 return self.pipe.readlines()
405 if self.pipe:
406 rc = self.pipe.close()
502 pipe = popen(cmd)
503 info = pipe.read()
504 if pipe.close():
[all...] |
| /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/Lib/ |
| platform.py | 373 Writing to the pipe is currently not supported.
377 pipe = None
variable in class:_popen
388 self.pipe = open(tmpfile,'rb')
394 return self.pipe.read()
399 return self.pipe.readlines()
405 if self.pipe:
406 rc = self.pipe.close()
502 pipe = popen(cmd)
503 info = pipe.read()
504 if pipe.close():
[all...] |
| /external/apache-http/android/src/android/net/http/ |
| Connection.java | 160 LinkedList<Request> pipe = new LinkedList<Request>(); local
167 states[state] + " pipe " + pipe.size());
181 if (pipe.size() == maxPipe) {
247 pipe.addLast(req);
250 state = clearPipe(pipe) ? DONE : SEND;
255 pipe.addLast(req);
263 int pipeSize = pipe.size();
274 req = (Request)pipe.removeFirst();
296 pipe.addFirst(req)
[all...] |
| /external/libdrm/etnaviv/ |
| etnaviv_priv.h | 148 struct etna_pipe *pipe; member in struct:etna_cmd_stream_priv
|
| /external/libmojo/mojo/android/javatests/src/org/chromium/mojo/bindings/ |
| InterfacesTest.java | 116 public void doStuff(Request request, MessagePipeHandle pipe, DoStuffResponse callback) {
117 if (pipe != null) {
118 pipe.close();
126 public void doStuff2(ConsumerHandle pipe, DoStuff2Response callback) {
|
| /external/libmojo/mojo/public/cpp/bindings/tests/ |
| associated_interface_unittest.cc | 162 // Bind to the same pipe two associated interfaces, whose implementation lives
165 MessagePipe pipe; local
167 true, std::move(pipe.handle0), base::ThreadTaskRunnerHandle::Get()));
169 false, std::move(pipe.handle1), base::ThreadTaskRunnerHandle::Get()));
355 // Set up four associated interfaces on a message pipe. Use the inteface
360 MessagePipe pipe; local
362 true, std::move(pipe.handle0), base::ThreadTaskRunnerHandle::Get()));
364 false, std::move(pipe.handle1), base::ThreadTaskRunnerHandle::Get()));
443 // Set up four associated interfaces on a message pipe. Use the inteface
449 MessagePipe pipe; local
[all...] |
| interface_ptr_unittest.cc | 284 MessagePipe pipe; local
287 Handle handle = pipe.handle0.get();
290 InterfacePtrInfo<math::Calculator>(std::move(pipe.handle0), 0u));
522 MessagePipe pipe; local
524 new StrongMathCalculatorImpl(std::move(pipe.handle0), &error_received,
528 calc.Bind(InterfacePtrInfo<math::Calculator>(std::move(pipe.handle1), 0u));
532 // message pipe.
545 // Destroying calculator_ui should close the pipe and generate an error on the
595 MessagePipe pipe; local
597 WeakMathCalculatorImpl impl(std::move(pipe.handle0), &error_received
[all...] |
| sync_method_unittest.cc | 403 // closed (and therefore the message pipe handle is closed) while the
574 // call, async responses are queued. If the message pipe is disconnected
650 // call, an invalid incoming message will disconnect the message pipe, cause
654 MessagePipe pipe; local
657 ptr.Bind(InterfacePtrInfo<TypeParam>(std::move(pipe.handle0), 0u));
659 MessagePipeHandle raw_binding_handle = pipe.handle1.get();
661 MakeRequest<TypeParam>(std::move(pipe.handle1)));
|
| /external/mesa3d/src/gallium/auxiliary/draw/ |
| draw_context.c | 34 #include "pipe/p_context.h"
71 draw_create_context(struct pipe_context *pipe, void *context,
87 draw->pipe = pipe;
109 draw_create(struct pipe_context *pipe)
111 return draw_create_context(pipe, NULL, TRUE);
117 draw_create_with_llvm_context(struct pipe_context *pipe,
120 return draw_create_context(pipe, context, TRUE);
128 draw_create_no_llvm(struct pipe_context *pipe)
130 return draw_create_context(pipe, NULL, FALSE)
191 struct pipe_context *pipe; local
933 struct pipe_context *pipe = draw->pipe; local
[all...] |
| /external/mesa3d/src/gallium/drivers/llvmpipe/ |
| lp_setup_context.h | 76 struct pipe_context *pipe; member in struct:lp_setup_context
|
| /external/mesa3d/src/gallium/drivers/nouveau/ |
| nouveau_video.c | 647 struct pipe_context *pipe; local
652 pipe = buf->base.context;
662 buf->sampler_view_planes[i] = pipe->create_sampler_view(pipe, buf->resources[i], &sv_templ);
682 struct pipe_context *pipe; local
687 pipe = buf->base.context;
700 buf->sampler_view_components[component] = pipe->create_sampler_view(pipe, buf->resources[i], &sv_templ);
721 struct pipe_context *pipe; local
726 pipe = buf->base.context
[all...] |
