Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
慢慢CG
TDengine
提交
936d9a33
T
TDengine
项目概览
慢慢CG
/
TDengine
与 Fork 源项目一致
Fork自
taosdata / TDengine
通知
1
Star
0
Fork
0
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
T
TDengine
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
提交
936d9a33
编写于
5月 18, 2020
作者:
S
Shengliang Guan
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
[TD-332] fix duplicate type in shell/taosdemo/taosdump
上级
f9056ac3
变更
7
隐藏空白更改
内联
并排
Showing
7 changed file
with
44 addition
and
45 deletion
+44
-45
src/kit/shell/inc/shell.h
src/kit/shell/inc/shell.h
+11
-12
src/kit/shell/src/shellEngine.c
src/kit/shell/src/shellEngine.c
+2
-2
src/kit/shell/src/shellImport.c
src/kit/shell/src/shellImport.c
+2
-2
src/kit/shell/src/shellLinux.c
src/kit/shell/src/shellLinux.c
+2
-2
src/kit/shell/src/shellMain.c
src/kit/shell/src/shellMain.c
+1
-1
src/kit/taosdemo/taosdemo.c
src/kit/taosdemo/taosdemo.c
+4
-4
src/kit/taosdump/taosdump.c
src/kit/taosdump/taosdump.c
+22
-22
未找到文件。
src/kit/shell/inc/shell.h
浏览文件 @
936d9a33
...
...
@@ -41,14 +41,13 @@
// dynamic config timestamp width according to maximum time precision
extern
int32_t
TIMESTAMP_OUTPUT_LENGTH
;
typedef
struct
History
History
;
struct
History
{
typedef
struct
SShellHistory
{
char
*
hist
[
MAX_HISTORY_SIZE
];
int
hstart
;
int
hend
;
};
}
SShellHistory
;
struct
a
rguments
{
typedef
struct
SShellA
rguments
{
char
*
host
;
char
*
password
;
char
*
user
;
...
...
@@ -62,11 +61,11 @@ struct arguments {
char
*
commands
;
int
abort
;
int
port
;
};
}
SShellArguments
;
/**************** Function declarations ****************/
extern
void
shellParseArgument
(
int
argc
,
char
*
argv
[],
struct
a
rguments
*
arguments
);
extern
TAOS
*
shellInit
(
struct
a
rguments
*
args
);
extern
void
shellParseArgument
(
int
argc
,
char
*
argv
[],
SShellA
rguments
*
arguments
);
extern
TAOS
*
shellInit
(
SShellA
rguments
*
args
);
extern
void
*
shellLoopQuery
(
void
*
arg
);
extern
void
taos_error
(
TAOS
*
con
);
extern
int
regex_match
(
const
char
*
s
,
const
char
*
reg
,
int
cflags
);
...
...
@@ -76,7 +75,7 @@ void shellRunCommandOnServer(TAOS* con, char command[]);
void
read_history
();
void
write_history
();
void
source_file
(
TAOS
*
con
,
char
*
fptr
);
void
source_dir
(
TAOS
*
con
,
struct
a
rguments
*
args
);
void
source_dir
(
TAOS
*
con
,
SShellA
rguments
*
args
);
void
get_history_path
(
char
*
history
);
void
cleanup_handler
(
void
*
arg
);
void
exitShell
();
...
...
@@ -89,12 +88,12 @@ int isCommentLine(char *line);
extern
char
PROMPT_HEADER
[];
extern
char
CONTINUE_PROMPT
[];
extern
int
prompt_size
;
extern
History
history
;
extern
SShellHistory
history
;
extern
struct
termios
oldtio
;
extern
void
set_terminal_mode
();
extern
int
get_old_terminal_mode
(
struct
termios
*
tio
);
extern
void
reset_terminal_mode
();
extern
struct
a
rguments
args
;
extern
TAOS_RES
*
result
;
extern
void
reset_terminal_mode
();
extern
SShellA
rguments
args
;
extern
TAOS_RES
*
result
;
#endif
src/kit/shell/src/shellEngine.c
浏览文件 @
936d9a33
...
...
@@ -33,12 +33,12 @@ char PROMPT_HEADER[] = "taos> ";
char
CONTINUE_PROMPT
[]
=
" -> "
;
int
prompt_size
=
6
;
TAOS_RES
*
result
=
NULL
;
History
history
;
SShell
History
history
;
/*
* FUNCTION: Initialize the shell.
*/
TAOS
*
shellInit
(
struct
a
rguments
*
args
)
{
TAOS
*
shellInit
(
SShellA
rguments
*
args
)
{
printf
(
"
\n
"
);
printf
(
CLIENT_VERSION
,
tsOsName
,
taos_get_client_info
());
fflush
(
stdout
);
...
...
src/kit/shell/src/shellImport.c
浏览文件 @
936d9a33
...
...
@@ -221,7 +221,7 @@ void* shellImportThreadFp(void *arg)
return
NULL
;
}
static
void
shellRunImportThreads
(
struct
a
rguments
*
args
)
static
void
shellRunImportThreads
(
SShellA
rguments
*
args
)
{
pthread_attr_t
thattr
;
ShellThreadObj
*
threadObj
=
(
ShellThreadObj
*
)
calloc
(
args
->
threadNum
,
sizeof
(
ShellThreadObj
));
...
...
@@ -254,7 +254,7 @@ static void shellRunImportThreads(struct arguments* args)
free
(
threadObj
);
}
void
source_dir
(
TAOS
*
con
,
struct
a
rguments
*
args
)
{
void
source_dir
(
TAOS
*
con
,
SShellA
rguments
*
args
)
{
shellGetDirectoryFileList
(
args
->
dir
);
int64_t
start
=
taosGetTimestampMs
();
...
...
src/kit/shell/src/shellLinux.c
浏览文件 @
936d9a33
...
...
@@ -50,7 +50,7 @@ static struct argp_option options[] = {
static
error_t
parse_opt
(
int
key
,
char
*
arg
,
struct
argp_state
*
state
)
{
/* Get the input argument from argp_parse, which we
know is a pointer to our arguments structure. */
struct
a
rguments
*
arguments
=
state
->
input
;
SShellA
rguments
*
arguments
=
state
->
input
;
wordexp_t
full_path
;
switch
(
key
)
{
...
...
@@ -129,7 +129,7 @@ static error_t parse_opt(int key, char *arg, struct argp_state *state) {
/* Our argp parser. */
static
struct
argp
argp
=
{
options
,
parse_opt
,
args_doc
,
doc
};
void
shellParseArgument
(
int
argc
,
char
*
argv
[],
struct
a
rguments
*
arguments
)
{
void
shellParseArgument
(
int
argc
,
char
*
argv
[],
SShellA
rguments
*
arguments
)
{
static
char
verType
[
32
]
=
{
0
};
sprintf
(
verType
,
"version: %s
\n
"
,
version
);
...
...
src/kit/shell/src/shellMain.c
浏览文件 @
936d9a33
...
...
@@ -62,7 +62,7 @@ int checkVersion() {
}
// Global configurations
struct
a
rguments
args
=
{
SShellA
rguments
args
=
{
.
host
=
NULL
,
.
password
=
NULL
,
.
user
=
NULL
,
...
...
src/kit/taosdemo/taosdemo.c
浏览文件 @
936d9a33
...
...
@@ -67,7 +67,7 @@ static struct argp_option options[] = {
{
0
}};
/* Used by main to communicate with parse_opt. */
struct
a
rguments
{
typedef
struct
DemoA
rguments
{
char
*
host
;
uint16_t
port
;
char
*
user
;
...
...
@@ -87,13 +87,13 @@ struct arguments {
int
num_of_DPT
;
int
abort
;
char
**
arg_list
;
};
}
SDemoArguments
;
/* Parse a single option. */
static
error_t
parse_opt
(
int
key
,
char
*
arg
,
struct
argp_state
*
state
)
{
/* Get the input argument from argp_parse, which we
know is a pointer to our arguments structure. */
struct
a
rguments
*
arguments
=
state
->
input
;
SDemoA
rguments
*
arguments
=
state
->
input
;
wordexp_t
full_path
;
char
**
sptr
;
switch
(
key
)
{
...
...
@@ -269,7 +269,7 @@ double getCurrentTime();
void
callBack
(
void
*
param
,
TAOS_RES
*
res
,
int
code
);
int
main
(
int
argc
,
char
*
argv
[])
{
struct
a
rguments
arguments
=
{
NULL
,
// host
SDemoA
rguments
arguments
=
{
NULL
,
// host
0
,
// port
"root"
,
// user
"taosdata"
,
// password
...
...
src/kit/taosdump/taosdump.c
浏览文件 @
936d9a33
...
...
@@ -168,7 +168,7 @@ static struct argp_option options[] = {
{
0
}};
/* Used by main to communicate with parse_opt. */
struct
a
rguments
{
typedef
struct
SDumpA
rguments
{
// connection option
char
*
host
;
char
*
user
;
...
...
@@ -193,13 +193,13 @@ struct arguments {
char
**
arg_list
;
int
arg_list_len
;
bool
isDumpIn
;
};
}
SDumpArguments
;
/* Parse a single option. */
static
error_t
parse_opt
(
int
key
,
char
*
arg
,
struct
argp_state
*
state
)
{
/* Get the input argument from argp_parse, which we
know is a pointer to our arguments structure. */
struct
a
rguments
*
arguments
=
state
->
input
;
SDumpA
rguments
*
arguments
=
state
->
input
;
wordexp_t
full_path
;
switch
(
key
)
{
...
...
@@ -296,31 +296,31 @@ char *command = NULL;
char
*
lcommand
=
NULL
;
char
*
buffer
=
NULL
;
int
taosDumpOut
(
struct
a
rguments
*
arguments
);
int
taosDumpOut
(
SDumpA
rguments
*
arguments
);
int
taosDumpIn
(
struct
a
rguments
*
arguments
);
int
taosDumpIn
(
SDumpA
rguments
*
arguments
);
void
taosDumpCreateDbClause
(
SDbInfo
*
dbInfo
,
bool
isDumpProperty
,
FILE
*
fp
);
int
taosDumpDb
(
SDbInfo
*
dbInfo
,
struct
a
rguments
*
arguments
,
FILE
*
fp
);
int
taosDumpDb
(
SDbInfo
*
dbInfo
,
SDumpA
rguments
*
arguments
,
FILE
*
fp
);
void
taosDumpCreateTableClause
(
STableDef
*
tableDes
,
int
numOfCols
,
struct
a
rguments
*
arguments
,
FILE
*
fp
);
void
taosDumpCreateTableClause
(
STableDef
*
tableDes
,
int
numOfCols
,
SDumpA
rguments
*
arguments
,
FILE
*
fp
);
void
taosDumpCreateMTableClause
(
STableDef
*
tableDes
,
char
*
metric
,
int
numOfCols
,
struct
a
rguments
*
arguments
,
void
taosDumpCreateMTableClause
(
STableDef
*
tableDes
,
char
*
metric
,
int
numOfCols
,
SDumpA
rguments
*
arguments
,
FILE
*
fp
);
int32_t
taosDumpTable
(
char
*
table
,
char
*
metric
,
struct
a
rguments
*
arguments
,
FILE
*
fp
);
int32_t
taosDumpTable
(
char
*
table
,
char
*
metric
,
SDumpA
rguments
*
arguments
,
FILE
*
fp
);
int32_t
taosDumpMetric
(
char
*
metric
,
struct
a
rguments
*
arguments
,
FILE
*
fp
);
int32_t
taosDumpMetric
(
char
*
metric
,
SDumpA
rguments
*
arguments
,
FILE
*
fp
);
int
taosDumpTableData
(
FILE
*
fp
,
char
*
tbname
,
struct
a
rguments
*
arguments
);
int
taosDumpTableData
(
FILE
*
fp
,
char
*
tbname
,
SDumpA
rguments
*
arguments
);
int
taosCheckParam
(
struct
a
rguments
*
arguments
);
int
taosCheckParam
(
SDumpA
rguments
*
arguments
);
void
taosFreeDbInfos
();
int
main
(
int
argc
,
char
*
argv
[])
{
struct
a
rguments
arguments
=
{
SDumpA
rguments
arguments
=
{
// connection option
NULL
,
"root"
,
"taosdata"
,
0
,
// output file
...
...
@@ -424,7 +424,7 @@ int taosGetTableRecordInfo(char *table, STableRecordInfo *pTableRecordInfo) {
return
-
1
;
}
int
taosDumpOut
(
struct
a
rguments
*
arguments
)
{
int
taosDumpOut
(
SDumpA
rguments
*
arguments
)
{
TAOS_ROW
row
;
char
*
temp
=
NULL
;
FILE
*
fp
=
NULL
;
...
...
@@ -602,7 +602,7 @@ void taosDumpCreateDbClause(SDbInfo *dbInfo, bool isDumpProperty, FILE *fp) {
fprintf
(
fp
,
"%s
\n\n
"
,
buffer
);
}
int
taosDumpDb
(
SDbInfo
*
dbInfo
,
struct
a
rguments
*
arguments
,
FILE
*
fp
)
{
int
taosDumpDb
(
SDbInfo
*
dbInfo
,
SDumpA
rguments
*
arguments
,
FILE
*
fp
)
{
TAOS_ROW
row
;
int
fd
=
-
1
;
STableRecord
tableRecord
;
...
...
@@ -660,7 +660,7 @@ int taosDumpDb(SDbInfo *dbInfo, struct arguments *arguments, FILE *fp) {
return
0
;
}
void
taosDumpCreateTableClause
(
STableDef
*
tableDes
,
int
numOfCols
,
struct
a
rguments
*
arguments
,
FILE
*
fp
)
{
void
taosDumpCreateTableClause
(
STableDef
*
tableDes
,
int
numOfCols
,
SDumpA
rguments
*
arguments
,
FILE
*
fp
)
{
char
*
pstr
=
NULL
;
pstr
=
buffer
;
int
counter
=
0
;
...
...
@@ -703,7 +703,7 @@ void taosDumpCreateTableClause(STableDef *tableDes, int numOfCols, struct argume
fprintf
(
fp
,
"%s
\n\n
"
,
buffer
);
}
void
taosDumpCreateMTableClause
(
STableDef
*
tableDes
,
char
*
metric
,
int
numOfCols
,
struct
a
rguments
*
arguments
,
void
taosDumpCreateMTableClause
(
STableDef
*
tableDes
,
char
*
metric
,
int
numOfCols
,
SDumpA
rguments
*
arguments
,
FILE
*
fp
)
{
char
*
pstr
=
NULL
;
pstr
=
buffer
;
...
...
@@ -786,7 +786,7 @@ int taosGetTableDes(char *table, STableDef *tableDes) {
return
count
;
}
int32_t
taosDumpTable
(
char
*
table
,
char
*
metric
,
struct
a
rguments
*
arguments
,
FILE
*
fp
)
{
int32_t
taosDumpTable
(
char
*
table
,
char
*
metric
,
SDumpA
rguments
*
arguments
,
FILE
*
fp
)
{
int
count
=
0
;
STableDef
*
tableDes
=
(
STableDef
*
)
calloc
(
1
,
sizeof
(
STableDef
)
+
sizeof
(
SColDes
)
*
TSDB_MAX_COLUMNS
);
...
...
@@ -828,7 +828,7 @@ int32_t taosDumpTable(char *table, char *metric, struct arguments *arguments, FI
return
taosDumpTableData
(
fp
,
table
,
arguments
);
}
int32_t
taosDumpMetric
(
char
*
metric
,
struct
a
rguments
*
arguments
,
FILE
*
fp
)
{
int32_t
taosDumpMetric
(
char
*
metric
,
SDumpA
rguments
*
arguments
,
FILE
*
fp
)
{
TAOS_ROW
row
=
NULL
;
int
fd
=
-
1
;
STableRecord
tableRecord
;
...
...
@@ -877,7 +877,7 @@ int32_t taosDumpMetric(char *metric, struct arguments *arguments, FILE *fp) {
return
0
;
}
int
taosDumpTableData
(
FILE
*
fp
,
char
*
tbname
,
struct
a
rguments
*
arguments
)
{
int
taosDumpTableData
(
FILE
*
fp
,
char
*
tbname
,
SDumpA
rguments
*
arguments
)
{
/* char temp[MAX_COMMAND_SIZE] = "\0"; */
int
count
=
0
;
char
*
pstr
=
NULL
;
...
...
@@ -987,7 +987,7 @@ int taosDumpTableData(FILE *fp, char *tbname, struct arguments *arguments) {
return
0
;
}
int
taosCheckParam
(
struct
a
rguments
*
arguments
)
{
int
taosCheckParam
(
SDumpA
rguments
*
arguments
)
{
if
(
arguments
->
all_databases
&&
arguments
->
databases
)
{
fprintf
(
stderr
,
"conflict option --all-databases and --databases
\n
"
);
return
-
1
;
...
...
@@ -1072,7 +1072,7 @@ void taosReplaceCtrlChar(char *str) {
*
pstr
=
'\0'
;
}
int
taosDumpIn
(
struct
a
rguments
*
arguments
)
{
int
taosDumpIn
(
SDumpA
rguments
*
arguments
)
{
assert
(
arguments
->
isDumpIn
);
int
tsize
=
0
;
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录