05c5378265
feat(http_lib): add normalise_headers API
2021-05-07 10:14:19 +08:00
c81cd8550d
perf(trie): do not call ets:info/2 to check if table is empty
...
emqx_trie table is a ordered_set, with write_concurrency set to
true, the counter is not centrialsed, the ets:info/2 call to
check size == 0 is very expensive
2021-05-06 23:27:29 +08:00
cfec4c9690
fix(logger): fix json formatter
...
crash when invalid string as json key.
2021-05-06 15:12:56 +02:00
1db8483bb3
feat(node_dump): Hide `secret' configuration keys
...
Co-authored-by: Zaiming (Stone) Shi <zmstone@gmail.com>
2021-05-06 14:19:09 +02:00
e6c85dfb04
fix(node_dump): Attempt to censor passwords
2021-05-06 14:19:09 +02:00
4cff5c4dac
chore: fix config doc
2021-05-06 11:03:02 +02:00
6b0487d69d
feat(logger): merge metadata to log data
2021-05-06 11:03:02 +02:00
79181072e2
feat(logger): add formatter emqx_logger_jsonfmt
2021-05-06 11:03:02 +02:00
92d3e16d43
perf(router): receive-mark optimise for short-lived transaction process
2021-05-05 11:00:00 +02:00
f8700e3f27
fix(emqx_packet): no crash if publish packet has no data
2021-05-04 13:48:35 +02:00
bf4baf708a
fix(emqx_packet): list element index out of range
2021-05-04 09:24:54 +02:00
171933301a
fix(dashboard): display full Erlang/OTP version
2021-04-30 12:26:59 +02:00
e122ac5716
perf(broker): speedup trans when broker has a big mqueue
2021-04-29 08:52:42 +02:00
e7fc75fdf2
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-28 15:39:46 +02:00
29475eb610
feat(emqx_http_lib): try to parse host ip
2021-04-28 10:43:36 +02:00
b688bcfe74
feat(eqmx_misc): add an api to ensure ipv6_probe socket option
2021-04-28 10:43:36 +02:00
e54433d342
feat(emqx_vm): add api to inspect which otp version running on
2021-04-28 10:43:36 +02:00
d926800204
chore: add emqx_broker_bench.erl
2021-04-26 14:40:39 +02:00
cdacaf8694
perf(emqx_trie): use ordered_set
2021-04-26 14:18:40 +02:00
b1df759adc
refactor(emqx_trie): rename internal function to match_#
2021-04-26 14:18:40 +02:00
8d55d425dc
chore(emqx_trie): add test case to cover multiple levels of + wildcards
2021-04-26 14:18:40 +02:00
eb946eb80c
fix(emqx_trie): do not try to match wildcard topics
2021-04-26 14:18:40 +02:00
22e72cdd82
refactor(emqx_trie): rename record from eqmx_topic to emqx_trie
2021-04-26 14:18:40 +02:00
bc6a87946c
refactor(emqx_trie): store only prefixes
...
This commit refactors emqx_trie implementation
with mainly two changes
1. Deleted the edge table.
In the old implementation, trie consist of nodes and edges.
e.g. for topic 'a/b/+/d', node 'a' with edge 'b'
points to node 'a/b' and so on.
However, edges can be computed at runtime,
so there is no need to store them in a table.
2021-04-26 14:18:40 +02:00
7128bc9e6e
chore(emqx_app): do not print 'starting' log when test
2021-04-26 14:18:40 +02:00
5569c86319
docs(emqx_trie): no doc for internal functions
2021-04-26 14:18:40 +02:00
6be28cecab
chore(logging): default to multi-line logging
2021-04-26 11:11:27 +02:00
907502fed0
Merge pull request #4645 from qzhuyan/dev/william/fix-issue-2985-c3
...
fix: issue 2985 attempt 3
2021-04-25 12:39:52 +02:00
708420eb97
fix(emqx_connection): log true stacktrace
2021-04-25 12:01:05 +02:00
2e6ad828a0
chore: remove copyright and license Erlang macros
2021-04-23 20:43:00 +02:00
6354e75626
chore: update copyrights
2021-04-23 20:43:00 +02:00
9b13bab2c9
perf: new perf toggle broker.perf.route_lock_type
2021-04-23 13:51:42 +02:00
3547dc4c93
fix(log): client id as string for log metadata
...
so it does not print <<"...">> to the logs
2021-04-23 06:54:10 +02:00
fd69969014
refactor(logging): Log to single line
2021-04-23 06:54:10 +02:00
0166bb5a87
fix: broker call should not timeout before client timeout
...
So change broker call timeout to infinity.
2021-04-21 18:59:46 +02:00
17870fdb39
perf(router): add route runs in async dirty context
2021-04-21 18:59:46 +02:00
3972a6b435
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-21 18:59:24 +02:00
97f2e5d544
test(auth_http): test unset acl_req app env
2021-04-19 08:39:26 +02:00
49502b4e7c
feat(uri): add missed function
2021-04-16 20:19:45 +08:00
bd1051d1e6
feat(uri): support decoding uri in string
2021-04-16 20:19:45 +08:00
4885171e4f
fix(emqx): add timeout for open/kick a session
2021-04-15 23:09:58 +08:00
446a69c814
fix(ws connection): fix peer_cert_as_username error when ws connect
2021-04-15 09:06:27 +08:00
a48e7df4f5
feat(emqx_ws_connection): check http header to know real IP/port
2021-04-14 06:45:39 +00:00
49b7d870e0
fix(modules): load application first for ekka_mnesia scanner
2021-04-13 09:57:33 +08:00
16c999ed9b
Start emqx-modules application by default ( #4518 )
...
* fix(modules): start emqx_modules by default
* chore(test): eliminate some compile warnings
2021-04-12 09:45:31 +08:00
f902d880c1
fix(emqx): rename wont_clear_alarm_in to min_alarm_sustain_duration
2021-04-10 12:17:04 +08:00
df0e905754
refactor(emqx): the congestion alarm
2021-04-10 12:17:04 +08:00
327b0c0995
fix(mqtt_sn): send pingresp until all pubacks received
2021-04-10 09:36:56 +08:00
e3a5f65c88
feat(config): print override env ( #4517 )
2021-04-09 16:28:01 +02:00
7667b65710
fix(emqx): Do not io:format when testing
2021-04-09 10:18:25 +02: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
2e30d7803f
fix(channel): fix `keep-alive` problem
2021-03-30 16:01:42 +08:00
7bf6ee0f4b
fix(mqtt-sn): sleep mode not working #4434 ( #4435 )
2021-03-29 17:51:49 +08:00
6c77fa1bf7
fix(emqx_channel): Receive Maximum spec compliance
...
According to MQTT 5.0 specification
If the Receive Maximum value is absent then its value defaults to
65,535.
2021-03-29 09:42:07 +02:00
b10a60cddb
fix(conninfo): Ensure receive_maximum do not exceed limit
2021-03-29 09:42:07 +02:00
496e5381fb
chore(rule-engine): compatible with the lower case hash string
2021-03-25 09:10:05 +08:00
a4b30ea77c
feat(emqx): Add backtrace_depth configuration
2021-03-23 21:30:49 +01:00
4c5273c1d1
style(emqx_inflight): elvis: User UPPER_CASE macro
2021-03-23 21:30:49 +01:00
277cab86d3
refactor: improve the speed of hexstr and binary conversions
2021-03-23 18:25:19 +08:00
8201e4c820
feat(emqx.erl): Add a help function to load debug secret
2021-03-19 21:46:03 +01:00
e06b54ff71
chore(boot-log): print a warning at boot when running on old otp
2021-03-19 15:39:11 +01:00
2d150127d4
feat(listeners): Ensure no tlsv1.3 for otp 22 or earlier
2021-03-19 15:39:11 +01:00
72c1ee264c
chore(elvis): fix elvis error
2021-03-19 16:11:23 +08:00
568f4de6e5
fix(channel): fix the wrong acl check order
...
when subscribe, check the acl rule before run 'client.subscribe' hooks
2021-03-19 16:11:23 +08:00
81602c973c
fix(emqx): deny pingreq when mqtt not connected #4370
2021-03-19 14:17:49 +08:00
c7b44caa1d
feat(acl): Add possibility to remove all acl cache
2021-03-17 19:48:42 +01:00
d5886c0c66
chore(build): Get rel vsn fallback ( #4339 )
2021-03-16 09:49:11 +01:00
e9180b9ce8
chore(emqx_messages): fix elvis
2021-03-11 16:01:35 +09:00
9087f0c138
feat(emqx_message): add from_map
2021-03-11 16:01:30 +09:00
b400571dbb
fix(emqx): validate mqtt malformed varible byte integer
2021-03-10 10:41:57 +01:00
582dea10f5
style(emqx_sys): make elvis happy
2021-03-09 20:22:48 +01:00
e1979bf488
chore(build): Single source of EMQX_DESCRIPTION
2021-03-09 20:22:48 +01:00
00a2daba19
chore(build): add more enterprise build support
2021-03-06 10:56:07 +01:00
1af1dd17b5
chore(build): use 'EMQ X test' as app description for test runs
2021-03-06 08:41:50 +01:00
73500a0983
chore(build): inject product description from makefile
2021-03-06 08:41:50 +01:00
c752f3bec5
Refactor http lib add uri parse ( #4292 )
...
* feat(http_lib): Add uri parse to emqx_http_lib
* fix(webhook): call emqx_http_lib to parse uri
* fix(auth-http): Call emqx_http_lib to parse uri
* fix(rule-engine): call emqx_http_lib to parse uri
2021-03-06 13:35:02 +08:00
9b3ab169ce
chore(versioning): detach package version from emqx app version
2021-03-04 20:24:58 +01:00
42098b497f
Merge pull request #4283 from zmstone/add-emqx-http-lib
...
refactor(http-lib): Add emqx_http_lib
2021-03-04 07:14:02 +01:00
67c8b2eed7
chore: update emqx.app.src version
2021-03-04 08:10:48 +08:00
63c001a7aa
refactor(http-lib): Add emqx_http_lib
...
So far only uri_encode and uri_decode APIs
2021-03-03 21:38:10 +01:00
3daefe954b
chore(src): fix elvis
2021-03-03 20:06:31 +09:00
a8558bc7b5
chore(emqx_channel): ignore peer_cert_as/5 from dialyzer
2021-03-03 20:06:31 +09:00
e1b915b91c
chore(emqx_tracer): pass proper map
2021-03-03 20:06:31 +09:00
cae0849152
fix(emqx_channel): fix bug when publish deny
...
fix the bug of replying to puback when the publish message with Qos equal to 2 is deny
2021-03-02 17:54:22 +08:00
dd06d70bce
refactor(build): Move parse_transform module to root app
...
So we do not have to workaround the compile order issue
2021-03-02 08:40:19 +08:00
6e0b53fbb9
fix(eunit): fix emqx_tls_lib_tests
2021-03-01 21:00:17 +08:00
0a51bd4c2f
fix(webhook): Call common lib for ssl options
2021-03-01 21:00:17 +08:00
700fa71754
refactor(tls): abstract lib for tls options parsing
2021-03-01 21:00:17 +08:00
64ac20eec5
chore(emqx_listeners): fix clauses for dialyzer
2021-03-01 16:56:21 +08:00
6ea4501de4
chore(emqx_listeners): fix type
2021-03-01 16:56:21 +08:00
3dfa9f45c4
Merge pull request #4183 from zmstone/merge-e4.2.4-to-dev-4.3.0
...
Merge e4.2.4 to dev 4.3.0
2021-02-19 10:26:47 +01:00
71d02e8011
chore(emqx_connection): delete stale code
2021-02-19 10:20:16 +01:00
ca1d24a98d
feature(mgmt): restart a listener
...
example:
```
emqx_ctl listener restart mqtt:ssl:external
```
or
```
PUT /api/v4/listeners/mqtt:ssl:external/restart
```
thank you @zmstone for providing the listener-identifier apis :)
2021-02-19 09:22:47 +01:00
98b319a0c0
Merge pull request #4190 from zmstone/refactor-assing-names-to-listeners
...
feat(listeners): Add identifier to listeners
2021-02-19 07:50:27 +01:00
64cfaf4385
improve(print): io:format error message without indentation
...
Avoid squeezing lines to the right.
2021-02-19 07:45:37 +01:00
28f9b4d519
feat(peer_cert_as_clientid): peer_cert_as_clientid = cn | dn | crt | pem | md5
...
pem is base64 encoded instead of binary crt
peer_cert_as_username=crt breaks exhook proto utf8 parsing of username
crt cannot be used in a topic name due to being invalid utf8
pem cannot be used in a topic name due to having slashes
peer_cert_as_clientid = md5 allows to e.g. subscribe to "t/%c" with ACL
existing peer_cert_as_username combinations are unaffected.
2021-02-19 10:53:11 +08:00
d2bd9b4078
Merge pull request #4197 from zmstone/improve-shared-sup-random-start-point-for-roundrobin
...
improve(shared-sub): Randomise the startpoint for round-robin
2021-02-18 13:26:01 +01:00
db461179c5
improve(shared-sub): Randomise the startpoint for round-robin
2021-02-17 19:10:37 +01:00
eec64e440d
fix(tracer): create short handler-id if clientid is too long ( #4164 )
...
* fix(tracer): create short handler-id if clientid is too long
No need to support lists and atoms for when tracing clients/topics.
2021-02-16 14:45:33 +08:00
a93d62ace6
refactor(cli): Print listener ID as table head
2021-02-15 10:34:47 +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
c5a02c729a
feat(listeners): Add an api to ensure all listeners are started
2021-02-14 21:30:50 +01:00
dfa9bbc0c2
refactor(listeners): use emqx_ctl to print cli messages
...
It's better to keep cli print behaviour consistent.
It also makes tests easier as they can meck emqx_ctl:print to
validate the output.
2021-02-14 20:40:01 +01:00
153977609e
feat(listeners): Add identifier to listeners
...
Listeners are internally identifiered by the listen-on tuple
which is not UI friendly when we have to find a listener by this
'signature'.
The listeners are actually named in configs, but the names are
discarded in the parsing functions.
This commit is to keep the name and provide an API to find
listener by name (identifier).
2021-02-14 18:12:40 +01:00
dc184574a3
chore(style): fix elvis check for emqx_access_rule
2021-02-13 11:54:09 +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
f000b6583c
fix(tls): Ensure tls config integrity
...
For default tsl version and ciphers, we try to use otp release number
to determin if we want to use tlsv1.3
For default configs, we try to porivde both tlsv1.3 and
ciphers in config (even for commented out configs)
2021-02-09 22:56:28 +01:00
2852ac79d4
feat(tls): Add a tls lib module
...
emqx_tls_lib is added to help ensure integrity of tls version
and cipher options.
2021-02-09 21:20:26 +01:00
7aff861f9b
refactor(emqx_modules): Move emqx_modules to lib-opensource
...
emqx_moduels for enterprise is refactored as a lib/plugin
in order to avoid merge conflicts, we make sure they can
co-exist in the same branch, because lib-opensource is compiled
in opensource project and lib-enterprise (to be added) is
compiled in enterprise project
2021-02-08 21:35:44 +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
d78b2b23c1
chore(build): update pkg version
2021-01-29 19:29:41 +08:00
5878950dc3
feat(websocket): support for checking subprotocols ( #4099 )
2021-01-28 20:42:57 +08:00
02cb8d0211
chore(style): set warnings_as_errors compile option
2021-01-27 18:02:12 +08:00
de972b3d84
fix(emqx_vm): Call recon_alloc:allocators/0 to get allocators
2021-01-23 11:42:28 +01:00
23b2f4fa72
Merge pull request #4050 from zmstone/chore-delete-stale-code
...
chore(emqx_vm): delete stale code
2021-01-23 11:13:22 +01:00
7c3cd26589
chore(elvis): fix elvis wanrings
2021-01-23 18:07:58 +08:00
f59377adf5
fix(logs): print the correct username and clientid
2021-01-23 18:07:58 +08:00
33c35915ca
refactor(emqx_vm): make elvis happy
2021-01-22 09:23:20 +01:00
4680ba574c
chore(emqx_vm): Delete get_ets_object, not used
2021-01-22 09:21:45 +01:00
47df29ae49
chore(emqx_vm): delete stale code
...
The port binary format is no longer compatible in OTP 23
2021-01-22 07:50:00 +01:00
0087303b25
feat(shared_sub): Support hashing from source topic.
2021-01-21 21:05:56 +01:00
5aa63ed203
fix(shared_sub): align default value and default config
...
Shared subscription default dispatch strategy is 'random' in config
but 'round_robin' in code. This commit is to make sure they are the
same: both are 'random'.
2021-01-21 21:05:56 +01:00
598207e308
fix(ws_connection): proplists:get_bool for boolean flags
2021-01-15 14:28:22 +01:00
5794a708ed
feat(emqx_ws_connection): Prevent EMQX from CSWSH Cross-Site Web-Socket Hijack
2021-01-15 14:28:22 +01:00
32b23b9181
Revert "feat(auth_http): support for getting websocket cookies"
...
This reverts commit 5427057c2c
2021-01-14 15:10:48 +01:00
d437f9f228
chore(elvis): fix elvis warnings
2021-01-14 15:46:16 +08:00
f2190dd5b5
chore(mnesia): explicitly specify the copy type for table
2021-01-14 15:46:16 +08:00
76fc6225d3
fix(elvis): fix elvis checking
2021-01-14 15:46:16 +08:00
2a029b71c9
perf(mnesia): unify the copy types of all nodes
2021-01-14 15:46:16 +08:00
5427057c2c
feat(auth_http): support for getting websocket cookies
...
see: https://github.com/emqx/emqx-auth-http/pull/225
2021-01-11 09:21:16 +08:00
2b481dabe7
Fix some dialyzer warnings ( #3988 )
2021-01-05 20:49:50 +01:00
b9bb88d9eb
fix(emqx): fix dialyzer warnings
2021-01-04 14:14:55 +01:00
fbf8d3e111
fix(share sub): fix the issue that the number of subscriptions dropped to 0 during the picking subscriber and caused a crash
2020-12-31 14:03:55 +08:00
4f82c77e7a
fix(log): improve the error log message on hook failure ( #3973 )
2020-12-31 13:55:09 +08:00
ac0f51fec3
fix(max topic len): use the maximum length limit by default
2020-12-28 14:48:32 +08:00
739e49218f
fix(cm): fix the problem of registering a channel twice ( #3831 )
2020-12-28 11:03:29 +08:00
b68a0b3730
fix(emqx_lua_hook): fix dialyzer warnings.
2020-12-25 07:42:01 +08:00
7bdd093ef5
Merge remote-tracking branch 'origin/dev/v4.3.0' into umbrella-fix-build
2020-12-11 08:55:57 +01:00
6973837829
fix(emqx_plugins): Dialyzer warnings
2020-12-10 23:34:36 +01:00
56d7b3deb1
Umbrella fix build ( #8 )
2020-12-10 11:25:25 +01:00
59d69b730b
fix(emqx_logger): Dialyzer warnings
2020-12-10 11:22:38 +01:00
b9b20ba268
fix(emqx.erl): Dialyzer warnings
2020-12-10 11:22:38 +01:00
62e0a21ad0
fix(emqx_auth_sys, emqx_ws_connection): Dialyzer warnings
2020-12-10 11:22:38 +01:00
18ae158f45
fix(emqx_plugins, emqx_sys, emqx_sys_mon, emqx_ws_connection): Dialyzer warnings
2020-12-10 11:22:38 +01:00
baaa4e847d
fix(emqx_sn_gateway): Dialyzer warnings
2020-12-10 09:49:24 +01:00
eecd2b5f35
fix(emqx_types): Non mandatory map fields
2020-12-10 09:38:07 +01:00
adc9cc30f6
refactor(emqx_modules): Swallow errors when write modules
2020-12-10 09:35:36 +01:00
d47a2294ca
fix(emqx_mod_topic_metrics): Dialyzer warnings
2020-12-10 09:35:36 +01:00
0f0ca1e9fd
fix(emqx_mod_rewrite): Dialyzer warnings
2020-12-10 09:35:36 +01:00
ab5599b3ec
refactor(hook): Add emqx_hooks:put to hide already_exists error
...
This also fixes dialyzer warnings in emqx_mod_presence
2020-12-10 09:35:36 +01:00
5793ef6640
fix(emqx_mod_sup): Dialyzer warning
...
All the callers of start_child API are discarding the return value.
2020-12-10 09:35:36 +01:00
f3d973689b
fix(emqx_listeners): Dialyzer warnings
2020-12-10 09:35:36 +01:00
7a39470200
fix(emqx_connection): Dialyzer warnings
2020-12-10 09:35:36 +01:00
7dd67a6caf
fix(emqx_channel): Dialyzer warning
2020-12-10 09:35:36 +01:00
cfe52cbb8d
fix(emqx_broker): Dialyzer warning
2020-12-10 09:35:36 +01:00
0eb697fa6f
fix(emqx_app): Dialyzer warnings
2020-12-10 09:35:35 +01:00
3fb69cc407
fix(emqx_alarm): Dialyzer warnings
2020-12-10 09:35:35 +01:00
0d90d5c66b
fix(emqx_acl_cache): Dialyzer warnings
2020-12-10 09:35:35 +01:00
d4aa5ebf55
fix(emqx): Fix dialyzer warnings
2020-12-10 09:35:35 +01:00
7f556d36d1
Merge branch 'dev/v4.3.0' into e422_to_v430
2020-12-09 11:28:36 +08:00
6d1cd6b7ea
refactor(emqx_password): move the module to emqx application
...
Future plugins will require emqx as a dependency.
This commit also brings back bcrypt to the system which was temporary
removed when converting to umbrella project
2020-12-08 22:09:59 +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
3f924631e4
refactor(limiter): not saving anonymous function
2020-12-05 17:03:57 +08:00
2e7ec25ae2
chore(appup): suspend esockd_acceptor
2020-12-05 15:04:14 +08:00
73d02beace
refactor(apps): Merge emqx_libs back to emqx
...
And move emqx app back to root level
After realising the challenges of developing plugins in standalone
rebar projects. it is perhaps more smooth to keep using emqx as
a rebar dependency
2020-12-04 19:58:58 +01: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
cf7c3b4f0c
fix(appup): fix syntax error
2020-11-13 17:40:36 +08:00
253c43e405
feat(emqx_metrics): add new functions to count message received
2020-11-13 16:42:48 +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
5a8efd9d20
feature(project): move src to apps/emqx/src
2020-10-31 09:19:28 +08:00
b373c0cf1b
fix(json): fix decoding/encoding empty object error
2020-10-24 15:49:15 +08:00
8462da9652
fix(topic metrics): add appup.src
2020-10-24 11:21:39 +08:00
b927bb7af6
fix(topic metrics): calculate the rate correctly
2020-10-24 11:21:39 +08:00
2feeb4d91f
fix(ws): take ws_cookie to clientinfo
...
see: https://github.com/emqx/emqx/issues/3747#issuecomment-702268570
2020-10-24 11:21:39 +08:00
87ef4e4dd9
chore(types): Add the disconnected_at field definition in conninfo ( #3764 )
2020-10-24 11:21:39 +08:00
eb4b9936dc
fix(modules): fix conflicts
2020-10-11 11:12:39 +08:00
7b98f62f7a
fix(config): enable force_shutdown_policy by default
2020-09-30 11:36:30 +08:00
da4d71917f
fix(ignore-loop-deliver): fix issue#3738 ( #3741 )
2020-09-29 15:35:16 +08:00
76ec65830c
fix: fix session_locking_strategy enum typos
2020-09-29 15:35:16 +08:00
fa31062a5e
chore(topic rewrite): export more functions
2020-09-11 12:37:47 +08:00
3d4eac7e7a
fix(json): fix safe_encode for utf8 string
2020-09-11 12:26:13 +08:00
edcbdcce87
improve: module_acl_internal load/unload api ( #3706 )
2020-09-05 17:23:22 +08:00
90b33b044d
feature(ratelimit): support to set ratelimit & quota policy
2020-09-05 17:23:22 +08:00
4233ef4e85
fix(xref): correct the type spec of logger_handler_info()
2020-08-28 17:10:26 +08:00
9985e2675c
fix(logger): resolve issues when starting and stopping log handlers
2020-08-28 17:10:26 +08:00
faf0b5289c
feature(logger): support starting and stopping log handlers
2020-08-28 17:10:26 +08:00
e411b4bad3
fix(cm): fix never matching clause
2020-08-28 17:10:26 +08:00
261bd66a3d
refactor(alarm): refactor resource down alarm
2020-08-22 15:27:11 +08:00
7a2a01a4de
fix(mqtt piggyback): bad data type
2020-08-22 15:27:11 +08:00
ec12acc4ef
feature(mqtt piggyback): transporting mutli MQTT packets at once or single
2020-08-22 15:27:11 +08:00
cfcbc53a8b
refactor(alarm): remove excess case
2020-08-22 15:27:11 +08:00
c2cc8ab218
feature(resource-down-alarm): add resource down alarm
2020-08-22 15:27:11 +08:00
901573c6a5
fix(topic-metrics): fix the issue that the corresponding data is not properly cleaned up when unregistering ( #3679 )
2020-08-22 15:27:11 +08:00
f47e10e08a
feature(emqx_mod_rewrite): separate rewrite rules for pub and sub ( #3676 )
2020-08-22 15:27:11 +08:00
dbeabf3de0
refactor(telemetry): remove telemetry code from emqx core
2020-08-22 15:27:11 +08:00
9e5e6f2e98
fix(guid): compatible with OTP 23
2020-08-22 15:27:11 +08:00
a76be8e0fa
chore: fix the compilation error when there is "/" in the branch name
2020-08-22 15:27:11 +08:00
e37a70509b
feature(telemetry): support for collecting telemetry data and disable it by default ( #3653 )
2020-08-14 16:58:08 +08:00
98faa698f3
feature(quota): add quota confs to limit the number of message forwards
2020-08-14 16:58:08 +08:00
89377aeaa2
improve(type): refine the message header types
2020-08-14 16:58:08 +08:00
87780c1c1b
fix(static-cluster): fix the issue that static cluster failure caused by the wrong way of creating tables
2020-08-14 16:58:08 +08:00
aaf29ee164
fix(alarm): fix the issue that memory watermark were not set correctly
2020-07-31 18:07:20 +08:00
1ba4743213
refactor(alarm): new data structure and support regular cleaning of deactivated alarms
2020-07-31 18:07:20 +08:00
5676026e2a
fix(alarm): missing partition alarm
2020-07-31 18:07:20 +08:00
43b49edd28
feature(alarm): new design for alarm
2020-07-31 18:07:20 +08:00
0817761aee
fix(emqx_channel): EMQ X replaces MQTT properties when node connects using "topic-alias-maximum" property
2020-07-31 18:07:20 +08:00
00bc525d8e
refactor(add-log): log when subscription fails
2020-07-31 18:07:20 +08:00
83a2af812f
feat(ratelimit): refactor ratelimit
2020-07-31 18:07:20 +08:00
961e7b9818
chore: update app.src.script
2020-07-20 10:08:47 +08:00
492d224728
Auto-pull-request-on-2020-07-17 ( #3600 )
...
* refactor(channel): skip the ACL checking for inner subscribe
* fix(props): fix the prop_emqx_sys results of judgment
* Update esockd to 5.7.1
* test(topic-metrics): add test cases for topic metrics
* perf(emqx_vm): make emqx_vm:get_memory/0 more efficiency
2020-07-17 18:25:46 +08:00
211c800e24
fix(properties): downlink will msg contains non-publish properties
...
The paho test failed because the client received a will message
that has an `Will-Delay-Interval` property.
All the 7 allowed PUBLISH properties are listed as follows:
```
'Payload-Format-Indicator',
'Message-Expiry-Interval',
'Response-Topic',
'Correlation-Data',
'User-Property',
'Subscription-Identifier',
'Content-Type'
```
2020-06-21 11:27:22 +08:00
600b1055f3
fix(json): convert a proplists to ejson instead of map
2020-06-20 15:42:07 +08:00
1b6a586948
feature(mqtt): support response information ( #3533 )
2020-06-20 15:07:37 +08:00
8707afa54c
fix(enhanced_auth): fix bug when "conn_props = undefined"
2020-06-20 14:29:20 +08:00
9a8859a44c
refactor(topic): move triples/1 func into emqx_trie module
2020-06-18 17:38:34 +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
6ad65d587e
feature(properties): add properties in message header
...
1. Add MQTT5.0 properties when invoking the hooks.
- Add a new key `properties` into the message header:
We used to put all of the properties into the `#message.headers`:
```erlang
#message{headers = #{'User-Property' => {<<"reason">>,<<"normal">>},
'Message-Expiry-Interval' => 60,
allow_publish => true}
```
I put them instead under a single key:
```erlang
#message{headers = #{properties =>
#{'User-Property' => {<<"reason">>,<<"normal">>},
'Message-Expiry-Interval' => 60},
allow_publish => true}
```
Note that the column `properties` may contain all the properties for
Publish and Will messages.
- Add `disconn_props` into the `Channel.conninfo`
- Add `puback_props` also into the message header:
```erlang
#message{headers = #{puback_props =>
#{'User-Property' => {<<"reason">>,<<"normal">>}},
allow_publish => true}
```
2. Change the data type of `#message.headers` and `#message.flags` to map.
It used to support `undefined`.
2020-06-17 18:46:26 +08:00
ea2a424ce2
Add ensure/2 funcs to avoid needless logs ( #3483 )
2020-06-04 10:46:53 +08:00
f456f40c59
Subscribe or unsubscribe via HTTP API skip ACL checking
2020-06-04 10:45:58 +08:00
42fc81338c
Fix(modules): correct the bad return value for emqx_modules:load/0
2020-06-04 10:38:28 +08:00
3fb82f7234
Fix(connect): fix the race condition for openning session
...
- Remove the register_channel/1,2 functions
2020-06-02 17:21:06 +08:00
59f95f8421
Helpful message when no commands available
2020-05-23 09:41:25 +08:00
83b1f3e6c8
Fix unexpected packet before connected
2020-05-22 18:18:52 +08:00
18ae15ef9a
Fix typos
2020-05-21 17:51:22 +08:00
1f07700930
Print helpful messages when no commands available
2020-05-16 08:48:05 +08:00
80e2bd19b9
Fix case_clause in issue#3455
2020-05-12 10:39:22 +08:00
48d6acdb25
Replace peercert with cn/dn feilds in ClientInfo
2020-04-30 16:35:15 +08:00
c35a40a6b6
Fix some error for reauthentication
2020-04-28 11:48:07 +08:00
7ba801c8d4
Fix reload acl module and clean acl caches ( #3409 )
2020-04-26 15:45:55 +08:00
7cf97acddd
Delete expiried client
2020-04-26 15:38:29 +08:00
021520315a
Update enhanced auth hooks
2020-04-24 10:21:22 +08:00
b37c61fdb5
Merge pull request #3392 from emqx/print
...
Optimize cli print
2020-04-17 18:05:37 +08:00
5922f5358e
Merge pull request #3396 from emqx/add_hook_to_auth_packet
...
Add hook to auth packet
2020-04-17 18:05:25 +08:00
6cab60b6ab
Export emqx_modules:find_module/1
2020-04-17 11:02:40 +08:00
dccf3560f0
Add hook to auth packet
2020-04-16 16:07:01 +08:00
fb661b1d92
Support return all registered topics
2020-04-16 10:35:35 +08:00
eebc5e4b0a
Optimize cli print
2020-04-15 18:05:30 +08:00
e806a96031
Change timestamps to millisecond
2020-04-15 09:03:52 +08:00
9ba938b9d9
EMQX failed to start when the listening port was occupied ( #3354 )
2020-04-11 10:18:35 +08:00
d49f4118fe
Mgmt emqx modules ( #3376 )
2020-04-10 19:55:21 +08:00
d4932533ca
Auth packet ( #3374 )
2020-04-10 19:45:18 +08:00
1790cde942
Get client's addr/port from proxy header if enable proxy_protocol
2020-04-10 19:40:10 +08:00
49440bd2e3
Export functions
2020-03-27 18:22:59 +08:00
edb42b1b0f
Set topic alias on v5 only
2020-03-27 17:02:38 +08:00
792a14aaf7
Fix plugin test case
2020-03-27 15:31:11 +08:00
55a8b1b173
Support topic metrics ( #3341 )
...
Support topic metrics
2020-03-27 13:33:10 +08:00
78144c0ca5
Update error log ( #3342 )
...
Optimize content of error log
2020-03-27 10:10:23 +08:00
5eadca1782
Merge pull request #3335 from emqx/reload_plugin
...
Read new configuration items when plugins is loaded
2020-03-26 18:35:49 +08:00
5c5267c96b
Merge pull request #3327 from emqx/fix_json_encode
...
Fix emqx_json encode return types error
2020-03-26 18:33:16 +08:00
9e6966110d
Move emqx_delay_publish here ( #3323 )
...
Move emqx_delay_publish here
2020-03-26 18:32:24 +08:00
9398865741
Fix the issue that configuration was not loaded when plugin started
2020-03-25 10:30:08 +08:00
59adb9a652
Supports broker-to-client topic aliases ( #3325 )
2020-03-24 15:23:01 +08:00
2ab6ec418e
Add subscription option for proxy subscribing
2020-03-24 11:31:25 +08:00
3b537760d5
Read new configuration items when plugins is loaded
2020-03-23 15:23:38 +08:00
95baee8c8e
Fix emqx_json encode return types error
2020-03-21 13:38:48 +08:00
7e00b58db5
Remove the CONNACK's `Maximum-QoS` key if it equal to 2 ( #3321 )
2020-03-17 17:56:34 +08:00
b2e5b523dd
Change global_gc to major mode ( #3317 )
2020-03-17 14:28:58 +08:00
1221b8eb00
Force utf8 json encoding by default #3287
2020-03-11 11:18:12 +08:00
47720b906f
Fix `peer_cert_as_username` option not working
...
see #3281
2020-03-05 15:55:39 +08:00
ad7cbb4428
Fix einval after socket was closed
2020-03-05 14:28:12 +08:00
caed16f57b
Fix `acl_deny_action`
2020-03-05 14:27:41 +08:00
6b5a8949c5
Change rate limit pausing logs to warning
2020-03-02 18:26:37 +08:00
9b6a8ebe84
Fix emqx_json:to_ejson
2020-02-21 13:17:12 +08:00
3f6f0eca40
Add an option to allow client bypass auth plugins
2020-02-21 09:42:26 +08:00
f6b0ad8873
Ignore some discarded exceptions
2020-02-17 09:40:44 +08:00
f29a8b0d5c
Mqtt protocol tests ( #3237 )
...
Add more test cases for MQTT
2020-02-07 10:07:36 +08:00
839465fbd8
Enhance security
2020-02-07 09:19:21 +08:00
b9bdb03005
Decode/Encode json from nested proplist
2020-02-06 12:00:18 +08:00
368b85027e
Fix issue#3228
2020-02-04 16:30:38 +08:00
3c459e8e74
Compatible jsx encode/decode ( #3230 )
2020-02-04 16:18:19 +08:00
367398e965
Remove jsx from app.src
2020-01-19 19:41:13 +08:00
eea377eb8f
Replace 'jsx' with 'jiffy' and add more test cases
2020-01-19 16:58:51 +08:00
b3e2cc5a18
Replace 'jsx' with 'jiffy' to optimize json encode/decode
2020-01-19 16:58:51 +08:00
e17241884c
Send DISCONNECT packet for mqttv5 ( #3183 ) ( #3208 )
2020-01-17 19:48:39 +08:00
f4081b5885
Tune the global GC
2020-01-17 18:32:00 +08:00
7a2234c608
Improve emqx_mqtt_caps:get_caps/1 ( #3198 )
2020-01-17 16:29:46 +08:00
8734922abb
Fix rap handling and keep the value of retain flag in bridge mode ( #3189 )
2020-01-17 11:37:28 +08:00
2897e4fa06
Fix the bug that cannot add a second MQTT-WS TCP Port ( #3196 )
2020-01-17 10:08:34 +08:00
a318532bb0
Tuning the 'force_gc_policy' of MQTT connections ( #3192 )
...
Tuning the 'force_gc_policy' of MQTT connections
2020-01-17 09:42:16 +08:00
2b3003b323
Move the global GC server from 'emqx-recon' to 'emqx' project ( #3190 )
2020-01-16 23:45:17 +08:00
f6b2c9a69f
Correct timestamp for banned ( #3188 )
2020-01-16 23:11:19 +08:00
2ba624ac31
Add 'compose/1', 'compose/2' functions
2020-01-13 21:00:40 +08:00
fdeade3212
Add more test cases
2020-01-09 20:01:46 +08:00
b1a22931f4
Add testcase for takeover ( #3160 )
2020-01-09 12:26:24 +08:00
7d3a08dc13
Improve 'client.connect', 'client.connack' hooks ( #3153 )
2020-01-04 10:44:17 +08:00
6b8ffc386a
Fix WS reason code ( #3149 )
2020-01-04 10:06:50 +08:00
7ea75f4289
Update copyright
2020-01-03 18:31:08 +08:00
f33217c049
Fix unexpected timeout
2019-12-31 09:06:58 +08:00
597558fee8
Fix unexpected timeout
2019-12-30 21:27:47 +08:00
46ca3f2f82
Add metrics for session's lifecircle
...
- session.created
- session.resumed
- session.takeovered
- session.discarded
- session.terminated
2019-12-30 09:29:41 +08:00
12c6d5fe2c
Add more metrics for client's lifecircle
...
- client.connect
- client.connack
- client.connected
- client.authenticate
- client.check_acl
- client.subscribe
- client.unsubscribe
- client.disconnected
2019-12-30 09:28:55 +08:00
9a3d16c654
Add 'emqx_packet:info/2' function and test cases
2019-12-30 09:28:38 +08:00
b7ca3905a6
Breaking Change: Add new hooks for client and session lifecircle ( #3138 )
2019-12-27 16:31:06 +08:00
d000284a40
Merge branch 'caps' into develop
2019-12-21 16:04:41 +08:00
b612674ffa
Update emqx_mqtt_caps.erl
2019-12-21 14:16:37 +08:00
b3eed9123f
Fix typo
2019-12-21 10:39:02 +08:00
578355442b
Add more metrics and improve the 'channel', 'session' modules ( #3128 )
2019-12-20 21:47:32 +08:00
2cf3af12ef
Update test cases for emqx_connection ( #3116 )
2019-12-20 19:15:45 +08:00
116c593178
Fix returned value of plugin reloading ( #3126 )
2019-12-20 16:34:07 +08:00
9b9df46718
Add sockport to ClientInfo ( #3122 )
2019-12-19 13:34:24 +08:00
70ae3c75a0
Remove emqx_time module
2019-12-17 09:38:33 +08:00
eea5e14b0c
Fix event/message out of order
2019-12-16 22:12:56 +08:00
814f103e34
Fix issue#3109 - remove the 'sessions.persistent.count', 'sessions.persistent.max' stats
2019-12-16 16:41:42 +08:00
1f25f4439f
Remove the 'stop_reason' field
2019-12-16 12:45:46 +08:00
635c3f75fe
Improve the 'emqx_connection' module for CT
2019-12-16 11:25:47 +08:00
ad9e0fc311
Support the 'clean_start = false' websocket connection
2019-12-16 11:25:47 +08:00
2ef52828bc
Improve 'emqx_connection' module and update test cases
2019-12-16 11:25:47 +08:00
7ac60678de
Add test cases for emqx_cm and emqx_router_helper modules
2019-12-13 18:09:48 +08:00
c5c99b7c4e
Improve 'emqx_ws_connection' module and add more test cases
2019-12-13 18:07:59 +08:00
2a3baed7e0
Merge pull request #3103 from emqx/ws-conn-ct
...
Rename 'channel.gc.cnt' to 'channel.gc'
2019-12-13 18:04:54 +08:00
d193b5fa0d
Rename 'channel.gc.cnt' to 'channel.gc'
2019-12-11 20:39:51 +08:00
d1c3dec730
Optimize emqx_session and add more test cases
2019-12-11 13:44:52 +08:00
e30c0ac31d
Change log level for existing metric
2019-12-10 17:20:21 +08:00
ec2f758c9f
Use erlang:system_time/1
2019-12-10 09:25:39 +08:00
08e234f61e
Fix typo
2019-12-10 09:24:33 +08:00
0f9f1258b6
Improve the emqx_message module and add more test cases
...
- Add 'emqx_message:clean_dup/1' function
- Clean dup flag before publishing a message
- Add more test cases for emqx_message module
2019-12-10 09:22:38 +08:00
cd94ba71b4
Remove the 'try' ... 'catch'
2019-12-10 09:01:55 +08:00
0c377c67cd
Use 'erlang:system_time' to replace 'os:timestamp' ( #3088 )
...
Use 'erlang:system_time/1' to replace 'os:timestamp/0'
2019-12-09 16:27:25 +08:00
dace882667
Fix will message
2019-12-07 17:06:22 +08:00
dc3e7dc21c
Ignore the expired messages
2019-12-07 16:51:20 +08:00
bbcd2bffc5
Improve the session module ( #3082 )
...
Improve the session module
2019-12-07 15:54:02 +08:00
32500685a1
Export emqx_cm:kick_session/2
2019-12-07 13:35:55 +08:00
5b949fda2c
Add emqx_cm:kick_session/1
2019-12-07 13:31:33 +08:00
9c3273a2c6
Improve the process of handling MQTT control packets ( #3079 )
2019-12-06 19:51:06 +08:00
98b109b6b2
Merge pull request #3074 from emqx/emqx_desc
...
Add emqx.app.src.script
2019-12-05 18:01:24 +08:00
dceb087039
Format code
2019-12-04 13:54:59 +08:00
4b59db62fa
Optimize caps
2019-12-04 13:52:01 +08:00
691c6aa182
Add emqx.app.src.script
2019-12-04 13:50:31 +08:00
Zaiming Shi