Home
last modified time | relevance | path

Searched refs:osSock (Results 1 – 12 of 12) sorted by relevance

/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/
H A Dspunge_stack.c32 struct SockOsSocket *osSock; in SpungeAllocSystemSocket() local
35 if (osSock == FILLP_NULL_PTR) { in SpungeAllocSystemSocket()
40 osSock->reference = 0; in SpungeAllocSystemSocket()
41 osSock->addrType = domain; in SpungeAllocSystemSocket()
47 osSock = FILLP_NULL_PTR; in SpungeAllocSystemSocket()
48 return osSock; in SpungeAllocSystemSocket()
51 HLIST_INIT_NODE(&osSock->osListNode); in SpungeAllocSystemSocket()
54 return osSock; in SpungeAllocSystemSocket()
281 osSock->ioSock->ops->freeSock((void *)sock, (void *)osSock); in SpungeFreeSock()
489 if (!OS_SOCK_OPS_FUNC_VALID(osSock, connected) || !OS_SOCK_OPS_FUNC_VALID(osSock, sendPacket)) { in SpungeSendConnectMsg()
[all …]
H A Dpcb.c63 struct SockOsSocket *osSock = NETCONN_GET_OSSOCK(conn, SPUNGE_GET_CUR_INSTANCE()->instIndex); in SpungePcbSend() local
65 if (!OS_SOCK_OPS_FUNC_VALID(osSock, send)) { in SpungePcbSend()
72 if (size != (FILLP_INT) osSock->ioSock->ops->send(osSock->ioSock, in SpungePcbSend()
156 struct SockOsSocket *osSock = FILLP_NULL_PTR; in SpungePcbSendmsg() local
169 osSock = NETCONN_GET_OSSOCK(conn, SPUNGE_GET_CUR_INSTANCE()->instIndex); in SpungePcbSendmsg()
170 if (osSock == FILLP_NULL_PTR) { in SpungePcbSendmsg()
174 udpSock = (SysIoUdpSock *)osSock->ioSock; in SpungePcbSendmsg()
296 struct SockOsSocket *osSock = FILLP_NULL_PTR; in SpungePcbRemove() local
306 osSock = NETCONN_GET_OSSOCK(conn, SPUNGE_GET_CUR_INSTANCE()->instIndex); in SpungePcbRemove()
307 if (OS_SOCK_OPS_FUNC_VALID(osSock, removePcb)) { in SpungePcbRemove()
[all …]
H A Dnet.c27 static void NetconnFreeOsSocket(struct SockOsSocket *osSock, struct SpungeInstance *curInst) in NetconnFreeOsSocket() argument
29 if ((osSock == FILLP_NULL_PTR) || (curInst == FILLP_NULL_PTR)) { in NetconnFreeOsSocket()
37 osSock->reference--; in NetconnFreeOsSocket()
38 if (osSock->reference <= 0) { in NetconnFreeOsSocket()
39 if (OS_SOCK_OPS_FUNC_VALID(osSock, destroySysIoSocket)) { in NetconnFreeOsSocket()
40 (void)osSock->ioSock->ops->destroySysIoSocket(osSock->ioSock); in NetconnFreeOsSocket()
42 HlistDelete(&curInst->osSockist, &osSock->osListNode); in NetconnFreeOsSocket()
43 SpungeFree(osSock, SPUNGE_ALLOC_TYPE_CALLOC); in NetconnFreeOsSocket()
H A Dsysio_udp.c36 FILLP_CONST struct SockOsSocket *osSock,
230 struct SockOsSocket *osSock = (struct SockOsSocket *)sock; in SysioFetchPacketUdp() local
231 SysIoUdpSock *sysioUdpSock = (SysIoUdpSock *)osSock->ioSock; in SysioFetchPacketUdp()
252 spcb = SysioGetPcbFromRemoteaddrUdp((struct sockaddr *)&netbuf->addr, osSock, list); in SysioFetchPacketUdp()
488 FILLP_CONST struct SockOsSocket *osSock) in SysioGetListenSocketByOssock() argument
501 if (osSock == sock->netconn->osSocket[instIndex]) { in SysioGetListenSocketByOssock()
512 FILLP_CONST struct SockOsSocket *osSock, in SysioGetPcbFromRemoteaddrUdp() argument
531 return SysioGetListenSocketByOssock(osSock); in SysioGetPcbFromRemoteaddrUdp()
H A Dspunge_core.c50 void SpungeDoRecvCycle(struct SockOsSocket *osSock, struct SpungeInstance *inst) in SpungeDoRecvCycle() argument
56 if (!OS_SOCK_OPS_FUNC_VALID(osSock, fetchPacket)) { in SpungeDoRecvCycle()
63 spcb = osSock->ioSock->ops->fetchPacket((void *)osSock, (void *)&buf, 0); in SpungeDoRecvCycle()
1538 struct SockOsSocket *osSock = SockOsListEntry(osSockNode); in SpinstLoopRecv() local
1540 readable = SysioIsSockReadable((void *)osSock->ioSock); in SpinstLoopRecv()
1545 SpungeDoRecvCycle(osSock, inst); in SpinstLoopRecv()
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/public/src/
H A Dspunge_message.c100 if (osSock == FILLP_NULL_PTR) { in SpungeHandleMsgAllocSock()
113 SockSetOsSocket(sock, osSock); in SpungeHandleMsgAllocSock()
167 if (osSock == FILLP_NULL_PTR) { in SpungeListenMsgCheckState()
179 *pOsSock = osSock; in SpungeListenMsgCheckState()
221 if (!OS_SOCK_OPS_FUNC_VALID(osSock, listen) || osSock->ioSock->ops->listen(sock) != ERR_OK) { in SpungeHandleMsgListen()
291 *pOsSock = osSock; in SpungeConnMsgGetSock()
323 osSock->ioSock->ops->connect(osSock->ioSock, sock->netconn->pcb) != ERR_OK) { in SpungeHandleMsgConnect()
338 (osSock->ioSock->ops->sendPacket(FILLP_PKT_TYPE_CONN_REQ, (void *)osSock->ioSock, in SpungeHandleMsgConnect()
409 *pOsSock = osSock; in SpungeBindMsgCheckState()
717 sysosSocket = osSock->ioSock->ops->getOsSocket(osSock->ioSock); in SpungeHandleMsgSetSendBuf()
[all …]
H A Dspunge.c64 void SockSetOsSocket(struct FtSocket *ftSock, struct SockOsSocket *osSock) in SockSetOsSocket() argument
66 ftSock->netconn->osSocket[SPUNGE_GET_CUR_INSTANCE()->instIndex] = osSock; in SockSetOsSocket()
67 osSock->reference++; in SockSetOsSocket()
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/app_lib/src/
H A Dsocket_opt.c104 struct SockOsSocket *osSock = FILLP_NULL_PTR; in SockGetSockOpt() local
137 osSock = NETCONN_GET_OSSOCK(sock->netconn, sock->inst->instIndex); in SockGetSockOpt()
138 if (!OS_SOCK_OPS_FUNC_VALID(osSock, getsockopt)) { in SockGetSockOpt()
142 err = osSock->ioSock->ops->getsockopt(osSock->ioSock, level, optName, optVal, optLen); in SockGetSockOpt()
296 struct SockOsSocket *osSock = FILLP_NULL_PTR; in SockSetSockOpt() local
320 osSock = NETCONN_GET_OSSOCK(sock->netconn, sock->inst->instIndex); in SockSetSockOpt()
321 if (OS_SOCK_OPS_FUNC_VALID(osSock, setsockopt)) { in SockSetSockOpt()
322 err = osSock->ioSock->ops->setsockopt(osSock->ioSock, level, optName, optVal, optLen); in SockSetSockOpt()
H A Dsocket_app.c1558 struct SockOsSocket *osSock = FILLP_NULL_PTR; in SockGetsockname() local
1583 osSock = NETCONN_GET_OSSOCK(sock->netconn, sock->inst->instIndex); in SockGetsockname()
1584 if (!OS_SOCK_OPS_FUNC_VALID(osSock, getSockName)) { in SockGetsockname()
1588 err = osSock->ioSock->ops->getSockName(osSock->ioSock, name, nameLen); in SockGetsockname()
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/include/
H A Dspunge_stack.h25 void SpungeDoRecvCycle(struct SockOsSocket *osSock, struct SpungeInstance *inst);
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/fillp/
H A Dfillp_conn.c662 struct SockOsSocket *osSock = NETCONN_GET_OSSOCK(conn, SPUNGE_GET_CUR_INSTANCE()->instIndex); in FillpProcessConnConfirm() local
663 if (!OS_SOCK_OPS_FUNC_VALID(osSock, handlePacket)) { in FillpProcessConnConfirm()
668 …FillpErrorType err = osSock->ioSock->ops->handlePacket(FILLP_PKT_TYPE_CONN_CONFIRM, (void *)osSock in FillpProcessConnConfirm()
672 newConn->osSocket[SPUNGE_GET_CUR_INSTANCE()->instIndex] = osSock; in FillpProcessConnConfirm()
673 osSock->reference++; in FillpProcessConnConfirm()
1075 struct SockOsSocket *osSock = NETCONN_GET_OSSOCK(sock->netconn, sock->inst->instIndex); in FillpConnConfirmAckInput() local
1076 if (!OS_SOCK_OPS_FUNC_VALID(osSock, connected)) { in FillpConnConfirmAckInput()
1081 osSock->ioSock->ops->connected(sock, osSock->ioSock); in FillpConnConfirmAckInput()
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/public/include/
H A Dspunge.h157 void SockSetOsSocket(struct FtSocket *ftSock, struct SockOsSocket *osSock);