1 /*
2 * Copyright (c) 2021 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
18 #include "softbus_def.h"
19 #include "softbus_errcode.h"
20 #include "softbus_log.h"
21 #include "trans_client_proxy.h"
22 #include "trans_lane_manager.h"
23 #include "trans_session_manager.h"
24
25 #include "softbus_qos.h"
26
27 static IServerChannelCallBack g_channelCallBack;
28
TransServerOnChannelOpened(const char * pkgName,const char * sessionName,const ChannelInfo * channel)29 static int32_t TransServerOnChannelOpened(const char *pkgName, const char *sessionName,
30 const ChannelInfo *channel)
31 {
32 if (pkgName == NULL || sessionName == NULL || channel == NULL) {
33 return SOFTBUS_INVALID_PARAM;
34 }
35
36 if (channel->isServer == false && channel->channelType == CHANNEL_TYPE_UDP &&
37 NotifyQosChannelOpened(channel) != SOFTBUS_OK) {
38 SoftBusLog(SOFTBUS_LOG_TRAN, SOFTBUS_LOG_WARN, "NotifyQosChannelOpened failed.");
39 return SOFTBUS_ERR;
40 }
41 return ClientIpcOnChannelOpened(pkgName, sessionName, channel);
42 }
43
TransServerOnChannelClosed(const char * pkgName,int32_t channelId,int32_t channelType)44 static int32_t TransServerOnChannelClosed(const char *pkgName, int32_t channelId, int32_t channelType)
45 {
46 if (pkgName == NULL) {
47 return SOFTBUS_INVALID_PARAM;
48 }
49
50 if (TransLaneMgrDelLane(channelId, channelType) != SOFTBUS_OK) {
51 SoftBusLog(SOFTBUS_LOG_TRAN, SOFTBUS_LOG_WARN, "delete lane object failed.");
52 }
53 NotifyQosChannelClosed(channelId, channelType);
54 if (ClientIpcOnChannelClosed(pkgName, channelId, channelType) != SOFTBUS_OK) {
55 SoftBusLog(SOFTBUS_LOG_TRAN, SOFTBUS_LOG_ERROR, "notify fail");
56 return SOFTBUS_ERR;
57 }
58 return SOFTBUS_OK;
59 }
60
TransServerOnChannelOpenFailed(const char * pkgName,int32_t channelId,int32_t channelType,int32_t errCode)61 static int32_t TransServerOnChannelOpenFailed(const char *pkgName, int32_t channelId,
62 int32_t channelType, int32_t errCode)
63 {
64 if (pkgName == NULL) {
65 return SOFTBUS_INVALID_PARAM;
66 }
67 if (TransLaneMgrDelLane(channelId, channelType) != SOFTBUS_OK) {
68 SoftBusLog(SOFTBUS_LOG_TRAN, SOFTBUS_LOG_WARN, "delete lane object failed.");
69 }
70 NotifyQosChannelClosed(channelId, channelType);
71 if (ClientIpcOnChannelOpenFailed(pkgName, channelId, channelType, errCode) != SOFTBUS_OK) {
72 SoftBusLog(SOFTBUS_LOG_TRAN, SOFTBUS_LOG_ERROR, "notify fail");
73 return SOFTBUS_ERR;
74 }
75 SoftBusLog(SOFTBUS_LOG_TRAN, SOFTBUS_LOG_WARN,
76 "trasn server on channel open failed.[pkgname=%s][channid=%d][type=%d]", pkgName, channelId, channelType);
77 return SOFTBUS_OK;
78 }
79
TransServerOnMsgReceived(const char * pkgName,int32_t channelId,int32_t channelType,const void * data,uint32_t len,int32_t type)80 static int32_t TransServerOnMsgReceived(const char *pkgName, int32_t channelId, int32_t channelType,
81 const void *data, uint32_t len, int32_t type)
82 {
83 if (pkgName == NULL || data == NULL || len == 0) {
84 return SOFTBUS_INVALID_PARAM;
85 }
86
87 if (ClientIpcOnChannelMsgReceived(pkgName, channelId, channelType, data, len, type) != SOFTBUS_OK) {
88 SoftBusLog(SOFTBUS_LOG_TRAN, SOFTBUS_LOG_ERROR, "get pkg name fail");
89 return SOFTBUS_ERR;
90 }
91 return SOFTBUS_OK;
92 }
93
TransServerOnQosEvent(const char * pkgName,const QosParam * param)94 static int32_t TransServerOnQosEvent(const char *pkgName, const QosParam *param)
95 {
96 if (pkgName == NULL || param == NULL || param->tvCount <= 0) {
97 return SOFTBUS_INVALID_PARAM;
98 }
99
100 if (ClientIpcOnChannelQosEvent(pkgName, param) != SOFTBUS_OK) {
101 SoftBusLog(SOFTBUS_LOG_TRAN, SOFTBUS_LOG_ERROR, "ClientIpcOnChannelQosEvent fail");
102 return SOFTBUS_ERR;
103 }
104 return SOFTBUS_OK;
105 }
106
TransServerGetChannelCb(void)107 IServerChannelCallBack *TransServerGetChannelCb(void)
108 {
109 g_channelCallBack.OnChannelOpened = TransServerOnChannelOpened;
110 g_channelCallBack.OnChannelClosed = TransServerOnChannelClosed;
111 g_channelCallBack.OnChannelOpenFailed = TransServerOnChannelOpenFailed;
112 g_channelCallBack.OnDataReceived = TransServerOnMsgReceived;
113 g_channelCallBack.OnQosEvent = TransServerOnQosEvent;
114 g_channelCallBack.GetPkgNameBySessionName = TransGetPkgNameBySessionName;
115 g_channelCallBack.GetUidAndPidBySessionName = TransGetUidAndPid;
116 return &g_channelCallBack;
117 }
118
TransServerOnChannelLinkDown(const char * pkgName,const char * networkId,int32_t routeType)119 int32_t TransServerOnChannelLinkDown(const char *pkgName, const char *networkId, int32_t routeType)
120 {
121 if (pkgName == NULL || networkId == NULL) {
122 return SOFTBUS_INVALID_PARAM;
123 }
124 SoftBusLog(SOFTBUS_LOG_TRAN, SOFTBUS_LOG_WARN, "TransServerOnChannelLinkDown: pkgName=%s", pkgName);
125
126 if (ClientIpcOnChannelLinkDown(pkgName, networkId, routeType) != SOFTBUS_OK) {
127 SoftBusLog(SOFTBUS_LOG_TRAN, SOFTBUS_LOG_ERROR, "notify fail");
128 return SOFTBUS_ERR;
129 }
130 return SOFTBUS_OK;
131 }
132
133