| /developtools/hdc/src/common/ |
| D | async_cmd.cpp | 149 int fds[2]; in Popen()
150 pipe(fds); in Popen()
152 fds[pipeRead], fds[pipeWrite]); in Popen()
159 fds[pipeRead], fds[pipeWrite]); in Popen()
162 dup2(fds[pipeRead], STDIN_FILENO); in Popen()
164 dup2(fds[pipeWrite], STDOUT_FILENO); in Popen()
165 dup2(fds[pipeWrite], STDERR_FILENO); in Popen()
167 close(fds[pipeRead]); in Popen()
168 close(fds[pipeWrite]); in Popen()
179 Base::CloseFd(fds[pipeWrite]); in Popen()
[all …]
|
| D | base.cpp | 996 int CreateSocketPair(int *fds) in CreateSocketPair() argument
1000 int ret = socketpair(AF_UNIX, SOCK_STREAM, 0, fds); in CreateSocketPair()
1003 if (fcntl(fds[i], F_SETFD, FD_CLOEXEC) == -1) { in CreateSocketPair()
1004 CloseFd(fds[0]); in CreateSocketPair()
1005 CloseFd(fds[1]); in CreateSocketPair()
1016 return socketpair(AF_UNIX, SOCK_STREAM | SOCK_CLOEXEC, 0, fds); in CreateSocketPair()
1022 if (fds == 0) { in CreateSocketPair()
1033 fds[0] = fds[1] = (int)-1; in CreateSocketPair()
1047 fds[0] = socket(AF_INET, SOCK_STREAM, 0); in CreateSocketPair()
1048 if (fds[0] == -1) { in CreateSocketPair()
[all …]
|
| D | base.h | 69 int CreateSocketPair(int *fds);
70 void CloseSocketPair(int *fds);
|
| /developtools/hdc/test/unittest/common/ |
| D | daemon_uart_test.cpp | 95 void PrepareDeamonReadThreadData(std::vector<uint8_t> &data, int fds[PAIR]) in PrepareDeamonReadThreadData()
101 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM | SOCK_CLOEXEC, 0, fds), 0); in PrepareDeamonReadThreadData()
108 mockDaemonUART.uartHandle = fds[RECEIVER]; in PrepareDeamonReadThreadData()
443 int fds[PAIR]; variable
446 PrepareDeamonReadThreadData(data, fds);
452 MockUartDevSender(fds[SENDER], data.data(), data.size(), 0ms, true);
456 close(fds[SENDER]);
457 close(fds[RECEIVER]);
469 int fds[PAIR]; variable
472 PrepareDeamonReadThreadData(data, fds);
[all …]
|
| /developtools/hdc/src/daemon/ |
| D | daemon_forward.cpp | 56 int fds[2] = { 0 }; in SetupJdwpPoint() local
58 Base::CreateSocketPair(fds); in SetupJdwpPoint()
63 if (uv_tcp_open(&ctxPoint->tcp, fds[0])) { in SetupJdwpPoint()
70 memcpy_s(flag + 1 + len, sizeof(flag) - len - 1, &fds[1], len)) { in SetupJdwpPoint()
76 WRITE_LOG(LOG_DEBUG, "SendJdwpNewFD Finish,ret:%d fd0:%d fd1:%d", ret, fds[0], fds[1]); in SetupJdwpPoint()
78 Base::CloseSocketPair(fds); in SetupJdwpPoint()
|
| /developtools/profiler/device/base/src/ |
| D | common.cpp | 225 FILE* CustomPopen(const std::vector<std::string>& command, const char* type, int fds[], in CustomPopen() argument
240 CHECK_TRUE(pipe(fds) == 0, nullptr, "Pipe open failed!"); in CustomPopen()
257 CHECK_TRUE(CustomFdClose(fds[READ]) == 0, nullptr, "CustomFdClose failed!"); in CustomPopen()
258 dup2(fds[WRITE], STDOUT_FILENO); // Redirect stdout to pipe in CustomPopen()
259 CHECK_TRUE(CustomFdClose(fds[WRITE]) == 0, nullptr, "CustomFdClose failed!"); in CustomPopen()
261 CHECK_TRUE(CustomFdClose(fds[WRITE]) == 0, nullptr, "CustomFdClose failed!"); in CustomPopen()
262 dup2(fds[READ], STDIN_FILENO); // Redirect stdin to pipe in CustomPopen()
263 CHECK_TRUE(CustomFdClose(fds[READ]) == 0, nullptr, "CustomFdClose failed!"); in CustomPopen()
277 … CHECK_TRUE(CustomFdClose(fds[WRITE]) == 0, nullptr, "%s %d CustomFdClose failed! errno(%s)\n", in CustomPopen()
281 … CHECK_TRUE(CustomFdClose(fds[READ]) == 0, nullptr, "%s %d CustomFdClose failed! errno(%s)\n", in CustomPopen()
[all …]
|
| /developtools/profiler/device/base/include/ |
| D | common.h | 31 FILE* CustomPopen(const std::vector<std::string>& command, const char* type, int fds[],
33 int CustomPclose(FILE* fp, int fds[], volatile pid_t& childPid, bool needUnblock = false);
34 int CustomPUnblock(int fds[]);
|
| /developtools/profiler/hiebpf/src/ |
| D | bpf_log_reader.cpp | 145 struct pollfd fds; in MoveBPFLog() local
146 fds.fd = ifd_; in MoveBPFLog()
147 fds.events = POLLIN; in MoveBPFLog()
150 int ret = poll(&fds, nfds, timeout); in MoveBPFLog()
|
| /developtools/smartperf_host/trace_streamer/sdk/dubai_sdk/rpc/ |
| D | http_server.cpp | 125 struct pollfd fds[COUNT_SOCKET]; in Run() local
127 fds[i] = {sockets_[i].GetFd(), POLLIN, 0}; in Run()
131 if (poll(fds, sizeof(fds) / sizeof(pollfd), pollTimeOut_) <= 0) { in Run()
136 if (fds[i].revents != POLLIN) { in Run()
|
| /developtools/smartperf_host/trace_streamer/sdk/demo_sdk/rpc/ |
| D | http_server.cpp | 125 struct pollfd fds[COUNT_SOCKET]; in Run() local
127 fds[i] = {sockets_[i].GetFd(), POLLIN, 0}; in Run()
131 if (poll(fds, sizeof(fds) / sizeof(pollfd), pollTimeOut_) <= 0) { in Run()
136 if (fds[i].revents != POLLIN) { in Run()
|
| /developtools/profiler/host/smartperf/trace_streamer/src/rpc/ |
| D | http_server.cpp | 126 struct pollfd fds[COUNT_SOCKET]; in Run() local
128 fds[i] = {sockets_[i].GetFd(), POLLIN, 0}; in Run()
132 if (poll(fds, sizeof(fds) / sizeof(pollfd), pollTimeOut_) <= 0) { in Run()
137 if (fds[i].revents != POLLIN) { in Run()
|
| /developtools/smartperf_host/trace_streamer/src/rpc/ |
| D | http_server.cpp | 130 struct pollfd fds[COUNT_SOCKET]; in Run() local
132 fds[i] = {sockets_[i].GetFd(), POLLIN, 0}; in Run()
136 if (poll(fds, sizeof(fds) / sizeof(pollfd), pollTimeOut_) <= 0) { in Run()
141 if (fds[i].revents != POLLIN) { in Run()
|
| /developtools/profiler/hiebpf/include/ |
| D | vmlinux.h | 26823 int fds[2]; member
|