yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity
12,722 Commits 393 Branches 684 Tags 74 MiB
Commit Graph

12722 Commits

Author SHA1 Message Date
Zaiming (Stone) Shi 90ca08a34e
Merge pull request #7216 from zmstone/chore-refine-boot-log 
chore(bin/emqx): refine boot message
 2022-03-05 09:09:55 +01:00
Zaiming (Stone) Shi 68fb80fc29 chore(bin/emqx): refine boot message 2022-03-04 21:02:54 +01:00
Thales Macedo Garitezi 3e08282ffb
chore: improve formatting 
Without `~0p`, had some weird indentation while printing
 2022-03-04 15:22:33 -03:00
Thales Macedo Garitezi 6905147093
style: fix nls at eof 2022-03-04 11:18:28 -03:00
Thales Macedo Garitezi e76f67e985
style: please elvis checks 2022-03-04 11:14:13 -03:00
Thales Macedo Garitezi 0c76b6cf4d
fix(congestion): fix congestion message formatting 
It seems that the `~ts` in the format string does not handle maps,
which results in a crash when trying to format the congestion message.

```erlang
28> io_lib:format("~ts", [#{}]).
** exception error: bad argument
     in function  io_lib:format/2
        called as io_lib:format("~ts",[#{}])
```

Example:

```
2022-03-04T12:43:26.900609+00:00 [warning] '$kind': unclean_terminate, clientid: 192.168.2.116_bench_sub_11412_1782328074, context: badarg, exception: error, line: 582, mfa: emqx_connection:terminate/2, peername: 192.168.2.116:47358, stacktrace: [{io_lib,format,["connection congested: ~ts",[#{buffer => 4096,clientid => <<"192.168.2.116_bench_sub_11412_1782328074">>,conn_state => disconnected,connected_at => 1646397524470,high_msgq_watermark => 8192,high_watermark => 1048576,memory => 57064,message_queue_len => 20,peername => <<"192.168.2.116:47358">>,pid => <<"<0.259.28>">>,proto_name => <<"MQTT">>,proto_ver => 5,recbuf => 4096,recv_cnt => 2,recv_oct => 81,reductions => 267523,send_cnt => 333,send_oct => 149869,send_pend => 128,sndbuf => 332800,sockname => <<"10.10.1.13:1883">>,socktype => tcp,username => undefined}]],[{file,"io_lib.erl"},{line,187}]},{emqx_congestion,do_cancel_alarm_congestion,4,[{file,"/emqx/apps/emqx/src/emqx_congestion.erl"},{line,88}]},{lists,foreach,2,[{file,"lists.erl"},{line,1342}]},{emqx_connection,terminate,2,[{file,"/emqx/apps/emqx/src/emqx_connection.erl"},{line,576}]},{proc_lib,wake_up,3,[{file,"proc_lib.erl"},{line,236}]}]
```
 2022-03-04 11:00:49 -03:00
lafirest e298ff9dca
Merge pull request #7206 from lafirest/coverage/retainer 
test(retainer): improve test coverage from 63% to 92%
 2022-03-04 16:34:20 +08:00
lafirest c6385762c6 test(retainer): improve test coverage from 63% to 92% 2022-03-04 15:24:08 +08:00
Zhongwen Deng 6ff2db6180 fix: elvis warning 2022-03-04 15:10:10 +08:00
Zhongwen Deng 153e1bcb91 fix: pre_update_config is executed one more time than expected 2022-03-04 14:43:51 +08:00
JimMoen b5c011d4a5
Merge pull request #7203 from JimMoen/mgmt_query_refactor 
refactor(mgmt): `Params` => `QString`, `QsScheam` => `QSchema`
 2022-03-04 12:24:38 +08:00
JimMoen f25da61f39 refactor(mgmt): `Params` => `QString`, `QsScheam` => `QSchema` 2022-03-04 11:14:03 +08:00
JimMoen f8073002b6 fix(mgmt): better desc for fuzzy field 2022-03-04 10:06:36 +08:00
JimMoen fab9ad91de fix(schema): nullable => required 2022-03-04 10:06:36 +08:00
Rory Z 5f80ac54c2
Merge pull request #7116 from Rory-Z/ci/update-cross-build 
ci(cross build): splitting cross builds and upload assets
 2022-03-04 09:19:56 +08:00
Zhongwen Deng e2f386383d fix: replace local ref by remote ref 2022-03-04 09:13:56 +08:00
Thales Macedo Garitezi f92f909c84
Merge pull request #7200 from thalesmg/fix-mix-make 
fix(elixir): add common target dependencies for `%-elixir-pkg`
 2022-03-03 14:57:29 -03:00
Thales Macedo Garitezi 1f59154dca
fix(elixir): add common target dependencies for `%-elixir-pkg` 
For installing Hex/Rebar and downloading dependencies on a fresh
clone.
 2022-03-03 13:56:30 -03:00
