| /ohos5.0/foundation/communication/dsoftbus/tests/adapter/unittest/ |
| H A D | softbus_socket_test.cpp | 338 int socketFd; variable
358 int socketFd; variable
393 int socketFd; variable
413 int socketFd; variable
433 int socketFd; variable
453 int socketFd; variable
576 int socketFd; variable
735 int socketFd; variable
1171 int32_t socketFd; variable
1188 int32_t socketFd; variable
[all …]
|
| /ohos5.0/foundation/communication/dsoftbus/adapter/common/kernel/posix/ |
| H A D | softbus_adapter_socket.c | 97 if (socketFd == NULL) { in SoftBusSocketCreate()
106 *socketFd = ret; in SoftBusSocketCreate()
132 int32_t SoftBusSocketGetError(int32_t socketFd) in SoftBusSocketGetError() argument
197 int32_t ret = listen(socketFd, backLog); in SoftBusSocketListen()
264 if (socketFd >= SOFTBUS_FD_SETSIZE) { in SoftBusSocketFdSet()
269 FD_SET(socketFd, (fd_set *)set->fdsBits); in SoftBusSocketFdSet()
279 FD_CLR(socketFd, (fd_set *)set->fdsBits); in SoftBusSocketFdClr()
288 if (socketFd >= SOFTBUS_FD_SETSIZE) { in SoftBusSocketFdIsset()
419 int32_t ret = shutdown(socketFd, how); in SoftBusSocketShutDown()
428 int32_t SoftBusSocketClose(int32_t socketFd) in SoftBusSocketClose() argument
[all …]
|
| /ohos5.0/foundation/communication/dsoftbus/adapter/common/include/ |
| H A D | softbus_adapter_socket.h | 142 int32_t SoftBusSocketGetLocalName(int32_t socketFd, SoftBusSockAddr *addr);
143 int32_t SoftBusSocketGetPeerName(int32_t socketFd, SoftBusSockAddr *addr);
146 int32_t SoftBusSocketListen(int32_t socketFd, int32_t backLog);
151 void SoftBusSocketFdSet(int32_t socketFd, SoftBusFdSet *set);
152 void SoftBusSocketFdClr(int32_t socketFd, SoftBusFdSet *set);
153 int32_t SoftBusSocketFdIsset(int32_t socketFd, SoftBusFdSet *set);
157 int32_t SoftBusSocketIoctl(int32_t socketFd, long cmd, void *argp);
158 int32_t SoftBusSocketFcntl(int32_t socketFd, long cmd, long flag);
169 int32_t SoftBusSocketShutDown(int32_t socketFd, int32_t how);
170 int32_t SoftBusSocketClose(int32_t socketFd);
[all …]
|
| /ohos5.0/foundation/communication/netmanager_base/services/netmanagernative/fwmarkclient/src/ |
| H A D | fwmark_client.cpp | 47 int32_t FwmarkClient::ProtectFromVpn(int32_t socketFd) in ProtectFromVpn() argument
49 if (socketFd < 0) { in ProtectFromVpn()
50 return HandleError(-1, ERROR_CODE_SOCKETFD_INVALID, socketFd); in ProtectFromVpn()
53 return Send(&command, socketFd); in ProtectFromVpn()
58 auto socketFd = socket(AF_UNIX, SOCK_STREAM | SOCK_CLOEXEC, 0); in Send() local
59 if (socketFd == -1) { in Send()
63 return HandleError(-1, ERROR_CODE_CONNECT_FAILED, socketFd); in Send()
86 int32_t ret = sendmsg(socketFd, &message, 0); in Send()
91 ret = read(socketFd, &error, sizeof(error)); in Send()
93 return HandleError(ret, ERROR_CODE_READ_FAILED, socketFd); in Send()
[all …]
|
| /ohos5.0/base/hiviewdfx/faultloggerd/test/fuzztest/faultloggerdserver_fuzzer/ |
| H A D | faultloggerdserver_fuzzer.cpp | 73 daemon->connectionMap_[socketFd[0]] = socketFd[0]; in HandleRequestTestCommon()
76 daemon->HandleRequest(0, socketFd[0]); in HandleRequestTestCommon()
81 close(socketFd[0]); in HandleRequestTestCommon()
82 close(socketFd[1]); in HandleRequestTestCommon()
86 daemon->HandleRequest(0, socketFd[0]); in HandleRequestTestCommon()
90 close(socketFd[1]); in HandleRequestTestCommon()
224 if (CheckReadResp(socketFd[1])) { in HandleRequestByPipeTypeCommon()
229 daemon->connectionMap_[socketFd[0]] = socketFd[0]; in HandleRequestByPipeTypeCommon()
232 close(socketFd[1]); in HandleRequestByPipeTypeCommon()
278 close(socketFd[1]); in FaultloggerdServerTestCallOnce()
[all …]
|
| /ohos5.0/foundation/communication/netmanager_base/services/netmanagernative/src/netsys/ |
| H A D | fwmark_network.cpp | 85 int32_t SetMark(int32_t *socketFd, FwmarkCommand *command) in SetMark() argument
87 if (command == nullptr || socketFd == nullptr) { in SetMark()
95 CloseSocket(socketFd, ret, ERROR_CODE_GETSOCKOPT_FAILED); in SetMark()
99 *socketFd, command->cmdId); in SetMark()
125 CloseSocket(socketFd, ret, NO_ERROR_CODE); in SetMark()
142 int32_t socketFd = -1; in SendMessage() local
145 char cmsg[CMSG_SPACE(sizeof(socketFd))]; in SendMessage()
158 cmsgh->cmsg_len == CMSG_LEN(sizeof(socketFd))) { in SendMessage()
159 int rst = memcpy_s(&socketFd, sizeof(socketFd), CMSG_DATA(cmsgh), sizeof(socketFd)); in SendMessage()
164 if (socketFd < 0) { in SendMessage()
[all …]
|
| /ohos5.0/foundation/communication/dsoftbus/tests/core/bus_center/mock_common/src/ |
| H A D | network_mock.cpp | 41 int32_t SoftBusSocketCreate(int32_t domain, int32_t type, int32_t protocol, int32_t *socketFd) in SoftBusSocketCreate() argument
43 return GetNetworkInterface()->SoftBusSocketCreate(domain, type, protocol, socketFd); in SoftBusSocketCreate()
46 int32_t SoftBusSocketSetOpt(int32_t socketFd, int32_t level, int32_t optName, const void *optVal, i… in SoftBusSocketSetOpt() argument
48 return GetNetworkInterface()->SoftBusSocketSetOpt(socketFd, level, optName, optVal, optLen); in SoftBusSocketSetOpt()
51 int32_t SoftBusSocketClose(int32_t socketFd) in SoftBusSocketClose() argument
53 return GetNetworkInterface()->SoftBusSocketClose(socketFd); in SoftBusSocketClose()
56 int32_t SoftBusSocketBind(int32_t socketFd, SoftBusSockAddr *addr, int32_t addrLen) in SoftBusSocketBind() argument
58 return GetNetworkInterface()->SoftBusSocketBind(socketFd, addr, addrLen); in SoftBusSocketBind()
71 int32_t SoftBusSocketRecv(int32_t socketFd, void *buf, uint32_t len, int32_t flags) in SoftBusSocketRecv() argument
73 return GetNetworkInterface()->SoftBusSocketRecv(socketFd, buf, len, flags); in SoftBusSocketRecv()
|
| /ohos5.0/foundation/filemanagement/storage_service/services/storage_daemon/netlink/test/ |
| H A D | netlink_handler_test.cpp | 31 int32_t StartSocket(int32_t& socketFd);
91 int32_t StartSocket(int32_t& socketFd) in StartSocket() argument
102 socketFd = socket(PF_NETLINK, SOCK_DGRAM | SOCK_CLOEXEC, NETLINK_KOBJECT_UEVENT); in StartSocket()
103 if (socketFd < 0) { in StartSocket()
108 if (setsockopt(socketFd, SOL_SOCKET, SO_RCVBUFFORCE, &sz, sizeof(sz)) != 0) { in StartSocket()
110 (void)close(socketFd); in StartSocket()
114 if (setsockopt(socketFd, SOL_SOCKET, SO_PASSCRED, &on, sizeof(on)) != 0) { in StartSocket()
116 (void)close(socketFd); in StartSocket()
120 if (bind(socketFd, reinterpret_cast<struct sockaddr *>(&addr), sizeof(addr)) != 0) { in StartSocket()
122 (void)close(socketFd); in StartSocket()
|
| H A D | netlink_listener_test.cpp | 31 int32_t StartSocket(int32_t& socketFd);
89 int32_t StartSocket(int32_t& socketFd) in StartSocket() argument
99 socketFd = socket(PF_NETLINK, SOCK_DGRAM | SOCK_CLOEXEC, NETLINK_KOBJECT_UEVENT); in StartSocket()
100 if (socketFd < 0) { in StartSocket()
105 if (setsockopt(socketFd, SOL_SOCKET, SO_RCVBUFFORCE, &sz, sizeof(sz)) != 0) { in StartSocket()
107 (void)close(socketFd); in StartSocket()
111 if (setsockopt(socketFd, SOL_SOCKET, SO_PASSCRED, &on, sizeof(on)) != 0) { in StartSocket()
113 (void)close(socketFd); in StartSocket()
117 if (bind(socketFd, reinterpret_cast<struct sockaddr *>(&addr), sizeof(addr)) != 0) { in StartSocket()
119 (void)close(socketFd); in StartSocket()
|
| /ohos5.0/foundation/communication/netstack/test/unittest/tlssocket/server/ |
| H A D | TlsSocketServerTest.cpp | 121 int socketFd = tlsServerSendOptions.GetSocket(); variable
138 int socketFd = tlsServerSendOptions.GetSocket(); variable
163 int socketFd = tlsServerSendOptions.GetSocket(); variable
171 server.GetRemoteAddress(socketFd, [&netAddress](int32_t errCode,
199 int socketFd = tlsServerSendOptions.GetSocket(); variable
227 int socketFd = tlsServerSendOptions.GetSocket(); variable
234 … (void)server.Close(socketFd, [](int32_t errCode) { EXPECT_TRUE(TlsSocket::TLSSOCKET_SUCCESS); }); in __anon487d28ab1302()
248 int socketFd = tlsServerSendOptions.GetSocket(); variable
269 … (void)server.Close(socketFd, [](int32_t errCode) { EXPECT_TRUE(TlsSocket::TLSSOCKET_SUCCESS); }); in __anon487d28ab1702()
285 int socketFd = tlsServerSendOptions.GetSocket(); variable
[all …]
|
| /ohos5.0/foundation/communication/netmanager_base/services/netmanagernative/src/netsys/wrapper/ |
| H A D | netlink_manager.cpp | 58 int32_t socketFd; in CreateNetlinkDistributor() local
64 if ((socketFd = socket(PF_NETLINK, SOCK_DGRAM | SOCK_CLOEXEC, netlinkType)) < 0) { in CreateNetlinkDistributor()
70 if (setsockopt(socketFd, SOL_SOCKET, SO_RCVBUFFORCE, &size, sizeof(size)) < 0 && in CreateNetlinkDistributor()
71 setsockopt(socketFd, SOL_SOCKET, SO_RCVBUF, &size, sizeof(size)) < 0) { in CreateNetlinkDistributor()
74 close(socketFd); in CreateNetlinkDistributor()
78 if (setsockopt(socketFd, SOL_SOCKET, SO_PASSCRED, &on, sizeof(on)) < 0) { in CreateNetlinkDistributor()
81 close(socketFd); in CreateNetlinkDistributor()
85 if (bind(socketFd, reinterpret_cast<sockaddr *>(&sockAddr), sizeof(sockAddr)) < 0) { in CreateNetlinkDistributor()
88 close(socketFd); in CreateNetlinkDistributor()
91 …I("CreateNetlinkDistributor netlinkType: %{public}d, socketFd: %{public}d", netlinkType, socketFd); in CreateNetlinkDistributor()
[all …]
|
| /ohos5.0/base/hiviewdfx/hilog/frameworks/libhilog/base/ |
| H A D | hilog_base.c | 39 int socketFd = TEMP_FAILURE_RETRY(socket(AF_UNIX, SOCKET_TYPE, 0)); in SendMessage() local
40 if (socketFd < 0) { in SendMessage()
42 return socketFd; in SendMessage()
46 …TEMP_FAILURE_RETRY(connect(socketFd, (const struct sockaddr *)(&SOCKET_ADDR), sizeof(SOCKET_ADDR))… in SendMessage()
49 if (socketFd >= 0) { in SendMessage()
50 close(socketFd); in SendMessage()
72 int ret = TEMP_FAILURE_RETRY(writev(socketFd, vec, LOG_LEN)); in SendMessage()
73 if (socketFd >= 0) { in SendMessage()
74 close(socketFd); in SendMessage()
|
| /ohos5.0/base/startup/appspawn/interfaces/innerkits/client/ |
| H A D | appspawn_client.c | 111 int socketFd = socket(AF_UNIX, SOCK_STREAM, 0); // SOCK_SEQPACKET in CreateClientSocket() local
112 APPSPAWN_CHECK(socketFd >= 0, return -1, in CreateClientSocket()
117 ret = setsockopt(socketFd, IPPROTO_TCP, TCP_NODELAY, (char *)&flag, sizeof(int)); in CreateClientSocket()
119 ret = setsockopt(socketFd, SOL_SOCKET, SO_PASSCRED, &flag, sizeof(flag)); in CreateClientSocket()
135 ret = connect(socketFd, (struct sockaddr *)(&addr), socketAddrLen); in CreateClientSocket()
139 return socketFd; in CreateClientSocket()
141 CloseClientSocket(socketFd); in CreateClientSocket()
145 APPSPAWN_STATIC int UpdateSocketTimeout(uint32_t timeout, int socketFd) in UpdateSocketTimeout() argument
150 ret = setsockopt(socketFd, SOL_SOCKET, SO_RCVTIMEO, &timeoutVal, sizeof(timeoutVal)); in UpdateSocketTimeout()
157 ssize_t rLen = TEMP_FAILURE_RETRY(read(socketFd, buf, len)); in ReadMessage()
[all …]
|
| /ohos5.0/foundation/communication/netmanager_base/services/netmanagernative/src/netsys/dnsresolv/ |
| H A D | dns_proxy_listen.cpp | 64 int32_t socketFd = -1; in DnsParseBySocket() local
70 if (socketFd < 0) { in DnsParseBySocket()
74 if (!PollUdpDataTransfer::MakeUdpNonBlock(socketFd)) { in DnsParseBySocket()
76 close(socketFd); in DnsParseBySocket()
81 SendRequest2Server(socketFd); in DnsParseBySocket()
130 void DnsProxyListen::SendRequest2Server(int32_t socketFd) in SendRequest2Server() argument
132 auto iter = serverIdxOfSocket.find(socketFd); in SendRequest2Server()
149 return SendRequest2Server(socketFd); in SendRequest2Server()
154 return SendRequest2Server(socketFd); in SendRequest2Server()
166 auto iter = serverIdxOfSocket.find(socketFd); in SendDnsBack2Client()
[all …]
|
| /ohos5.0/foundation/communication/netstack/interfaces/innerkits/tls_socket/include/ |
| H A D | tls_socket_server.h | 55 using OnCloseCallback = std::function<void(const int &socketFd)>;
64 void SetSocket(const int &socketFd);
119 void Close(const int socketFd, const TlsSocket::CloseCallback &callback);
132 void GetRemoteAddress(const int socketFd, const TlsSocket::GetRemoteAddressCallback &callback);
139 void GetLocalAddress(const int socketFd, const TlsSocket::GetLocalAddressCallback &callback);
180 void GetCipherSuite(const int socketFd, const TlsSocket::GetCipherSuiteCallback &callback);
377 void CallOnMessageCallback(int32_t socketFd, const std::string &data,
386 void CallOnCloseCallback(const int32_t socketFd);
470 int RecvRemoteInfo(int socketFd, int index);
471 void RemoveConnect(int socketFd);
[all …]
|
| /ohos5.0/foundation/multimodalinput/input/intention/ipc/socket/src/ |
| H A D | socket_params.cpp | 41 AllocSocketPairReply::AllocSocketPairReply(int32_t tokenType, int32_t socketFd) in AllocSocketPairReply() argument
42 : tokenType(tokenType), socketFd(socketFd) in AllocSocketPairReply()
49 parcel.WriteFileDescriptor(socketFd) in Marshalling()
56 socketFd = parcel.ReadFileDescriptor(); in Unmarshalling()
57 return (ret && (socketFd >= 0)); in Unmarshalling()
|
| /ohos5.0/base/msdp/device_status/intention/ipc/socket/src/ |
| H A D | socket_params.cpp | 41 AllocSocketPairReply::AllocSocketPairReply(int32_t tokenType, int32_t socketFd) in AllocSocketPairReply() argument
42 : tokenType(tokenType), socketFd(socketFd) in AllocSocketPairReply()
49 parcel.WriteFileDescriptor(socketFd) in Marshalling()
56 socketFd = parcel.ReadFileDescriptor(); in Unmarshalling()
57 return (ret && (socketFd >= 0)); in Unmarshalling()
|
| /ohos5.0/foundation/filemanagement/dfs_service/services/distributedfiledaemon/src/network/softbus/ |
| H A D | softbus_session.cpp | 31 int32_t socketFd = INVALID_SOCKET_FD; in SoftbusSession() local
32 int32_t ret = ::GetSessionHandle(sessionId_, &socketFd); in SoftbusSession()
33 if (ret != SOFTBUS_OK || socketFd < 0) { in SoftbusSession()
38 int32_t flags = fcntl(socketFd, F_GETFL, 0); in SoftbusSession()
44 ret = fcntl(socketFd, F_SETFL, flags); in SoftbusSession()
49 socketFd_ = socketFd; in SoftbusSession()
|
| /ohos5.0/foundation/communication/dsoftbus/tests/adapter/fuzztest/softbussocketrecv_fuzzer/ |
| H A D | softbussocketrecv_fuzzer.cpp | 68 int32_t socketFd = GetData<int32_t>(); in SoftBusSocketRecvFuzzTest() local
71 SoftBusSocketRecv(socketFd, &buf, len, flags); in SoftBusSocketRecvFuzzTest()
87 int32_t socketFd = GetData<int32_t>(); in SoftBusSocketRecvFromFuzzTest() local
93 SoftBusSocketRecvFrom(socketFd, &buf, len, flags, &fromAddr, &fromAddrLen); in SoftBusSocketRecvFromFuzzTest()
117 int32_t socketFd = GetData<int32_t>(); in SoftBusSocketSendFuzzTest() local
121 SoftBusSocketSend(socketFd, buf, len, flags); in SoftBusSocketSendFuzzTest()
145 int32_t socketFd = GetData<int32_t>(); in SoftBusSocketSendToFuzzTest() local
155 SoftBusSocketSendTo(socketFd, buf, len, flags, &toAddr, toAddrLen); in SoftBusSocketSendToFuzzTest()
|
| /ohos5.0/foundation/communication/wifi/wifi/services/wifi_standard/wifi_framework/wifi_toolkit/net_helper/ |
| H A D | raw_socket.cpp | 74 int socketFd = socket(PF_PACKET, SOCK_DGRAM, htons(protocol)); in CreateSocket() local
75 if (socketFd < 0) { in CreateSocket()
80 if (SetNonBlock(socketFd)) { in CreateSocket()
82 (void)close(socketFd); in CreateSocket()
91 int ret = bind(socketFd, reinterpret_cast<struct sockaddr *>(&rawAddr), sizeof(rawAddr)); in CreateSocket()
94 (void)close(socketFd); in CreateSocket()
97 socketFd_ = socketFd; in CreateSocket()
|
| /ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/service/src/sock/ |
| H A D | socket_service.cpp | 103 int socketFd = SOCK_INVALID_FD; in Connect() local
105 if (socket->Connect(addr, uuid, securityFlag, socketFd) < 0) { in Connect()
106 socketFd = SOCK_INVALID_FD; in Connect()
115 return socketFd; in Connect()
122 int socketFd = SOCK_INVALID_FD; in Listen() local
124 if (socket->Listen(name, uuid, securityFlag, socketFd) < 0) { in Listen()
125 socketFd = SOCK_INVALID_FD; in Listen()
133 return socketFd; in Listen()
|
| /ohos5.0/foundation/communication/netstack/frameworks/native/tls_socket/src/ |
| H A D | tls_socket_server.cpp | 157 void TLSServerSendOptions::SetSocket(const int &socketFd) in SetSocket() argument
159 socketFd_ = socketFd; in SetSocket()
289 int socketFd = data.GetSocket(); in Send() local
330 if (it->first == socketFd) { in Close()
1260 void TLSSocketServer::RemoveConnect(int socketFd) in RemoveConnect() argument
1267 if (it->second->GetSocketFd() == socketFd) { in RemoveConnect()
1286 if (it->second->GetSocketFd() == socketFd) { in RecvRemoteInfo()
1312 RemoveConnect(socketFd); in RecvRemoteInfo()
1332 CallBackfunc(socketFd, data, remoteInfo); in CallOnMessageCallback()
1355 CallBackfunc(socketFd); in CallOnCloseCallback()
[all …]
|
| /ohos5.0/foundation/communication/dsoftbus/sdk/transmission/trans_channel/udp/file/src/ |
| H A D | file_adapter.c | 137 int32_t socketFd = -1; in CreateServerSocket() local
139 socketFd = CreateServerSocketByIpv6(ip, 0); in CreateServerSocket()
141 socketFd = CreateServerSocketByIpv4(ip, 0); in CreateServerSocket()
144 if (socketFd < 0) { in CreateServerSocket()
151 ConnShutdownSocket(socketFd); in CreateServerSocket()
154 int32_t socketPort = interface->GetSockPort(socketFd); in CreateServerSocket()
157 ConnShutdownSocket(socketFd); in CreateServerSocket()
160 *fd = socketFd; in CreateServerSocket()
162 …TRANS_LOGI(TRANS_FILE, "create socket success, fd=%{public}d, port=%{public}d", socketFd, socketPo… in CreateServerSocket()
|
| /ohos5.0/foundation/communication/dsoftbus/tests/core/bus_center/mock_common/include/ |
| H A D | network_mock.h | 46 …int32_t SoftBusSocketCreate(int32_t domain, int32_t type, int32_t protocol, int32_t *socketFd) = 0;
48 int32_t socketFd, int32_t level, int32_t optName, const void *optVal, int32_t optLen) = 0;
49 virtual int32_t SoftBusSocketClose(int32_t socketFd) = 0;
50 virtual int32_t SoftBusSocketBind(int32_t socketFd, SoftBusSockAddr *addr, int32_t addrLen) = 0;
53 virtual int32_t SoftBusSocketRecv(int32_t socketFd, void *buf, uint32_t len, int32_t flags) = 0;
|
| /ohos5.0/foundation/ability/ability_runtime/test/unittest/connect_server_manager_test/ |
| H A D | connect_server_manager_test.cpp | 67 uint32_t socketFd = 0; variable
68 connectServerManager.StartConnectServer(bundleName, socketFd, true);
174 uint32_t socketFd = 0; variable
175 connectServerManager.StartConnectServer(bundleName, socketFd, true);
192 uint32_t socketFd = 0; variable
193 connectServerManager.StartConnectServer(bundleName, socketFd, true);
211 uint32_t socketFd = 0; variable
212 connectServerManager.StartConnectServer(bundleName, socketFd, true);
|