Germany/hunting
7
0
Fork 0
Code Issues Pull Requests Actions Packages Projects 1 Releases Wiki Activity

Add test of shared data module.

Browse Source
This commit is contained in:
fancy 2023-11-03 20:11:58 -07:00
parent c345c87297
commit aaa3fb036d
3 changed files with 136 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

125
test/utils/SharedData/src/SharedDataTest.cpp
View File

@ -49,6 +49,7 @@ namespace SharedDataTest
// ../output_files/test/bin/SharedDataTest --gtest_filter=SharedDataTest.Demo2
TEST(SharedDataTest, Demo2)
{
constexpr int WRITABLE_DATA = 189;
CreateLogModule();
ILogInit(LOG_INSTANCE_TYPE_END);
constexpr int PROJECT_ID = 9;
@ -56,17 +57,129 @@ namespace SharedDataTest
SharedData *sharedDataMinor = CreateSharedData(SHARER_NAME_MINOR, "./shared_file", PROJECT_ID);
if (nullptr != sharedDataMinor)
{
int writableData = 189;
IMakeSharedData(sharedDataMinor, sizeof(int) * 200, sizeof(int));
ISetWritableData(sharedDataMinor, &writableData, sizeof(int));
IMakeSharedData(sharedDataMinor, sizeof(int), sizeof(int));
ISetWritableData(sharedDataMinor, (void *)&WRITABLE_DATA, sizeof(int));
}
if (nullptr != sharedDataPrimary)
{
int readableData[2] = {0};
IMakeSharedData(sharedDataPrimary, sizeof(int) * 2, sizeof(int));
StatusCode code = IGetReadableData(sharedDataPrimary, readableData, sizeof(int) * 2);
int readableData = 0;
IMakeSharedData(sharedDataPrimary, sizeof(int), sizeof(int));
StatusCode code = IGetReadableData(sharedDataPrimary, &readableData, sizeof(int));
PrintStringCode(code);
LogInfo("readableData = %d\n", readableData);
EXPECT_EQ(readableData, WRITABLE_DATA);
IFree(sharedDataPrimary);
}
if (nullptr != sharedDataMinor)
{
IFree(sharedDataMinor);
}
ILogUnInit();
}
// ../output_files/test/bin/SharedDataTest --gtest_filter=SharedDataTest.Demo3
TEST(SharedDataTest, Demo3)
{
CreateLogModule();
ILogInit(LOG_INSTANCE_TYPE_END);
constexpr int PROJECT_ID = 9;
SharedData *sharedDataPrimary = CreateSharedData(SHARER_NAME_PRIMARY, "./shared_file", PROJECT_ID);
SharedData *sharedDataMinor = CreateSharedData(SHARER_NAME_MINOR, "./shared_file", PROJECT_ID);
if (nullptr != sharedDataMinor)
{
constexpr int WRITABLE_DATA_LENGTH = 9;
char writableData[WRITABLE_DATA_LENGTH] = {0};
IMakeSharedData(sharedDataMinor, sizeof(int), sizeof(writableData));
ISetWritableData(sharedDataMinor, writableData, sizeof(writableData));
}
if (nullptr != sharedDataPrimary)
{
constexpr int DEFAULT_DATA = 0;
int readableData = DEFAULT_DATA;
IMakeSharedData(sharedDataPrimary, sizeof(int), sizeof(int));
StatusCode code = IGetReadableData(sharedDataPrimary, &readableData, sizeof(int));
PrintStringCode(code);
LogInfo("readableData = %d\n", readableData);
EXPECT_NE(code.mStatusCode, STATUS_CODE_OK);
EXPECT_EQ(readableData, DEFAULT_DATA);
IFree(sharedDataPrimary);
}
if (nullptr != sharedDataMinor)
{
IFree(sharedDataMinor);
}
ILogUnInit();
}
// ../output_files/test/bin/SharedDataTest --gtest_filter=SharedDataTest.Demo4
TEST(SharedDataTest, Demo4)
{
constexpr int WRITABLE_DATA = 189;
CreateLogModule();
ILogInit(LOG_INSTANCE_TYPE_END);
constexpr int PROJECT_ID = 9;
SharedData *sharedDataPrimary = CreateSharedData(SHARER_NAME_PRIMARY, "./shared_file", PROJECT_ID);
SharedData *sharedDataMinor = CreateSharedData(SHARER_NAME_MINOR, "./shared_file", PROJECT_ID);
if (nullptr != sharedDataMinor)
{
IMakeSharedData(sharedDataMinor, sizeof(int) * 2, sizeof(int));
ISetWritableData(sharedDataMinor, (void *)&WRITABLE_DATA, sizeof(int));
}
if (nullptr != sharedDataPrimary)
{
constexpr int DEFAULT_DATA = 0;
int readableData = DEFAULT_DATA;
IMakeSharedData(sharedDataPrimary, sizeof(int), sizeof(int));
StatusCode code = IGetReadableData(sharedDataPrimary, &readableData, sizeof(int));
PrintStringCode(code);
LogInfo("readableData = %d\n", readableData);
EXPECT_EQ(code.mStatusCode, STATUS_CODE_OK);
EXPECT_EQ(readableData, WRITABLE_DATA);
IFree(sharedDataPrimary);
}
if (nullptr != sharedDataMinor)
{
IFree(sharedDataMinor);
}
ILogUnInit();
}
// ../output_files/test/bin/SharedDataTest --gtest_filter=SharedDataTest.Demo5
TEST(SharedDataTest, Demo5)
{
CreateLogModule();
ILogInit(LOG_INSTANCE_TYPE_END);
constexpr int PROJECT_ID = 9;
SharedData *sharedDataPrimary = CreateSharedData(SHARER_NAME_PRIMARY, "./shared_file", PROJECT_ID);
if (nullptr != sharedDataPrimary)
{
constexpr int DEFAULT_DATA = 0;
int readableData = DEFAULT_DATA;
IMakeSharedData(sharedDataPrimary, sizeof(int), sizeof(int));
StatusCode code = IGetReadableData(sharedDataPrimary, &readableData, sizeof(int));
PrintStringCode(code);
LogInfo("readableData = %d\n", readableData);
EXPECT_NE(code.mStatusCode, STATUS_CODE_OK);
EXPECT_EQ(readableData, DEFAULT_DATA);
IFree(sharedDataPrimary);
}
ILogUnInit();
}
// ../output_files/test/bin/SharedDataTest --gtest_filter=SharedDataTest.Demo6
TEST(SharedDataTest, Demo6)
{
CreateLogModule();
ILogInit(LOG_INSTANCE_TYPE_END);
constexpr int PROJECT_ID = 9;
SharedData *sharedDataPrimary = CreateSharedData(SHARER_NAME_PRIMARY, "./shared_file", PROJECT_ID);
SharedData *sharedDataMinor = CreateSharedData(SHARER_NAME_MINOR, "./shared_file", PROJECT_ID);
if (nullptr != sharedDataPrimary)
{
constexpr int DEFAULT_DATA = 0;
int readableData = DEFAULT_DATA;
IMakeSharedData(sharedDataPrimary, sizeof(int), sizeof(int));
StatusCode code = IGetReadableData(sharedDataPrimary, &readableData, sizeof(int));
PrintStringCode(code);
LogInfo("readableData = %d\n", readableData);
EXPECT_NE(code.mStatusCode, STATUS_CODE_OK);
EXPECT_EQ(readableData, DEFAULT_DATA);
IFree(sharedDataPrimary);
}
if (nullptr != sharedDataMinor)

9
utils/SharedData/src/SharedDataImpl.cpp
View File

@ -126,11 +126,20 @@ void SharedDataCpp::SetWritableMemory(void *buf, const unsigned int &bufLength)
return;
}
if (SHARER_NAME_PRIMARY == mSharerName && bufLength == mMinorReadSize)
{
UserDataHeader *readableHeader = (UserDataHeader *)((char *)mSharedMemeory);
if (memcmp(readableHeader->mUserName, USER_NAME_INIT_NAME, USER_NAME_BUF_LENGTH) == 0 &&
mPrimaryReadSize == readableHeader->mDataLength)
{
memcpy((char *)mSharedMemeory + sizeof(UserDataHeader) * THERE_TWO_USER_DATA_HEADER + mPrimaryReadSize,
buf,
bufLength);
}
else
{
LogError("Peer not match.\n");
}
}
else if (SHARER_NAME_MINOR == mSharerName && bufLength == mPrimaryReadSize)
{
memcpy((char *)mSharedMemeory + sizeof(UserDataHeader), buf, bufLength);

5
utils/SharedData/src/SharedDataImpl.h
View File

@ -17,6 +17,7 @@
#include "SharedData.h"
#include "SharedMemory.h"
#include <memory>
#include <mutex>
constexpr int USER_NAME_BUF_LENGTH = 4;
#define USER_NAME_INIT_NAME "XING"
enum USER_DATA_INIT
@ -29,6 +30,10 @@ typedef struct shared_data_header
{
const char *mCheckName;
} SharedDataHeader;
typedef struct shared_memory_header
{
std::mutex mMutex;
};
typedef struct user_data_header
{
char mUserName[USER_NAME_BUF_LENGTH];