/system/connectivity/wificond/tests/ |
D | looper_backed_event_loop_unittest.cpp | 41 ::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/ |
D | nfa_hci_api.cc | 422 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 …]
|
D | nfa_hci_act.cc | 417 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 …]
|
D | nfa_hci_utils.cc | 871 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 …]
|
D | nfa_hci_main.cc | 67 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/ |
D | Looper_test.cpp | 33 ::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/ |
D | nfa_hci_api.h | 133 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 …]
|
D | nfa_hci_int.h | 172 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/ |
D | action_pipe.h | 72 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/ |
D | alloc-stress.cpp | 103 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/ |
D | LeakPipe.h | 65 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()
|
D | MemUnreachable.cpp | 289 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/ |
D | test_utils.cpp | 147 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()
|
D | test_utils.h | 90 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/ |
D | statsd.te | 9 # stdint through a pipe. It allows statsd to capture traces and hand them 22 # Allow StatsCompanionService to pipe data to statsd.
|
D | incident_helper.te | 8 # use pipe to transmit data from/to incidentd/incident_helper for parsing
|
D | traceur_app.te | 16 # stdint through a pipe.
|
/system/sepolicy/private/ |
D | statsd.te | 9 # stdint through a pipe. It allows statsd to capture traces and hand them 22 # Allow StatsCompanionService to pipe data to statsd.
|
D | incident_helper.te | 8 # use pipe to transmit data from/to incidentd/incident_helper for parsing
|
D | traceur_app.te | 16 # stdint through a pipe.
|
/system/core/libmemunreachable/tests/ |
D | ThreadCapture_test.cpp | 285 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/ |
D | IOEventLoop_test.cpp | 29 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/ |
D | incident_helper.te | 8 # use pipe to transmit data from/to incidentd/incident_helper for parsing
|
/system/netd/resolv/ |
D | README.md | 51 "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/ |
D | binderservicedomain.te | 13 # Receive and write to a pipe received over Binder from an app.
|