chore: add notify test

This commit is contained in:
kailixu 2023-09-28 16:30:52 +08:00
parent 1088b80a46
commit 43eee9ab84
1 changed files with 17 additions and 4 deletions

View File

@ -30,7 +30,7 @@
#define nDup 1 #define nDup 1
#define nRoot 10 #define nRoot 10
#define nUser 10 #define nUser 1
#define USER_LEN 24 #define USER_LEN 24
#define BUF_LEN 1024 #define BUF_LEN 1024
@ -207,8 +207,8 @@ int main(int argc, char *argv[]) {
exit(1); exit(1);
} }
createUsers(taos, argv[1], qstr); createUsers(taos, argv[1], qstr);
passVerTestMulti(argv[1], qstr); // passVerTestMulti(argv[1], qstr);
sysInfoTest(taos, argv[1], qstr); // sysInfoTest(taos, argv[1], qstr);
userDroppedTest(taos, argv[1], qstr); userDroppedTest(taos, argv[1], qstr);
taos_close(taos); taos_close(taos);
@ -391,6 +391,10 @@ _REP:
void userDroppedTest(TAOS *taos, const char *host, char *qstr) { void userDroppedTest(TAOS *taos, const char *host, char *qstr) {
// users // users
int nTestUsers = nUser; int nTestUsers = nUser;
int nLoop = 0;
_loop:
++nLoop;
printf("%s:%d loop %d\n", __func__, __LINE__, nLoop);
for (int i = 0; i < nTestUsers; ++i) { for (int i = 0; i < nTestUsers; ++i) {
// sprintf(users[i], "user%d", i); // sprintf(users[i], "user%d", i);
taosu[i] = taos_connect(host, users[i], "taos", NULL, 0); taosu[i] = taos_connect(host, users[i], "taos", NULL, 0);
@ -437,5 +441,14 @@ void userDroppedTest(TAOS *taos, const char *host, char *qstr) {
exit(1); exit(1);
} }
fprintf(stderr, "######## %s #########\n", __func__); fprintf(stderr, "######## %s #########\n", __func__);
// sleep(300);
if (nLoop < 5) {
for (int i = 0; i < nTestUsers; ++i) {
sprintf(users[i], "user%d", i);
sprintf(qstr, "CREATE USER %s PASS 'taos'", users[i]);
queryDB(taos, qstr);
goto _loop;
}
// sleep(300);
}
} }