| /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 | 35 class Pipe { class
38 Pipe(const Pipe &) = delete;
39 Pipe& operator=(const Pipe &) = delete;
40 Pipe& operator=(const Pipe &&) = delete;
42 Pipe(int readFd, int writeFd) : m_readFd{readFd}, m_writeFd{writeFd} { in Pipe() function in Pipe
46 Pipe(Pipe&& rval) noexcept { in Pipe() function in Pipe
52 ~Pipe() { in ~Pipe()
96 static Pipe makePipeFromFds(int readFd, int writeFd) { in makePipeFromFds()
97 return Pipe(readFd, writeFd); in makePipeFromFds()
99 static tuple<Pipe, Pipe> createPipePair() { in createPipePair()
[all …]
|
| /system/connectivity/wificond/tests/ |
| D | looper_backed_event_loop_unittest.cpp | 34 class Pipe { class
39 Pipe() { in Pipe() function in __anonbd9bf3d90111::Pipe
108 Pipe pipe; in TEST_F()
125 Pipe pipe; in TEST_F()
141 Pipe pipe; in TEST_F()
|
| /system/core/libutils/ |
| D | Looper_test.cpp | 27 class Pipe { class
32 Pipe() { in Pipe() function in android::Pipe
40 ~Pipe() { in ~Pipe()
95 Pipe* mPipe;
98 DelayedWriteSignal(int delayMillis, Pipe* pipe) : in DelayedWriteSignal()
219 Pipe pipe; in TEST_F()
237 Pipe pipe; in TEST_F()
260 Pipe pipe; in TEST_F()
278 Pipe pipe; in TEST_F()
303 Pipe pipe; in TEST_F()
[all …]
|
| /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/adb/fastdeploy/deploypatchgenerator/ |
| D | patch_utils.h | 55 static void Pipe(android::base::borrowed_fd input, android::base::borrowed_fd output,
|
| D | patch_utils.cpp | 95 void PatchUtils::Pipe(borrowed_fd input, borrowed_fd output, size_t amount) { in Pipe() function in PatchUtils
|
| D | deploy_patch_generator.cpp | 112 PatchUtils::Pipe(input, output, patchEntry.deltaFromDeviceDataStart); in WritePatchEntry()
172 PatchUtils::Pipe(input, output, newApkSize - currentSizeOut); in GeneratePatch()
|
| D | patch_utils_test.cpp | 77 PatchUtils::Pipe(input.fd, output.fd, expected.size()); in TEST()
|
| /system/core/debuggerd/ |
| D | debuggerd.cpp | 101 if (!Pipe(&piperead, &pipewrite)) { in main()
|
| D | crash_dump.cpp | 409 if (!Pipe(&fork_exit_read, &fork_exit_write)) { in main()
|
| D | debuggerd_test.cpp | 115 if (!Pipe(output_fd, &output_pipe_write)) { in tombstoned_intercept()
224 if (!Pipe(&crasher_read_pipe, &crasher_pipe)) { in StartProcess()
|
| /system/core/debuggerd/handler/ |
| D | debuggerd_handler.cpp | 65 using android::base::Pipe;
341 if (!Pipe(&input_read, &input_write) != 0 || !Pipe(&output_read, &output_write)) { in debuggerd_dispatch_pseudothread()
|
| D | debuggerd_fallback.cpp | 254 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/core/adb/daemon/ |
| D | services.cpp | 130 if (!Pipe(&pipe_read, &pipe_write)) { in spin_service()
|
| D | shell_service.cpp | 800 if (!Pipe(&read, &write)) { in ReportError()
|
| /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/netd/server/ |
| D | TetherController.cpp | 65 using android::base::Pipe;
247 if (!Pipe(&pipeRead, &pipeWrite, O_CLOEXEC)) { in startTethering()
|
| /system/extras/simpleperf/ |
| D | environment.cpp | 673 if (!android::base::Pipe(&stop_signal_rfd, &stop_signal_wfd, 0)) { in RunCmdInApp()
|
| /system/vold/ |
| D | Utils.cpp | 349 if (!android::base::Pipe(&pipe_read, &pipe_write)) { in ForkExecvp()
|