| /developtools/integration_verification/tools/deps_guard/elf_file_mgr/ |
| H A D | utils.py | 38 pipe = os.popen(command + ' ' + ' '.join(args), 'r')
39 output = pipe.read().strip()
40 status = pipe.close()
|
| /developtools/hdc/src/test/jdwp/ |
| H A D | HdcJdwpSimulator.cpp | 159 uv_pipe_t *pipe = reinterpret_cast<uv_pipe_t *>(q);
in ReceiveNewFd() local
160 if (!uv_pipe_pending_count(pipe)) {
in ReceiveNewFd()
164 uv_handle_type pending = uv_pipe_pending_type(pipe);
in ReceiveNewFd()
221 thisClass->SendToStream(reinterpret_cast<uv_stream_t *>(&ctxJdwp->pipe), info, pkgSize,
in ConnectJdwp()
237 thisClass->SendToStream(reinterpret_cast<uv_stream_t *>(&ctxJdwp->pipe),
in ConnectJdwp()
241 uv_read_start(reinterpret_cast<uv_stream_t *>(&ctxJdwp->pipe), thisClass->alloc_buffer,
in ConnectJdwp()
253 ctx->pipe.data = ctx;
in MallocContext()
264 if (loop && !uv_is_closing(reinterpret_cast<uv_handle_t *>(&ctxPoint->pipe))) {
in FreeContext()
265 uv_close(reinterpret_cast<uv_handle_t *>(&ctxPoint->pipe), nullptr);
in FreeContext()
286 uv_pipe_init(loop, static_cast<uv_pipe_t *>(&ctxPoint->pipe), in Connect()
[all...] |
| H A D | HdcJdwpSimulator.h | 31 uv_pipe_t pipe;
member
|
| /developtools/hdc/test/fuzztest/jdwpreadstream_fuzzer/ |
| H A D | JdwpReadStream_fuzzer.cpp | 46 uv_pipe_t pipe; in FuzzJdwpReadStream() local
47 pipe.data = ctx; in FuzzJdwpReadStream()
48 uv_stream_t *stream = (uv_stream_t *)&pipe; in FuzzJdwpReadStream()
|
| /developtools/profiler/device/plugins/ffrt_profiler/test/unittest/ |
| H A D | ffrt_profiler_test.cpp | 91 std::unique_ptr<FILE, decltype(&pclose)> pipe(popen(cmd.c_str(), "r"), pclose); in RunCommand()
92 CHECK_TRUE(pipe, false, "RunCommand: create popen FAILED!"); in RunCommand()
95 while (fgets(buffer.data(), buffer.size(), pipe.get()) != nullptr) { in RunCommand()
|
| /developtools/profiler/device/plugins/hiebpf_plugin/src/ |
| H A D | hiebpf_module.cpp | 43 std::unique_ptr<FILE, decltype(&pclose)> pipe(popen(cmd.c_str(), "r"), pclose); in RunCmd()
44 if (pipe == nullptr) { in RunCmd()
51 while (fgets(buffer.data(), buffer.size(), pipe.get()) != nullptr) { in RunCmd()
|
| /developtools/hdc/test/unittest/common/ |
| H A D | HdcJdwpTest.cpp | 71 * @tc.desc: Check ReadStream interface of pipe connection.
78 uv_pipe_t pipe;
in HWTEST_F() local
79 uv_stream_t *stream = (uv_stream_t *)&pipe;
in HWTEST_F()
81 ctxJdwp->finish = true; // For skip HdcJdwp::FreeContext, because the pipe
in HWTEST_F()
83 pipe.data = ctxJdwp;
in HWTEST_F()
|
| /developtools/hdc/src/common/ |
| H A D | forward.cpp | 110 uv_pipe_init(ctxClient->thisClass->loopTask, &ctxClient->pipe, 0); in ListenCallback()
111 client = (uv_stream_t *)&ctxClient->pipe; in ListenCallback()
127 ctx->pipe.data = ctx; in MallocContext()
205 Base::TryCloseHandle((uv_handle_t *)&ctx->pipe, true, funcHandleClose); in FreeContext()
425 bool HdcForwardBase::LocalAbstractConnect(uv_pipe_t *pipe, string &sNodeCfg) in LocalAbstractConnect() argument
450 if (uv_pipe_open(pipe, s)) { in LocalAbstractConnect()
465 ctxPoint->pipe.data = ctxPoint; in SetupFilePoint()
466 uv_pipe_init(loopTask, &ctxPoint->pipe, 0); in SetupFilePoint()
471 if (uv_pipe_bind(&ctxPoint->pipe, sNodeCfg.c_str())) { in SetupFilePoint()
472 ctxPoint->lastError = "Unix pipe bin in SetupFilePoint()
[all...] |
| H A D | forward.h | 49 uv_pipe_t pipe; member
102 bool LocalAbstractConnect(uv_pipe_t *pipe, string &sNodeCfg);
|
| H A D | async_cmd.cpp | 212 pipe(fds); in Popen()
213 WRITE_LOG(LOG_DEBUG, "Popen pipe fds[pipeRead]:%d fds[pipeWrite]:%d, mode %d", in Popen()
|
| /developtools/hdc/src/daemon/ |
| H A D | jdwp.cpp | 70 ctx->pipe.data = ctx; in MallocContext()
91 Base::TryCloseHandle((const uv_handle_t *)&ctxIn->pipe, [](uv_handle_t *handle) { in FreeContext()
115 void HdcJdwp::ReadStream(uv_stream_t *pipe, ssize_t nread, const uv_buf_t *buf) in ReadStream() argument
136 HCtxJdwp ctxJdwp = static_cast<HCtxJdwp>(pipe->data); in ReadStream()
169 if (uv_fileno(reinterpret_cast<uv_handle_t *>(&(ctxJdwp->pipe)), &fd) < 0) { in ReadStream()
232 uv_pipe_init(thisClass->loop, &ctxJdwp->pipe, 1); in AcceptClient()
233 if (uv_accept(server, (uv_stream_t *)&ctxJdwp->pipe) < 0) { in AcceptClient()
245 uv_read_start((uv_stream_t *)&ctxJdwp->pipe, funAlloc, ReadStream); in AcceptClient()
249 // Test uv connect(pipe): 'uv_pipe_connect'
405 if (Base::SendToStreamEx((uv_stream_t *)&ctx->pipe, (uint8_ in SendJdwpNewFD()
[all...] |
| H A D | jdwp.h | 70 uv_pipe_t pipe; member
88 static void ReadStream(uv_stream_t *pipe, ssize_t nread, const uv_buf_t *buf);
|
| H A D | daemon_unity.cpp | 166 if (pipe(pipefd) == -1) { in CallRemount()
167 WRITE_LOG(LOG_FATAL, "Failed to create pipe: %s", strerror(errno)); in CallRemount()
|
| /developtools/profiler/device/cmds/test/unittest/ |
| H A D | hiprofiler_cmd_test.cpp | 84 std::unique_ptr<FILE, decltype(&pclose)> pipe(popen(stopCmd.c_str(), "r"), pclose); in StopProcessStub()
90 std::unique_ptr<FILE, decltype(&pclose)> pipe(popen(cmd.c_str(), "r"), pclose); in RunCommand()
91 CHECK_TRUE(pipe, false, "RunCommand: create popen FAILED!"); in RunCommand()
93 while (fgets(buffer.data(), buffer.size(), pipe.get()) != nullptr) { in RunCommand()
443 std::unique_ptr<FILE, decltype(&pclose)> pipe(popen(findpid.c_str(), "r"), pclose); in KillProcess()
447 if (fgets(line, sizeof(line), pipe.get()) == nullptr) { in KillProcess()
|
| /developtools/ace_js2bundle/ace-loader/ |
| H A D | module-source.js | 55 readable.pipe(writable);
|
| H A D | copy_deps_source.js | 63 readable.pipe(writable);
|
| /developtools/hdc/hdc_rust/src/common/ |
| H A D | forward.rs | 909 "Unix pipe bind failed",
921 "Unix pipe listen failed",
1053 crate::info!("pipe, fd0:{}, fd1:{}", fd0, fd1);
|
| H A D | uds.rs | 25 use libc::{eventfd, fcntl, pipe, read, send, socketpair, write, MSG_EOR};
242 crate::debug!("pipe() begin..."); in wrap_pipe()
243 let ret = pipe(fd_buf[..].as_mut_ptr()); in wrap_pipe()
244 crate::debug!("pipe() ret:{}", ret); in wrap_pipe()
|
| /developtools/profiler/device/plugins/native_daemon/test/unittest/common/native/ |
| H A D | hook_manager_test.cpp | 69 std::unique_ptr<FILE, decltype(&pclose)> pipe(popen(stopCmd.c_str(), "r"), pclose); in StopServerStub()
|
| /developtools/profiler/device/services/ipc/src/ |
| H A D | unix_socket_server.cpp | 143 std::unique_ptr<FILE, decltype(&pclose)> pipe(popen(chmodCmd.c_str(), "r"), pclose); in StartServer()
|
| /developtools/profiler/device/plugins/api/test/unittest/ |
| H A D | plugin_manager_test.cpp | 73 std::unique_ptr<FILE, decltype(&pclose)> pipe(popen(stopCmd.c_str(), "r"), pclose); in TearDownTestCase()
|
| /developtools/hiperf/interfaces/innerkits/native/src/ |
| H A D | hiperf_client.cpp | 449 if (pipe(clientToServerFd) != 0) { in Start()
452 HIPERF_HILOGI(MODULE_CPP_API, "failed to create pipe: %" HILOG_PUBLIC "s", errInfo); in Start()
454 } else if (pipe(serverToClientFd) != 0) { in Start()
457 HIPERF_HILOGI(MODULE_CPP_API, "failed to create pipe: %" HILOG_PUBLIC "s", errInfo); in Start()
651 HIPERF_HILOGI(MODULE_CPP_API, "read failed from pipe"); in WaitCommandReply()
|
| /developtools/hdc/sudo/src/ |
| H A D | main.cpp | 274 if (pipe(fds) != 0) { in UserAccountVerify()
275 WriteStdErr("exec pipe failed\n"); in UserAccountVerify()
|
| /developtools/profiler/host/smartperf/client/client_command/ |
| H A D | sdk_data_recv.cpp | 192 if (pipe(sdkParams.pipFd) == -1) {
in ServerThread()
|
| H A D | FPS.cpp | 157 if (pipe(pipefd) == -1) { in GetSurfaceFrame()
158 LOGE("FPS::Failed to create pipe"); in GetSurfaceFrame()
|