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 "client_trans_channel_manager.h"
17
18 #include "client_trans_auth_manager.h"
19 #include "client_trans_proxy_manager.h"
20 #include "client_trans_session_callback.h"
21 #include "client_trans_tcp_direct_manager.h"
22 #include "client_trans_tcp_direct_message.h"
23 #include "client_trans_udp_manager.h"
24 #include "softbus_errcode.h"
25 #include "trans_log.h"
26
ClientTransChannelInit(void)27 int32_t ClientTransChannelInit(void)
28 {
29 IClientSessionCallBack *cb = GetClientSessionCb();
30 if (cb == NULL) {
31 TRANS_LOGE(TRANS_SDK, "get client session Cb failed.");
32 return SOFTBUS_ERR;
33 }
34 if (TransTdcManagerInit(cb) != SOFTBUS_OK) {
35 TRANS_LOGE(TRANS_SDK, "trans tcp manager init failed.");
36 return SOFTBUS_ERR;
37 }
38 if (ClientTransAuthInit(cb) != SOFTBUS_OK) {
39 TRANS_LOGE(TRANS_SDK, "client trans auth init failed.");
40 return SOFTBUS_ERR;
41 }
42 if (ClientTransProxyInit(cb) != SOFTBUS_OK) {
43 TRANS_LOGE(TRANS_SDK, "client trans proxy init failed.");
44 return SOFTBUS_ERR;
45 }
46 if (ClientTransUdpMgrInit(cb) != SOFTBUS_OK) {
47 TRANS_LOGE(TRANS_SDK, "client trans udp mgr init failed.");
48 return SOFTBUS_ERR;
49 }
50 return SOFTBUS_OK;
51 }
52
ClientTransChannelDeinit(void)53 void ClientTransChannelDeinit(void)
54 {
55 TransTdcManagerDeinit();
56 ClientTransUdpMgrDeinit();
57 ClientTransProxyDeinit();
58 }
59
ClientTransCloseChannel(int32_t channelId,int32_t type)60 int32_t ClientTransCloseChannel(int32_t channelId, int32_t type)
61 {
62 if (channelId < 0) {
63 TRANS_LOGW(TRANS_SDK, "Invalid param");
64 return SOFTBUS_INVALID_PARAM;
65 }
66 int32_t ret = SOFTBUS_OK;
67 switch (type) {
68 case CHANNEL_TYPE_PROXY:
69 ClientTransProxyCloseChannel(channelId);
70 break;
71 case CHANNEL_TYPE_TCP_DIRECT:
72 TransDelDataBufNode(channelId);
73 TransTdcCloseChannel(channelId);
74 break;
75 case CHANNEL_TYPE_UDP:
76 ret = ClientTransCloseUdpChannel(channelId, SHUTDOWN_REASON_LOCAL);
77 break;
78 case CHANNEL_TYPE_AUTH:
79 ClientTransAuthCloseChannel(channelId, SHUTDOWN_REASON_LOCAL);
80 break;
81 default:
82 TRANS_LOGE(TRANS_SDK, "Invalid type");
83 return SOFTBUS_TRANS_INVALID_CHANNEL_TYPE;
84 }
85 return ret;
86 }
87
ClientTransChannelSendBytes(int32_t channelId,int32_t type,const void * data,uint32_t len)88 int32_t ClientTransChannelSendBytes(int32_t channelId, int32_t type, const void *data, uint32_t len)
89 {
90 if ((data == NULL) || (len == 0)) {
91 TRANS_LOGW(TRANS_BYTES, "Invalid param");
92 return SOFTBUS_INVALID_PARAM;
93 }
94
95 int32_t ret = SOFTBUS_OK;
96 switch (type) {
97 case CHANNEL_TYPE_AUTH:
98 ret = TransAuthChannelSendBytes(channelId, data, len);
99 break;
100 case CHANNEL_TYPE_PROXY:
101 ret = TransProxyChannelSendBytes(channelId, data, len);
102 break;
103 case CHANNEL_TYPE_TCP_DIRECT:
104 ret = TransTdcSendBytes(channelId, data, len);
105 break;
106 default:
107 TRANS_LOGE(TRANS_SDK, "Invalid type");
108 return SOFTBUS_ERR;
109 }
110 return ret;
111 }
112
ClientTransChannelSendMessage(int32_t channelId,int32_t type,const void * data,uint32_t len)113 int32_t ClientTransChannelSendMessage(int32_t channelId, int32_t type, const void *data, uint32_t len)
114 {
115 if ((data == NULL) || (len == 0)) {
116 TRANS_LOGW(TRANS_MSG, "Invalid param.");
117 return SOFTBUS_INVALID_PARAM;
118 }
119
120 int32_t ret = SOFTBUS_OK;
121 switch (type) {
122 case CHANNEL_TYPE_AUTH:
123 ret = TransAuthChannelSendMessage(channelId, data, len);
124 break;
125 case CHANNEL_TYPE_PROXY:
126 ret = TransProxyChannelSendMessage(channelId, data, len);
127 break;
128 case CHANNEL_TYPE_TCP_DIRECT:
129 ret = TransTdcSendMessage(channelId, data, len);
130 break;
131 default:
132 TRANS_LOGE(TRANS_MSG, "Invalid type.");
133 return SOFTBUS_TRANS_CHANNEL_TYPE_INVALID;
134 }
135 return ret;
136 }
137
ClientTransChannelSendStream(int32_t channelId,int32_t type,const StreamData * data,const StreamData * ext,const StreamFrameInfo * param)138 int32_t ClientTransChannelSendStream(int32_t channelId, int32_t type, const StreamData *data,
139 const StreamData *ext, const StreamFrameInfo *param)
140 {
141 if ((data == NULL) || (ext == NULL) || (param == NULL)) {
142 TRANS_LOGW(TRANS_STREAM, "Invalid param");
143 return SOFTBUS_INVALID_PARAM;
144 }
145
146 int32_t ret = SOFTBUS_OK;
147 switch (type) {
148 case CHANNEL_TYPE_UDP:
149 ret = TransUdpChannelSendStream(channelId, data, ext, param);
150 break;
151 default:
152 TRANS_LOGE(TRANS_STREAM, "unsupport channelType=%{public}d.", type);
153 return SOFTBUS_TRANS_CHANNEL_TYPE_INVALID;
154 }
155 return ret;
156 }
157
ClientTransChannelSendFile(int32_t channelId,int32_t type,const char * sFileList[],const char * dFileList[],uint32_t fileCnt)158 int32_t ClientTransChannelSendFile(int32_t channelId, int32_t type, const char *sFileList[],
159 const char *dFileList[], uint32_t fileCnt)
160 {
161 int32_t ret = SOFTBUS_OK;
162 switch (type) {
163 case CHANNEL_TYPE_UDP:
164 ret = TransUdpChannelSendFile(channelId, sFileList, dFileList, fileCnt);
165 break;
166 case CHANNEL_TYPE_PROXY:
167 ret = TransProxyChannelSendFile(channelId, sFileList, dFileList, fileCnt);
168 break;
169 default:
170 TRANS_LOGE(TRANS_FILE, "unsupport channelType=%{public}d.", type);
171 return SOFTBUS_TRANS_CHANNEL_TYPE_INVALID;
172 }
173 return ret;
174 }
175
DeleteFileListener(const char * sessionName)176 void DeleteFileListener(const char *sessionName)
177 {
178 TransUdpDeleteFileListener(sessionName);
179 }
180
ClientGetSessionKey(int32_t channelId,char * key,unsigned int len)181 int32_t ClientGetSessionKey(int32_t channelId, char *key, unsigned int len)
182 {
183 return TransTdcGetSessionKey(channelId, key, len);
184 }
185
ClientGetHandle(int32_t channelId,int * handle)186 int32_t ClientGetHandle(int32_t channelId, int *handle)
187 {
188 return TransTdcGetHandle(channelId, handle);
189 }
190
ClientDisableSessionListener(int32_t channelId)191 int32_t ClientDisableSessionListener(int32_t channelId)
192 {
193 return TransDisableSessionListener(channelId);
194 }