Home
last modified time | relevance | path

Searched refs:pipe (Results 1 – 25 of 71) sorted by relevance

123

/system/connectivity/wificond/tests/
Dlooper_backed_event_loop_unittest.cpp41 ::pipe(fds); in Pipe()
108 Pipe pipe; in TEST_F() local
111 event_loop_->PostTask([&write_result, &pipe]() {write_result = pipe.writeSignal();}); in TEST_F()
114 pipe.receive_fd, in TEST_F()
116 [&read_result, &pipe, this](int fd) { in TEST_F()
117 read_result = pipe.readSignal(); in TEST_F()
125 Pipe pipe; in TEST_F() local
129 pipe.send_fd, in TEST_F()
131 [&write_result, &pipe, this](int fd) { in TEST_F()
132 write_result = pipe.writeSignal(); in TEST_F()
[all …]
/system/nfc/src/nfa/hci/
Dnfa_hci_api.cc422 tNFA_STATUS NFA_HciOpenPipe(tNFA_HANDLE hci_handle, uint8_t pipe) { in NFA_HciOpenPipe() argument
431 if ((pipe < NFA_HCI_FIRST_DYNAMIC_PIPE) || in NFA_HciOpenPipe()
432 (pipe > NFA_HCI_LAST_DYNAMIC_PIPE)) { in NFA_HciOpenPipe()
434 << StringPrintf("Invalid Pipe:0x%02x", pipe); in NFA_HciOpenPipe()
439 << StringPrintf("hci_handle:0x%04x, pipe:0x%02X", hci_handle, pipe); in NFA_HciOpenPipe()
448 p_msg->pipe = pipe; /* Pipe ID of the pipe to open */ in NFA_HciOpenPipe()
472 tNFA_STATUS NFA_HciGetRegistry(tNFA_HANDLE hci_handle, uint8_t pipe, in NFA_HciGetRegistry() argument
482 if (pipe < NFA_HCI_FIRST_DYNAMIC_PIPE) { in NFA_HciGetRegistry()
484 << StringPrintf("Invalid Pipe:0x%02x", pipe); in NFA_HciGetRegistry()
489 << StringPrintf("hci_handle:0x%04x Pipe: 0x%02x", hci_handle, pipe); in NFA_HciGetRegistry()
[all …]
Dnfa_hci_act.cc417 evt_data.gates_pipes.pipe[evt_data.gates_pipes.num_pipes++] = in nfa_hci_api_get_gate_pipe_list()
656 nfa_hciu_find_pipe_by_pid(p_evt_data->open_pipe.pipe); in nfa_hci_api_open_pipe()
665 nfa_hciu_send_open_pipe_cmd(p_evt_data->open_pipe.pipe); in nfa_hci_api_open_pipe()
667 evt_data.opened.pipe = p_evt_data->open_pipe.pipe; in nfa_hci_api_open_pipe()
674 evt_data.opened.pipe = p_evt_data->open_pipe.pipe; in nfa_hci_api_open_pipe()
694 nfa_hciu_find_pipe_by_pid(p_evt_data->get_registry.pipe); in nfa_hci_api_get_reg_value()
714 p_evt_data->get_registry.pipe); in nfa_hci_api_get_reg_value()
716 status = nfa_hciu_send_get_param_cmd(p_evt_data->get_registry.pipe, in nfa_hci_api_get_reg_value()
743 nfa_hciu_find_pipe_by_pid(p_evt_data->set_registry.pipe); in nfa_hci_api_set_reg_value()
763 p_evt_data->set_registry.pipe); in nfa_hci_api_set_reg_value()
[all …]
Dnfa_hci_utils.cc871 evt_data.deleted.pipe = pp->pipe_id; in nfa_hciu_remove_all_pipes_from_host()
918 tNFA_STATUS nfa_hciu_send_delete_pipe_cmd(uint8_t pipe) { in nfa_hciu_send_delete_pipe_cmd() argument
922 << StringPrintf("nfa_hciu_send_delete_pipe_cmd: %d", pipe); in nfa_hciu_send_delete_pipe_cmd()
924 if (pipe > NFA_HCI_LAST_DYNAMIC_PIPE) { in nfa_hciu_send_delete_pipe_cmd()
925 DLOG_IF(INFO, nfc_debug_enabled) << StringPrintf("ignore pipe: %d", pipe); in nfa_hciu_send_delete_pipe_cmd()
928 nfa_hci_cb.pipe_in_use = pipe; in nfa_hciu_send_delete_pipe_cmd()
931 NFA_HCI_ADM_DELETE_PIPE, 1, &pipe); in nfa_hciu_send_delete_pipe_cmd()
971 tNFA_STATUS nfa_hciu_send_open_pipe_cmd(uint8_t pipe) { in nfa_hciu_send_open_pipe_cmd() argument
974 nfa_hci_cb.pipe_in_use = pipe; in nfa_hciu_send_open_pipe_cmd()
976 status = nfa_hciu_send_msg(pipe, NFA_HCI_COMMAND_TYPE, NFA_HCI_ANY_OPEN_PIPE, in nfa_hciu_send_open_pipe_cmd()
[all …]
Dnfa_hci_main.cc67 static void nfa_hci_set_receive_buf(uint8_t pipe);
700 uint8_t pipe; in nfa_hci_conn_cback() local
745 pipe = (*p++) & 0x7F; in nfa_hci_conn_cback()
758 nfa_hci_set_receive_buf(pipe); in nfa_hci_conn_cback()
761 if ((pipe >= NFA_HCI_FIRST_DYNAMIC_PIPE) && in nfa_hci_conn_cback()
763 nfa_hci_set_receive_buf(pipe); in nfa_hci_conn_cback()
791 (uint8_t)pipe, in nfa_hci_conn_cback()
792 nfa_hciu_get_type_inst_names(pipe, nfa_hci_cb.type, nfa_hci_cb.inst, in nfa_hci_conn_cback()
812 switch (pipe) { in nfa_hci_conn_cback()
831 if (pipe >= NFA_HCI_FIRST_DYNAMIC_PIPE) in nfa_hci_conn_cback()
[all …]
/system/core/libutils/
DLooper_test.cpp33 ::pipe(fds); in Pipe()
97 DelayedWriteSignal(int delayMillis, Pipe* pipe) : in DelayedWriteSignal() argument
98 DelayedTask(delayMillis), mPipe(pipe) { in DelayedWriteSignal()
218 Pipe pipe; in TEST_F() local
221 handler.setCallback(mLooper, pipe.receiveFd, Looper::EVENT_INPUT); in TEST_F()
236 Pipe pipe; in TEST_F() local
239 ASSERT_EQ(OK, pipe.writeSignal()); in TEST_F()
240 handler.setCallback(mLooper, pipe.receiveFd, Looper::EVENT_INPUT); in TEST_F()
252 EXPECT_EQ(pipe.receiveFd, handler.fd) in TEST_F()
259 Pipe pipe; in TEST_F() local
[all …]
/system/nfc/src/nfa/include/
Dnfa_hci_api.h133 pipe[NFA_HCI_MAX_PIPE_CB]; /* List of pipe created for the application */ member
157 uint8_t pipe; /* The pipe created for the application */ member
170 uint8_t pipe; /* The dynamic pipe for open operation */ member
176 uint8_t pipe; /* The dynamic pipe for close operation */ member
182 uint8_t pipe; /* The dynamic pipe for delete operation */ member
196 uint8_t pipe; /* The pipe on which HCP packet is exchanged */ member
205 uint8_t pipe; /* The pipe on which HCP EVT packet is received */ member
214 uint8_t pipe; /* The pipe on which HCP CMD packet is received */ member
253 uint8_t pipe; /* Pipe on whose registry is of interest */ member
445 extern tNFA_STATUS NFA_HciOpenPipe(tNFA_HANDLE hci_handle, uint8_t pipe);
[all …]
Dnfa_hci_int.h172 uint8_t pipe; member
180 uint8_t pipe; member
201 uint8_t pipe; member
209 uint8_t pipe; member
217 uint8_t pipe; member
227 uint8_t pipe; member
234 uint8_t pipe; member
247 uint8_t pipe; member
271 uint8_t pipe; member
455 extern void nfa_hci_handle_dyn_pipe_pkt(uint8_t pipe, uint8_t* p_data,
[all …]
/system/update_engine/common/
Daction_pipe.h72 std::shared_ptr<ActionPipe<ObjectType>> pipe(new ActionPipe<ObjectType>); in Bond()
73 from->set_out_pipe(pipe); in Bond()
75 to->set_in_pipe(pipe); // If you get an error on this line, then in Bond()
/system/extras/alloc-stress/
Dalloc-stress.cpp103 int error1 = pipe(a); in createPipePair()
104 int error2 = pipe(b); in createPipePair()
112 pid_t createProcess(Pipe pipe, const char *exName, in createProcess() argument
115 pipe.preserveOverFork(true); in createProcess()
121 snprintf(readFdStr, sizeof(readFdStr), "%d", pipe.getReadFd()); in createProcess()
122 snprintf(writeFdStr, sizeof(writeFdStr), "%d", pipe.getWriteFd()); in createProcess()
136 pipe.preserveOverFork(false); in createProcess()
/system/core/libmemunreachable/
DLeakPipe.h65 ScopedPipe pipe; in OpenSender() local
67 if (!SendFd(sv_[1], pipe.Receiver())) { in OpenSender()
70 pipe.ReleaseReceiver(); in OpenSender()
72 sender_.SetFd(pipe.ReleaseSender()); in OpenSender()
DMemUnreachable.cpp289 LeakPipe pipe; in GetUnreachableMemory() local
344 if (!pipe.OpenSender()) { in GetUnreachableMemory()
362 ok = ok && pipe.Sender().Send(num_allocations); in GetUnreachableMemory()
363 ok = ok && pipe.Sender().Send(allocation_bytes); in GetUnreachableMemory()
364 ok = ok && pipe.Sender().Send(num_leaks); in GetUnreachableMemory()
365 ok = ok && pipe.Sender().Send(leak_bytes); in GetUnreachableMemory()
366 ok = ok && pipe.Sender().SendVector(leaks); in GetUnreachableMemory()
408 if (!pipe.OpenReceiver()) { in GetUnreachableMemory()
413 ok = ok && pipe.Receiver().Receive(&info.num_allocations); in GetUnreachableMemory()
414 ok = ok && pipe.Receiver().Receive(&info.allocation_bytes); in GetUnreachableMemory()
[all …]
/system/core/fastboot/fuzzy_fastboot/
Dtest_utils.cpp147 if (pipe(link) < 0) { in StartProgram()
183 int WaitProgram(const int pid, const int pipe, std::string* error_msg) { in WaitProgram() argument
186 close(pipe); in WaitProgram()
192 while ((n = read(pipe, buf, sizeof(buf))) > 0) { in WaitProgram()
196 close(pipe); in WaitProgram()
Dtest_utils.h90 int StartProgram(const std::string program, const std::vector<std::string> args, int* pipe);
91 int WaitProgram(const pid_t pid, const int pipe, std::string* error_msg);
/system/sepolicy/prebuilts/api/29.0/private/
Dstatsd.te9 # stdint through a pipe. It allows statsd to capture traces and hand them
22 # Allow StatsCompanionService to pipe data to statsd.
Dincident_helper.te8 # use pipe to transmit data from/to incidentd/incident_helper for parsing
Dtraceur_app.te16 # stdint through a pipe.
/system/sepolicy/private/
Dstatsd.te9 # stdint through a pipe. It allows statsd to capture traces and hand them
22 # Allow StatsCompanionService to pipe data to statsd.
Dincident_helper.te8 # use pipe to transmit data from/to incidentd/incident_helper for parsing
Dtraceur_app.te16 # stdint through a pipe.
/system/core/libmemunreachable/tests/
DThreadCapture_test.cpp285 ScopedPipe pipe; in TEST_F() local
293 pipe.CloseReceiver(); in TEST_F()
295 g_pipe = &pipe; in TEST_F()
312 pipe.Close(); in TEST_F()
317 pipe.CloseSender(); in TEST_F()
341 ASSERT_EQ(1, TEMP_FAILURE_RETRY(read(pipe.Receiver(), &buf, 1))); in TEST_F()
/system/extras/simpleperf/
DIOEventLoop_test.cpp29 ASSERT_EQ(0, pipe(fd)); in TEST()
68 ASSERT_EQ(0, pipe(fd)); in TEST()
161 ASSERT_EQ(0, pipe(fd)); in TEST()
186 ASSERT_EQ(0, pipe(fd)); in TEST()
/system/sepolicy/prebuilts/api/28.0/private/
Dincident_helper.te8 # use pipe to transmit data from/to incidentd/incident_helper for parsing
/system/netd/resolv/
DREADME.md51 "reliable datagram pipe" (`socketpair()` in `SOCK_SEQPACKET` mode).
52 The query method writes a struct (containing a pointer to the query) to the pipe
54 reads off the other end of the pipe. The pipe doesn't actually have a queue "inside";
58 We need to pass messages between threads using a pipe, and not a condition variable
/system/sepolicy/prebuilts/api/26.0/private/
Dbinderservicedomain.te13 # Receive and write to a pipe received over Binder from an app.

123