| /foundation/communication/dsoftbus/sdk/transmission/trans_channel/tcp_direct/src/ |
| H A D | client_trans_tcp_direct_callback.c | 28 static IClientSessionCallBack g_sessionCb; variable
36 g_sessionCb = *cb; in ClientTransTdcSetCallBack()
42 return g_sessionCb.OnSessionOpened(sessionName, channel, TYPE_BYTES); in ClientTransTdcOnSessionOpened()
49 return g_sessionCb.OnSessionClosed(channelId, CHANNEL_TYPE_TCP_DIRECT, reason); in ClientTransTdcOnSessionClosed()
54 return g_sessionCb.OnSessionOpenFailed(channelId, CHANNEL_TYPE_TCP_DIRECT, errCode); in ClientTransTdcOnSessionOpenFailed()
60 return g_sessionCb.OnDataReceived(channelId, CHANNEL_TYPE_TCP_DIRECT, data, len, type); in ClientTransTdcOnDataReceived()
65 if (g_sessionCb.OnChannelBind == NULL) { in ClientTransTdcOnChannelBind()
70 int32_t ret = g_sessionCb.OnChannelBind(channelId, channelType); in ClientTransTdcOnChannelBind()
89 g_sessionCb.OnSessionClosed(channelId, CHANNEL_TYPE_TCP_DIRECT, SHUTDOWN_REASON_LOCAL); in ClientTransTdcOnChannelBind()
96 g_sessionCb in ClientTransTdcOnChannelBind()
[all...] |
| /foundation/communication/dsoftbus/sdk/transmission/trans_channel/udp/common/src/ |
| H A D | client_trans_udp_manager.c | 33 static IClientSessionCallBack *g_sessionCb = NULL; variable
192 if ((g_sessionCb != NULL) && (g_sessionCb->OnSessionOpened != NULL)) { in OnUdpChannelOpened()
193 return g_sessionCb->OnSessionOpened(channel.info.mySessionName, &info, type); in OnUdpChannelOpened()
339 if ((g_sessionCb == NULL) || (g_sessionCb->OnSessionOpenFailed == NULL)) { in TransOnUdpChannelOpenFailed()
344 return g_sessionCb->OnSessionOpenFailed(channelId, CHANNEL_TYPE_UDP, errCode); in TransOnUdpChannelOpenFailed()
349 if ((g_sessionCb == NULL) || (g_sessionCb->OnChannelBind == NULL)) { in TransOnUdpChannelBind()
354 int32_t ret = g_sessionCb in TransOnUdpChannelBind()
[all...] |
| /foundation/communication/dsoftbus/sdk/transmission/trans_channel/auth/src/ |
| H A D | client_trans_auth_manager.c | 22 static IClientSessionCallBack g_sessionCb; variable
30 g_sessionCb = *cb; in ClientTransAuthInit()
41 int32_t ret = g_sessionCb.OnSessionOpened(sessionName, channel, TYPE_MESSAGE); in ClientTransAuthOnChannelOpened()
52 int32_t ret = g_sessionCb.OnSessionClosed(channelId, CHANNEL_TYPE_AUTH, reason); in ClientTransAuthOnChannelClosed()
62 int32_t ret = g_sessionCb.OnSessionOpenFailed(channelId, CHANNEL_TYPE_AUTH, errCode); in ClientTransAuthOnChannelOpenFailed()
79 int32_t ret = g_sessionCb.OnDataReceived(channelId, CHANNEL_TYPE_AUTH, data, len, type); in ClientTransAuthOnDataReceived()
|
| /foundation/communication/dsoftbus/sdk/transmission/session/src/ |
| H A D | client_trans_session_callback.c | 35 static IClientSessionCallBack g_sessionCb; variable
628 g_sessionCb.OnSessionOpened = TransOnSessionOpened; in GetClientSessionCb()
629 g_sessionCb.OnSessionClosed = TransOnSessionClosed; in GetClientSessionCb()
630 g_sessionCb.OnSessionOpenFailed = TransOnSessionOpenFailed; in GetClientSessionCb()
631 g_sessionCb.OnDataReceived = TransOnDataReceived; in GetClientSessionCb()
632 g_sessionCb.OnStreamReceived = TransOnOnStreamRecevied; in GetClientSessionCb()
633 g_sessionCb.OnGetSessionId = ClientGetSessionIdByChannelId; in GetClientSessionCb()
634 g_sessionCb.OnQosEvent = TransOnQosEvent; in GetClientSessionCb()
635 g_sessionCb.OnIdleTimeoutReset = ClientResetIdleTimeoutById; in GetClientSessionCb()
636 g_sessionCb in GetClientSessionCb()
[all...] |
| /foundation/communication/dsoftbus/sdk/transmission/trans_channel/proxy/src/ |
| H A D | client_trans_proxy_manager.c | 39 static IClientSessionCallBack g_sessionCb; variable
140 g_sessionCb = *cb; in ClientTransProxyInit()
340 ret = g_sessionCb.OnSessionOpened(sessionName, channel, TYPE_MESSAGE); in ClientTransProxyOnChannelOpened()
359 int ret = g_sessionCb.OnSessionClosed(channelId, CHANNEL_TYPE_PROXY, reason); in ClientTransProxyOnChannelClosed()
369 int ret = g_sessionCb.OnSessionOpenFailed(channelId, CHANNEL_TYPE_PROXY, errCode); in ClientTransProxyOnChannelOpenFailed()
500 return g_sessionCb.OnDataReceived(channelId, CHANNEL_TYPE_PROXY, data, len, flags); in ClientTransProxyNotifySession()
514 return g_sessionCb.OnDataReceived(channelId, CHANNEL_TYPE_PROXY, data, len, flags); in ClientTransProxyNotifySession()
898 return g_sessionCb.OnDataReceived(channelId, CHANNEL_TYPE_PROXY, data, len, TRANS_SESSION_BYTES); in ClientTransProxyOnDataReceived()
1074 if (g_sessionCb.OnChannelBind == NULL) { in ClientTransProxyOnChannelBind()
1078 int32_t ret = g_sessionCb in ClientTransProxyOnChannelBind()
[all...] |
| /foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/tcp_direct/ |
| H A D | trans_sdk_tcp_direct_test.cpp | 117 static IClientSessionCallBack g_sessionCb = { member
151 TransTdcManagerInit(&g_sessionCb); in SetUpTestCase()
197 TransTdcManagerInit(&g_sessionCb); in HWTEST_F()
430 int32_t ret = ClientTransTdcSetCallBack(&g_sessionCb); in HWTEST_F()
459 int32_t ret = ClientTransTdcSetCallBack(&g_sessionCb); in HWTEST_F()
|
| /foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/udp/common/ |
| H A D | client_trans_udp_manager_test.cpp | 83 static IClientSessionCallBack g_sessionCb = { member
92 int32_t ret = ClientTransUdpMgrInit(&g_sessionCb); in SetUpTestCase()
251 ret = ClientTransUdpMgrInit(&g_sessionCb); in HWTEST_F()
|
| /foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/proxy/ |
| H A D | client_trans_proxy_manager_test.cpp | 150 static IClientSessionCallBack g_sessionCb = { member
416 ret = ClientTransProxyInit(&g_sessionCb); in HWTEST_F()
434 int32_t ret = ClientTransProxyInit(&g_sessionCb); in HWTEST_F()
|