| /ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/public/include/ |
| H A D | spunge.h | 45 FILLP_UINT maxInstNum;
46 FILLP_UINT maxSockNum;
47 FILLP_UINT maxTimerItemNum;
48 FILLP_UINT maxMsgItemNum;
49 FILLP_UINT maxConnNum;
50 FILLP_UINT maxEpollItemNum;
51 FILLP_UINT maxEpollEventNum;
108 FILLP_UINT netMask;
131 FILLP_UINT insNum;
|
| H A D | queue.h | 36 …ine FillpErrorType FillpQueuePush(FillpQueue *q, void **msg, FILLP_INT isTryPush, FILLP_UINT count) in FillpQueuePush()
41 ret = FillpLfRingMpEnqueue(&q->ring, &msg[totalPush], count - (FILLP_UINT)totalPush); in FillpQueuePush()
44 if ((FILLP_UINT)totalPush == count) { in FillpQueuePush()
53 static __inline FILLP_INT FillpQueuePop(FillpQueue *q, void **msg, FILLP_UINT count) in FillpQueuePop()
|
| H A D | callbacks.h | 119 IN FILLP_UINT sockFd, /* socket fd */
123 IN FILLP_UINT sockFd, /* socket fd */
226 void FillpSysSleepMs(IN FILLP_UINT time); /* In Millseconds */
228 FILLP_INT FillpSysSleepUs(IN FILLP_UINT time); /* In seconds */
|
| H A D | lf_ring.h | 99 FillpErrorType FillpLfRingMpEnqueue(struct FillpLfRing *ring, void **dataTable, FILLP_UINT count);
116 FILLP_INT FillpLfRingMcDequeue(struct FillpLfRing *ring, void **dataTable, FILLP_UINT count);
|
| H A D | rb_tree.h | 31 FILLP_UINT color;
|
| H A D | sockets.h | 241 FILLP_INT SysArchSetSockRcvbuf(FILLP_INT sock, FILLP_UINT size);
242 FILLP_INT SysArchSetSockSndbuf(FILLP_INT sock, FILLP_UINT size);
|
| /ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/public/src/ |
| H A D | fillp_os.c | 91 flags = (FILLP_INT)(blocking ? ((FILLP_UINT)flags & ~(FILLP_UINT)O_NONBLOCK) : in SysArchSetSockBlocking()
92 ((FILLP_UINT)flags | (FILLP_UINT)O_NONBLOCK)); in SysArchSetSockBlocking()
133 FILLP_INT SysArchSetSockSndbuf(FILLP_INT sock, FILLP_UINT size) in SysArchSetSockSndbuf()
142 FILLP_INT SysArchSetSockRcvbuf(FILLP_INT sock, FILLP_UINT size) in SysArchSetSockRcvbuf()
|
| H A D | lf_ring.c | 98 static FILLP_ULONG FillpLfRingMpEnqueueWait(struct FillpLfRing *ring, FILLP_UINT count, in FillpLfRingMpEnqueueWait()
131 FillpErrorType FillpLfRingMpEnqueue(struct FillpLfRing *ring, void **dataTable, FILLP_UINT count) in FillpLfRingMpEnqueue()
150 for (i = 0, j = 1; i < (FILLP_UINT)ret; i++, j++) { in FillpLfRingMpEnqueue()
181 static FILLP_ULONG FillpLfRingMcDequeueWait(struct FillpLfRing *ring, FILLP_UINT count, FILLP_ULONG… in FillpLfRingMcDequeueWait()
214 FILLP_INT FillpLfRingMcDequeue(struct FillpLfRing *ring, void **dataTable, FILLP_UINT count) in FillpLfRingMcDequeue()
|
| H A D | rb_tree.c | 255 FILLP_UINT color; in FillpRbEraseLowlvlNode()
305 FILLP_UINT color; in FillpRbErase()
|
| H A D | callbacks.c | 329 IN FILLP_UINT sockFd, /* socket fd */ in FillpFuncFdClr()
336 IN FILLP_UINT sockFd, /* socket fd */ in FillpFuncFdSet()
614 void FillpSysSleepMs(IN FILLP_UINT timeValue) /* In Millseconds */ in FillpSysSleepMs()
619 FILLP_INT FillpSysSleepUs(IN FILLP_UINT timeValue) /* In micro seconds */ in FillpSysSleepUs()
|
| H A D | dympool.c | 133 …mem = (DympMemory *)SpungeAlloc(1, (FILLP_SIZE_T)((FILLP_UINT)askSize), (FILLP_INT)SPUNGE_ALLOC_TY… in DympExpandMemory()
|
| /ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/include/ |
| H A D | fillpcallbacks.h | 377 typedef void (*FillpSysSleepMsFunc)(IN FILLP_UINT time); /* In Millseconds */
388 typedef FILLP_INT (*FillpSysUSleepFunc)(IN FILLP_UINT time); /* us */
698 typedef void (*FillpFdClrFunc)(IN FILLP_UINT fd, IN FT_FD_SET socketDescriptorSet);
709 typedef void (*FillpFdSetFunc)(IN FILLP_UINT fd, IN FT_FD_SET socketDescriptorSet);
|
| H A D | fillptypes.h | 124 typedef unsigned int FILLP_UINT; typedef
|
| /ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/ |
| H A D | spunge_core.c | 186 struct FtSocketTable *SpungeCreateSockTable(FILLP_UINT maxSock) in SpungeCreateSockTable()
474 FILLP_UINT i; in SpungeAllocInstRes()
475 FILLP_UINT j; in SpungeAllocInstRes()
565 … resConf->maxInstNum = (FILLP_UINT)UTILS_MIN(g_resource.common.maxInstNum, MAX_SPUNGEINSTANCE_NUM); in FtGetSpungeRes()
568 …resConf->maxMsgItemNum = ((FILLP_UINT)g_resource.common.maxSockNum * FILLP_SPUNGE_EVENTG_MULT_N… in FtGetSpungeRes()
569 resConf->maxTimerItemNum = ((FILLP_UINT)g_resource.common.maxSockNum * FILLP_ITEM_MULT_NUM); in FtGetSpungeRes()
570 resConf->maxEpollEventNum = (FILLP_UINT)(g_resource.common.maxSockNum * FILLP_ITEM_MULT_NUM); in FtGetSpungeRes()
571 resConf->maxEpollItemNum = (FILLP_UINT)(g_resource.common.maxSockNum * FILLP_ITEM_MULT_NUM); in FtGetSpungeRes()
639 FILLP_UINT netPoolInitSize = FILLP_CONN_ITEM_INIT_NUM; in FtInitGlobalNetPool()
857 FILLP_UINT i; in FtDestroyInner()
[all …]
|
| H A D | pcb.c | 36 …FillpErrorType err = FillpQueuePush(conn->pcb->fpcb.recv.recvBox, buf, FILLP_TRUE, (FILLP_UINT)cou… in SpungePcbRecv()
74 (FILLP_SIZE_T)((FILLP_UINT)size), in SpungePcbSend()
185 conn->sendIov[conn->iovCount].iov_len = (size_t)(FILLP_UINT)size; in SpungePcbSendmsg()
|
| H A D | hmac.c | 79 FILLP_UINT i; in FillpHmacSha256Init()
|
| H A D | sysio_udp.c | 314 FILLP_FD_SET((FILLP_UINT)udpSock->udpSock, g_udpIo.readSet); in SysioCreateSocketUdp()
|
| /ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/app_lib/src/ |
| H A D | socket_app.c | 365 if ((SOCK_IS_NONBLOCKING(sock) || ((FILLP_UINT)flags & MSG_DONTWAIT))) { in SockSendReqFpcbItemWithoutSem()
591 if (SOCK_IS_NONBLOCKING(sock) || ((FILLP_UINT)flags & MSG_DONTWAIT)) { in SockRecvReqFpcbItemWithSem()
691 flags = (FILLP_INT)((FILLP_UINT)flags | MSG_DONTWAIT); in SockRecvmsgDataFromBufCache()
799 msg.msg_iovlen = (size_t)(FILLP_UINT)iovCount; in SockWritev()
820 msg.msg_iovlen = (size_t)(FILLP_UINT)iovCount; in SockReadv()
1459 if (((FILLP_UINT)val & ~(FILLP_UINT)O_NONBLOCK) == 0) { in SockFcntl()
1461 SockSetNonblocking(sock, (FILLP_INT)((FILLP_UINT)val & (FILLP_UINT)O_NONBLOCK)); in SockFcntl()
1648 FILLP_UINT ret = 0; in SockGetSockEvt()
|
| H A D | epoll_app.c | 37 FILLP_UINT loopLimit = g_spunge->resConf.maxEpollItemNum; in EpFind()
63 FILLP_UINT loopLimit = g_spunge->resConf.maxEpollItemNum; in EpRbtreeInsert()
|
| H A D | api.c | 1529 if ((instInx < 0) || ((FILLP_UINT)instInx >= g_spunge->insNum)) { in FtGetStackTime()
|
| /ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/include/ |
| H A D | spunge_core.h | 83 struct FtSocketTable *SpungeCreateSockTable(FILLP_UINT maxSock);
|
| /ohos5.0/foundation/communication/dsoftbus/sdk/transmission/trans_channel/udp/stream/libsoftbus_stream/ |
| H A D | vtp_stream_socket.cpp | 1425 flags = nonBlock ? static_cast<FILLP_INT>((static_cast<FILLP_UINT>(flags) | O_NONBLOCK)) : in SetNonBlockMode()
1426 static_cast<FILLP_INT>((static_cast<FILLP_UINT>(flags) & ~O_NONBLOCK)); in SetNonBlockMode()
|
| /ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/fillp/ |
| H A D | fillp_pcb.c | 310 …FillpQueue *recvBox = FillpQueueCreate("sock_recv_box", fpcb->mpRecvSize + (FILLP_UINT)privRecvSiz… in FillpInitRecvPcbBox()
|
| H A D | fillp_common.c | 768 FILLP_UINT tmpDataLen; in FillpBuildAndSendPack()
|