/foundation/communication/dsoftbus/sdk/transmission/session/src/ |
H A D | client_trans_session_manager.c | 74 SessionInfo *sessionNode = NULL; in CheckPermissionState() local 80 LIST_FOR_EACH_ENTRY(sessionNode, &(serverNode->sessionList), SessionInfo, node) { in CheckPermissionState() 81 if (sessionNode->sessionId == sessionId) { in CheckPermissionState() 141 SessionInfo *sessionNode = NULL; in SessionIdIsAvailable() local 147 LIST_FOR_EACH_ENTRY(sessionNode, &(serverNode->sessionList), SessionInfo, node) { in SessionIdIsAvailable() 148 if (sessionNode->sessionId == sessionId) { in SessionIdIsAvailable() 161 SessionInfo *sessionNode = NULL; in ShowAllSessionInfo() local 175 LIST_FOR_EACH_ENTRY(sessionNode, &(serverNode->sessionList), SessionInfo, node) { in ShowAllSessionInfo() 176 Anonymize(sessionNode->info.peerSessionName, &tmpPeerSessionName); in ShowAllSessionInfo() 180 sessionCount, AnonymizeWrapper(tmpPeerSessionName), sessionNode in ShowAllSessionInfo() 419 SessionInfo *sessionNode = NULL; GetExistSession() local 442 SessionInfo *sessionNode = NULL; GetSessionById() local 617 SessionInfo *sessionNode = NULL; ClientDeleteSession() local 661 SessionInfo *sessionNode = NULL; ClientGetSessionDataById() local 707 SessionInfo *sessionNode = NULL; ClientGetSessionIntegerDataById() local 749 SessionInfo *sessionNode = NULL; ClientGetChannelBySessionId() local 783 SessionInfo *sessionNode = NULL; ClientSetStatusClosingBySocket() local 809 SessionInfo *sessionNode = NULL; ClientSetEnableStatusBySocket() local 833 SessionInfo *sessionNode = NULL; ClientGetChannelBusinessTypeBySessionId() local 860 SessionInfo *sessionNode = NULL; ClientSetChannelBySessionId() local 889 SessionInfo *sessionNode = NULL; GetEncryptByChannelId() local 924 SessionInfo *sessionNode = NULL; ClientGetSessionStateByChannelId() local 959 SessionInfo *sessionNode = NULL; ClientGetSessionIdByChannelId() local 994 SessionInfo *sessionNode = NULL; ClientGetSessionIsAsyncBySessionId() local 1028 SessionInfo *sessionNode = NULL; ClientGetRouteTypeByChannelId() local 1063 SessionInfo *sessionNode = NULL; ClientGetDataConfigByChannelId() local 1085 ClientSetAuthSessionTimer(const ClientSessionServer *serverNode, SessionInfo *sessionNode) ClientSetAuthSessionTimer() argument 1107 SessionInfo *sessionNode = NULL; ClientEnableSessionByChannelId() local 1164 SessionInfo *sessionNode = NULL; ClientGetSessionCallbackById() local 1225 SessionInfo *sessionNode = NULL; ClientGetSessionSide() local 1323 SessionInfo *sessionNode = NULL; ClientGetFileConfigInfoById() local 1351 SessionInfo *sessionNode = NULL; ClientCleanAllSessionWhenServerDeath() local 1436 SessionInfo *sessionNode = NULL; DeleteSocketSession() local 1549 SessionInfo *sessionNode = NULL; ClientSetListenerBySessionId() local 1598 SessionInfo *sessionNode = NULL; ClientIpcOpenSession() local 1649 SessionInfo *sessionNode = NULL; ClientSetActionIdBySessionId() local 1688 SessionInfo *sessionNode = NULL; ClientHandleBindWaitTimer() local 1733 SessionInfo *sessionNode = NULL; ClientSetSocketState() local 1808 SessionInfo *sessionNode = NULL; ClientGetSessionCallbackAdapterById() local 1841 SessionInfo *sessionNode = NULL; ClientGetPeerSocketInfoById() local 1879 SessionInfo *sessionNode = NULL; ClientTransSessionTimerProc() local 1913 SessionInfo *sessionNode = NULL; ClientResetIdleTimeoutById() local 1947 SessionInfo *sessionNode = NULL; ClientGetSessionNameByChannelId() local 2011 SessionInfo *sessionNode = NULL; ClientRawStreamEncryptOptGet() local 2044 SessionInfo *sessionNode = NULL; SetSessionIsAsyncById() local 2075 SessionInfo *sessionNode = NULL; SetSessionInitInfoById() local 2108 SessionInfo *sessionNode = NULL; ClientTransSetChannelInfo() local 2141 SessionInfo *sessionNode = NULL; GetSocketLifecycleAndSessionNameBySessionId() local 2192 SessionInfo *sessionNode = NULL; SetSessionStateBySessionId() local 2219 SessionInfo *sessionNode = NULL; CheckSessionEnableStatus() local 2258 SessionInfo *sessionNode = NULL; ClientWaitSyncBind() local 2329 SessionInfo *sessionNode = NULL; ClientSignalSyncBind() local 2370 SessionInfo *sessionNode = NULL; ClientDfsIpcOpenSession() local 2402 ClientUpdateAuthSessionTimer(SessionInfo *sessionNode, int32_t sessionId) ClientUpdateAuthSessionTimer() argument 2430 SessionInfo *sessionNode = NULL; ClientCancelAuthSessionTimer() local 2462 SessionInfo *sessionNode = NULL; ClientGetChannelOsTypeBySessionId() local [all...] |
H A D | client_trans_socket_manager.c | 91 NO_SANITIZE("cfi") DestroySessionInfo *CreateDestroySessionNode(SessionInfo *sessionNode, in CreateDestroySessionNode() argument 94 if (sessionNode == NULL || server == NULL) { in CreateDestroySessionNode() 103 destroyNode->sessionId = sessionNode->sessionId; in CreateDestroySessionNode() 104 destroyNode->channelId = sessionNode->channelId; in CreateDestroySessionNode() 105 destroyNode->channelType = sessionNode->channelType; in CreateDestroySessionNode() 106 destroyNode->isAsync = sessionNode->isAsync; in CreateDestroySessionNode() 107 if (!sessionNode->lifecycle.condIsWaiting) { in CreateDestroySessionNode() 108 (void)SoftBusCondDestroy(&(sessionNode->lifecycle.callbackCond)); in CreateDestroySessionNode() 110 (void)SoftBusCondSignal(&(sessionNode->lifecycle.callbackCond)); // destroy in CheckSessionEnableStatus in CreateDestroySessionNode() 111 TRANS_LOGI(TRANS_SDK, "sessionId=%{public}d condition is waiting", sessionNode in CreateDestroySessionNode() 166 SessionInfo *sessionNode = NULL; DestroyClientSessionServer() local 290 ClientTransCheckNeedDel(SessionInfo *sessionNode, int32_t routeType, int32_t connType) ClientTransCheckNeedDel() argument 340 SessionInfo *sessionNode = NULL; DestroyClientSessionByNetworkId() local 561 FillSessionParam(SessionParam *param, SessionAttribute *tmpAttr, ClientSessionServer *serverNode, SessionInfo *sessionNode) FillSessionParam() argument 631 ClientCheckWaitTimeOut(const ClientSessionServer *serverNode, SessionInfo *sessionNode, int32_t waitOutSocket[], uint32_t capacity, uint32_t *num) ClientCheckWaitTimeOut() argument 714 ClientUpdateIdleTimeout(const ClientSessionServer *serverNode, SessionInfo *sessionNode, ListNode *destroyList) ClientUpdateIdleTimeout() argument 765 FillDfsSocketParam( SessionParam *param, SessionAttribute *tmpAttr, ClientSessionServer *serverNode, SessionInfo *sessionNode) FillDfsSocketParam() argument [all...] |
/foundation/communication/dsoftbus/sdk/transmission/session/include/ |
H A D | client_trans_socket_manager.h | 38 NO_SANITIZE("cfi") DestroySessionInfo *CreateDestroySessionNode(SessionInfo *sessionNode, 66 ClientSessionServer *serverNode, SessionInfo *sessionNode); 72 void ClientCheckWaitTimeOut(const ClientSessionServer *serverNode, SessionInfo *sessionNode, 77 void ClientUpdateIdleTimeout(const ClientSessionServer *serverNode, SessionInfo *sessionNode, ListNode *destroyList); 90 SessionParam *param, SessionAttribute *tmpAttr, ClientSessionServer *serverNode, SessionInfo *sessionNode);
|
/foundation/communication/dsoftbus/components/nstackx/nstackx_core/dfile/core/ |
H A D | nstackx_dfile.c | 1463 DFileSessionNode *sessionNode = PopDFileSessionNodeById((uint16_t)sessionId); in NSTACKX_DFileClose() local 1464 if (CheckDFileSessionNodeValid(sessionNode) != NSTACKX_EOK) { in NSTACKX_DFileClose() 1469 StopDFileThreads(sessionNode->session); in NSTACKX_DFileClose() 1470 ClearPendingFileList(sessionNode->session); in NSTACKX_DFileClose() 1472 ClearSmallFileList(sessionNode->session); in NSTACKX_DFileClose() 1474 ClearTransChain(sessionNode->session); in NSTACKX_DFileClose() 1475 ClearOutboundQueue(sessionNode->session); in NSTACKX_DFileClose() 1476 ClearInboundQueue(sessionNode->session); in NSTACKX_DFileClose() 1477 ClearTransStateList(sessionNode->session); in NSTACKX_DFileClose() 1478 FileManagerDestroy(sessionNode in NSTACKX_DFileClose() [all...] |