Home
last modified time | relevance | path

Searched refs:sockTable (Results 1 - 7 of 7) sorted by relevance

/foundation/communication/dsoftbus/components/nstackx/fillp/src/public/src/
H A Dsocket_common.c168 (void)FillpQueuePush(g_spunge->sockTable->freeQueqe, (void *)&sock, FILLP_FALSE, 1); in SockFreeSocket()
264 ret = FillpQueuePop(g_spunge->sockTable->freeQueqe, (void *)&sock, 1); in SockAllocSocket()
266 FILLP_LOGDBG("sockets not available from the sockTable->freeQueqe"); in SockAllocSocket()
268 if (SpungeAllocFtSock(g_spunge->sockTable) != FILLP_OK) { in SockAllocSocket()
281 if ((g_spunge == FILLP_NULL_PTR) || (!g_spunge->hasInited) || (g_spunge->sockTable == FILLP_NULL_PTR)) { in SockGetSocket()
287 if ((sockIndex < 0) || (sockIndex >= SYS_ARCH_ATOMIC_READ(&g_spunge->sockTable->used))) { in SockGetSocket()
292 sock = g_spunge->sockTable->sockPool[sockIndex]; in SockGetSocket()
/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/
H A Dspunge_stack.c80 if ((assIdex < 0) || (assIdex >= SYS_ARCH_ATOMIC_READ(&g_spunge->sockTable->used))) { in SpungeEpollFreeResource()
85 epollSock = g_spunge->sockTable->sockPool[assIdex]; in SpungeEpollFreeResource()
234 (void)FillpQueuePush(g_spunge->sockTable->freeQueqe, (void *)&sock, FILLP_FALSE, 1); in SpungEpollClose()
301 (void)FillpQueuePush(g_spunge->sockTable->freeQueqe, (void *)&sock, FILLP_FALSE, 1); in SpungeFreeSock()
H A Dspunge_core.c629 g_spunge->sockTable = SpungeCreateSockTable(g_spunge->resConf.maxSockNum); in FtInitGlobalSockTable()
630 if (g_spunge->sockTable == FILLP_NULL_PTR) { in FtInitGlobalSockTable()
631 FILLP_LOGERR("Malloc g_spunge->sockTable failed"); in FtInitGlobalSockTable()
680 if (g_spunge->sockTable != FILLP_NULL_PTR) { in FtFreeGlobalSpunge()
681 SpungeDestroySockTable(g_spunge->sockTable); in FtFreeGlobalSpunge()
682 g_spunge->sockTable = FILLP_NULL_PTR; in FtFreeGlobalSpunge()
1171 for (i = 0; i < SYS_ARCH_ATOMIC_READ(&g_spunge->sockTable->used); i++) { in FillpKillCore()
1172 struct FtSocket *sock = g_spunge->sockTable->sockPool[i]; in FillpKillCore()
/foundation/communication/dsoftbus/components/nstackx/fillp/src/app_lib/src/
H A Dspunge_app.c88 if ((g_spunge == FILLP_NULL_PTR) || (!g_spunge->hasInited) || (g_spunge->sockTable == FILLP_NULL_PTR)) { in SpungeAllocSock()
100 FILLP_LOGERR("sockets not available from the sockTable->freeQueqe"); in SpungeAllocSock()
H A Dapi.c487 if (SYS_ARCH_ATOMIC_READ(&g_spunge->sockTable->used) <= 0) { in FtStartStopTrace()
513 } while ((traceObj == FILLP_CONFIG_ALL_SOCKET) && (sockIndex < SYS_ARCH_ATOMIC_READ(&g_spunge->sockTable->used))); in FtStartStopTrace()
1374 FILLP_SHOWDATABUTT("Total Sockets : %d,Total Free Sockets : %d", g_spunge->sockTable->size, in FtFillpStatShow()
1375 FillpRingFreeEntries(&(g_spunge->sockTable->freeQueqe->ring))); in FtFillpStatShow()
H A Dfillp_dfx.c556 if ((g_spunge == FILLP_NULL_PTR) || (!g_spunge->hasInited) || (g_spunge->sockTable == FILLP_NULL_PTR)) { in FillpDumpShowSockList()
575 for (i = 0; i < SYS_ARCH_ATOMIC_READ(&g_spunge->sockTable->used); i++) { in FillpDumpShowSockList()
/foundation/communication/dsoftbus/components/nstackx/fillp/src/public/include/
H A Dspunge.h137 struct FtSocketTable *sockTable; /* alloc socket source */ member

Completed in 9 milliseconds