Home
last modified time | relevance | path

Searched refs:sock (Results 1 – 25 of 113) sorted by relevance

12345

/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/app_lib/src/
H A Dsocket_app.c129 sockMsg.sock = (void *)sock; in SockSocket()
152 return sock->index; in SockSocket()
308 return sock; in SocketGetForDataTrans()
863 return sock; in SockApiGetAndCheckListenState()
944 return sock; in SockAcceptGetAndCheck()
1078 SOCK_DESTROY_CONN(&sock->sockConnSem, conn, sock, FILLP_ENOMEM); in SockAccept()
1216 shutdownMsg.sock = sock; in SockShutdown()
1345 connectMsg.sock = (void *)sock; in SockConnect()
1398 bindMsg.sock = (void *)sock; in SockBind()
1552 return sock; in SockGetnameCheckParam()
[all …]
H A Dspunge_app.c28 (void)memset_s(sock->coreErrType, sizeof(sock->coreErrType), 0, sizeof(sock->coreErrType)); in SpungeInitSocket()
30 sock->listenBacklog = 0; in SpungeInitSocket()
56 sock->offset = 0; in SpungeInitSocket()
58 sock->dataOptionFlag = 0; in SpungeInitSocket()
62 sock->transmit = 0; in SpungeInitSocket()
63 sock->jitter = 0; in SpungeInitSocket()
65 sock->flags = 0; in SpungeInitSocket()
73 (void)memset_s(&sock->fillpLinger, sizeof(sock->fillpLinger), 0, sizeof(sock->fillpLinger)); in SpungeInitSocket()
74 sock->directlySend = 0; in SpungeInitSocket()
111 return sock; in SpungeAllocSock()
[all …]
H A Dsocket_opt.c34 if ((sock->netconn == FILLP_NULL_PTR) || (sock->netconn->state != CONN_STATE_CONNECTED)) { in SockGetOptSendCache()
109 if (sock == FILLP_NULL_PTR) { in SockGetSockOpt()
132 *(int *)optVal = sock->err; in SockGetSockOpt()
133 sock->err = ERR_OK; in SockGetSockOpt()
137 osSock = NETCONN_GET_OSSOCK(sock->netconn, sock->inst->instIndex); in SockGetSockOpt()
228 NetconnSetRecvCacheSize(sock->netconn, sock->resConf.common.recvCache); in SockSetFcAlg()
229 NetconnSetSendCacheSize(sock->netconn, sock->resConf.common.sendCache); in SockSetFcAlg()
260 FILLP_LOGBUTT("fillp sock id: %d, set directlySend to %d", sock->index, sock->directlySend); in SockSetOptDirectlySend()
312 sock = SockApiGetAndCheck(sockIndex); in SockSetSockOpt()
313 if (sock == FILLP_NULL_PTR) { in SockSetSockOpt()
[all …]
H A Depoll_app.c102 struct FtSocket *sock, in EpollCtlTriggleEvent() argument
147 struct FtSocket *sock, in EpModify() argument
240 if ((sock == FILLP_NULL_PTR) || (sock->allocState == SOCK_ALLOC_STATE_EPOLL)) { in EpRemove()
326 struct FtSocket *sock, in EpPoll() argument
561 struct FtSocket *sock, in SpungeEpollCtlHandleAddEvent() argument
599 sock->associatedEpollInstanceArr[sock->associatedEpollInstanceIdx++] = epFd; in SpungeEpollCtlHandleAddEvent()
607 struct FtSocket *sock, in SpungeEpollCtlHandleDelEvent() argument
637 struct FtSocket *sock, in SpungeEpollCtlHandleModEvent() argument
797 struct FtSocket *sock; in SpungeEpollWait() local
862 sock->errEvent = 0; in SpungeEpollCreate()
[all …]
H A Dfillp_stack_app_config.c35 struct FtSocket *sock = FILLP_NULL_PTR; in FtGetRightAppResourceByIndex() local
37 sock = SockGetSocket(sockIndex); in FtGetRightAppResourceByIndex()
38 if (sock == FILLP_NULL_PTR) { in FtGetRightAppResourceByIndex()
54 *resource = &sock->resConf; in FtGetRightAppResourceByIndex()
159 sock = SockGetSocket(sockIndex); in FtAppInitConfigSet()
234 if (sock == FILLP_NULL_PTR) { in FtAppInitConfigGet()
297 if (sock == FILLP_NULL_PTR) { in FtSetConfigApp()
319 resource = &sock->resConf; in FtSetConfigApp()
333 if ((sock->netconn == FILLP_NULL_PTR) || (sock->allocState == SOCK_ALLOC_STATE_FREE)) { in FtCheckSockValid()
435 resource = &sock->resConf; in FtGetSockValue()
[all …]
H A Dfillp_stack_app_config_in.c349 if ((sock != FILLP_NULL_PTR) && (sock->netconn != FILLP_NULL_PTR) && in FtAppConfigSetSendCache()
376 if ((sock != FILLP_NULL_PTR) && (sock->netconn != FILLP_NULL_PTR) && in FtAppConfigSetRecvCache()
440 if ((sock != FILLP_NULL_PTR) && (sock->netconn != FILLP_NULL_PTR) && in FtAppConfigSetOppositeSetRate()
468 if ((sock != FILLP_NULL_PTR) && (sock->dataOptionFlag != FILLP_NULL)) { in FtAppConfigSetPktSize()
476 if ((sock != FILLP_NULL_PTR) && (sock->netconn != FILLP_NULL_PTR) && in FtAppConfigSetPktSize()
499 struct FtSocket *sock) in FtAppConfigSetSendBufSize() argument
534 struct FtSocket *sock) in FtAppConfigSetRecvBufSize() argument
577 if ((sock != FILLP_NULL_PTR) && (sock->netconn != FILLP_NULL_PTR) && in FtAppConfigSetSlowStart()
602 if (FILLP_INVALID_PTR(sock) || FILLP_INVALID_PTR(sock->netconn)) { in FtAppConfigSetMaxRate()
656 struct FtSocket *sock) in FtAppEnlargePackInterval() argument
[all …]
H A Dfillp_dfx.c320 FillpDfxSockQosNotify(sock); in FillpDfxSockLinkAndQosNotify()
490 if (sock == FILLP_NULL_PTR) { in FillpDumpShowSockResource()
560 struct FtSocket *sock = FILLP_NULL_PTR; in FillpDumpShowSockList() local
576 sock = SockApiGetAndCheck(i); in FillpDumpShowSockList()
577 if (sock == FILLP_NULL_PTR) { in FillpDumpShowSockList()
580 if (sock->netconn == FILLP_NULL_PTR || sock->netconn->pcb == FILLP_NULL_PTR) { in FillpDumpShowSockList()
621 sock->jitter); in DoShowSockQos()
629 …if (sock == FILLP_NULL_PTR || sock->netconn == FILLP_NULL_PTR || sock->netconn->pcb == FILLP_NULL_… in FillpDfxGetSock()
630 if (sock != FILLP_NULL_PTR) { in FillpDfxGetSock()
638 return sock; in FillpDfxGetSock()
[all …]
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/public/src/
H A Dspunge_message.c78 struct FtSocket *sock = (struct FtSocket *)msg->sock; in SpungeHandleMsgAllocSock() local
94 … sock->resConf.common.sendCache, sock->resConf.common.recvCache, sock->resConf.flowControl.pktSize, in SpungeHandleMsgAllocSock()
95 …sock->resConf.flowControl.oppositeSetRate, sock->resConf.flowControl.slowStart, sock->sockAddrType… in SpungeHandleMsgAllocSock()
178 *pSock = sock; in SpungeListenMsgCheckState()
259 struct FtSocket *sock = (struct FtSocket *)connMsg->sock; in SpungeConnMsgGetSock() local
262 *pSock = sock; in SpungeConnMsgGetSock()
331 NetconnSetDirectlySend(sock->netconn, sock->directlySend); in SpungeHandleMsgConnect()
333 SpungeStartConnRetryTimer(&sock->netconn->pcb->fpcb, sock); in SpungeHandleMsgConnect()
432 sock = (struct FtSocket *)bindMsg->sock; in SpungeHandleMsgBind()
566 sock = (struct FtSocket *)shutdownMsg->sock; in SpungeHandleMsgDoShutdown()
[all …]
H A Dsocket_common.c26 struct FtSocket *sock; in EpollUpdateEpEvent() local
29 if (sock == FILLP_NULL_PTR) { in EpollUpdateEpEvent()
164 if (sock == FILLP_NULL_PTR) { in SockFreeSocket()
173 struct FtSocket *sock; in SpungeInitSocket() local
176 sock->index = tableIndex; in SpungeInitSocket()
274 return sock; in SockAllocSocket()
294 return sock; in SockGetSocket()
319 return sock; in SockApiGetAndCheck()
324 if ((sock->netconn == FILLP_NULL_PTR) || (sock->netconn->shutdownWrSet)) { in SockCanSendData()
339 if ((sock->netconn == FILLP_NULL_PTR) || sock->netconn->shutdownRdSet) { in SockCanRecvData()
[all …]
H A Dfillp_os.c79 FILLP_INT SysArchSetSockBlocking(FILLP_INT sock, FILLP_BOOL blocking) in SysArchSetSockBlocking() argument
83 if (sock < 0) { in SysArchSetSockBlocking()
87 flags = FILLP_FCNTL(sock, F_GETFL, 0); in SysArchSetSockBlocking()
93 if (FILLP_FCNTL(sock, F_SETFL, flags) < 0) { in SysArchSetSockBlocking()
102 FILLP_INT SysArchSetSockBlocking(FILLP_INT sock, FILLP_BOOL blocking) in SysArchSetSockBlocking() argument
105 if (sock < 0) { in SysArchSetSockBlocking()
109 return FILLP_IOCTLSOCKET(sock, (FILLP_INT)FIONBIO, &mode); in SysArchSetSockBlocking()
133 FILLP_INT SysArchSetSockSndbuf(FILLP_INT sock, FILLP_UINT size) in SysArchSetSockSndbuf() argument
135 if (sock < 0) { in SysArchSetSockSndbuf()
142 FILLP_INT SysArchSetSockRcvbuf(FILLP_INT sock, FILLP_UINT size) in SysArchSetSockRcvbuf() argument
[all …]
H A Dspunge.c35 void SpungeEpollAppRecvOne(struct FtSocket *sock) in SpungeEpollAppRecvOne() argument
37 (void)SYS_ARCH_ATOMIC_DEC(&sock->rcvEvent, 1); in SpungeEpollAppRecvOne()
40 void SpungeEpollEventCallback(struct FtSocket *sock, FILLP_INT event, FILLP_INT count) in SpungeEpollEventCallback() argument
42 if (sock == FILLP_NULL_PTR) { in SpungeEpollEventCallback()
48 (void)SYS_ARCH_ATOMIC_INC(&sock->rcvEvent, count); in SpungeEpollEventCallback()
52 (void)SYS_ARCH_ATOMIC_SET(&sock->sendEvent, 1); in SpungeEpollEventCallback()
55 … sock->errEvent |= ((FILLP_UINT32)event & (SPUNGE_EPOLLRDHUP | SPUNGE_EPOLLHUP | SPUNGE_EPOLLERR)); in SpungeEpollEventCallback()
57 if ((sock->netconn != FILLP_NULL_PTR) && (!sock->netconn->closeSet)) { in SpungeEpollEventCallback()
58 if (SYS_ARCH_ATOMIC_READ(&sock->epollWaiting) > 0) { in SpungeEpollEventCallback()
59 EpollEventCallback(sock, (FILLP_UINT32)event); in SpungeEpollEventCallback()
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/
H A Dspunge_stack.c103 sock->errEvent = 0; in SpungeEpollFreeResource()
129 sock->freeTimeCount++; in SpungeIncFreeCntPostEagain()
131 sock->index, sock->freeTimeCount, FT_OS_GET_ERRNO); in SpungeIncFreeCntPostEagain()
228 sock->flags = 0; in SpungEpollClose()
229 sock->traceFlag = 0; in SpungEpollClose()
254 if ((sock == FILLP_NULL_PTR) || (sock->allocState == SOCK_ALLOC_STATE_FREE)) { in SpungeFreeSock()
291 sock->flags = 0; in SpungeFreeSock()
292 sock->traceFlag = 0; in SpungeFreeSock()
393 struct FtSocket *sock = (struct FtSocket *)conn->sock; in SpungeCheckDisconn() local
454 struct FtSocket *sock = (struct FtSocket *)conn->sock; in SpungeSendConnectMsg() local
[all …]
/ohos5.0/foundation/communication/netstack/frameworks/js/napi/socket/socket_exec/include/
H A Dsocket_exec_common.h28 static bool MakeNonBlock(int sock) in MakeNonBlock() argument
56 if (sock < 0) {
61 close(sock);
64 return sock;
74 if (sock < 0) { in MakeUdpSocket()
78 if (!MakeNonBlock(sock)) { in MakeUdpSocket()
79 close(sock); in MakeUdpSocket()
82 return sock; in MakeUdpSocket()
89 if (sock < 0) {
94 close(sock);
[all …]
/ohos5.0/foundation/communication/netmanager_ext/services/mdnsmanager/src/
H A Dmdns_socket_listener.cpp63 int InitFdFlags(int sock) in InitFdFlags() argument
75 int InitReusedSocket(int sock) in InitReusedSocket() argument
84 return sock; in InitReusedSocket()
92 if (sock < 0) { in InitSocketV4()
134 return InitFdFlags(sock); in InitSocketV4()
142 if (sock < 0) { in InitSocketV6()
185 return InitFdFlags(sock); in InitSocketV6()
295 if (sock < 0) { in OpenSocketV4()
301 close(sock); in OpenSocketV4()
327 if (sock < 0) { in OpenSocketV6()
[all …]
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/fillp/
H A Dfillp_conn.c568 struct FtSocket *sock = (struct FtSocket *)conn->sock; in FillpInitNewConnByConfirm() local
636 struct FtSocket *sock = (struct FtSocket *)conn->sock; in FillpProcessConnConfirm() local
751 struct FtSocket *sock = (struct FtSocket *)conn->sock; in FillpConnConfirmInput() local
798 sock->index, sock->listenBacklog); in FillpConnConfirmInput()
900 sock = (struct FtSocket *)conn->sock; in FillpConnConnectionEstFailure()
989 struct FtSocket *sock = (struct FtSocket *)conn->sock; in FillpCheckConfirmAckPar() local
1049 struct FtSocket *sock = (struct FtSocket *)conn->sock; in FillpConnConfirmAckInput() local
1231 sock = (struct FtSocket *)conn->sock; in FillpHandleFin()
1307 sock = (struct FtSocket *)conn->sock; in FillpFinInput()
1380 struct FtSocket *sock = (struct FtSocket *)conn->sock; in FillpSendConnReq() local
[all …]
H A Dfillp_flow_control.c167 struct FtSocket *sock = FILLP_GET_SOCKET(pcb); in FillpCalSendInterval() local
169 if (sock->resConf.flowControl.constRateEnbale) { in FillpCalSendInterval()
170 flowControl->sendRate = sock->resConf.flowControl.maxRate; in FillpCalSendInterval()
366 struct FtSocket *sock; in FillpFcCycle() local
368 sock = (struct FtSocket *)netconn->sock; in FillpFcCycle()
370 if (sock->isListenSock) { in FillpFcCycle()
379 sock->index, detaTime, sock->resConf.common.keepAliveTime); in FillpFcCycle()
381 FillpDfxSockLinkAndQosNotify(sock, FILLP_DFX_LINK_KEEPALIVE_TIMEOUT); in FillpFcCycle()
382 SpungeShutdownSock(sock, SPUNGE_SHUT_RDWR); in FillpFcCycle()
383 sock->errEvent |= SPUNGE_EPOLLERR; in FillpFcCycle()
[all …]
/ohos5.0/foundation/communication/wifi/wifi/base/cRPC/src/
H A Dnet.c111 if (sock < 0) { in CreateSocket()
115 return sock; in CreateSocket()
129 if (sock < 0) { in CreateUnixServer()
145 close(sock); in CreateUnixServer()
148 if (SetNonBlock(sock, 1) != 0) { in CreateUnixServer()
150 close(sock); in CreateUnixServer()
156 close(sock); in CreateUnixServer()
159 return sock; in CreateUnixServer()
173 if (sock < 0) { in ConnectUnixServer()
178 close(sock); in ConnectUnixServer()
[all …]
/ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/service/src/sock/
H A Dsocket_listener.cpp89 fdMap_[&sock] = fd; in AddSocket()
94 event.data.ptr = &sock; in AddSocket()
133 readCallback_(sock); in OnListenEvents()
136 int fd = FindFd(sock); in OnListenEvents()
138 writeCallback_(sock); in OnListenEvents()
150 DeleteFd(sock); in OnListenEvents()
153 exceptCallback_(sock); in OnListenEvents()
164 fd = fdMap_.at(&sock); in FindFd()
174 fdMap_.erase(&sock); in DeleteFd()
179 int fd = FindFd(sock); in DeleteSocket()
[all …]
/ohos5.0/foundation/communication/netmanager_base/services/netmanagernative/src/netsys/
H A Dnetsys_tcp_client.c28 bool MakeNonBlock(int sock) in MakeNonBlock() argument
30 int flags = fcntl(sock, F_GETFL, 0); in MakeNonBlock()
32 flags = fcntl(sock, F_GETFL, 0); in MakeNonBlock()
39 int ret = fcntl(sock, F_SETFL, tempFlags); in MakeNonBlock()
41 ret = fcntl(sock, F_SETFL, tempFlags); in MakeNonBlock()
60 int64_t Poll(int sock, short event, int *retry) in Poll() argument
64 fds[0].fd = sock; in Poll()
90 int32_t resPoll = Poll(sock, event, &retry); in ProcData()
97 int64_t length = func(sock, curPos, leftSize); in ProcData()
120 bool PollSendData(int sock, const char *data, size_t size) in PollSendData() argument
[all …]
H A Dnetsys_udp_transfer.cpp25 int32_t sock; member
37 length = func(udpBuffer.sock, curPos, leftSize, udpBuffer.addr, lenAddr); in ProcUdpData()
61 bool PollUdpDataTransfer::MakeUdpNonBlock(int32_t sock) in MakeUdpNonBlock() argument
63 if (sock < 0) { in MakeUdpNonBlock()
66 return MakeNonBlock(sock); in MakeUdpNonBlock()
68 int32_t PollUdpDataTransfer::PollUdpSendData(int32_t sock, char *data, size_t size, AlignedSockAddr… in PollUdpSendData() argument
73 udpBuffer.sock = sock; in PollUdpSendData()
78 int32_t PollUdpDataTransfer::PollUdpRecvData(int32_t sock, char *data, size_t size, AlignedSockAddr… in PollUdpRecvData() argument
83 udpBuffer.sock = sock; in PollUdpRecvData()
/ohos5.0/drivers/peripheral/wlan/chip/hdi_service/
H A Diface_tool.cpp43 bool GetIfState(const char* ifName, int sock, struct ifreq* ifr) in GetIfState() argument
54 if (TEMP_FAILURE_RETRY(ioctl(sock, SIOCGIFFLAGS, ifr)) != 0) { in GetIfState()
63 UniqueFd sock(socket(PF_INET, SOCK_DGRAM | SOCK_CLOEXEC, 0)); in GetUpState() local
64 if (sock.Get() < 0) { in GetUpState()
69 if (!GetIfState(ifName, sock.Get(), &ifr)) { in GetUpState()
77 UniqueFd sock(socket(PF_INET, SOCK_DGRAM | SOCK_CLOEXEC, 0)); in SetUpState() local
78 if (sock.Get() < 0) { in SetUpState()
83 if (!GetIfState(ifName, sock.Get(), &ifr)) { in SetUpState()
117 UniqueFd sock(socket(PF_INET, SOCK_DGRAM | SOCK_CLOEXEC, 0)); in SetMacAddress() local
118 if (sock.Get() < 0) { in SetMacAddress()
[all …]
/ohos5.0/foundation/communication/netmanager_base/test/netmanagernative/unittest/netsys_manager_test/
H A Dnetsys_udp_transfer_test.cpp46 int32_t sock = 34343; variable
53 int32_t ret = PollUdpDataTransfer::PollUdpSendData(sock, data, size, addr, addrLen);
59 int32_t sock = 34343; variable
66 int32_t ret = PollUdpDataTransfer::PollUdpSendData(sock, data, size, addr, addrLen);
72 int32_t sock = 34343; variable
78 …int32_t ret = PollUdpDataTransfer::PollUdpRecvData(sock, requesData, MAX_REQUESTDATA_LEN, addr, ad…
84 int32_t sock = 34343; variable
96 int32_t sock = -1; variable
97 bool ret = PollUdpDataTransfer::MakeUdpNonBlock(sock);
103 int32_t sock = 34343; variable
[all …]
/ohos5.0/foundation/communication/netmanager_base/services/netmanagernative/src/netsys/dnsresolv/
H A Ddns_proxy_request_socket.cpp21 DnsProxyRequestSocket::DnsProxyRequestSocket(int32_t sock, std::unique_ptr<AlignedSockAddr> &&clien… in DnsProxyRequestSocket() argument
25 this->sock = sock; in DnsProxyRequestSocket()
26 event.data.fd = sock; in DnsProxyRequestSocket()
35 NETNATIVE_LOG_D("dns_proxy_listen ~DnsProxyRequestSocket sock: %{public}d", sock); in ~DnsProxyRequestSocket()
36 if (sock > 0) { in ~DnsProxyRequestSocket()
37 close(sock); in ~DnsProxyRequestSocket()
43 return sock; in GetSock()
/ohos5.0/base/startup/init/services/init/standard/
H A Dinit.c47 int sock = -1; in FdHolderSockInit() local
50 sock = socket(AF_UNIX, SOCK_DGRAM | SOCK_CLOEXEC | SOCK_NONBLOCK, 0); in FdHolderSockInit()
51 if (sock < 0) { in FdHolderSockInit()
57 setsockopt(sock, SOL_SOCKET, SO_PASSCRED, &on, sizeof(on)); in FdHolderSockInit()
68 close(sock); in FdHolderSockInit()
72 if (bind(sock, (struct sockaddr *)&addr, len) < 0) { in FdHolderSockInit()
74 close(sock); in FdHolderSockInit()
87 return sock; in FdHolderSockInit()
100 int sock = FdHolderSockInit(); in SystemInit() local
101 if (sock >= 0) { in SystemInit()
[all …]
H A Dfd_holder_service.c58 static void SendErrorInfo(int sock, const char *errInfo, const char *serviceName) in SendErrorInfo() argument
86 if (TEMP_FAILURE_RETRY(sendmsg(sock, &msghdr, MSG_NOSIGNAL)) < 0) { in SendErrorInfo()
118 static void HandlerFdHolder(int sock) in HandlerFdHolder() argument
127 int *fds = ReceiveFds(sock, iovec, &fdCount, true, &requestPid); in HandlerFdHolder()
145 SendErrorInfo(sock, "Invalid service", serviceName); in HandlerFdHolder()
172 void RegisterFdHoldWatcher(int sock) in RegisterFdHoldWatcher() argument
174 if (sock < 0) { in RegisterFdHoldWatcher()
181 info.fd = sock; in RegisterFdHoldWatcher()

12345