4adc914372
feat: Support set keepalive via queryString & Body HTTP API.
2022-03-15 10:40:01 +08:00
32fac8b67b
Merge pull request #7299 from mononym/fix-typo-in-log-message
...
fix: typo in log message
2022-03-14 12:55:04 +01:00
55eddfa16c
fix: typo in log message
2022-03-14 10:18:18 +01:00
8ea84e4a01
chore(appup): update appup.src
2022-03-10 12:12:42 +08:00
c0b688b51f
feat(frame): utf-8 string check in `strict_mode`
2022-03-10 11:23:44 +08:00
27617539f1
fix(appup): adjust update-appup.sh for 4.4.
2022-03-08 19:31:21 +01:00
571456b3c4
Merge remote-tracking branch 'origin/main-v4.3' into main-v4.4
2022-03-08 18:59:38 +01:00
d8e29f19cb
refactor(appup): always generate appup from script
2022-03-08 13:24:54 +01:00
fbd70b02bc
fix: override plugins list
2022-03-07 10:32:49 +08:00
278fa96bc1
fix(plugins): usort plugin list
2022-03-04 10:46:09 +08:00
a94dc87c34
chore: add missed appup instructions
2022-03-03 11:20:50 +08:00
f0be91b7fd
Merge remote-tracking branch 'ce/main-v4.3' into merge-main-v4.3-into-v4.4
2022-03-03 11:13:45 +08:00
77e3c1d3ac
feat(relup): support providing 'Extra' parameter from appup.src
2022-03-02 10:48:10 +08:00
41afbd2b13
refactor(relup): don't collect relvsn -> appvsn mappings
2022-03-01 23:10:11 +08:00
cca9e52c9a
chore(appup): add missing appup instructions
2022-03-01 11:41:52 +01:00
7698ad7c4b
chore(relup): print more info after release upgrade complete
2022-03-01 17:15:19 +08:00
b1816a6647
fix: add uptime/1 for CT test.
2022-03-01 14:19:37 +08:00
ed41a66c6e
fix: rpc get node info maybe crash when emqx_sys process is not start yet.
2022-03-01 14:19:35 +08:00
a7791b6c58
fix(relup): download to 4.4.0 failed with error bad_lib_vsn
2022-03-01 11:33:49 +08:00
bcd56d3db2
Merge branch 'main-v4.4' into inject_relup_instructions_v4.4
2022-02-28 19:13:55 +08:00
28bd2fcfa4
fix(relup): release upgrade failed with {bad_lib_vsn,emqx,"4.4.2"}
2022-02-27 20:04:21 +08:00
17440b2b53
fix(relup): add module emqx_relup
2022-02-27 10:25:57 +08:00
cc8168ba23
chore(appup): commit script updated emqx.app.src
2022-02-26 16:45:55 +01:00
c157a16907
Merge remote-tracking branch 'origin/main-v4.3' into main-v4.4
2022-02-26 01:05:06 +01:00
cf1cc7e9db
chore(appup): update appup files
2022-02-24 17:14:47 -03:00
6b93127ecb
fix(sys_mon): guard before calling `erlang:port_info`
...
Port of #7108 .
Sometimes, the `emqx_sys_mon:procinfo/1` might be called with
something that is not a port, like `[]`. Not sure on the conditions
for this to happen.
```
2022-02-18T20:05:02.671592+00:00 [error] Generic server emqx_sys_mon terminating. Reason: {badarg,[{erlang,port_info,[[]],[{error_info,#{module => erl_erts_errors}}]},{emqx_sys_mon,portinfo,1,[{file,"/emqx/apps/emqx/src/emqx_sys_mon.erl"},{line,205}]},{emqx_sys_mon,'-handle_info/2-fun-5-',2,[{file,"/emqx/apps/emqx/src/emqx_sys_mon.erl"},{line,150}]},{emqx_sys_mon,suppress,3,[{file,"/emqx/apps/emqx/src/emqx_sys_mon.erl"},{line,184}]},{gen_server,try_dispatch,4,[{file,"gen_server.erl"},{line,695}]},{gen_server,handle_msg,6,[{file,"gen_server.erl"},{line,771}]},{proc_lib,wake_up,3,[{file,"proc_lib.erl"},{line,236}]}]}. Last message: {monitor,<0.7796.0>,busy_dist_port,[]}. State: #{events => [{busy_dist_port,#Port<0.127>}],timer => #Ref<0.2758388682.1853620226.133920>}.
```
2022-02-24 16:28:35 -03:00
d622eb848f
refactor(cm): rename takeover -> request_stepdown
...
see: https://github.com/emqx/emqx/pull/7026#pullrequestreview-891954135
2022-02-24 14:43:46 +08:00
4673ca43a0
chore(emqx): update appup.src
2022-02-24 11:51:00 +08:00
bfd0fd9019
refactor(cm): rename call_or_kill to takeover
2022-02-24 11:50:57 +08:00
6dd0b49dd2
feat(cm): force shutdown of processe that cannot answer takeover event
...
Related PR: #6030
2022-02-24 09:53:17 +08:00
372ea29d96
fix: upgrade code, system mem false alarm
2022-02-23 09:38:54 +01:00
841d6d5036
fix: system mem false alarm
2022-02-23 09:14:28 +01:00
6b720286c6
chore: fix bad sytanx for emqx.appup.src
2022-02-22 11:55:20 +08:00
521bdd20b4
Merge remote-tracking branch 'ce/main-v4.3' into merge-main-v4.3-into-v4.4
2022-02-22 11:43:46 +08:00
a2d8405f99
chore: update appup.src
2022-02-22 10:30:52 +08:00
b802bcb6fc
refactor(exproto): pre-register the anonymous client
2022-02-22 10:23:16 +08:00
31b006a0d1
fix(frame): `server_keepalive` only for MQTT v5.0
2022-02-21 18:46:53 +08:00
557c52dd8a
chore(codestyle): remove Elvis
2022-02-18 20:35:19 +03:00
a42927f173
chore(emqx): fix mutiply defined module in emqx.appup.src
2022-02-16 13:46:38 +08:00
3f31df2297
docs: add comment explaining application and release vsn discrepancy
2022-02-14 13:18:53 -03:00
acf3b8cbe9
chore(emqx): update appup
2022-02-14 13:18:07 -03:00
8302cac329
fix(channel): wrong case clause when alias is inexistent
...
Fixes #6978 .
2022-02-14 13:18:07 -03:00
a88dd4aaa5
Merge tag 'v4.3.12' into main-v4.4
2022-02-14 19:37:59 +08:00
e9f1af8098
feat(ws): appup remove old
2022-02-11 11:16:31 +08:00
c6bafd5131
feat(ws): appup
2022-02-11 11:04:14 +08:00
0bb01210ae
feat(ws): more client metrics
2022-02-11 10:50:46 +08:00
646ef25d96
Merge branch 'main-v4.3' into fix-ctl-print-43
2022-02-10 19:13:29 +08:00
1392fa0b1d
Merge remote-tracking branch 'origin/main-v4.3' into merge-v4.3-to-v4.4
2022-02-10 11:25:17 +01:00
8cf268dffb
fix: emqx_message:format/1 failed on undefined message id
2022-02-10 12:43:39 +08:00
038136fc83
fix(appup): update appup file for module emqx_message
2022-02-10 11:04:25 +08:00
3b5b4b99ed
fix(log): format the message id to hexstring before printing
2022-02-10 09:47:33 +08:00
e053700441
style: please elvis checks
2022-02-09 11:02:05 -03:00
5e223ac64f
chore(appup): update appup files
2022-02-09 09:54:39 -03:00
b968d4c416
fix(ctl): fix formatting when printing messages without arguments (4.3)
...
Without passing an empty argument list to `emqx_ctl:print`, formatting
instructions like `~n` are being printed literally.
```
Ignore.~nJoin the cluster successfully.~nCluster status: #{running_nodes =>
['emqx@emqx-0.int.thalesmg','emqx@emqx-1.int.thalesmg',
'emqx@emqx-2.int.thalesmg','emqx@emqx-3.int.thalesmg',
'emqx@emqx-4.int.thalesmg'],
stopped_nodes => []}
```
2022-02-09 09:36:27 -03:00
31a68f4627
fix(appup): No such module: emqx_mod_sup
2022-01-28 14:33:18 +08:00
0500c475cf
fix(appup): Multiply defined module: emqx_slow_subs
2022-01-28 12:22:29 +08:00
d15fd95ad4
fix(appup): Multiply defined module: emqx_session
2022-01-28 11:54:10 +08:00
791b22f151
Merge branch 'main-v4.4' into copy_of_main-v4.3
2022-01-27 18:46:49 +08:00
6319c3402f
fix(appup): Multiply defined module: emqx_metrics
...
make emqx-zip failed:
```
===> Error generating relup:
Multiply defined module: emqx_metrics
```
2022-01-27 18:01:17 +08:00
e2dec09b0d
fix(alarm): watermark replace >= =< with > <
2022-01-27 11:59:48 +08:00
9d633507f5
fix(appup): add emqx.erl to appup.src
2022-01-26 14:32:00 +08:00
16a5eb4493
Merge remote-tracking branch 'origin/main-v4.3' into merge-v4.3-to-v4.4
2022-01-25 22:29:01 +01:00
2eae1088ac
fix(metrics): client metrics key name
2022-01-25 17:11:22 +08:00
78f294cda2
fix: sys_mem alarm is not triggered after reboot.
2022-01-25 16:12:17 +08:00
0fadc85c15
Merge pull request #6841 from lafirest/fix/slow_subs_qos2
...
fix(emqx_slow_subs): fix qos2 pattern matching error
2022-01-24 17:35:25 +08:00
954e85bb73
fix(emqx_slow_subs): fix qos2 pattern matching error
2022-01-24 17:03:37 +08:00
b635d56aec
Merge branch 'main-v4.3' into merge-main-v4.3-into-v4.4
2022-01-21 16:27:56 +08:00
14538e5f6d
chore(emqx): update appup.src
2022-01-21 14:24:01 +08:00
c56be7dcd7
refactor(metrics): more clear for acl metrics
...
For clarity in the meaning of metrics, we put `client.acl.allow`,
`client.acl.deny` into emqx_metrics and increased after a acl checking
returned.
2022-01-21 11:21:25 +08:00
e82c73988b
Merge pull request #6790 from lafirest/fix/slow_subs
...
fix(emqx_slow_subs): add ClientInfo into the args of the delivery.com…
2022-01-19 15:54:44 +08:00
46f86204c0
fix(emqx_slow_subs): add ClientInfo into the args of the delivery.completed hook
2022-01-19 14:02:30 +08:00
24f8c353dc
Merge branch 'main-v4.4' into sync-from-4.3-to-4.4
2022-01-19 11:24:57 +08:00
6414f7e55a
fix(emqx_slow_subs): add compatibility for old code
2022-01-19 09:50:31 +08:00
696acbfc5c
fix(emqx_slow_subs): change on_publish_completed to on_delivery_completed
2022-01-19 09:50:31 +08:00
0a85e71e09
fix(appup): add slow subs into appup file
2022-01-19 09:50:31 +08:00
44fe882f14
refactor(emqx_slow_subs): refactor slow subs
2022-01-19 09:50:31 +08:00
040d04c9fb
fix(test): for paho qos3
2022-01-18 18:46:03 +08:00
deada0ea44
chore(appup): update appup file and esockd version
2022-01-18 16:26:01 +08:00
eb003e3305
feat(emqx_limiter): add support for update overall limiter
2022-01-18 14:06:26 +08:00
578199ad3a
fix: client metrics count with qos
2022-01-18 10:38:06 +08:00
6278951d57
fix: code style
2022-01-17 15:43:59 +08:00
5397d80680
feat(metrics): session metrics & api format
2022-01-17 15:15:00 +08:00
1ce77de080
feat(metrics): client metrics
2022-01-17 14:51:46 +08:00
1daf2e4fc9
fix(appup): add emqx_alarm into appup file
2022-01-14 15:57:50 +08:00
2da30465de
fix(merge): solve conflicts when merge 4.4 to 4.3
2022-01-14 15:45:33 +08:00
729ab6f60d
Merge branch 'main-v4.3' into auth-mnesia-default-import
2022-01-14 11:29:41 +08:00
ab18020eea
Merge pull request #6736 from zhongwencool/support-license-alarm-type
...
chore(alarm): support license alarm type
2022-01-14 11:19:48 +08:00
9a17bcfcc9
chore(appup): update eqmx.appup.src
2022-01-14 11:03:27 +08:00
7c0d70cfde
feat(license): license expriy early alarm.
2022-01-14 00:31:56 +08:00
4abcab8d52
fix(appup): update appup files for emqx,emqx_sn,rule_engine
2022-01-13 18:37:22 +08:00
c6a571c207
chore(alarm): support license alarm type
2022-01-13 17:41:16 +08:00
b3862fb283
chore: fix the app vsn and appup.src
2022-01-13 17:30:20 +08:00
a6408cee4f
fix(session): update testcases for emqx_session
2022-01-13 15:28:18 +08:00
9f7f5070b2
fix(channel): update the calls to emqx_session APIs
2022-01-13 13:33:27 +08:00
217acc0154
feat(rule): add new event 'delivery_dropped'
2022-01-12 20:11:08 +08:00
9434c0fa6c
feat(hook): new emqx hook 'delivery.dropped'
2022-01-12 18:34:20 +08:00
b297388c20
Merge branch 'main-v4.3' into merge-main-v4.3-into-v4.4
2022-01-11 10:03:28 +08:00
02dc216173
chore: update appup.src
2021-12-23 08:48:24 +08:00
cb8a3725b4
fix: disconnect the client due to exceed receive-maximum packets
...
As described in the 5.0 specification, we should disconnect clients that
exceed the receive-maximum limit.
> If it receives more than Receive Maximum QoS 1 and QoS 2 PUBLISH packets
where it has not sent a PUBACK or PUBCOMP in response, **the Server uses a
DISCONNECT packet with Reason Code 0x9**
fix : #6447
2021-12-23 08:48:24 +08:00
799aabdd04
chore(emqx): bump emqx to 4.4.0
2021-12-20 15:12:09 +08:00
c1cbf39552
fix(appup): add missing beams to emqx.appup.src
...
also re-formated emqx_sn.appup.src
2021-12-17 13:41:25 +01:00
b592565363
fix: trace not work if client is utf8
2021-12-15 09:53:46 +08:00
d76159d543
Merge remote-tracking branch 'emqx/main-v4.3' into sync-from-v4.3
2021-12-13 18:46:23 +08:00
24060285c5
chore(appup): update appup.src
2021-12-10 18:08:47 +08:00
3ecc79e1bc
test(frame): test packet proxy_protocol config disabled
2021-12-10 18:08:47 +08:00
b9acf94fd7
feat(frame): better log for proxy_protocol config disabled
2021-12-10 18:08:47 +08:00
2ed5e01054
Merge branch 'main-v4.4' into sync-from-v4.3
2021-12-09 18:49:38 +08:00
d435f1211e
fix(live_conn): fix live connection count on race condition
...
When multiple clients try to connect concurrently using the same
client ID, they all call `emqx_channel:ensure_connected`, increasing
the live connection count, but only one will successfully acquire the
lock for that client ID. This means that all other clients that
increased the live connection count will not get to call neither
`emqx_channel:ensure_disconnected` nor be monitored for `DOWN`
messages, effectively causing a count leak.
By moving the increment to `emqx_cm:register_channel`, which is only
called inside the lock, we can remove this leakage.
Also, during the handling of `DOWN` messages, we now iterate over all
channel PIDs returned by `eqmx_misc:drain_down`, since it could be
that one or more PIDs are not contained in the `pmon` state.
2021-12-08 10:33:57 -03:00
c2cc3c78f1
Merge pull request #6395 from zhongwencool/sync-from-4.3
...
Sync from 4.3
2021-12-08 10:57:55 +01:00
e651becd99
fix(emqx_slow_subs): fix threshold related bugs
...
1. limit the interval between calling hooks
2. improve the code of update threshold
2021-12-08 15:05:39 +08:00
2c2145dfe6
Merge branch 'main-v4.3' into sync-from-4.3
2021-12-07 23:20:01 +08:00
2348e612fa
fix(emqx_channel): fix race condition in session takeover
...
Sessions must not enqueue messages when another process is taking over
the client id, since it already passed on the message queue in the
session state.
Without this fix, messages arriving after `{takeover, 'begin'} to a
channel with no connection (i.e., a persistent session) would be lost.
2021-12-07 16:05:49 +01:00
14aa408b5e
style: make elvis happy
2021-12-07 14:17:33 +08:00
c5e28bd32b
fix(vm): add literal_alloc memory calculation
2021-12-07 14:17:33 +08:00
3f49e3186c
fix(emqx_slow_subs): add default threshold macro
2021-12-06 17:22:36 +08:00
48f8c735ea
feat(emqx_slow_subs): add dyanamic threshold
2021-12-03 18:11:07 +08:00
ef6f867304
chore(conn): change terminated print to debug level
2021-12-02 18:01:36 +08:00
8dd4d88d5b
fix(emx_slow_updates): fix the error of topk update ( #6312 )
2021-11-26 14:57:25 +08:00
fef3fc27cb
refactor(emqx_slow_subs): refactor use moving average ( #6287 )
...
* refactor(emqx_slow_subs): refactor use moving average
* fix(emqx_slow_subs): change elapsed to latency, and fix some error
* fix(emqx_slow_subs): fix emqx_mgmt_api.erl indent
* fix(emqx_slow_subs): change api name
* fix(emqx_slow_subs): fix and improve some code
* fix(emqx_slow_subs): move clienid filed from latency_stats to session
2021-11-26 10:42:15 +08:00
64ce2eea1c
chore(appup): run ./scripts/update_appup.escript to bump vsns
2021-11-25 12:08:02 -03:00
0260db6640
feat(sys_mon): Add proc_lib:initial_call/1 and current_stacktrace (4.3)
...
(Same as #6289 )
This adds the information from `proc_lib:initial_call/1` and the
current stacktrace from the process info to `emqx_sys_mon:procinfo/1`
to aid in debugging some warnings with no context such as the
following:
```
2021-11-23T12:33:59.387818+00:00 [warning] info: [{old_heap_block_size,45988046},{heap_block_size,22177879},{mbuf_size,0},{stack_size,40},{old_heap_size,22354134},{heap_size,7106339}], line: 130, mfa: emqx_sys_mon:handle_info/2, msg: large_heap, procinfo: [{pid,<0.2667.0>},{memory,579763664},{total_heap_size,68510672},{heap_size,22177879},{stack_size,40},{min_heap_size,233},{initial_call,{proc_lib,init_p,5}},{current_function,{gen,do_call,4}},{registered_name,[]},{status,running},{message_queue_len,360945},{group_leader,<0.1660.0>},{priority,normal},{trap_exit,false},{reductions,16493271},{last_calls,false},{catchlevel,4},{trace,0},{suspending,[]},{sequential_trace_token,[]},{error_handler,error_handler}]
```
2021-11-25 12:08:02 -03:00
2514f474b0
Sync v4.3 to v4.4 ( #6262 )
...
* fix(http): fix duplicate http headers
* chore(appup): add appup.src
* fix(appup): fix multiply defined module in appup
* chore(appup): fix wrong version
* chore(ekka): Bump version to 0.8.1.5
* fix(update_appup): Fix warnings, add support for external repos
* build: use find command's -delete option
* ci: do not sync master branch
* build: ensure openssl11
* build: copy only libcrypto and libtinfo
* fix(trace): handler_id now always return atom
Co-authored-by: zhouzb <zhouzb@emqx.io>
Co-authored-by: k32 <10274441+k32@users.noreply.github.com>
2021-11-23 09:33:20 +08:00
0f52824872
refactor(trace): hash non-printable or too long names
2021-11-22 16:59:17 +01:00
1c64a9d95d
Merge pull request #6251 from zhongwencool/log-trace-api
...
feat: add support ip_address trace options
2021-11-22 16:19:53 +01:00
30fb9dd7ae
fix: name must be printable unicode and len < 256
2021-11-22 22:20:02 +08:00
a91f975dc2
fix: make sure keepalive only 0~65535 ( #6232 )
2021-11-22 18:08:48 +08:00
d76275d17d
feat: add support ip_address trace options
2021-11-22 15:20:24 +08:00
3b25df9b47
fix(appup): fix multiply defined module in appup
2021-11-17 15:18:16 +08:00
f948eb927d
chore(appup): add appup.src
2021-11-17 14:31:37 +08:00
5e3fe6714e
fix(http): fix duplicate http headers
2021-11-17 14:14:12 +08:00
88efc6612d
Merge remote-tracking branch 'origin/main-v4.4' into chore/rename-packages-name
2021-11-16 09:47:13 +01:00
2dc63cffea
fix(emqx_misc): call gen_tcp to decide if ipv6_probe is supported
2021-11-16 08:37:53 +01:00
d05e2ff0b1
Merge remote-tracking branch 'origin/main-v4.3' into main-v4.4-alpha.1
2021-11-15 13:41:51 +01:00
0357f7ad85
improve(emqx_st_statistics): optimize the parameters of on_publish_done ( #6151 )
...
* fix(emqx_st_statistics): optimize the parameters of on_publish_done
2021-11-15 11:00:04 +08:00
641f36514f
chore: fix elvis warnings
2021-11-15 09:50:32 +08:00
6fb3ff1f9f
feat(exhook): expose headers for on_messages_publish hook
2021-11-15 09:50:32 +08:00
8bf6668e4c
Set keepalive via http api ( #6143 )
...
* feat: set keepalive over http api
* chore: elvis warning
* fix: bump retainer to 4.4.0
2021-11-12 20:11:59 +08:00
a4a7cac647
fix(eqmx_st_statistics): add ignore_before_create in config ( #6140 )
...
1. allows not to process the message before the session is created
to solve the problem caused by clean session = false
2. fix some elvis errors
2021-11-12 14:00:48 +08:00
835ad52498
feat(trace): http api for trace ( #6052 )
...
* feat(trace): add http trace API
* feat: sub/unsub trace topic
* chore(trace): stream log use _page and _limit
* fix: elvis warning
* fix: mod_trace test failed
* fix: http api meta rename _page/_limit to _page/_limit
* fix: clientid string not working
* fix: add emqx_mod_trace to module
* fix(trace): fixed by review suggestions
2021-11-11 14:54:40 +08:00
86b8d88165
chore(emqx): update appup.src
2021-11-11 11:55:57 +08:00
8f07f26744
fix: ensure starting listeners before plugins
2021-11-11 11:37:54 +08:00
6222e1b0eb
Merge remote-tracking branch 'origin/main-v4.3' into sync-v4.3-to-v4.4
2021-11-08 21:01:14 +01:00
b9270ad719
feat(stats): track live / connected channel count for monitoring
...
In order to correctly display the number of connected clients in our
monitor dashboard, we need to track those connections that are
actually connected to clients, not considering connections from
persistent sessions that are disconnected. Today, the
`connections.count` that is displayed in the dashboards considers
those disconnected persistent sessions as well.
2021-11-08 14:45:57 -03:00
7d07e8d948
chore(emqx): Update version and appup file
2021-11-08 14:24:37 +01:00
27afecb3ac
fix(emqx_connection): Introduce backpressure while sending data
...
Fixes #5494
2021-11-04 15:25:34 +01:00
f36abc281a
chore(types): add comment for ver type
2021-11-04 09:11:02 +08:00
f8acb31f89
feat: add slow topics statistics plugin
2021-11-03 17:20:07 +08:00
2c4d3d1d24
chore(stomp): fix dialyzer warnings
2021-11-02 17:09:57 +08:00
763f567f7d
chore(appup): update appup.src
2021-11-01 18:35:41 +08:00
c9d39b4d35
chore(channel): remove redundant logs
...
Multiple sock_closed events may be generated,
so we need to allow sock_closed events to be reentrant
2021-11-01 18:17:38 +08:00
zhongwencool