1 /*
2 * Copyright (c) 2023 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 "softbus_session_server.h"
17
18 #include "avsession_log.h"
19 #include "avsession_errors.h"
20 #include "softbus_session_manager.h"
21 #include "softbus_session_utils.h"
22
23 namespace OHOS::AVSession {
~SoftbusSessionServer()24 SoftbusSessionServer::~SoftbusSessionServer() {}
25
ConnectProxy(int sessionId)26 void SoftbusSessionServer::ConnectProxy(int sessionId)
27 {
28 std::string deviceId;
29 int ret = SoftbusSessionManager::GetInstance().ObtainPeerDeviceId(sessionId, deviceId);
30 CHECK_AND_RETURN_LOG(ret == AVSESSION_SUCCESS, "obtain peer device id failed");
31 SLOGI("connectProxy for device: %{public}s.", SoftbusSessionUtils::AnonymizeDeviceId(deviceId).c_str());
32 OnConnectSession(sessionId);
33 OnConnectProxy(deviceId);
34 }
35
36 // LCOV_EXCL_START
DisconnectProxy(int sessionId)37 void SoftbusSessionServer::DisconnectProxy(int sessionId)
38 {
39 std::string deviceId;
40 int ret = SoftbusSessionManager::GetInstance().ObtainPeerDeviceId(sessionId, deviceId);
41 CHECK_AND_RETURN_LOG(ret == AVSESSION_SUCCESS, "obtain peer device id failed");
42 SLOGI("disconnectProxy for device: %{public}s.", SoftbusSessionUtils::AnonymizeDeviceId(deviceId).c_str());
43 OnDisConnectSession(sessionId);
44 OnDisconnectProxy(deviceId);
45 }
46
DisconnectAllProxy()47 void SoftbusSessionServer::DisconnectAllProxy()
48 {
49 SLOGI("DisConnectAllProxy");
50 for (auto it = deviceToSessionMap_.begin(); it != deviceToSessionMap_.end();) {
51 SLOGI("disConnectAllProxy anonymizeDeviceId: %{public}s.",
52 SoftbusSessionUtils::AnonymizeDeviceId(it->first).c_str());
53 OnDisconnectProxy(it->first);
54 deviceToSessionMap_.erase(it++);
55 }
56 }
57 // LCOV_EXCL_STOP
58 } // namespace OHOS::AVSession