| /foundation/communication/dsoftbus/components/nstackx/nstackx_core/platform/liteos/dfile/ |
| H A D | sys_dfile_session.c | 49 PipeDesc pipe = session->receiverPipe[PIPE_OUT]; in WaitSocketEvent() local
50 if (pipe >= FD_SETSIZE) { in WaitSocketEvent()
51 LOGE(TAG, "pipe fd %d is too big", pipe); in WaitSocketEvent()
54 if (nfds < pipe + 1) { in WaitSocketEvent()
55 nfds = pipe + 1; in WaitSocketEvent()
57 FD_SET(pipe, &readFds); in WaitSocketEvent()
|
| /foundation/communication/dsoftbus/components/nstackx/nstackx_core/platform/unix/dfile/ |
| H A D | sys_dfile_session.c | 49 PipeDesc pipe = session->receiverPipe[PIPE_OUT]; in WaitSocketEvent() local
50 if (pipe >= FD_SETSIZE) { in WaitSocketEvent()
51 LOGE(TAG, "pipe fd %d is too big", pipe); in WaitSocketEvent()
54 if (nfds < pipe + 1) { in WaitSocketEvent()
55 nfds = pipe + 1; in WaitSocketEvent()
57 FD_SET(pipe, &readFds); in WaitSocketEvent()
|
| H A D | sys_dfile.c | 31 if (pipe(session->receiverPipe) < 0) { in CreateReceiverPipe()
32 LOGE(TAG, "create pipe error: %d", errno); in CreateReceiverPipe()
38 LOGE(TAG, "pipe fd %d is too big for monitoring by select", session->receiverPipe[PIPE_OUT]); in CreateReceiverPipe()
68 LOGE(TAG, "write to receiver pipe failed. errno %d", errno); in NotifyPipeEvent()
|
| /foundation/arkui/ace_engine/frameworks/core/components/picker/ |
| H A D | picker_animation.h | 33 PickerAnimation(const WeakPtr<PipelineBase>& pipe, double start, double end, int delay, int duration, in PickerAnimation() argument
35 : start_(start), end_(end), delay_(delay), duration_(duration), pipe_(pipe), curve_(curve), callback_(callback) in PickerAnimation()
|
| /foundation/arkui/ace_engine/test/unittest/core/base/ |
| H A D | view_stack_processor_test_ng.cpp | 215 auto pipe = MockPipelineContext::GetCurrent(); in HWTEST_F() local
219 root->context_ = AceType::RawPtr(pipe); in HWTEST_F()
220 child->context_ = AceType::RawPtr(pipe); in HWTEST_F()
221 child2->context_ = AceType::RawPtr(pipe); in HWTEST_F()
233 FRAME_NODE_ROOT->context_ = AceType::RawPtr(pipe); in HWTEST_F()
|
| /foundation/communication/netmanager_base/services/netmanagernative/src/netsys/wrapper/ |
| H A D | wrapper_listener.cpp | 58 NETNATIVE_LOGE("pipeRes = %{public}d, pipe create failed errno = %{public}d, %{public}s", pipeRet, errno, in Start()
69 char pipe = PIPE_SHUTDOWN; in Stop() local
70 if (TEMP_FAILURE_RETRY(write(pipe_[1], &pipe, sizeof(pipe))) != 1) { in Stop()
71 NETNATIVE_LOGE("write pipe failed errno = %{public}d, %{public}s", errno, strerror(errno)); in Stop()
|
| /foundation/arkui/ace_engine/test/component_test/tools/previewer_host/main/ |
| H A D | gitee_rest_api.js | 66 response.pipe(fileStream);
85 readStream.pipe(unzipper.Parse())
92 entry.pipe(fs.createWriteStream(outputPath));
115 .pipe(unzipper.Extract({ path: outputDirectory }))
|
| /foundation/graphic/graphic_2d/rosen/modules/composer/vsync/test/systemtest/ |
| H A D | vsync_callbackeveryframe_test.cpp | 156 if (pipe(pipeFd) < 0) { in HWTEST_F()
159 if (pipe(pipe1Fd) < 0) { in HWTEST_F()
|
| H A D | vsync_test.cpp | 150 if (pipe(pipeFd) < 0) { in HWTEST_F()
153 if (pipe(pipe1Fd) < 0) { in HWTEST_F()
|
| H A D | vsync_multicallback_test.cpp | 168 if (pipe(pipeFd) < 0) { in HWTEST_F()
171 if (pipe(pipe1Fd) < 0) { in HWTEST_F()
|
| H A D | vsync_setvsyncrate_test.cpp | 158 if (pipe(pipeFd) < 0) { in HWTEST_F()
161 if (pipe(pipe1Fd) < 0) { in HWTEST_F()
|
| H A D | vsync_120to30_test.cpp | 368 if (pipe(pipeFd) < 0) { in HWTEST_F()
371 if (pipe(pipe1Fd) < 0) { in HWTEST_F()
|
| H A D | vsync_ltpo_test.cpp | 452 if (pipe(pipeFd) < 0) { in HWTEST_F()
455 if (pipe(pipe1Fd) < 0) { in HWTEST_F()
|
| H A D | vsync_90to30_test.cpp | 368 if (pipe(pipeFd) < 0) { in HWTEST_F()
371 if (pipe(pipe1Fd) < 0) { in HWTEST_F()
|
| /foundation/communication/ipc/ipc/test/serializer/ |
| H A D | utils_serializer_test.cpp | 133 if (pipe(fd) < 0) { in HWTEST_F()
134 perror("pipe error!\n"); in HWTEST_F()
230 if (pipe(fd) < 0) { in HWTEST_F()
231 perror("pipe error!\n"); in HWTEST_F()
271 if (pipe(fd) < 0) { in HWTEST_F()
323 if (pipe(fd) < 0) { in HWTEST_F()
377 if (pipe(fd) < 0) { in HWTEST_F()
424 if (pipe(fd) < 0) { in HWTEST_F()
474 if (pipe(fd) < 0) { in HWTEST_F()
524 if (pipe(f in HWTEST_F()
[all...] |
| /foundation/arkui/ace_engine/frameworks/core/components/option/ |
| H A D | render_option.cpp | 353 auto pipe = context_.Upgrade(); in UpdateOthersStatus() local
354 if (!data_ || !pipe) { in UpdateOthersStatus()
359 needLine_ = (!(data_->GetFocused() && pipe->IsKeyEvent()) && upOption && upOption->IsNormalStatus()) && in UpdateOthersStatus()
396 auto pipe = context_.Upgrade(); in IsNormalStatus() local
397 if (!data_ || !pipe) { in IsNormalStatus()
401 return (!data_->GetClicked() && !hovered_ && !data_->GetSelected() && !(data_->GetFocused() && pipe->IsKeyEvent())); in IsNormalStatus()
|
| /foundation/arkui/ace_engine/test/unittest/core/layout/ |
| H A D | box_layout_algorithm_test_ng.cpp | 146 * @tc.expected: expect the pipe is return true. in HWTEST_F()
149 auto pipe = PipelineContext::GetCurrentContext()->safeAreaManager_->isFullScreen_; in HWTEST_F() local
151 EXPECT_FALSE(pipe); in HWTEST_F()
196 * @tc.expected: expect the pipe and pipe1 is return false. in HWTEST_F()
200 auto pipe = PipelineContext::GetCurrentContext()->safeAreaManager_->isFullScreen_; in HWTEST_F() local
203 EXPECT_FALSE(pipe); in HWTEST_F()
315 * @tc.expected: expect the pipe and pipe1 is return false. in HWTEST_F()
320 auto pipe = PipelineContext::GetCurrentContext()->safeAreaManager_->isFullScreen_; in HWTEST_F() local
322 EXPECT_FALSE(pipe); in HWTEST_F()
|
| /foundation/graphic/graphic_surface/surface/test/systemtest/ |
| H A D | native_window_test.cpp | 144 pipe(pipeFd);
in HWTEST_F()
263 pipe(pipeFd);
in HWTEST_F()
366 pipe(pipeFd);
in HWTEST_F()
519 pipe(pipeFd);
in HWTEST_F()
658 pipe(pipeFd);
in HWTEST_F()
748 pipe(pipeFd);
in HWTEST_F()
866 pipe(pipeFd);
in HWTEST_F()
1027 pipe(pipeFd);
in HWTEST_F()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/ |
| H A D | kvstore_meta_manager.cpp | 104 auto pipe = Bootstrap::GetInstance().GetProcessLabel() + "-" + "default"; in InitBroadcast() local
105 auto result = Commu::GetInstance().ListenBroadcastMsg({ pipe }, in InitBroadcast()
115 EventCenter::GetInstance().Subscribe(DeviceMatrix::MATRIX_BROADCAST, [pipe](const Event &event) { in InitBroadcast()
123 Commu::GetInstance().Broadcast({ pipe }, std::move(level)); in InitBroadcast()
|
| /foundation/arkui/ace_engine/frameworks/core/components/select/ |
| H A D | select_element.cpp | 363 auto pipe = context_.Upgrade(); in OnFocus() local
364 if (!pipe) { in OnFocus()
378 pipe->ShowFocusAnimation(rrect, data->GetClickedColor(), offset, true); in OnFocus()
|
| /foundation/arkui/ace_engine/test/component_test/tools/middle_ground/util/ |
| H A D | index.js | 26 readStream.pipe(csvParser())
44 let workerProcess = spawn('node', [hostPath, pr, path], { encoding: 'utf-8', stdio: 'pipe' });
|
| /foundation/filemanagement/app_file_service/utils/src/b_process/ |
| H A D | b_process.cpp | 87 if (pipe(pipeFd) < 0) { in ExecuteCmd()
|
| /foundation/multimodalinput/input/service/delegate_task/src/ |
| H A D | delegate_tasks.cpp | 62 if (pipe(fds_) == -1) { in Init()
63 MMI_HILOGE("The pipe create failed, errno:%{public}d", errno); in Init()
|
| /foundation/communication/dsoftbus/components/nstackx/nstackx_util/platform/unix/ |
| H A D | sys_event.c | 46 LOGE(TAG, "failed to read from pipe: %d", GetErrno()); in EventProcessHandle()
76 LOGE(TAG, "failed to write to pipe: %d", errno); in PostEvent()
115 if (pipe(node->pipeFd) < 0) { in CreateNonBlockPipe()
116 LOGE(TAG, "create pipe error: %d", errno); in CreateNonBlockPipe()
|
| /foundation/filemanagement/storage_service/services/storage_daemon/netlink/src/ |
| H A D | netlink_listener.cpp | 103 LOGE("Read socket pipe failed"); in ReadMsg()
177 if (pipe(socketPipe_) == -1) { in StartListener()
|