Home
last modified time | relevance | path

Searched refs:channelId (Results 1 - 25 of 328) sorted by relevance

12345678910>>...14

/foundation/communication/dsoftbus/sdk/transmission/trans_channel/udp/stream/src/
H A Dclient_trans_stream.c45 static void SetStreamChannelStatus(int32_t channelId, int32_t status) in SetStreamChannelStatus() argument
54 TRANS_LOGI(TRANS_STREAM, "dstream connected. channelId=%{public}d", channelId); in SetStreamChannelStatus()
57 TRANS_LOGI(TRANS_STREAM, "dstream closed. channelId=%{public}d", channelId); in SetStreamChannelStatus()
60 TRANS_LOGI(TRANS_STREAM, "dstream init. channelId=%{public}d", channelId); in SetStreamChannelStatus()
63 TRANS_LOGI(TRANS_STREAM, "dstream opening. channelId=%{public}d", channelId); in SetStreamChannelStatus()
66 TRANS_LOGI(TRANS_STREAM, "dstream connecting. channelId in SetStreamChannelStatus()
77 OnStreamReceived(int32_t channelId, const StreamData *data, const StreamData *ext, const StreamFrameInfo *param) OnStreamReceived() argument
88 OnQosEvent(int channelId, int eventId, int tvCount, const QosTv *tvList) OnQosEvent() argument
96 OnFrameStats(int32_t channelId, const StreamSendStats *data) OnFrameStats() argument
106 OnRippleStats(int32_t channelId, const TrafficStats *data) OnRippleStats() argument
124 GetRawStreamEncryptOptByChannelId(int32_t channelId, bool *isEncryptRawStream) GetRawStreamEncryptOptByChannelId() argument
137 OnStreamUdpChannelOpened(int32_t channelId) OnStreamUdpChannelOpened() argument
208 TransSendStream(int32_t channelId, const StreamData *data, const StreamData *ext, const StreamFrameInfo *param) TransSendStream() argument
217 TransSetStreamMultiLayer(int32_t channelId, const void *optValue) TransSetStreamMultiLayer() argument
226 TransCloseStreamChannel(int32_t channelId) TransCloseStreamChannel() argument
[all...]
/foundation/communication/dsoftbus/sdk/transmission/trans_channel/manager/src/
H A Dclient_trans_channel_callback.c65 int32_t TransOnChannelOpenFailed(int32_t channelId, int32_t channelType, int32_t errCode) in TransOnChannelOpenFailed() argument
68 "[client]: channelId=%{public}d, channelType=%{public}d, errCode=%{public}d", in TransOnChannelOpenFailed()
69 channelId, channelType, errCode); in TransOnChannelOpenFailed()
72 return ClientTransAuthOnChannelOpenFailed(channelId, errCode); in TransOnChannelOpenFailed()
74 return ClientTransProxyOnChannelOpenFailed(channelId, errCode); in TransOnChannelOpenFailed()
76 return ClientTransTdcOnChannelOpenFailed(channelId, errCode); in TransOnChannelOpenFailed()
78 return TransOnUdpChannelOpenFailed(channelId, errCode); in TransOnChannelOpenFailed()
80 // channelId is sessionId in TransOnChannelOpenFailed()
81 return GetClientSessionCb()->OnSessionOpenFailed(channelId, channelType, errCode); in TransOnChannelOpenFailed()
98 static int32_t NofifyChannelClosed(int32_t channelId, int32_ argument
115 NofifyCloseAckReceived(int32_t channelId, int32_t channelType) NofifyCloseAckReceived() argument
129 TransOnChannelClosed(int32_t channelId, int32_t channelType, int32_t messageType, ShutdownReason reason) TransOnChannelClosed() argument
144 TransOnChannelMsgReceived(int32_t channelId, int32_t channelType, const void *data, unsigned int len, SessionPktType type) TransOnChannelMsgReceived() argument
165 TransOnChannelQosEvent(int32_t channelId, int32_t channelType, int32_t eventId, int32_t tvCount, const QosTv *tvList) TransOnChannelQosEvent() argument
188 TransOnChannelBind(int32_t channelId, int32_t channelType) TransOnChannelBind() argument
[all...]
H A Dclient_trans_channel_manager.c58 int32_t ClientTransCloseChannel(int32_t channelId, int32_t type) in ClientTransCloseChannel() argument
60 if (channelId < 0) { in ClientTransCloseChannel()
64 DeleteSocketResourceByChannelId(channelId, type); in ClientTransCloseChannel()
68 ClientTransProxyCloseChannel(channelId); in ClientTransCloseChannel()
71 TransDelDataBufNode(channelId); in ClientTransCloseChannel()
72 TransTdcCloseChannel(channelId); in ClientTransCloseChannel()
75 ret = ClientTransCloseUdpChannel(channelId, SHUTDOWN_REASON_LOCAL); in ClientTransCloseChannel()
78 ClientTransAuthCloseChannel(channelId, SHUTDOWN_REASON_LOCAL); in ClientTransCloseChannel()
87 int32_t ClientTransChannelSendBytes(int32_t channelId, int32_t channelType, const void *data, uint32_t len) in ClientTransChannelSendBytes() argument
97 ret = TransAuthChannelSendBytes(channelId, dat in ClientTransChannelSendBytes()
112 ClientTransChannelSendMessage(int32_t channelId, int32_t channelType, const void *data, uint32_t len) ClientTransChannelSendMessage() argument
137 ClientTransChannelSendStream(int32_t channelId, int32_t channelType, const StreamData *data, const StreamData *ext, const StreamFrameInfo *param) ClientTransChannelSendStream() argument
157 ClientTransChannelSendFile(int32_t channelId, int32_t channelType, const char *sFileList[], const char *dFileList[], uint32_t fileCnt) ClientTransChannelSendFile() argument
180 ClientGetSessionKey(int32_t channelId, char *key, unsigned int len) ClientGetSessionKey() argument
185 ClientGetHandle(int32_t channelId, int *handle) ClientGetHandle() argument
190 ClientDisableSessionListener(int32_t channelId) ClientDisableSessionListener() argument
[all...]
/foundation/communication/dsoftbus/sdk/transmission/trans_channel/udp/common/src/
H A Dclient_trans_udp_manager.c53 if (channelNode->channelId == channel->channelId) { in ClientTransAddUdpChannel()
54 TRANS_LOGE(TRANS_SDK, "udp channel has exited.channelId=%{public}d.", channel->channelId); in ClientTransAddUdpChannel()
61 TRANS_LOGI(TRANS_SDK, "add channelId=%{public}d", channel->channelId); in ClientTransAddUdpChannel()
68 int32_t TransDeleteUdpChannel(int32_t channelId) in TransDeleteUdpChannel() argument
81 if (channelNode->channelId == channelId) { in TransDeleteUdpChannel()
83 TRANS_LOGI(TRANS_SDK, "delete channelId in TransDeleteUdpChannel()
95 TransGetUdpChannel(int32_t channelId, UdpChannel *channel) TransGetUdpChannel() argument
127 TransSetUdpChannelEnable(int32_t channelId, bool isEnable) TransSetUdpChannelEnable() argument
152 OnUdpChannelOpened(int32_t channelId) OnUdpChannelOpened() argument
226 TransSetdFileIdByChannelId(int32_t channelId, int32_t value) TransSetdFileIdByChannelId() argument
321 TransOnUdpChannelOpenFailed(int32_t channelId, int32_t errCode) TransOnUdpChannelOpenFailed() argument
347 TransOnUdpChannelBind(int32_t channelId, int32_t channelType) TransOnUdpChannelBind() argument
361 ClosePeerUdpChannel(int32_t channelId) ClosePeerUdpChannel() argument
366 RleaseUdpResources(int32_t channelId) RleaseUdpResources() argument
371 NotifyCallback(UdpChannel *channel, int32_t channelId, ShutdownReason reason) NotifyCallback() argument
390 CloseUdpChannelProc(UdpChannel *channel, int32_t channelId, ShutdownReason reason) CloseUdpChannelProc() argument
434 CloseUdpChannel(int32_t channelId, ShutdownReason reason) CloseUdpChannel() argument
455 TransOnUdpChannelClosed(int32_t channelId, ShutdownReason reason) TransOnUdpChannelClosed() argument
460 TransOnUdpChannelQosEvent(int32_t channelId, int32_t eventId, int32_t tvCount, const QosTv *tvList) TransOnUdpChannelQosEvent() argument
474 ClientTransCloseUdpChannel(int32_t channelId, ShutdownReason reason) ClientTransCloseUdpChannel() argument
492 TransUdpChannelSendStream(int32_t channelId, const StreamData *data, const StreamData *ext, const StreamFrameInfo *param) TransUdpChannelSendStream() argument
508 TransUdpChannelSetStreamMultiLayer(int32_t channelId, const void *optValue) TransUdpChannelSetStreamMultiLayer() argument
523 OnUdpChannelClosed(int32_t channelId, ShutdownReason reason) OnUdpChannelClosed() argument
534 OnStreamReceived(int32_t channelId, const StreamData *data, const StreamData *ext, const StreamFrameInfo *param) OnStreamReceived() argument
543 OnFileGetSessionId(int32_t channelId, int32_t *sessionId) OnFileGetSessionId() argument
551 OnQosEvent(int channelId, int eventId, int tvCount, const QosTv *tvList) OnQosEvent() argument
567 OnRawStreamEncryptOptGet(int32_t channelId, bool *isEncrypt) OnRawStreamEncryptOptGet() argument
668 TransUdpChannelSendFile(int32_t channelId, const char *sFileList[], const char *dFileList[], uint32_t fileCnt) TransUdpChannelSendFile() argument
718 TransLimitChange(int32_t channelId, uint8_t tos) TransLimitChange() argument
753 TransUdpOnCloseAckReceived(int32_t channelId) TransUdpOnCloseAckReceived() argument
759 ClientEmitFileEvent(int32_t channelId) ClientEmitFileEvent() argument
779 TransSetUdpChanelSessionId(int32_t channelId, int32_t sessionId) TransSetUdpChanelSessionId() argument
804 TransSetUdpChannelRenameHook(int32_t channelId, OnRenameFileCallback onRenameFile) TransSetUdpChannelRenameHook() argument
[all...]
H A Dclient_trans_udp_virtual.c39 int32_t TransOnUdpChannelOpenFailed(int32_t channelId, int32_t errCode) in TransOnUdpChannelOpenFailed() argument
41 (void)channelId; in TransOnUdpChannelOpenFailed()
45 int32_t TransOnUdpChannelClosed(int32_t channelId, ShutdownReason reason) in TransOnUdpChannelClosed() argument
47 (void)channelId; in TransOnUdpChannelClosed()
51 int32_t ClientTransCloseUdpChannel(int32_t channelId, ShutdownReason reason) in ClientTransCloseUdpChannel() argument
53 (void)channelId; in ClientTransCloseUdpChannel()
58 int32_t TransUdpChannelSendStream(int32_t channelId, const StreamData *data, const StreamData *ext, in TransUdpChannelSendStream() argument
61 (void)channelId; in TransUdpChannelSendStream()
68 int32_t TransUdpChannelSendFile(int32_t channelId, const char *sFileList[], const char *dFileList[], uint32_t fileCnt) in TransUdpChannelSendFile() argument
70 (void)channelId; in TransUdpChannelSendFile()
89 TransOnUdpChannelQosEvent(int32_t channelId, int32_t eventId, int32_t tvCount, const QosTv *tvList) TransOnUdpChannelQosEvent() argument
98 TransGetUdpChannel(int32_t channelId, UdpChannel *udpChannel) TransGetUdpChannel() argument
[all...]
/foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/udp/stream/
H A Dclient_trans_udp_stream_interface_test.cpp49 void ClientSetStatus(int32_t channelId, int32_t status) in ClientSetStatus() argument
51 std::cout << "[server]:channelID:" << channelId << ", status:" << status << std::endl; in ClientSetStatus()
87 int32_t channelId = -1; in HWTEST_F() local
88 int32_t ret = StartVtpStreamChannelServer(channelId, &g_serverParam1, &g_callback); in HWTEST_F()
90 ret = CloseVtpStreamChannel(channelId, g_pkgName); in HWTEST_F()
102 int32_t channelId = 1; in HWTEST_F() local
103 int32_t ret = StartVtpStreamChannelServer(channelId, &g_serverParam1, &g_callback); in HWTEST_F()
105 ret = StartVtpStreamChannelServer(channelId, &g_serverParam1, &g_callback); in HWTEST_F()
107 CloseVtpStreamChannel(channelId, g_pkgName); in HWTEST_F()
118 int32_t channelId in HWTEST_F() local
132 int32_t channelId = 1; HWTEST_F() local
147 int32_t channelId = 1; HWTEST_F() local
160 int32_t channelId = 1; HWTEST_F() local
182 int32_t channelId = 1; HWTEST_F() local
217 int32_t channelId = 1; HWTEST_F() local
[all...]
H A Dclient_trans_stream_test.cpp61 int32_t channelId = 12; in HWTEST_F() local
63 SetStreamChannelStatus(channelId, status); in HWTEST_F()
73 SetStreamChannelStatus(channelId, status); in HWTEST_F()
76 SetStreamChannelStatus(channelId, status); in HWTEST_F()
79 SetStreamChannelStatus(channelId, status); in HWTEST_F()
82 SetStreamChannelStatus(channelId, status); in HWTEST_F()
85 SetStreamChannelStatus(channelId, status); in HWTEST_F()
88 SetStreamChannelStatus(channelId, status); in HWTEST_F()
91 SetStreamChannelStatus(channelId, status); in HWTEST_F()
94 SetStreamChannelStatus(channelId, statu in HWTEST_F()
115 int32_t channelId = 12; HWTEST_F() local
150 int32_t channelId = 12; HWTEST_F() local
196 int32_t channelId = 12; HWTEST_F() local
270 int32_t channelId = -1; HWTEST_F() local
[all...]
/foundation/communication/dsoftbus/sdk/transmission/trans_channel/tcp_direct/src/
H A Dclient_trans_tcp_direct_manager.c52 TcpDirectChannelInfo *TransTdcGetInfoById(int32_t channelId, TcpDirectChannelInfo *info) in TransTdcGetInfoById() argument
60 if (item->channelId == channelId) { in TransTdcGetInfoById()
71 int32_t TransTdcSetListenerStateById(int32_t channelId, bool needStopListener) in TransTdcSetListenerStateById() argument
74 TRANS_LOGE(TRANS_SDK, "g_tcpDirectChannelInfoList is NULL, channelId=%{public}d", channelId); in TransTdcSetListenerStateById()
78 TRANS_LOGE(TRANS_SDK, "lock failed, channelId=%{public}d", channelId); in TransTdcSetListenerStateById()
84 if (item->channelId == channelId) { in TransTdcSetListenerStateById()
98 TransTdcGetInfoByIdWithIncSeq(int32_t channelId, TcpDirectChannelInfo *info) TransTdcGetInfoByIdWithIncSeq() argument
138 TransTdcCloseChannel(int32_t channelId) TransTdcCloseChannel() argument
207 ClientTransCheckTdcChannelExist(int32_t channelId) ClientTransCheckTdcChannelExist() argument
225 TransTdcDelChannelInfo(int32_t channelId, int32_t errCode) TransTdcDelChannelInfo() argument
400 ClientTransTdcOnChannelOpenFailed(int32_t channelId, int32_t errCode) ClientTransTdcOnChannelOpenFailed() argument
405 TransTdcGetSessionKey(int32_t channelId, char *key, unsigned int len) TransTdcGetSessionKey() argument
423 TransTdcGetHandle(int32_t channelId, int *handle) TransTdcGetHandle() argument
438 TransDisableSessionListener(int32_t channelId) TransDisableSessionListener() argument
458 TransUpdateFdState(int32_t channelId) TransUpdateFdState() argument
[all...]
H A Dclient_trans_tcp_direct_callback.c45 int32_t ClientTransTdcOnSessionClosed(int32_t channelId, ShutdownReason reason) in ClientTransTdcOnSessionClosed() argument
47 (void)TransDelDataBufNode(channelId); in ClientTransTdcOnSessionClosed()
48 (void)TransTdcCloseChannel(channelId); in ClientTransTdcOnSessionClosed()
49 return g_sessionCb.OnSessionClosed(channelId, CHANNEL_TYPE_TCP_DIRECT, reason); in ClientTransTdcOnSessionClosed()
52 int32_t ClientTransTdcOnSessionOpenFailed(int32_t channelId, int32_t errCode) in ClientTransTdcOnSessionOpenFailed() argument
54 return g_sessionCb.OnSessionOpenFailed(channelId, CHANNEL_TYPE_TCP_DIRECT, errCode); in ClientTransTdcOnSessionOpenFailed()
57 int32_t ClientTransTdcOnDataReceived(int32_t channelId, in ClientTransTdcOnDataReceived() argument
60 return g_sessionCb.OnDataReceived(channelId, CHANNEL_TYPE_TCP_DIRECT, data, len, type); in ClientTransTdcOnDataReceived()
63 int32_t ClientTransTdcOnChannelBind(int32_t channelId, int32_t channelType) in ClientTransTdcOnChannelBind() argument
66 TRANS_LOGW(TRANS_SDK, "OnChannelBind is null channelId in ClientTransTdcOnChannelBind()
[all...]
/foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/proxy/
H A Dclient_trans_proxy_manager_test.cpp74 int32_t TransOnSessionClosed(int32_t channelId, int32_t channelType, ShutdownReason reason) in TransOnSessionClosed() argument
79 int32_t TransOnSessionOpenFailed(int32_t channelId, int32_t channelType, int32_t errCode) in TransOnSessionOpenFailed() argument
84 int32_t TransOnBytesReceived(int32_t channelId, int32_t channelType, in TransOnBytesReceived() argument
90 int32_t TransOnOnStreamRecevied(int32_t channelId, int32_t channelType, in TransOnOnStreamRecevied() argument
96 int32_t TransOnGetSessionId(int32_t channelId, int32_t channelType, int32_t *sessionId) in TransOnGetSessionId() argument
100 int32_t TransOnQosEvent(int32_t channelId, int32_t channelType, int32_t eventId, in TransOnQosEvent() argument
123 int32_t OnSessionClosed(int32_t channelId, int32_t channelType, ShutdownReason reason) in OnSessionClosed() argument
125 (void)channelId; in OnSessionClosed()
131 int32_t OnSessionOpenFailed(int32_t channelId, int32_t channelType, int32_t errCode) in OnSessionOpenFailed() argument
133 (void)channelId; in OnSessionOpenFailed()
139 OnBytesReceived(int32_t channelId, int32_t channelType, const void *data, uint32_t len, SessionPktType type) OnBytesReceived() argument
211 int32_t channelId = 1; HWTEST_F() local
227 int32_t channelId = 1; HWTEST_F() local
290 int32_t channelId = 1; HWTEST_F() local
346 int32_t channelId = 1; HWTEST_F() local
375 int32_t channelId = 1; HWTEST_F() local
404 int32_t channelId = 1; HWTEST_F() local
436 int32_t channelId = 1; HWTEST_F() local
450 int32_t channelId = 1; HWTEST_F() local
473 int32_t channelId = 1; HWTEST_F() local
492 int32_t channelId = 1; HWTEST_F() local
516 int32_t channelId = -1; HWTEST_F() local
[all...]
/foundation/communication/dsoftbus/tests/core/transmission/trans_channel/proxy_channel/
H A Dsoftbus_proxychannel_pipeline_test.cpp61 static void OnDataReceived(int32_t channelId, const char *data, uint32_t len) in OnDataReceived() argument
63 (void)channelId; in OnDataReceived()
68 static void OnDisconnected(int32_t channelId) in OnDisconnected() argument
70 (void)channelId; in OnDisconnected()
89 static void OnProxyChannelOpened(int32_t channelRequestId, int32_t channelId) in OnProxyChannelOpened() argument
91 TRANS_LOGI(TRANS_TEST, "channelRequestId=%{public}d, channelId=%{public}d", channelRequestId, channelId); in OnProxyChannelOpened()
93 (void)channelId; in OnProxyChannelOpened()
149 int32_t channelId = TEST_NUMBER_TWO; in HWTEST_F() local
151 int32_t ret = TransProxyPipelineGetUuidByChannelId(channelId, uui in HWTEST_F()
195 int32_t channelId = TEST_NUMBER_TEN; HWTEST_F() local
214 int32_t channelId = TEST_NUMBER_TEN; HWTEST_F() local
235 int32_t channelId = TEST_NUMBER_25; HWTEST_F() local
255 int32_t channelId = TEST_NUMBER_25; HWTEST_F() local
281 int32_t channelId = 1; HWTEST_F() local
303 int32_t channelId = INVALID_CHANNEL_ID; HWTEST_F() local
320 int32_t channelId = INVALID_CHANNEL_ID; HWTEST_F() local
[all...]
H A Dtrans_proxy_manager_test.cpp78 int32_t TestOnDataReceived(const char *pkgName, int32_t pid, int32_t channelId, int32_t channelType, in TestOnDataReceived() argument
83 (void)channelId; in TestOnDataReceived()
103 int32_t channelId, int32_t channelType, int32_t messageType) in TestOnChannelClosed()
107 (void)channelId; in TestOnChannelClosed()
115 int32_t TestOnChannelOpenFailed(const char *pkgName, int32_t pid, int32_t channelId, in TestOnChannelOpenFailed() argument
120 (void)channelId; in TestOnChannelOpenFailed()
148 void TestOnNetworkingChannelOpenFailed(int32_t channelId, const char *uuid) in TestOnNetworkingChannelOpenFailed() argument
150 (void)channelId; in TestOnNetworkingChannelOpenFailed()
181 void TestTransProxyAddAuthChannel(int32_t channelId, const char *identity, ProxyChannelStatus status) in TestTransProxyAddAuthChannel() argument
190 chan->authId = channelId; in TestTransProxyAddAuthChannel()
102 TestOnChannelClosed(const char *pkgName, int32_t pid, int32_t channelId, int32_t channelType, int32_t messageType) TestOnChannelClosed() argument
204 TestTransProxyAddNormalChannel(int32_t channelId, const char *identity, ProxyChannelStatus status) TestTransProxyAddNormalChannel() argument
266 int32_t channelId = -1; HWTEST_F() local
286 int32_t channelId = -1; HWTEST_F() local
375 int32_t channelId = -1; HWTEST_F() local
408 int32_t channelId = m_testProxyNormalChannelId; HWTEST_F() local
426 int32_t channelId = -1; HWTEST_F() local
443 int32_t channelId = -1; HWTEST_F() local
464 int32_t channelId = -1; HWTEST_F() local
484 int32_t channelId = -1; HWTEST_F() local
502 int32_t channelId = -1; HWTEST_F() local
521 int32_t channelId = -1; HWTEST_F() local
563 int32_t channelId = -1; HWTEST_F() local
582 int32_t channelId = 25; HWTEST_F() local
751 int32_t channelId = 15; HWTEST_F() local
823 int32_t channelId = -1; HWTEST_F() local
870 int32_t channelId = 31; HWTEST_F() local
901 int32_t channelId = 32; HWTEST_F() local
[all...]
H A Dsoftbus_proxy_session_test.cpp89 int32_t TestSessionDataReceived(const char *pkgName, int32_t pid, int32_t channelId, int32_t channelType, in TestSessionDataReceived() argument
94 (void)channelId; in TestSessionDataReceived()
117 void TestAddProxyChannel(int32_t channelId, AppType appType, ProxyChannelStatus status) in TestAddProxyChannel() argument
122 chan->authHandle.authId = channelId; in TestAddProxyChannel()
123 chan->connId = channelId; in TestAddProxyChannel()
124 chan->myId = channelId; in TestAddProxyChannel()
125 chan->peerId = channelId; in TestAddProxyChannel()
126 chan->reqId = channelId; in TestAddProxyChannel()
127 chan->channelId = channelId; in TestAddProxyChannel()
143 int32_t channelId = -1; HWTEST_F() local
165 int32_t channelId = TEST_VALID_CHANNELIDA; HWTEST_F() local
188 int32_t channelId = TEST_VALID_CHANNELIDB; HWTEST_F() local
233 int32_t channelId = -1; HWTEST_F() local
270 int32_t channelId = TEST_VALID_CHANNELIDC; HWTEST_F() local
328 int32_t channelId = TEST_VALID_CHANNELIDA; HWTEST_F() local
376 int32_t channelId = TEST_VALID_CHANNELIDA; HWTEST_F() local
408 int32_t channelId = 1; HWTEST_F() local
442 int32_t channelId = -1; HWTEST_F() local
[all...]
H A Dtrans_proxy_session_test.cpp92 int32_t TestSessionDataReceived(const char *pkgName, int32_t pid, int32_t channelId, int32_t channelType, in TestSessionDataReceived() argument
97 (void)channelId; in TestSessionDataReceived()
125 void TestAddProxyChannel(int32_t channelId, AppType appType, ProxyChannelStatus status) in TestAddProxyChannel() argument
139 chan->authId = channelId; in TestAddProxyChannel()
140 chan->connId = channelId; in TestAddProxyChannel()
141 chan->myId = channelId; in TestAddProxyChannel()
142 chan->peerId = channelId; in TestAddProxyChannel()
143 chan->reqId = channelId; in TestAddProxyChannel()
144 chan->channelId = channelId; in TestAddProxyChannel()
161 int32_t channelId = -1; HWTEST_F() local
183 int32_t channelId = TEST_VALID_CHANNELIDA; HWTEST_F() local
214 int32_t channelId = TEST_VALID_CHANNELIDB; HWTEST_F() local
252 int32_t channelId = -1; HWTEST_F() local
289 int32_t channelId = TEST_VALID_CHANNELIDC; HWTEST_F() local
350 int32_t channelId = TEST_VALID_CHANNELIDA; HWTEST_F() local
408 int32_t channelId = TEST_VALID_CHANNELIDA; HWTEST_F() local
444 int32_t channelId = 1; HWTEST_F() local
479 int32_t channelId = -1; HWTEST_F() local
500 int32_t channelId = -1; HWTEST_F() local
[all...]
H A Dtrans_proxy_network_test.cpp48 static int32_t TestOnNetworkChannelOpened(int32_t channelId, const char *uuid, unsigned char isServer);
49 static void TestOnNetworkChannelOpenFailed(int32_t channelId, const char *uuid);
50 static void TestOnNetworkChannelClosed(int32_t channelId);
51 static void TestOnNetworkMessageReceived(int32_t channelId, const char *data, uint32_t len);
72 int32_t TestChannelDataReceived(const char *pkgName, int32_t pid, int32_t channelId, int32_t channelType, in TestChannelDataReceived() argument
77 (void)channelId; in TestChannelDataReceived()
95 int32_t TransProxyNetworkTest::TestOnNetworkChannelOpened(int32_t channelId, const char *uuid, unsigned char isServer) in TestOnNetworkChannelOpened() argument
97 (void)channelId; in TestOnNetworkChannelOpened()
104 void TransProxyNetworkTest::TestOnNetworkChannelOpenFailed(int32_t channelId, const char *uuid) in TestOnNetworkChannelOpenFailed() argument
106 (void)channelId; in TestOnNetworkChannelOpenFailed()
112 TestOnNetworkChannelClosed(int32_t channelId) TestOnNetworkChannelClosed() argument
119 TestOnNetworkMessageReceived(int32_t channelId, const char *data, uint32_t len) TestOnNetworkMessageReceived() argument
187 int32_t channelId = -1; HWTEST_F() local
219 int32_t channelId = -1; HWTEST_F() local
240 int32_t channelId = -1; HWTEST_F() local
263 int32_t channelId = -1; HWTEST_F() local
[all...]
H A Dsoftbus_proxy_network_test.cpp50 static int32_t TestOnNetworkChannelOpened(int32_t channelId, const char *uuid, unsigned char isServer);
51 static void TestOnNetworkChannelOpenFailed(int32_t channelId, const char *uuid);
52 static void TestOnNetworkChannelClosed(int32_t channelId);
53 static void TestOnNetworkMessageReceived(int32_t channelId, const char *data, uint32_t len);
74 int32_t TestChannelDataReceived(const char *pkgName, int32_t pid, int32_t channelId, int32_t channelType, in TestChannelDataReceived() argument
79 (void)channelId; in TestChannelDataReceived()
97 int32_t SoftbusProxyNetworkTest::TestOnNetworkChannelOpened(int32_t channelId, const char *uuid, unsigned char isServer) in TestOnNetworkChannelOpened() argument
99 (void)channelId; in TestOnNetworkChannelOpened()
105 void SoftbusProxyNetworkTest::TestOnNetworkChannelOpenFailed(int32_t channelId, const char *uuid) in TestOnNetworkChannelOpenFailed() argument
107 (void)channelId; in TestOnNetworkChannelOpenFailed()
112 TestOnNetworkChannelClosed(int32_t channelId) TestOnNetworkChannelClosed() argument
118 TestOnNetworkMessageReceived(int32_t channelId, const char *data, uint32_t len) TestOnNetworkMessageReceived() argument
192 int32_t channelId = -1; HWTEST_F() local
222 int32_t channelId = -1; HWTEST_F() local
243 int32_t channelId = -1; HWTEST_F() local
266 int32_t channelId = -1; HWTEST_F() local
[all...]
/foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/manager/
H A Dclient_trans_channel_manager_test.cpp48 int32_t OnSessionClosed(int32_t channelId, int32_t channelType, ShutdownReason reason) in OnSessionClosed() argument
53 int32_t OnSessionOpenFailed(int32_t channelId, int32_t channelType, int32_t errCode) in OnSessionOpenFailed() argument
58 static int32_t OnDataReceived(int32_t channelId, int32_t channelType, in OnDataReceived() argument
64 static int32_t OnStreamReceived(int32_t channelId, int32_t channelType, const StreamData *data, in OnStreamReceived() argument
70 static int32_t OnQosEvent(int32_t channelId, int32_t channelType, int32_t eventId, in OnQosEvent() argument
109 int32_t channelId = 1; in HWTEST_F() local
110 int32_t ret = ClientTransCloseChannel(channelId, CHANNEL_TYPE_PROXY); in HWTEST_F()
113 ret = ClientTransCloseChannel(channelId, CHANNEL_TYPE_TCP_DIRECT); in HWTEST_F()
116 ret = ClientTransCloseChannel(channelId, CHANNEL_TYPE_AUTH); in HWTEST_F()
119 ret = ClientTransCloseChannel(channelId, CHANNEL_TYPE_BUT in HWTEST_F()
132 int32_t channelId = 1; HWTEST_F() local
162 int32_t channelId = 1; HWTEST_F() local
192 int32_t channelId = 1; HWTEST_F() local
221 int32_t channelId = 1; HWTEST_F() local
[all...]
H A Dclient_trans_channel_callback_test.cpp41 int32_t OnSessionClosed(int32_t channelId, int32_t channelType, ShutdownReason reason) in OnSessionClosed() argument
46 int32_t OnSessionOpenFailed(int32_t channelId, int32_t channelType, int32_t errCode) in OnSessionOpenFailed() argument
51 static int32_t OnDataReceived(int32_t channelId, int32_t channelType, in OnDataReceived() argument
57 static int32_t OnStreamReceived(int32_t channelId, int32_t channelType, const StreamData *data, in OnStreamReceived() argument
63 static int32_t OnQosEvent(int32_t channelId, int32_t channelType, int32_t eventId, in OnQosEvent() argument
69 static int32_t OnChannelBind(int32_t channelId, int32_t channelType) in OnChannelBind() argument
71 (void)channelId; in OnChannelBind()
163 int32_t channelId = 1; in HWTEST_F() local
164 int32_t ret = TransOnChannelOpenFailed(channelId, CHANNEL_TYPE_AUTH, SOFTBUS_MEM_ERR); in HWTEST_F()
167 ret = TransOnChannelOpenFailed(channelId, CHANNEL_TYPE_PROX in HWTEST_F()
206 int32_t channelId = 1; HWTEST_F() local
248 int32_t channelId = 1; HWTEST_F() local
276 int32_t channelId = 1; HWTEST_F() local
301 const int32_t channelId = 1; HWTEST_F() local
[all...]
/foundation/communication/dsoftbus/sdk/transmission/trans_channel/udp/common/include/
H A Dclient_trans_udp_manager.h30 void (*OnStreamReceived)(int32_t channelId, const StreamData *data, const StreamData *ext,
32 int32_t (*OnFileGetSessionId)(int32_t channelId, int32_t *sessionId);
34 int32_t (*OnUdpChannelOpened)(int32_t channelId);
35 void (*OnUdpChannelClosed)(int32_t channelId, ShutdownReason reason);
36 void (*OnQosEvent)(int channelId, int eventId, int tvCount, const QosTv *tvList);
39 int32_t (*OnRawStreamEncryptOptGet)(int32_t channelId, bool *isEncrypt);
55 int32_t channelId; member
69 int32_t TransOnUdpChannelOpenFailed(int32_t channelId, int32_t errCode);
70 int32_t TransOnUdpChannelClosed(int32_t channelId, ShutdownReason reason);
71 int32_t TransOnUdpChannelQosEvent(int32_t channelId, int32_
[all...]
/foundation/communication/dsoftbus/sdk/transmission/trans_channel/auth/src/
H A Dclient_trans_auth_manager.c50 int32_t ClientTransAuthOnChannelClosed(int32_t channelId, ShutdownReason reason) in ClientTransAuthOnChannelClosed() argument
52 int32_t ret = g_sessionCb.OnSessionClosed(channelId, CHANNEL_TYPE_AUTH, reason); in ClientTransAuthOnChannelClosed()
54 TRANS_LOGE(TRANS_SDK, "notify session open fail. ret=%{public}d, channelId=%{public}d", ret, channelId); in ClientTransAuthOnChannelClosed()
60 int32_t ClientTransAuthOnChannelOpenFailed(int32_t channelId, int32_t errCode) in ClientTransAuthOnChannelOpenFailed() argument
62 int32_t ret = g_sessionCb.OnSessionOpenFailed(channelId, CHANNEL_TYPE_AUTH, errCode); in ClientTransAuthOnChannelOpenFailed()
65 "notify session open fail. ret=%{public}d, errCode=%{public}d, channelId=%{public}d", in ClientTransAuthOnChannelOpenFailed()
66 ret, errCode, channelId); in ClientTransAuthOnChannelOpenFailed()
73 int32_t ClientTransAuthOnDataReceived(int32_t channelId, const void *data, uint32_t len, SessionPktType type) in ClientTransAuthOnDataReceived() argument
79 int32_t ret = g_sessionCb.OnDataReceived(channelId, CHANNEL_TYPE_AUT in ClientTransAuthOnDataReceived()
87 ClientTransAuthCloseChannel(int32_t channelId, ShutdownReason reason) ClientTransAuthCloseChannel() argument
98 TransAuthChannelSendBytes(int32_t channelId, const void *data, uint32_t len) TransAuthChannelSendBytes() argument
105 TransAuthChannelSendMessage(int32_t channelId, const void *data, uint32_t len) TransAuthChannelSendMessage() argument
[all...]
/foundation/communication/dsoftbus/sdk/transmission/trans_channel/proxy/include/
H A Dclient_trans_proxy_manager.h37 int32_t channelId; member
60 int32_t channelId; member
68 int32_t ClientTransProxyGetInfoByChannelId(int32_t channelId, ProxyChannelInfoDetail *info);
70 int32_t ClientTransProxyGetOsTypeByChannelId(int32_t channelId, int32_t *osType);
72 int32_t ClientTransProxyGetLinkTypeByChannelId(int32_t channelId, int32_t *linkType);
76 int32_t ClientTransProxyDelChannelInfo(int32_t channelId);
80 int32_t ClientTransProxyOnChannelClosed(int32_t channelId, ShutdownReason reason);
82 int32_t ClientTransProxyOnChannelOpenFailed(int32_t channelId, int32_t errCode);
84 int32_t ClientTransProxyOnDataReceived(int32_t channelId,
87 void ClientTransProxyCloseChannel(int32_t channelId);
[all...]
/foundation/communication/dsoftbus/tests/core/common/dfx/statistics/unittest/
H A Dtrans_network_statistics_test.cpp59 * @tc.desc: Test IsChannelDfxInfoValid when channelId is less than 0.
65 int32_t channelId = -1; in HWTEST_F() local
67 EXPECT_FALSE(IsChannelDfxInfoValid(channelId, channelType)); in HWTEST_F()
78 int32_t channelId = 1; in HWTEST_F() local
81 EXPECT_FALSE(IsChannelDfxInfoValid(channelId, channelType)); in HWTEST_F()
92 int32_t channelId = 1; in HWTEST_F() local
95 EXPECT_FALSE(IsChannelDfxInfoValid(channelId, channelType)); in HWTEST_F()
107 int32_t channelId = 1; in HWTEST_F() local
110 EXPECT_EQ(SOFTBUS_INVALID_PARAM, ChannelStatisticsInfoInit(nullptr, channelId, dataInfo, len)); in HWTEST_F()
121 int32_t channelId in HWTEST_F() local
135 int32_t channelId = 1; HWTEST_F() local
150 int32_t channelId = 1; HWTEST_F() local
212 int32_t channelId = -1; HWTEST_F() local
226 int32_t channelId = 1; HWTEST_F() local
268 int32_t channelId = 1; HWTEST_F() local
[all...]
/foundation/communication/dsoftbus/sdk/transmission/trans_channel/proxy/src/
H A Dclient_trans_proxy_manager.c175 int32_t ClientTransProxyGetInfoByChannelId(int32_t channelId, ProxyChannelInfoDetail *info) in ClientTransProxyGetInfoByChannelId() argument
188 if (item->channelId == channelId) { in ClientTransProxyGetInfoByChannelId()
197 TRANS_LOGE(TRANS_SDK, "can not find proxy channel by channelId=%{public}d", channelId); in ClientTransProxyGetInfoByChannelId()
201 int32_t ClientTransProxyGetOsTypeByChannelId(int32_t channelId, int32_t *osType) in ClientTransProxyGetOsTypeByChannelId() argument
204 TRANS_LOGE(TRANS_SDK, "param invalid channelId=%{public}d", channelId); in ClientTransProxyGetOsTypeByChannelId()
213 if (item->channelId == channelId) { in ClientTransProxyGetOsTypeByChannelId()
225 ClientTransProxyGetLinkTypeByChannelId(int32_t channelId, int32_t *linkType) ClientTransProxyGetLinkTypeByChannelId() argument
275 ClientTransProxyDelChannelInfo(int32_t channelId) ClientTransProxyDelChannelInfo() argument
354 ClientTransProxyOnChannelClosed(int32_t channelId, ShutdownReason reason) ClientTransProxyOnChannelClosed() argument
367 ClientTransProxyOnChannelOpenFailed(int32_t channelId, int32_t errCode) ClientTransProxyOnChannelOpenFailed() argument
401 ClientTransProxyDecryptPacketData(int32_t channelId, int32_t seq, ClientProxyDataInfo *dataInfo) ClientTransProxyDecryptPacketData() argument
448 ClientTransProxySendSessionAck(int32_t channelId, int32_t seq) ClientTransProxySendSessionAck() argument
472 ClientTransProxyProcSendMsgAck(int32_t channelId, const char *data, int32_t len, int32_t dataHeadSeq) ClientTransProxyProcSendMsgAck() argument
494 ClientTransProxyNotifySession( int32_t channelId, SessionPktType flags, int32_t seq, const char *data, uint32_t len) ClientTransProxyNotifySession() argument
521 ClientTransProxyProcessSessionData(int32_t channelId, const PacketHead *dataHead, const char *data) ClientTransProxyProcessSessionData() argument
566 ClientTransProxyNoSubPacketProc(int32_t channelId, const char *data, uint32_t len) ClientTransProxyNoSubPacketProc() argument
598 ClientTransProxyGetChannelSliceProcessor(int32_t channelId) ClientTransProxyGetChannelSliceProcessor() argument
635 TransProxyDelSliceProcessorByChannelId(int32_t channelId) TransProxyDelSliceProcessorByChannelId() argument
735 IsValidCheckoutProcess(int32_t channelId) IsValidCheckoutProcess() argument
748 ClientTransProxyLastSliceProcess( SliceProcessor *processor, const SliceHead *head, const char *data, uint32_t len, int32_t channelId) ClientTransProxyLastSliceProcess() argument
796 ClientTransProxySubPacketProc(int32_t channelId, const SliceHead *head, const char *data, uint32_t len) ClientTransProxySubPacketProc() argument
832 ClientTransProxySliceProc(int32_t channelId, const char *data, uint32_t len) ClientTransProxySliceProc() argument
885 ClientTransProxyOnDataReceived(int32_t channelId, const void *data, uint32_t len, SessionPktType type) ClientTransProxyOnDataReceived() argument
904 ClientTransProxyCloseChannel(int32_t channelId) ClientTransProxyCloseChannel() argument
914 ClientTransProxyPackBytes( int32_t channelId, ClientProxyDataInfo *dataInfo, int seq, char *sessionKey, SessionPktType flag) ClientTransProxyPackBytes() argument
972 TransProxyPackAndSendData( int32_t channelId, const void *data, uint32_t len, ProxyChannelInfoDetail *info, SessionPktType pktType) TransProxyPackAndSendData() argument
1030 TransProxyChannelSendBytes(int32_t channelId, const void *data, uint32_t len) TransProxyChannelSendBytes() argument
1045 TransProxyChannelSendMessage(int32_t channelId, const void *data, uint32_t len) TransProxyChannelSendMessage() argument
1072 ClientTransProxyOnChannelBind(int32_t channelId, int32_t channelType) ClientTransProxyOnChannelBind() argument
[all...]
/foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/tcp_direct/
H A Dtrans_sdk_tcp_direct_test.cpp99 static int32_t OnSessionClosed(int32_t channelId, int32_t channelType, ShutdownReason reason) in OnSessionClosed() argument
101 TRANS_LOGI(TRANS_TEST, "session closed, channelId=%{public}d", channelId); in OnSessionClosed()
105 static int32_t OnSessionOpenFailed(int32_t channelId, int32_t channelType, int32_t errCode) in OnSessionOpenFailed() argument
107 TRANS_LOGI(TRANS_TEST, "session bytes received, channelId=%{public}d", channelId); in OnSessionOpenFailed()
111 static int32_t OnDataReceived(int32_t channelId, int32_t channelType, in OnDataReceived() argument
114 TRANS_LOGI(TRANS_TEST, "session msg received, channelId=%{public}d", channelId); in OnDataReceived()
129 info->channelId in TestGetChannelInfo()
193 int32_t channelId = 1; HWTEST_F() local
220 int32_t channelId = 1; HWTEST_F() local
249 int32_t channelId = 1; HWTEST_F() local
279 int32_t channelId = 1; HWTEST_F() local
315 int32_t channelId = 1; HWTEST_F() local
379 int32_t channelId = 1; HWTEST_F() local
457 int32_t channelId = 1; HWTEST_F() local
528 int32_t channelId = 1; HWTEST_F() local
546 int32_t channelId = 1; HWTEST_F() local
575 int32_t channelId = 1; HWTEST_F() local
606 int32_t channelId = 1; HWTEST_F() local
637 int32_t channelId = 1; HWTEST_F() local
[all...]
/foundation/communication/dsoftbus/tests/core/transmission/trans_channel/tcp_direct/unittest/
H A Dtrans_tcp_direct_message_test.cpp79 conn->channelId = 1; in TestSetSessionConn()
134 int32_t channelId = 1; in HWTEST_F() local
137 int32_t ret = OpenP2pDirectChannel(nullptr, connInfo, &channelId); in HWTEST_F()
140 ret = OpenP2pDirectChannel(appInfo, nullptr, &channelId); in HWTEST_F()
146 ret = OpenP2pDirectChannel(appInfo, connInfo, &channelId); in HWTEST_F()
159 ret = OpenP2pDirectChannel(appInfo, connInfo, &channelId); in HWTEST_F()
163 ret = OpenP2pDirectChannel(appInfo, connInfo, &channelId); in HWTEST_F()
307 int32_t channelId = 1; in HWTEST_F() local
312 int32_t session = GetSessionConnById(channelId, nullptr); in HWTEST_F()
315 channelId in HWTEST_F()
330 int32_t channelId = 1; HWTEST_F() local
350 int32_t channelId = 1; HWTEST_F() local
370 int32_t channelId = 1; HWTEST_F() local
388 int32_t channelId = 1; HWTEST_F() local
414 int32_t channelId = 1; HWTEST_F() local
460 int32_t channelId = 1; HWTEST_F() local
487 int32_t channelId = 1; HWTEST_F() local
514 int32_t channelId = 1; HWTEST_F() local
599 int32_t *channelId = GetChannelIdsByAuthIdAndStatus(&count, &authHandle, TCP_DIRECT_CHANNEL_STATUS_VERIFY_P2P); HWTEST_F() local
[all...]

Completed in 13 milliseconds

12345678910>>...14