| /ohos5.0/foundation/communication/dsoftbus/core/transmission/trans_channel/tcp_direct/src/ |
| H A D | trans_tcp_direct_sessionconn.c | 116 SessionConn *item = NULL; in GetSessionConnByRequestId()
132 SessionConn *item = NULL; in GetSessionConnByReq()
145 SessionConn *conn = (SessionConn *)SoftBusCalloc(sizeof(SessionConn)); in CreateNewSessinConn()
174 (void)memcpy_s(conn, sizeof(SessionConn), connInfo, sizeof(SessionConn)); in GetSessionConnByFd()
194 (void)memcpy_s(conn, sizeof(SessionConn), connInfo, sizeof(SessionConn)); in GetSessionConnById()
208 SessionConn *conn = NULL; in SetAppInfoById()
226 SessionConn *conn = NULL; in GetAppInfoById()
244 SessionConn *conn = NULL; in SetAuthHandleByChanId()
262 SessionConn *conn = NULL; in GetAuthIdByChanId()
284 SessionConn *conn = NULL; in GetAuthHandleByChanId()
[all …]
|
| H A D | trans_tcp_direct_manager.c | 92 SessionConn *item = NULL; in NotifyTdcChannelTimeOut()
93 SessionConn *nextItem = NULL; in NotifyTdcChannelTimeOut()
104 SessionConn *item = NULL; in TransTdcTimerProc()
105 SessionConn *nextItem = NULL; in TransTdcTimerProc()
139 SessionConn *item = NULL; in NotifyTdcChannelStopProc()
140 SessionConn *nextItem = NULL; in NotifyTdcChannelStopProc()
153 SessionConn *item = NULL; in TransTdcStopSessionProc()
154 SessionConn *nextItem = NULL; in TransTdcStopSessionProc()
224 SessionConn *item = NULL; in TransTdcDeathCallback()
225 SessionConn *nextItem = NULL; in TransTdcDeathCallback()
[all …]
|
| H A D | trans_tcp_direct_listener.c | 88 static int32_t StartVerifySession(SessionConn *conn) in StartVerifySession()
156 SessionConn *conn = (SessionConn *)SoftBusCalloc(sizeof(SessionConn)); in CreateSessionConnNode()
284 SessionConn conn; in TransProcDataRes()
301 static int32_t ProcessSocketInEvent(SessionConn *conn, int fd) in ProcessSocketInEvent()
314 static int32_t ProcessSocketOutEvent(SessionConn *conn, int fd) in ProcessSocketOutEvent()
349 static void ProcessSocketExceptionEvent(SessionConn *conn, int fd) in ProcessSocketExceptionEvent()
361 SessionConn *conn = (SessionConn *)SoftBusCalloc(sizeof(SessionConn)); in TdcOnDataEvent()
|
| H A D | trans_tcp_direct_p2p.c | 153 SessionConn *item = NULL; in NotifyP2pSessionConnClear()
154 SessionConn *nextItem = NULL; in NotifyP2pSessionConnClear()
166 SessionConn *item = NULL; in ClearP2pSessionConn()
167 SessionConn *nextItem = NULL; in ClearP2pSessionConn()
415 SessionConn *conn = NULL; in OnAuthConnOpened()
457 SessionConn *conn = NULL; in OnAuthConnOpenFailed()
683 SessionConn *conn = NULL; in AddHmlTrigger()
732 SessionConn *conn = NULL; in OnVerifyP2pReply()
853 static int32_t OpenNewAuthConn(const AppInfo *appInfo, SessionConn *conn, in OpenNewAuthConn()
890 static int32_t TransProxyGetAuthIdByUuid(SessionConn *conn) in TransProxyGetAuthIdByUuid()
[all …]
|
| H A D | trans_tcp_direct_message.c | 238 static void SendFailToFlushDevice(SessionConn *conn) in SendFailToFlushDevice()
275 SessionConn *conn = (SessionConn *)SoftBusCalloc(sizeof(SessionConn)); in TransTdcPostBytes()
380 SessionConn conn; in NotifyChannelOpened()
434 SessionConn conn; in NotifyChannelBind()
512 SessionConn conn; in NotifyChannelOpenFailed()
522 static int32_t TransTdcPostFastData(SessionConn *conn) in TransTdcPostFastData()
619 SessionConn conn; in OpenDataBusReply()
620 (void)memset_s(&conn, sizeof(SessionConn), 0, sizeof(SessionConn)); in OpenDataBusReply()
727 SessionConn *conn = (SessionConn *)SoftBusCalloc(sizeof(SessionConn)); in GetSessionConnFromDataBusRequest()
744 static void NotifyFastDataRecv(SessionConn *conn, int32_t channelId) in NotifyFastDataRecv()
[all …]
|
| H A D | trans_tcp_direct_wifi.c | 41 static int32_t AddTcpConnAndSessionInfo(int32_t newchannelId, int32_t fd, SessionConn *newConn, in AddTcpConnAndSessionInfo()
94 static int32_t CopyAppInfoFastTransData(SessionConn *conn, const AppInfo *appInfo) in CopyAppInfoFastTransData()
128 SessionConn *newConn = CreateNewSessinConn(module, false); in OpenTcpDirectChannel()
|
| /ohos5.0/foundation/communication/dsoftbus/tests/core/transmission/trans_channel/tcp_direct/unittest/ |
| H A D | trans_tcp_direct_message_test.cpp | 71 SessionConn *TestSetSessionConn() in TestSetSessionConn()
73 SessionConn *conn = (SessionConn*)SoftBusCalloc(sizeof(SessionConn)); in TestSetSessionConn()
77 (void)memset_s(conn, sizeof(SessionConn), 0, sizeof(SessionConn)); in TestSetSessionConn()
217 SessionConn *conn = TestSetSessionConn();
277 SessionConn *conn = (SessionConn*)SoftBusMalloc(sizeof(SessionConn));
279 (void)memset_s(conn, sizeof(SessionConn), 0, sizeof(SessionConn));
285 SessionConn *con = TestSetSessionConn();
307 SessionConn *conn = (SessionConn*)SoftBusMalloc(sizeof(SessionConn));
309 (void)memset_s(conn, sizeof(SessionConn), 0, sizeof(SessionConn));
395 SessionConn *con = TestSetSessionConn();
[all …]
|
| H A D | trans_tcp_direct_wifi_test.cpp | 123 SessionConn *conn = (SessionConn *)SoftBusCalloc(sizeof(SessionConn));
199 SessionConn *conn = (SessionConn *)SoftBusCalloc(sizeof(SessionConn));
227 SessionConn *conn = (SessionConn *)SoftBusCalloc(sizeof(SessionConn));
254 SessionConn *conn = (SessionConn *)SoftBusCalloc(sizeof(SessionConn));
283 SessionConn *conn = (SessionConn *)SoftBusCalloc(sizeof(SessionConn));
311 SessionConn *conn = (SessionConn *)SoftBusCalloc(sizeof(SessionConn));
|
| H A D | trans_tcp_direct_p2p_test.cpp | 80 SessionConn *TestSetSessionConn() in TestSetSessionConn()
82 SessionConn *conn = static_cast<SessionConn *>(SoftBusCalloc(sizeof(SessionConn))); in TestSetSessionConn()
87 (void)memset_s(conn, sizeof(SessionConn), 0, sizeof(SessionConn)); in TestSetSessionConn()
228 SessionConn *conn = TestSetSessionConn();
448 SessionConn *conn = static_cast<SessionConn *>(SoftBusCalloc(sizeof(SessionConn)));
480 SessionConn *conn = static_cast<SessionConn *>(SoftBusCalloc(sizeof(SessionConn)));
563 SessionConn *conn = static_cast<SessionConn *>(SoftBusCalloc(sizeof(SessionConn)));
636 SessionConn *conn = static_cast<SessionConn *>(SoftBusCalloc(sizeof(SessionConn)));
|
| H A D | trans_core_tcp_direct_test.cpp | 88 SessionConn *TestSetSessionConn() in TestSetSessionConn()
90 SessionConn *conn = (SessionConn*)SoftBusCalloc(sizeof(SessionConn)); in TestSetSessionConn()
95 (void)memset_s(conn, sizeof(SessionConn), 0, sizeof(SessionConn)); in TestSetSessionConn()
171 SessionConn *conn = TestSetSessionConn();
480 SessionConn* conn = TestSetSessionConn();
537 SessionConn *conn = (SessionConn*)SoftBusCalloc(sizeof(SessionConn));
539 (void)memset_s(conn, sizeof(SessionConn), 0, sizeof(SessionConn));
584 SessionConn *conn = (SessionConn*)SoftBusCalloc(sizeof(SessionConn));
586 (void)memset_s(conn, sizeof(SessionConn), 0, sizeof(SessionConn));
|
| H A D | trans_tcp_direct_message_static_test.cpp | 84 SessionConn *TestSetSessionConn() in TestSetSessionConn()
86 SessionConn *conn = (SessionConn*)SoftBusCalloc(sizeof(SessionConn)); in TestSetSessionConn()
130 SessionConn *conn = (SessionConn *)SoftBusCalloc(sizeof(SessionConn));
186 SessionConn *conn = (SessionConn *)SoftBusCalloc(sizeof(SessionConn));
507 SessionConn *conn = (SessionConn *)SoftBusCalloc(sizeof(SessionConn));
523 SessionConn *con = TestSetSessionConn();
660 SessionConn *conn = TestSetSessionConn();
784 SessionConn conn;
836 SessionConn *conn = TestSetSessionConn();
856 SessionConn *chan = (SessionConn *)SoftBusCalloc(sizeof(SessionConn));
|
| H A D | trans_tcp_direct_listener_test.cpp | 98 SessionConn *conn = (SessionConn *)SoftBusMalloc(sizeof(SessionConn));
209 SessionConn *conn = (SessionConn *)SoftBusCalloc(sizeof(SessionConn));
|
| H A D | trans_tcp_direct_message_append_test.cpp | 109 SessionConn *TestSetSessionConn() in TestSetSessionConn()
111 SessionConn *conn = (SessionConn*)SoftBusCalloc(sizeof(SessionConn)); in TestSetSessionConn()
265 SessionConn *conn = TestSetSessionConn();
299 SessionConn *conn = TestSetSessionConn();
579 SessionConn *conn = TestSetSessionConn();
1384 SessionConn connInfo;
1385 (void)memset_s(&connInfo, sizeof(SessionConn), 0, sizeof(SessionConn));
1418 SessionConn connInfo;
1419 (void)memset_s(&connInfo, sizeof(SessionConn), 0, sizeof(SessionConn));
1452 SessionConn connInfo;
[all …]
|
| H A D | trans_tcp_direct_p2p_mock_test.cpp | 105 SessionConn *TestSetSessionConn() in TestSetSessionConn()
107 SessionConn *testConn = (SessionConn*)SoftBusCalloc(sizeof(SessionConn)); in TestSetSessionConn()
339 SessionConn *conn = TestSetSessionConn();
533 SessionConn *conn = TestSetSessionConn();
596 SessionConn *conn = TestSetSessionConn();
635 SessionConn *conn = TestSetSessionConn();
693 SessionConn *conn = TestSetSessionConn();
715 SessionConn *conn = TestSetSessionConn();
778 SessionConn *conn = TestSetSessionConn();
809 SessionConn *conn = TestSetSessionConn();
[all …]
|
| H A D | trans_server_tcp_direct_test.cpp | 78 static SessionConn *g_conn = NULL;
97 g_conn = (SessionConn *)SoftBusCalloc(sizeof(SessionConn)); in TestAddTestSessionConn()
204 SessionConn *session = CreateNewSessinConn(DIRECT_CHANNEL_CLIENT, isServerSide); in TestAddSessionConn()
294 static SessionConn *tmpSessionConn = NULL;
570 SessionConn *conn = (SessionConn*)SoftBusMalloc(sizeof(SessionConn));
571 (void)memset_s(conn, sizeof(SessionConn), 0, sizeof(SessionConn));
|
| /ohos5.0/foundation/communication/dsoftbus/core/transmission/trans_channel/tcp_direct/include/ |
| H A D | trans_tcp_direct_sessionconn.h | 56 } SessionConn; typedef
91 SessionConn *GetSessionConnByRequestId(uint32_t requestId);
93 SessionConn *GetSessionConnByReq(int64_t req);
95 SessionConn *CreateNewSessinConn(ListenerModule module, bool isServerSid);
97 int32_t GetSessionConnByFd(int32_t fd, SessionConn *conn);
99 int32_t GetSessionConnById(int32_t channelId, SessionConn *conn);
110 int32_t TransTdcAddSessionConn(SessionConn *conn);
|
| H A D | trans_tcp_direct_message.h | 40 int32_t NotifyChannelOpenFailedBySessionConn(const SessionConn *conn, int32_t errCode);
|
| /ohos5.0/foundation/communication/dsoftbus/tests/core/transmission/trans_channel/tcp_direct/unittest/mock/ |
| H A D | trans_tcp_direct_wifi_test_mock.h | 31 virtual SessionConn *CreateNewSessinConn(ListenerModule module, bool isServerSid) = 0;
36 virtual int32_t TransTdcAddSessionConn(SessionConn *conn) = 0;
45 MOCK_METHOD2(CreateNewSessinConn, SessionConn * (ListenerModule module, bool isServerSid));
51 MOCK_METHOD1(TransTdcAddSessionConn, int32_t (SessionConn *conn));
|
| H A D | trans_tcp_direct_wifi_test_mock.cpp | 39 SessionConn *CreateNewSessinConn(ListenerModule module, bool isServerSid) in CreateNewSessinConn()
64 int32_t TransTdcAddSessionConn(SessionConn *conn) in TransTdcAddSessionConn()
|
| H A D | trans_tcp_direct_p2p_test_mock.h | 58 virtual SessionConn *CreateNewSessinConn(ListenerModule module, bool isServerSid) = 0;
91 MOCK_METHOD2(CreateNewSessinConn, SessionConn *(ListenerModule module, bool isServerSid));
|
| H A D | trans_tcp_direct_p2p_test_mock.cpp | 155 SessionConn *CreateNewSessinConn(ListenerModule module, bool isServerSid) in CreateNewSessinConn()
|
| /ohos5.0/foundation/communication/dsoftbus/core/common/dfx/statistics/instant/ |
| H A D | instant_statistics.cpp | 215 static bool InstIsMatchSessionConn(const InstantRemoteInfo *rInfo, const SessionConn *conn) in InstIsMatchSessionConn()
318 static void UpdateRemoteInfoBySessionConn(InstantRemoteInfo *remoteInfo, const SessionConn *conn) in UpdateRemoteInfoBySessionConn()
380 static void InstAddSessionConnToRemoteInfo(InstantRemoteInfo *remoteInfo, SessionConn *conn) in InstAddSessionConnToRemoteInfo()
421 SessionConn *item = NULL; in InstUpdateRemoteInfoBySessionConn()
426 LIST_FOR_EACH_ENTRY(item, &sessionList->list, SessionConn, node) { in InstUpdateRemoteInfoBySessionConn()
|