| /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()
236 thisClass->SendToStream(reinterpret_cast<uv_stream_t *>(&ctxJdwp->pipe), in ConnectJdwp()
240 uv_read_start(reinterpret_cast<uv_stream_t *>(&ctxJdwp->pipe), thisClass->alloc_buffer, in ConnectJdwp()
252 ctx->pipe.data = ctx; in MallocContext()
263 if (loop && !uv_is_closing(reinterpret_cast<uv_handle_t *>(&ctxPoint->pipe))) { in FreeContext()
264 uv_close(reinterpret_cast<uv_handle_t *>(&ctxPoint->pipe), nullptr); in FreeContext()
285 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/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/common/ |
| D | forward.cpp | 103 uv_pipe_init(ctxClient->thisClass->loopTask, &ctxClient->pipe, 0); in ListenCallback()
104 client = (uv_stream_t *)&ctxClient->pipe; in ListenCallback()
120 ctx->pipe.data = ctx; in MallocContext()
194 Base::TryCloseHandle((uv_handle_t *)&ctx->pipe, true, funcHandleClose); in FreeContext()
402 bool HdcForwardBase::LocalAbstractConnect(uv_pipe_t *pipe, string &sNodeCfg) in LocalAbstractConnect() argument
425 if (uv_pipe_open(pipe, s)) { in LocalAbstractConnect()
440 ctxPoint->pipe.data = ctxPoint; in SetupFilePoint()
441 uv_pipe_init(loopTask, &ctxPoint->pipe, 0); in SetupFilePoint()
446 if (uv_pipe_bind(&ctxPoint->pipe, sNodeCfg.c_str())) { in SetupFilePoint()
450 if (uv_listen((uv_stream_t *)&ctxPoint->pipe, 4, ListenCallback)) { in SetupFilePoint()
[all …]
|
| D | forward.h | 47 uv_pipe_t pipe; member
96 bool LocalAbstractConnect(uv_pipe_t *pipe, string &sNodeCfg);
|
| D | async_cmd.cpp | 101 pipe(fds); in Popen()
|
| /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/profiler/device/cmds/test/unittest/ |
| D | hiprofiler_cmd_test.cpp | 79 std::unique_ptr<FILE, decltype(&pclose)> pipe(popen(stopCmd.c_str(), "r"), pclose); in StopProcessStub() local
84 std::unique_ptr<FILE, decltype(&pclose)> pipe(popen(cmd.c_str(), "r"), pclose); in RunCommand() local
85 CHECK_TRUE(pipe, false, "RunCommand: create popen FAILED!"); in RunCommand()
88 while (fgets(buffer.data(), buffer.size(), pipe.get()) != nullptr) { in RunCommand()
256 std::unique_ptr<FILE, decltype(&pclose)> pipe(popen(findpid.c_str(), "r"), pclose); in KillProcess() local
260 if (fgets(line, sizeof(line), pipe.get()) == nullptr) { in KillProcess()
|
| /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 | 70 ctx->pipe.data = ctx; in MallocContext()
83 Base::TryCloseHandle((const uv_handle_t *)&ctx->pipe); in FreeContext()
105 void HdcJdwp::ReadStream(uv_stream_t *pipe, ssize_t nread, const uv_buf_t *buf) in ReadStream() argument
122 HCtxJdwp ctxJdwp = static_cast<HCtxJdwp>(pipe->data); in ReadStream()
152 if (uv_fileno(reinterpret_cast<uv_handle_t *>(&(ctxJdwp->pipe)), &fd) < 0) { in ReadStream()
193 uv_pipe_init(thisClass->loop, &ctxJdwp->pipe, 1); in AcceptClient()
194 if (uv_accept(server, (uv_stream_t *)&ctxJdwp->pipe) < 0) { in AcceptClient()
206 uv_read_start((uv_stream_t *)&ctxJdwp->pipe, funAlloc, ReadStream); in AcceptClient()
365 …if (Base::SendToStreamEx((uv_stream_t *)&ctx->pipe, (uint8_t *)&ctx->dummy, 1, (uv_stream_t *)&ctx… in SendJdwpNewFD()
|
| D | jdwp.h | 63 uv_pipe_t pipe; member
80 static void ReadStream(uv_stream_t *pipe, ssize_t nread, const uv_buf_t *buf);
|
| /developtools/ace_js2bundle/ace-loader/ |
| D | module-source.js | 55 readable.pipe(writable);
|
| /developtools/profiler/device/plugins/ftrace_plugin/src/ |
| D | process_utils.cpp | 57 CHECK_TRUE(pipe(pipe_) != -1, -1, "create pipe failed, %d", errno); in Init()
227 CHECK_TRUE(pipe(pipeFds) != -1, -1, "create pipe failed, %d", errno); in Execute()
|
| /developtools/ace_js2bundle/ace-loader/src/ |
| D | resource-plugin.js | 61 readStream.pipe(writeStream);
|
| /developtools/profiler/device/services/ipc/src/ |
| D | unix_socket_server.cpp | 126 std::unique_ptr<FILE, decltype(&pclose)> pipe(popen(chmodCmd.c_str(), "r"), pclose); in StartServer() local
|
| /developtools/profiler/device/plugins/native_daemon/test/unittest/common/native/ |
| D | hook_manager_test.cpp | 62 std::unique_ptr<FILE, decltype(&pclose)> pipe(popen(stopCmd.c_str(), "r"), pclose); in StopServerStub() local
|
| /developtools/profiler/device/plugins/api/test/unittest/ |
| D | plugin_manager_test.cpp | 66 std::unique_ptr<FILE, decltype(&pclose)> pipe(popen(stopCmd.c_str(), "r"), pclose); in TearDownTestCase() local
|
| /developtools/hiperf/interfaces/innerkits/native/src/ |
| D | hiperf_client.cpp | 374 if (pipe(clientToServerFd) != 0) { in Start()
379 } else if (pipe(serverToClientFd) != 0) { in Start()
|
| /developtools/profiler/device/plugins/hidump_plugin/src/ |
| D | hidump_plugin.cpp | 188 pipe(fd); in CustomPopen()
|
| /developtools/profiler/device/plugins/hisysevent_plugin/src/ |
| D | hisysevent_plugin.cpp | 220 pipe(fd); in CustomPopen()
|
| /developtools/profiler/device/base/src/ |
| D | common.cpp | 205 pipe(fd); in CustomPopen()
|
| /developtools/profiler/device/plugins/hilog_plugin/src/ |
| D | hilog_plugin.cpp | 487 pipe(fd); in CustomPopen()
|
| /developtools/ace_ets2bundle/compiler/src/ |
| D | utils.ts | 244 readStream.pipe(writeStream);
|
| /developtools/profiler/device/services/profiler_service/test/unittest/ |
| D | profiler_service_performance_test.cpp | 131 std::unique_ptr<FILE, decltype(&pclose)> pipe(popen(stopCmd.c_str(), "r"), pclose); in StopProcessStub() local
|