| /aosp12/system/connectivity/wificond/tests/ |
| H A 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()
117 read_result = pipe.readSignal(); in TEST_F()
125 Pipe pipe; in TEST_F() local
129 pipe.send_fd, in TEST_F()
136 EXPECT_EQ(true, pipe.readSignal()); in TEST_F()
141 Pipe pipe; in TEST_F() local
144 event_loop_->PostTask([&write_result, &pipe]() {write_result = pipe.writeSignal();}); in TEST_F()
[all …]
|
| /aosp12/system/nfc/src/nfa/hci/ |
| H A D | nfa_hci_api.cc | 448 p_msg->pipe = pipe; /* Pipe ID of the pipe to open */ in NFA_HciOpenPipe()
482 if (pipe < NFA_HCI_FIRST_DYNAMIC_PIPE) { in NFA_HciGetRegistry()
497 p_msg->pipe = pipe; in NFA_HciGetRegistry()
533 if (pipe < NFA_HCI_FIRST_DYNAMIC_PIPE) { in NFA_HciSendCommand()
555 p_msg->pipe = pipe; in NFA_HciSendCommand()
615 if (pipe < NFA_HCI_FIRST_DYNAMIC_PIPE) { in NFA_HciSendEvent()
641 p_msg->pipe = pipe; in NFA_HciSendEvent()
695 p_msg->pipe = pipe; in NFA_HciClosePipe()
746 p_msg->pipe = pipe; in NFA_HciDeletePipe()
789 if (pipe <= NFA_HCI_LAST_DYNAMIC_PIPE) { in NFA_HciAddStaticPipe()
[all …]
|
| H A D | nfa_hci_act.cc | 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()
804 evt_data.closed.pipe = p_evt_data->close_pipe.pipe; in nfa_hci_api_close_pipe()
811 evt_data.closed.pipe = 0x00; in nfa_hci_api_close_pipe()
844 evt_data.deleted.pipe = 0x00; in nfa_hci_api_delete_pipe()
1222 STREAM_TO_UINT8(pipe, p_data); in nfa_hci_handle_admin_gate_cmd()
1243 evt_data.created.pipe = pipe; in nfa_hci_handle_admin_gate_cmd()
1265 STREAM_TO_UINT8(pipe, p_data); in nfa_hci_handle_admin_gate_cmd()
1321 uint8_t pipe = 0; in nfa_hci_handle_admin_gate_rsp() local
1551 STREAM_TO_UINT8(pipe, p_data); in nfa_hci_handle_admin_gate_rsp()
[all …]
|
| H A D | nfa_hci_utils.cc | 884 evt_data.deleted.pipe = pp->pipe_id; in nfa_hciu_remove_all_pipes_from_host()
931 tNFA_STATUS nfa_hciu_send_delete_pipe_cmd(uint8_t pipe) { in nfa_hciu_send_delete_pipe_cmd() argument
937 if (pipe > NFA_HCI_LAST_DYNAMIC_PIPE) { in nfa_hciu_send_delete_pipe_cmd()
941 nfa_hci_cb.pipe_in_use = pipe; in nfa_hciu_send_delete_pipe_cmd()
944 NFA_HCI_ADM_DELETE_PIPE, 1, &pipe); in nfa_hciu_send_delete_pipe_cmd()
984 tNFA_STATUS nfa_hciu_send_open_pipe_cmd(uint8_t pipe) { in nfa_hciu_send_open_pipe_cmd() argument
987 nfa_hci_cb.pipe_in_use = pipe; in nfa_hciu_send_open_pipe_cmd()
1004 tNFA_STATUS nfa_hciu_send_close_pipe_cmd(uint8_t pipe) { in nfa_hciu_send_close_pipe_cmd() argument
1007 nfa_hci_cb.pipe_in_use = pipe; in nfa_hciu_send_close_pipe_cmd()
1027 status = nfa_hciu_send_msg(pipe, NFA_HCI_COMMAND_TYPE, in nfa_hciu_send_get_param_cmd()
[all …]
|
| H A 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
754 pipe = (*p++) & 0x7F; in nfa_hci_conn_cback()
774 nfa_hci_set_receive_buf(pipe); in nfa_hci_conn_cback()
777 if ((pipe >= NFA_HCI_FIRST_DYNAMIC_PIPE) && in nfa_hci_conn_cback()
779 nfa_hci_set_receive_buf(pipe); in nfa_hci_conn_cback()
807 (uint8_t)pipe, in nfa_hci_conn_cback()
828 switch (pipe) { in nfa_hci_conn_cback()
847 if (pipe >= NFA_HCI_FIRST_DYNAMIC_PIPE) in nfa_hci_conn_cback()
1086 static void nfa_hci_set_receive_buf(uint8_t pipe) { in nfa_hci_set_receive_buf() argument
[all …]
|
| /aosp12/system/core/libutils/ |
| H A D | Looper_test.cpp | 185 Pipe pipe; in TEST_F() local
203 Pipe pipe; in TEST_F() local
226 Pipe pipe; in TEST_F() local
244 Pipe pipe; in TEST_F() local
269 Pipe pipe; in TEST_F() local
295 Pipe pipe; in TEST_F() local
317 Pipe pipe; in TEST_F() local
359 Pipe pipe; in TEST_F() local
386 Pipe pipe; in TEST_F() local
394 Pipe pipe; in TEST_F() local
[all …]
|
| /aosp12/art/runtime/ |
| H A D | native_stack_dump.cc | 158 DCHECK(pipe != nullptr); in Drain()
159 DCHECK(pipe->get() != nullptr); in Drain()
160 int in = pipe->get()->in.Fd(); in Drain()
174 pipe->reset(); in Drain()
185 pipe->reset(); in Drain()
196 pipe->reset(); in Drain()
220 (*pipe)->odd = !(*pipe)->odd; in Drain()
249 if (*pipe == nullptr || (*pipe)->file != map_src) { in Addr2line()
250 if (*pipe != nullptr) { in Addr2line()
279 pipe->reset(); in Addr2line()
[all …]
|
| /aosp12/system/nfc/src/nfa/include/ |
| H A D | nfa_hci_api.h | 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);
511 tNFA_STATUS NFA_HciSendEvent(tNFA_HANDLE hci_handle, uint8_t pipe,
[all …]
|
| H A 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
508 extern tNFA_STATUS nfa_hciu_send_close_pipe_cmd(uint8_t pipe);
[all …]
|
| /aosp12/art/tools/signal_dumper/ |
| H A D | signal_dumper.cc | 206 DCHECK(pipe != nullptr); in Drain()
207 DCHECK(pipe->get() != nullptr); in Drain()
222 pipe->reset(); in Drain()
233 pipe->reset(); in Drain()
244 pipe->reset(); in Drain()
265 (*pipe)->odd = !(*pipe)->odd; in Drain()
281 DCHECK(pipe != nullptr); in Addr2line()
290 if (*pipe == nullptr || (*pipe)->file != map_src) { in Addr2line()
291 if (*pipe != nullptr) { in Addr2line()
319 pipe->reset(); in Addr2line()
[all …]
|
| /aosp12/bionic/libc/kernel/uapi/drm/ |
| H A D | etnaviv_drm.h | 58 __u32 pipe; member
123 __u32 pipe; member
139 __u32 pipe; member
154 __u32 pipe; member
161 __u32 pipe; member
168 __u32 pipe; member
|
| /aosp12/frameworks/av/media/libnbaio/ |
| H A D | PipeReader.cpp | 27 PipeReader::PipeReader(Pipe& pipe) : in PipeReader() argument
28 NBAIO_Source(pipe.mFormat), in PipeReader()
29 mPipe(pipe), mFifoReader(mPipe.mFifo, false /*throttlesWriter*/, false /*flush*/), in PipeReader()
33 android_atomic_inc(&pipe.mReaders); in PipeReader()
|
| H A D | MonoPipeReader.cpp | 26 MonoPipeReader::MonoPipeReader(MonoPipe* pipe) : in MonoPipeReader() argument
27 NBAIO_Source(pipe->mFormat), in MonoPipeReader()
28 mPipe(pipe), mFifoReader(mPipe->mFifo, true /*throttlesWriter*/) in MonoPipeReader()
|
| /aosp12/system/memory/libmemunreachable/ |
| H A D | MemUnreachable.cpp | 298 LeakPipe pipe; in GetUnreachableMemory() local
353 if (!pipe.OpenSender()) { in GetUnreachableMemory()
371 ok = ok && pipe.Sender().Send(num_allocations); in GetUnreachableMemory()
372 ok = ok && pipe.Sender().Send(allocation_bytes); in GetUnreachableMemory()
373 ok = ok && pipe.Sender().Send(num_leaks); in GetUnreachableMemory()
374 ok = ok && pipe.Sender().Send(leak_bytes); in GetUnreachableMemory()
375 ok = ok && pipe.Sender().SendVector(leaks); in GetUnreachableMemory()
417 if (!pipe.OpenReceiver()) { in GetUnreachableMemory()
424 ok = ok && pipe.Receiver().Receive(&info.num_leaks); in GetUnreachableMemory()
425 ok = ok && pipe.Receiver().Receive(&info.leak_bytes); in GetUnreachableMemory()
[all …]
|
| H A 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()
|
| /aosp12/system/extras/alloc-stress/ |
| H A D | alloc-stress.cpp | 99 int error1 = pipe(a); in createPipePair()
100 int error2 = pipe(b); in createPipePair()
108 pid_t createProcess(Pipe pipe, const char* exName, const char* arg, bool use_memcg) { in createProcess() argument
109 pipe.preserveOverFork(true); in createProcess()
115 snprintf(readFdStr, sizeof(readFdStr), "%d", pipe.getReadFd()); in createProcess()
116 snprintf(writeFdStr, sizeof(writeFdStr), "%d", pipe.getWriteFd()); in createProcess()
130 pipe.preserveOverFork(false); in createProcess()
|
| /aosp12/packages/apps/DocumentsUI/tests/functional/com/android/documentsui/archives/ |
| H A D | TestUtils.java | 92 ParcelFileDescriptor[] pipe = null; in getNonSeekableDescriptor() local
94 pipe = ParcelFileDescriptor.createPipe(); in getNonSeekableDescriptor()
95 final ParcelFileDescriptor finalOutputPipe = pipe[1]; in getNonSeekableDescriptor()
117 return pipe[0]; in getNonSeekableDescriptor()
|
| /aosp12/frameworks/base/core/java/com/android/internal/os/ |
| H A D | TransferPipe.java | 104 ParcelFileDescriptor[] pipe = ParcelFileDescriptor.createPipe(); in dumpAsync() local
106 TransferPipe.dumpAsync(binder, pipe[1].getFileDescriptor(), args); in dumpAsync()
109 pipe[1].close(); in dumpAsync()
110 pipe[1] = null; in dumpAsync()
114 try (FileInputStream is = new FileInputStream(pipe[0].getFileDescriptor())) { in dumpAsync()
128 pipe[0].close(); in dumpAsync()
129 IoUtils.closeQuietly(pipe[1]); in dumpAsync()
|
| /aosp12/system/update_engine/common/ |
| H A 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()
|
| /aosp12/packages/apps/DocumentsUI/src/com/android/documentsui/archives/ |
| H A D | WriteableArchive.java | 223 ParcelFileDescriptor[] pipe; in openDocument() local
225 pipe = ParcelFileDescriptor.createReliablePipe(); in openDocument()
231 final ParcelFileDescriptor inputPipe = pipe[0]; in openDocument()
274 FileUtils.closeQuietly(pipe[0]); in openDocument()
275 FileUtils.closeQuietly(pipe[1]); in openDocument()
279 return pipe[1]; in openDocument()
|
| /aosp12/system/core/fastboot/fuzzy_fastboot/ |
| H A 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()
|
| /aosp12/frameworks/base/core/java/com/android/internal/infra/ |
| H A D | RemoteStream.java | 189 ParcelFileDescriptor[] pipe;
192 pipe = ParcelFileDescriptor.createPipe();
193 try (ParcelFileDescriptor remotePipe = pipe[read ? 1 : 0]) {
198 mLocalPipe = pipe[read ? 0 : 1];
|
| /aosp12/system/memory/libmemunreachable/tests/ |
| H A 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()
|
| /aosp12/hardware/qcom/display/msm8909/sdm/libs/core/ |
| H A D | resource_default.cpp | 823 DisplayError ResourceDefault::SetDecimationFactor(HWPipeInfo *pipe) { in SetDecimationFactor() argument
824 float src_h = pipe->src_roi.bottom - pipe->src_roi.top; in SetDecimationFactor()
825 float dst_h = pipe->dst_roi.bottom - pipe->dst_roi.top; in SetDecimationFactor()
828 float src_w = pipe->src_roi.right - pipe->src_roi.left; in SetDecimationFactor()
829 float dst_w = pipe->dst_roi.right - pipe->dst_roi.left; in SetDecimationFactor()
832 pipe->horizontal_decimation = 0; in SetDecimationFactor()
833 pipe->vertical_decimation = 0; in SetDecimationFactor()
835 if (CalculateDecimation(down_scale_w, &pipe->horizontal_decimation) != kErrorNone) { in SetDecimationFactor()
839 if (CalculateDecimation(down_scale_h, &pipe->vertical_decimation) != kErrorNone) { in SetDecimationFactor()
844 pipe->horizontal_decimation, pipe->vertical_decimation); in SetDecimationFactor()
|
| /aosp12/hardware/qcom/display/msm8909w_3100/sdm/libs/core/ |
| H A D | resource_default.cpp | 823 DisplayError ResourceDefault::SetDecimationFactor(HWPipeInfo *pipe) { in SetDecimationFactor() argument
824 float src_h = pipe->src_roi.bottom - pipe->src_roi.top; in SetDecimationFactor()
825 float dst_h = pipe->dst_roi.bottom - pipe->dst_roi.top; in SetDecimationFactor()
828 float src_w = pipe->src_roi.right - pipe->src_roi.left; in SetDecimationFactor()
829 float dst_w = pipe->dst_roi.right - pipe->dst_roi.left; in SetDecimationFactor()
832 pipe->horizontal_decimation = 0; in SetDecimationFactor()
833 pipe->vertical_decimation = 0; in SetDecimationFactor()
835 if (CalculateDecimation(down_scale_w, &pipe->horizontal_decimation) != kErrorNone) { in SetDecimationFactor()
839 if (CalculateDecimation(down_scale_h, &pipe->vertical_decimation) != kErrorNone) { in SetDecimationFactor()
844 pipe->horizontal_decimation, pipe->vertical_decimation); in SetDecimationFactor()
|