| /system/extras/alloc-stress/ |
| D | alloc-stress.cpp | 38 class Pipe { class
41 Pipe(const Pipe&) = delete;
42 Pipe& operator=(const Pipe&) = delete;
43 Pipe& operator=(const Pipe&&) = delete;
46 Pipe(int readFd, int writeFd) : m_readFd{readFd}, m_writeFd{writeFd} { in Pipe() function in Pipe
50 Pipe(Pipe&& rval) noexcept { in Pipe() function in Pipe
56 ~Pipe() { in ~Pipe()
96 static Pipe makePipeFromFds(int readFd, int writeFd) { return Pipe(readFd, writeFd); } in makePipeFromFds()
97 static tuple<Pipe, Pipe> createPipePair() { in createPipePair()
106 return make_tuple(Pipe(a[0], b[1]), Pipe(b[0], a[1])); in createPipePair()
[all …]
|
| /system/libhwbinder/vts/performance/ |
| D | PerfTest.h | 34 class Pipe {
36 static tuple<Pipe, Pipe> createPipePair();
37 Pipe(Pipe&& rval) noexcept;
38 ~Pipe();
62 Pipe(int read_fd, int write_fd) : fd_read_{read_fd}, fd_write_{write_fd} {} in Pipe() function
63 Pipe(const Pipe&) = delete;
64 Pipe& operator=(const Pipe&) = delete;
65 Pipe& operator=(const Pipe&&) = delete;
|
| D | Benchmark_throughput.cpp | 48 class Pipe { class
51 Pipe(int readFd, int writeFd) in Pipe() function in Pipe
54 Pipe(const Pipe &) = delete;
55 Pipe& operator=(const Pipe &) = delete;
56 Pipe& operator=(const Pipe &&) = delete;
58 Pipe(Pipe&& rval) noexcept { in Pipe() function in Pipe
64 ~Pipe() { in ~Pipe()
88 static tuple<Pipe, Pipe> createPipePair() { in createPipePair()
97 return make_tuple(Pipe(a[0], b[1]), Pipe(b[0], a[1])); in createPipePair()
179 void service_fx(const string &serviceName, Pipe p) { in service_fx()
[all …]
|
| D | PerfTest.cpp | 54 tuple<Pipe, Pipe> Pipe::createPipePair() { in createPipePair()
63 return make_tuple(Pipe(a[0], b[1]), Pipe(b[0], a[1])); in createPipePair()
66 Pipe::Pipe(Pipe&& rval) noexcept { in Pipe() function in Pipe
73 Pipe::~Pipe() { in ~Pipe()
|
| D | Latency.cpp | 147 static void serviceFx(const string& serviceName, Pipe p) { in serviceFx()
160 static Pipe makeServiceProces(string service_name) { in makeServiceProces()
161 auto pipe_pair = Pipe::createPipePair(); in makeServiceProces()
176 static void clientFx(int num, int server_count, int iterations, Pipe p) { in clientFx()
239 static Pipe makeClientProcess(int num, int iterations, int no_pair) { in makeClientProcess()
240 auto pipe_pair = Pipe::createPipePair(); in makeClientProcess()
255 static void waitAll(vector<Pipe>& v) { in waitAll()
261 static void signalAll(vector<Pipe>& v) { in signalAll()
287 vector<Pipe> client_pipes; in main()
288 vector<Pipe> service_pipes; in main()
|
| /system/core/libutils/ |
| D | Looper_fuzz.cpp | 40 std::vector<std::function<void(FuzzedDataProvider*, sp<Looper>, Pipe)>> operations = {
41 [](FuzzedDataProvider* dataProvider, sp<Looper> looper, Pipe) -> void { in __anon1c5cf7260102()
44 [](FuzzedDataProvider* dataProvider, sp<Looper> looper, Pipe) -> void { in __anon1c5cf7260202()
48 [](FuzzedDataProvider* dataProvider, sp<Looper> looper, Pipe pipeObj) -> void { in __anon1c5cf7260302()
53 [](FuzzedDataProvider* dataProvider, sp<Looper> looper, Pipe pipeObj) -> void { in __anon1c5cf7260402()
58 [](FuzzedDataProvider* dataProvider, sp<Looper> looper, Pipe pipeObj) -> void { in __anon1c5cf7260502()
63 [](FuzzedDataProvider* dataProvider, sp<Looper> looper, Pipe pipeObj) -> void { in __anon1c5cf7260602()
68 [](FuzzedDataProvider*, sp<Looper> looper, Pipe) -> void { looper->wake(); }, in __anon1c5cf7260702()
69 [](FuzzedDataProvider*, sp<Looper>, Pipe pipeObj) -> void { pipeObj.writeSignal(); }}; in __anon1c5cf7260802()
72 Pipe pipeObj; in LLVMFuzzerTestOneInput()
|
| D | Looper_test_pipe.h | 22 class Pipe {
27 Pipe() { in Pipe() function
35 ~Pipe() { in ~Pipe()
|
| D | Looper_test.cpp | 64 Pipe* mPipe;
67 DelayedWriteSignal(int delayMillis, Pipe* pipe) : in DelayedWriteSignal()
188 Pipe pipe; in TEST_F()
206 Pipe pipe; in TEST_F()
229 Pipe pipe; in TEST_F()
247 Pipe pipe; in TEST_F()
272 Pipe pipe; in TEST_F()
298 Pipe pipe; in TEST_F()
320 Pipe pipe; in TEST_F()
362 Pipe pipe; in TEST_F()
[all …]
|
| /system/connectivity/wificond/tests/ |
| D | looper_backed_event_loop_unittest.cpp | 34 class Pipe { class
39 Pipe() { in Pipe() function in __anon966f6c6d0111::Pipe
108 Pipe pipe; in TEST_F()
125 Pipe pipe; in TEST_F()
141 Pipe pipe; in TEST_F()
|
| /system/core/debuggerd/client/ |
| D | debuggerd_client_test.cpp | 87 ASSERT_TRUE(Pipe(&pipe_read, &pipe_write)); in TEST()
119 ASSERT_TRUE(Pipe(&pipe_read, &pipe_write)); in TEST()
133 ASSERT_TRUE(Pipe(&output_read, &output_write)); in TEST()
|
| D | debuggerd_client.cpp | 179 if (!Pipe(&pipe_read, &pipe_write)) { in debuggerd_trigger_dump()
|
| /system/core/debuggerd/handler/ |
| D | debuggerd_handler.cpp | 57 using ::android::base::Pipe;
358 if (!Pipe(&input_read, &input_write) != 0 || !Pipe(&output_read, &output_write)) { in debuggerd_dispatch_pseudothread()
|
| D | debuggerd_fallback.cpp | 220 if (!Pipe(&pipe_read, &pipe_write)) { in trace_handler()
|
| /system/media/audio_utils/include/audio_utils/ |
| D | FdToString.h | 191 if (!android::base::Pipe(&readFd, &writeFd)) return {};
|
| /system/libbase/include/android-base/ |
| D | unique_fd.h | 194 inline bool Pipe(unique_fd_impl<Closer>* read, unique_fd_impl<Closer>* write,
|
| /system/netd/server/ |
| D | TetherController.cpp | 64 using android::base::Pipe;
220 if (!Pipe(&pipeRead, &pipeWrite, O_CLOEXEC)) { in startTethering()
|
| /system/testing/gtest_extras/gtest_isolated/ |
| D | Isolate.cpp | 200 static bool Pipe(int* read_fd, int* write_fd) { in Pipe() function
226 if (!Pipe(&read_fd, &write_fd)) { in LaunchTests()
|
| /system/extras/simpleperf/scripts/test/ |
| D | do_test.py | 247 self.parent_conn, child_conn = mp.Pipe(duplex=False)
|
| /system/core/debuggerd/ |
| D | crash_dump.cpp | 565 if (!Pipe(&fork_exit_read, &fork_exit_write)) { in main()
|
| D | debuggerd_test.cpp | 132 if (!Pipe(output_fd, &output_pipe_write)) { in tombstoned_intercept()
252 if (!Pipe(&crasher_read_pipe, &crasher_pipe)) { in StartProcess()
|
| /system/extras/simpleperf/ |
| D | environment.cpp | 622 if (!android::base::Pipe(&stop_signal_rfd, &stop_signal_wfd, 0)) { in RunCmdInApp()
|
| /system/vold/ |
| D | Utils.cpp | 709 if (!android::base::Pipe(&pipe_read, &pipe_write)) { in ForkExecvp()
|