| /foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/fillp/ |
| H A D | fillp_timer.c | 46 struct FtSocket *sock = FILLP_GET_SOCKET(pcb); in FillpCalFcAppStastics() local
54 if (appFcStastics->periodTimePassed < (FILLP_LLONG)(sock->resConf.common.fcStasticsInterval)) { in FillpCalFcAppStastics()
151 struct FtSocket *sock = FILLP_GET_SOCKET(pcb); in FillpPackTimerCb() local
170 (curTime - pack->packRttDetectTime) > (FILLP_LLONG)(sock->resConf.common.fcStasticsInterval)) { in FillpPackTimerCb()
|
| H A D | fillp_flow_control_alg0.c | 211 struct FtSocket *sock = FILLP_GET_SOCKET(pcb); in FillpAlg0PackStateProcess() local
230 FILLP_LOGDTL("fillp_sock_id:%d fcState:%u wrong", sock->index, alg->fcState); in FillpAlg0PackStateProcess()
|
| H A D | fillp_pcb.c | 646 struct FtSocket *sock = FILLP_GET_SOCKET(pcb); in FillpInitPcbTimeNode() local
664 pcb->keepAliveTimerNode.interval = FILLP_UTILS_MS2US(sock->resConf.common.keepAliveTime); in FillpInitPcbTimeNode()
755 FILLP_CONST struct FtSocket *sock = FILLP_GET_SOCKET(pcb); in FillpGetSockPackInterval() local
756 return sock->resConf.flowControl.packInterval; in FillpGetSockPackInterval()
|
| /foundation/communication/netstack/frameworks/js/napi/socket/async_context/src/ |
| H A D | local_socket_server_context.cpp | 34 void LocalSocketServerBaseContext::SetSocketFd(int sock) in SetSocketFd() argument
41 pManagerInfo->sockfd_ = sock; in SetSocketFd()
|
| H A D | local_socket_context.cpp | 33 void LocalSocketBaseContext::SetSocketFd(int sock) in SetSocketFd() argument
39 pMgr->sockfd_ = sock; in SetSocketFd()
|
| /foundation/communication/netstack/frameworks/js/napi/tls/src/ |
| H A D | tls_socket.cpp | 147 static bool SetSockBlockFlag(int sock, bool noneBlock) in SetSockBlockFlag() argument
149 int flags = fcntl(sock, F_GETFL, 0); in SetSockBlockFlag()
151 flags = fcntl(sock, F_GETFL, 0); in SetSockBlockFlag()
154 NETSTACK_LOGE("set block flags failed, socket is %{public}d, errno is %{public}d", sock, errno); in SetSockBlockFlag()
165 int ret = fcntl(sock, F_SETFL, newFlags); in SetSockBlockFlag()
167 ret = fcntl(sock, F_SETFL, newFlags); in SetSockBlockFlag()
170 NETSTACK_LOGE("set block flags failed, socket is %{public}d, errno is %{public}d", sock, errno); in SetSockBlockFlag()
399 int sock = socket(family, SOCK_STREAM, IPPROTO_IP); in MakeIpSocket() local
400 if (sock < 0) { in MakeIpSocket()
406 sockFd_ = sock; in MakeIpSocket()
1176 TlsConnectToHost(int sock, const TLSConnectOptions &options, bool isExtSock) TlsConnectToHost() argument
[all...] |
| H A D | tls_socket_server.cpp | 645 int sock = socket(family, SOCK_STREAM, IPPROTO_IP);
in MakeIpSocket() local
646 if (sock < 0) {
in MakeIpSocket()
652 listenSocketFd_ = sock;
in MakeIpSocket()
758 bool TLSSocketServer::Connection::TlsAcceptToHost(int sock, const TlsSocket::TLSConnectOptions &options)
in TlsAcceptToHost() argument
774 socketFd_ = sock;
in TlsAcceptToHost()
|
| /foundation/communication/netstack/test/unittest/tls_test/client/ |
| H A D | TlsSocketTest.cpp | 430 int sock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
in HWTEST_F() local
431 EXPECT_TRUE(sock > 0);
in HWTEST_F()
440 int ret = connect(sock, reinterpret_cast<sockaddr *>(&addr4), sizeof(sockaddr_in));
in HWTEST_F()
443 TLSSocket testService(sock);
in HWTEST_F()
|
| /foundation/communication/netstack/test/unittest/tlssocket/client/ |
| H A D | TlsSocketTest.cpp | 430 int sock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP); in HWTEST_F() local
431 EXPECT_TRUE(sock > 0); in HWTEST_F()
440 int ret = connect(sock, reinterpret_cast<sockaddr *>(&addr4), sizeof(sockaddr_in)); in HWTEST_F()
443 TLSSocket testService(sock); in HWTEST_F()
|
| /foundation/communication/netmanager_base/services/netmanagernative/src/netsys/ |
| H A D | clat_utils.cpp | 344 int AddFilterAndBindPacketSocket(const int sock, const in6_addr *const addr, const int ifIndex) in AddFilterAndBindPacketSocket() argument
363 if (setsockopt(sock, SOL_SOCKET, SO_ATTACH_FILTER, &filterProg, sizeof(filterProg))) { in AddFilterAndBindPacketSocket()
375 if (bind(sock, reinterpret_cast<sockaddr *>(&sll), sizeof(sll))) { in AddFilterAndBindPacketSocket()
|
| /foundation/communication/dsoftbus/components/nstackx/nstackx_ctrl/core/coap_discover/ |
| H A D | coap_client.c | 199 if (needBind && BindToDevice(ep->sock.fd, sockIpPtr) != NSTACKX_EOK) { in CoapGetContextEx()
337 if (iterator->sock.fd == fd) { in IsCoapCtxEndpointSocket()
|
| /foundation/communication/netstack/frameworks/js/napi/socket/async_context/include/ |
| H A D | local_socket_context.h | 55 virtual void SetSocketFd(int sock);
|
| H A D | local_socket_server_context.h | 226 void SetSocketFd(int sock) override;
|
| /foundation/communication/netstack/frameworks/js/napi/socket/socket_exec/include/ |
| H A D | socket_exec.h | 273 virtual bool OnMessage(int sock, void *data, size_t dataLen, sockaddr *addr, EventManager *manager) const = 0;
|
| /foundation/communication/dsoftbus/components/nstackx/nstackx_core/dfile/include/ |
| H A D | nstackx_dfile_session.h | 185 int32_t CheckFdSetSize(SocketDesc sock);
|
| /foundation/communication/netstack/interfaces/innerkits/tls_socket/include/ |
| H A D | tls_socket_server.h | 233 * @param sock socket for establishing encrypted connection
237 bool TlsAcceptToHost(int sock, const TlsSocket::TLSConnectOptions &options);
|
| H A D | tls_socket.h | 449 * @param sock socket for establishing encrypted connection
454 bool TlsConnectToHost(int sock, const TLSConnectOptions &options, bool isExtSock);
|
| /foundation/communication/dhcp/services/dhcp_server/src/ |
| H A D | dhcp_s_server.cpp | 256 int ReceiveDhcpMessage(int sock, PDhcpMsgInfo msgInfo) in ReceiveDhcpMessage() argument
262 FD_SET(sock, &recvFd); in ReceiveDhcpMessage()
265 int ret = select(sock + 1, &recvFd, nullptr, nullptr, &tmt); in ReceiveDhcpMessage()
273 if (!FD_ISSET(sock, &recvFd)) { in ReceiveDhcpMessage()
281 int rsize = recvfrom(sock, recvBuffer, RECV_BUFFER_SIZE, 0, (struct sockaddr *)srcAddrIn, (socklen_t *)&ssize); in ReceiveDhcpMessage()
|