| /ohos5.0/foundation/graphic/graphic_surface/surface/test/systemtest/ |
| H A D | native_window_test.cpp | 144 pipe(pipeFd);
171 close(pipeFd[0]);
172 close(pipeFd[1]);
263 pipe(pipeFd);
291 close(pipeFd[0]);
366 pipe(pipeFd);
519 pipe(pipeFd);
658 pipe(pipeFd);
748 pipe(pipeFd);
866 pipe(pipeFd);
[all …]
|
| H A D | surface_ipc_test.cpp | 40 static inline int32_t pipeFd[2] = {};
129 pipe(pipeFd); in ChildProcessMain()
136 read(pipeFd[0], &data, sizeof(data)); in ChildProcessMain()
157 write(pipeFd[1], &data, sizeof(data)); in ChildProcessMain()
159 read(pipeFd[0], &data, sizeof(data)); in ChildProcessMain()
170 close(pipeFd[0]); in ChildProcessMain()
171 close(pipeFd[1]); in ChildProcessMain()
216 write(pipeFd[1], &data, sizeof(data));
218 read(pipeFd[0], &data, sizeof(data));
243 close(pipeFd[0]);
[all …]
|
| H A D | native_window_buffer_test.cpp | 42 static inline int32_t pipeFd[2] = {};
159 pipe(pipeFd); in ChildProcessMain()
166 read(pipeFd[0], &data, sizeof(data)); in ChildProcessMain()
186 write(pipeFd[1], &data, sizeof(data)); in ChildProcessMain()
188 read(pipeFd[0], &data, sizeof(data)); in ChildProcessMain()
189 close(pipeFd[0]); in ChildProcessMain()
190 close(pipeFd[1]); in ChildProcessMain()
235 write(pipeFd[1], &data, sizeof(data));
237 read(pipeFd[0], &data, sizeof(data));
253 close(pipeFd[0]);
[all …]
|
| /ohos5.0/base/hiviewdfx/faultloggerd/tools/process_dump/ |
| H A D | cppcrash_reporter.cpp | 107 info.pipeFd = WriteCppCrashInfoByPipe(); in ReportToHiview()
126 int pipeFd[2] = {-1, -1}; in WriteCppCrashInfoByPipe() local
127 if (pipe(pipeFd) != 0) { in WriteCppCrashInfoByPipe()
131 if (fcntl(pipeFd[PIPE_READ], F_SETPIPE_SZ, sz) < 0 || in WriteCppCrashInfoByPipe()
132 fcntl(pipeFd[PIPE_WRITE], F_SETPIPE_SZ, sz) < 0) { in WriteCppCrashInfoByPipe()
136 if (fcntl(pipeFd[PIPE_READ], F_GETFL) < 0) { in WriteCppCrashInfoByPipe()
140 uint32_t flags = static_cast<uint32_t>(fcntl(pipeFd[PIPE_READ], F_GETFL)); in WriteCppCrashInfoByPipe()
142 if (fcntl(pipeFd[PIPE_READ], F_SETFL, flags) < 0) { in WriteCppCrashInfoByPipe()
149 close(pipeFd[PIPE_WRITE]); in WriteCppCrashInfoByPipe()
152 close(pipeFd[PIPE_READ]); in WriteCppCrashInfoByPipe()
[all …]
|
| H A D | faultlogger_client_msg.h | 31 int32_t pipeFd{-1};
|
| /ohos5.0/foundation/communication/dsoftbus/components/nstackx/nstackx_util/platform/liteos/ |
| H A D | sys_event.c | 33 CloseDesc(node->pipeFd[PIPE_OUT]); in CloseNodePipe()
34 CloseDesc(node->pipeFd[PIPE_IN]); in CloseNodePipe()
45 ret = (int32_t)recvfrom(node->pipeFd[PIPE_OUT], &event, sizeof(event), 0, NULL, NULL); in EventProcessHandle()
47 ret = (int32_t)read(node->pipeFd[PIPE_OUT], &event, sizeof(event)); in EventProcessHandle()
78 ret = (int32_t)sendto(node->pipeFd[PIPE_IN], &event, sizeof(event), 0, NULL, 0); in PostEvent()
80 ret = (int32_t)write(node->pipeFd[PIPE_IN], &event, sizeof(event)); in PostEvent()
108 ret = (int32_t)recvfrom(node->pipeFd[PIPE_OUT], &event, sizeof(event), 0, NULL, NULL); in ClearEvent()
110 ret = (int32_t)read(node->pipeFd[PIPE_OUT], &event, sizeof(event)); in ClearEvent()
131 node->pipeFd[PIPE_OUT] = fds.recvFd; in CreateNonBlockPipe()
132 node->pipeFd[PIPE_IN] = fds.sendFd; in CreateNonBlockPipe()
[all …]
|
| /ohos5.0/foundation/graphic/graphic_2d/rosen/modules/composer/vsync/test/systemtest/ |
| H A D | vsync_ltpo_test.cpp | 78 static inline int pipeFd[2] = {};
157 close(pipeFd[1]); in Process1()
177 read(pipeFd[0], &timeStamps, sizeof(timeStamps)); in Process1()
224 read(pipeFd[0], &timeStamps, sizeof(timeStamps)); in Process1()
271 read(pipeFd[0], &timeStamps, sizeof(timeStamps)); in Process1()
318 read(pipeFd[0], &timeStamps, sizeof(timeStamps)); in Process1()
350 read(pipeFd[0], buf, sizeof(buf)); in Process1()
353 close(pipeFd[0]); in Process1()
360 close(pipeFd[0]); in Process2()
397 write(pipeFd[1], &g_timeStamps, sizeof(g_timeStamps)); in Process2()
[all …]
|
| H A D | vsync_test.cpp | 57 static inline int pipeFd[2] = {};
104 close(pipeFd[1]); in Process1()
108 read(pipeFd[0], buf, sizeof(buf)); in Process1()
110 close(pipeFd[0]); in Process1()
117 close(pipeFd[0]); in Process2()
150 if (pipe(pipeFd) < 0) {
|
| /ohos5.0/foundation/filemanagement/app_file_service/utils/src/b_process/ |
| H A D | b_process.cpp | 86 int pipeFd[2]; in ExecuteCmd() local
87 if (pipe(pipeFd) < 0) { in ExecuteCmd()
95 close(pipeFd[0]); in ExecuteCmd()
96 UniqueFd fd(pipeFd[1]); in ExecuteCmd()
97 if (dup2(pipeFd[1], STDERR_FILENO) == -1) { in ExecuteCmd()
103 UniqueFd fd(pipeFd[0]); in ExecuteCmd()
104 close(pipeFd[1]); in ExecuteCmd()
108 unique_ptr<FILE, function<void(FILE *)>> pipeStream {fdopen(pipeFd[0], "r"), fclose}; in ExecuteCmd()
|
| /ohos5.0/base/hiviewdfx/faultloggerd/test/moduletest/ |
| H A D | faultloggerd_module_test.cpp | 155 int32_t pipeFd = RequestPipeFd(getpid(), FaultLoggerPipeType::PIPE_FD_READ_BUF); variable
156 ASSERT_NE(pipeFd, -1);
159 pipeFd = RequestPipeFd(getpid(), FaultLoggerPipeType::PIPE_FD_READ_BUF);
160 ASSERT_EQ(pipeFd, -1);
171 int32_t pipeFd = RequestPipeFd(getpid(), -1); variable
172 ASSERT_EQ(pipeFd, -1);
173 pipeFd = RequestPipeFd(getpid(), FaultLoggerPipeType::PIPE_FD_DELETE);
174 ASSERT_EQ(pipeFd, -1);
|
| /ohos5.0/foundation/communication/dsoftbus/components/nstackx/nstackx_util/platform/unix/ |
| H A D | sys_event.c | 33 CloseDesc(node->pipeFd[PIPE_OUT]); in CloseNodePipe()
34 CloseDesc(node->pipeFd[PIPE_IN]); in CloseNodePipe()
44 ret = (int32_t)read(node->pipeFd[PIPE_OUT], &event, sizeof(event)); in EventProcessHandle()
74 ret = (int32_t)write(node->pipeFd[PIPE_IN], &event, sizeof(event)); in PostEvent()
99 ret = (int32_t)read(node->pipeFd[PIPE_OUT], &event, sizeof(event)); in ClearEvent()
115 if (pipe(node->pipeFd) < 0) { in CreateNonBlockPipe()
121 flags = fcntl(node->pipeFd[i], F_GETFL, 0); in CreateNonBlockPipe()
129 ret = fcntl(node->pipeFd[i], F_SETFL, flags); in CreateNonBlockPipe()
164 node->task.taskfd = node->pipeFd[PIPE_OUT]; in EventModuleInit()
|
| /ohos5.0/base/update/updater/services/updater_binary/ |
| H A D | main.cpp | 36 int pipeFd; in main() local
40 pipeFd = static_cast<int>(std::strtol(argv[1], nullptr, DECIMAL)); in main()
46 pipeFd = static_cast<int>(std::strtol(argv[1], nullptr, DECIMAL)); in main()
49 pipeFd = static_cast<int>(std::strtol(argv[2], nullptr, DECIMAL)); // 2: pipe index in main()
55 return ProcessUpdater(retry, pipeFd, packagePath, Utils::GetCertName()); in main()
|
| /ohos5.0/base/security/selinux_adapter/interfaces/policycoreutils/src/ |
| H A D | load_policy.cpp | 261 int pipeFd[PIPE_NUM]; in CompilePolicyWithFork() local
262 if (pipe(pipeFd) < 0) { in CompilePolicyWithFork()
269 (void)close(pipeFd[0]); in CompilePolicyWithFork()
270 (void)close(pipeFd[1]); in CompilePolicyWithFork()
274 (void)close(pipeFd[0]); in CompilePolicyWithFork()
275 if (dup2(pipeFd[1], STDERR_FILENO) == -1) { in CompilePolicyWithFork()
277 (void)close(pipeFd[1]); in CompilePolicyWithFork()
280 (void)close(pipeFd[1]); in CompilePolicyWithFork()
287 (void)close(pipeFd[1]); in CompilePolicyWithFork()
289 FILE *fp = fdopen(pipeFd[0], "r"); in CompilePolicyWithFork()
[all …]
|
| /ohos5.0/foundation/communication/wifi/wifi/test/wifi_standard/wifi_hal/unittest/ |
| H A D | mock_wpa_ctrl.cpp | 149 int pipeFd[OncePipeFdNum] = {0}; in wpa_ctrl_open() local
150 pipe(pipeFd); in wpa_ctrl_open()
151 SetNonBlock(pipeFd[0]); in wpa_ctrl_open()
152 gPipeFd.push_back(pipeFd[0]); in wpa_ctrl_open()
153 gPipeFd.push_back(pipeFd[1]); in wpa_ctrl_open()
|
| /ohos5.0/base/hiviewdfx/hiview/plugins/faultlogger/service/idl/src/ |
| H A D | faultlogger_service_proxy.cpp | 47 if (info.pipeFd != -1) { in AddFaultLog()
48 if (!data.WriteFileDescriptor(info.pipeFd)) { in AddFaultLog()
51 close(info.pipeFd); in AddFaultLog()
|
| /ohos5.0/foundation/communication/netmanager_base/utils/common_utils/src/ |
| H A D | netmanager_base_common_utils.cpp | 497 if (close(pipeFd[PIPE_OUT]) != 0) { in ForkExecChildProcess()
501 if (dup2(pipeFd[PIPE_IN], STDOUT_FILENO) == -1) { in ForkExecChildProcess()
508 if (close(pipeFd[PIPE_IN]) != 0) { in ForkExecChildProcess()
522 int32_t ForkExecParentProcess(const int32_t *pipeFd, int32_t count, pid_t childPid, std::string *ou… in ForkExecParentProcess() argument
528 if (close(pipeFd[PIPE_IN]) != 0) { in ForkExecParentProcess()
534 while (read(pipeFd[PIPE_OUT], buf, CHAR_ARRAY_SIZE_MAX - 1) > 0) { in ForkExecParentProcess()
542 if (close(pipeFd[PIPE_OUT]) != 0) { in ForkExecParentProcess()
578 int32_t pipeFd[PIPE_FD_NUM] = {0}; in ForkExec() local
579 if (pipe(pipeFd) < 0) { in ForkExec()
589 ForkExecChildProcess(pipeFd, PIPE_FD_NUM, args); in ForkExec()
[all …]
|
| /ohos5.0/base/update/updater/test/unittest/updater_test/ |
| H A D | test_update_binary_abnormal.cpp | 42 int pipeFd = static_cast<int>(std::strtol(argv[1], nullptr, decimal)); in main() local
46 FILE *pipeWrite = fdopen(pipeFd, "w"); in main()
|
| H A D | test_update_binary.cpp | 42 int pipeFd = static_cast<int>(std::strtol(argv[1], nullptr, decimal)); in main() local
46 FILE *pipeWrite = fdopen(pipeFd, "w"); in main()
|
| /ohos5.0/foundation/graphic/graphic_surface/surface/test/unittest/ |
| H A D | buffer_client_producer_remote_test.cpp | 63 static inline int pipeFd[2] = {};
95 if (pipe(pipeFd) < 0) { in SetUpTestCase()
115 close(pipeFd[1]); in SetUpTestCase()
120 read(pipeFd[0], buf, sizeof(buf)); in SetUpTestCase()
122 close(pipeFd[0]); in SetUpTestCase()
126 close(pipeFd[0]); in SetUpTestCase()
142 write(pipeFd[1], buf, sizeof(buf)); in TearDownTestCase()
143 close(pipeFd[1]); in TearDownTestCase()
|
| /ohos5.0/base/hiviewdfx/hiview/plugins/faultlogger/interfaces/cpp/innerkits/impl/ |
| H A D | faultlogger_client.cpp | 94 infoOhos.pipeFd = info.pipeFd; in AddFaultLog()
|
| /ohos5.0/base/hiviewdfx/hiview/plugins/faultlogger/service/idl/ |
| H A D | faultlogger_service_ohos.cpp | 127 outInfo.pipeFd.reset(new int32_t(info.pipeFd), fdDeleter); in AddFaultLog()
|
| /ohos5.0/base/hiviewdfx/hiview/plugins/faultlogger/interfaces/cpp/innerkits/include/ |
| H A D | faultlogger_client_msg.h | 31 int32_t pipeFd{-1};
|
| /ohos5.0/base/hiviewdfx/hiview/plugins/faultlogger/service/idl/include/ |
| H A D | faultlog_info_ohos.h | 31 int32_t pipeFd {-1};
|
| /ohos5.0/foundation/communication/dsoftbus/components/nstackx/nstackx_util/interface/ |
| H A D | nstackx_event.h | 32 PipeDesc pipeFd[PIPE_FD_NUM]; member
|
| /ohos5.0/base/hiviewdfx/hiview/plugins/faultlogger/common/ |
| H A D | faultlog_info.h | 28 std::shared_ptr<int32_t> pipeFd; member
|