提交 ef3d5b93 编写于 作者: S Shengliang Guan

[TD-1025] change ip list while vgroup master changed

上级 4ac04e47
...@@ -818,7 +818,7 @@ static SMDCreateVnodeMsg *mnodeBuildVnodeMsg(SVgObj *pVgroup) { ...@@ -818,7 +818,7 @@ static SMDCreateVnodeMsg *mnodeBuildVnodeMsg(SVgObj *pVgroup) {
SRpcEpSet mnodeGetEpSetFromVgroup(SVgObj *pVgroup) { SRpcEpSet mnodeGetEpSetFromVgroup(SVgObj *pVgroup) {
SRpcEpSet epSet = { SRpcEpSet epSet = {
.numOfEps = pVgroup->numOfVnodes, .numOfEps = pVgroup->numOfVnodes,
.inUse = 0, .inUse = pVgroup->inUse,
}; };
for (int i = 0; i < pVgroup->numOfVnodes; ++i) { for (int i = 0; i < pVgroup->numOfVnodes; ++i) {
strcpy(epSet.fqdn[i], pVgroup->vnodeGid[i].pDnode->dnodeFqdn); strcpy(epSet.fqdn[i], pVgroup->vnodeGid[i].pDnode->dnodeFqdn);
......
...@@ -31,7 +31,6 @@ char dbName[32] = "db"; ...@@ -31,7 +31,6 @@ char dbName[32] = "db";
char stableName[64] = "st"; char stableName[64] = "st";
int32_t numOfThreads = 30; int32_t numOfThreads = 30;
int32_t numOfTables = 100000; int32_t numOfTables = 100000;
int32_t maxTables = 5000;
int32_t replica = 1; int32_t replica = 1;
int32_t numOfColumns = 2; int32_t numOfColumns = 2;
...@@ -98,7 +97,7 @@ void createDbAndSTable() { ...@@ -98,7 +97,7 @@ void createDbAndSTable() {
exit(1); exit(1);
} }
sprintf(qstr, "create database if not exists %s maxtables %d replica %d", dbName, maxTables, replica); sprintf(qstr, "create database if not exists %s replica %d", dbName, replica);
TAOS_RES *pSql = taos_query(con, qstr); TAOS_RES *pSql = taos_query(con, qstr);
int32_t code = taos_errno(pSql); int32_t code = taos_errno(pSql);
if (code != 0) { if (code != 0) {
...@@ -195,8 +194,6 @@ void printHelp() { ...@@ -195,8 +194,6 @@ void printHelp() {
printf("%s%s%s%d\n", indent, indent, "replica, default is ", replica); printf("%s%s%s%d\n", indent, indent, "replica, default is ", replica);
printf("%s%s\n", indent, "-columns"); printf("%s%s\n", indent, "-columns");
printf("%s%s%s%d\n", indent, indent, "numOfColumns, default is ", numOfColumns); printf("%s%s%s%d\n", indent, indent, "numOfColumns, default is ", numOfColumns);
printf("%s%s\n", indent, "-tables");
printf("%s%s%s%d\n", indent, indent, "Database parameters tables, default is ", maxTables);
exit(EXIT_SUCCESS); exit(EXIT_SUCCESS);
} }
...@@ -218,8 +215,6 @@ void shellParseArgument(int argc, char *argv[]) { ...@@ -218,8 +215,6 @@ void shellParseArgument(int argc, char *argv[]) {
numOfTables = atoi(argv[++i]); numOfTables = atoi(argv[++i]);
} else if (strcmp(argv[i], "-r") == 0) { } else if (strcmp(argv[i], "-r") == 0) {
replica = atoi(argv[++i]); replica = atoi(argv[++i]);
} else if (strcmp(argv[i], "-tables") == 0) {
maxTables = atoi(argv[++i]);
} else if (strcmp(argv[i], "-columns") == 0) { } else if (strcmp(argv[i], "-columns") == 0) {
numOfColumns = atoi(argv[++i]); numOfColumns = atoi(argv[++i]);
} else { } else {
...@@ -233,7 +228,6 @@ void shellParseArgument(int argc, char *argv[]) { ...@@ -233,7 +228,6 @@ void shellParseArgument(int argc, char *argv[]) {
pPrint("%s numOfThreads:%d %s", GREEN, numOfThreads, NC); pPrint("%s numOfThreads:%d %s", GREEN, numOfThreads, NC);
pPrint("%s numOfColumns:%d %s", GREEN, numOfColumns, NC); pPrint("%s numOfColumns:%d %s", GREEN, numOfColumns, NC);
pPrint("%s replica:%d %s", GREEN, replica, NC); pPrint("%s replica:%d %s", GREEN, replica, NC);
pPrint("%s dbPara maxTables:%d %s", GREEN, maxTables, NC);
pPrint("%s start create table performace test %s", GREEN, NC); pPrint("%s start create table performace test %s", GREEN, NC);
} }
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册