Home
last modified time | relevance | path

Searched refs:netconn (Results 1 – 19 of 19) sorted by relevance

/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/public/src/
H A Dspunge_message.c115 sock->netconn->lastErr = ERR_OK; in SpungeHandleMsgAllocSock()
154 netconn = sock->netconn; in SpungeListenMsgCheckState()
155 netState = NETCONN_GET_STATE(netconn); in SpungeListenMsgCheckState()
270 …err = memcpy_s(&sock->netconn->pcb->remoteAddr, sizeof(sock->netconn->pcb->remoteAddr), connMsg->a… in SpungeConnMsgGetSock()
376 conn = sock->netconn; in SpungeBindMsgCheckState()
489 netconn = (struct FtNetconn *)acceptMsg->netconn; in SpungeHandleMsgConnAccepted()
509 NetconnSetSock(sock, netconn); in SpungeHandleMsgConnAccepted()
527 … netconn->pcb->fpcb.recv.seqNum, netconn->pcb->fpcb.recv.pktNum, sock->resConf.flowControl.maxRate, in SpungeHandleMsgConnAccepted()
567 conn = sock->netconn; in SpungeHandleMsgDoShutdown()
683 conn = sock->netconn; in SpungeHandleMsgClose()
[all …]
H A Dsocket_common.c324 if ((sock->netconn == FILLP_NULL_PTR) || (sock->netconn->shutdownWrSet)) { in SockCanSendData()
328 int netConnState = NETCONN_GET_STATE(sock->netconn); in SockCanSendData()
339 if ((sock->netconn == FILLP_NULL_PTR) || sock->netconn->shutdownRdSet) { in SockCanRecvData()
343 int netConnState = NETCONN_GET_STATE(sock->netconn); in SockCanRecvData()
368 if ((sock->netconn != FILLP_NULL_PTR) && (sock->netconn->pcb != FILLP_NULL_PTR) && in SockUpdatePktDataOpt()
H A Dspunge.c57 if ((sock->netconn != FILLP_NULL_PTR) && (!sock->netconn->closeSet)) { in SpungeEpollEventCallback()
66 ftSock->netconn->osSocket[SPUNGE_GET_CUR_INSTANCE()->instIndex] = osSock; in SockSetOsSocket()
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/app_lib/src/
H A Dfillp_stack_app_config.c256 if (sock->netconn != FILLP_NULL_PTR) { in FtInnerValidateAppConfigSet()
332 struct FtNetconn *netconn = FILLP_NULL_PTR; in FtCheckSockValid() local
338 netconn = (struct FtNetconn *)(sock->netconn); in FtCheckSockValid()
339 if (netconn->pcb == FILLP_NULL_PTR) { in FtCheckSockValid()
349 struct FtNetconn *netconn = FILLP_NULL_PTR; in FtGetAppFcPeriodRecvRate() local
354 netconn = (struct FtNetconn *)(sock->netconn); in FtGetAppFcPeriodRecvRate()
363 struct FtNetconn *netconn = FILLP_NULL_PTR; in FtGetAppFcPeriodRecvRateBps() local
368 netconn = (struct FtNetconn *)(sock->netconn); in FtGetAppFcPeriodRecvRateBps()
376 struct FtNetconn *netconn = FILLP_NULL_PTR; in FtGetAppFcPeriodRecvPktLost() local
381 netconn = (struct FtNetconn *)(sock->netconn); in FtGetAppFcPeriodRecvPktLost()
[all …]
H A Dsocket_opt.c34 if ((sock->netconn == FILLP_NULL_PTR) || (sock->netconn->state != CONN_STATE_CONNECTED)) { in SockGetOptSendCache()
41 sendPcb = &(sock->netconn->pcb->fpcb.send); in SockGetOptSendCache()
128 int errToErrno = FillpErrToErrno(sock->netconn->lastErr); in SockGetSockOpt()
137 osSock = NETCONN_GET_OSSOCK(sock->netconn, sock->inst->instIndex); in SockGetSockOpt()
198 if (sock->netconn == FILLP_NULL_PTR) { in SockSetFcAlg()
203 connState = NETCONN_GET_STATE(sock->netconn); in SockSetFcAlg()
209 if (sock->netconn->pcb == FILLP_NULL_PTR) { in SockSetFcAlg()
221 sock->netconn->pcb->fpcb.fcAlg = (FILLP_UINT8)FILLP_SUPPORT_ALG_N(alg); in SockSetFcAlg()
223 sock->netconn->pcb->fpcb.fcAlg = FILLP_SUPPORT_ALG_BASE; in SockSetFcAlg()
228 NetconnSetRecvCacheSize(sock->netconn, sock->resConf.common.recvCache); in SockSetFcAlg()
[all …]
H A Dfillp_stack_app_config_in.c246 if ((sock->netconn != FILLP_NULL_PTR) && (sock->netconn->state == CONN_STATE_CONNECTED)) { in FtAppSetKeepAliveTime()
350 (sock->netconn->pcb != FILLP_NULL_PTR) && (sock->netconn->state == CONN_STATE_IDLE)) { in FtAppConfigSetSendCache()
377 (sock->netconn->pcb != FILLP_NULL_PTR) && (sock->netconn->state == CONN_STATE_IDLE)) { in FtAppConfigSetRecvCache()
441 (sock->netconn->pcb != FILLP_NULL_PTR)) { in FtAppConfigSetOppositeSetRate()
477 … (sock->netconn->pcb != FILLP_NULL_PTR) && (sock->netconn->state <= CONN_STATE_LISTENING)) { in FtAppConfigSetPktSize()
479 NetconnSetPktSize(sock->netconn, configValue); in FtAppConfigSetPktSize()
578 (sock->netconn->pcb != FILLP_NULL_PTR)) { in FtAppConfigSetSlowStart()
579 NetconnSetSlowStart(sock->netconn, val); in FtAppConfigSetSlowStart()
795 …if ((sock != FILLP_NULL_PTR) && (sock->netconn != FILLP_NULL_PTR) && (sock->netconn->pcb != FILLP_… in FtAppConfigSetPackInterval()
796 (sock->netconn->state <= CONN_STATE_LISTENING)) { in FtAppConfigSetPackInterval()
[all …]
H A Dsocket_app.c295 if (sock->netconn == FILLP_NULL_PTR) { in SocketGetForDataTrans()
415 item->netconn = (void *)sock->netconn; in SockSendMsgSetItem()
746 …if ((sock->netconn->state != CONN_STATE_CONNECTED) && (sock->netconn->state != CONN_STATE_CLOSING)… in SockRecvmsg()
755 …ret = memcpy_s(msg->msg_name, msg->msg_namelen, &sock->netconn->pcb->remoteAddr, sock->netconn->pc… in SockRecvmsg()
856 if (sock->netconn == FILLP_NULL_PTR) { in SockApiGetAndCheckListenState()
921 if (sock->netconn == FILLP_NULL_PTR) { in SockAcceptGetAndCheck()
1067 acceptMsg.netconn = conn; in SockAccept()
1168 …if ((sock->netconn == FILLP_NULL_PTR) || (NETCONN_GET_STATE(sock->netconn) != CONN_STATE_CONNECTED… in SockCheckCanShutdown()
1170 …if ((sock->netconn != FILLP_NULL_PTR) && (CONN_STATE_LISTENING == NETCONN_GET_STATE(sock->netconn)… in SockCheckCanShutdown()
1305 if (sock->netconn != FILLP_NULL_PTR) { in SockGetRtt()
[all …]
H A Dfillp_dfx.c283 const struct FillpPcb *pcb = &sock->netconn->pcb->fpcb; in FillpDfxSockQosNotify()
319 if (sock->netconn->state == CONN_STATE_CONNECTED) { in FillpDfxSockLinkAndQosNotify()
524 struct sockaddr_in *local = (struct sockaddr_in *)&sock->netconn->pcb->localAddr; in DoShowSockList()
525 struct sockaddr_in *peer = (struct sockaddr_in *)&sock->netconn->pcb->remoteAddr; in DoShowSockList()
526 const struct FillpSendPcb *sendPcb = &sock->netconn->pcb->fpcb.send; in DoShowSockList()
536 if (sock->netconn->state > CONN_STATE_LISTENING) { in DoShowSockList()
550 g_sockStateStr[sock->netconn->state]); in DoShowSockList()
580 if (sock->netconn == FILLP_NULL_PTR || sock->netconn->pcb == FILLP_NULL_PTR) { in FillpDumpShowSockList()
598 const struct FillpPcb *pcb = &sock->netconn->pcb->fpcb; in DoShowSockQos()
629 …if (sock == FILLP_NULL_PTR || sock->netconn == FILLP_NULL_PTR || sock->netconn->pcb == FILLP_NULL_… in FillpDfxGetSock()
[all …]
H A Dapi.c1141 …if ((sock->netconn != FILLP_NULL_PTR) && (((struct FtNetconn *)sock->netconn)->pcb != FILLP_NULL_P… in FtFillpStatsGet()
1143 … &((struct FtNetconn *)sock->netconn)->pcb->fpcb.statistics, sizeof(struct FillpStatisticsPcb)); in FtFillpStatsGet()
1355 (sock->netconn == FILLP_NULL_PTR) || in FtFillpStatShow()
1356 (((struct FtNetconn *)sock->netconn)->pcb) == FILLP_NULL_PTR) { in FtFillpStatShow()
1370 pcb = &(((struct FtNetconn *)sock->netconn)->pcb->fpcb.statistics); in FtFillpStatShow()
H A Dspunge_app.c27 sock->netconn = FILLP_NULL_PTR; in SpungeInitSocket()
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/
H A Dspunge_stack.c240 (sock->netconn != FILLP_NULL_PTR) && (sock->netconn->pcb != FILLP_NULL_PTR) && in SpungeCloseCBSocket()
266 if ((sock->netconn != FILLP_NULL_PTR) && !SpungeConnCheckUnsendBoxEmpty(sock->netconn)) { in SpungeFreeSock()
278 if (sock->netconn != FILLP_NULL_PTR) { in SpungeFreeSock()
283 FillpNetconnDestroy(sock->netconn); in SpungeFreeSock()
284 sock->netconn = FILLP_NULL_PTR; in SpungeFreeSock()
308 struct FtNetconn *netconn = sock->netconn; in SpungeShutdownSock() local
311 if (netconn == FILLP_NULL_PTR) { in SpungeShutdownSock()
316 connState = NETCONN_GET_STATE(netconn); in SpungeShutdownSock()
320 netconn->shutdownRdSet = 1; in SpungeShutdownSock()
331 netconn->shutdownWrSet = 1; in SpungeShutdownSock()
[all …]
H A Dsysio_udp.c501 if (osSock == sock->netconn->osSocket[instIndex]) { in SysioGetListenSocketByOssock()
502 return sock->netconn->pcb; in SysioGetListenSocketByOssock()
539 if (FILLP_CONNECT(udpSock->udpSock, (struct sockaddr *)&sock->netconn->pcb->remoteAddr, in SysioConnectedUdp()
540 … (FILLP_INT32)UtilsAddrValidLength((struct sockaddr_in *)&sock->netconn->pcb->remoteAddr)) == 0) { in SysioConnectedUdp()
H A Dspunge_core.c926 struct FtNetconn *netconn = FILLP_NULL_PTR; in SpungeLoopCheckUnsendBox() local
936 netconn = (struct FtNetconn *)item[j]->netconn; in SpungeLoopCheckUnsendBox()
937 if (netconn == FILLP_NULL_PTR) { in SpungeLoopCheckUnsendBox()
942 fpcb = &(netconn->pcb->fpcb); in SpungeLoopCheckUnsendBox()
H A Dnet.c50 sock->netconn = conn; in NetconnSetSock()
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/public/include/
H A Dsockets.h93 struct FtNetconn *netconn; member
156 #define SOCK_GET_SENDPKTPOOL(_sock) ((_sock)->netconn->pcb->fpcb.send.itemPool)
157 #define SOCK_GET_SENDBOX(_sock) ((_sock)->netconn->pcb->fpcb.send.unsendBox)
158 #define SOCK_GET_RECVBOX(_sock) ((_sock)->netconn->pcb->fpcb.recv.recvBox)
159 #define SOCK_GET_PKTSIZE(_sock) ((_sock)->netconn->pcb->fpcb.pktSize)
167 #define SOCK_GET_SENDSEM(_sock) ((_sock)->netconn->pcb->fpcb.send.sendSem)
168 #define SOCK_GET_RECVSEM(_sock) ((_sock)->netconn->pcb->fpcb.recv.recvSem)
H A Dspunge_message.h51 void *netconn; member
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/fillp/
H A Dfillp_flow_control.c365 struct FtNetconn *netconn = FILLP_GET_CONN(pcb); in FillpFcCycle() local
368 sock = (struct FtSocket *)netconn->sock; in FillpFcCycle()
H A Dfillp_conn.c832 FillpNetconnSetSafeErr(sock->netconn, ERR_OK); in FillpHandleConnConfirmAckInput()
1075 struct SockOsSocket *osSock = NETCONN_GET_OSSOCK(sock->netconn, sock->inst->instIndex); in FillpConnConfirmAckInput()
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/include/fillp/
H A Dfillp.h92 void *netconn; member