Home
last modified time | relevance | path

Searched refs:channelType (Results 1 - 25 of 156) sorted by relevance

1234567

/foundation/communication/dsoftbus/sdk/transmission/trans_channel/manager/src/
H A Dclient_trans_channel_callback.c39 switch (channel->channelType) { in TransOnChannelOpened()
58 if (channel->channelType == CHANNEL_TYPE_UDP && channel->isServer && udpPort > 0) { in TransOnChannelOpened()
65 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()
70 switch (channelType) { in TransOnChannelOpenFailed()
81 return GetClientSessionCb()->OnSessionOpenFailed(channelId, channelType, errCode); in TransOnChannelOpenFailed()
98 static int32_t NofifyChannelClosed(int32_t channelId, int32_t channelType, ShutdownReason reason) in NofifyChannelClosed() argument
100 DeleteSocketResourceByChannelId(channelId, channelType); in NofifyChannelClosed()
101 switch (channelType) { in NofifyChannelClosed()
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
183 TransSetChannelInfo(const char* sessionName, int32_t sessionId, int32_t channleId, int32_t channelType) TransSetChannelInfo() argument
188 TransOnChannelBind(int32_t channelId, int32_t channelType) TransOnChannelBind() argument
[all...]
H A Dclient_trans_channel_manager.c87 int32_t ClientTransChannelSendBytes(int32_t channelId, int32_t channelType, const void *data, uint32_t len) in ClientTransChannelSendBytes() argument
95 switch (channelType) { in ClientTransChannelSendBytes()
106 TRANS_LOGE(TRANS_SDK, "Invalid channelType=%{public}d", channelType); in ClientTransChannelSendBytes()
112 int32_t ClientTransChannelSendMessage(int32_t channelId, int32_t channelType, const void *data, uint32_t len) in ClientTransChannelSendMessage() argument
120 switch (channelType) { in ClientTransChannelSendMessage()
131 TRANS_LOGE(TRANS_MSG, "Invalid channelType=%{public}d", channelType); in ClientTransChannelSendMessage()
137 int32_t ClientTransChannelSendStream(int32_t channelId, int32_t channelType, const StreamData *data, in ClientTransChannelSendStream() argument
146 switch (channelType) { in ClientTransChannelSendStream()
157 ClientTransChannelSendFile(int32_t channelId, int32_t channelType, const char *sFileList[], const char *dFileList[], uint32_t fileCnt) ClientTransChannelSendFile() argument
[all...]
/foundation/communication/dsoftbus/sdk/frame/small/src/
H A Dtrans_client_stub.c31 ReadInt32(data, &(channel.channelType)); in ClientOnChannelOpened()
47 if (channel.channelType == CHANNEL_TYPE_TCP_DIRECT) { in ClientOnChannelOpened()
53 if (channel.channelType == CHANNEL_TYPE_UDP) { in ClientOnChannelOpened()
79 int32_t channelType = 0; in ClientOnChannelOpenfailed() local
82 ReadInt32(data, &channelType); in ClientOnChannelOpenfailed()
84 (void)TransOnChannelOpenFailed(channelId, channelType, errCode); in ClientOnChannelOpenfailed()
95 int32_t channelType = 0; in ClientOnChannelClosed() local
98 ReadInt32(data, &channelType); in ClientOnChannelClosed()
100 (void)TransOnChannelClosed(channelId, channelType, messageType, SHUTDOWN_REASON_PEER); in ClientOnChannelClosed()
111 int32_t channelType in ClientOnChannelMsgreceived() local
134 int32_t channelType = 0; ClientSetChannelInfo() local
150 int32_t channelType = 0; ClientOnChannelBind() local
[all...]
/foundation/communication/dsoftbus/tests/core/common/dfx/statistics/unittest/
H A Dtrans_network_statistics_test.cpp66 int32_t channelType = 1; in HWTEST_F() local
67 EXPECT_FALSE(IsChannelDfxInfoValid(channelId, channelType)); in HWTEST_F()
79 int32_t channelType = 1; in HWTEST_F() local
81 EXPECT_FALSE(IsChannelDfxInfoValid(channelId, channelType)); in HWTEST_F()
86 * @tc.desc: Test IsChannelDfxInfoValid when channelType is invalid
93 int32_t channelType = -1; in HWTEST_F() local
95 EXPECT_FALSE(IsChannelDfxInfoValid(channelId, channelType)); in HWTEST_F()
213 int32_t channelType = 1; in HWTEST_F() local
214 AddChannelStatisticsInfo(channelId, channelType); in HWTEST_F()
215 EXPECT_NO_FATAL_FAILURE(AddChannelStatisticsInfo(channelId, channelType)); in HWTEST_F()
227 int32_t channelType = 1; HWTEST_F() local
269 int32_t channelType = 1; HWTEST_F() local
[all...]
/foundation/communication/dsoftbus/sdk/transmission/session/include/
H A Dclient_trans_session_callback.h28 int32_t (*OnSessionClosed)(int32_t channelId, int32_t channelType, ShutdownReason reason);
29 int32_t (*OnSessionOpenFailed)(int32_t channelId, int32_t channelType, int32_t errCode);
30 int32_t (*OnDataReceived)(int32_t channelId, int32_t channelType,
32 int32_t (*OnStreamReceived)(int32_t channelId, int32_t channelType,
34 int32_t (*OnGetSessionId)(int32_t channelId, int32_t channelType, int32_t *sessionId, bool isClosing);
35 int32_t (*OnQosEvent)(int32_t channelId, int32_t channelType, int32_t eventId,
39 int32_t (*OnRawStreamEncryptOptGet)(int32_t channelId, int32_t channelType, bool *isEncrypt);
40 int32_t (*OnChannelBind)(int32_t channelId, int32_t channelType);
/foundation/communication/dsoftbus/sdk/transmission/ipc/mini/
H A Dtrans_server_proxy.c63 int32_t ServerIpcNotifyAuthSuccess(int32_t channelId, int32_t channelType) in ServerIpcNotifyAuthSuccess() argument
65 return TransNotifyAuthSuccess(channelId, channelType); in ServerIpcNotifyAuthSuccess()
68 int32_t ServerIpcCloseChannel(const char *sessionName, int32_t channelId, int32_t channelType) in ServerIpcCloseChannel() argument
70 return TransCloseChannel(sessionName, channelId, channelType); in ServerIpcCloseChannel()
73 int32_t ServerIpcCloseChannelWithStatistics(int32_t channelId, int32_t channelType, uint64_t laneId, in ServerIpcCloseChannelWithStatistics() argument
77 (void)channelType; in ServerIpcCloseChannelWithStatistics()
89 int32_t ServerIpcSendMessage(int32_t channelId, int32_t channelType, const void *data, uint32_t len, int32_t msgType) in ServerIpcSendMessage() argument
91 return TransSendMsg(channelId, channelType, data, len, msgType); in ServerIpcSendMessage()
117 int32_t ServerIpcStreamStats(int32_t channelId, int32_t channelType, const StreamSendStats *data) in ServerIpcStreamStats() argument
120 (void)channelType; in ServerIpcStreamStats()
125 ServerIpcRippleStats(int32_t channelId, int32_t channelType, const TrafficStats *data) ServerIpcRippleStats() argument
[all...]
/foundation/communication/dsoftbus/tests/core/transmission/trans_channel/manager/trans_channel_manager_test/
H A Dtrans_channel_manager_test.cpp234 int32_t channelType = 222; in HWTEST_F() local
243 int32_t ret = TransRippleStats(channelId, channelType, trafficStats); in HWTEST_F()
246 ret = TransRippleStats(channelId, channelType, NULL); in HWTEST_F()
250 ret = TransStreamStats(channelId, channelType, data); in HWTEST_F()
253 ret = TransStreamStats(channelId, channelType, NULL); in HWTEST_F()
257 ret = TransStreamStats(channelId, channelType, data); in HWTEST_F()
274 int32_t channelType = CHANNEL_TYPE_UDP; in HWTEST_F() local
276 int32_t ret = TransNotifyAuthSuccess(channelId, channelType); in HWTEST_F()
279 channelType = CHANNEL_TYPE_AUTH; in HWTEST_F()
280 ret = TransNotifyAuthSuccess(channelId, channelType); in HWTEST_F()
293 int32_t channelType = 222; HWTEST_F() local
310 int32_t channelType = 222; HWTEST_F() local
342 int32_t channelType = 222; HWTEST_F() local
415 int32_t channelType = 222; HWTEST_F() local
449 int32_t channelType = 222; HWTEST_F() local
467 int32_t channelType = CHANNEL_TYPE_AUTH; HWTEST_F() local
[all...]
/foundation/communication/dsoftbus/core/transmission/trans_channel/manager/include/
H A Dtrans_channel_manager.h39 int32_t TransStreamStats(int32_t channelId, int32_t channelType, const StreamSendStats *data);
41 int32_t TransRippleStats(int32_t channelId, int32_t channelType, const TrafficStats *data);
45 int32_t TransNotifyAuthSuccess(int32_t channelId, int32_t channelType);
49 int32_t TransCloseChannel(const char *sessionName, int32_t channelId, int32_t channelType);
51 int32_t TransCloseChannelWithStatistics(int32_t channelId, int32_t channelType, uint64_t laneId,
54 int32_t TransSendMsg(int32_t channelId, int32_t channelType, const void *data, uint32_t len, int32_t msgType);
61 int32_t TransGetAndComparePid(pid_t pid, int32_t channelId, int32_t channelType);
65 int32_t TransGetAppInfoByChanId(int32_t channelId, int32_t channelType, AppInfo* appInfo);
67 int32_t TransGetConnByChanId(int32_t channelId, int32_t channelType, int32_t* connId);
H A Dtrans_lane_manager.h49 int32_t TransLaneMgrDelLane(int32_t channelId, int32_t channelType, bool isAsync);
57 int32_t TransGetChannelInfoByLaneHandle(uint32_t laneHandle, int32_t *channelId, int32_t *channelType);
60 const char *sessionName, int32_t sessionId, int32_t channelId, int32_t channelType, CoreSessionState state);
63 const char *sessionName, int32_t sessionId, int32_t channelId, int32_t channelType);
70 int32_t TransDeleteSocketChannelInfoByChannel(int32_t channelId, int32_t channelType);
76 int32_t TransSetSocketChannelStateByChannel(int32_t channelId, int32_t channelType, CoreSessionState state);
80 int32_t TransGetSocketChannelStateByChannel(int32_t channelId, int32_t channelType, CoreSessionState *state);
H A Dtrans_channel_callback.h34 const char *pkgName, int32_t pid, int32_t channelId, int32_t channelType, int32_t messageType);
36 const char *pkgName, int32_t pid, int32_t channelId, int32_t channelType, int32_t errCode);
37 int32_t (*OnDataReceived)(const char *pkgName, int32_t pid, int32_t channelId, int32_t channelType,
42 int32_t (*OnChannelBind)(const char *pkgName, int32_t pid, int32_t channelId, int32_t channelType);
/foundation/communication/dsoftbus/sdk/transmission/trans_channel/manager/include/
H A Dclient_trans_channel_callback.h28 int32_t TransOnChannelOpenFailed(int32_t channelId, int32_t channelType, int32_t errCode);
32 int32_t TransOnChannelClosed(int32_t channelId, int32_t channelType, int32_t messageType, ShutdownReason reason);
34 int32_t TransOnChannelMsgReceived(int32_t channelId, int32_t channelType,
37 int32_t TransOnChannelQosEvent(int32_t channelId, int32_t channelType, int32_t eventId,
40 int32_t TransSetChannelInfo(const char* sessionName, int32_t sessionId, int32_t channleId, int32_t channelType);
41 int32_t TransOnChannelBind(int32_t channelId, int32_t channelType);
/foundation/communication/dsoftbus/core/transmission/trans_channel/manager/src/
H A Dtrans_channel_callback.c96 TransGetSocketChannelStateByChannel(channel->channelId, channel->channelType, &state); in TransServerOnChannelOpened()
108 channel->channelId, channel->channelType, CORE_SESSION_STATE_CHANNEL_OPENED); in TransServerOnChannelOpened()
110 int32_t ret = !channel->isServer && channel->channelType == CHANNEL_TYPE_UDP && NotifyQosChannelOpened(channel); in TransServerOnChannelOpened()
117 if (channel->channelType == CHANNEL_TYPE_TCP_DIRECT) { in TransServerOnChannelOpened()
121 if (channel->channelType == CHANNEL_TYPE_TCP_DIRECT && ret != SOFTBUS_OK) { in TransServerOnChannelOpened()
131 const char *pkgName, int32_t pid, int32_t channelId, int32_t channelType, int32_t messageType) in TransServerOnChannelClosed()
137 if (TransLaneMgrDelLane(channelId, channelType, true) != SOFTBUS_OK) { in TransServerOnChannelClosed()
140 NotifyQosChannelClosed(channelId, channelType); in TransServerOnChannelClosed()
143 .msgChannelType = channelType, in TransServerOnChannelClosed()
150 TransDeleteSocketChannelInfoByChannel(channelId, channelType); in TransServerOnChannelClosed()
130 TransServerOnChannelClosed( const char *pkgName, int32_t pid, int32_t channelId, int32_t channelType, int32_t messageType) TransServerOnChannelClosed() argument
161 TransServerOnChannelOpenFailed(const char *pkgName, int32_t pid, int32_t channelId, int32_t channelType, int32_t errCode) TransServerOnChannelOpenFailed() argument
191 TransServerOnMsgReceived(const char *pkgName, int32_t pid, int32_t channelId, int32_t channelType, TransReceiveData* receiveData) TransServerOnMsgReceived() argument
226 TransServerOnChannelBind(const char *pkgName, int32_t pid, int32_t channelId, int32_t channelType) TransServerOnChannelBind() argument
[all...]
H A Dtrans_channel_manager.c275 transInfo->channelType = CHANNEL_TYPE_BUTT; in TransOpenChannel()
299 TransOpenChannelSetModule(transInfo->channelType, &connOpt); in TransOpenChannel()
300 TRANS_LOGI(TRANS_CTRL, "laneHandle=%{public}u, channelType=%{public}u", laneHandle, transInfo->channelType); in TransOpenChannel()
306 ret = TransOpenChannelProc((ChannelType)transInfo->channelType, appInfo, &connOpt, in TransOpenChannel()
316 param->sessionName, param->sessionId, transInfo->channelId, transInfo->channelType); in TransOpenChannel()
318 transInfo->channelId, transInfo->channelType, CORE_SESSION_STATE_CHANNEL_OPENED); in TransOpenChannel()
322 TransCloseChannel(NULL, transInfo->channelId, transInfo->channelType); in TransOpenChannel()
325 AddChannelStatisticsInfo(transInfo->channelId, transInfo->channelType); in TransOpenChannel()
328 "server TransOpenChannel ok: socket=%{public}d, channelId=%{public}d, channelType in TransOpenChannel()
474 TransStreamStats(int32_t channelId, int32_t channelType, const StreamSendStats *data) TransStreamStats() argument
532 TransRippleStats(int32_t channelId, int32_t channelType, const TrafficStats *data) TransRippleStats() argument
558 TransNotifyAuthSuccess(int32_t channelId, int32_t channelType) TransNotifyAuthSuccess() argument
591 TransCloseChannel(const char *sessionName, int32_t channelId, int32_t channelType) TransCloseChannel() argument
600 TransCloseChannelWithStatistics(int32_t channelId, int32_t channelType, uint64_t laneId, const void *dataInfo, uint32_t len) TransCloseChannelWithStatistics() argument
607 TransSendMsg(int32_t channelId, int32_t channelType, const void *data, uint32_t len, int32_t msgType) TransSendMsg() argument
659 TransGetAndComparePid(pid_t pid, int32_t channelId, int32_t channelType) TransGetAndComparePid() argument
705 TransGetAppInfoByChanId(int32_t channelId, int32_t channelType, AppInfo* appInfo) TransGetAppInfoByChanId() argument
724 TransGetConnByChanId(int32_t channelId, int32_t channelType, int32_t* connId) TransGetConnByChanId() argument
[all...]
H A Dtrans_lane_manager.c36 int32_t channelType; member
50 int32_t channelType; member
63 if (TransGetAppInfoByChanId(laneItem->channelId, laneItem->channelType, appInfo) != SOFTBUS_OK) { in GetTransSessionInfoByLane()
207 newLane->channelType = transInfo->channelType; in TransLaneMgrAddLane()
229 if (laneItem->channelId == transInfo->channelId && laneItem->channelType == transInfo->channelType) { in TransLaneMgrAddLane()
232 TRANS_LOGI(TRANS_SVC, "trans lane info has existed. channelId=%{public}d, channelType=%{public}d", in TransLaneMgrAddLane()
233 transInfo->channelId, transInfo->channelType); in TransLaneMgrAddLane()
246 int32_t TransLaneMgrDelLane(int32_t channelId, int32_t channelType, boo argument
364 TransGetChannelInfoByLaneHandle(uint32_t laneHandle, int32_t *channelId, int32_t *channelType) TransGetChannelInfoByLaneHandle() argument
407 TransAddSocketChannelInfo( const char *sessionName, int32_t sessionId, int32_t channelId, int32_t channelType, CoreSessionState state) TransAddSocketChannelInfo() argument
477 TransUpdateSocketChannelInfoBySession( const char *sessionName, int32_t sessionId, int32_t channelId, int32_t channelType) TransUpdateSocketChannelInfoBySession() argument
567 TransDeleteSocketChannelInfoByChannel(int32_t channelId, int32_t channelType) TransDeleteSocketChannelInfoByChannel() argument
651 TransSetSocketChannelStateByChannel(int32_t channelId, int32_t channelType, CoreSessionState state) TransSetSocketChannelStateByChannel() argument
738 TransGetSocketChannelStateByChannel(int32_t channelId, int32_t channelType, CoreSessionState *state) TransGetSocketChannelStateByChannel() argument
[all...]
/foundation/communication/dsoftbus/tests/core/transmission/trans_channel/manager/trans_lane_manager_test/
H A Dtrans_lane_manager_test.cpp142 .channelType = 2112 in HWTEST_F()
165 transInfo.channelType = 2; in HWTEST_F()
185 int32_t channelType = 22; in HWTEST_F() local
188 int32_t ret = TransLaneMgrDelLane(channelId, channelType, true); in HWTEST_F()
195 channelType = 9999999; in HWTEST_F()
196 ret = TransLaneMgrDelLane(channelId, channelType, true); in HWTEST_F()
252 int32_t channelType = 2112; in HWTEST_F() local
259 ret = TransGetChannelInfoByLaneHandle(laneHandle, NULL, &channelType); in HWTEST_F()
267 ret = TransGetChannelInfoByLaneHandle(laneHandle, &channelId, &channelType); in HWTEST_F()
291 int32_t channelType in HWTEST_F() local
409 int32_t channelType = 0; HWTEST_F() local
[all...]
/foundation/communication/dsoftbus/sdk/transmission/ipc/include/
H A Dtrans_server_proxy.h33 int32_t ServerIpcNotifyAuthSuccess(int32_t channelId, int32_t channelType);
34 int32_t ServerIpcCloseChannel(const char *sessionName, int32_t channelId, int32_t channelType);
35 int32_t ServerIpcCloseChannelWithStatistics(int32_t channelId, int32_t channelType, uint64_t laneId,
37 int32_t ServerIpcSendMessage(int32_t channelId, int32_t channelType, const void *data, uint32_t len, int32_t msgType);
42 int32_t ServerIpcStreamStats(int32_t channelId, int32_t channelType, const StreamSendStats *data);
43 int32_t ServerIpcRippleStats(int32_t channelId, int32_t channelType, const TrafficStats *data);
/foundation/communication/dsoftbus/sdk/transmission/session/src/
H A Dclient_trans_message_service.c33 int CheckSendLen(int32_t channelId, int32_t channelType, unsigned int len, int32_t businessType) in CheckSendLen() argument
36 if (ClientGetDataConfigByChannelId(channelId, channelType, &dataConfig) != SOFTBUS_OK) { in CheckSendLen()
41 ConfigType configType = (ConfigType)GetDefaultConfigType(channelType, businessType); in CheckSendLen()
43 TRANS_LOGE(TRANS_SDK, "Invalid channelType=%{public}d, businessType=%{public}d", in CheckSendLen()
44 channelType, businessType); in CheckSendLen()
77 int32_t channelType = CHANNEL_TYPE_BUTT; in SendBytes() local
79 ret = ClientGetChannelBySessionId(sessionId, &channelId, &channelType, &enableStatus); in SendBytes()
93 (channelType != CHANNEL_TYPE_AUTH)) { in SendBytes()
99 int checkRet = CheckSendLen(channelId, channelType, len, BUSINESS_TYPE_BYTE); in SendBytes()
110 return ClientTransChannelSendBytes(channelId, channelType, dat in SendBytes()
127 int32_t channelType = CHANNEL_TYPE_BUTT; SendMessage() local
[all...]
H A Dclient_trans_session_callback.c48 session->channelType = (ChannelType)channel->channelType; in AcceptSessionAsServer()
83 static int32_t GetSessionCallbackByChannelId(int32_t channelId, int32_t channelType, in GetSessionCallbackByChannelId() argument
90 int32_t ret = ClientGetSessionIdByChannelId(channelId, channelType, sessionId, false); in GetSessionCallbackByChannelId()
103 static int32_t GetSocketCallbackAdapterByChannelId(int32_t channelId, int32_t channelType, int32_t *sessionId, in GetSocketCallbackAdapterByChannelId() argument
112 int32_t ret = ClientGetSessionIdByChannelId(channelId, channelType, sessionId, false); in GetSocketCallbackAdapterByChannelId()
126 static int32_t GetSocketCallbackAdapterByUdpChannelId(int32_t channelId, int32_t channelType, int32_t *sessionId, in GetSocketCallbackAdapterByUdpChannelId() argument
135 int32_t ret = ClientGetSessionIdByChannelId(channelId, channelType, sessionId, true); in GetSocketCallbackAdapterByUdpChannelId()
311 "TransOnSessionOpened: sessionName=%{public}s, channelId=%{public}d, channelType=%{public}d, flag=%{public}d," in AnonymizeLogTransOnSessionOpenedInfo()
313 channel->channelType, fla in AnonymizeLogTransOnSessionOpenedInfo()
369 TransOnSessionOpenFailed(int32_t channelId, int32_t channelType, int32_t errCode) TransOnSessionOpenFailed() argument
415 TransOnSessionClosed(int32_t channelId, int32_t channelType, ShutdownReason reason) TransOnSessionClosed() argument
470 TransOnDataReceived(int32_t channelId, int32_t channelType, const void *data, uint32_t len, SessionPktType type) TransOnDataReceived() argument
521 TransOnOnStreamRecevied(int32_t channelId, int32_t channelType, const StreamData *data, const StreamData *ext, const StreamFrameInfo *param) TransOnOnStreamRecevied() argument
552 TransOnQosEvent(int32_t channelId, int32_t channelType, int32_t eventId, int32_t tvCount, const QosTv *tvList) TransOnQosEvent() argument
571 ClientTransOnChannelBind(int32_t channelId, int32_t channelType) ClientTransOnChannelBind() argument
[all...]
/foundation/communication/dsoftbus/tests/core/transmission/trans_channel/manager/trans_channel_callback_test/
H A Dtrans_channel_callback_test.cpp71 channel->channelType = CHANNEL_TYPE_UDP; in HWTEST_F()
76 channel->channelType = CHANNEL_TYPE_TCP_DIRECT; in HWTEST_F()
93 int32_t channelType = 21; in HWTEST_F() local
95 int32_t ret = TransServerGetChannelCb()->OnChannelOpenFailed(NULL, pid, channelId, channelType, errCode); in HWTEST_F()
110 int32_t channelType = -1; in HWTEST_F() local
114 int32_t ret = TransServerGetChannelCb()->OnDataReceived(NULL, pid, channelId, channelType, receiveData); in HWTEST_F()
116 ret = TransServerGetChannelCb()->OnDataReceived(pkgName, pid, channelId, channelType, NULL); in HWTEST_F()
122 channelType = -2; in HWTEST_F()
123 ret = TransServerGetChannelCb()->OnDataReceived(pkgName, pid, channelId, channelType, receiveData); in HWTEST_F()
127 channelType in HWTEST_F()
213 int32_t channelType = CHANNEL_TYPE_UDP; HWTEST_F() local
[all...]
/foundation/communication/dsoftbus/sdk/frame/standard/src/
H A Dsoftbus_server_proxy_standard.cpp109 int32_t SoftBusServerProxyFrame::NotifyAuthSuccess(int32_t channelId, int32_t channelType) in NotifyAuthSuccess() argument
112 (void)channelType; in NotifyAuthSuccess()
122 int32_t SoftBusServerProxyFrame::CloseChannel(const char *sessionName, int32_t channelId, int32_t channelType) in CloseChannel() argument
126 (void)channelType; in CloseChannel()
130 int32_t SoftBusServerProxyFrame::CloseChannelWithStatistics(int32_t channelId, int32_t channelType, uint64_t laneId, in CloseChannelWithStatistics() argument
134 (void)channelType; in CloseChannelWithStatistics()
141 int32_t SoftBusServerProxyFrame::SendMessage(int32_t channelId, int32_t channelType, const void *data, in SendMessage() argument
145 (void)channelType; in SendMessage()
250 int32_t SoftBusServerProxyFrame::StreamStats(int32_t channelId, int32_t channelType, const StreamSendStats *data) in StreamStats() argument
253 (void)channelType; in StreamStats()
258 RippleStats(int32_t channelId, int32_t channelType, const TrafficStats *data) RippleStats() argument
[all...]
H A Dsoftbus_client_stub.cpp123 int32_t SoftBusClientStub::OnChannelOpenFailed(int32_t channelId, int32_t channelType, int32_t errCode) in OnChannelOpenFailed() argument
125 return TransOnChannelOpenFailed(channelId, channelType, errCode); in OnChannelOpenFailed()
133 int32_t SoftBusClientStub::OnChannelClosed(int32_t channelId, int32_t channelType, int32_t messageType) in OnChannelClosed() argument
135 return TransOnChannelClosed(channelId, channelType, messageType, SHUTDOWN_REASON_PEER); in OnChannelClosed()
138 int32_t SoftBusClientStub::OnChannelMsgReceived(int32_t channelId, int32_t channelType, const void *data, in OnChannelMsgReceived() argument
141 return TransOnChannelMsgReceived(channelId, channelType, data, len, static_cast<SessionPktType>(type)); in OnChannelMsgReceived()
144 int32_t SoftBusClientStub::OnChannelQosEvent(int32_t channelId, int32_t channelType, int32_t eventId, in OnChannelQosEvent() argument
147 return TransOnChannelQosEvent(channelId, channelType, eventId, tvCount, tvList); in OnChannelQosEvent()
151 const char *sessionName, int32_t sessionId, int32_t channelId, int32_t channelType) in SetChannelInfo()
153 return TransSetChannelInfo(sessionName, sessionId, channelId, channelType); in SetChannelInfo()
150 SetChannelInfo( const char *sessionName, int32_t sessionId, int32_t channelId, int32_t channelType) SetChannelInfo() argument
226 int32_t channelType; OnChannelOpenFailedInner() local
263 int32_t channelType; OnChannelClosedInner() local
281 int32_t channelType; OnChannelMsgReceivedInner() local
311 int32_t channelType; OnChannelQosEventInner() local
345 int32_t channelType; SetChannelInfoInner() local
675 OnChannelBind(int32_t channelId, int32_t channelType) OnChannelBind() argument
685 int32_t channelType; OnChannelBindInner() local
[all...]
/foundation/communication/dsoftbus/tests/sdk/transmission/fuzztest/clienttranschannelcallback_fuzzer/
H A Dclienttranschannelcallback_fuzzer.cpp76 int32_t channelType = *(reinterpret_cast<const int32_t *>(data)); in ClientTransChannelCallbackTest() local
92 TransOnChannelOpenFailed(channelId, channelType, errCode); in ClientTransChannelCallbackTest()
94 TransOnChannelClosed(channelId, channelType, messageType, (ShutdownReason)shutdownReason); in ClientTransChannelCallbackTest()
100 TransOnChannelQosEvent(channelId, channelType, eventId, tvCount, &tvList); in ClientTransChannelCallbackTest()
102 TransSetChannelInfo(sessionName, sessionId, channelId, channelType); in ClientTransChannelCallbackTest()
104 TransOnChannelBind(channelId, channelType); in ClientTransChannelCallbackTest()
/foundation/communication/dsoftbus/tests/sdk/transmission/fuzztest/transserverproxyextern_fuzzer/
H A Dtransserverproxyextern_fuzzer.cpp107 .channelType = *(reinterpret_cast<const int32_t *>(data)), in ServerIpcOpenSessionTest()
136 int32_t channelType = *(reinterpret_cast<const int32_t *>(data)); in ServerIpcNotifyAuthSuccessTest() local
138 (void)ServerIpcNotifyAuthSuccess(channelId, channelType); in ServerIpcNotifyAuthSuccessTest()
145 int32_t channelType = *(reinterpret_cast<const int32_t *>(data)); in ServerIpcCloseChannelTest() local
147 (void)ServerIpcCloseChannel(sessionName, channelId, channelType); in ServerIpcCloseChannelTest()
157 int32_t channelType = *(reinterpret_cast<const int32_t *>(data)); in ServerIpcCloseChannelWithStatisticsTest() local
160 (void)ServerIpcCloseChannelWithStatistics(channelId, channelType, laneId, data, size); in ServerIpcCloseChannelWithStatisticsTest()
173 int32_t channelType = *(reinterpret_cast<const int32_t *>(data)); in ServerIpcSendMessageTest() local
176 (void)ServerIpcSendMessage(channelId, channelType, data, size, msgType); in ServerIpcSendMessageTest()
182 int32_t channelType in ServerIpcQosReportTest() local
192 int32_t channelType = *(reinterpret_cast<const int32_t *>(data)); ServerIpcStreamStatsTest() local
202 int32_t channelType = *(reinterpret_cast<const int32_t *>(data)); ServerIpcRippleStatsTest() local
[all...]
/foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/manager/
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
72 (void)channelType; in OnChannelBind()
128 info.channelType = CHANNEL_TYPE_AUTH; in HWTEST_F()
132 info.channelType = CHANNEL_TYPE_PROXY; in HWTEST_F()
136 info.channelType in HWTEST_F()
[all...]
/foundation/communication/dsoftbus/core/transmission/trans_channel/common/src/
H A Dtrans_channel_common.c44 int32_t channelType; member
58 static int32_t FindConfigType(int32_t channelType, int32_t businessType) in FindConfigType() argument
62 if ((g_configTypeMap[i].channelType == channelType) && (g_configTypeMap[i].businessType == businessType)) { in FindConfigType()
85 TransEventExtra *extra, int32_t channelId, int32_t channelType, int32_t ret) in BuildTransCloseChannelEventExtra()
92 extra->channelType = channelType; in BuildTransCloseChannelEventExtra()
122 int32_t TransCommonGetLocalConfig(int32_t channelType, int32_t businessType, uint32_t *len) in TransCommonGetLocalConfig() argument
128 ConfigType configType = (ConfigType)FindConfigType(channelType, businessType); in TransCommonGetLocalConfig()
130 TRANS_LOGE(TRANS_CTRL, "Invalid channelType in TransCommonGetLocalConfig()
84 BuildTransCloseChannelEventExtra( TransEventExtra *extra, int32_t channelId, int32_t channelType, int32_t ret) BuildTransCloseChannelEventExtra() argument
324 TransOpenChannelSetModule(int32_t channelType, ConnectOption *connOpt) TransOpenChannelSetModule() argument
400 TransCommonCloseChannel(const char *sessionName, int32_t channelId, int32_t channelType) TransCommonCloseChannel() argument
[all...]

Completed in 13 milliseconds

1234567