test: replace unsecure function with secure function
Signed-off-by: xuxinyu <xuxinyu6@huawei.com> Change-Id: Ie120ffa529798f0f087ddfcd34f5d9c5802b6766
This commit is contained in:
@@ -51,6 +51,7 @@ static UINT32 testcase(VOID)
|
||||
sigset_t mask;
|
||||
struct epoll_event ev;
|
||||
struct epoll_event evWait[2]; /* 2, evs num */
|
||||
UINT32 ret;
|
||||
|
||||
retval = pipe(pipeFd);
|
||||
ICUNIT_GOTO_EQUAL(retval, 0, retval, OUT);
|
||||
@@ -71,7 +72,8 @@ static UINT32 testcase(VOID)
|
||||
if (pid == 0) {
|
||||
close(pipeFd[1]);
|
||||
|
||||
memset(evWait, 0, sizeof(struct epoll_event) * 2); /* 2, evs num */
|
||||
ret = memset_s(evWait, sizeof(struct epoll_event) * 2, 0, sizeof(struct epoll_event) * 2); /* 2, evs num */
|
||||
ICUNIT_ASSERT_EQUAL(ret, 0, ret);
|
||||
retval = epoll_wait(epFd, evWait, 2, 3000); /* 2, num of wait fd. 3000, wait time */
|
||||
close(pipeFd[0]);
|
||||
|
||||
|
||||
@@ -97,7 +97,7 @@ static UINT32 testcase(VOID)
|
||||
if (pid == 0) {
|
||||
close(pipeFd[1]);
|
||||
|
||||
memset(evWait, 0, sizeof(struct epoll_event) * 2); /* 2, evs num */
|
||||
(void)memset_s(evWait, sizeof(struct epoll_event) * 2, 0, sizeof(struct epoll_event) * 2); /* 2, evs num */
|
||||
evWait[0].data.fd = pipeFd[0];
|
||||
|
||||
retval = epoll_pwait(epFd, evWait, 2, 3000, &mask); /* 2, num of wait fd. 3000, wait time */
|
||||
|
||||
@@ -40,9 +40,13 @@ static UINT32 Testcase(VOID)
|
||||
int nType;
|
||||
char pathname[50]; // 50, path name buffer size
|
||||
FILE *testFile;
|
||||
(void)strncpy_s(pathname, 50, g_ioTestPath, 50); // 50, path name buffer size
|
||||
int ret;
|
||||
|
||||
ret = strncpy_s(pathname, 50, g_ioTestPath, 50); // 50, path name buffer size
|
||||
ICUNIT_ASSERT_EQUAL(ret, 0, ret);
|
||||
char *filename = "/crtfputwstest1";
|
||||
strcat(pathname, filename);
|
||||
ret = strcat_s(pathname, 50, filename); // 50, path name buffer size
|
||||
ICUNIT_ASSERT_EQUAL(ret, EOK, ret);
|
||||
for (nType = 0; nType < 6; nType++) { // 6, test loop num
|
||||
testFile = fopen(pathname, "a");
|
||||
|
||||
|
||||
@@ -38,12 +38,14 @@ static UINT32 Testcase(VOID)
|
||||
int nRet;
|
||||
unsigned int nPos;
|
||||
int nType;
|
||||
char pathname[50]; // 50, path name buffer size
|
||||
strncpy(pathname, g_ioTestPath, 50); // 50, path name buffer size
|
||||
char pathname[50]; // 50, path name buffer size
|
||||
(void)strncpy_s(pathname, 50, g_ioTestPath, 50); // 50, path name buffer size
|
||||
char *filename = "/crtfwprintftest1";
|
||||
FILE *testFile = NULL;
|
||||
int ret;
|
||||
|
||||
strcat(pathname, filename);
|
||||
ret = strcat_s(pathname, 50, filename); // 50, path name buffer size
|
||||
ICUNIT_ASSERT_EQUAL(ret, EOK, ret);
|
||||
|
||||
for (nType = 0; nType < 6; nType++) { // 6, loop test num
|
||||
testFile = fopen(pathname, "w+");
|
||||
@@ -52,7 +54,7 @@ static UINT32 Testcase(VOID)
|
||||
nPos = (unsigned int)ftell(testFile);
|
||||
|
||||
nRet = fwprintf(testFile, L"hello world %d", 666); // 666, for test, print to testFile
|
||||
ICUNIT_GOTO_EQUAL(nRet, 15, nRet, EXIT); // 15, total write size
|
||||
ICUNIT_GOTO_EQUAL(nRet, 15, nRet, EXIT); // 15, total write size
|
||||
|
||||
if ((nPos + 15) != (unsigned int)ftell(testFile)) { // 15, total write size
|
||||
ICUNIT_GOTO_EQUAL(1, 0, 1, EXIT);
|
||||
|
||||
@@ -37,11 +37,15 @@ static UINT32 Testcase(VOID)
|
||||
unsigned int nPos;
|
||||
int ret;
|
||||
char pathname[50]; // 50, enough space.
|
||||
(void)strncpy_s(pathname, sizeof(pathname), g_ioTestPath, sizeof(pathname));
|
||||
char *filename = "/crt_getc_unlocked_test1";
|
||||
FILE *testFile = NULL;
|
||||
|
||||
strcat(pathname, filename);
|
||||
ret = strncpy_s(pathname, sizeof(pathname), g_ioTestPath, sizeof(pathname));
|
||||
ICUNIT_ASSERT_EQUAL(ret, 0, ret);
|
||||
|
||||
ret = strcat_s(pathname, 50, filename); // 50, path name buffer size
|
||||
ICUNIT_ASSERT_EQUAL(ret, EOK, ret);
|
||||
|
||||
testFile = fopen(pathname, "w+");
|
||||
ICUNIT_ASSERT_NOT_EQUAL(testFile, NULL, LOS_NOK);
|
||||
ret = fputs("0123456789abcdefghijklmnopqrstuvwxyz", testFile);
|
||||
|
||||
@@ -38,9 +38,11 @@ static UINT32 Testcase(VOID)
|
||||
const char *str = "水";
|
||||
size_t sz = strlen(str);
|
||||
int len1, len2, len3;
|
||||
UINT32 ret;
|
||||
|
||||
mbstate_t mb;
|
||||
memset(&mb, 0, sizeof(mb));
|
||||
ret = memset_s(&mb, sizeof(mb), 0, sizeof(mb));
|
||||
ICUNIT_GOTO_EQUAL(ret, 0, ret, EXIT);
|
||||
len1 = mbrlen(str, 1, &mb);
|
||||
ICUNIT_GOTO_EQUAL(len1, -2, len1, EXIT); // -2, except return value
|
||||
|
||||
|
||||
@@ -38,11 +38,15 @@ static UINT32 Testcase(VOID)
|
||||
long nPos;
|
||||
int nType, i;
|
||||
FILE *putwcFile = NULL;
|
||||
char pathname[50]; // 50, pathname size
|
||||
strncpy(pathname, g_ioTestPath, 50); // 50, pathname size
|
||||
char pathname[50]; // 50, pathname size
|
||||
char *filename = "/crtputwctest1";
|
||||
int ret;
|
||||
|
||||
strcat(pathname, filename);
|
||||
ret = strncpy_s(pathname, 50, g_ioTestPath, 50); // 50, pathname size
|
||||
ICUNIT_ASSERT_EQUAL(ret, 0, ret);
|
||||
|
||||
ret = strcat_s(pathname, 50, filename); // 50, path name buffer size
|
||||
ICUNIT_ASSERT_EQUAL(ret, EOK, ret);
|
||||
|
||||
for (nType = 0; nType < 6; nType++) { // 6, loop test num
|
||||
putwcFile = fopen(pathname, "w+");
|
||||
|
||||
@@ -41,14 +41,16 @@ static UINT32 Testcase(VOID)
|
||||
struct iovec iov[2]; // 2, read 2 block
|
||||
ssize_t nread;
|
||||
const int testStrLen = 10;
|
||||
UINT32 ret;
|
||||
|
||||
iov[0].iov_base = buf1;
|
||||
iov[0].iov_len = sizeof(buf1) - 1;
|
||||
iov[1].iov_base = buf2;
|
||||
iov[1].iov_len = sizeof(buf2) - 1;
|
||||
|
||||
strncpy(pathname, g_ioTestPath, 50); // 50, path name size
|
||||
strcat(pathname, filename);
|
||||
(void)strncpy_s(pathname, 50, g_ioTestPath, 50); // 50, path name size
|
||||
ret = strcat_s(pathname, 50, filename); // 50, path name buffer size
|
||||
ICUNIT_ASSERT_EQUAL(ret, EOK, ret);
|
||||
fd = open(pathname, O_CREAT | O_RDWR | O_TRUNC, 0666); // 0666, file authority
|
||||
if (fd < 0) {
|
||||
printf("error: can`t open file\n");
|
||||
|
||||
@@ -42,7 +42,9 @@ static UINT32 Testcase(VOID)
|
||||
attr.mq_msgsize = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
attr.mq_maxmsg = 1;
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq002_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1,
|
||||
"/mq002_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
|
||||
mqueue = mq_open(mqname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, &attr);
|
||||
ICUNIT_GOTO_NOT_EQUAL(mqueue, (mqd_t)-1, mqueue, EXIT1);
|
||||
@@ -66,6 +68,7 @@ EXIT1:
|
||||
mq_close(mqueue);
|
||||
EXIT:
|
||||
mq_unlink(mqname);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -32,10 +32,13 @@
|
||||
|
||||
static UINT32 Testcase(VOID)
|
||||
{
|
||||
INT32 ret;
|
||||
CHAR mqname[MQUEUE_STANDARD_NAME_LENGTH] = "";
|
||||
mqd_t mqueue;
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq005_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1,
|
||||
"/mq005_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT1);
|
||||
mqueue = mq_open(mqname, O_RDWR, S_IRUSR | S_IWUSR, NULL);
|
||||
ICUNIT_GOTO_EQUAL(mqueue, (mqd_t)-1, mqueue, EXIT);
|
||||
ICUNIT_ASSERT_EQUAL(errno, ENOENT, errno);
|
||||
@@ -45,6 +48,7 @@ static UINT32 Testcase(VOID)
|
||||
EXIT:
|
||||
mq_close(mqueue);
|
||||
mq_unlink(mqname);
|
||||
EXIT1:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -36,8 +36,10 @@ static UINT32 Testcase(VOID)
|
||||
CHAR mqname[MQUEUE_STANDARD_NAME_LENGTH] = "";
|
||||
mqd_t roqueue, roqueue2;
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq008_%d", LosCurTaskIDGet());
|
||||
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1,
|
||||
"/mq008_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
|
||||
roqueue = mq_open(mqname, O_CREAT | O_RDONLY, S_IRUSR | S_IWUSR, NULL);
|
||||
ICUNIT_GOTO_NOT_EQUAL(roqueue, (mqd_t)-1, roqueue, EXIT);
|
||||
|
||||
@@ -59,6 +61,7 @@ EXIT1:
|
||||
EXIT:
|
||||
mq_close(roqueue);
|
||||
mq_unlink(mqname);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -40,8 +40,10 @@ static UINT32 Testcase(VOID)
|
||||
mqd_t rdwrqueue, rdwrqueue2;
|
||||
struct mq_attr attr = { 0 };
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq011_%d", LosCurTaskIDGet());
|
||||
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1,
|
||||
"/mq011_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
|
||||
attr.mq_msgsize = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
attr.mq_maxmsg = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
rdwrqueue = mq_open(mqname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, &attr);
|
||||
@@ -77,6 +79,7 @@ EXIT1:
|
||||
EXIT:
|
||||
mq_close(rdwrqueue);
|
||||
mq_unlink(mqname);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -37,8 +37,10 @@ static UINT32 Testcase(VOID)
|
||||
const CHAR *msgptr = MQUEUE_SEND_STRING_TEST;
|
||||
mqd_t mqueue1, mqueue2;
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq013_%d", LosCurTaskIDGet());
|
||||
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1,
|
||||
"/mq013_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT3);
|
||||
|
||||
mqueue1 = mq_open(mqname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, NULL);
|
||||
ICUNIT_GOTO_NOT_EQUAL(mqueue1, (mqd_t)-1, mqueue1, EXIT1);
|
||||
|
||||
@@ -67,6 +69,7 @@ EXIT1:
|
||||
mq_close(mqueue1);
|
||||
EXIT:
|
||||
mq_unlink(mqname);
|
||||
EXIT3:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -37,7 +37,9 @@ static UINT32 Testcase(VOID)
|
||||
mqd_t mqueue;
|
||||
struct mq_attr attr = { 0 };
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq014_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1,
|
||||
"/mq014_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
|
||||
mqueue = mq_open(mqname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, NULL);
|
||||
ICUNIT_GOTO_NOT_EQUAL(mqueue, (mqd_t)-1, mqueue, EXIT1);
|
||||
@@ -60,6 +62,7 @@ EXIT1:
|
||||
mq_close(mqueue);
|
||||
EXIT:
|
||||
mq_unlink(mqname);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -38,7 +38,9 @@ static UINT32 Testcase(VOID)
|
||||
struct mq_attr attr = { 0 };
|
||||
struct mq_attr attrget;
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq015_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1,
|
||||
"/mq015_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
|
||||
attr.mq_maxmsg = MQUEUE_SHORT_ARRAY_LENGTH;
|
||||
attr.mq_msgsize = 5; // 5, queue message size.
|
||||
@@ -67,6 +69,7 @@ EXIT1:
|
||||
mq_close(mqueue);
|
||||
EXIT:
|
||||
mq_unlink(mqname);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -36,8 +36,10 @@ static UINT32 Testcase(VOID)
|
||||
CHAR mqname[MQUEUE_STANDARD_NAME_LENGTH] = "";
|
||||
mqd_t mqueue1, mqueue2;
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq016_%d", LosCurTaskIDGet());
|
||||
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1,
|
||||
"/mq016_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT3);
|
||||
|
||||
mqueue1 = mq_open(mqname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, NULL);
|
||||
ICUNIT_GOTO_NOT_EQUAL(mqueue1, (mqd_t)-1, mqueue1, EXIT1);
|
||||
|
||||
@@ -57,6 +59,7 @@ EXIT1:
|
||||
mq_close(mqueue1);
|
||||
EXIT:
|
||||
mq_unlink(mqname);
|
||||
EXIT3:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -37,7 +37,9 @@ static UINT32 Testcase(VOID)
|
||||
const CHAR *msgptr = MQUEUE_SEND_STRING_TEST;
|
||||
mqd_t mqueue;
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq018_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1,
|
||||
"/mq018_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
|
||||
mqueue = mq_open(mqname, O_CREAT | O_RDWR | O_NONBLOCK, S_IRUSR | S_IWUSR, NULL);
|
||||
ICUNIT_GOTO_NOT_EQUAL(mqueue, (mqd_t)-1, mqueue, EXIT1);
|
||||
@@ -56,6 +58,7 @@ EXIT1:
|
||||
mq_close(mqueue);
|
||||
EXIT:
|
||||
mq_unlink(mqname);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -39,7 +39,9 @@ static UINT32 Testcase(VOID)
|
||||
mqd_t mqueue1, mqueue2;
|
||||
struct mq_attr attr = { 0 };
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq019_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1,
|
||||
"/mq019_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT3);
|
||||
|
||||
attr.mq_msgsize = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
attr.mq_maxmsg = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
@@ -76,6 +78,7 @@ EXIT1:
|
||||
mq_close(mqueue1);
|
||||
EXIT:
|
||||
mq_unlink(mqname);
|
||||
EXIT3:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -38,7 +38,9 @@ static UINT32 Testcase(VOID)
|
||||
struct sigevent ev;
|
||||
struct sigaction act;
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq020_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1,
|
||||
"/mq020_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
|
||||
mqueue = mq_open(mqname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, NULL);
|
||||
ICUNIT_GOTO_NOT_EQUAL(mqueue, (mqd_t)-1, mqueue, EXIT1);
|
||||
@@ -54,6 +56,7 @@ EXIT1:
|
||||
mq_close(mqueue);
|
||||
EXIT:
|
||||
mq_unlink(mqname);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -32,10 +32,13 @@
|
||||
|
||||
static UINT32 Testcase(VOID)
|
||||
{
|
||||
INT32 ret;
|
||||
CHAR mqname[MQUEUE_STANDARD_NAME_LENGTH] = "";
|
||||
mqd_t mqueue;
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq021_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1,
|
||||
"/mq021_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT1);
|
||||
|
||||
mqueue = mq_open(mqname, O_RDWR, S_IRUSR | S_IWUSR, NULL);
|
||||
ICUNIT_GOTO_EQUAL(mqueue, (mqd_t)-1, mqueue, EXIT);
|
||||
@@ -45,6 +48,7 @@ static UINT32 Testcase(VOID)
|
||||
EXIT:
|
||||
mq_close(mqueue);
|
||||
mq_unlink(mqname);
|
||||
EXIT1:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -30,16 +30,23 @@
|
||||
*/
|
||||
#include "It_posix_queue.h"
|
||||
|
||||
#define QUEUE_NAME_MAX_LEN (MQUEUE_NAME_MAX_TEST * 2)
|
||||
|
||||
static UINT32 Testcase(VOID)
|
||||
{
|
||||
CHAR mqname[MQUEUE_NAME_MAX_TEST * 2];
|
||||
CHAR mqname[QUEUE_NAME_MAX_LEN];
|
||||
mqd_t mqueue;
|
||||
UINT32 ret;
|
||||
INT32 i;
|
||||
|
||||
snprintf(mqname, MQUEUE_NAME_MAX_TEST * 2, "/mq025_%d", LosCurTaskIDGet()); // 2, mqname length.
|
||||
ret = snprintf_s(mqname, QUEUE_NAME_MAX_LEN, QUEUE_NAME_MAX_LEN - 1, \
|
||||
"/mq025_%d", LosCurTaskIDGet()); // 2, mqname length.
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT1);
|
||||
|
||||
for (i = 0; i < MQUEUE_NAME_MAX_TEST; i++)
|
||||
strcat(mqname, "0");
|
||||
for (i = 0; i < MQUEUE_NAME_MAX_TEST; i++) {
|
||||
ret = strcat_s(mqname, QUEUE_NAME_MAX_LEN, "0");
|
||||
ICUNIT_ASSERT_EQUAL(ret, EOK, ret);
|
||||
}
|
||||
|
||||
mqueue = mq_open(mqname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, NULL);
|
||||
ICUNIT_GOTO_EQUAL(mqueue, (mqd_t)-1, mqueue, EXIT);
|
||||
@@ -49,6 +56,7 @@ static UINT32 Testcase(VOID)
|
||||
EXIT:
|
||||
mq_close(mqueue);
|
||||
mq_unlink(mqname);
|
||||
EXIT1:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -32,10 +32,13 @@
|
||||
|
||||
static UINT32 Testcase(VOID)
|
||||
{
|
||||
INT32 ret;
|
||||
CHAR qname[MQUEUE_STANDARD_NAME_LENGTH] = "";
|
||||
mqd_t queue;
|
||||
|
||||
snprintf(qname, MQUEUE_STANDARD_NAME_LENGTH, "/mq026-1_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(qname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq026-1_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT1);
|
||||
|
||||
queue = mq_open(qname, O_RDWR, S_IRUSR | S_IWUSR, NULL);
|
||||
ICUNIT_GOTO_EQUAL(queue, (mqd_t)-1, queue, EXIT);
|
||||
@@ -45,6 +48,7 @@ static UINT32 Testcase(VOID)
|
||||
EXIT:
|
||||
mq_close(queue);
|
||||
mq_unlink(qname);
|
||||
EXIT1:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -36,7 +36,9 @@ static UINT32 Testcase(VOID)
|
||||
INT32 ret;
|
||||
mqd_t queue;
|
||||
|
||||
snprintf(qname, MQUEUE_STANDARD_NAME_LENGTH, "/mq027-1_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(qname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq027-1_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT1);
|
||||
|
||||
queue = mq_open(qname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, NULL);
|
||||
if (queue == (mqd_t)-1) {
|
||||
@@ -53,6 +55,7 @@ static UINT32 Testcase(VOID)
|
||||
EXIT:
|
||||
mq_close(queue);
|
||||
mq_unlink(qname);
|
||||
EXIT1:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -40,7 +40,9 @@ static UINT32 Testcase(VOID)
|
||||
mqd_t mqueue;
|
||||
struct mq_attr attr = { 0 };
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq031_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq031_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
|
||||
attr.mq_msgsize = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
attr.mq_maxmsg = MQUEUE_SHORT_ARRAY_LENGTH;
|
||||
@@ -69,6 +71,7 @@ EXIT1:
|
||||
mq_close(mqueue);
|
||||
EXIT:
|
||||
mq_unlink(mqname);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -37,7 +37,9 @@ static UINT32 Testcase(VOID)
|
||||
mqd_t mqueue;
|
||||
struct sigevent se;
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq032_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1,
|
||||
"/mq032_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
|
||||
mqueue = mq_open(mqname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, NULL);
|
||||
ICUNIT_GOTO_NOT_EQUAL(mqueue, (mqd_t)-1, mqueue, EXIT1);
|
||||
@@ -53,6 +55,7 @@ EXIT1:
|
||||
mq_close(mqueue);
|
||||
EXIT:
|
||||
mq_unlink(mqname);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -39,7 +39,9 @@ static UINT32 Testcase(VOID)
|
||||
mqd_t mqueue;
|
||||
struct mq_attr attr = { 0 };
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq033_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq033_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
|
||||
attr.mq_msgsize = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
attr.mq_maxmsg = MQUEUE_SHORT_ARRAY_LENGTH;
|
||||
@@ -66,6 +68,7 @@ EXIT1:
|
||||
mq_close(mqueue);
|
||||
EXIT:
|
||||
mq_unlink(mqname);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -38,7 +38,9 @@ static UINT32 Testcase(VOID)
|
||||
struct timespec ts;
|
||||
mqd_t mqueue;
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq036_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq036_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
|
||||
mqueue = mq_open(mqname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, NULL);
|
||||
ICUNIT_GOTO_NOT_EQUAL(mqueue, (mqd_t)-1, mqueue, EXIT1);
|
||||
@@ -60,6 +62,7 @@ EXIT1:
|
||||
mq_close(mqueue);
|
||||
EXIT:
|
||||
mq_unlink(mqname);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -37,8 +37,10 @@ static UINT32 Testcase(VOID)
|
||||
const CHAR *msgptr = MQUEUE_SEND_STRING_TEST;
|
||||
mqd_t mqueue;
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq038_%d", LosCurTaskIDGet());
|
||||
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq038_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
|
||||
mqueue = mq_open(mqname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, NULL);
|
||||
ICUNIT_GOTO_NOT_EQUAL(mqueue, (mqd_t)-1, mqueue, EXIT1);
|
||||
|
||||
@@ -57,6 +59,7 @@ EXIT1:
|
||||
mq_close(mqueue);
|
||||
EXIT:
|
||||
mq_unlink(mqname);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -88,7 +88,9 @@ static UINT32 Testcase(VOID)
|
||||
struct mq_attr attr = { 0 };
|
||||
pthread_attr_t attr1;
|
||||
|
||||
snprintf(g_gqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq040_%d", getpid());
|
||||
ret = snprintf_s(g_gqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq040_%d", getpid());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT3);
|
||||
|
||||
attr.mq_msgsize = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
attr.mq_maxmsg = 5; // 5, queue max message size.
|
||||
@@ -133,6 +135,7 @@ EXIT1:
|
||||
EXIT:
|
||||
mq_close(g_gqueue);
|
||||
mq_unlink(g_gqname);
|
||||
EXIT3:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -91,7 +91,9 @@ static UINT32 Testcase(VOID)
|
||||
pthread_attr_t attr1;
|
||||
pthread_t newTh1, newTh2;
|
||||
|
||||
snprintf(g_gqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq041_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(g_gqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq041_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT3);
|
||||
|
||||
attr.mq_msgsize = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
attr.mq_maxmsg = 5; // 5, queue max message size.
|
||||
@@ -135,6 +137,7 @@ EXIT1:
|
||||
EXIT:
|
||||
mq_close(g_gqueue);
|
||||
mq_unlink(g_gqname);
|
||||
EXIT3:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -39,7 +39,9 @@ static UINT32 Testcase(VOID)
|
||||
mqd_t mqueue;
|
||||
struct mq_attr attr = { 0 };
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq042_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1,
|
||||
"/mq042_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
|
||||
attr.mq_msgsize = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
attr.mq_maxmsg = MQUEUE_SHORT_ARRAY_LENGTH;
|
||||
@@ -48,7 +50,8 @@ static UINT32 Testcase(VOID)
|
||||
ICUNIT_GOTO_NOT_EQUAL(mqueue, (mqd_t)-1, mqueue, EXIT1);
|
||||
|
||||
while (1) {
|
||||
snprintf(msgptr, MQUEUE_STANDARD_NAME_LENGTH, "message %d", i);
|
||||
ret = snprintf_s(msgptr, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, "message %d", i);
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT1);
|
||||
ret = mq_send(mqueue, msgptr, strlen(msgptr), 0);
|
||||
if (ret == -1) {
|
||||
ICUNIT_GOTO_EQUAL(errno, EAGAIN, errno, EXIT1);
|
||||
@@ -59,7 +62,8 @@ static UINT32 Testcase(VOID)
|
||||
ICUNIT_GOTO_EQUAL(i, MQUEUE_SHORT_ARRAY_LENGTH, i, EXIT1);
|
||||
|
||||
i = 0;
|
||||
snprintf(msgptr, MQUEUE_STANDARD_NAME_LENGTH, "message %d", i);
|
||||
ret = snprintf_s(msgptr, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, "message %d", i);
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT1);
|
||||
ret = mq_receive(mqueue, msgrcd, MQUEUE_STANDARD_NAME_LENGTH, NULL);
|
||||
ICUNIT_GOTO_EQUAL(ret, strlen(msgptr), ret, EXIT1);
|
||||
|
||||
@@ -77,6 +81,7 @@ EXIT1:
|
||||
mq_close(mqueue);
|
||||
EXIT:
|
||||
mq_unlink(mqname);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -39,7 +39,9 @@ static UINT32 Testcase(VOID)
|
||||
mqd_t mqueue;
|
||||
struct mq_attr attr = { 0 };
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq043_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1,
|
||||
"/mq043_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
|
||||
attr.mq_msgsize = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
attr.mq_maxmsg = MQUEUE_SHORT_ARRAY_LENGTH;
|
||||
@@ -67,6 +69,7 @@ EXIT1:
|
||||
mq_close(mqueue);
|
||||
EXIT:
|
||||
mq_unlink(mqname);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -39,7 +39,9 @@ static UINT32 Testcase(VOID)
|
||||
mqd_t mqueue;
|
||||
struct mq_attr attr = { 0 };
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq044_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1,
|
||||
"/mq044_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
|
||||
attr.mq_msgsize = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
attr.mq_maxmsg = MQUEUE_SHORT_ARRAY_LENGTH;
|
||||
@@ -68,6 +70,7 @@ EXIT1:
|
||||
mq_close(mqueue);
|
||||
EXIT:
|
||||
mq_unlink(mqname);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -37,7 +37,9 @@ static UINT32 Testcase(VOID)
|
||||
mqd_t queue;
|
||||
INT32 unresolved = 0, failure = 0, ret = 0;
|
||||
|
||||
snprintf(qname, MQUEUE_STANDARD_NAME_LENGTH, "/mq046-1_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(qname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq046-1_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT);
|
||||
|
||||
queue = mq_open(qname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, NULL);
|
||||
ICUNIT_GOTO_NOT_EQUAL(queue, (mqd_t)-1, queue, EXIT);
|
||||
|
||||
@@ -38,7 +38,9 @@ static UINT32 Testcase(VOID)
|
||||
const CHAR *msgptr = MQUEUE_SEND_STRING_TEST;
|
||||
mqd_t mqueue;
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq047_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1,
|
||||
"/mq047_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
|
||||
mqueue = mq_open(mqname, O_CREAT | O_RDONLY | O_NONBLOCK, S_IRUSR | S_IWUSR, NULL);
|
||||
ICUNIT_GOTO_NOT_EQUAL(mqueue, (mqd_t)-1, mqueue, EXIT1);
|
||||
@@ -66,6 +68,7 @@ EXIT1:
|
||||
mq_close(mqueue);
|
||||
EXIT:
|
||||
mq_unlink(mqname);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -40,7 +40,9 @@ static UINT32 Testcase(VOID)
|
||||
struct timespec ts;
|
||||
struct mq_attr attr = { 0 };
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq048_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq048_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
|
||||
attr.mq_msgsize = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
attr.mq_maxmsg = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
@@ -67,6 +69,7 @@ EXIT1:
|
||||
mq_close(mqueue);
|
||||
EXIT:
|
||||
mq_unlink(mqname);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -38,7 +38,9 @@ static UINT32 Testcase(VOID)
|
||||
const CHAR *msgptr = MQUEUE_SEND_STRING_TEST;
|
||||
mqd_t mqueue;
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq049_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq049_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
|
||||
mqueue = mq_open(mqname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, NULL);
|
||||
ICUNIT_GOTO_NOT_EQUAL(mqueue, (mqd_t)-1, mqueue, EXIT1);
|
||||
@@ -60,6 +62,7 @@ EXIT1:
|
||||
mq_close(mqueue);
|
||||
EXIT:
|
||||
mq_unlink(mqname);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -40,8 +40,10 @@ static UINT32 Testcase(VOID)
|
||||
|
||||
struct mq_attr attr = { 0 };
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq050_%d", LosCurTaskIDGet());
|
||||
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1,
|
||||
"/mq050_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
|
||||
for (i = 0; i < MQUEUE_PRIORITY_NUM_TEST; i++) {
|
||||
attr.mq_msgsize = messagesize[i];
|
||||
attr.mq_maxmsg = messagesize[i];
|
||||
@@ -65,6 +67,7 @@ EXIT1:
|
||||
mq_close(mqueue);
|
||||
EXIT:
|
||||
mq_unlink(mqname);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -39,7 +39,9 @@ static UINT32 Testcase(VOID)
|
||||
mqd_t mqueue;
|
||||
struct mq_attr attr;
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq052_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1,
|
||||
"/mq052_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
|
||||
attr.mq_msgsize = MQUEUE_STANDARD_NAME_LENGTH + 1;
|
||||
attr.mq_maxmsg = MQUEUE_STANDARD_NAME_LENGTH + 1;
|
||||
@@ -65,6 +67,7 @@ EXIT1:
|
||||
mq_close(mqueue);
|
||||
EXIT:
|
||||
mq_unlink(mqname);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -38,7 +38,9 @@ static UINT32 Testcase(VOID)
|
||||
mqd_t mqueue;
|
||||
struct mq_attr attr = { 0 };
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq054_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq054_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
|
||||
attr.mq_msgsize = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
attr.mq_maxmsg = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
@@ -60,6 +62,7 @@ EXIT1:
|
||||
mq_close(mqueue);
|
||||
EXIT:
|
||||
mq_unlink(mqname);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -41,7 +41,9 @@ static UINT32 Testcase(VOID)
|
||||
mqd_t mqueue;
|
||||
struct mq_attr attr = { 0 };
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq055_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq055_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
|
||||
attr.mq_msgsize = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
attr.mq_maxmsg = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
@@ -80,6 +82,7 @@ EXIT1:
|
||||
mq_close(mqueue);
|
||||
EXIT:
|
||||
mq_unlink(mqname);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -37,7 +37,9 @@ static UINT32 Testcase(VOID)
|
||||
struct mq_attr attr = { 0 };
|
||||
INT32 unresolved = 0, failure = 0, ret = 0;
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq056-1-%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq056-1-%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT1);
|
||||
|
||||
attr.mq_msgsize = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
attr.mq_maxmsg = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
@@ -63,6 +65,7 @@ static UINT32 Testcase(VOID)
|
||||
EXIT:
|
||||
mq_close(mqdes);
|
||||
mq_unlink(mqname);
|
||||
EXIT1:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -38,7 +38,9 @@ static UINT32 Testcase(VOID)
|
||||
CHAR msgrv[MQUEUE_STANDARD_NAME_LENGTH] = {0};
|
||||
struct mq_attr attr = { 0 };
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq057_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq057_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
|
||||
attr.mq_msgsize = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
attr.mq_maxmsg = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
@@ -61,6 +63,7 @@ EXIT1:
|
||||
mq_close(mqueue);
|
||||
EXIT:
|
||||
mq_unlink(mqname);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -38,7 +38,9 @@ static UINT32 Testcase(VOID)
|
||||
struct mq_attr attr = { 0 };
|
||||
INT32 unresolved = 0, failure = 0, ret = 0;
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq058-2-%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq058-2-%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT1);
|
||||
|
||||
attr.mq_msgsize = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
attr.mq_maxmsg = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
@@ -59,6 +61,7 @@ static UINT32 Testcase(VOID)
|
||||
EXIT:
|
||||
mq_close(mqdes);
|
||||
mq_unlink(mqname);
|
||||
EXIT1:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -35,8 +35,10 @@ static UINT32 Testcase(VOID)
|
||||
INT32 ret;
|
||||
CHAR mqname[MQUEUE_STANDARD_NAME_LENGTH] = "";
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq060_%d", LosCurTaskIDGet());
|
||||
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq060_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT);
|
||||
|
||||
ret = mq_unlink(mqname);
|
||||
ICUNIT_GOTO_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT1);
|
||||
ICUNIT_GOTO_EQUAL(errno, ENOENT, errno, EXIT);
|
||||
|
||||
@@ -38,12 +38,15 @@ static UINT32 Testcase(VOID)
|
||||
INT32 unresolved = 0;
|
||||
INT32 failure = 0, ret = 0;
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq061-1_%d", LosCurTaskIDGet());
|
||||
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq061-1_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT1);
|
||||
|
||||
mqdes = mq_open(mqname, O_CREAT | O_RDWR | O_NONBLOCK, S_IRUSR | S_IWUSR, NULL);
|
||||
ICUNIT_GOTO_NOT_EQUAL(mqdes, (mqd_t)-1, mqdes, EXIT);
|
||||
|
||||
memset(&mqstat, 0, sizeof(mqstat));
|
||||
ret = memset_s(&mqstat, sizeof(mqstat), 0, sizeof(mqstat));
|
||||
ICUNIT_GOTO_EQUAL(ret, 0, ret, EXIT);
|
||||
|
||||
ret = mq_getattr(mqdes, &mqstat);
|
||||
ICUNIT_GOTO_EQUAL(ret, 0, ret, EXIT);
|
||||
@@ -63,6 +66,7 @@ static UINT32 Testcase(VOID)
|
||||
EXIT:
|
||||
mq_close(mqdes);
|
||||
mq_unlink(mqname);
|
||||
EXIT1:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -38,15 +38,19 @@ static UINT32 Testcase(VOID)
|
||||
INT32 unresolved = 0;
|
||||
INT32 failure = 0, ret = 0;
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq063-1_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq063-1_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT1);
|
||||
|
||||
memset(&mqstat, 0, sizeof(mqstat));
|
||||
ret = memset_s(&mqstat, sizeof(mqstat), 0, sizeof(mqstat));
|
||||
ICUNIT_ASSERT_EQUAL(ret, 0, ret);
|
||||
mqstat.mq_msgsize = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
mqstat.mq_maxmsg = 40; // 40, queue max message size.
|
||||
mqdes = mq_open(mqname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, &mqstat);
|
||||
ICUNIT_GOTO_NOT_EQUAL(mqdes, (mqd_t)-1, mqdes, EXIT);
|
||||
|
||||
memset(&nmqstat, 0, sizeof(nmqstat));
|
||||
ret = memset_s(&nmqstat, sizeof(nmqstat), 0, sizeof(nmqstat));
|
||||
ICUNIT_GOTO_EQUAL(ret, 0, ret, EXIT);
|
||||
|
||||
ret = mq_getattr(mqdes, &nmqstat);
|
||||
ICUNIT_GOTO_EQUAL(ret, 0, ret, EXIT);
|
||||
@@ -66,6 +70,7 @@ static UINT32 Testcase(VOID)
|
||||
EXIT:
|
||||
mq_close(mqdes);
|
||||
mq_unlink(mqname);
|
||||
EXIT1:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -38,9 +38,12 @@ static UINT32 Testcase(VOID)
|
||||
mqd_t mqueue;
|
||||
struct mq_attr mqstat;
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq064_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq064_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
|
||||
memset(&mqstat, 0, sizeof(mqstat));
|
||||
ret = memset_s(&mqstat, sizeof(mqstat), 0, sizeof(mqstat));
|
||||
ICUNIT_ASSERT_EQUAL(ret, 0, ret);
|
||||
mqstat.mq_msgsize = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
mqstat.mq_maxmsg = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
mqueue = mq_open(mqname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, &mqstat);
|
||||
@@ -50,7 +53,8 @@ static UINT32 Testcase(VOID)
|
||||
ret = mq_send(mqueue, msgptr, strlen(msgptr), 0);
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT1);
|
||||
}
|
||||
memset(&mqstat, 0, sizeof(mqstat));
|
||||
ret = memset_s(&mqstat, sizeof(mqstat), 0, sizeof(mqstat));
|
||||
ICUNIT_GOTO_EQUAL(ret, 0, ret, EXIT1);
|
||||
ret = mq_getattr(mqueue, &mqstat);
|
||||
ICUNIT_GOTO_EQUAL(ret, MQUEUE_NO_ERROR, ret, EXIT1);
|
||||
ICUNIT_GOTO_EQUAL(mqstat.mq_curmsgs, 5, mqstat.mq_curmsgs, EXIT1); // 5, assert the curmsgs.
|
||||
@@ -66,6 +70,7 @@ EXIT1:
|
||||
mq_close(mqueue);
|
||||
EXIT:
|
||||
mq_unlink(mqname);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -37,13 +37,16 @@ static UINT32 Testcase(VOID)
|
||||
mqd_t mqueue, mqdesInvalid;
|
||||
struct mq_attr mqstat;
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq065_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq065_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
|
||||
mqueue = mq_open(mqname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, 0);
|
||||
ICUNIT_GOTO_NOT_EQUAL(mqueue, (mqd_t)-1, mqueue, EXIT1);
|
||||
|
||||
mqdesInvalid = (mqd_t)((UINTPTR)mqueue + PER_ADDED_VALUE);
|
||||
memset(&mqstat, 0, sizeof(mqstat));
|
||||
ret = memset_s(&mqstat, sizeof(mqstat), 0, sizeof(mqstat));
|
||||
ICUNIT_GOTO_EQUAL(ret, 0, ret, EXIT1);
|
||||
|
||||
ret = mq_getattr(mqdesInvalid, &mqstat);
|
||||
ICUNIT_GOTO_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT1);
|
||||
@@ -60,6 +63,7 @@ EXIT1:
|
||||
mq_close(mqueue);
|
||||
EXIT:
|
||||
mq_unlink(mqname);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -39,13 +39,17 @@ static UINT32 Testcase(VOID)
|
||||
INT32 unresolved = 0;
|
||||
INT32 failure = 0, ret = 0;
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq066-1_%d", LosCurTaskIDGet());
|
||||
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq066-1_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT1);
|
||||
|
||||
mqdes = mq_open(mqname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, 0);
|
||||
ICUNIT_GOTO_NOT_EQUAL(mqdes, (mqd_t)-1, mqdes, EXIT);
|
||||
|
||||
memset(&mqstat, 0, sizeof(mqstat));
|
||||
memset(&nmqstat, 0, sizeof(nmqstat));
|
||||
ret = memset_s(&mqstat, sizeof(mqstat), 0, sizeof(mqstat));
|
||||
ICUNIT_GOTO_EQUAL(ret, 0, ret, EXIT);
|
||||
ret = memset_s(&nmqstat, sizeof(nmqstat), 0, sizeof(nmqstat));
|
||||
ICUNIT_ASSERT_EQUAL(ret, 0, ret);
|
||||
|
||||
ret = mq_getattr(mqdes, &mqstat);
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, -1, ret, EXIT);
|
||||
@@ -73,6 +77,7 @@ static UINT32 Testcase(VOID)
|
||||
EXIT:
|
||||
mq_close(mqdes);
|
||||
mq_unlink(mqname);
|
||||
EXIT1:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -38,13 +38,17 @@ static UINT32 Testcase(VOID)
|
||||
struct mq_attr mqstat1 = { 0 };
|
||||
struct mq_attr mqstat2 = { 0 };
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq067_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq067_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
|
||||
mqueue = mq_open(mqname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, 0);
|
||||
ICUNIT_GOTO_NOT_EQUAL(mqueue, (mqd_t)-1, mqueue, EXIT1);
|
||||
|
||||
memset(&mqstat1, 0, sizeof(mqstat1));
|
||||
memset(&mqstat2, 0, sizeof(mqstat1));
|
||||
ret = memset_s(&mqstat1, sizeof(mqstat1), 0, sizeof(mqstat1));
|
||||
ICUNIT_GOTO_EQUAL(ret, 0, ret, EXIT);
|
||||
ret = memset_s(&mqstat2, sizeof(mqstat2), 0, sizeof(mqstat1));
|
||||
ICUNIT_GOTO_EQUAL(ret, 0, ret, EXIT);
|
||||
|
||||
ret = mq_getattr(mqueue, &mqstat1);
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, -1, ret, EXIT1);
|
||||
@@ -73,6 +77,7 @@ EXIT1:
|
||||
mq_close(mqueue);
|
||||
EXIT:
|
||||
mq_unlink(mqname);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -38,16 +38,20 @@ static UINT32 Testcase(VOID)
|
||||
struct mq_attr mqstat1;
|
||||
struct mq_attr mqstat2;
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq069_%d", LosCurTaskIDGet());
|
||||
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq069_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT3);
|
||||
|
||||
mqueue1 = mq_open(mqname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, 0);
|
||||
ICUNIT_GOTO_NOT_EQUAL(mqueue1, (mqd_t)-1, mqueue1, EXIT1);
|
||||
|
||||
mqueue2 = mqueue1;
|
||||
mqueue1 = (mqd_t)((UINTPTR)mqueue1 + PER_ADDED_VALUE);
|
||||
|
||||
memset(&mqstat1, 0, sizeof(mqstat1));
|
||||
memset(&mqstat2, 0, sizeof(mqstat2));
|
||||
ret = memset_s(&mqstat1, sizeof(mqstat1), 0, sizeof(mqstat1));
|
||||
ICUNIT_GOTO_EQUAL(ret, 0, ret, EXIT);
|
||||
ret = memset_s(&mqstat2, sizeof(mqstat2), 0, sizeof(mqstat2));
|
||||
ICUNIT_GOTO_EQUAL(ret, 0, ret, EXIT);
|
||||
mqstat2.mq_flags = 1;
|
||||
|
||||
ret = mq_setattr(mqueue1, &mqstat1, NULL);
|
||||
@@ -73,6 +77,7 @@ EXIT1:
|
||||
mq_close(mqueue1);
|
||||
EXIT:
|
||||
mq_unlink(mqname);
|
||||
EXIT3:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -44,8 +44,10 @@ static UINT32 Testcase(VOID)
|
||||
attr.mq_msgsize = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
attr.mq_maxmsg = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq070_%d", LosCurTaskIDGet());
|
||||
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq070_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
|
||||
mqueue = mq_open(mqname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, &attr);
|
||||
ICUNIT_GOTO_NOT_EQUAL(mqueue, (mqd_t)-1, mqueue, EXIT1);
|
||||
|
||||
@@ -85,6 +87,7 @@ EXIT1:
|
||||
mq_close(mqueue);
|
||||
EXIT:
|
||||
mq_unlink(mqname);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -42,7 +42,9 @@ static UINT32 Testcase(VOID)
|
||||
attr.mq_msgsize = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
attr.mq_maxmsg = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq071_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq071_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
|
||||
mqueue = mq_open(mqname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, &attr);
|
||||
ICUNIT_GOTO_NOT_EQUAL(mqueue, (mqd_t)-1, mqueue, EXIT1);
|
||||
@@ -65,6 +67,7 @@ EXIT1:
|
||||
mq_close(mqueue);
|
||||
EXIT:
|
||||
mq_unlink(mqname);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -43,7 +43,9 @@ static UINT32 Testcase(VOID)
|
||||
msgAttr.mq_msgsize = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
msgAttr.mq_maxmsg = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
|
||||
snprintf(qName, MQUEUE_STANDARD_NAME_LENGTH, "/mq072_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(qName, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq072_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT);
|
||||
|
||||
msgQId = mq_open(qName, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, &msgAttr);
|
||||
ICUNIT_GOTO_NOT_EQUAL(msgQId, (mqd_t)-1, msgQId, EXIT);
|
||||
|
||||
@@ -43,9 +43,13 @@ static UINT32 Testcase(VOID)
|
||||
attr.mq_msgsize = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
attr.mq_maxmsg = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
|
||||
snprintf(mqname1, MQUEUE_STANDARD_NAME_LENGTH, "/mq073_1_%d", LosCurTaskIDGet());
|
||||
snprintf(mqname2, MQUEUE_STANDARD_NAME_LENGTH, "/mq073_2_%d", LosCurTaskIDGet());
|
||||
|
||||
ret = snprintf_s(mqname1, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq073_1_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
ret = snprintf_s(mqname2, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq073_2_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
|
||||
mqueue1 = mq_open(mqname1, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, &attr);
|
||||
ICUNIT_GOTO_NOT_EQUAL(mqueue1, (mqd_t)-1, mqueue1, EXIT);
|
||||
|
||||
@@ -77,6 +81,7 @@ EXIT1:
|
||||
EXIT:
|
||||
mq_close(mqueue1);
|
||||
mq_unlink(mqname1);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -65,8 +65,9 @@ static UINT32 Testcase(VOID)
|
||||
|
||||
g_testFlag = 1; // 1 initialize the flag
|
||||
LOS_TaskLock();
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq075_%d", LosCurTaskIDGet());
|
||||
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq075_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
g_gqueue = mq_open(mqname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, &attr);
|
||||
ICUNIT_GOTO_NOT_EQUAL(g_gqueue, (mqd_t)-1, g_gqueue, EXIT1);
|
||||
ret = pthread_attr_init(&attr1);
|
||||
@@ -110,6 +111,7 @@ EXIT1:
|
||||
mq_unlink(mqname);
|
||||
EXIT:
|
||||
PosixPthreadDestroy(&attr1, pthread1);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -63,7 +63,9 @@ static VOID *PthreadF02(VOID *arg)
|
||||
attr.mq_msgsize = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
attr.mq_maxmsg = 2; // 2, queue max message size.
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq076_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq076_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
|
||||
g_gqueue = mq_open(mqname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, &attr);
|
||||
ICUNIT_GOTO_NOT_EQUAL(g_gqueue, (mqd_t)-1, g_gqueue, EXIT1);
|
||||
@@ -103,6 +105,7 @@ EXIT1:
|
||||
EXIT:
|
||||
PosixPthreadDestroy(&attr1, thread1);
|
||||
g_testCount = 0;
|
||||
EXIT2:
|
||||
return NULL;
|
||||
}
|
||||
|
||||
|
||||
@@ -64,8 +64,9 @@ static UINT32 Testcase(VOID)
|
||||
|
||||
g_testCount = 0;
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq077_%d", LosCurTaskIDGet());
|
||||
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq077_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
g_gqueue = mq_open(mqname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, &attr);
|
||||
ICUNIT_GOTO_NOT_EQUAL(g_gqueue, (mqd_t)-1, g_gqueue, EXIT1);
|
||||
|
||||
@@ -104,6 +105,7 @@ EXIT1:
|
||||
EXIT:
|
||||
mq_close(g_gqueue);
|
||||
mq_unlink(mqname);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -65,7 +65,9 @@ static UINT32 Testcase(VOID)
|
||||
|
||||
g_testCount = 0;
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq078_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq078_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
|
||||
g_gqueue = mq_open(mqname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, &attr);
|
||||
ICUNIT_ASSERT_NOT_EQUAL(g_gqueue, (mqd_t)-1, g_gqueue);
|
||||
@@ -107,6 +109,7 @@ EXIT1:
|
||||
EXIT:
|
||||
mq_close(g_gqueue);
|
||||
mq_unlink(mqname);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -91,8 +91,10 @@ static UINT32 Testcase(VOID)
|
||||
pthread_attr_t attr1;
|
||||
struct sched_param schedparam;
|
||||
|
||||
memset(g_gqname, 0, MQUEUE_STANDARD_NAME_LENGTH);
|
||||
snprintf(g_gqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq079_%d", LosCurTaskIDGet());
|
||||
ret = memset_s(g_gqname, MQUEUE_STANDARD_NAME_LENGTH, 0, MQUEUE_STANDARD_NAME_LENGTH);
|
||||
ICUNIT_ASSERT_EQUAL(ret, 0, ret);
|
||||
(void)snprintf_s(g_gqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq079_%d", LosCurTaskIDGet());
|
||||
|
||||
g_testCount = 0;
|
||||
|
||||
|
||||
@@ -40,8 +40,10 @@ static UINT32 Testcase(VOID)
|
||||
INT32 unresolved = 0, failure = 0, i, maxreached = 0, ret = 0;
|
||||
unsigned pri;
|
||||
|
||||
snprintf(qname, MQUEUE_STANDARD_NAME_LENGTH, "/mq080-1_%d", LosCurTaskIDGet());
|
||||
|
||||
ret = snprintf_s(qname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq080-1_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
|
||||
attr.mq_msgsize = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
attr.mq_maxmsg = MAXMSG5;
|
||||
queue = mq_open(qname, O_CREAT | O_RDWR | O_NONBLOCK, S_IRUSR | S_IWUSR, &attr);
|
||||
@@ -50,7 +52,8 @@ static UINT32 Testcase(VOID)
|
||||
ts.tv_sec = 0;
|
||||
ts.tv_nsec = 0;
|
||||
for (i = 0; i < MAXMSG5 + 1; i++) {
|
||||
snprintf(msgptr, MQUEUE_STANDARD_NAME_LENGTH, "message %d", i);
|
||||
ret = snprintf_s(msgptr, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, "message %d", i);
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT);
|
||||
ts.tv_sec++;
|
||||
if (mq_timedsend(queue, msgptr, strlen(msgptr), 0, &ts) == -1) {
|
||||
maxreached = 1;
|
||||
@@ -77,6 +80,7 @@ static UINT32 Testcase(VOID)
|
||||
EXIT:
|
||||
mq_close(queue);
|
||||
mq_unlink(qname);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -40,7 +40,9 @@ static UINT32 Testcase(VOID)
|
||||
INT32 unresolved = 0, ret;
|
||||
unsigned pri;
|
||||
|
||||
snprintf(qname, MQUEUE_STANDARD_NAME_LENGTH, "/mq081-1_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(qname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq081-1_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT1);
|
||||
|
||||
attr.mq_msgsize = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
attr.mq_maxmsg = MAXMSG5;
|
||||
@@ -68,6 +70,7 @@ static UINT32 Testcase(VOID)
|
||||
EXIT:
|
||||
mq_close(queue);
|
||||
mq_unlink(qname);
|
||||
EXIT1:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -40,7 +40,9 @@ static UINT32 Testcase(VOID)
|
||||
mqd_t mqueue;
|
||||
struct mq_attr attr = { 0 };
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq082_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq082_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
|
||||
attr.mq_msgsize = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
attr.mq_maxmsg = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
@@ -67,6 +69,7 @@ EXIT1:
|
||||
mq_close(mqueue);
|
||||
EXIT:
|
||||
mq_unlink(mqname);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -39,8 +39,9 @@ static UINT32 Testcase(VOID)
|
||||
mqd_t queue;
|
||||
INT32 unresolved = 0, failure = 0, i, maxreached = 0, ret = 0;
|
||||
|
||||
snprintf(qname, MQUEUE_STANDARD_NAME_LENGTH, "/mq083-1_%d", LosCurTaskIDGet());
|
||||
|
||||
ret = snprintf_s(qname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq083-1_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT1);
|
||||
attr.mq_msgsize = 100; // 100, queue message size.
|
||||
attr.mq_maxmsg = MAXMSG5;
|
||||
queue = mq_open(qname, O_CREAT | O_RDWR | O_NONBLOCK, S_IRUSR | S_IWUSR, &attr);
|
||||
@@ -49,12 +50,14 @@ static UINT32 Testcase(VOID)
|
||||
ts.tv_sec = 1;
|
||||
ts.tv_nsec = 0;
|
||||
for (i = 0; i < MAXMSG5; i++) {
|
||||
snprintf(msgptr, MQUEUE_STANDARD_NAME_LENGTH, "message %d", i);
|
||||
ret = snprintf_s(msgptr, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, "message %d", i);
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT);
|
||||
ret = mq_timedsend(queue, msgptr, strlen(msgptr), 0, &ts);
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, -1, ret, EXIT);
|
||||
}
|
||||
|
||||
snprintf(msgptr, MQUEUE_STANDARD_NAME_LENGTH, "message %d", i);
|
||||
ret = snprintf_s(msgptr, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, "message %d", i);
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT1);
|
||||
ret = mq_timedsend(queue, msgptr, strlen(msgptr), 0, &ts);
|
||||
ICUNIT_GOTO_EQUAL(ret, -1, ret, EXIT);
|
||||
ICUNIT_GOTO_EQUAL(errno, EAGAIN, errno, EXIT);
|
||||
@@ -69,6 +72,7 @@ static UINT32 Testcase(VOID)
|
||||
EXIT:
|
||||
mq_close(queue);
|
||||
mq_unlink(qname);
|
||||
EXIT1:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -38,8 +38,9 @@ static UINT32 Testcase(VOID)
|
||||
mqd_t queue;
|
||||
INT32 unresolved = 0, failure = 0, ret = 0;
|
||||
|
||||
snprintf(qname, MQUEUE_STANDARD_NAME_LENGTH, "/mq084-1_%d", LosCurTaskIDGet());
|
||||
|
||||
ret = snprintf_s(qname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq084-1_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT1);
|
||||
queue = mq_open(qname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, NULL);
|
||||
ICUNIT_GOTO_NOT_EQUAL(queue, (mqd_t)-1, queue, EXIT);
|
||||
|
||||
@@ -59,6 +60,7 @@ static UINT32 Testcase(VOID)
|
||||
EXIT:
|
||||
mq_close(queue);
|
||||
mq_unlink(qname);
|
||||
EXIT1:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -38,8 +38,9 @@ static UINT32 Testcase(VOID)
|
||||
struct timespec ts;
|
||||
mqd_t mqueue;
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq085_%d", LosCurTaskIDGet());
|
||||
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq085_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
mqueue = mq_open(mqname, O_CREAT | O_RDONLY, S_IRUSR | S_IWUSR, NULL);
|
||||
ICUNIT_GOTO_NOT_EQUAL(mqueue, (mqd_t)-1, mqueue, EXIT1);
|
||||
|
||||
@@ -60,6 +61,7 @@ EXIT1:
|
||||
mq_close(mqueue);
|
||||
EXIT:
|
||||
mq_unlink(mqname);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -38,7 +38,9 @@ static UINT32 Testcase(VOID)
|
||||
struct timespec ts;
|
||||
mqd_t mqueue;
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "mq086_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"mq086_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
|
||||
mqueue = mq_open(mqname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, NULL);
|
||||
ICUNIT_GOTO_NOT_EQUAL(mqueue, (mqd_t)-1, mqueue, EXIT1);
|
||||
@@ -59,6 +61,7 @@ EXIT1:
|
||||
mq_close(mqueue);
|
||||
EXIT:
|
||||
mq_unlink(mqname);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -39,8 +39,9 @@ static UINT32 Testcase(VOID)
|
||||
struct timespec ts;
|
||||
mqd_t mqueue;
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq087_%d", LosCurTaskIDGet());
|
||||
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq087_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
mqueue = mq_open(mqname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, NULL);
|
||||
ICUNIT_GOTO_NOT_EQUAL(mqueue, (mqd_t)-1, mqueue, EXIT1);
|
||||
|
||||
@@ -63,6 +64,7 @@ EXIT1:
|
||||
mq_close(mqueue);
|
||||
EXIT:
|
||||
mq_unlink(mqname);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -40,8 +40,9 @@ static UINT32 Testcase(VOID)
|
||||
mqd_t mqueue;
|
||||
struct mq_attr attr = { 0 };
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq088_%d", LosCurTaskIDGet());
|
||||
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq088_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
ts.tv_sec = 0;
|
||||
ts.tv_nsec = 0;
|
||||
for (i = 0; i < MQUEUE_PRIORITY_NUM_TEST; i++) {
|
||||
@@ -68,6 +69,7 @@ EXIT1:
|
||||
mq_close(mqueue);
|
||||
EXIT:
|
||||
mq_unlink(mqname);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -38,8 +38,9 @@ static UINT32 Testcase(VOID)
|
||||
struct timespec ts;
|
||||
mqd_t mqueue;
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/tm/mq089_%d", LosCurTaskIDGet());
|
||||
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/tm/mq089_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
mqueue = mq_open(mqname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, NULL);
|
||||
ICUNIT_GOTO_NOT_EQUAL(mqueue, (mqd_t)-1, mqueue, EXIT1);
|
||||
|
||||
@@ -59,6 +60,7 @@ EXIT1:
|
||||
mq_close(mqueue);
|
||||
EXIT:
|
||||
mq_unlink(mqname);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -37,7 +37,8 @@ static UINT32 Testcase(VOID)
|
||||
INT32 i, unresolved = 0, failure = 0, numqueues = 0, ret;
|
||||
|
||||
for (i = 0; (i < _POSIX_OPEN_MAX) && (i < _POSIX_MQ_OPEN_MAX); i++, numqueues++) {
|
||||
snprintf(qname, MQUEUE_STANDARD_NAME_LENGTH, "/mq090%d_%d", i, LosCurTaskIDGet());
|
||||
(void)snprintf_s(qname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq090%d_%d", i, LosCurTaskIDGet());
|
||||
|
||||
queue[i] = mq_open(qname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, NULL);
|
||||
if (queue[i] == (mqd_t)-1) {
|
||||
@@ -59,12 +60,14 @@ static UINT32 Testcase(VOID)
|
||||
ICUNIT_GOTO_EQUAL(ret, 0, ret, EXIT);
|
||||
}
|
||||
for (i = 0; i < numqueues; i++) {
|
||||
snprintf(qname, MQUEUE_STANDARD_NAME_LENGTH, "/mq090%d_%d", i, LosCurTaskIDGet());
|
||||
(void)snprintf_s(qname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq090%d_%d", i, LosCurTaskIDGet());
|
||||
ret = mq_unlink(qname);
|
||||
ICUNIT_GOTO_EQUAL(ret, 0, ret, EXIT);
|
||||
}
|
||||
|
||||
snprintf(qname, MQUEUE_STANDARD_NAME_LENGTH, "/mq090%d_%d", numqueues, LosCurTaskIDGet());
|
||||
(void)snprintf_s(qname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq090%d_%d", numqueues, LosCurTaskIDGet());
|
||||
ret = mq_unlink(qname);
|
||||
ICUNIT_GOTO_EQUAL(ret, -1, ret, EXIT);
|
||||
|
||||
|
||||
@@ -38,8 +38,9 @@ static UINT32 Testcase(VOID)
|
||||
struct timespec ts;
|
||||
mqd_t mqueue;
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq091_%d", LosCurTaskIDGet());
|
||||
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq091_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
mqueue = mq_open(mqname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, NULL);
|
||||
ICUNIT_GOTO_NOT_EQUAL(mqueue, (mqd_t)-1, mqueue, EXIT1);
|
||||
|
||||
@@ -60,6 +61,7 @@ EXIT1:
|
||||
mq_close(mqueue);
|
||||
EXIT:
|
||||
mq_unlink(mqname);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -40,8 +40,9 @@ static UINT32 Testcase(VOID)
|
||||
struct sigaction act;
|
||||
time_t currsec;
|
||||
|
||||
snprintf(g_gqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq093_%d", LosCurTaskIDGet());
|
||||
|
||||
ret = snprintf_s(g_gqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq093_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
attr.mq_maxmsg = MQUEUE_SHORT_ARRAY_LENGTH;
|
||||
attr.mq_msgsize = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
|
||||
@@ -71,6 +72,7 @@ EXIT1:
|
||||
mq_close(g_gqueue);
|
||||
EXIT:
|
||||
mq_unlink(g_gqname);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -38,8 +38,10 @@ static UINT32 Testcase(VOID)
|
||||
struct timespec ts;
|
||||
mqd_t mqueue;
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq094_%d", LosCurTaskIDGet());
|
||||
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq094_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
|
||||
mqueue = mq_open(mqname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, NULL);
|
||||
ICUNIT_GOTO_NOT_EQUAL(mqueue, (mqd_t)-1, mqueue, EXIT);
|
||||
|
||||
@@ -61,6 +63,7 @@ EXIT1:
|
||||
mq_close(mqueue);
|
||||
EXIT:
|
||||
mq_unlink(mqname);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -42,7 +42,9 @@ static UINT32 Testcase(VOID)
|
||||
struct timespec ts;
|
||||
struct mq_attr attr = { 0 };
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq095_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq095_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
|
||||
attr.mq_maxmsg = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
attr.mq_msgsize = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
@@ -83,6 +85,7 @@ EXIT1:
|
||||
mq_close(mqueue);
|
||||
EXIT:
|
||||
mq_unlink(mqname);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -40,9 +40,12 @@ static UINT32 Testcase(VOID)
|
||||
struct mq_attr attr;
|
||||
struct timespec ts;
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq096_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq096_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
|
||||
memset(&attr, 0, sizeof(attr));
|
||||
ret = memset_s(&attr, sizeof(attr), 0, sizeof(attr));
|
||||
ICUNIT_ASSERT_EQUAL(ret, 0, ret);
|
||||
attr.mq_msgsize = 20 + 1; // 20, queue message size.
|
||||
attr.mq_maxmsg = 20 + 1; // 20, queue max message size.
|
||||
|
||||
@@ -69,6 +72,7 @@ EXIT1:
|
||||
mq_close(mqueue);
|
||||
EXIT:
|
||||
mq_unlink(mqname);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -92,7 +92,9 @@ static UINT32 Testcase(VOID)
|
||||
pthread_attr_t attr1;
|
||||
pthread_t newTh, newTh2;
|
||||
|
||||
snprintf(g_gqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq097_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(g_gqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq097_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT3);
|
||||
|
||||
attr.mq_msgsize = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
attr.mq_maxmsg = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
@@ -133,6 +135,7 @@ EXIT1:
|
||||
EXIT:
|
||||
mq_close(g_gqueue);
|
||||
mq_unlink(g_gqname);
|
||||
EXIT3:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -36,7 +36,9 @@ static UINT32 Testcase(VOID)
|
||||
INT32 ret = 0;
|
||||
mqd_t queue;
|
||||
|
||||
snprintf(qname, MQUEUE_STANDARD_NAME_LENGTH, "/mq098_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(qname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq098_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT1);
|
||||
|
||||
queue = mq_open(qname, O_CREAT | O_RDWR | O_WRONLY, S_IRUSR | S_IWUSR, NULL);
|
||||
ICUNIT_GOTO_NOT_EQUAL(queue, (mqd_t)-1, queue, EXIT);
|
||||
@@ -51,6 +53,7 @@ static UINT32 Testcase(VOID)
|
||||
EXIT:
|
||||
mq_close(queue);
|
||||
mq_unlink(qname);
|
||||
EXIT1:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -39,7 +39,9 @@ static UINT32 Testcase(VOID)
|
||||
struct timespec ts;
|
||||
struct mq_attr attr = { 0 };
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq100_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq100_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
|
||||
attr.mq_msgsize = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
attr.mq_maxmsg = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
@@ -64,6 +66,7 @@ EXIT1:
|
||||
mq_close(mqueue);
|
||||
EXIT:
|
||||
mq_unlink(mqname);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -42,7 +42,9 @@ static UINT32 Testcase(VOID)
|
||||
attr.mq_msgsize = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
attr.mq_maxmsg = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq101_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq101_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
|
||||
mqueue = mq_open(mqname, O_CREAT | O_RDWR | O_NONBLOCK, S_IRUSR | S_IWUSR, &attr);
|
||||
ICUNIT_GOTO_NOT_EQUAL(mqueue, (mqd_t)-1, mqueue, EXIT1);
|
||||
@@ -73,6 +75,7 @@ EXIT1:
|
||||
mq_close(mqueue);
|
||||
EXIT:
|
||||
mq_unlink(mqname);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -40,7 +40,9 @@ static UINT32 Testcase(VOID)
|
||||
struct timespec ts;
|
||||
struct mq_attr attr = { 0 };
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq102_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq102_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
|
||||
attr.mq_msgsize = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
attr.mq_maxmsg = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
@@ -68,6 +70,7 @@ EXIT1:
|
||||
mq_close(mqueue);
|
||||
EXIT:
|
||||
mq_unlink(mqname);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -40,7 +40,9 @@ static UINT32 Testcase(VOID)
|
||||
struct timespec ts;
|
||||
struct mq_attr attr = { 0 };
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq103_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq103_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
|
||||
attr.mq_msgsize = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
attr.mq_maxmsg = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
@@ -68,6 +70,7 @@ EXIT1:
|
||||
mq_close(mqueue);
|
||||
EXIT:
|
||||
mq_unlink(mqname);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -42,7 +42,9 @@ static UINT32 Testcase(VOID)
|
||||
struct timespec ts;
|
||||
struct mq_attr attr = { 0 };
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq104_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq104_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
|
||||
attr.mq_msgsize = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
attr.mq_maxmsg = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
@@ -83,6 +85,7 @@ EXIT1:
|
||||
mq_close(mqueue);
|
||||
EXIT:
|
||||
mq_unlink(mqname);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -39,7 +39,9 @@ static UINT32 Testcase(VOID)
|
||||
struct timespec ts;
|
||||
struct mq_attr attr = { 0 };
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq106_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq106_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
|
||||
attr.mq_msgsize = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
attr.mq_maxmsg = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
@@ -64,6 +66,7 @@ EXIT1:
|
||||
mq_close(mqueue);
|
||||
EXIT:
|
||||
mq_unlink(mqname);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -38,7 +38,9 @@ static UINT32 Testcase(VOID)
|
||||
struct mq_attr attr = { 0 };
|
||||
INT32 unresolved = 0, failure = 0, ret = 0;
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq108-1_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq108-1_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT1);
|
||||
|
||||
attr.mq_msgsize = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
attr.mq_maxmsg = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
@@ -61,6 +63,7 @@ static UINT32 Testcase(VOID)
|
||||
EXIT:
|
||||
mq_close(mqdes);
|
||||
mq_unlink(mqname);
|
||||
EXIT1:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -39,7 +39,9 @@ static UINT32 Testcase(VOID)
|
||||
struct timespec ts;
|
||||
struct mq_attr attr = { 0 };
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq109_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq109_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
|
||||
attr.mq_msgsize = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
attr.mq_maxmsg = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
@@ -63,6 +65,7 @@ EXIT1:
|
||||
mq_close(mqueue);
|
||||
EXIT:
|
||||
mq_unlink(mqname);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -39,7 +39,9 @@ static UINT32 Testcase(VOID)
|
||||
struct timespec ts;
|
||||
struct mq_attr attr = { 0 };
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq110_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq110_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
|
||||
attr.mq_msgsize = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
attr.mq_maxmsg = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
@@ -63,6 +65,7 @@ EXIT1:
|
||||
mq_close(mqueue);
|
||||
EXIT:
|
||||
mq_unlink(mqname);
|
||||
EXIT2:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -59,7 +59,9 @@ static VOID *PthreadF02(VOID *arg)
|
||||
|
||||
attr.mq_msgsize = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
attr.mq_maxmsg = MQUEUE_STANDARD_NAME_LENGTH;
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq111_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq111_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT3);
|
||||
|
||||
g_gqueue = mq_open(mqname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, &attr);
|
||||
ICUNIT_GOTO_NOT_EQUAL(g_gqueue, (mqd_t)-1, g_gqueue, EXIT2);
|
||||
@@ -95,6 +97,7 @@ EXIT1:
|
||||
mq_unlink(mqname);
|
||||
EXIT:
|
||||
pthread_join(pthread1, NULL);
|
||||
EXIT3:
|
||||
return NULL;
|
||||
}
|
||||
|
||||
|
||||
@@ -61,7 +61,9 @@ static UINT32 Testcase(VOID)
|
||||
|
||||
g_testCount = 0;
|
||||
|
||||
snprintf(qName, MQUEUE_STANDARD_NAME_LENGTH, "/mq112_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(qName, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq112_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT);
|
||||
|
||||
g_messageQId = mq_open(qName, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, &msgAttr);
|
||||
ICUNIT_GOTO_NOT_EQUAL(g_messageQId, (mqd_t)-1, g_messageQId, EXIT);
|
||||
|
||||
@@ -66,7 +66,9 @@ static UINT32 Testcase(VOID)
|
||||
|
||||
g_testCount = 0;
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq113_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq113_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT3);
|
||||
|
||||
g_gqueue = mq_open(mqname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, &attr);
|
||||
ICUNIT_GOTO_NOT_EQUAL(g_gqueue, (mqd_t)-1, g_gqueue, EXIT2);
|
||||
@@ -115,6 +117,7 @@ EXIT1:
|
||||
pthread_join(pthread1, NULL);
|
||||
EXIT:
|
||||
pthread_attr_destroy(&attr1);
|
||||
EXIT3:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -65,7 +65,9 @@ static UINT32 Testcase(VOID)
|
||||
g_testCount = 0;
|
||||
|
||||
LOS_TaskLock();
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq114_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq114_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT3);
|
||||
|
||||
g_gqueue = mq_open(mqname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, &attr);
|
||||
ICUNIT_GOTO_NOT_EQUAL(g_gqueue, (mqd_t)-1, g_gqueue, EXIT2);
|
||||
@@ -114,6 +116,7 @@ EXIT1:
|
||||
pthread_join(pthread1, NULL);
|
||||
EXIT:
|
||||
pthread_attr_destroy(&attr1);
|
||||
EXIT3:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -67,7 +67,9 @@ static UINT32 Testcase(VOID)
|
||||
|
||||
LOS_TaskLock();
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq115_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq115_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT3);
|
||||
|
||||
g_gqueue = mq_open(mqname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, &attr);
|
||||
ICUNIT_GOTO_NOT_EQUAL(g_gqueue, (mqd_t)-1, g_gqueue, EXIT2);
|
||||
@@ -113,6 +115,7 @@ EXIT1:
|
||||
pthread_join(pthread1, NULL);
|
||||
EXIT:
|
||||
pthread_attr_destroy(&attr1);
|
||||
EXIT3:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -43,7 +43,9 @@ static VOID *PthreadF01(VOID *arg)
|
||||
|
||||
LOS_AtomicInc(&g_testCount);
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq116_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq116_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT2);
|
||||
|
||||
g_gqueue = mq_open(mqname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, &attr);
|
||||
ICUNIT_GOTO_NOT_EQUAL(g_gqueue, (mqd_t)-1, g_gqueue, EXIT1);
|
||||
@@ -67,6 +69,7 @@ EXIT1:
|
||||
EXIT:
|
||||
mq_unlink(mqname);
|
||||
g_testCount = 0;
|
||||
EXIT2:
|
||||
return NULL;
|
||||
}
|
||||
|
||||
|
||||
@@ -63,7 +63,9 @@ static UINT32 Testcase(VOID)
|
||||
g_testCount = 0;
|
||||
|
||||
LOS_TaskLock();
|
||||
snprintf(qName, MQUEUE_STANDARD_NAME_LENGTH, "/mq117_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(qName, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq117_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT);
|
||||
|
||||
g_messageQId = mq_open(qName, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, &msgAttr);
|
||||
ICUNIT_GOTO_NOT_EQUAL(g_messageQId, (mqd_t)-1, g_messageQId, EXIT2);
|
||||
|
||||
@@ -99,7 +99,8 @@ static UINT32 Testcase(VOID)
|
||||
|
||||
LOS_TaskLock();
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq118_%d", LosCurTaskIDGet());
|
||||
(void)snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1,
|
||||
"/mq118_%d", LosCurTaskIDGet());
|
||||
|
||||
g_gqueue = mq_open(mqname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, &attr);
|
||||
ICUNIT_GOTO_NOT_EQUAL(g_gqueue, (mqd_t)-1, g_gqueue, EXIT);
|
||||
|
||||
@@ -77,7 +77,9 @@ static VOID *PthreadF02(VOID *arg)
|
||||
|
||||
LOS_AtomicInc(&g_testCount);
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq119_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq119_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT3);
|
||||
|
||||
g_gqueue = mq_open(mqname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, &attr);
|
||||
ICUNIT_GOTO_NOT_EQUAL(g_gqueue, (mqd_t)-1, g_gqueue, EXIT);
|
||||
@@ -117,6 +119,7 @@ EXIT1:
|
||||
EXIT:
|
||||
mq_close(g_gqueue);
|
||||
mq_unlink(mqname);
|
||||
EXIT3:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
@@ -89,7 +89,8 @@ static UINT32 Testcase(VOID)
|
||||
|
||||
g_testCount = 0;
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq120_%d", LosCurTaskIDGet());
|
||||
(void)snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1,
|
||||
"/mq120_%d", LosCurTaskIDGet());
|
||||
|
||||
g_gqueue = mq_open(mqname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, &attr);
|
||||
ICUNIT_GOTO_NOT_EQUAL(g_gqueue, (mqd_t)-1, g_gqueue, EXIT1);
|
||||
|
||||
@@ -141,7 +141,8 @@ static UINT32 Testcase(VOID)
|
||||
|
||||
g_testCount = 0;
|
||||
|
||||
snprintf(qName, MQUEUE_STANDARD_NAME_LENGTH, "/mq121_%d", LosCurTaskIDGet());
|
||||
(void)snprintf_s(qName, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq121_%d", LosCurTaskIDGet());
|
||||
|
||||
g_messageQId = mq_open(qName, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, &msgAttr);
|
||||
ICUNIT_GOTO_NOT_EQUAL(g_messageQId, (mqd_t)-1, g_messageQId, EXIT);
|
||||
|
||||
@@ -68,7 +68,9 @@ static UINT32 Testcase(VOID)
|
||||
|
||||
g_testCount = 0;
|
||||
|
||||
snprintf(mqname, MQUEUE_STANDARD_NAME_LENGTH, "/mq122_%d", LosCurTaskIDGet());
|
||||
ret = snprintf_s(mqname, MQUEUE_STANDARD_NAME_LENGTH, MQUEUE_STANDARD_NAME_LENGTH - 1, \
|
||||
"/mq122_%d", LosCurTaskIDGet());
|
||||
ICUNIT_GOTO_NOT_EQUAL(ret, MQUEUE_IS_ERROR, ret, EXIT3);
|
||||
|
||||
g_gqueue = mq_open(mqname, O_CREAT | O_RDWR, S_IRUSR | S_IWUSR, &attr);
|
||||
ICUNIT_GOTO_NOT_EQUAL(g_gqueue, (mqd_t)-1, g_gqueue, EXIT1);
|
||||
@@ -101,6 +103,7 @@ EXIT1:
|
||||
mq_close(g_gqueue);
|
||||
EXIT:
|
||||
mq_unlink(mqname);
|
||||
EXIT3:
|
||||
return MQUEUE_NO_ERROR;
|
||||
}
|
||||
|
||||
|
||||
Some files were not shown because too many files have changed in this diff Show More
Reference in New Issue
Block a user