Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
慢慢CG
TDengine
提交
943c6183
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看板
未验证
提交
943c6183
编写于
9月 29, 2020
作者:
S
Shengliang Guan
提交者:
GitHub
9月 29, 2020
浏览文件
操作
浏览文件
下载
差异文件
Merge pull request #3726 from paopaol/fix/compile-arm
fix cross compile failed in arm32
上级
64ebb7ac
f7c06f24
变更
3
隐藏空白更改
内联
并排
Showing
3 changed file
with
13 addition
and
11 deletion
+13
-11
src/client/src/tscFunctionImpl.c
src/client/src/tscFunctionImpl.c
+6
-6
src/common/src/ttypes.c
src/common/src/ttypes.c
+5
-5
src/os/inc/osDir.h
src/os/inc/osDir.h
+2
-0
未找到文件。
src/client/src/tscFunctionImpl.c
浏览文件 @
943c6183
...
...
@@ -525,7 +525,7 @@ static void do_sum(SQLFunctionCtx *pCtx) {
*
retVal
+=
pCtx
->
preAggVals
.
statis
.
sum
;
}
else
if
(
pCtx
->
inputType
==
TSDB_DATA_TYPE_DOUBLE
||
pCtx
->
inputType
==
TSDB_DATA_TYPE_FLOAT
)
{
double
*
retVal
=
(
double
*
)
pCtx
->
aOutputBuf
;
*
retVal
+=
GET_DOUBLE_VAL
(
&
(
pCtx
->
preAggVals
.
statis
.
sum
));
*
retVal
+=
GET_DOUBLE_VAL
(
(
const
char
*
)
&
(
pCtx
->
preAggVals
.
statis
.
sum
));
}
}
else
{
// computing based on the true data block
void
*
pData
=
GET_INPUT_CHAR
(
pCtx
);
...
...
@@ -768,7 +768,7 @@ static void avg_function(SQLFunctionCtx *pCtx) {
if
(
pCtx
->
inputType
>=
TSDB_DATA_TYPE_TINYINT
&&
pCtx
->
inputType
<=
TSDB_DATA_TYPE_BIGINT
)
{
*
pVal
+=
pCtx
->
preAggVals
.
statis
.
sum
;
}
else
if
(
pCtx
->
inputType
==
TSDB_DATA_TYPE_DOUBLE
||
pCtx
->
inputType
==
TSDB_DATA_TYPE_FLOAT
)
{
*
pVal
+=
GET_DOUBLE_VAL
(
&
(
pCtx
->
preAggVals
.
statis
.
sum
));
*
pVal
+=
GET_DOUBLE_VAL
(
(
const
char
*
)
&
(
pCtx
->
preAggVals
.
statis
.
sum
));
}
}
else
{
void
*
pData
=
GET_INPUT_CHAR
(
pCtx
);
...
...
@@ -3516,12 +3516,12 @@ static void spread_function(SQLFunctionCtx *pCtx) {
pInfo
->
max
=
(
double
)
pCtx
->
preAggVals
.
statis
.
max
;
}
}
else
if
(
pCtx
->
inputType
==
TSDB_DATA_TYPE_DOUBLE
||
pCtx
->
inputType
==
TSDB_DATA_TYPE_FLOAT
)
{
if
(
pInfo
->
min
>
GET_DOUBLE_VAL
(
&
(
pCtx
->
preAggVals
.
statis
.
min
)))
{
pInfo
->
min
=
GET_DOUBLE_VAL
(
&
(
pCtx
->
preAggVals
.
statis
.
min
));
if
(
pInfo
->
min
>
GET_DOUBLE_VAL
(
(
const
char
*
)
&
(
pCtx
->
preAggVals
.
statis
.
min
)))
{
pInfo
->
min
=
GET_DOUBLE_VAL
(
(
const
char
*
)
&
(
pCtx
->
preAggVals
.
statis
.
min
));
}
if
(
pInfo
->
max
<
GET_DOUBLE_VAL
(
&
(
pCtx
->
preAggVals
.
statis
.
max
)))
{
pInfo
->
max
=
GET_DOUBLE_VAL
(
&
(
pCtx
->
preAggVals
.
statis
.
max
));
if
(
pInfo
->
max
<
GET_DOUBLE_VAL
(
(
const
char
*
)
&
(
pCtx
->
preAggVals
.
statis
.
max
)))
{
pInfo
->
max
=
GET_DOUBLE_VAL
(
(
const
char
*
)
&
(
pCtx
->
preAggVals
.
statis
.
max
));
}
}
...
...
src/common/src/ttypes.c
浏览文件 @
943c6183
...
...
@@ -219,7 +219,7 @@ static void getStatics_f(const TSKEY *primaryKey, const void *pData, int32_t num
}
float
fv
=
0
;
fv
=
GET_FLOAT_VAL
(
&
(
data
[
i
]));
fv
=
GET_FLOAT_VAL
(
(
const
char
*
)
&
(
data
[
i
]));
dsum
+=
fv
;
if
(
fmin
>
fv
)
{
fmin
=
fv
;
...
...
@@ -233,7 +233,7 @@ static void getStatics_f(const TSKEY *primaryKey, const void *pData, int32_t num
}
double
csum
=
0
;
csum
=
GET_DOUBLE_VAL
(
sum
);
csum
=
GET_DOUBLE_VAL
(
(
const
char
*
)
sum
);
csum
+=
dsum
;
SET_DOUBLE_VAL
(
sum
,
csum
);
...
...
@@ -259,7 +259,7 @@ static void getStatics_d(const TSKEY *primaryKey, const void *pData, int32_t num
}
double
dv
=
0
;
dv
=
GET_DOUBLE_VAL
(
&
(
data
[
i
]));
dv
=
GET_DOUBLE_VAL
(
(
const
char
*
)
&
(
data
[
i
]));
dsum
+=
dv
;
if
(
dmin
>
dv
)
{
dmin
=
dv
;
...
...
@@ -273,7 +273,7 @@ static void getStatics_d(const TSKEY *primaryKey, const void *pData, int32_t num
}
double
csum
=
0
;
csum
=
GET_DOUBLE_VAL
(
sum
);
csum
=
GET_DOUBLE_VAL
(
(
const
char
*
)
sum
);
csum
+=
dsum
;
SET_DOUBLE_PTR
(
sum
,
&
csum
);
...
...
@@ -550,4 +550,4 @@ void tsDataSwap(void *pLeft, void *pRight, int32_t type, int32_t size, void* buf
break
;
}
}
}
\ No newline at end of file
}
src/os/inc/osDir.h
浏览文件 @
943c6183
...
...
@@ -20,6 +20,8 @@
extern
"C"
{
#endif
#include <sys/types.h>
// TAOS_OS_FUNC_DIR
void
taosRemoveDir
(
char
*
rootDir
);
int
taosMkDir
(
const
char
*
pathname
,
mode_t
mode
);
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录