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
094c8fc48b
Merge branch 'stable/e4.2.7' into dev/e4.2.8
2021-09-27 17:09:34 +08:00
34375c6cc6
chore(appup): update appup.src
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
c0ca7f8bea
fix(force_shutdown): cannot suicide if the process hangs up
2021-09-26 18:37:11 +08:00
903a9e57a8
feat(mqueue): Interleave messages with different priorities
2021-09-24 12:51:28 +08:00
e10e241fe9
chore: export function
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
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
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
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
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
8cc69e639f
fix(congestion): change the conn congestion alarm msg body
2020-11-11 17:33:38 +08:00
26c03aaa43
feat(connection): update alarm info
2020-11-11 09:37:39 +08:00
e100b0a5e9
feat(emqx_metrics): add new functions to count message received
2020-11-10 23:36:11 +08:00
cc69225b6d
feature(tcp): alarm when tcp connection congested ( #3818 )
2020-11-10 23:36:11 +08:00
139306b61c
fix(json): fix decoding/encoding empty object error
2020-11-10 23:36:11 +08:00
b883e238bf
fix(ws): take ws_cookie to clientinfo
...
see: https://github.com/emqx/emqx/issues/3747#issuecomment-702268570
2020-11-10 23:36:11 +08:00
eb4b9936dc
fix(modules): fix conflicts
2020-10-11 11:12:39 +08:00
fa31062a5e
chore(topic rewrite): export more functions
2020-09-11 12:37:47 +08:00
JianBo He