cf3354d30d
revert(zones_conf): zone.external.max_topic_levels
2022-01-07 15:08:20 +08:00
80608e9c99
chroe(appup): update appup.src
2022-01-07 15:08:20 +08:00
9969fd0d18
feat(frame): better log for proxy_protocol config disabled
2022-01-07 15:08:20 +08:00
93ec2ef995
Merge pull request #6673 from emqx/fix-appup
...
chore(appup): fix syntax error
2022-01-07 11:33:20 +08:00
dc6bc76512
chore(appup): fix syntax error
2022-01-07 11:27:56 +08:00
f09bf74c99
Merge pull request #6471 from lafirest/fix/quota_limiter
...
fix(emqx_limiter): update the overall limiter when config updating
2021-12-23 17:19:49 +08:00
0f1b14f865
fix(emqx_limiter): update the overall limiter when config updating
2021-12-17 14:37:54 +08:00
e57c30a0b9
fix(conf): change `max_topic_levels` default configuration
2021-11-25 20:39:12 +08:00
47b2642423
Merge pull request #6145 from emqx/dev/e4.2.9
...
Auto-pull-request-on-2021-11-12
2021-11-12 14:29:17 +08:00
a0a44eecb5
Merge pull request #6144 from JimMoen/fix-variable-byte-int-e42
...
fix(frame): variable byte num not limited in 4 bytes
2021-11-12 13:46:37 +08:00
cf9d82073c
fix(ekka): update ekka to 0.7.10
2021-11-12 13:39:19 +08:00
a11208b307
fix(frame): variable byte num not limited in 4 bytes
2021-11-12 11:36:11 +08:00
fb7c84a5b8
Merge pull request #6103 from HJianBo/fix-force-kill-after-kick-or-discard-timeout-e42
...
Fix force kill after kick or discard timeout
2021-11-11 10:55:52 +08:00
edb2c5f3c1
chore(appup): update appup.src
2021-11-10 11:34:32 +08:00
3d7f4335a0
fix(emqx_cm): replace ?tp with ?LOG
2021-11-10 11:34:30 +08:00
915c827fdc
fix(session): force kill session for 'kick' and 'discard'
...
Prior to this fix, 'kick' and 'discard' calls may timeout (or
fail for other reason), failures lead to only a log, then
continue to allow the new session to get registered.
As a result, in case a client is stuck, there is no way to
force it to step down, end up with multiple connections (sessions)
for the client ID in dashboard.
After this fix, the stale pids are notified to shutdown
via a gen_server:call, and forced with a exit(Pid, kill) for any
exception happend to the gen_server:call
2021-11-09 18:12:10 +08:00
649bf2f4cb
chore(appup): update appup.src
2021-11-01 09:46:57 +08:00
437837d687
chore(cm): remove needless logs
2021-11-01 09:46:57 +08:00
26b426b7ad
Merge pull request #5816 from emqx/dev/e4.2.8
...
Auto-pull-request-on-2021-09-27
2021-09-27 11:50:28 +02:00
094c8fc48b
Merge branch 'stable/e4.2.7' into dev/e4.2.8
2021-09-27 17:09:34 +08:00
e86e1e0430
fix(ekka): kill the process if don't release lock
2021-09-27 09:57:23 +08:00
34375c6cc6
chore(appup): update appup.src
2021-09-26 20:10:23 +08:00
b9527cfe9d
test: increase waiting time to avoid test failure
2021-09-26 20:10:23 +08:00
5f2adb42ed
chore: export keepalive funcs for mqtt-sn
2021-09-26 20:10:23 +08:00
7b177a7929
fix: more safe session call
2021-09-26 20:10:23 +08:00
aa5d274464
feat: acl.conf support ipaddrs
2021-09-26 20:10:23 +08:00
fb65d1c581
chore: add mqtt-sn protocol define
2021-09-26 20:10:23 +08:00
c0ca7f8bea
fix(force_shutdown): cannot suicide if the process hangs up
2021-09-26 18:37:11 +08:00
4c30c50490
Merge pull request #5799 from emqx/merge-e4.3.4
...
feat(mqueue): Interleave messages with different priorities
2021-09-24 11:52:00 +02:00
903a9e57a8
feat(mqueue): Interleave messages with different priorities
2021-09-24 12:51:28 +08:00
830150b309
chore: update ekka tag
2021-06-17 11:30:43 +08:00
e10e241fe9
chore: export function
2021-06-08 10:54:19 +08:00
eeb480c051
core(deps): pin ekka 0.7.7
2021-06-08 10:54:19 +08:00
ca9b90be9a
perf(broker): speedup trans when broker has a big mqueue
2021-04-29 17:10:10 +08:00
e02704e05a
perf(broker): Optimization for handling bursty traffic
...
intro. new lock type: 'spawn' of broker.perf.route_lock_type
mnesia get lock calls are not optimized for selective receive.
hence taking locks would be very expensive while there are tones of
messages in the brokers message queue.
This optimization run the transaction in a separate process to utilize
the selective receive optimization of the compiler.
2021-04-29 17:10:10 +08:00
5cc21dc3f0
fix(upgrade): duplicated modules loading.
2021-04-28 17:01:54 +02:00
806cd33d1f
chore(ct): fix a testcase timing.
2021-04-28 17:01:54 +02:00
f8ca066d74
upgrade: safe upgrade of emqx_connection
2021-04-28 21:29:20 +08:00
59b7e8e3ba
perf(lock): upgrade code for new lock types.
2021-04-28 21:29:20 +08:00
571219f073
perf: new perf toggle broker.perf.route_lock_type
2021-04-28 21:29:20 +08:00
9084554f4f
fix: broker call should not timeout before client timeout
...
So change broker call timeout to infinity.
2021-04-28 21:29:20 +08:00
1b179c8e2a
perf(router): add route runs in async dirty context
2021-04-28 21:29:20 +08:00
fb8f5b79ad
perf(trie): use global lock
...
Use global lock to reduce remote lock overhead.
So that emqx route trans can run in dirty *sync* context.
At least 10X subscribe/unsubscribe improvments.
2021-04-28 21:29:20 +08:00
e427b0ff75
chore(appup): supply appup instructions for ws-connetion
2021-04-28 21:29:20 +08:00
b4e3c32e24
chore(conf): log only to file by default
2021-04-28 21:29:20 +08:00
c511e324bb
fix(ekka): allow remote_console
2021-04-28 21:29:20 +08:00
1eb0f7b3b2
fix(ws connection): fix peer_cert_as_username error when ws connect
2021-04-28 21:29:20 +08:00
7d003e0bfc
Porting code for congestion alarms from 4.3.0 to e4.2.6 ( #4523 )
...
* fix(congestion): port some code from 4.3.0
* chore(emqx): update the appup file
2021-04-28 21:29:20 +08:00
927264d793
fix(emqx): export do_deliver/2 for emqx_sn
2021-04-28 21:29:20 +08:00
70da59c3bb
chore(emqx): update appup
2021-04-28 21:29:20 +08:00
JimMoen