| /foundation/communication/dsoftbus/components/nstackx/nstackx_util/core/ |
| H A D | nstackx_socket.c | 34 CloseSocketInner(socket->sockfd); in CloseSocket()
35 socket->sockfd = INVALID_SOCKET; in CloseSocket()
92 clientSocket->sockfd = socket(AF_INET, SOCK_STREAM, 0); in ConnectTcpServerWithTargetDev()
93 if (clientSocket->sockfd == INVALID_SOCKET) { in ConnectTcpServerWithTargetDev()
97 if (SetTcpSocketBufSize(clientSocket->sockfd, NSTACKX_TCP_SOCKET_BUFFER_SIZE) != NSTACKX_EOK) { in ConnectTcpServerWithTargetDev()
100 if (SetSocketNonBlock(clientSocket->sockfd) != NSTACKX_EOK) { in ConnectTcpServerWithTargetDev()
104 BindToDevInTheSameLan(clientSocket->sockfd, sockAddr); in ConnectTcpServerWithTargetDev()
107 if (BindToTargetDev(clientSocket->sockfd, localInterface) != NSTACKX_EOK) { in ConnectTcpServerWithTargetDev()
113 int32_t ret = connect(clientSocket->sockfd, (struct sockaddr *)sockAddr, addrLen); in ConnectTcpServerWithTargetDev()
126 CloseSocketInner(clientSocket->sockfd); in ConnectTcpServerWithTargetDev()
[all...] |
| /foundation/communication/netmanager_ext/frameworks/native/netvpnclient/src/ |
| H A D | vpn_interface.cpp | 38 int32_t VpnInterface::ConnectControl(int32_t sockfd, int32_t nsec) in ConnectControl() argument
40 uint32_t flags = static_cast<uint32_t>(fcntl(sockfd, F_GETFL, 0)); in ConnectControl()
41 fcntl(sockfd, F_SETFL, flags | O_NONBLOCK); in ConnectControl()
44 int32_t ret = connect(sockfd, reinterpret_cast<const sockaddr *>(&SERVER_PATH), sizeof(SERVER_PATH)); in ConnectControl()
50 fcntl(sockfd, F_SETFL, flags); /* restore file status flags */ in ConnectControl()
57 FD_SET(sockfd, &rset); in ConnectControl()
63 ret = select(sockfd + 1, &rset, &wset, NULL, nsec ? &tval : NULL); in ConnectControl()
73 if (FD_ISSET(sockfd, &rset) || FD_ISSET(sockfd, &wset)) { in ConnectControl()
74 if (getsockopt(sockfd, SOL_SOCKE in ConnectControl()
94 RecvMsgFromUnixServer(int32_t sockfd) RecvMsgFromUnixServer() argument
145 int32_t sockfd = socket(AF_UNIX, SOCK_STREAM, 0); GetVpnInterfaceFd() local
[all...] |
| /foundation/CastEngine/castengine_wifi_display/tests/demo/network/ |
| H A D | udp_client_demo.cpp | 30 void do_cli(FILE *fp, int sockfd, struct sockaddr *pservaddr, socklen_t servlen) in do_cli() argument
33 if (connect(sockfd, (struct sockaddr *)pservaddr, servlen) == -1) { in do_cli()
42 write(sockfd, msg.c_str(), msg.length()); in do_cli()
50 int sockfd; in main() local
68 sockfd = socket(AF_INET, SOCK_DGRAM, 0); in main()
70 do_cli(stdin, sockfd, (struct sockaddr *)&servaddr, sizeof(servaddr)); in main()
|
| H A D | udp_server_demo.cpp | 36 int setnonblocking(int sockfd) in setnonblocking() argument
38 return fcntl(sockfd, F_SETFL, fcntl(sockfd, F_GETFL) | O_NONBLOCK); in setnonblocking()
|
| /foundation/CastEngine/castengine_cast_plus_stream/src/channel/src/tcp/ |
| H A D | tcp_connection.cpp | 119 int sockfd = socket_.Accept(); in Accept() local
120 if (sockfd == INVALID_SOCKET) { in Accept()
123 listener->OnConnectionConnectFailed(channelRequest_, sockfd); in Accept()
126 int remotePort = socket_.GetPeerPort(sockfd); in Accept()
137 SetAudioConnection(sockfd); in Accept()
140 sockfd); in Accept()
143 remoteSocket_ = sockfd; in Accept()
146 channelRequest_.remoteDeviceInfo.sessionId, channelRequest_.moduleType, sockfd); in Accept()
154 Receive(sockfd); in Accept()
195 int sockfd in HandleReceivedData() local
299 int sockfd = remoteSocket_ == INVALID_SOCKET ? socket_.GetSocketFd() : remoteSocket_; Send() local
[all...] |
| /foundation/CastEngine/castengine_cast_framework/service/src/session/src/channel/src/tcp/ |
| H A D | tcp_connection.cpp | 119 int sockfd = socket_.Accept(); in Accept() local
120 if (sockfd == INVALID_SOCKET) { in Accept()
123 listener->OnConnectionConnectFailed(channelRequest_, sockfd); in Accept()
126 int remotePort = socket_.GetPeerPort(sockfd); in Accept()
137 SetAudioConnection(sockfd); in Accept()
140 sockfd); in Accept()
143 remoteSocket_ = sockfd; in Accept()
146 channelRequest_.remoteDeviceInfo.sessionId, channelRequest_.moduleType, sockfd); in Accept()
154 Receive(sockfd); in Accept()
195 int sockfd in HandleReceivedData() local
299 int sockfd = remoteSocket_ == INVALID_SOCKET ? socket_.GetSocketFd() : remoteSocket_; Send() local
[all...] |
| /foundation/communication/dsoftbus/components/nstackx/nstackx_util/interface/ |
| H A D | nstackx_dev.h | 59 NSTACKX_EXPORT int32_t BindToDevice(SocketDesc sockfd, const struct sockaddr_in *localAddr);
62 NSTACKX_EXPORT int32_t BindToTargetDev(SocketDesc sockfd, const char *targetInterfaceName);
64 NSTACKX_EXPORT void BindToDevInTheSameLan(SocketDesc sockfd, const struct sockaddr_in *sockAddr);
|
| H A D | nstackx_socket.h | 31 SocketDesc sockfd; member
|
| /foundation/communication/netmanager_ext/interfaces/innerkits/netvpnclient/include/ |
| H A D | vpn_interface.h | 36 int32_t ConnectControl(int32_t sockfd, int32_t nsec);
37 int32_t RecvMsgFromUnixServer(int32_t sockfd);
|
| /foundation/communication/netstack/frameworks/js/napi/socket/async_context/include/ |
| H A D | local_socket_context.h | 30 explicit SocketBaseManager(int sockfd) : sockfd_(sockfd) {} in SocketBaseManager()
35 explicit LocalSocketManager(int sockfd) : SocketBaseManager(sockfd) {} in LocalSocketManager()
|
| H A D | local_socket_server_context.h | 58 explicit LocalSocketServerManager(int sockfd) : SocketBaseManager(sockfd) {} in LocalSocketServerManager()
78 int RegisterEpollEvent(int sockfd, int events) in RegisterEpollEvent()
82 event.data.fd = sockfd; in RegisterEpollEvent()
83 return epoll_ctl(epollFd_, EPOLL_CTL_ADD, sockfd, &event); in RegisterEpollEvent()
|
| /foundation/communication/dsoftbus/components/nstackx/nstackx_util/platform/liteos/ |
| H A D | sys_dev.c | 175 static int32_t BindToDeviceInner(int32_t sockfd, const struct ifreq *ifBinding) in BindToDeviceInner() argument
187 if (setsockopt(sockfd, SOL_SOCKET, SO_BINDTODEVICE, (char *)&ifr, sizeof(ifr)) < 0) { in BindToDeviceInner()
199 int32_t BindToDevice(SocketDesc sockfd, const struct sockaddr_in *localAddr) in BindToDevice() argument
241 return BindToDeviceInner(sockfd, ifBinding); in BindToDevice()
361 void BindToDevInTheSameLan(SocketDesc sockfd, const struct sockaddr_in *sockAddr) in BindToDevInTheSameLan() argument
364 if (sockfd < 0) { in BindToDevInTheSameLan()
372 if (setsockopt(sockfd, SOL_SOCKET, SO_BINDTODEVICE, (char *)&localInterface, sizeof(localInterface)) < 0) { in BindToDevInTheSameLan()
379 int32_t BindToTargetDev(SocketDesc sockfd, const char *targetInterfaceName) in BindToTargetDev() argument
400 ret = BindToDeviceInner(sockfd, &buf[i]); in BindToTargetDev()
|
| H A D | sys_socket.c | 117 ret = (int32_t)sendmsg(s->sockfd, &mh, 0); in SocketSendEx()
|
| /foundation/communication/dsoftbus/components/nstackx/nstackx_util/platform/unix/ |
| H A D | sys_dev.c | 175 static int32_t BindToDeviceInner(int32_t sockfd, const struct ifreq *ifBinding) in BindToDeviceInner() argument
187 if (setsockopt(sockfd, SOL_SOCKET, SO_BINDTODEVICE, (char *)&ifr, sizeof(ifr)) < 0) { in BindToDeviceInner()
199 int32_t BindToDevice(SocketDesc sockfd, const struct sockaddr_in *localAddr) in BindToDevice() argument
248 return BindToDeviceInner(sockfd, ifBinding); in BindToDevice()
368 void BindToDevInTheSameLan(SocketDesc sockfd, const struct sockaddr_in *sockAddr) in BindToDevInTheSameLan() argument
371 if (sockfd < 0) { in BindToDevInTheSameLan()
379 if (setsockopt(sockfd, SOL_SOCKET, SO_BINDTODEVICE, (char *)&localInterface, sizeof(localInterface)) < 0) { in BindToDevInTheSameLan()
386 int32_t BindToTargetDev(SocketDesc sockfd, const char *targetInterfaceName) in BindToTargetDev() argument
407 ret = BindToDeviceInner(sockfd, &buf[i]); in BindToTargetDev()
|
| /foundation/communication/netmanager_ext/services/mdnsmanager/src/ |
| H A D | mdns_protocol_impl.cpp | 121 int32_t MDnsProtocolImpl::ConnectControl(int32_t sockfd, sockaddr* serverAddr) in ConnectControl() argument
123 uint32_t flags = static_cast<uint32_t>(fcntl(sockfd, F_GETFL, 0)); in ConnectControl()
124 fcntl(sockfd, F_SETFL, flags | O_NONBLOCK); in ConnectControl()
125 int32_t ret = connect(sockfd, serverAddr, sizeof(sockaddr)); in ConnectControl()
131 fcntl(sockfd, F_SETFL, flags); /* restore file status flags */ in ConnectControl()
138 FD_SET(sockfd, &rset); in ConnectControl()
141 ret = select(sockfd + 1, &rset, &wset, NULL, &tval); in ConnectControl()
150 if (!FD_ISSET(sockfd, &rset) && !FD_ISSET(sockfd, &wset)) { in ConnectControl()
151 NETMGR_EXT_LOG_E("select error: sockfd no in ConnectControl()
177 int32_t sockfd = socket(AF_INET, SOCK_STREAM, 0); IsConnectivity() local
[all...] |
| /foundation/communication/netmanager_base/services/netmanagernative/src/manager/ |
| H A D | interface_manager.cpp | 125 int32_t sockfd = socket(AF_INET, SOCK_DGRAM, 0); in SetMtu() local
126 if (sockfd < 0) { in SetMtu()
133 close(sockfd); in SetMtu()
137 close(sockfd); in SetMtu()
144 if (ioctl(sockfd, SIOCSIFMTU, &ifr) < 0) { in SetMtu()
146 close(sockfd); in SetMtu()
150 close(sockfd); in SetMtu()
|
| /foundation/communication/netstack/frameworks/js/napi/socket/socket_exec/src/ |
| H A D | local_socket_exec.cpp | 412 static bool SetSocketBufferSize(int sockfd, int type, uint32_t size) in SetSocketBufferSize() argument
418 if (setsockopt(sockfd, SOL_SOCKET, type, reinterpret_cast<void *>(&size), sizeof(size)) < 0) { in SetSocketBufferSize()
420 sockfd, type, size); in SetSocketBufferSize()
426 static bool SetLocalSocketOptions(int sockfd, const LocalExtraOptions &options) in SetLocalSocketOptions() argument
430 if (!SetSocketBufferSize(sockfd, SO_RCVBUF, recvBufSize)) { in SetLocalSocketOptions()
436 if (!SetSocketBufferSize(sockfd, SO_SNDBUF, sendBufSize)) { in SetLocalSocketOptions()
443 if (setsockopt(sockfd, SOL_SOCKET, SO_RCVTIMEO, reinterpret_cast<void *>(&timeout), sizeof(timeout)) < 0) { in SetLocalSocketOptions()
444 NETSTACK_LOGE("localsocket setsockopt error, SO_RCVTIMEO, fd: %{public}d", sockfd); in SetLocalSocketOptions()
447 if (setsockopt(sockfd, SOL_SOCKET, SO_SNDTIMEO, reinterpret_cast<void *>(&timeout), sizeof(timeout)) < 0) { in SetLocalSocketOptions()
448 NETSTACK_LOGE("localsocket setsockopt error, SO_SNDTIMEO, fd: %{public}d", sockfd); in SetLocalSocketOptions()
455 SetSocketDefaultBufferSize(int sockfd, LocalSocketServerManager *mgr) SetSocketDefaultBufferSize() argument
815 int sockfd = context->GetSocketFd(); ExecLocalSocketConnect() local
935 GetLocalSocketOptions(int sockfd, LocalExtraOptions &optionsRef) GetLocalSocketOptions() argument
[all...] |
| H A D | socket_exec.cpp | 670 static bool IsTCPSocket(int sockfd) in IsTCPSocket() argument
675 if (getsockopt(sockfd, SOL_SOCKET, SO_PROTOCOL, &optval, &optlen) != 0) { in IsTCPSocket()
1269 static bool SocketSetTcpExtraOptions(int sockfd, TCPExtraOptions& option) in SocketSetTcpExtraOptions() argument
1271 if (!SetBaseOptions(sockfd, &option)) { in SocketSetTcpExtraOptions()
1276 if (setsockopt(sockfd, SOL_SOCKET, SO_KEEPALIVE, reinterpret_cast<void*>(&alive), sizeof(alive)) < 0) { in SocketSetTcpExtraOptions()
1277 NETSTACK_LOGE("set SO_KEEPALIVE failed, fd: %{public}d", sockfd); in SocketSetTcpExtraOptions()
1284 if (setsockopt(sockfd, SOL_SOCKET, SO_OOBINLINE, reinterpret_cast<void*>(&oob), sizeof(oob)) < 0) { in SocketSetTcpExtraOptions()
1285 NETSTACK_LOGE("set SO_OOBINLINE failed, fd: %{public}d", sockfd); in SocketSetTcpExtraOptions()
1292 if (setsockopt(sockfd, IPPROTO_TCP, TCP_NODELAY, reinterpret_cast<void*>(&noDelay), sizeof(noDelay)) < 0) { in SocketSetTcpExtraOptions()
1293 NETSTACK_LOGE("set TCP_NODELAY failed, fd: %{public}d", sockfd); in SocketSetTcpExtraOptions()
[all...] |
| /foundation/communication/netmanager_base/frameworks/native/netstatsclient/src/ |
| H A D | net_stats_client.cpp | 369 int32_t NetStatsClient::GetSockfdRxBytes(uint64_t &stats, int32_t sockfd) in GetSockfdRxBytes() argument
371 if (sockfd <= 0) { in GetSockfdRxBytes()
372 NETMGR_LOG_E("sockfd is invalid"); in GetSockfdRxBytes()
384 if (getsockopt(sockfd, SOL_SOCKET, SO_COOKIE, &optrval, &optlen) == -1) { in GetSockfdRxBytes()
392 int32_t NetStatsClient::GetSockfdTxBytes(uint64_t &stats, int32_t sockfd) in GetSockfdTxBytes() argument
394 if (sockfd <= 0) { in GetSockfdTxBytes()
395 NETMGR_LOG_E("sockfd is invalid"); in GetSockfdTxBytes()
407 if (getsockopt(sockfd, SOL_SOCKET, SO_COOKIE, &optrval, &optlen) == -1) { in GetSockfdTxBytes()
|
| /foundation/communication/netmanager_base/interfaces/innerkits/netstatsclient/include/ |
| H A D | net_stats_client.h | 260 * @param sockfd sockfd
265 int32_t GetSockfdRxBytes(uint64_t &stats, int32_t sockfd);
271 * @param sockfd sockfd
276 int32_t GetSockfdTxBytes(uint64_t &stats, int32_t sockfd);
|
| /foundation/communication/bluetooth_service/services/bluetooth/service/src/sock/ |
| H A D | socket.h | 67 * @param sockfd the upper socket fd that generated by the socketpair.
70 int Connect(const std::string &addr, const Uuid &uuid, int securityFlag, int &sockfd);
79 * @param sockfd the upper socket fd that generated by the socketpair.
82 int Listen(const std::string &name, const Uuid &uuid, int securityFlag, int &sockfd);
|
| /foundation/communication/netstack/test/fuzztest/socket/fuzztest/socketexec_fuzzer/ |
| H A D | socket_exec_fuzzer.cpp | 65 int sockfd = ExecCommonUtils::MakeUdpSocket(family); in MakeUdpSocketFuzzTest() local
66 close(sockfd); in MakeUdpSocketFuzzTest()
79 int sockfd = ExecCommonUtils::MakeTcpSocket(family); in MakeTcpSocketFuzzTest() local
80 close(sockfd); in MakeTcpSocketFuzzTest()
375 int sockfd = ExecCommonUtils::MakeLocalSocket(SOCK_STREAM); in MakeLocalSocketFuzzTest() local
376 close(sockfd); in MakeLocalSocketFuzzTest()
|
| /foundation/communication/netmanager_base/test/netmanagernative/unittest/netsys_manager_test/ |
| H A D | netsys_native_client_test.cpp | 295 int32_t sockfd = socket(AF_INET, SOCK_STREAM, 0); in HWTEST_F() local
296 ret = nativeClient_.BindNetworkServiceVpn(sockfd); in HWTEST_F()
298 nativeClient_.EnableVirtualNetIfaceCard(sockfd, ifreq, ifacefd2); in HWTEST_F()
307 int32_t sockfd = socket(AF_INET, SOCK_STREAM, 0); in HWTEST_F() local
308 ret = nativeClient_.SetIpAddress(sockfd, LOCALIP, PREFIX_LENGTH, ifreq); in HWTEST_F()
|
| /foundation/communication/netmanager_base/test/netstatsmanager/unittest/net_stats_manager_test/ |
| H A D | net_stats_client_test.cpp | 312 int32_t sockfd = 0; in HWTEST_F() local
313 int32_t ret = DelayedSingleton<NetStatsClient>::GetInstance()->GetSockfdRxBytes(stats, sockfd); in HWTEST_F()
315 ret = DelayedSingleton<NetStatsClient>::GetInstance()->GetSockfdTxBytes(stats, sockfd); in HWTEST_F()
|
| /foundation/CastEngine/castengine_wifi_display/services/network/socket/ |
| H A D | socket_utils.h | 39 static void SetKeepAlive(int32_t sockfd);
|