7cc8cb4f88
fix(frame): variable byte integer could be larger than 4 bytes
2021-09-27 23:01:37 +08: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
c69e1c6222
fix(mqtt-sn): sleep mode not working #4434
2021-04-28 21:29:20 +08:00
6666210211
fix(congestion): alarm and clear congestion too frequetly
2021-04-28 21:29:20 +08:00
238eaa8e40
fix(emqx): validate mqtt malformed variable byte integer
2021-03-10 19:42:44 +08:00
6c1129dc6a
Auto-pull-request-on-2021-01-29 ( #4114 )
...
* fix(share sub): fix the issue that the number of subscriptions dropped to 0 during the picking subscriber and caused a crash
* Connection Busy Alarms (#3992 )
feat(emqx_connection): improve port_busy alarm
* fix(emqx_connection): tune the congestion alarm params
* chore(deps): upgrade esockd to 5.7.5
* fix(appup): correct the appup file
2021-01-30 10:30:18 +08:00
2e7ec25ae2
chore(appup): suspend esockd_acceptor
2020-12-05 15:04:14 +08:00
042b75adc7
fix(ekka): update ekka version to fix oom
2020-12-04 22:56:55 +08:00
f8369f5280
test: comment the will message cases
2020-12-04 22:33:29 +08:00
7462ed92ba
chore: eliminate diaylzer warnings
2020-12-04 22:33:29 +08:00
ca0f6b69a4
chore: supply the code_change logic
2020-12-04 22:33:29 +08:00
80c503fd64
refactor(conn): not saving anonymous func
2020-12-04 22:33:29 +08:00
40d272815a
refactor(limiter): not saving anonymous function
2020-12-04 22:33:29 +08:00
a3cdae3b42
feat(listener): add depth for ssl listener
2020-11-30 18:51:02 +08:00
f5162562a4
chore(appup): update appup
2020-11-26 10:42:35 +08:00
aa7124f3c9
chore(appup): use binding var 'VSN'
2020-11-25 14:40:25 +08:00
3ca39cb9cb
chore(appup): update version
2020-11-25 10:27:56 +08:00
3f41adc3bd
chore(appup): update version
2020-11-25 01:07:19 +08:00
41a8f2f811
Merge branch 'stable/e4.2.0' of https://github.com/emqx/emqx into stable/e4.2.0
2020-11-13 10:40:28 +08:00
77d777fd11
chore(acl): rollback emqx_access_rule module
2020-11-13 10:40:14 +08:00
Turtle