Home
last modified time | relevance | path

Searched refs:pipe (Results 1 – 25 of 59) 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.cc406 tNFA_STATUS NFA_HciOpenPipe(tNFA_HANDLE hci_handle, uint8_t pipe) { in NFA_HciOpenPipe() argument
414 if ((pipe < NFA_HCI_FIRST_DYNAMIC_PIPE) || in NFA_HciOpenPipe()
415 (pipe > NFA_HCI_LAST_DYNAMIC_PIPE)) { in NFA_HciOpenPipe()
416 LOG(VERBOSE) << StringPrintf("Invalid Pipe:0x%02x", pipe); in NFA_HciOpenPipe()
421 pipe); in NFA_HciOpenPipe()
430 p_msg->pipe = pipe; /* Pipe ID of the pipe to open */ in NFA_HciOpenPipe()
454 tNFA_STATUS NFA_HciGetRegistry(tNFA_HANDLE hci_handle, uint8_t pipe, in NFA_HciGetRegistry() argument
463 if (pipe < NFA_HCI_FIRST_DYNAMIC_PIPE) { in NFA_HciGetRegistry()
464 LOG(VERBOSE) << StringPrintf("Invalid Pipe:0x%02x", pipe); in NFA_HciGetRegistry()
469 pipe); in NFA_HciGetRegistry()
[all …]
Dnfa_hci_act.cc413 evt_data.gates_pipes.pipe[evt_data.gates_pipes.num_pipes++] = in nfa_hci_api_get_gate_pipe_list()
652 nfa_hciu_find_pipe_by_pid(p_evt_data->open_pipe.pipe); in nfa_hci_api_open_pipe()
661 nfa_hciu_send_open_pipe_cmd(p_evt_data->open_pipe.pipe); in nfa_hci_api_open_pipe()
663 evt_data.opened.pipe = p_evt_data->open_pipe.pipe; in nfa_hci_api_open_pipe()
670 evt_data.opened.pipe = p_evt_data->open_pipe.pipe; in nfa_hci_api_open_pipe()
690 nfa_hciu_find_pipe_by_pid(p_evt_data->get_registry.pipe); in nfa_hci_api_get_reg_value()
710 p_evt_data->get_registry.pipe); in nfa_hci_api_get_reg_value()
712 status = nfa_hciu_send_get_param_cmd(p_evt_data->get_registry.pipe, in nfa_hci_api_get_reg_value()
739 nfa_hciu_find_pipe_by_pid(p_evt_data->set_registry.pipe); in nfa_hci_api_set_reg_value()
759 p_evt_data->set_registry.pipe); in nfa_hci_api_set_reg_value()
[all …]
Dnfa_hci_utils.cc878 evt_data.deleted.pipe = pp->pipe_id; in nfa_hciu_remove_all_pipes_from_host()
925 tNFA_STATUS nfa_hciu_send_delete_pipe_cmd(uint8_t pipe) { in nfa_hciu_send_delete_pipe_cmd() argument
928 LOG(VERBOSE) << StringPrintf("nfa_hciu_send_delete_pipe_cmd: %d", pipe); in nfa_hciu_send_delete_pipe_cmd()
930 if (pipe > NFA_HCI_LAST_DYNAMIC_PIPE) { in nfa_hciu_send_delete_pipe_cmd()
931 LOG(VERBOSE) << StringPrintf("ignore pipe: %d", pipe); in nfa_hciu_send_delete_pipe_cmd()
934 nfa_hci_cb.pipe_in_use = pipe; in nfa_hciu_send_delete_pipe_cmd()
937 NFA_HCI_ADM_DELETE_PIPE, 1, &pipe); in nfa_hciu_send_delete_pipe_cmd()
976 tNFA_STATUS nfa_hciu_send_open_pipe_cmd(uint8_t pipe) { in nfa_hciu_send_open_pipe_cmd() argument
979 nfa_hci_cb.pipe_in_use = pipe; in nfa_hciu_send_open_pipe_cmd()
981 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.cc64 static void nfa_hci_set_receive_buf(uint8_t pipe);
692 uint8_t pipe; in nfa_hci_conn_cback() local
746 pipe = (*p++) & 0x7F; in nfa_hci_conn_cback()
766 nfa_hci_set_receive_buf(pipe); in nfa_hci_conn_cback()
769 if ((pipe >= NFA_HCI_FIRST_DYNAMIC_PIPE) && in nfa_hci_conn_cback()
771 nfa_hci_set_receive_buf(pipe); in nfa_hci_conn_cback()
799 (uint8_t)pipe, in nfa_hci_conn_cback()
800 nfa_hciu_get_type_inst_names(pipe, nfa_hci_cb.type, nfa_hci_cb.inst, buff, in nfa_hci_conn_cback()
820 switch (pipe) { in nfa_hci_conn_cback()
839 if (pipe >= NFA_HCI_FIRST_DYNAMIC_PIPE) in nfa_hci_conn_cback()
[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.h174 uint8_t pipe; member
182 uint8_t pipe; member
203 uint8_t pipe; member
211 uint8_t pipe; member
219 uint8_t pipe; member
229 uint8_t pipe; member
236 uint8_t pipe; member
249 uint8_t pipe; member
273 uint8_t pipe; member
459 extern void nfa_hci_handle_dyn_pipe_pkt(uint8_t pipe, uint8_t* p_data,
[all …]
/system/core/libutils/
DLooper_test.cpp67 DelayedWriteSignal(int delayMillis, Pipe* pipe) : in DelayedWriteSignal() argument
68 DelayedTask(delayMillis), mPipe(pipe) { in DelayedWriteSignal()
188 Pipe pipe; in TEST_F() local
191 handler.setCallback(mLooper, pipe.receiveFd, Looper::EVENT_INPUT); in TEST_F()
206 Pipe pipe; in TEST_F() local
209 ASSERT_EQ(OK, pipe.writeSignal()); in TEST_F()
210 handler.setCallback(mLooper, pipe.receiveFd, Looper::EVENT_INPUT); in TEST_F()
222 EXPECT_EQ(pipe.receiveFd, handler.fd) in TEST_F()
229 Pipe pipe; in TEST_F() local
232 handler.setCallback(mLooper, pipe.receiveFd, Looper::EVENT_INPUT); in TEST_F()
[all …]
DLooper_test_pipe.h29 ::pipe(fds); in Pipe()
/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.cpp101 int error1 = pipe(a); in createPipePair()
102 int error2 = pipe(b); in createPipePair()
110 pid_t createProcess(Pipe pipe, const char* exName, const char* arg, bool use_memcg) { in createProcess() argument
111 pipe.preserveOverFork(true); in createProcess()
117 snprintf(readFdStr, sizeof(readFdStr), "%d", pipe.getReadFd()); in createProcess()
118 snprintf(writeFdStr, sizeof(writeFdStr), "%d", pipe.getWriteFd()); in createProcess()
132 pipe.preserveOverFork(false); in createProcess()
/system/memory/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.cpp307 LeakPipe pipe; in GetUnreachableMemory() local
378 if (!pipe.OpenSender()) { in GetUnreachableMemory()
396 ok = ok && pipe.Sender().Send(num_allocations); in GetUnreachableMemory()
397 ok = ok && pipe.Sender().Send(allocation_bytes); in GetUnreachableMemory()
398 ok = ok && pipe.Sender().Send(num_leaks); in GetUnreachableMemory()
399 ok = ok && pipe.Sender().Send(leak_bytes); in GetUnreachableMemory()
400 ok = ok && pipe.Sender().SendVector(leaks); in GetUnreachableMemory()
450 if (!pipe.OpenReceiver()) { in GetUnreachableMemory()
455 ok = ok && pipe.Receiver().Receive(&info.num_allocations); in GetUnreachableMemory()
456 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/extras/simpleperf/
DIOEventLoop_test.cpp32 ASSERT_EQ(0, pipe(fd)); in TEST()
72 ASSERT_EQ(0, pipe(fd)); in TEST()
190 ASSERT_EQ(0, pipe(fd)); in TEST()
216 ASSERT_EQ(0, pipe(fd)); in TEST()
287 ASSERT_EQ(0, pipe(low_priority_fd)); in TEST()
289 ASSERT_EQ(0, pipe(high_priority_fd)); in TEST()
/system/memory/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/core/trusty/keymaster/set_attestation_ids/
Dset_attestation_ids.cpp51 FILE* pipe = popen(command.c_str(), "r"); in exec_command() local
52 if (!pipe) { in exec_command()
57 while (!feof(pipe)) { in exec_command()
58 if (fgets(buffer, 128, pipe) != NULL) { in exec_command()
63 pclose(pipe); in exec_command()
/system/dmesgd/
Ddmesgd.cpp91 std::unique_ptr<FILE, decltype(&pclose)> pipe(popen("dmesg", "r"), pclose); in ProcessDmesg() local
92 if (!pipe) { in ProcessDmesg()
100 while (getline(&buffer, &buffer_size, pipe.get()) != -1) { in ProcessDmesg()
/system/sepolicy/private/
Dsimpleperf_app_runner.te30 # simpleperf_app_runner passes pipe fds.
31 # simpleperf_app_runner writes app type (debuggable or profileable) to pipe fds.
Dincident_helper.te8 # use pipe to transmit data from/to incidentd/incident_helper for parsing
Dstatsd.te6 # stdint through a pipe. It allows statsd to capture traces and hand them
19 # Allow StatsCompanionService to pipe data to statsd.
22 # Allow any app to pipe data to statsd.
/system/sepolicy/microdroid/system/private/
Datrace.te8 # Allow atrace to write data when a pipe is used for stdout/stderr.
/system/core/init/
Depoll_test.cpp45 ASSERT_EQ(pipe(fds), 0); in TEST()
Dinterprocess_fifo.cpp64 if (pipe(fds_.data()) < 0) { // NOLINT(android-cloexec-pipe) in Initialize()

123