| /developtools/integration_verification/tools/deps_guard/elf_file_mgr/ |
| D | utils.py | 36 pipe = os.popen(command + ' ' + ' '.join(args), 'r')
37 output = pipe.read().strip()
38 status = pipe.close()
|
| /developtools/hdc/src/test/jdwp/ |
| 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), 1); in Connect()
[all …]
|
| D | HdcJdwpSimulator.h | 31 uv_pipe_t pipe; member
|
| /developtools/hdc/test/fuzztest/jdwpreadstream_fuzzer/ |
| 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/hdc/test/unittest/common/ |
| D | HdcJdwpTest.cpp | 78 uv_pipe_t pipe; variable
79 uv_stream_t *stream = (uv_stream_t *)&pipe;
83 pipe.data = ctxJdwp;
|
| /developtools/hdc/src/common/ |
| 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()
204 Base::TryCloseHandle((uv_handle_t *)&ctx->pipe, true, funcHandleClose); in FreeContext()
420 bool HdcForwardBase::LocalAbstractConnect(uv_pipe_t *pipe, string &sNodeCfg) in LocalAbstractConnect() argument
445 if (uv_pipe_open(pipe, s)) { in LocalAbstractConnect()
460 ctxPoint->pipe.data = ctxPoint; in SetupFilePoint()
461 uv_pipe_init(loopTask, &ctxPoint->pipe, 0); in SetupFilePoint()
466 if (uv_pipe_bind(&ctxPoint->pipe, sNodeCfg.c_str())) { in SetupFilePoint()
470 if (uv_listen((uv_stream_t *)&ctxPoint->pipe, 4, ListenCallback)) { in SetupFilePoint()
[all …]
|
| D | forward.h | 49 uv_pipe_t pipe; member
102 bool LocalAbstractConnect(uv_pipe_t *pipe, string &sNodeCfg);
|
| D | async_cmd.cpp | 210 pipe(fds); in Popen()
|
| /developtools/profiler/device/plugins/hiebpf_plugin/src/ |
| D | hiebpf_module.cpp | 39 std::unique_ptr<FILE, decltype(&pclose)> pipe(popen(cmd.c_str(), "r"), pclose); in RunCmd() local
40 if (pipe == nullptr) { in RunCmd()
47 while (fgets(buffer.data(), buffer.size(), pipe.get()) != nullptr) { in RunCmd()
|
| /developtools/profiler/device/plugins/bytrace_plugin/src/ |
| D | bytrace_module.cpp | 69 std::unique_ptr<FILE, decltype(&pclose)> pipe(popen(cmd.data(), "r"), pclose); in RunCommand() local
70 CHECK_TRUE(pipe, false, "BytraceCall::RunCommand: create popen FAILED!"); in RunCommand()
74 while (fgets(buffer.data(), buffer.size(), pipe.get()) != nullptr) { in RunCommand()
|
| /developtools/hdc/src/daemon/ |
| D | jdwp.cpp | 69 ctx->pipe.data = ctx; in MallocContext()
82 Base::TryCloseHandle((const uv_handle_t *)&ctx->pipe); in FreeContext()
111 void HdcJdwp::ReadStream(uv_stream_t *pipe, ssize_t nread, const uv_buf_t *buf) in ReadStream() argument
129 HCtxJdwp ctxJdwp = static_cast<HCtxJdwp>(pipe->data); in ReadStream()
162 if (uv_fileno(reinterpret_cast<uv_handle_t *>(&(ctxJdwp->pipe)), &fd) < 0) { in ReadStream()
216 uv_pipe_init(thisClass->loop, &ctxJdwp->pipe, 1); in AcceptClient()
217 if (uv_accept(server, (uv_stream_t *)&ctxJdwp->pipe) < 0) { in AcceptClient()
229 uv_read_start((uv_stream_t *)&ctxJdwp->pipe, funAlloc, ReadStream); in AcceptClient()
389 …if (Base::SendToStreamEx((uv_stream_t *)&ctx->pipe, (uint8_t *)&ctx->dummy, 1, (uv_stream_t *)&ctx… in SendJdwpNewFD()
428 uv_stream_t *stream = (uv_stream_t *)&ctx->pipe; in SendArkNewFD()
|
| 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);
|
| /developtools/profiler/device/cmds/test/unittest/ |
| D | hiprofiler_cmd_test.cpp | 85 std::unique_ptr<FILE, decltype(&pclose)> pipe(popen(stopCmd.c_str(), "r"), pclose); in StopProcessStub() local
91 std::unique_ptr<FILE, decltype(&pclose)> pipe(popen(cmd.c_str(), "r"), pclose); in RunCommand() local
92 CHECK_TRUE(pipe, false, "RunCommand: create popen FAILED!"); in RunCommand()
94 while (fgets(buffer.data(), buffer.size(), pipe.get()) != nullptr) { in RunCommand()
474 std::unique_ptr<FILE, decltype(&pclose)> pipe(popen(findpid.c_str(), "r"), pclose); in KillProcess() local
478 if (fgets(line, sizeof(line), pipe.get()) == nullptr) { in KillProcess()
|
| /developtools/ace_js2bundle/ace-loader/ |
| D | module-source.js | 55 readable.pipe(writable);
|
| /developtools/profiler/device/plugins/ftrace_plugin/src/ |
| D | process_utils.cpp | 56 CHECK_TRUE(pipe(pipe_) != -1, -1, "create pipe failed, %d", errno); in Init()
223 CHECK_TRUE(pipe(pipeFds) != -1, -1, "create pipe failed, %d", errno); in Execute()
|
| /developtools/hdc/hdc_rust/src/common/ |
| D | uds.rs | 26 use libc::{fcntl, pipe, read, send, socketpair, write, MSG_EOR};
216 let ret = pipe(fd_buf[..].as_mut_ptr()); in wrap_pipe()
|
| /developtools/ace_js2bundle/ace-loader/src/ |
| D | resource-plugin.js | 61 readStream.pipe(writeStream);
|
| /developtools/profiler/device/plugins/native_daemon/test/unittest/common/native/ |
| D | hook_manager_test.cpp | 71 std::unique_ptr<FILE, decltype(&pclose)> pipe(popen(stopCmd.c_str(), "r"), pclose); in StopServerStub() local
|
| /developtools/profiler/device/services/ipc/src/ |
| D | unix_socket_server.cpp | 134 std::unique_ptr<FILE, decltype(&pclose)> pipe(popen(chmodCmd.c_str(), "r"), pclose); in StartServer() local
|
| /developtools/profiler/device/plugins/api/test/unittest/ |
| D | plugin_manager_test.cpp | 74 std::unique_ptr<FILE, decltype(&pclose)> pipe(popen(stopCmd.c_str(), "r"), pclose); in TearDownTestCase() local
|
| /developtools/profiler/device/plugins/hidump_plugin/src/ |
| D | hidump_plugin.cpp | 195 pipe(fd); in CustomPopen()
|
| /developtools/hiperf/interfaces/innerkits/native/src/ |
| D | hiperf_client.cpp | 401 if (pipe(clientToServerFd) != 0) { in Start()
406 } else if (pipe(serverToClientFd) != 0) { in Start()
|
| /developtools/profiler/device/plugins/memory_plugin/src/ |
| D | memory_data_plugin.cpp | 1045 std::unique_ptr<FILE, decltype(&pclose)> pipe(popen(cmd.c_str(), "r"), pclose); in RunCommand() local
1046 if (!pipe) { in RunCommand()
1052 while (fgets(buffer.data(), buffer.size(), pipe.get()) != nullptr) { in RunCommand()
|
| /developtools/profiler/device/base/src/ |
| D | common.cpp | 257 CHECK_TRUE(pipe(fds) == 0, nullptr, "Pipe open failed!"); in CustomPopen()
|
| /developtools/profiler/device/plugins/memory_plugin/test/unittest/ |
| D | memory_data_plugin_unittest.cpp | 370 std::unique_ptr<FILE, decltype(&pclose)> pipe(popen(findpid.c_str(), "r"), pclose); in GetPid() local
374 if (fgets(line, sizeof(line), pipe.get()) == nullptr) { in GetPid()
|