Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
taosdata
TDengine
提交
97a373fa
T
TDengine
项目概览
taosdata
/
TDengine
1 年多 前同步成功
通知
1185
Star
22016
Fork
4786
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
1
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
T
TDengine
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
1
Issue
1
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
提交
97a373fa
编写于
4月 16, 2022
作者:
wafwerar
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
fix(build): exec output build bin.
上级
0231f6af
变更
31
隐藏空白更改
内联
并排
Showing
31 changed file
with
280 addition
and
213 deletion
+280
-213
cmake/cmake.define
cmake/cmake.define
+10
-0
packaging/release.sh
packaging/release.sh
+3
-3
tests/pytest/concurrent_inquiry.sh
tests/pytest/concurrent_inquiry.sh
+2
-2
tests/pytest/crash_gen.sh
tests/pytest/crash_gen.sh
+2
-2
tests/pytest/handle_taosd_val_log.sh
tests/pytest/handle_taosd_val_log.sh
+1
-1
tests/pytest/perf_gen.sh
tests/pytest/perf_gen.sh
+2
-2
tests/pytest/test.sh
tests/pytest/test.sh
+1
-1
tests/script/sh/cfg.sh
tests/script/sh/cfg.sh
+3
-3
tests/script/sh/clear.sh
tests/script/sh/clear.sh
+3
-3
tests/script/sh/deploy.sh
tests/script/sh/deploy.sh
+3
-3
tests/script/sh/exec-default.sh
tests/script/sh/exec-default.sh
+3
-3
tests/script/sh/exec-no-random-fail.sh
tests/script/sh/exec-no-random-fail.sh
+3
-3
tests/script/sh/exec-random-fail.sh
tests/script/sh/exec-random-fail.sh
+3
-3
tests/script/sh/exec.sh
tests/script/sh/exec.sh
+4
-4
tests/script/sh/exec_tarbitrator.sh
tests/script/sh/exec_tarbitrator.sh
+3
-3
tests/script/sh/massiveTable/compileVersion.sh
tests/script/sh/massiveTable/compileVersion.sh
+5
-5
tests/script/sh/move_dnode.sh
tests/script/sh/move_dnode.sh
+3
-3
tests/script/sh/mv_old_data.sh
tests/script/sh/mv_old_data.sh
+3
-3
tests/script/test.sh
tests/script/test.sh
+6
-6
tests/script/tsim/tmq/basic.sim
tests/script/tsim/tmq/basic.sim
+11
-4
tests/script/tsim/tmq/basic1.sim
tests/script/tsim/tmq/basic1.sim
+23
-18
tests/script/tsim/tmq/main2Con1Cgrp1TopicFrCtb.sim
tests/script/tsim/tmq/main2Con1Cgrp1TopicFrCtb.sim
+23
-18
tests/script/tsim/tmq/main2Con1Cgrp1TopicFrStb.sim
tests/script/tsim/tmq/main2Con1Cgrp1TopicFrStb.sim
+23
-18
tests/script/tsim/tmq/main2Con1Cgrp2TopicFrCtb.sim
tests/script/tsim/tmq/main2Con1Cgrp2TopicFrCtb.sim
+23
-18
tests/script/tsim/tmq/main2Con1Cgrp2TopicFrStb.sim
tests/script/tsim/tmq/main2Con1Cgrp2TopicFrStb.sim
+23
-18
tests/script/tsim/tmq/mainConsumerInMultiTopic.sim
tests/script/tsim/tmq/mainConsumerInMultiTopic.sim
+13
-8
tests/script/tsim/tmq/mainConsumerInOneTopic.sim
tests/script/tsim/tmq/mainConsumerInOneTopic.sim
+23
-18
tests/script/tsim/tmq/multiTopic.sim
tests/script/tsim/tmq/multiTopic.sim
+13
-8
tests/script/tsim/tmq/oneTopic.sim
tests/script/tsim/tmq/oneTopic.sim
+23
-18
tests/script/tsim/tmq/overlapTopic2Con1Cgrp.sim
tests/script/tsim/tmq/overlapTopic2Con1Cgrp.sim
+17
-12
tests/test/c/CMakeLists.txt
tests/test/c/CMakeLists.txt
+2
-2
未找到文件。
cmake/cmake.define
浏览文件 @
97a373fa
cmake_minimum_required(VERSION 3.16)
#set output directory
SET(LIBRARY_OUTPUT_PATH ${PROJECT_BINARY_DIR}/build/lib)
SET(EXECUTABLE_OUTPUT_PATH ${PROJECT_BINARY_DIR}/build/bin)
SET(TD_TESTS_OUTPUT_DIR ${PROJECT_BINARY_DIR}/test)
MESSAGE(STATUS "Project source directory: " ${PROJECT_SOURCE_DIR})
MESSAGE(STATUS "Project binary files output path: " ${PROJECT_BINARY_DIR})
MESSAGE(STATUS "Project executable files output path: " ${EXECUTABLE_OUTPUT_PATH})
MESSAGE(STATUS "Project library files output path: " ${LIBRARY_OUTPUT_PATH})
if (NOT DEFINED TD_GRANT)
SET(TD_GRANT FALSE)
endif()
...
...
packaging/release.sh
浏览文件 @
97a373fa
...
...
@@ -64,11 +64,11 @@ cp ${install_files} ${install_dir}
header_files
=
"
${
top_dir
}
/include/client/taos.h
${
top_dir
}
/include/util/taoserror.h"
cp
${
header_files
}
${
install_dir
}
/inc
bin_files
=
"
${
compile_dir
}
/
source/dnode/mgmt/taosd
${
compile_dir
}
/tools/shell/taos
${
compile_dir
}
/tests/test/c/create_table
${
compile_dir
}
/tests/test/c
/tmq_sim
${
script_dir
}
/remove.sh"
bin_files
=
"
${
compile_dir
}
/
build/bin/taosd
${
compile_dir
}
/build/bin/taos
${
compile_dir
}
/build/bin/create_table
${
compile_dir
}
/build/bin
/tmq_sim
${
script_dir
}
/remove.sh"
cp
${
bin_files
}
${
install_dir
}
/bin
&&
chmod
a+x
${
install_dir
}
/bin/
*
||
:
cp
${
compile_dir
}
/
source/client
/libtaos.so
${
install_dir
}
/lib/
cp
${
compile_dir
}
/
source/libs/td
b/libtdb.so
${
install_dir
}
/lib/
cp
${
compile_dir
}
/
build/lib
/libtaos.so
${
install_dir
}
/lib/
cp
${
compile_dir
}
/
build/li
b/libtdb.so
${
install_dir
}
/lib/
taostoolfile
=
"
${
top_dir
}
/tools/taosTools-1.4.1-Linux-x64.tar.gz"
cp
${
taostoolfile
}
${
install_dir
}
/taos-tools
...
...
tests/pytest/concurrent_inquiry.sh
浏览文件 @
97a373fa
...
...
@@ -35,11 +35,11 @@ CURR_DIR=`pwd`
IN_TDINTERNAL
=
"community"
if
[[
"
$CURR_DIR
"
==
*
"
$IN_TDINTERNAL
"
*
]]
;
then
TAOS_DIR
=
$CURR_DIR
/../../..
TAOSD_DIR
=
`
find
$TAOS_DIR
-name
"taosd"
|grep
debug
|head
-n1
`
TAOSD_DIR
=
`
find
$TAOS_DIR
-name
"taosd"
|grep
bin
|head
-n1
`
LIB_DIR
=
`
echo
$TAOSD_DIR
|rev|cut
-d
'/'
-f
3,4,5,6,7|rev
`
/lib
else
TAOS_DIR
=
$CURR_DIR
/../..
TAOSD_DIR
=
`
find
$TAOS_DIR
-name
"taosd"
|grep
debug
|head
-n1
`
TAOSD_DIR
=
`
find
$TAOS_DIR
-name
"taosd"
|grep
bin
|head
-n1
`
LIB_DIR
=
`
echo
$TAOSD_DIR
|rev|cut
-d
'/'
-f
3,4,5,6|rev
`
/lib
fi
...
...
tests/pytest/crash_gen.sh
浏览文件 @
97a373fa
...
...
@@ -35,11 +35,11 @@ CURR_DIR=`pwd`
IN_TDINTERNAL
=
"community"
if
[[
"
$CURR_DIR
"
==
*
"
$IN_TDINTERNAL
"
*
]]
;
then
TAOS_DIR
=
$CURR_DIR
/../../..
TAOSD_DIR
=
`
find
$TAOS_DIR
-name
"taosd"
|grep
debug
|head
-n1
`
TAOSD_DIR
=
`
find
$TAOS_DIR
-name
"taosd"
|grep
bin
|head
-n1
`
LIB_DIR
=
`
echo
$TAOSD_DIR
|rev|cut
-d
'/'
-f
3,4,5,6,7|rev
`
/lib
else
TAOS_DIR
=
$CURR_DIR
/../..
TAOSD_DIR
=
`
find
$TAOS_DIR
-name
"taosd"
|grep
debug
|head
-n1
`
TAOSD_DIR
=
`
find
$TAOS_DIR
-name
"taosd"
|grep
bin
|head
-n1
`
LIB_DIR
=
`
echo
$TAOSD_DIR
|rev|cut
-d
'/'
-f
3,4,5,6|rev
`
/lib
fi
...
...
tests/pytest/handle_taosd_val_log.sh
浏览文件 @
97a373fa
...
...
@@ -13,7 +13,7 @@ else
cd
../../..
fi
TOP_DIR
=
`
pwd
`
TAOSD_DIR
=
`
find
.
-name
"taosd"
|grep
-v
community|grep
debug
|head
-n1
`
TAOSD_DIR
=
`
find
.
-name
"taosd"
|grep
-v
community|grep
bin
|head
-n1
`
VALGRIND_OUT
=
taosd_valgrind.out
VALGRIND_ERR
=
taosd_valgrind.err
rm
-rf
/var/lib/taos/
*
...
...
tests/pytest/perf_gen.sh
浏览文件 @
97a373fa
...
...
@@ -35,11 +35,11 @@ CURR_DIR=`pwd`
IN_TDINTERNAL
=
"community"
if
[[
"
$CURR_DIR
"
==
*
"
$IN_TDINTERNAL
"
*
]]
;
then
TAOS_DIR
=
$CURR_DIR
/../../..
TAOSD_DIR
=
`
find
$TAOS_DIR
-name
"taosd"
|grep
debug
|head
-n1
`
TAOSD_DIR
=
`
find
$TAOS_DIR
-name
"taosd"
|grep
bin
|head
-n1
`
LIB_DIR
=
`
echo
$TAOSD_DIR
|rev|cut
-d
'/'
-f
3,4,5,6,7|rev
`
/lib
else
TAOS_DIR
=
$CURR_DIR
/../..
TAOSD_DIR
=
`
find
$TAOS_DIR
-name
"taosd"
|grep
debug
|head
-n1
`
TAOSD_DIR
=
`
find
$TAOS_DIR
-name
"taosd"
|grep
bin
|head
-n1
`
LIB_DIR
=
`
echo
$TAOSD_DIR
|rev|cut
-d
'/'
-f
3,4,5,6|rev
`
/lib
fi
...
...
tests/pytest/test.sh
浏览文件 @
97a373fa
...
...
@@ -11,7 +11,7 @@ if [[ "$CURR_DIR" == *"$IN_TDINTERNAL"* ]]; then
else
TAOS_DIR
=
$CURR_DIR
/../..
fi
TAOSD_DIR
=
`
find
$TAOS_DIR
-name
"taosd"
|grep
debug
|head
-n1
`
TAOSD_DIR
=
`
find
$TAOS_DIR
-name
"taosd"
|grep
bin
|head
-n1
`
LIB_DIR
=
`
echo
$TAOSD_DIR
|rev|cut
-d
'/'
-f
3,4,5,6|rev
`
/lib
export
PYTHONPATH
=
$(
pwd
)
/../../src/connector/python
export
LD_LIBRARY_PATH
=
$LD_LIBRARY_PATH
:
$LIB_DIR
...
...
tests/script/sh/cfg.sh
浏览文件 @
97a373fa
...
...
@@ -43,7 +43,7 @@ else
fi
TAOS_DIR
=
`
pwd
`
TAOSD_DIR
=
`
find
.
-name
"taosd"
|grep
debug
|head
-n1
`
TAOSD_DIR
=
`
find
.
-name
"taosd"
|grep
bin
|head
-n1
`
if
[[
"
$OS_TYPE
"
!=
"Darwin"
]]
;
then
cut_opt
=
"--field="
...
...
@@ -52,9 +52,9 @@ else
fi
if
[[
"
$TAOSD_DIR
"
==
*
"
$IN_TDINTERNAL
"
*
]]
;
then
BIN_DIR
=
`
find
.
-name
"taosd"
|grep
debug
|head
-n1
|cut
-d
'/'
${
cut_opt
}
2,3
`
BIN_DIR
=
`
find
.
-name
"taosd"
|grep
bin
|head
-n1
|cut
-d
'/'
${
cut_opt
}
2,3
`
else
BIN_DIR
=
`
find
.
-name
"taosd"
|grep
debug
|head
-n1
|cut
-d
'/'
${
cut_opt
}
2
`
BIN_DIR
=
`
find
.
-name
"taosd"
|grep
bin
|head
-n1
|cut
-d
'/'
${
cut_opt
}
2
`
fi
BUILD_DIR
=
$TAOS_DIR
/
$BIN_DIR
/build
...
...
tests/script/sh/clear.sh
浏览文件 @
97a373fa
...
...
@@ -46,7 +46,7 @@ else
fi
TAOS_DIR
=
`
pwd
`
TAOSD_DIR
=
`
find
.
-name
"taosd"
|grep
debug
|head
-n1
`
TAOSD_DIR
=
`
find
.
-name
"taosd"
|grep
bin
|head
-n1
`
if
[[
"
$OS_TYPE
"
!=
"Darwin"
]]
;
then
cut_opt
=
"--field="
...
...
@@ -55,9 +55,9 @@ else
fi
if
[[
"
$TAOSD_DIR
"
==
*
"
$IN_TDINTERNAL
"
*
]]
;
then
BIN_DIR
=
`
find
.
-name
"taosd"
|grep
debug
|head
-n1
|cut
-d
'/'
${
cut_opt
}
2,3
`
BIN_DIR
=
`
find
.
-name
"taosd"
|grep
bin
|head
-n1
|cut
-d
'/'
${
cut_opt
}
2,3
`
else
BIN_DIR
=
`
find
.
-name
"taosd"
|grep
debug
|head
-n1
|cut
-d
'/'
${
cut_opt
}
2
`
BIN_DIR
=
`
find
.
-name
"taosd"
|grep
bin
|head
-n1
|cut
-d
'/'
${
cut_opt
}
2
`
fi
BUILD_DIR
=
$TAOS_DIR
/
$BIN_DIR
/build
...
...
tests/script/sh/deploy.sh
浏览文件 @
97a373fa
...
...
@@ -41,7 +41,7 @@ else
fi
TAOS_DIR
=
`
pwd
`
TAOSD_DIR
=
`
find
.
-name
"taosd"
|grep
debug
|head
-n1
`
TAOSD_DIR
=
`
find
.
-name
"taosd"
|grep
bin
|head
-n1
`
if
[[
"
$OS_TYPE
"
!=
"Darwin"
]]
;
then
cut_opt
=
"--field="
...
...
@@ -50,9 +50,9 @@ else
fi
if
[[
"
$TAOSD_DIR
"
==
*
"
$IN_TDINTERNAL
"
*
]]
;
then
BIN_DIR
=
`
find
.
-name
"taosd"
|grep
source
|head
-n1
|cut
-d
'/'
${
cut_opt
}
2,3
`
BIN_DIR
=
`
find
.
-name
"taosd"
|grep
bin
|head
-n1
|cut
-d
'/'
${
cut_opt
}
2,3
`
else
BIN_DIR
=
`
find
.
-name
"taosd"
|grep
source
|head
-n1
|cut
-d
'/'
${
cut_opt
}
2
`
BIN_DIR
=
`
find
.
-name
"taosd"
|grep
bin
|head
-n1
|cut
-d
'/'
${
cut_opt
}
2
`
fi
BUILD_DIR
=
$TAOS_DIR
/
$BIN_DIR
...
...
tests/script/sh/exec-default.sh
浏览文件 @
97a373fa
...
...
@@ -52,7 +52,7 @@ else
fi
TAOS_DIR
=
`
pwd
`
TAOSD_DIR
=
`
find
.
-name
"taosd"
|grep
debug
|head
-n1
`
TAOSD_DIR
=
`
find
.
-name
"taosd"
|grep
bin
|head
-n1
`
if
[[
"
$OS_TYPE
"
!=
"Darwin"
]]
;
then
cut_opt
=
"--field="
...
...
@@ -61,9 +61,9 @@ else
fi
if
[[
"
$TAOSD_DIR
"
==
*
"
$IN_TDINTERNAL
"
*
]]
;
then
BIN_DIR
=
`
find
.
-name
"taosd"
|grep
debug
|head
-n1
|cut
-d
'/'
${
cut_opt
}
2,3
`
BIN_DIR
=
`
find
.
-name
"taosd"
|grep
bin
|head
-n1
|cut
-d
'/'
${
cut_opt
}
2,3
`
else
BIN_DIR
=
`
find
.
-name
"taosd"
|grep
debug
|head
-n1
|cut
-d
'/'
${
cut_opt
}
2
`
BIN_DIR
=
`
find
.
-name
"taosd"
|grep
bin
|head
-n1
|cut
-d
'/'
${
cut_opt
}
2
`
fi
BUILD_DIR
=
$TAOS_DIR
/
$BIN_DIR
/build
...
...
tests/script/sh/exec-no-random-fail.sh
浏览文件 @
97a373fa
...
...
@@ -52,7 +52,7 @@ else
fi
TAOS_DIR
=
`
pwd
`
TAOSD_DIR
=
`
find
.
-name
"taosd"
|grep
debug
|head
-n1
`
TAOSD_DIR
=
`
find
.
-name
"taosd"
|grep
bin
|head
-n1
`
if
[[
"
$OS_TYPE
"
!=
"Darwin"
]]
;
then
cut_opt
=
"--field="
...
...
@@ -61,9 +61,9 @@ else
fi
if
[[
"
$TAOSD_DIR
"
==
*
"
$IN_TDINTERNAL
"
*
]]
;
then
BIN_DIR
=
`
find
.
-name
"taosd"
|grep
debug
|head
-n1
|cut
-d
'/'
${
cut_opt
}
2,3
`
BIN_DIR
=
`
find
.
-name
"taosd"
|grep
bin
|head
-n1
|cut
-d
'/'
${
cut_opt
}
2,3
`
else
BIN_DIR
=
`
find
.
-name
"taosd"
|grep
debug
|head
-n1
|cut
-d
'/'
${
cut_opt
}
2
`
BIN_DIR
=
`
find
.
-name
"taosd"
|grep
bin
|head
-n1
|cut
-d
'/'
${
cut_opt
}
2
`
fi
BUILD_DIR
=
$TAOS_DIR
/
$BIN_DIR
/build
...
...
tests/script/sh/exec-random-fail.sh
浏览文件 @
97a373fa
...
...
@@ -52,7 +52,7 @@ else
fi
TAOS_DIR
=
`
pwd
`
TAOSD_DIR
=
`
find
.
-name
"taosd"
|grep
debug
|head
-n1
`
TAOSD_DIR
=
`
find
.
-name
"taosd"
|grep
bin
|head
-n1
`
if
[[
"
$OS_TYPE
"
!=
"Darwin"
]]
;
then
cut_opt
=
"--field="
...
...
@@ -61,9 +61,9 @@ else
fi
if
[[
"
$TAOSD_DIR
"
==
*
"
$IN_TDINTERNAL
"
*
]]
;
then
BIN_DIR
=
`
find
.
-name
"taosd"
|grep
debug
|head
-n1
|cut
-d
'/'
${
cut_opt
}
2,3
`
BIN_DIR
=
`
find
.
-name
"taosd"
|grep
bin
|head
-n1
|cut
-d
'/'
${
cut_opt
}
2,3
`
else
BIN_DIR
=
`
find
.
-name
"taosd"
|grep
debug
|head
-n1
|cut
-d
'/'
${
cut_opt
}
2
`
BIN_DIR
=
`
find
.
-name
"taosd"
|grep
bin
|head
-n1
|cut
-d
'/'
${
cut_opt
}
2
`
fi
BUILD_DIR
=
$TAOS_DIR
/
$BIN_DIR
/build
...
...
tests/script/sh/exec.sh
浏览文件 @
97a373fa
...
...
@@ -56,7 +56,7 @@ else
fi
TAOS_DIR
=
`
pwd
`
TAOSD_DIR
=
`
find
.
-name
"taosd"
|grep
debug
|head
-n1
`
TAOSD_DIR
=
`
find
.
-name
"taosd"
|grep
bin
|head
-n1
`
if
[[
"
$OS_TYPE
"
!=
"Darwin"
]]
;
then
cut_opt
=
"--field="
...
...
@@ -65,16 +65,16 @@ else
fi
if
[[
"
$TAOSD_DIR
"
==
*
"
$IN_TDINTERNAL
"
*
]]
;
then
BIN_DIR
=
`
find
.
-name
"taosd"
|grep
source
|head
-n1
|cut
-d
'/'
${
cut_opt
}
2,3
`
BIN_DIR
=
`
find
.
-name
"taosd"
|grep
bin
|head
-n1
|cut
-d
'/'
${
cut_opt
}
2,3
`
else
BIN_DIR
=
`
find
.
-name
"taosd"
|grep
source
|head
-n1
|cut
-d
'/'
${
cut_opt
}
2
`
BIN_DIR
=
`
find
.
-name
"taosd"
|grep
bin
|head
-n1
|cut
-d
'/'
${
cut_opt
}
2
`
fi
BUILD_DIR
=
$TAOS_DIR
/
$BIN_DIR
SIM_DIR
=
$TAOS_DIR
/sim
NODE_DIR
=
$SIM_DIR
/
$NODE_NAME
EXE_DIR
=
$BUILD_DIR
/
source/dnode/mgmt
EXE_DIR
=
$BUILD_DIR
/
build/bin
CFG_DIR
=
$NODE_DIR
/cfg
LOG_DIR
=
$NODE_DIR
/log
DATA_DIR
=
$NODE_DIR
/data
...
...
tests/script/sh/exec_tarbitrator.sh
浏览文件 @
97a373fa
...
...
@@ -49,7 +49,7 @@ else
fi
TAOS_DIR
=
`
pwd
`
TAOSD_DIR
=
`
find
.
-name
"taosd"
|grep
debug
|head
-n1
`
TAOSD_DIR
=
`
find
.
-name
"taosd"
|grep
bin
|head
-n1
`
if
[[
"
$OS_TYPE
"
!=
"Darwin"
]]
;
then
cut_opt
=
"--field="
...
...
@@ -58,9 +58,9 @@ else
fi
if
[[
"
$TAOSD_DIR
"
==
*
"
$IN_TDINTERNAL
"
*
]]
;
then
BIN_DIR
=
`
find
.
-name
"taosd"
|grep
debug
|head
-n1
|cut
-d
'/'
${
cut_opt
}
2,3
`
BIN_DIR
=
`
find
.
-name
"taosd"
|grep
bin
|head
-n1
|cut
-d
'/'
${
cut_opt
}
2,3
`
else
BIN_DIR
=
`
find
.
-name
"taosd"
|grep
debug
|head
-n1
|cut
-d
'/'
${
cut_opt
}
2
`
BIN_DIR
=
`
find
.
-name
"taosd"
|grep
bin
|head
-n1
|cut
-d
'/'
${
cut_opt
}
2
`
fi
BUILD_DIR
=
$TAOS_DIR
/
$BIN_DIR
/build
...
...
tests/script/sh/massiveTable/compileVersion.sh
浏览文件 @
97a373fa
...
...
@@ -67,20 +67,20 @@ cd ${projectDir}
gitPullBranchInfo
$TDengineBrVer
compileTDengineVersion
taos_dir
=
${
projectDir
}
/debug/
tools/shell
taosd_dir
=
${
projectDir
}
/debug/
source/dnode/mgmt
exec_process_dir
=
${
projectDir
}
/debug/
tests/test/c
taos_dir
=
${
projectDir
}
/debug/
build/bin
taosd_dir
=
${
projectDir
}
/debug/
build/bin
exec_process_dir
=
${
projectDir
}
/debug/
build/bin
rm
-f
/usr/bin/taos
rm
-f
/usr/bin/taosd
rm
-f
/usr/bin/create_table
rm
-f
/usr/bin/tmq_
demo
rm
-f
/usr/bin/tmq_
sim
rm
-f
/usr/bin/tmq_sim
ln
-s
$taos_dir
/taos /usr/bin/taos
ln
-s
$taosd_dir
/taosd /usr/bin/taosd
ln
-s
$exec_process_dir
/create_table /usr/bin/create_table
ln
-s
$exec_process_dir
/tmq_
demo /usr/bin/tmq_demo
ln
-s
$exec_process_dir
/tmq_
sim /usr/bin/tmq_sim
ln
-s
$exec_process_dir
/tmq_sim /usr/bin/tmq_sim
tests/script/sh/move_dnode.sh
浏览文件 @
97a373fa
...
...
@@ -18,7 +18,7 @@ else
fi
TAOS_DIR
=
`
pwd
`
TAOSD_DIR
=
`
find
.
-name
"taosd"
|grep
debug
|head
-n1
`
TAOSD_DIR
=
`
find
.
-name
"taosd"
|grep
bin
|head
-n1
`
if
[[
"
$OS_TYPE
"
!=
"Darwin"
]]
;
then
cut_opt
=
"--field="
...
...
@@ -27,9 +27,9 @@ else
fi
if
[[
"
$TAOSD_DIR
"
==
*
"
$IN_TDINTERNAL
"
*
]]
;
then
BIN_DIR
=
`
find
.
-name
"taosd"
|grep
debug
|head
-n1
|cut
-d
'/'
${
cut_opt
}
2,3
`
BIN_DIR
=
`
find
.
-name
"taosd"
|grep
bin
|head
-n1
|cut
-d
'/'
${
cut_opt
}
2,3
`
else
BIN_DIR
=
`
find
.
-name
"taosd"
|grep
debug
|head
-n1
|cut
-d
'/'
${
cut_opt
}
2
`
BIN_DIR
=
`
find
.
-name
"taosd"
|grep
bin
|head
-n1
|cut
-d
'/'
${
cut_opt
}
2
`
fi
BUILD_DIR
=
$TAOS_DIR
/
$BIN_DIR
/build
...
...
tests/script/sh/mv_old_data.sh
浏览文件 @
97a373fa
...
...
@@ -18,7 +18,7 @@ else
fi
TAOS_DIR
=
`
pwd
`
TAOSD_DIR
=
`
find
.
-name
"taosd"
|grep
debug
|head
-n1
`
TAOSD_DIR
=
`
find
.
-name
"taosd"
|grep
bin
|head
-n1
`
if
[[
"
$OS_TYPE
"
!=
"Darwin"
]]
;
then
cut_opt
=
"--field="
...
...
@@ -27,9 +27,9 @@ else
fi
if
[[
"
$TAOSD_DIR
"
==
*
"
$IN_TDINTERNAL
"
*
]]
;
then
BIN_DIR
=
`
find
.
-name
"taosd"
|grep
debug
|head
-n1
|cut
-d
'/'
${
cut_opt
}
2,3
`
BIN_DIR
=
`
find
.
-name
"taosd"
|grep
bin
|head
-n1
|cut
-d
'/'
${
cut_opt
}
2,3
`
else
BIN_DIR
=
`
find
.
-name
"taosd"
|grep
debug
|head
-n1
|cut
-d
'/'
${
cut_opt
}
2
`
BIN_DIR
=
`
find
.
-name
"taosd"
|grep
bin
|head
-n1
|cut
-d
'/'
${
cut_opt
}
2
`
fi
BUILD_DIR
=
$TAOS_DIR
/
$BIN_DIR
/build
...
...
tests/script/test.sh
浏览文件 @
97a373fa
...
...
@@ -51,7 +51,7 @@ else
fi
TOP_DIR
=
`
pwd
`
TAOSD_DIR
=
`
find
.
-name
"taosd"
|grep
debug
|head
-n1
`
TAOSD_DIR
=
`
find
.
-name
"taosd"
|grep
bin
|head
-n1
`
if
[[
"
$OS_TYPE
"
!=
"Darwin"
]]
;
then
cut_opt
=
"--field="
...
...
@@ -60,16 +60,16 @@ else
fi
if
[[
"
$TAOSD_DIR
"
==
*
"
$IN_TDINTERNAL
"
*
]]
;
then
BIN_DIR
=
`
find
.
-name
"taosd"
|grep
source
|head
-n1
|cut
-d
'/'
${
cut_opt
}
2,3
`
BIN_DIR
=
`
find
.
-name
"taosd"
|grep
bin
|head
-n1
|cut
-d
'/'
${
cut_opt
}
2,3
`
else
BIN_DIR
=
`
find
.
-name
"taosd"
|grep
source
|head
-n1
|cut
-d
'/'
${
cut_opt
}
2
`
BIN_DIR
=
`
find
.
-name
"taosd"
|grep
bin
|head
-n1
|cut
-d
'/'
${
cut_opt
}
2
`
fi
BUILD_DIR
=
$TOP_DIR
/
$BIN_DIR
declare
-x
BUILD_DIR
=
$TOP_DIR
/
$BIN_DIR
SIM_DIR
=
$TOP_DIR
/sim
declare
-x
SIM_DIR
=
$TOP_DIR
/sim
PROGRAM
=
$BUILD_DIR
/
tests/tsim
/tsim
PROGRAM
=
$BUILD_DIR
/
build/bin
/tsim
PRG_DIR
=
$SIM_DIR
/tsim
CFG_DIR
=
$PRG_DIR
/cfg
...
...
tests/script/tsim/tmq/basic.sim
浏览文件 @
97a373fa
...
...
@@ -23,8 +23,8 @@ if $data04 != ready then
goto check_dnode_ready
endi
#root@trd02 /data2/dnode $ tmq_
demo
--help
#Used to tmq_
demo
#root@trd02 /data2/dnode $ tmq_
sim
--help
#Used to tmq_
sim
# -c Configuration directory, default is
# -d The name of the database to be created, default is tmqdb
# -s The name of the super table to be created, default is stb
...
...
@@ -41,8 +41,15 @@ endi
# -m startTimestamp, default is 1640966400000 [2022-01-01 00:00:00]
# -g showMsgFlag, default is 0
#
print cmd===> system_content ../../debug/tests/test/c/tmq_demo -sim 1 -b 100 -c ../../sim/tsim/cfg -w ../../sim/dnode1/data/vnode/vnode4/wal
system_content ../../debug/tests/test/c/tmq_demo -sim 1 -b 100 -c ../../sim/tsim/cfg -w ../../sim/dnode1/data/vnode/vnode4/wal
system_content echo -n \$BUILD_DIR
$tmq_demo = $system_content . /build/bin/tmq_demo
system_content echo -n \$SIM_DIR
$tsim_cfg = $system_content . /tsim/cfg
$sim_wal = $system_content . /dnode1/data/vnode/vnode4/wal
print cmd===> system_content $tmq_demo -sim 1 -b 100 -c $tsim_cfg -w $sim_wal
system_content $tmq_demo -sim 1 -b 100 -c $tsim_cfg -w $sim_wal
print cmd result----> $system_content
if $system_content != @{consume success: 100}@ then
return -1
...
...
tests/script/tsim/tmq/basic1.sim
浏览文件 @
97a373fa
...
...
@@ -127,65 +127,70 @@ print inserted totalMsgCnt: $totalMsgCnt
# td.connect.port:6030
# td.connect.db:db
print cmd===> system_content ../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/cfg -d $dbNamme -t "topic_stb_column" -k "group.id:tg2"
system_content ../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/cfg -d $dbNamme -t "topic_stb_column" -k "group.id:tg2"
system_content echo -n \$BUILD_DIR
$tmq_sim = $system_content . /build/bin/tmq_sim
system_content echo -n \$SIM_DIR
$tsim_cfg = $system_content . /tsim/cfg
print cmd===> system_content $tmq_sim -c $tsim_cfg -d $dbNamme -t "topic_stb_column" -k "group.id:tg2"
system_content $tmq_sim -c $tsim_cfg -d $dbNamme -t "topic_stb_column" -k "group.id:tg2"
print cmd result----> $system_content
if $system_content != @{consume success: 20, 0}@ then
return -1
endi
#print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_stb_all" -k "group.id:tg2"
#system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_stb_all" -k "group.id:tg2"
#print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_stb_all" -k "group.id:tg2"
#system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_stb_all" -k "group.id:tg2"
#print cmd result----> $system_content
#if $system_content != @{consume success: 20, 0}@ then
# return -1
#endi
print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_stb_function" -k "group.id:tg2"
system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_stb_function" -k "group.id:tg2"
print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_stb_function" -k "group.id:tg2"
system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_stb_function" -k "group.id:tg2"
print cmd result----> $system_content
if $system_content != @{consume success: 20, 0}@ then
print expect @{consume success: 20, 0}@, actual: $system_content
return -1
endi
print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ctb_column" -k "group.id:tg2"
system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ctb_column" -k "group.id:tg2"
print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ctb_column" -k "group.id:tg2"
system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ctb_column" -k "group.id:tg2"
print cmd result----> $system_content
if $system_content != @{consume success: 10, 0}@ then
return -1
endi
print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ctb_all" -k "group.id:tg2"
system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ctb_all" -k "group.id:tg2"
print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ctb_all" -k "group.id:tg2"
system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ctb_all" -k "group.id:tg2"
print cmd result----> $system_content
if $system_content != @{consume success: 10, 0}@ then
return -1
endi
print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ctb_function" -k "group.id:tg2"
system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ctb_function" -k "group.id:tg2"
print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ctb_function" -k "group.id:tg2"
system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ctb_function" -k "group.id:tg2"
print cmd result----> $system_content
if $system_content != @{consume success: 10, 0}@ then
return -1
endi
print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ntb_column" -k "group.id:tg2"
system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ntb_column" -k "group.id:tg2"
print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ntb_column" -k "group.id:tg2"
system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ntb_column" -k "group.id:tg2"
print cmd result----> $system_content
if $system_content != @{consume success: 20, 0}@ then
return -1
endi
print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ntb_all" -k "group.id:tg2"
system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ntb_all" -k "group.id:tg2"
print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ntb_all" -k "group.id:tg2"
system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ntb_all" -k "group.id:tg2"
print cmd result----> $system_content
if $system_content != @{consume success: 20, 0}@ then
return -1
endi
print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ntb_function" -k "group.id:tg2"
system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ntb_function" -k "group.id:tg2"
print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ntb_function" -k "group.id:tg2"
system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ntb_function" -k "group.id:tg2"
print cmd result----> $system_content
if $system_content != @{consume success: 20, 0}@ then
return -1
...
...
tests/script/tsim/tmq/main2Con1Cgrp1TopicFrCtb.sim
浏览文件 @
97a373fa
...
...
@@ -180,22 +180,27 @@ $expect_result = $expect_result . $rowNum
$expect_result = $expect_result . @, @
$expect_result = $expect_result . 0}
print expect_result----> $expect_result
print cmd===> system_content ../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/cfg -d $dbNamme -t1 "topic_ctb_column" -k1 "group.id:tg2" -t "topic_ctb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb -j 0
system_content ../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/cfg -d $dbNamme -t1 "topic_ctb_column" -k1 "group.id:tg2" -t "topic_ctb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb -j 0
system_content echo -n \$BUILD_DIR
$tmq_sim = $system_content . /build/bin/tmq_sim
$tsim_cfg = $system_content . /tsim/cfg
print cmd===> system_content $tmq_sim -c $tsim_cfg -d $dbNamme -t1 "topic_ctb_column" -k1 "group.id:tg2" -t "topic_ctb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb -j 0
system_content $tmq_sim -c $tsim_cfg -d $dbNamme -t1 "topic_ctb_column" -k1 "group.id:tg2" -t "topic_ctb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb -j 0
print cmd result----> $system_content
if $system_content != success then
return -1
endi
print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_ctb_all" -k1 "group.id:tg2" -t "topic_ctb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb -j 0
system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_ctb_all" -k1 "group.id:tg2" -t "topic_ctb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb -j 0
print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_ctb_all" -k1 "group.id:tg2" -t "topic_ctb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb -j 0
system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_ctb_all" -k1 "group.id:tg2" -t "topic_ctb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb -j 0
print cmd result----> $system_content
if $system_content != success then
return -1
endi
print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_ctb_function" -k1 "group.id:tg2" -t "topic_ctb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb -j 0
system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_ctb_function" -k1 "group.id:tg2" -t "topic_ctb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb -j 0
print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_ctb_function" -k1 "group.id:tg2" -t "topic_ctb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb -j 0
system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_ctb_function" -k1 "group.id:tg2" -t "topic_ctb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb -j 0
print cmd result----> $system_content
if $system_content != success then
return -1
...
...
@@ -206,22 +211,22 @@ endi
#$expect_result = $expect_result . @, @
#$expect_result = $expect_result . 0}
#print expect_result----> $expect_result
#print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_ntb_column" -k1 "group.id:tg2" -t "topic_ntb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_ntb_column" -k1 "group.id:tg2" -t "topic_ntb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_ntb_column" -k1 "group.id:tg2" -t "topic_ntb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_ntb_column" -k1 "group.id:tg2" -t "topic_ntb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#print cmd result----> $system_content
#if $system_content != success then
# return -1
#endi
#
#print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_ntb_all" -k1 "group.id:tg2" -t "topic_ntb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_ntb_all" -k1 "group.id:tg2" -t "topic_ntb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_ntb_all" -k1 "group.id:tg2" -t "topic_ntb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_ntb_all" -k1 "group.id:tg2" -t "topic_ntb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#print cmd result----> $system_content
#if $system_content != success then
# return -1
#endi
#
#print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_ntb_function" -k1 "group.id:tg2" -t "topic_ntb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_ntb_function" -k1 "group.id:tg2" -t "topic_ntb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_ntb_function" -k1 "group.id:tg2" -t "topic_ntb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_ntb_function" -k1 "group.id:tg2" -t "topic_ntb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#print cmd result----> $system_content
#if $system_content != success then
# return -1
...
...
@@ -232,23 +237,23 @@ endi
#$expect_result = $expect_result . @, @
#$expect_result = $expect_result . 0}
#print expect_result----> $expect_result
#print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_stb_column" -k1 "group.id:tg2" -t "topic_stb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb
#system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_stb_column" -k1 "group.id:tg2" -t "topic_stb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb
#print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_stb_column" -k1 "group.id:tg2" -t "topic_stb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb
#system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_stb_column" -k1 "group.id:tg2" -t "topic_stb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb
#print cmd result----> $system_content
#if $system_content != success then
# return -1
#endi
#
##print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_stb_all" -k1 "group.id:tg2" -t "topic_stb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb
##system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_stb_all" -k1 "group.id:tg2" -t "topic_stb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb
##print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_stb_all" -k1 "group.id:tg2" -t "topic_stb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb
##system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_stb_all" -k1 "group.id:tg2" -t "topic_stb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb
##print cmd result----> $system_content
###if $system_content != @{consume success: 10000, 0}@ then
##if $system_content != success then
## return -1
##endi
#
#print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_stb_function" -k1 "group.id:tg2" -t "topic_stb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb
#system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_stb_function" -k1 "group.id:tg2" -t "topic_stb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb
#print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_stb_function" -k1 "group.id:tg2" -t "topic_stb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb
#system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_stb_function" -k1 "group.id:tg2" -t "topic_stb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb
#print cmd result----> $system_content
##if $system_content != @{consume success: 10000, 0}@ then
#if $system_content != success then
...
...
tests/script/tsim/tmq/main2Con1Cgrp1TopicFrStb.sim
浏览文件 @
97a373fa
...
...
@@ -156,22 +156,27 @@ print expectMsgCntFromStb: $expectMsgCntFromStb
#$expect_result = $expect_result . @, @
#$expect_result = $expect_result . 0}
#print expect_result----> $expect_result
#print cmd===> system_content ../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/cfg -d $dbNamme -t1 "topic_ctb_column" -k1 "group.id:tg2" -t "topic_ctb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#system_content ../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/cfg -d $dbNamme -t1 "topic_ctb_column" -k1 "group.id:tg2" -t "topic_ctb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
system_content echo -n \$BUILD_DIR
$tmq_sim = $system_content . /build/bin/tmq_sim
$tsim_cfg = $system_content . /tsim/cfg
#print cmd===> system_content $tmq_sim -c $tsim_cfg -d $dbNamme -t1 "topic_ctb_column" -k1 "group.id:tg2" -t "topic_ctb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#system_content $tmq_sim -c $tsim_cfg -d $dbNamme -t1 "topic_ctb_column" -k1 "group.id:tg2" -t "topic_ctb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#print cmd result----> $system_content
#if $system_content != success then
# return -1
#endi
#
#print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_ctb_all" -k1 "group.id:tg2" -t "topic_ctb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_ctb_all" -k1 "group.id:tg2" -t "topic_ctb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_ctb_all" -k1 "group.id:tg2" -t "topic_ctb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_ctb_all" -k1 "group.id:tg2" -t "topic_ctb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#print cmd result----> $system_content
#if $system_content != success then
# return -1
#endi
#
#print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_ctb_function" -k1 "group.id:tg2" -t "topic_ctb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_ctb_function" -k1 "group.id:tg2" -t "topic_ctb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_ctb_function" -k1 "group.id:tg2" -t "topic_ctb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_ctb_function" -k1 "group.id:tg2" -t "topic_ctb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#print cmd result----> $system_content
#if $system_content != success then
# return -1
...
...
@@ -182,22 +187,22 @@ print expectMsgCntFromStb: $expectMsgCntFromStb
#$expect_result = $expect_result . @, @
#$expect_result = $expect_result . 0}
#print expect_result----> $expect_result
#print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_ntb_column" -k1 "group.id:tg2" -t "topic_ntb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_ntb_column" -k1 "group.id:tg2" -t "topic_ntb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_ntb_column" -k1 "group.id:tg2" -t "topic_ntb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_ntb_column" -k1 "group.id:tg2" -t "topic_ntb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#print cmd result----> $system_content
#if $system_content != success then
# return -1
#endi
#
#print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_ntb_all" -k1 "group.id:tg2" -t "topic_ntb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_ntb_all" -k1 "group.id:tg2" -t "topic_ntb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_ntb_all" -k1 "group.id:tg2" -t "topic_ntb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_ntb_all" -k1 "group.id:tg2" -t "topic_ntb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#print cmd result----> $system_content
#if $system_content != success then
# return -1
#endi
#
#print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_ntb_function" -k1 "group.id:tg2" -t "topic_ntb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_ntb_function" -k1 "group.id:tg2" -t "topic_ntb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_ntb_function" -k1 "group.id:tg2" -t "topic_ntb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_ntb_function" -k1 "group.id:tg2" -t "topic_ntb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#print cmd result----> $system_content
#if $system_content != success then
# return -1
...
...
@@ -208,23 +213,23 @@ $expect_result = $expect_result . $expectMsgCntFromStb
$expect_result = $expect_result . @, @
$expect_result = $expect_result . 0}
print expect_result----> $expect_result
print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_stb_column" -k1 "group.id:tg2" -t "topic_stb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb -j 0
system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_stb_column" -k1 "group.id:tg2" -t "topic_stb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb -j 0
print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_stb_column" -k1 "group.id:tg2" -t "topic_stb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb -j 0
system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_stb_column" -k1 "group.id:tg2" -t "topic_stb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb -j 0
print cmd result----> $system_content
if $system_content != success then
return -1
endi
#print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_stb_all" -k1 "group.id:tg2" -t "topic_stb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb -j 0
#system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_stb_all" -k1 "group.id:tg2" -t "topic_stb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb -j 0
#print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_stb_all" -k1 "group.id:tg2" -t "topic_stb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb -j 0
#system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_stb_all" -k1 "group.id:tg2" -t "topic_stb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb -j 0
#print cmd result----> $system_content
##if $system_content != @{consume success: 10000, 0}@ then
#if $system_content != success then
# return -1
#endi
print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_stb_function" -k1 "group.id:tg2" -t "topic_stb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb -j 0
system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_stb_function" -k1 "group.id:tg2" -t "topic_stb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb -j 0
print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_stb_function" -k1 "group.id:tg2" -t "topic_stb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb -j 0
system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_stb_function" -k1 "group.id:tg2" -t "topic_stb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb -j 0
print cmd result----> $system_content
#if $system_content != @{consume success: 10000, 0}@ then
if $system_content != success then
...
...
tests/script/tsim/tmq/main2Con1Cgrp2TopicFrCtb.sim
浏览文件 @
97a373fa
...
...
@@ -150,22 +150,27 @@ $expect_result = $expect_result . $rowNum
$expect_result = $expect_result . @, @
$expect_result = $expect_result . 0}
print expect_result----> $expect_result
print cmd===> system_content ../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/cfg -d $dbNamme -t1 "topic_ctb_all" -k1 "group.id:tg2" -t "topic_ctb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb -j 1
system_content ../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/cfg -d $dbNamme -t1 "topic_ctb_all" -k1 "group.id:tg2" -t "topic_ctb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb -j 1
system_content echo -n \$BUILD_DIR
$tmq_sim = $system_content . /build/bin/tmq_sim
$tsim_cfg = $system_content . /tsim/cfg
print cmd===> system_content $tmq_sim -c $tsim_cfg -d $dbNamme -t1 "topic_ctb_all" -k1 "group.id:tg2" -t "topic_ctb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb -j 1
system_content $tmq_sim -c $tsim_cfg -d $dbNamme -t1 "topic_ctb_all" -k1 "group.id:tg2" -t "topic_ctb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb -j 1
print cmd result----> $system_content
if $system_content != success then
return -1
endi
print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_ctb_function" -k1 "group.id:tg2" -t "topic_ctb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb -j 1
system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_ctb_function" -k1 "group.id:tg2" -t "topic_ctb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb -j 1
print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_ctb_function" -k1 "group.id:tg2" -t "topic_ctb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb -j 1
system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_ctb_function" -k1 "group.id:tg2" -t "topic_ctb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb -j 1
print cmd result----> $system_content
if $system_content != success then
return -1
endi
print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_ctb_column" -k1 "group.id:tg2" -t "topic_ctb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb -j 1
system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_ctb_column" -k1 "group.id:tg2" -t "topic_ctb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb -j 1
print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_ctb_column" -k1 "group.id:tg2" -t "topic_ctb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb -j 1
system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_ctb_column" -k1 "group.id:tg2" -t "topic_ctb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb -j 1
print cmd result----> $system_content
if $system_content != success then
return -1
...
...
@@ -176,22 +181,22 @@ endi
#$expect_result = $expect_result . @, @
#$expect_result = $expect_result . 0}
#print expect_result----> $expect_result
#print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_ntb_column" -k1 "group.id:tg2" -t "topic_ntb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb -j 1
#system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_ntb_column" -k1 "group.id:tg2" -t "topic_ntb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb -j 1
#print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_ntb_column" -k1 "group.id:tg2" -t "topic_ntb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb -j 1
#system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_ntb_column" -k1 "group.id:tg2" -t "topic_ntb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb -j 1
#print cmd result----> $system_content
#if $system_content != success then
# return -1
#endi
#
#print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_ntb_all" -k1 "group.id:tg2" -t "topic_ntb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_ntb_all" -k1 "group.id:tg2" -t "topic_ntb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_ntb_all" -k1 "group.id:tg2" -t "topic_ntb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_ntb_all" -k1 "group.id:tg2" -t "topic_ntb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#print cmd result----> $system_content
#if $system_content != success then
# return -1
#endi
#
#print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_ntb_function" -k1 "group.id:tg2" -t "topic_ntb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_ntb_function" -k1 "group.id:tg2" -t "topic_ntb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_ntb_function" -k1 "group.id:tg2" -t "topic_ntb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_ntb_function" -k1 "group.id:tg2" -t "topic_ntb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#print cmd result----> $system_content
#if $system_content != success then
# return -1
...
...
@@ -202,23 +207,23 @@ endi
#$expect_result = $expect_result . @, @
#$expect_result = $expect_result . 0}
#print expect_result----> $expect_result
#print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_stb_column" -k1 "group.id:tg2" -t "topic_stb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb
#system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_stb_column" -k1 "group.id:tg2" -t "topic_stb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb
#print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_stb_column" -k1 "group.id:tg2" -t "topic_stb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb
#system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_stb_column" -k1 "group.id:tg2" -t "topic_stb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb
#print cmd result----> $system_content
#if $system_content != success then
# return -1
#endi
#
##print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_stb_all" -k1 "group.id:tg2" -t "topic_stb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb
##system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_stb_all" -k1 "group.id:tg2" -t "topic_stb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb
##print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_stb_all" -k1 "group.id:tg2" -t "topic_stb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb
##system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_stb_all" -k1 "group.id:tg2" -t "topic_stb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb
##print cmd result----> $system_content
###if $system_content != @{consume success: 10000, 0}@ then
##if $system_content != success then
## return -1
##endi
#
#print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_stb_function" -k1 "group.id:tg2" -t "topic_stb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb
#system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_stb_function" -k1 "group.id:tg2" -t "topic_stb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb
#print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_stb_function" -k1 "group.id:tg2" -t "topic_stb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb
#system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_stb_function" -k1 "group.id:tg2" -t "topic_stb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb
#print cmd result----> $system_content
##if $system_content != @{consume success: 10000, 0}@ then
#if $system_content != success then
...
...
tests/script/tsim/tmq/main2Con1Cgrp2TopicFrStb.sim
浏览文件 @
97a373fa
...
...
@@ -156,22 +156,27 @@ print expectMsgCntFromStb: $expectMsgCntFromStb
#$expect_result = $expect_result . @, @
#$expect_result = $expect_result . 0}
#print expect_result----> $expect_result
#print cmd===> system_content ../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/cfg -d $dbNamme -t1 "topic_ctb_column" -k1 "group.id:tg2" -t "topic_ctb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#system_content ../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/cfg -d $dbNamme -t1 "topic_ctb_column" -k1 "group.id:tg2" -t "topic_ctb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
system_content echo -n \$BUILD_DIR
$tmq_sim = $system_content . /build/bin/tmq_sim
$tsim_cfg = $system_content . /tsim/cfg
#print cmd===> system_content $tmq_sim -c $tsim_cfg -d $dbNamme -t1 "topic_ctb_column" -k1 "group.id:tg2" -t "topic_ctb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#system_content $tmq_sim -c $tsim_cfg -d $dbNamme -t1 "topic_ctb_column" -k1 "group.id:tg2" -t "topic_ctb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#print cmd result----> $system_content
#if $system_content != success then
# return -1
#endi
#
#print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_ctb_all" -k1 "group.id:tg2" -t "topic_ctb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_ctb_all" -k1 "group.id:tg2" -t "topic_ctb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_ctb_all" -k1 "group.id:tg2" -t "topic_ctb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_ctb_all" -k1 "group.id:tg2" -t "topic_ctb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#print cmd result----> $system_content
#if $system_content != success then
# return -1
#endi
#
#print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_ctb_function" -k1 "group.id:tg2" -t "topic_ctb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_ctb_function" -k1 "group.id:tg2" -t "topic_ctb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_ctb_function" -k1 "group.id:tg2" -t "topic_ctb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_ctb_function" -k1 "group.id:tg2" -t "topic_ctb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#print cmd result----> $system_content
#if $system_content != success then
# return -1
...
...
@@ -182,22 +187,22 @@ print expectMsgCntFromStb: $expectMsgCntFromStb
#$expect_result = $expect_result . @, @
#$expect_result = $expect_result . 0}
#print expect_result----> $expect_result
#print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_ntb_column" -k1 "group.id:tg2" -t "topic_ntb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_ntb_column" -k1 "group.id:tg2" -t "topic_ntb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_ntb_column" -k1 "group.id:tg2" -t "topic_ntb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_ntb_column" -k1 "group.id:tg2" -t "topic_ntb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#print cmd result----> $system_content
#if $system_content != success then
# return -1
#endi
#
#print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_ntb_all" -k1 "group.id:tg2" -t "topic_ntb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_ntb_all" -k1 "group.id:tg2" -t "topic_ntb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_ntb_all" -k1 "group.id:tg2" -t "topic_ntb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_ntb_all" -k1 "group.id:tg2" -t "topic_ntb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#print cmd result----> $system_content
#if $system_content != success then
# return -1
#endi
#
#print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_ntb_function" -k1 "group.id:tg2" -t "topic_ntb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_ntb_function" -k1 "group.id:tg2" -t "topic_ntb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_ntb_function" -k1 "group.id:tg2" -t "topic_ntb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_ntb_function" -k1 "group.id:tg2" -t "topic_ntb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
#print cmd result----> $system_content
#if $system_content != success then
# return -1
...
...
@@ -208,23 +213,23 @@ $expect_result = $expect_result . $expectMsgCntFromStb
$expect_result = $expect_result . @, @
$expect_result = $expect_result . 0}
print expect_result----> $expect_result
print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_stb_function" -k1 "group.id:tg2" -t "topic_stb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb -j 1
system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_stb_function" -k1 "group.id:tg2" -t "topic_stb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb -j 1
print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_stb_function" -k1 "group.id:tg2" -t "topic_stb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb -j 1
system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_stb_function" -k1 "group.id:tg2" -t "topic_stb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb -j 1
print cmd result----> $system_content
if $system_content != success then
return -1
endi
#print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_stb_all" -k1 "group.id:tg2" -t "topic_stb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb -j 1
#system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_stb_all" -k1 "group.id:tg2" -t "topic_stb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb -j 1
#print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_stb_all" -k1 "group.id:tg2" -t "topic_stb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb -j 1
#system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_stb_all" -k1 "group.id:tg2" -t "topic_stb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb -j 1
#print cmd result----> $system_content
##if $system_content != @{consume success: 10000, 0}@ then
#if $system_content != success then
# return -1
#endi
print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_stb_column" -k1 "group.id:tg2" -t "topic_stb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb -j 1
system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_stb_column" -k1 "group.id:tg2" -t "topic_stb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb -j 1
print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_stb_column" -k1 "group.id:tg2" -t "topic_stb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb -j 1
system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_stb_column" -k1 "group.id:tg2" -t "topic_stb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb -j 1
print cmd result----> $system_content
#if $system_content != @{consume success: 10000, 0}@ then
if $system_content != success then
...
...
tests/script/tsim/tmq/mainConsumerInMultiTopic.sim
浏览文件 @
97a373fa
...
...
@@ -160,10 +160,15 @@ $expect_result = $expect_result . $expectMsgCntFromStb
$expect_result = $expect_result . @, @
$expect_result = $expect_result . 0}
print expect_result----> $expect_result
#print cmd===> system_content ../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/cfg -d $dbNamme -t "topic_stb_column, topic_stb_function, topic_stb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb
#system_content ../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/cfg -d $dbNamme -t "topic_stb_column, topic_stb_function, topic_stb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb
print cmd===> system_content ../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/cfg -d $dbNamme -t "topic_stb_column, topic_stb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb
system_content ../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/cfg -d $dbNamme -t "topic_stb_column, topic_stb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb
system_content echo -n \$BUILD_DIR
$tmq_sim = $system_content . /build/bin/tmq_sim
$tsim_cfg = $system_content . /tsim/cfg
#print cmd===> system_content $tmq_sim -c $tsim_cfg -d $dbNamme -t "topic_stb_column, topic_stb_function, topic_stb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb
#system_content $tmq_sim -c $tsim_cfg -d $dbNamme -t "topic_stb_column, topic_stb_function, topic_stb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb
print cmd===> system_content $tmq_sim -c $tsim_cfg -d $dbNamme -t "topic_stb_column, topic_stb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb
system_content $tmq_sim -c $tsim_cfg -d $dbNamme -t "topic_stb_column, topic_stb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb
print cmd result----> $system_content
#if $system_content != @{consume success: 20000, 0}@ then
if $system_content != $expect_result then
...
...
@@ -178,8 +183,8 @@ $expect_result = $expect_result . $expectMsgCntFromCtb
$expect_result = $expect_result . @, @
$expect_result = $expect_result . 0}
print expect_result----> $expect_result
print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ctb_column, topic_ctb_function, topic_ctb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ctb_column, topic_ctb_function, topic_ctb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ctb_column, topic_ctb_function, topic_ctb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ctb_column, topic_ctb_function, topic_ctb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
print cmd result----> $system_content
#if $system_content != @{consume success: 300, 0}@ then
if $system_content != $expect_result then
...
...
@@ -194,8 +199,8 @@ $expect_result = $expect_result . $expectMsgCntFromNtb
$expect_result = $expect_result . @, @
$expect_result = $expect_result . 0}
print expect_result----> $expect_result
print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ntb_column, topic_ntb_all, topic_ntb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromNtb
system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ntb_column, topic_ntb_all, topic_ntb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromNtb
print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ntb_column, topic_ntb_all, topic_ntb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromNtb
system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ntb_column, topic_ntb_all, topic_ntb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromNtb
print cmd result----> $system_content
#if $system_content != @{consume success: 30000, 0}@ then
if $system_content != $expect_result then
...
...
tests/script/tsim/tmq/mainConsumerInOneTopic.sim
浏览文件 @
97a373fa
...
...
@@ -157,23 +157,28 @@ $expect_result = $expect_result . $expectMsgCntFromStb
$expect_result = $expect_result . @, @
$expect_result = $expect_result . 0}
print expect_result----> $expect_result
print cmd===> system_content ../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/cfg -d $dbNamme -t "topic_stb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb
system_content ../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/cfg -d $dbNamme -t "topic_stb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb
system_content echo -n \$BUILD_DIR
$tmq_sim = $system_content . /build/bin/tmq_sim
$tsim_cfg = $system_content . /tsim/cfg
print cmd===> system_content $tmq_sim -c $tsim_cfg -d $dbNamme -t "topic_stb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb
system_content $tmq_sim -c $tsim_cfg -d $dbNamme -t "topic_stb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb
print cmd result----> $system_content
if $system_content != $expect_result then
return -1
endi
#print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_stb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb
#system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_stb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb
#print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_stb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb
#system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_stb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb
#print cmd result----> $system_content
##if $system_content != @{consume success: 10000, 0}@ then
#if $system_content != $expect_result then
# return -1
#endi
print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_stb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb
system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_stb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb
print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_stb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb
system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_stb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb
print cmd result----> $system_content
#if $system_content != @{consume success: 10000, 0}@ then
if $system_content != $expect_result then
...
...
@@ -185,22 +190,22 @@ $expect_result = $expect_result . $expectMsgCntFromCtb
$expect_result = $expect_result . @, @
$expect_result = $expect_result . 0}
print expect_result----> $expect_result
print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ctb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ctb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ctb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ctb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
print cmd result----> $system_content
if $system_content != $expect_result then
return -1
endi
print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ctb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ctb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ctb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ctb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
print cmd result----> $system_content
if $system_content != $expect_result then
return -1
endi
print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ctb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ctb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ctb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ctb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
print cmd result----> $system_content
if $system_content != $expect_result then
return -1
...
...
@@ -211,22 +216,22 @@ $expect_result = $expect_result . $expectMsgCntFromStb
$expect_result = $expect_result . @, @
$expect_result = $expect_result . 0}
print expect_result----> $expect_result
print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ntb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ntb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ntb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ntb_column" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
print cmd result----> $system_content
if $system_content != $expect_result then
return -1
endi
print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ntb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ntb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ntb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ntb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
print cmd result----> $system_content
if $system_content != $expect_result then
return -1
endi
print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ntb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ntb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ntb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ntb_function" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb
print cmd result----> $system_content
if $system_content != $expect_result then
return -1
...
...
tests/script/tsim/tmq/multiTopic.sim
浏览文件 @
97a373fa
...
...
@@ -173,10 +173,15 @@ $expect_result = $expect_result . $totalMsgCntOfmultiTopics
$expect_result = $expect_result . @, @
$expect_result = $expect_result . 0}
print expect_result----> $expect_result
#print cmd===> system_content ../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/cfg -d $dbNamme -t "topic_stb_column, topic_stb_function, topic_stb_all" -k "group.id:tg2"
#system_content ../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/cfg -d $dbNamme -t "topic_stb_column, topic_stb_function, topic_stb_all" -k "group.id:tg2"
print cmd===> system_content ../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/cfg -d $dbNamme -t "topic_stb_column, topic_stb_function" -k "group.id:tg2"
system_content ../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/cfg -d $dbNamme -t "topic_stb_column, topic_stb_function" -k "group.id:tg2"
system_content echo -n \$BUILD_DIR
$tmq_sim = $system_content . /build/bin/tmq_sim
$tsim_cfg = $system_content . /tsim/cfg
#print cmd===> system_content $tmq_sim -c $tsim_cfg -d $dbNamme -t "topic_stb_column, topic_stb_function, topic_stb_all" -k "group.id:tg2"
#system_content $tmq_sim -c $tsim_cfg -d $dbNamme -t "topic_stb_column, topic_stb_function, topic_stb_all" -k "group.id:tg2"
print cmd===> system_content $tmq_sim -c $tsim_cfg -d $dbNamme -t "topic_stb_column, topic_stb_function" -k "group.id:tg2"
system_content $tmq_sim -c $tsim_cfg -d $dbNamme -t "topic_stb_column, topic_stb_function" -k "group.id:tg2"
print cmd result----> $system_content
#if $system_content != @{consume success: 20000, 0}@ then
if $system_content != $expect_result then
...
...
@@ -190,8 +195,8 @@ $expect_result = $expect_result . $totalMsgCntOfmultiTopics
$expect_result = $expect_result . @, @
$expect_result = $expect_result . 0}
print expect_result----> $expect_result
print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ctb_column, topic_ctb_function, topic_ctb_all" -k "group.id:tg2"
system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ctb_column, topic_ctb_function, topic_ctb_all" -k "group.id:tg2"
print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ctb_column, topic_ctb_function, topic_ctb_all" -k "group.id:tg2"
system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ctb_column, topic_ctb_function, topic_ctb_all" -k "group.id:tg2"
print cmd result----> $system_content
#if $system_content != @{consume success: 300, 0}@ then
if $system_content != $expect_result then
...
...
@@ -205,8 +210,8 @@ $expect_result = $expect_result . $totalMsgCntOfmultiTopics
$expect_result = $expect_result . @, @
$expect_result = $expect_result . 0}
print expect_result----> $expect_result
print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ntb_column, topic_ntb_all, topic_ntb_function" -k "group.id:tg2"
system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ntb_column, topic_ntb_all, topic_ntb_function" -k "group.id:tg2"
print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ntb_column, topic_ntb_all, topic_ntb_function" -k "group.id:tg2"
system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ntb_column, topic_ntb_all, topic_ntb_function" -k "group.id:tg2"
print cmd result----> $system_content
#if $system_content != @{consume success: 30000, 0}@ then
if $system_content != $expect_result then
...
...
tests/script/tsim/tmq/oneTopic.sim
浏览文件 @
97a373fa
...
...
@@ -171,24 +171,29 @@ $expect_result = $expect_result . $totalMsgCnt
$expect_result = $expect_result . @, @
$expect_result = $expect_result . 0}
print expect_result----> $expect_result
print cmd===> system_content ../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/cfg -d $dbNamme -t "topic_stb_column" -k "group.id:tg2"
system_content ../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/cfg -d $dbNamme -t "topic_stb_column" -k "group.id:tg2"
system_content echo -n \$BUILD_DIR
$tmq_sim = $system_content . /build/bin/tmq_sim
$tsim_cfg = $system_content . /tsim/cfg
print cmd===> system_content $tmq_sim -c $tsim_cfg -d $dbNamme -t "topic_stb_column" -k "group.id:tg2"
system_content $tmq_sim -c $tsim_cfg -d $dbNamme -t "topic_stb_column" -k "group.id:tg2"
print cmd result----> $system_content
#if $system_content != @{consume success: 10000, 0}@ then
if $system_content != $expect_result then
return -1
endi
#print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_stb_all" -k "group.id:tg2"
#system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_stb_all" -k "group.id:tg2"
#print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_stb_all" -k "group.id:tg2"
#system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_stb_all" -k "group.id:tg2"
#print cmd result----> $system_content
##if $system_content != @{consume success: 10000, 0}@ then
#if $system_content != $expect_result then
# return -1
#endi
print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_stb_function" -k "group.id:tg2"
system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_stb_function" -k "group.id:tg2"
print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_stb_function" -k "group.id:tg2"
system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_stb_function" -k "group.id:tg2"
print cmd result----> $system_content
#if $system_content != @{consume success: 10000, 0}@ then
if $system_content != $expect_result then
...
...
@@ -200,24 +205,24 @@ $expect_result = $expect_result . $rowNum
$expect_result = $expect_result . @, @
$expect_result = $expect_result . 0}
print expect_result----> $expect_result
print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ctb_column" -k "group.id:tg2"
system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ctb_column" -k "group.id:tg2"
print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ctb_column" -k "group.id:tg2"
system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ctb_column" -k "group.id:tg2"
print cmd result----> $system_content
#if $system_content != @{consume success: 100, 0}@ then
if $system_content != $expect_result then
return -1
endi
print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ctb_all" -k "group.id:tg2"
system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ctb_all" -k "group.id:tg2"
print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ctb_all" -k "group.id:tg2"
system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ctb_all" -k "group.id:tg2"
print cmd result----> $system_content
#if $system_content != @{consume success: 100, 0}@ then
if $system_content != $expect_result then
return -1
endi
print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ctb_function" -k "group.id:tg2"
system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ctb_function" -k "group.id:tg2"
print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ctb_function" -k "group.id:tg2"
system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ctb_function" -k "group.id:tg2"
print cmd result----> $system_content
#if $system_content != @{consume success: 100, 0}@ then
if $system_content != $expect_result then
...
...
@@ -229,24 +234,24 @@ $expect_result = $expect_result . $totalMsgCnt
$expect_result = $expect_result . @, @
$expect_result = $expect_result . 0}
print expect_result----> $expect_result
print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ntb_column" -k "group.id:tg2"
system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ntb_column" -k "group.id:tg2"
print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ntb_column" -k "group.id:tg2"
system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ntb_column" -k "group.id:tg2"
print cmd result----> $system_content
#if $system_content != @{consume success: 10000, 0}@ then
if $system_content != $expect_result then
return -1
endi
print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ntb_all" -k "group.id:tg2"
system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ntb_all" -k "group.id:tg2"
print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ntb_all" -k "group.id:tg2"
system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ntb_all" -k "group.id:tg2"
print cmd result----> $system_content
#if $system_content != @{consume success: 10000, 0}@ then
if $system_content != $expect_result then
return -1
endi
print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ntb_function" -k "group.id:tg2"
system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ntb_function" -k "group.id:tg2"
print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ntb_function" -k "group.id:tg2"
system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ntb_function" -k "group.id:tg2"
print cmd result----> $system_content
#if $system_content != @{consume success: 10000, 0}@ then
if $system_content != $expect_result then
...
...
tests/script/tsim/tmq/overlapTopic2Con1Cgrp.sim
浏览文件 @
97a373fa
...
...
@@ -190,15 +190,20 @@ endi
$expectMsgCntFromStb0 = 2001
$expectMsgCntFromStb1 = 2001
print cmd===> system_content ../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/cfg -d $dbNamme -t1 "topic_stb_column, topic_stb_function" -k1 "group.id:tg2" -t "topic_stb_function, topic_stb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb0 -m1 $expectMsgCntFromStb1 -j 2
system_content ../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/cfg -d $dbNamme -t1 "topic_stb_column, topic_stb_function" -k1 "group.id:tg2" -t "topic_stb_function, topic_stb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb0 -m1 $expectMsgCntFromStb1 -j 2
system_content echo -n \$BUILD_DIR
$tmq_sim = $system_content . /build/bin/tmq_sim
$tsim_cfg = $system_content . /tsim/cfg
print cmd===> system_content $tmq_sim -c $tsim_cfg -d $dbNamme -t1 "topic_stb_column, topic_stb_function" -k1 "group.id:tg2" -t "topic_stb_function, topic_stb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb0 -m1 $expectMsgCntFromStb1 -j 2
system_content $tmq_sim -c $tsim_cfg -d $dbNamme -t1 "topic_stb_column, topic_stb_function" -k1 "group.id:tg2" -t "topic_stb_function, topic_stb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb0 -m1 $expectMsgCntFromStb1 -j 2
print cmd result----> $system_content
if $system_content != success then
return -1
endi
print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_stb_column, topic_stb_function" -k1 "group.id:tg1" -t "topic_stb_function, topic_stb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb -j 3
system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t1 "topic_stb_column, topic_stb_function" -k1 "group.id:tg1" -t "topic_stb_function, topic_stb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb -j 3
print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_stb_column, topic_stb_function" -k1 "group.id:tg1" -t "topic_stb_function, topic_stb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb -j 3
system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t1 "topic_stb_column, topic_stb_function" -k1 "group.id:tg1" -t "topic_stb_function, topic_stb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromStb -j 3
print cmd result----> $system_content
if $system_content != success then
return -1
...
...
@@ -211,29 +216,29 @@ endi
#$expect_result = $expect_result . @, @
#$expect_result = $expect_result . 0}
#print expect_result----> $expect_result
print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ctb_column, topic_ctb_function, topic_ctb_all" -k "group.id:tg2" -t "topic_ctb_column, topic_ctb_function, topic_ctb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb -j 4
system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ctb_column, topic_ctb_function, topic_ctb_all" -k "group.id:tg2" -t "topic_ctb_column, topic_ctb_function, topic_ctb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb -j 4
print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ctb_column, topic_ctb_function, topic_ctb_all" -k "group.id:tg2" -t "topic_ctb_column, topic_ctb_function, topic_ctb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb -j 4
system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ctb_column, topic_ctb_function, topic_ctb_all" -k "group.id:tg2" -t "topic_ctb_column, topic_ctb_function, topic_ctb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb -j 4
print cmd result----> $system_content
if $system_content != success then
return -1
endi
print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ctb_column, topic_ctb_function" -k "group.id:tg1" -t "topic_ctb_function, topic_ctb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb -j 3
system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ctb_column, topic_ctb_function" -k "group.id:tg1" -t "topic_ctb_function, topic_ctb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb -j 3
print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ctb_column, topic_ctb_function" -k "group.id:tg1" -t "topic_ctb_function, topic_ctb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb -j 3
system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ctb_column, topic_ctb_function" -k "group.id:tg1" -t "topic_ctb_function, topic_ctb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromCtb -j 3
print cmd result----> $system_content
if $system_content != success then
return -1
endi
print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ntb_column, topic_ntb_function, topic_ntb_all" -k "group.id:tg2" -t "topic_ntb_column, topic_ntb_function, topic_ntb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromNtb -j 4
system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ntb_column, topic_ntb_function, topic_ntb_all" -k "group.id:tg2" -t "topic_ntb_column, topic_ntb_function, topic_ntb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromNtb -j 4
print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ntb_column, topic_ntb_function, topic_ntb_all" -k "group.id:tg2" -t "topic_ntb_column, topic_ntb_function, topic_ntb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromNtb -j 4
system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ntb_column, topic_ntb_function, topic_ntb_all" -k "group.id:tg2" -t "topic_ntb_column, topic_ntb_function, topic_ntb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromNtb -j 4
print cmd result----> $system_content
if $system_content != success then
return -1
endi
print cmd===> system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ntb_column, topic_ntb_function" -k "group.id:tg1" -t "topic_ntb_function, topic_ntb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromNtb -j 3
system_content
../../debug/tests/test/c/tmq_sim -c ../../sim/tsim/
cfg -d $dbNamme -t "topic_ntb_column, topic_ntb_function" -k "group.id:tg1" -t "topic_ntb_function, topic_ntb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromNtb -j 3
print cmd===> system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ntb_column, topic_ntb_function" -k "group.id:tg1" -t "topic_ntb_function, topic_ntb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromNtb -j 3
system_content
$tmq_sim -c $tsim_
cfg -d $dbNamme -t "topic_ntb_column, topic_ntb_function" -k "group.id:tg1" -t "topic_ntb_function, topic_ntb_all" -k "group.id:tg2" -y $consumeDelay -m $expectMsgCntFromNtb -j 3
print cmd result----> $system_content
if $system_content != success then
return -1
...
...
tests/test/c/CMakeLists.txt
浏览文件 @
97a373fa
add_executable
(
create_table create_table.c
)
add_executable
(
tmq_
demo
tmqDemo.c
)
add_executable
(
tmq_
sim
tmqDemo.c
)
add_executable
(
tmq_sim tmqSim.c
)
target_link_libraries
(
create_table
...
...
@@ -9,7 +9,7 @@ target_link_libraries(
PUBLIC os
)
target_link_libraries
(
tmq_
demo
tmq_
sim
PUBLIC taos
PUBLIC util
PUBLIC common
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录