| /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/extras/alloc-stress/ |
| D | alloc-stress.cpp | 36 class Pipe { class
39 Pipe(const Pipe&) = delete;
40 Pipe& operator=(const Pipe&) = delete;
41 Pipe& operator=(const Pipe&&) = delete;
44 Pipe(int readFd, int writeFd) : m_readFd{readFd}, m_writeFd{writeFd} { in Pipe() function in Pipe
48 Pipe(Pipe&& rval) noexcept { in Pipe() function in Pipe
54 ~Pipe() { in ~Pipe()
94 static Pipe makePipeFromFds(int readFd, int writeFd) { return Pipe(readFd, writeFd); } in makePipeFromFds()
95 static tuple<Pipe, Pipe> createPipePair() { in createPipePair()
104 return make_tuple(Pipe(a[0], b[1]), Pipe(b[0], a[1])); in createPipePair()
[all …]
|
| /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 __anonf7ee24f90102()
44 [](FuzzedDataProvider* dataProvider, sp<Looper> looper, Pipe) -> void { in __anonf7ee24f90202()
48 [](FuzzedDataProvider* dataProvider, sp<Looper> looper, Pipe pipeObj) -> void { in __anonf7ee24f90302()
53 [](FuzzedDataProvider* dataProvider, sp<Looper> looper, Pipe pipeObj) -> void { in __anonf7ee24f90402()
58 [](FuzzedDataProvider* dataProvider, sp<Looper> looper, Pipe pipeObj) -> void { in __anonf7ee24f90502()
63 [](FuzzedDataProvider* dataProvider, sp<Looper> looper, Pipe pipeObj) -> void { in __anonf7ee24f90602()
68 [](FuzzedDataProvider*, sp<Looper> looper, Pipe) -> void { looper->wake(); }, in __anonf7ee24f90702()
69 [](FuzzedDataProvider*, sp<Looper>, Pipe pipeObj) -> void { pipeObj.writeSignal(); }}; in __anonf7ee24f90802()
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 | 61 Pipe* mPipe;
64 DelayedWriteSignal(int delayMillis, Pipe* pipe) : in DelayedWriteSignal()
185 Pipe pipe; in TEST_F()
203 Pipe pipe; in TEST_F()
226 Pipe pipe; in TEST_F()
244 Pipe pipe; in TEST_F()
269 Pipe pipe; in TEST_F()
295 Pipe pipe; in TEST_F()
317 Pipe pipe; in TEST_F()
359 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 __anon1c89d7c00111::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 | 74 ASSERT_TRUE(Pipe(&pipe_read, &pipe_write)); in TEST()
109 ASSERT_TRUE(Pipe(&pipe_read, &pipe_write)); in TEST()
123 ASSERT_TRUE(Pipe(&output_read, &output_write)); in TEST()
|
| D | debuggerd_client.cpp | 181 if (!Pipe(&pipe_read, &pipe_write)) { in debuggerd_trigger_dump()
|
| /system/core/debuggerd/ |
| D | debuggerd.cpp | 101 if (!Pipe(&piperead, &pipewrite)) { in main()
|
| D | crash_dump.cpp | 421 if (!Pipe(&fork_exit_read, &fork_exit_write)) { in main()
|
| D | debuggerd_test.cpp | 128 if (!Pipe(output_fd, &output_pipe_write)) { in tombstoned_intercept()
242 if (!Pipe(&crasher_read_pipe, &crasher_pipe)) { in StartProcess()
|
| /system/core/debuggerd/handler/ |
| D | debuggerd_handler.cpp | 64 using android::base::Pipe;
339 if (!Pipe(&input_read, &input_write) != 0 || !Pipe(&output_read, &output_write)) { in debuggerd_dispatch_pseudothread()
|
| D | debuggerd_fallback.cpp | 259 if (!Pipe(&pipe_read, &pipe_write)) { in trace_handler()
|
| /system/libbase/include/android-base/ |
| D | unique_fd.h | 184 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/ |
| D | Isolate.cpp | 197 static bool Pipe(int* read_fd, int* write_fd) { in Pipe() function
223 if (!Pipe(&read_fd, &write_fd)) { in LaunchTests()
|
| /system/iorap/src/inode2filename/ |
| D | out_of_process_inode_resolver.cc | 262 if (!::android::base::Pipe(/*out*/&pipe_reader, /*out*/&pipe_writer)) { in EmitFromCommandWithArgv()
|
| /system/extras/simpleperf/scripts/test/ |
| D | do_test.py | 222 self.parent_conn, child_conn = mp.Pipe(duplex=False)
|
| /system/extras/simpleperf/ |
| D | environment.cpp | 599 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()
|
| /system/netd/tests/ |
| D | binder_test.cpp | 3830 bool success = Pipe(&localFd, &remoteFd); in dumpService()
|