openharmony/distributedhardware_distributed_input
1
0
Fork 0
mirror of https://github.com/openharmony/distributedhardware_distributed_input.git synced 2026-07-18 16:04:40 -04:00
Code Issues Packages Projects Releases Wiki Activity

add

Browse Source 
Signed-off-by: hwzhangchuang <zhangchuang.zhang@huawei.com>
This commit is contained in:
hwzhangchuang
2023-12-22 16:36:16 +08:00
parent 79b4dd8e04
commit 58f525c193
5 changed files with 0 additions and 187 deletions
Download Patch File Download Diff File Expand all files Collapse all files
common/test/mock/session_mock.cpp
-183
View File
@@ -1,183 +0,0 @@
/*
* Copyright (c) 2022-2023 Huawei Device Co., Ltd.
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
#include <iostream>
#include <cstring>
#include <thread>
#include "securec.h"
#include "session.h"
constexpr int32_t DH_SUCCESS = 0;
const uint32_t AUTH_SESSION_SIDE_CLIENT = 1;
constexpr int32_t DH_ERROR = -1;
constexpr int32_t MOCK_SESSION_ID = 1;
static ISessionListener g_listener;
static char g_peerDeviceId[CHAR_ARRAY_SIZE + 1];
static char g_peerSessionName[CHAR_ARRAY_SIZE + 1];
static char g_mySessionName[CHAR_ARRAY_SIZE + 1];
int CreateSessionServer(const char *pkgName, const char *sessionName, const ISessionListener *listener)
{
(void)pkgName;
std::cout << "CreateSessionServer start sessionName:" << sessionName << std::endl;
if (strlen(sessionName) == 0) {
std::cout << "CreateSessionServer sessionName is empty." << std::endl;
return DH_ERROR;
}
if (listener == nullptr) {
std::cout << "CreateSessionServer listener is null." << std::endl;
return DH_ERROR;
}
if (strcpy_s(g_mySessionName, strlen(sessionName) + 1, sessionName) != EOK) {
std::cout << "strcpy_s failed" << std::endl;
return DH_ERROR;
}
g_listener.OnBytesReceived = listener->OnBytesReceived;
g_listener.OnMessageReceived = listener->OnMessageReceived;
g_listener.OnSessionClosed = listener->OnSessionClosed;
g_listener.OnSessionOpened = listener->OnSessionOpened;
g_listener.OnStreamReceived = listener->OnStreamReceived;
return DH_SUCCESS;
}
int RemoveSessionServer(const char *pkgName, const char *sessionName)
{
(void)pkgName;
(void)sessionName;
return DH_SUCCESS;
}
int OpenSession(const char *mySessionName, const char *peerSessionName, const char *peerDeviceId, const char *groupId,
const SessionAttribute *attr)
{
(void)mySessionName;
(void)groupId;
(void)attr;
if (strlen(peerSessionName) == 0) {
return DH_ERROR;
}
if (strlen(peerDeviceId) == 0) {
return DH_ERROR;
}
if (strncpy_s(g_peerSessionName, CHAR_ARRAY_SIZE + 1, peerSessionName, CHAR_ARRAY_SIZE) != EOK) {
std::cout << "strncpy_s failed" << std::endl;
return DH_ERROR;
}
if (strncpy_s(g_peerDeviceId, CHAR_ARRAY_SIZE + 1, peerDeviceId, DEVICE_ID_SIZE_MAX) != EOK) {
std::cout << "strncpy_s failed" << std::endl;
return DH_ERROR;
}
std::thread thd(OpenSessionResult);
thd.detach();
return MOCK_SESSION_ID;
}
void OpenSessionResult()
{
g_listener.OnSessionOpened(MOCK_SESSION_ID, DH_SUCCESS);
}
void CloseSession(int sessionId)
{
(void)sessionId;
}
int SendBytes(int sessionId, const void *data, unsigned int len)
{
(void)sessionId;
(void)data;
(void)len;
return DH_SUCCESS;
}
int SendMessage(int sessionId, const void *data, unsigned int len)
{
(void)sessionId;
(void)data;
(void)len;
return DH_SUCCESS;
}
int SendStream(int sessionId, const StreamData *data, const StreamData *ext, const FrameInfo *param)
{
(void)sessionId;
(void)data;
(void)ext;
(void)param;
return DH_SUCCESS;
}
int GetMySessionName(int sessionId, char *sessionName, unsigned int len)
{
(void)sessionId;
if (strncpy_s(sessionName, len + 1, g_mySessionName, CHAR_ARRAY_SIZE) != EOK) {
std::cout << "strncpy_s failed" << std::endl;
return DH_ERROR;
}
return DH_SUCCESS;
}
int GetPeerSessionName(int sessionId, char *sessionName, unsigned int len)
{
(void)sessionId;
if (strncpy_s(sessionName, len + 1, g_peerSessionName, CHAR_ARRAY_SIZE) != EOK) {
std::cout << "strncpy_s failed" << std::endl;
return DH_ERROR;
}
return DH_SUCCESS;
}
int GetPeerDeviceId(int sessionId, char *devId, unsigned int len)
{
(void)sessionId;
if (strncpy_s(devId, len + 1, g_peerDeviceId, DEVICE_ID_SIZE_MAX) != EOK) {
std::cout << "strncpy_s failed" << std::endl;
return DH_ERROR;
}
return DH_SUCCESS;
}
int GetSessionSide(int sessionId)
{
(void)sessionId;
return AUTH_SESSION_SIDE_CLIENT;
}
int SetFileReceiveListener(const char *pkgName, const char *sessionName, const IFileReceiveListener *recvListener,
const char *rootDir)
{
(void)pkgName;
(void)sessionName;
(void)recvListener;
(void)rootDir;
return DH_SUCCESS;
}
int SetFileSendListener(const char *pkgName, const char *sessionName, const IFileSendListener *sendListener)
{
(void)pkgName;
(void)sessionName;
(void)sendListener;
return DH_SUCCESS;
}
int SendFile(int sessionId, const char *sFileList[], const char *dFileList[], uint32_t fileCnt)
{
(void)sessionId;
(void)sFileList;
(void)dFileList;
(void)fileCnt;
return DH_SUCCESS;
}
services/sink/sinkmanager/test/sinkmanagerunittest/BUILD.gn
-1
View File
@@ -62,7 +62,6 @@ ohos_unittest("distributed_input_sinkmanager_test") {
sources = [
"${common_path}/include/input_hub.cpp",
"${common_path}/include/white_list_util.cpp",
"${common_path}/test/mock/session_mock.cpp",
"${common_path}/test/mock/softbus_bus_center_mock.cpp",
"${ipc_path}/src/distributed_input_sink_stub.cpp",
"${ipc_path}/src/get_sink_screen_infos_call_back_stub.cpp",
services/sink/transport/test/sinktransunittest/BUILD.gn
-1
View File
@@ -54,7 +54,6 @@ ohos_unittest("distributed_input_sinktrans_test") {
]
sources = [
"${common_path}/test/mock/session_mock.cpp",
"${common_path}/test/mock/softbus_bus_center_mock.cpp",
"${distributedinput_path}/services/transportbase/src/distributed_input_transport_base.cpp",
"${services_sink_path}/sinkmanager/src/distributed_input_sink_manager.cpp",
services/source/sourcemanager/test/sourcemanagerunittest/BUILD.gn
-1
View File
@@ -56,7 +56,6 @@ ohos_unittest("distributed_input_sourcemanager_test") {
sources = [
"${common_path}/include/input_hub.cpp",
"${common_path}/test/mock/session_mock.cpp",
"${common_path}/test/mock/softbus_bus_center_mock.cpp",
"${distributedinput_path}/services/transportbase/src/distributed_input_transport_base.cpp",
"${distributedinput_path}/utils/src/dinput_context.cpp",
services/source/transport/test/sourcetransunittest/BUILD.gn
-1
View File
@@ -52,7 +52,6 @@ ohos_unittest("distributed_input_sourcetrans_test") {
]
sources = [
"${common_path}/test/mock/session_mock.cpp",
"${common_path}/test/mock/softbus_bus_center_mock.cpp",
"${distributedinput_path}/services/transportbase/src/distributed_input_transport_base.cpp",
"${services_source_path}/transport/src/distributed_input_source_transport.cpp",