Searched refs:pipe (Results 1 - 25 of 34) sorted by relevance

12

/system/connectivity/wificond/tests/
H A Dlooper_backed_event_loop_unittest.cpp41 ::pipe(fds);
50 LOG(ERROR) << "Failed to write signal to pipe: " << strerror(errno);
61 LOG(ERROR) << "No data from pipe";
63 LOG(ERROR) << "Failed to read signal from pipe: " << strerror(errno);
108 Pipe pipe; local
111 event_loop_->PostTask([&write_result, &pipe]() {write_result = pipe.writeSignal();});
112 // Read data from pipe when fd is ready for input.
114 pipe.receive_fd,
116 [&read_result, &pipe, thi
125 Pipe pipe; local
141 Pipe pipe; local
[all...]
/system/core/libutils/tests/
H A DLooper_test.cpp44 DelayedWriteSignal(int delayMillis, Pipe* pipe) : argument
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());
187 handler.setCallback(mLooper, pipe.receiveFd, Looper::EVENT_INPUT);
199 EXPECT_EQ(pipe.receiveFd, handler.fd)
200 << "callback should have received pipe fd as parameter";
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...]
H A DTestHelpers.h31 ::pipe(fds);
/system/nfc/src/nfa/hci/
H A Dnfa_hci_api.cc339 ** Description This function is called to create a dynamic pipe with the
340 ** specified host. When the dynamic pipe is created (or
342 ** NFA_HCI_CREATE_PIPE_EVT with the pipe id. If a pipe exists
344 ** created earlier by the calling application then the pipe
345 ** id of the existing pipe will be returned and a new pipe
346 ** will not be created. After successful creation of pipe,
347 ** registry entry will be created for the dynamic pipe and
348 ** all information related to the pipe wil
426 NFA_HciOpenPipe(tNFA_HANDLE hci_handle, uint8_t pipe) argument
476 NFA_HciGetRegistry(tNFA_HANDLE hci_handle, uint8_t pipe, uint8_t reg_inx) argument
526 NFA_HciSendCommand(tNFA_HANDLE hci_handle, uint8_t pipe, uint8_t cmd_code, uint16_t cmd_size, uint8_t* p_data) argument
603 NFA_HciSendEvent(tNFA_HANDLE hci_handle, uint8_t pipe, uint8_t evt_code, uint16_t evt_size, uint8_t* p_data, uint16_t rsp_size, uint8_t* p_rsp_buf, uint16_t rsp_timeout) argument
673 NFA_HciClosePipe(tNFA_HANDLE hci_handle, uint8_t pipe) argument
723 NFA_HciDeletePipe(tNFA_HANDLE hci_handle, uint8_t pipe) argument
771 NFA_HciAddStaticPipe(tNFA_HANDLE hci_handle, uint8_t host, uint8_t gate, uint8_t pipe) argument
[all...]
H A Dnfa_hci_act.cc340 /* See if any pipe is owned by this app */
416 evt_data.gates_pipes.pipe[evt_data.gates_pipes.num_pipes++] =
530 /* See if any pipe is owned by this app */
541 /* UICC is not active at the moment and cannot delete the pipe */
588 ** Description action function to create a pipe
600 /* Verify that the app owns the gate that the pipe is being created on */
605 "nfa_hci_api_create_pipe Cannot create pipe! APP: 0x%02x does not own "
615 "nfa_hci_api_create_pipe : Cannot create multiple pipe between the "
647 ** Description action function to open a pipe
655 nfa_hciu_find_pipe_by_pid(p_evt_data->open_pipe.pipe);
1192 uint8_t source_host, source_gate, dest_host, dest_gate, pipe; local
1314 uint8_t pipe = 0; local
[all...]
H A Dnfa_hci_main.cc68 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 i
701 uint8_t pipe; local
1073 nfa_hci_set_receive_buf(uint8_t pipe) argument
[all...]
H A Dnfa_hci_utils.cc47 ** Description look for the pipe control block based on pipe id
49 ** Returns pointer to the pipe control block, or NULL if not found
166 /* For each pipe on this gate, check if it is open */
199 ** Description Find the application that owns a pipe
292 ** and send it on the given pipe.
411 ** Description Allocate a pipe control block
413 ** Returns pointer to the pipe control block, or NULL if
421 /* If we already have a pipe of the same ID, release it first it */
428 /* Look for a free pipe contro
911 nfa_hciu_send_delete_pipe_cmd(uint8_t pipe) argument
964 nfa_hciu_send_open_pipe_cmd(uint8_t pipe) argument
984 nfa_hciu_send_close_pipe_cmd(uint8_t pipe) argument
1004 nfa_hciu_send_get_param_cmd(uint8_t pipe, uint8_t index) argument
1023 nfa_hciu_send_set_param_cmd(uint8_t pipe, uint8_t index, uint8_t length, uint8_t* p_data) argument
1306 nfa_hciu_get_type_inst_names(uint8_t pipe, uint8_t type, uint8_t inst, char* p_buff) argument
[all...]
/system/nfc/src/nfa/include/
H A Dnfa_hci_api.h65 /* Response recvd to cmd sent on app owned pipe */
67 /* Response sent on app owned pipe */
69 /* Command sent on app owned pipe */
71 /* Event sent on app owned pipe */
73 /* Command received on app owned pipe */
75 /* Event received on app owned pipe */
85 /* A static pipe is added */
106 /* Dynamic pipe control block */
111 uint8_t dest_host; /* Peer host to which this pipe is connected */
112 uint8_t dest_gate; /* Peer gate to which this pipe i
133 pipe[NFA_HCI_MAX_PIPE_CB]; /* List of pipe created for the application */ member in struct:__anon2286
157 uint8_t pipe; /* The pipe created for the application */ member in struct:__anon2289
170 uint8_t pipe; /* The dynamic pipe for open operation */ member in struct:__anon2290
176 uint8_t pipe; /* The dynamic pipe for close operation */ member in struct:__anon2291
182 uint8_t pipe; /* The dynamic pipe for delete operation */ member in struct:__anon2292
196 uint8_t pipe; /* The pipe on which HCP packet is exchanged */ member in struct:__anon2294
205 uint8_t pipe; /* The pipe on which HCP EVT packet is received */ member in struct:__anon2295
214 uint8_t pipe; /* The pipe on which HCP CMD packet is received */ member in struct:__anon2296
253 uint8_t pipe; /* Pipe on whose registry is of interest */ member in struct:__anon2303
[all...]
H A Dnfa_hci_int.h92 NFA_HCI_API_GET_APP_GATE_PIPE_EVT, /* Get the list of gate and pipe associated
100 NFA_HCI_API_CREATE_PIPE_EVT, /* Create a pipe between two gates */
101 NFA_HCI_API_OPEN_PIPE_EVT, /* Open a pipe */
102 NFA_HCI_API_CLOSE_PIPE_EVT, /* Close a pipe */
103 NFA_HCI_API_DELETE_PIPE_EVT, /* Delete a pipe */
104 NFA_HCI_API_ADD_STATIC_PIPE_EVT, /* Add a static pipe */
105 NFA_HCI_API_SEND_CMD_EVT, /* Send command via pipe */
107 NFA_HCI_API_SEND_EVENT_EVT, /* Send event via pipe */
170 uint8_t pipe; member in struct:__anon2312
178 uint8_t pipe; member in struct:__anon2313
199 uint8_t pipe; member in struct:__anon2315
207 uint8_t pipe; member in struct:__anon2316
215 uint8_t pipe; member in struct:__anon2317
225 uint8_t pipe; member in struct:__anon2318
232 uint8_t pipe; member in struct:__anon2319
245 uint8_t pipe; member in struct:__anon2320
269 uint8_t pipe; member in struct:__anon2323
[all...]
/system/update_engine/common/
H A Daction_pipe.h38 // cannot be bonded (i.e., connected with a pipe) if their output/input
59 // This should be called by an Action on its input pipe.
63 // This should be called by an Action on its output pipe.
64 // Stores a copy of the passed object in this pipe.
72 std::shared_ptr<ActionPipe<ObjectType>> pipe(new ActionPipe<ObjectType>);
73 from->set_out_pipe(pipe);
75 to->set_in_pipe(pipe); // If you get an error on this line, then
H A Dsubprocess_unittest.cc157 {kBinPath "/sh", "-c", "echo on pipe >&3"},
160 base::Bind(&ExpectedDataOnPipe, &subprocess_, &pid, 3, "on pipe\n", 0));
170 // Test that a pipe file descriptor open in the parent is not open in the child.
172 brillo::ScopedPipe pipe; local
179 std::to_string(pipe.writer)};
277 // Check that there isn't anything else to read from the pipe.
/system/tpm/attestation/server/
H A Dattestationd-seccomp-amd64.policy35 pipe: 1
/system/tpm/tpm_manager/server/
H A Dtpm_managerd-seccomp-amd64.policy36 pipe: 1
/system/extras/alloc-stress/
H A Dalloc-stress.cpp103 int error1 = pipe(a);
104 int error2 = pipe(b);
112 pid_t createProcess(Pipe pipe, const char *exName, argument
115 pipe.preserveOverFork(true);
121 snprintf(readFdStr, sizeof(readFdStr), "%d", pipe.getReadFd());
122 snprintf(writeFdStr, sizeof(writeFdStr), "%d", pipe.getWriteFd());
136 pipe.preserveOverFork(false);
/system/core/libmemunreachable/
H A DLeakPipe.h31 // LeakPipe implements a pipe that can transfer vectors of simple objects
32 // between processes. The pipe is created in the sending process and
34 // that only the sending process can have the send side of the pipe open, so if
35 // the sending process dies the pipe will close.
65 ScopedPipe pipe; local
67 if (!SendFd(sv_[1], pipe.Receiver())) {
70 pipe.ReleaseReceiver();
72 sender_.SetFd(pipe.ReleaseSender());
H A DMemUnreachable.cpp279 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 wil
[all...]
/system/extras/simpleperf/
H A DIOEventLoop_test.cpp27 ASSERT_EQ(0, pipe(fd));
66 ASSERT_EQ(0, pipe(fd));
159 ASSERT_EQ(0, pipe(fd));
184 ASSERT_EQ(0, pipe(fd));
/system/core/libmemunreachable/tests/
H A DThreadCapture_test.cpp283 ScopedPipe pipe; local
291 pipe.CloseReceiver();
293 g_pipe = &pipe;
310 pipe.Close();
315 pipe.CloseSender();
339 ASSERT_EQ(1, TEMP_FAILURE_RETRY(read(pipe.Receiver(), &buf, 1)));
/system/extras/tests/sdcard/
H A Dtestcase.cpp57 if (pipe(mIpc) < 0)
59 fprintf(stderr, "pipe failed\n");
62 if (pipe(mIpc + 2) < 0)
64 fprintf(stderr, "pipe failed\n");
/system/core/base/include/android-base/
H A Dunique_fd.h109 if (pipe(pipefd) != 0) {
/system/tools/aidl/tests/
H A Daidl_test_client_file_descriptors.cpp97 if (pipe(fds)) {
/system/core/adb/
H A Dtest_adb.py71 # Helper method that reads a pipe until it is closed, then sets the event.
72 def _read_pipe_and_set_event(self, pipe, event):
73 x = pipe.read()
/system/libhwbinder/vts/performance/
H A DPerfTest.cpp58 int error1 = pipe(a);
59 int error2 = pipe(b);
H A DBenchmark_throughput.cpp91 int error1 = pipe(a);
92 int error2 = pipe(b);
/system/core/libsysutils/src/
H A DSocketListener.cpp100 if (pipe(mCtrlPipe)) {
101 SLOGE("pipe failed (%s)", strerror(errno));
119 SLOGE("Error writing to control pipe (%s)", strerror(errno));

Completed in 574 milliseconds

12