merge from master
This commit is contained in:
commit
935a758435
|
@ -108,7 +108,7 @@ static error_t parse_opt(int key, char *arg, struct argp_state *state) {
|
||||||
arguments->is_raw_time = true;
|
arguments->is_raw_time = true;
|
||||||
break;
|
break;
|
||||||
case 'f':
|
case 'f':
|
||||||
if (wordexp(arg, &full_path, 0) != 0) {
|
if ((0 == strlen(arg)) || (wordexp(arg, &full_path, 0) != 0)) {
|
||||||
fprintf(stderr, "Invalid path %s\n", arg);
|
fprintf(stderr, "Invalid path %s\n", arg);
|
||||||
return -1;
|
return -1;
|
||||||
}
|
}
|
||||||
|
|
|
@ -3328,7 +3328,9 @@ static void* createTable(void *sarg)
|
||||||
}
|
}
|
||||||
|
|
||||||
len = 0;
|
len = 0;
|
||||||
if (0 != queryDbExec(pThreadInfo->taos, pThreadInfo->buffer, NO_INSERT_TYPE, false)) {
|
|
||||||
|
if (0 != queryDbExec(pThreadInfo->taos, pThreadInfo->buffer,
|
||||||
|
NO_INSERT_TYPE, false)) {
|
||||||
errorPrint2("queryDbExec() failed. buffer:\n%s\n", pThreadInfo->buffer);
|
errorPrint2("queryDbExec() failed. buffer:\n%s\n", pThreadInfo->buffer);
|
||||||
free(pThreadInfo->buffer);
|
free(pThreadInfo->buffer);
|
||||||
return NULL;
|
return NULL;
|
||||||
|
|
|
@ -1572,7 +1572,7 @@ static void mergeTwoRowFromMem(STsdbQueryHandle* pQueryHandle, int32_t capacity,
|
||||||
int32_t numOfColsOfRow1 = 0;
|
int32_t numOfColsOfRow1 = 0;
|
||||||
|
|
||||||
if (pSchema1 == NULL) {
|
if (pSchema1 == NULL) {
|
||||||
pSchema1 = tsdbGetTableSchemaByVersion(pTable, dataRowVersion(row1));
|
pSchema1 = tsdbGetTableSchemaByVersion(pTable, memRowVersion(row1));
|
||||||
}
|
}
|
||||||
if(isRow1DataRow) {
|
if(isRow1DataRow) {
|
||||||
numOfColsOfRow1 = schemaNCols(pSchema1);
|
numOfColsOfRow1 = schemaNCols(pSchema1);
|
||||||
|
@ -1584,7 +1584,7 @@ static void mergeTwoRowFromMem(STsdbQueryHandle* pQueryHandle, int32_t capacity,
|
||||||
if(row2) {
|
if(row2) {
|
||||||
isRow2DataRow = isDataRow(row2);
|
isRow2DataRow = isDataRow(row2);
|
||||||
if (pSchema2 == NULL) {
|
if (pSchema2 == NULL) {
|
||||||
pSchema2 = tsdbGetTableSchemaByVersion(pTable, dataRowVersion(row2));
|
pSchema2 = tsdbGetTableSchemaByVersion(pTable, memRowVersion(row2));
|
||||||
}
|
}
|
||||||
if(isRow2DataRow) {
|
if(isRow2DataRow) {
|
||||||
numOfColsOfRow2 = schemaNCols(pSchema2);
|
numOfColsOfRow2 = schemaNCols(pSchema2);
|
||||||
|
|
|
@ -0,0 +1,3 @@
|
||||||
|
#!/bin/bash
|
||||||
|
|
||||||
|
taos -n fqdn
|
|
@ -0,0 +1,12 @@
|
||||||
|
#!/bin/bash
|
||||||
|
|
||||||
|
for N in -1 0 1 10000 10001
|
||||||
|
do
|
||||||
|
for l in 1023 1024 1073741824 1073741825
|
||||||
|
do
|
||||||
|
for S in udp tcp
|
||||||
|
do
|
||||||
|
taos -n speed -h BCC-2 -P 6030 -N $N -l $l -S $S 2>&1 | tee -a result.txt
|
||||||
|
done
|
||||||
|
done
|
||||||
|
done
|
Loading…
Reference in New Issue