73d72eacce
fix: demote rate limit log level to notice
2022-10-11 13:05:21 +02:00
d72ca84af0
chore: fix ignored dialyzer warnings (part 1) (4.3)
2022-09-12 10:56:35 -03:00
6168745f90
chore: update copyright
2022-04-14 11:23:25 +08:00
557c52dd8a
chore(codestyle): remove Elvis
2022-02-18 20:35:19 +03:00
b9acf94fd7
feat(frame): better log for proxy_protocol config disabled
2021-12-10 18:08:47 +08:00
ef6f867304
chore(conn): change terminated print to debug level
2021-12-02 18:01:36 +08:00
27afecb3ac
fix(emqx_connection): Introduce backpressure while sending data
...
Fixes #5494
2021-11-04 15:25:34 +01:00
8bf3c511d8
test: fix a flacky test case
2021-06-04 16:04:58 +02:00
1e2bd2610f
feat(emqx_connection): async_set_keepalive defaults to self()
2021-05-27 16:18:17 +08:00
6701d716dd
feat: async API to support tcp keepalive inet options
2021-05-24 19:01:13 +02:00
dfab9492c6
fix(emqx_connection): do not log einval error
...
einval happens when trying to send data to a closed socket.
2021-05-18 20:30:27 +08:00
de43da881a
fix(emqx_frame): poor large frame concatenation performance
...
piror to this change, binary concatenation eats most of the CPU
2021-05-13 22:58:22 +02:00
708420eb97
fix(emqx_connection): log true stacktrace
2021-04-25 12:01:05 +02:00
6354e75626
chore: update copyrights
2021-04-23 20:43:00 +02:00
4885171e4f
fix(emqx): add timeout for open/kick a session
2021-04-15 23:09:58 +08:00
df0e905754
refactor(emqx): the congestion alarm
2021-04-10 12:17:04 +08:00
6f5aa88562
chore(emqx_connection): Add a test case to cover oom kill
2021-03-30 10:08:13 +02:00
6e1a55e9ed
perf(emqx_connection): no priority receive
...
Prior to this change the main message receive loop of emqx_connection
is a priority receive which selects system messages and parent EXIT
signals prior to other message.
This accidental (not intended) design may cause the receive operation
to scan potentially large mail box.
2021-03-30 10:08:13 +02:00
66693d6846
fix(emqx_connection): connection OOM kill immediately
...
Prior to this change, connection process' OOM kill is a loopback
message, which results in a delayed kill when message queue length
is large.
In this change, the loopback message is changed to an exit signal.
2021-03-30 10:08:13 +02:00
81602c973c
fix(emqx): deny pingreq when mqtt not connected #4370
2021-03-19 14:17:49 +08:00
71d02e8011
chore(emqx_connection): delete stale code
2021-02-19 10:20:16 +01:00
f9465dda16
Merge branch 'dev/v4.3.0' into merge-e4.2.4-to-dev-4.3.0
2021-02-14 21:41:23 +01:00
406a7d60c7
chore(style): fix elvis check for emqx_connection
2021-02-13 11:50:17 +01:00
9b82112b7c
Merge remote-tracking branch 'origin/dev/e4.3.0' into merge-e4.2.4-to-dev-4.3.0
2021-02-13 11:10:08 +01: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
739e49218f
fix(cm): fix the problem of registering a channel twice ( #3831 )
2020-12-28 11:03:29 +08:00
7bdd093ef5
Merge remote-tracking branch 'origin/dev/v4.3.0' into umbrella-fix-build
2020-12-11 08:55:57 +01:00
7a39470200
fix(emqx_connection): Dialyzer warnings
2020-12-10 09:35:36 +01:00
0ee489a9be
fix(congestion): change the conn congestion alarm msg body
2020-12-07 15:05:20 +08:00
d00ea48752
feature(tcp): alarm when tcp connection congested
2020-12-07 14:35:38 +08:00
505257b25b
chore(appup): remeove the code_change codes
2020-12-05 17:22:44 +08:00
ae9449a004
chore: eliminate diaylzer warnings
2020-12-05 17:20:50 +08:00
f1b3bbd7bc
chore: supply the code_change logic
2020-12-05 17:20:50 +08:00
3b1074d11f
refactor(conn): not saving anonymous func
2020-12-05 17:11:58 +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
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
cc69225b6d
feature(tcp): alarm when tcp connection congested ( #3818 )
2020-11-10 23:36:11 +08:00
90b33b044d
feature(ratelimit): support to set ratelimit & quota policy
2020-09-05 17:23:22 +08:00
83a2af812f
feat(ratelimit): refactor ratelimit
2020-07-31 18:07:20 +08:00
e3489b9d46
refactor(style): improve all types declaration
...
- Add dialyzer for code analysis
- Correct all the module type declarations
- Use `-type()` to declaration a type instead of `-opaque`
(It is advantageous to the code dialyzer)
BROKEN CHANGES:
- Add a ?DEFAULT_SUBOPTS for emqx_broker:subscribe/1,2,3
- Remove the needless internal function `emqx_vm:port_info(PortTerm, Keys)`
2020-06-18 17:38:34 +08:00
78144c0ca5
Update error log ( #3342 )
...
Optimize content of error log
2020-03-27 10:10:23 +08:00
ad7cbb4428
Fix einval after socket was closed
2020-03-05 14:28:12 +08:00
6b5a8949c5
Change rate limit pausing logs to warning
2020-03-02 18:26:37 +08:00
f29a8b0d5c
Mqtt protocol tests ( #3237 )
...
Add more test cases for MQTT
2020-02-07 10:07:36 +08:00
fdeade3212
Add more test cases
2020-01-09 20:01:46 +08:00
7ea75f4289
Update copyright
2020-01-03 18:31:08 +08:00
597558fee8
Fix unexpected timeout
2019-12-30 21:27:47 +08:00
Ivan Dyachkov