openharmony/xts_dcts
1
0
Fork 0
mirror of https://gitee.com/openharmony/xts_dcts synced 2024-11-23 07:39:59 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

xts用例概率性失败

Browse Source 
Signed-off-by: wuxiaodan <wuxiaodan5@huawei.com>
This commit is contained in:
wuxiaodan 2022-09-21 16:17:56 +08:00
parent 748e3e8f61
commit f6de50cfae
2 changed files with 12 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
common/shm_utils.cpp
View File

@ -113,10 +113,12 @@ int readDataFromShmNoClear(char* buf)
int waitDataWithCode(char* code, char* data)
{
LOG("waitDataWithCode begin...");
int i = 0;
int timeout = 10;
char str[MAX_DATA_LENGTH] = { 0 };
if (code == nullptr || data == nullptr) {
LOG("code = nullptr ,data = nullptr");
return RES_FAIL;
}
while (i < timeout) {

14
distributeddatamgr/cpptest/distributed_kv_store/disdata_func_test.cpp
View File

@ -209,17 +209,19 @@ void DisKvTest::RemoteCreateKV(char* str)
char code[CODE_LEN_TEN] = { 0 };
(void)memset_s(str, MAX_DATA_LENGTH, 0, MAX_DATA_LENGTH);
if (memset_s(code, strlen(code), 0, CODE_LEN_TEN) != EOK) {
return;
}
Int2String(CTRL_CODE_RESULT_TYPE, str);
if (str == nullptr) {
LOG("%s Int2String(CTRL_CODE_RESULT_TYPE, str)", LOGSTR);
return;
}
if (strcpy_s(code, strlen(str) + 1, str) != EOK) {
LOG("%s strcpy_s(code", LOGSTR);
return;
}
(void)memset_s(str, MAX_DATA_LENGTH, 0, MAX_DATA_LENGTH);
LOG("%s code=%s, str=%s", LOGSTR, code, str);
waitDataWithCode(code, str);
LOG("%s waitDataWithCode(code, str)", LOGSTR);
int ret = strcmp(str, "0");
if (ret == 0) {
LOG("%s SUCCESS: Remote---CREATE_KV ", LOGSTR);
@ -229,21 +231,25 @@ void DisKvTest::RemoteCreateKV(char* str)
}
void DisKvTest::RemoteDeleteKV(char* str)
{
LOG("%s RemoteCreateKV", LOGSTR);
LOG("%s RemoteDeleteKV", LOGSTR);
writeCodeDataToShm(CTRL_CODE_DATAMGR_DELETE_KV, str);
char code[CODE_LEN_TEN] = { 0 };
(void)memset_s(str, MAX_DATA_LENGTH, 0, MAX_DATA_LENGTH);
Int2String(CTRL_CODE_RESULT_TYPE, str);
if (str == nullptr) {
LOG("%s Int2String(CTRL_CODE_RESULT_TYPE, str)", LOGSTR);
return;
}
if (strcpy_s(code, strlen(str) + 1, str) != EOK) {
LOG("%s strcpy_s(code", LOGSTR);
return;
}
(void)memset_s(str, MAX_DATA_LENGTH, 0, MAX_DATA_LENGTH);
LOG("%s code=%s, str=%s", LOGSTR, code, str);
waitDataWithCode(code, str);
LOG("%s waitDataWithCode(code, str)", LOGSTR);
int ret = strcmp(str, "0");
if (ret == 0) {
LOG("%s SUCCESS: Remote---DELETE_KV ", LOGSTR);