Merge pull request #8573 from zhongwencool/copy-of-main-v4.4
sync main-v4.3 to main-v4.4
This commit is contained in:
commit
955e92cba1
|
@ -127,11 +127,12 @@ node_query(Node, Params, {Tab, QsSchema}, QueryFun, SortFun) ->
|
||||||
true -> Meta#{count => count(Tab), hasnext => length(Rows) > Limit};
|
true -> Meta#{count => count(Tab), hasnext => length(Rows) > Limit};
|
||||||
_ -> Meta#{count => -1, hasnext => length(Rows) > Limit}
|
_ -> Meta#{count => -1, hasnext => length(Rows) > Limit}
|
||||||
end,
|
end,
|
||||||
NRows = case SortFun of
|
Data0 = lists:sublist(Rows, Limit),
|
||||||
undefined -> Rows;
|
Data = case SortFun of
|
||||||
_ -> lists:sort(SortFun, Rows)
|
undefined -> Data0;
|
||||||
|
_ -> lists:sort(SortFun, Data0)
|
||||||
end,
|
end,
|
||||||
#{meta => NMeta, data => lists:sublist(NRows, Limit)}.
|
#{meta => NMeta, data => Data}.
|
||||||
|
|
||||||
%% @private
|
%% @private
|
||||||
do_query(Node, Qs, {M,F}, Start, Limit) when Node =:= node() ->
|
do_query(Node, Qs, {M,F}, Start, Limit) when Node =:= node() ->
|
||||||
|
|
5
bin/emqx
5
bin/emqx
|
@ -879,7 +879,12 @@ case "$1" in
|
||||||
;;
|
;;
|
||||||
check_conf)
|
check_conf)
|
||||||
generate_config "check_only"
|
generate_config "check_only"
|
||||||
|
INCLUDE_CONFS=$(< "$RUNNER_ETC_DIR/emqx.conf" grep "include" |awk '{print $2}'|xargs)
|
||||||
|
if [ "$INCLUDE_CONFS" == "" ]; then
|
||||||
echo "$RUNNER_ETC_DIR/emqx.conf is ok"
|
echo "$RUNNER_ETC_DIR/emqx.conf is ok"
|
||||||
|
else
|
||||||
|
echo "$RUNNER_ETC_DIR/emqx.conf(include $INCLUDE_CONFS) is ok"
|
||||||
|
fi
|
||||||
;;
|
;;
|
||||||
|
|
||||||
ctl)
|
ctl)
|
||||||
|
|
|
@ -29,7 +29,7 @@
|
||||||
|
|
||||||
-ifndef(EMQX_ENTERPRISE).
|
-ifndef(EMQX_ENTERPRISE).
|
||||||
|
|
||||||
-define(EMQX_RELEASE, {opensource, "4.4.6-beta.3"}).
|
-define(EMQX_RELEASE, {opensource, "4.4.6-beta.4"}).
|
||||||
|
|
||||||
-else.
|
-else.
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue