Home
last modified time | relevance | path

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

/foundation/communication/dsoftbus/components/nstackx/fillp/src/public/src/
H A Dspunge_message.c82 FILLP_LOGERR("Error to alloc netconn"); in SpungeHandleMsgAllocSock()
115 sock->netconn->lastErr = ERR_OK; in SpungeHandleMsgAllocSock()
143 struct FtNetconn *netconn = FILLP_NULL_PTR; in SpungeListenMsgCheckState() local
154 netconn = sock->netconn; in SpungeListenMsgCheckState()
155 netState = NETCONN_GET_STATE(netconn); in SpungeListenMsgCheckState()
157 FILLP_LOGERR("netconn state error state:%d", netState); in SpungeListenMsgCheckState()
163 FillpNetconnSetState(netconn, CONN_STATE_LISTENING); in SpungeListenMsgCheckState()
166 osSock = NETCONN_GET_OSSOCK(sock->netconn, inst->instIndex); in SpungeListenMsgCheckState()
263 if (sock->netconn in SpungeConnMsgGetSock()
480 struct FtNetconn *netconn = FILLP_NULL_PTR; SpungeHandleMsgConnAccepted() local
[all...]
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()
H A Dsocket_common.c49 * Callback registered in the netconn layer for each socket-netconn.
324 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 in SockUpdatePktDataOpt()
[all...]
/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()
257 if (sock->netconn->state == CONN_STATE_CONNECTING) { in FtInnerValidateAppConfigSet()
259 sock->netconn->state, sockIndex); in FtInnerValidateAppConfigSet()
332 struct FtNetconn *netconn = FILLP_NULL_PTR; in FtCheckSockValid() local
333 if ((sock->netconn == FILLP_NULL_PTR) || (sock->allocState == SOCK_ALLOC_STATE_FREE)) { in FtCheckSockValid()
334 FILLP_LOGERR("ERR_NULLPTR sock->netconn or sock->allocState is SOCK_ALLOC_STATE_FREE"); in FtCheckSockValid()
338 netconn = (struct FtNetconn *)(sock->netconn); in FtCheckSockValid()
339 if (netconn->pcb == FILLP_NULL_PTR) { in FtCheckSockValid()
340 FILLP_LOGERR("ERR_NULLPTR netconn in FtCheckSockValid()
349 struct FtNetconn *netconn = FILLP_NULL_PTR; FtGetAppFcPeriodRecvRate() local
363 struct FtNetconn *netconn = FILLP_NULL_PTR; FtGetAppFcPeriodRecvRateBps() local
376 struct FtNetconn *netconn = FILLP_NULL_PTR; FtGetAppFcPeriodRecvPktLost() local
390 struct FtNetconn *netconn = FILLP_NULL_PTR; FtGetAppFcPeriodStastics() local
[all...]
H A Dsocket_opt.c30 if ((*optLen < (FILLP_INT)sizeof(struct FillpCurrentSendCacheInf)) || (sock->netconn == FILLP_NULL_PTR)) { in SockGetOptSendCache()
34 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()
199 FILLP_LOGERR("netconn is NULL, fillp_sock_id:%d", sock->index); in SockSetFcAlg()
203 connState = NETCONN_GET_STATE(sock->netconn); in SockSetFcAlg()
209 if (sock->netconn 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()
349 if ((sock != FILLP_NULL_PTR) && (sock->netconn != FILLP_NULL_PTR) && in FtAppConfigSetSendCache()
350 (sock->netconn->pcb != FILLP_NULL_PTR) && (sock->netconn->state == CONN_STATE_IDLE)) { in FtAppConfigSetSendCache()
351 NetconnSetSendCacheSize(sock->netconn, configValue); in FtAppConfigSetSendCache()
376 if ((sock != FILLP_NULL_PTR) && (sock->netconn != FILLP_NULL_PTR) && in FtAppConfigSetRecvCache()
377 (sock->netconn->pcb != FILLP_NULL_PTR) && (sock->netconn->state == CONN_STATE_IDLE)) { in FtAppConfigSetRecvCache()
378 NetconnSetRecvCacheSize(sock->netconn, configValu in FtAppConfigSetRecvCache()
[all...]
H A Dsocket_app.c290 FILLP_LOGERR("netconn is null for sock id=%d", sockIndex); in SocketGetForDataTrans()
295 if (sock->netconn == FILLP_NULL_PTR) { in SocketGetForDataTrans()
394 if (!FillpPcbGetDirectlySend(&sock->netconn->pcb->fpcb)) { in SockSendmsgPushOrSendItem()
400 (tmpItemCnt >= (FillpPcbGetSendCacheSize(&sock->netconn->pcb->fpcb) >> 1))) { /* > half of the cache */ in SockSendmsgPushOrSendItem()
401 FillpPcbSend(&sock->netconn->pcb->fpcb, itemList, tmpItemCnt); in SockSendmsgPushOrSendItem()
415 item->netconn = (void *)sock->netconn; in SockSendMsgSetItem()
416 item->fpcb = (void *)&sock->netconn->pcb->fpcb; in SockSendMsgSetItem()
441 FillpFrameTxInitItem(&sock->netconn->pcb->fpcb.frameHandle, item, frame, (FILLP_UINT32)bufLen, isFirstPkt); in SockItemSetFrameInfo()
454 if (FillpPcbGetDirectlySend(&sock->netconn in SockSendLastItem()
[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 in DoShowSockQos()
[all...]
H A Dspunge_app.c27 sock->netconn = FILLP_NULL_PTR; in SpungeInitSocket()
H A Dapi.c1141 if ((sock->netconn != FILLP_NULL_PTR) && (((struct FtNetconn *)sock->netconn)->pcb != FILLP_NULL_PTR)) { in FtFillpStatsGet()
1143 &((struct FtNetconn *)sock->netconn)->pcb->fpcb.statistics, sizeof(struct FillpStatisticsPcb)); in FtFillpStatsGet()
1145 FILLP_LOGERR(" error: netconn/pcb is NULLPTR"); 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()
/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()
241 (sock->netconn->state == CONN_STATE_CLOSED)) { in SpungeCloseCBSocket()
243 struct SockOsSocket *osSock = NETCONN_GET_OSSOCK(sock->netconn, sock->inst->instIndex); in SpungeCloseCBSocket()
246 FILLP_SOCKETCLOSE_CBK(udpSock->udpSock, (struct sockaddr *)&sock->netconn->pcb->localAddr, in SpungeCloseCBSocket()
247 (struct sockaddr *)&sock->netconn->pcb->remoteAddr); in SpungeCloseCBSocket()
266 if ((sock->netconn != FILLP_NULL_PTR) && !SpungeConnCheckUnsendBoxEmpty(sock->netconn)) { in SpungeFreeSock()
278 if (sock->netconn != FILLP_NULL_PTR) { in SpungeFreeSock()
279 struct SockOsSocket *osSock = NETCONN_GET_OSSOCK(sock->netconn, soc in SpungeFreeSock()
308 struct FtNetconn *netconn = sock->netconn; SpungeShutdownSock() local
[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 Dnet.c50 sock->netconn = conn; in NetconnSetSock()
116 FILLP_LOGERR("Failed to allocate the netconn connection, Ret=%d", ret); in FillpNetconnAlloc()
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()
/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)
219 /* Should this netconn avoid blocking? */
222 /* Get the blocking status of netconn calls (@todo: write/send is missing) */
228 The flag (which contains the socket options is in FtSocket and NOT in netconn C
[all...]
H A Dspunge_message.h51 void *netconn; member
/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.c585 Temporarily the accepted->netconn sock reference is LISTEN socket. It will reference in FillpInitNewConnByConfirm()
588 then fc_cyle() will run and coredump can happen as the netconn->sock will be NULL in FillpInitNewConnByConfirm()
591 newConn->sock = sock; // It is very important to set this , because it is necessary to make netconn has a socket in FillpInitNewConnByConfirm()
645 FILLP_LOGERR("fillp_sock_id:%d Failed in allocate new netconn connection", sock->index); in FillpProcessConnConfirm()
832 FillpNetconnSetSafeErr(sock->netconn, ERR_OK); in FillpHandleConnConfirmAckInput()
1075 struct SockOsSocket *osSock = NETCONN_GET_OSSOCK(sock->netconn, sock->inst->instIndex); in FillpConnConfirmAckInput()
1244 send() return 0 and netconn state goto CLOSED in FillpHandleFin()
/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/include/fillp/
H A Dfillp.h92 void *netconn; member

Completed in 21 milliseconds