1 /*
2 * Copyright (c) 2021-2024 Huawei Device Co., Ltd.
3 * Licensed under the Apache License, Version 2.0 (the "License");
4 * you may not use this file except in compliance with the License.
5 * You may obtain a copy of the License at
6 *
7 * http://www.apache.org/licenses/LICENSE-2.0
8 *
9 * Unless required by applicable law or agreed to in writing, software
10 * distributed under the License is distributed on an "AS IS" BASIS,
11 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12 * See the License for the specific language governing permissions and
13 * limitations under the License.
14 */
15
16 #include "trans_channel_callback.h"
17 #include "bus_center_info_key.h"
18 #include "bus_center_manager.h"
19 #include "lnn_distributed_net_ledger.h"
20 #include "securec.h"
21 #include "softbus_adapter_hitrace.h"
22 #include "softbus_adapter_mem.h"
23 #include "softbus_app_info.h"
24 #include "softbus_def.h"
25 #include "softbus_errcode.h"
26 #include "softbus_hisysevt_transreporter.h"
27 #include "softbus_qos.h"
28 #include "trans_channel_common.h"
29 #include "trans_client_proxy.h"
30 #include "trans_event.h"
31 #include "trans_lane_manager.h"
32 #include "trans_log.h"
33 #include "trans_session_manager.h"
34 #include "trans_tcp_direct_sessionconn.h"
35 #include "trans_udp_channel_manager.h"
36
37 static IServerChannelCallBack g_channelCallBack;
38
TransAddTcpChannel(const ChannelInfo * channel,const char * pkgName,int32_t pid)39 static int32_t TransAddTcpChannel(const ChannelInfo *channel, const char *pkgName, int32_t pid)
40 {
41 TcpChannelInfo *info = CreateTcpChannelInfo(channel);
42 if (info == NULL) {
43 TRANS_LOGE(TRANS_CTRL, "create new TcpChannelInfo failed.");
44 return SOFTBUS_MEM_ERR;
45 }
46 info->pid = pid;
47 if (strcpy_s(info->pkgName, sizeof(info->pkgName), pkgName) != EOK) {
48 TRANS_LOGE(TRANS_CTRL, "copy pkgName failed.");
49 SoftBusFree(info);
50 return SOFTBUS_STRCPY_ERR;
51 }
52 int32_t ret = TransAddTcpChannelInfo(info);
53 if (ret != SOFTBUS_OK) {
54 TRANS_LOGE(TRANS_CTRL, "TransAddTcpChannelInfo failed.");
55 SoftBusFree(info);
56 }
57 return ret;
58 }
59
TransServerOnChannelOpened(const char * pkgName,int32_t pid,const char * sessionName,const ChannelInfo * channel)60 static int32_t TransServerOnChannelOpened(const char *pkgName, int32_t pid, const char *sessionName,
61 const ChannelInfo *channel)
62 {
63 if (pkgName == NULL || sessionName == NULL || channel == NULL) {
64 return SOFTBUS_INVALID_PARAM;
65 }
66 char peerUdid[DEVICE_ID_SIZE_MAX] = { 0 };
67 if (channel->isEncrypt) {
68 GetRemoteUdidWithNetworkId(channel->peerDeviceId, peerUdid, sizeof(peerUdid));
69 }
70 int32_t osType = 0;
71 GetOsTypeByNetworkId(channel->peerDeviceId, &osType);
72 char localUdid[UDID_BUF_LEN] = { 0 };
73 (void)LnnGetLocalStrInfo(STRING_KEY_DEV_UDID, localUdid, sizeof(localUdid));
74 char deviceVersion[DEVICE_VERSION_SIZE_MAX] = { 0 };
75 TransGetRemoteDeviceVersion(channel->peerDeviceId, channel->isEncrypt ? CATEGORY_NETWORK_ID : CATEGORY_UDID,
76 deviceVersion, sizeof(deviceVersion));
77 int64_t timeStart = channel->timeStart;
78 int64_t timediff = GetSoftbusRecordTimeMillis() - timeStart;
79 TransEventExtra extra = {
80 .calleePkg = NULL,
81 .peerNetworkId = channel->peerDeviceId,
82 .linkType = channel->connectType,
83 .channelId = channel->channelId,
84 .costTime = (int32_t)timediff,
85 .result = EVENT_STAGE_RESULT_OK,
86 .callerPkg = pkgName,
87 .socketName = sessionName,
88 .osType = (osType < 0) ? UNKNOW_OS_TYPE : osType,
89 .peerDevVer = deviceVersion,
90 .localUdid = localUdid,
91 .peerUdid = channel->isEncrypt ? peerUdid : channel->peerDeviceId
92 };
93 extra.deviceState = TransGetDeviceState(channel->peerDeviceId);
94 if (!channel->isServer) {
95 CoreSessionState state = CORE_SESSION_STATE_INIT;
96 TransGetSocketChannelStateByChannel(channel->channelId, channel->channelType, &state);
97 if (state == CORE_SESSION_STATE_CANCELLING) {
98 char *tmpName = NULL;
99 Anonymize(sessionName, &tmpName);
100 TRANS_LOGW(TRANS_CTRL, "Cancel bind name=%{public}s, channelId=%{public}d", tmpName, channel->channelId);
101 AnonymizeFree(tmpName);
102 extra.result = EVENT_STAGE_RESULT_CANCELED;
103 TRANS_EVENT(EVENT_SCENE_OPEN_CHANNEL_SERVER, EVENT_STAGE_OPEN_CHANNEL_END, extra);
104 return SOFTBUS_TRANS_STOP_BIND_BY_CANCEL;
105 }
106 TransSetSocketChannelStateByChannel(
107 channel->channelId, channel->channelType, CORE_SESSION_STATE_CHANNEL_OPENED);
108 }
109 int32_t ret = !channel->isServer && channel->channelType == CHANNEL_TYPE_UDP && NotifyQosChannelOpened(channel);
110 TRANS_CHECK_AND_RETURN_RET_LOGE(ret == SOFTBUS_OK, ret, TRANS_CTRL, "NotifyQosChannelOpened failed.");
111 int32_t sceneCommand = channel->isServer ? EVENT_SCENE_OPEN_CHANNEL_SERVER : EVENT_SCENE_OPEN_CHANNEL;
112 TRANS_EVENT(sceneCommand, EVENT_STAGE_OPEN_CHANNEL_END, extra);
113
114 SoftbusRecordOpenSessionKpi(pkgName, channel->linkType, SOFTBUS_EVT_OPEN_SESSION_SUCC, timediff);
115 SoftbusHitraceStop();
116 if (channel->channelType == CHANNEL_TYPE_TCP_DIRECT) {
117 (void)TransAddTcpChannel(channel, pkgName, pid);
118 }
119 ret = ClientIpcOnChannelOpened(pkgName, sessionName, channel, pid);
120 if (channel->channelType == CHANNEL_TYPE_TCP_DIRECT && ret != SOFTBUS_OK) {
121 (void)TransDelTcpChannelInfoByChannelId(channel->channelId);
122 }
123 if (!IsTdcRecoveryTransLimit() || !IsUdpRecoveryTransLimit()) {
124 (void)UdpChannelFileTransLimit(channel, FILE_PRIORITY_BK);
125 }
126 return ret;
127 }
128
TransServerOnChannelClosed(const char * pkgName,int32_t pid,int32_t channelId,int32_t channelType,int32_t messageType)129 static int32_t TransServerOnChannelClosed(
130 const char *pkgName, int32_t pid, int32_t channelId, int32_t channelType, int32_t messageType)
131 {
132 if (pkgName == NULL) {
133 return SOFTBUS_INVALID_PARAM;
134 }
135
136 if (TransLaneMgrDelLane(channelId, channelType, true) != SOFTBUS_OK) {
137 TRANS_LOGW(TRANS_CTRL, "delete lane object failed.");
138 }
139 NotifyQosChannelClosed(channelId, channelType);
140 ChannelMsg data = {
141 .msgChannelId = channelId,
142 .msgChannelType = channelType,
143 .msgPid = pid,
144 .msgMessageType = messageType,
145 .msgPkgName = pkgName,
146 .msgUuid = NULL,
147 .msgUdid = NULL
148 };
149 TransDeleteSocketChannelInfoByChannel(channelId, channelType);
150 if (ClientIpcOnChannelClosed(&data) != SOFTBUS_OK) {
151 TRANS_LOGE(TRANS_CTRL, "client ipc on channel close fail");
152 return SOFTBUS_IPC_ERR;
153 }
154 if (IsTdcRecoveryTransLimit() && IsUdpRecoveryTransLimit()) {
155 UdpChannelFileTransRecoveryLimit(FILE_PRIORITY_BE);
156 }
157 return SOFTBUS_OK;
158 }
159
TransServerOnChannelOpenFailed(const char * pkgName,int32_t pid,int32_t channelId,int32_t channelType,int32_t errCode)160 static int32_t TransServerOnChannelOpenFailed(const char *pkgName, int32_t pid, int32_t channelId,
161 int32_t channelType, int32_t errCode)
162 {
163 if (pkgName == NULL) {
164 return SOFTBUS_INVALID_PARAM;
165 }
166 if (TransLaneMgrDelLane(channelId, channelType, true) != SOFTBUS_OK) {
167 TRANS_LOGW(TRANS_CTRL, "delete lane object failed.");
168 }
169 NotifyQosChannelClosed(channelId, channelType);
170 ChannelMsg data = {
171 .msgChannelId = channelId,
172 .msgChannelType = channelType,
173 .msgPid = pid,
174 .msgPkgName = pkgName,
175 .msgUuid = NULL,
176 .msgUdid = NULL
177 };
178 TransDeleteSocketChannelInfoByChannel(channelId, channelType);
179 if (ClientIpcOnChannelOpenFailed(&data, errCode) != SOFTBUS_OK) {
180 TRANS_LOGE(TRANS_CTRL, "client ipc on channel open fail");
181 return SOFTBUS_IPC_ERR;
182 }
183 SoftbusHitraceStop();
184 TRANS_LOGW(TRANS_CTRL,
185 "trasn server on channel open failed. pkgname=%{public}s, channelId=%{public}d, type=%{public}d",
186 pkgName, channelId, channelType);
187 return SOFTBUS_OK;
188 }
189
TransServerOnMsgReceived(const char * pkgName,int32_t pid,int32_t channelId,int32_t channelType,TransReceiveData * receiveData)190 static int32_t TransServerOnMsgReceived(const char *pkgName, int32_t pid, int32_t channelId, int32_t channelType,
191 TransReceiveData* receiveData)
192 {
193 if (pkgName == NULL || receiveData == NULL || receiveData->data == NULL || receiveData->dataLen == 0) {
194 return SOFTBUS_INVALID_PARAM;
195 }
196
197 ChannelMsg data = {
198 .msgChannelId = channelId,
199 .msgChannelType = channelType,
200 .msgPid = pid,
201 .msgPkgName = pkgName,
202 .msgUuid = NULL,
203 .msgUdid = NULL
204 };
205 if (ClientIpcOnChannelMsgReceived(&data, receiveData) != SOFTBUS_OK) {
206 TRANS_LOGE(TRANS_CTRL, "get pkg name fail");
207 return SOFTBUS_IPC_ERR;
208 }
209 return SOFTBUS_OK;
210 }
211
TransServerOnQosEvent(const char * pkgName,const QosParam * param)212 static int32_t TransServerOnQosEvent(const char *pkgName, const QosParam *param)
213 {
214 if (pkgName == NULL || param == NULL || param->tvCount <= 0) {
215 return SOFTBUS_INVALID_PARAM;
216 }
217
218 if (ClientIpcOnChannelQosEvent(pkgName, param) != SOFTBUS_OK) {
219 TRANS_LOGE(TRANS_CTRL, "ClientIpcOnChannelQosEvent fail");
220 return SOFTBUS_IPC_ERR;
221 }
222 return SOFTBUS_OK;
223 }
224
TransServerOnChannelBind(const char * pkgName,int32_t pid,int32_t channelId,int32_t channelType)225 static int32_t TransServerOnChannelBind(const char *pkgName, int32_t pid, int32_t channelId, int32_t channelType)
226 {
227 if (pkgName == NULL) {
228 TRANS_LOGE(TRANS_CTRL, "pkgName is null channelId=%{public}d", channelId);
229 return SOFTBUS_INVALID_PARAM;
230 }
231 ChannelMsg data = {
232 .msgChannelId = channelId,
233 .msgChannelType = channelType,
234 .msgPid = pid,
235 .msgPkgName = pkgName,
236 .msgUuid = NULL,
237 .msgUdid = NULL
238 };
239 int32_t ret = ClientIpcOnChannelBind(&data);
240 if (ret != SOFTBUS_OK) {
241 TRANS_LOGE(TRANS_CTRL, "client ipc on channel bind fail, ret=%{public}d, channelId=%{public}d", ret, channelId);
242 return ret;
243 }
244 char *anonymizePkgName = NULL;
245 Anonymize(pkgName, &anonymizePkgName);
246 TRANS_LOGI(TRANS_CTRL,
247 "trasn server on channel bind. pkgname=%{public}s, channelId=%{public}d, type=%{public}d",
248 anonymizePkgName, channelId, channelType);
249 AnonymizeFree(anonymizePkgName);
250 return SOFTBUS_OK;
251 }
252
TransServerGetChannelCb(void)253 IServerChannelCallBack *TransServerGetChannelCb(void)
254 {
255 g_channelCallBack.OnChannelOpened = TransServerOnChannelOpened;
256 g_channelCallBack.OnChannelClosed = TransServerOnChannelClosed;
257 g_channelCallBack.OnChannelOpenFailed = TransServerOnChannelOpenFailed;
258 g_channelCallBack.OnDataReceived = TransServerOnMsgReceived;
259 g_channelCallBack.OnQosEvent = TransServerOnQosEvent;
260 g_channelCallBack.GetPkgNameBySessionName = TransGetPkgNameBySessionName;
261 g_channelCallBack.GetUidAndPidBySessionName = TransGetUidAndPid;
262 g_channelCallBack.OnChannelBind = TransServerOnChannelBind;
263 return &g_channelCallBack;
264 }
265
TransServerOnChannelLinkDown(const char * pkgName,int32_t pid,const LinkDownInfo * info)266 int32_t TransServerOnChannelLinkDown(const char *pkgName, int32_t pid, const LinkDownInfo *info)
267 {
268 if (pkgName == NULL || info == NULL || info->networkId == NULL) {
269 return SOFTBUS_INVALID_PARAM;
270 }
271 TRANS_LOGD(TRANS_CTRL, "pkgName=%{public}s", pkgName);
272
273 ChannelMsg data = {
274 .msgPid = pid,
275 .msgPkgName = pkgName,
276 .msgUuid = info->uuid,
277 .msgUdid = info->udid
278 };
279 if (ClientIpcOnChannelLinkDown(&data, info->networkId, info->peerIp, info->routeType) != SOFTBUS_OK) {
280 TRANS_LOGE(TRANS_CTRL, "client ipc on channel link down fail");
281 return SOFTBUS_IPC_ERR;
282 }
283 return SOFTBUS_OK;
284 }
285
286