Zhongwen Deng 71d20d153b fix: replace deep_merge with merge. 2022-03-03 22:52:46 +08:00
Zhongwen Deng 4dfcb90b16 fix: get_roots broken 2022-03-03 20:31:30 +08:00
Thales Macedo Garitezi f3e7ec43dd
Merge pull request #7190 from thalesmg/fix-typos 
docs: fix a few typos
 2022-03-03 08:57:51 -03:00
Zhongwen Deng a862eb0252 chore: add more test for emqx_config_handler 2022-03-03 17:39:32 +08:00
Ilya Averyanov 4b19fb575a
Merge pull request #7187 from savonarola/mongo-no-double-pooling 
chore(mongodb): do not use mongodb internal pool
 2022-03-03 11:47:41 +03:00
lafirest c0df5cd80f
Merge pull request #7193 from lafirest/fix/retainer_api 
fix(retainer): fix config lookup error
 2022-03-03 10:58:35 +08:00
JianBo He 7ba1db759e
Merge pull request #7182 from HJianBo/mqttsn-replay-register 2022-03-03 10:55:45 +08:00
lafirest be61d918bf fix(retainer): fix config lookup error 2022-03-03 10:43:08 +08:00
JianBo He cc7db4a104
Merge pull request #7183 from lafirest/refactor/retainer_api 
refactor(retainer): refactor the api use swagger
 2022-03-03 09:55:13 +08:00
Zaiming (Stone) Shi 0f93c23936
Merge pull request #7186 from zmstone/structured-build-info 
build: more structured build info
 2022-03-02 23:58:08 +01:00
Zaiming (Stone) Shi 72dbfeee14
Merge pull request #7191 from zmstone/build-update-builder-to-5.0-8 
Build update builder to 5.0 8
 2022-03-02 23:57:49 +01:00
Zaiming (Stone) Shi e6495f4300 ci: upgrade emqx-builder to 5.0-8:1.13.3-24.2.1-1 2022-03-02 21:57:26 +01:00
Zaiming (Stone) Shi d1cf1cca67 ci: add debian11 2022-03-02 21:56:10 +01:00
Zaiming (Stone) Shi 4e64010a3b build: more structured build info 2022-03-02 21:22:03 +01:00
Zaiming (Stone) Shi 18abf7bd1e
Merge pull request #7188 from thalesmg/bugfix-exclude-gpb-from-build 
fix(mix): do not include gpb in the release
 2022-03-02 21:21:48 +01:00
Thales Macedo Garitezi 4aa15c1e78
docs: fix a few typos 2022-03-02 16:21:07 -03:00
Thales Macedo Garitezi c9058121a1
chore: add gpb check to elixir build 2022-03-02 14:57:39 -03:00
Thales Macedo Garitezi e69ca61d49
fix(mix): do not include gpb in the release 
Since `gpb` is a GPL compile-time-only dependency, we should not
include it in the release.

Note that adding `gpb: :none` to the release applications list *will*
make Mix include its files *and* reference them in the startup +
release scripts...
 2022-03-02 14:49:06 -03:00
Ilya Averyanov a0cd877669 chore(mongodb): do not use mongodb internal pool 2022-03-02 16:26:39 +03:00
JianBo He 61251be20b
Merge pull request #7185 from lafirest/fix/retainer_update 
fix(retainer): trap exit message
 2022-03-02 18:16:06 +08:00
JianBo He 4460373cd5
Merge pull request #7184 from lafirest/fix/slow_subs_state 
fix(slow_subs): change enable to false when unload
 2022-03-02 18:11:36 +08:00
lafirest 4a9ba7f8b8 fix(retainer): trap exit message 2022-03-02 17:06:48 +08:00
lafirest d7321e8b77 fix(slow_subs): change enable to false when unload 2022-03-02 16:54:25 +08:00
JianBo He 63ef00a208 fix(gw): add takeover_session/3 for cm_proto_v1 2022-03-02 16:43:53 +08:00
lafirest ddb7786d30 refactor(retainer): refactor the api use swagger 2022-03-02 16:37:54 +08:00
JianBo He 7ade24b344 feat(mqttsn): support to register unknown topic-name to the client 2022-03-02 14:58:43 +08:00
JianBo He 5b1ba335cb chore(session): add obtain_next_pkt_id/1 
In the current implement, mqtt-sn gateway is using the emqx_session as
its session structure. We need a method to get a pkt_id for sending like
REGISTER related messages
 2022-03-02 14:58:43 +08:00
JianBo He ddf3585b22 refactor(gw): support session takeover 2022-03-02 14:58:43 +08:00
JianBo He 123b667eb0
Merge pull request #7128 from lafirest/refactor/retainer_flow_control 
refactor(emqx_retainer): use hierarchical limiter for the flow control
 2022-03-02 14:46:56 +08:00
JianBo He 365e0c7f34
Merge pull request #7180 from HJianBo/update-dashboard-vsn 
Update dashboard vsn
 2022-03-02 14:12:44 +08:00
lafirest 9bdebabdbc fix(retainer): fix/add some comment 2022-03-02 11:34:19 +08:00
JianBo He 612611c954 chore: update dashboard vsn to 0.21.0 2022-03-02 10:48:39 +08:00