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
a540958846
Add mqtt.strict_mode configuration ( #3069 )
...
Add mqtt.strict_mode configuration
2019-12-04 10:54:52 +08:00
8bf06b9c63
Fix typo
2019-11-23 10:53:27 +08:00
f44b8ce607
Avoid emqx crashes due to auth plugins ( #3047 )
...
Avoid emqx crashes due to auth plugins
2019-11-23 10:11:48 +08:00
790c729b1f
Optimize code
2019-11-21 16:26:50 +08:00
d7ddc406fa
Fix ConnInfo of client.connected hook
2019-11-21 15:01:57 +08:00
1af1fc4f6a
Fix the check of limiter
2019-11-18 11:51:58 +08:00
39dbb03629
Fix the 'undefined function' call
2019-11-18 11:11:20 +08:00
c9963b1df5
Replace esockd_net with inet
2019-11-18 10:58:15 +08:00
6288cd1345
Merge branch 'develop' into bump-version
2019-11-18 10:53:33 +08:00
d793c4256f
Merge pull request #3034 from emqx/rm-vm-module
...
Improve the emqx_vm module and update test cases
2019-11-18 10:51:54 +08:00
b10cd85ba3
Merge pull request #3033 from emqx/flapping2
...
Optimize flapping and banned modules
2019-11-18 10:50:35 +08:00
2ad701361d
Merge pull request #3031 from emqx/more_test_cases
...
Add more test cases
2019-11-18 10:49:56 +08:00
4935ba11a8
Upgrade deps to ekka v0.7.0 and esockd v5.6.0
2019-11-18 10:40:53 +08:00
73275a2b4d
Replace inflight with inflight_cnt in STATS_KEYS
2019-11-18 10:24:23 +08:00
17332b0465
Improve the emqx_vm module and update test cases
2019-11-14 10:40:55 +08:00
d3107facf9
Validate packet id if strict mode.
2019-11-14 09:46:56 +08:00
2fb4d66496
Optimize flapping and banned modules
2019-11-14 09:37:37 +08:00
1072536382
Add more test cases for emqx_sup
2019-11-13 18:30:02 +08:00
b22a1a87ba
Add more test case for emqx_plugins
2019-11-09 21:26:15 +08:00
f1ae430d43
Add more test cases for emqx_sys
2019-11-08 17:01:10 +08:00
df3d7b628b
Update emqx_ws_connection for clientinfo
2019-11-01 21:36:30 +08:00
3cc2bf2bfa
Merge branch 'develop' into make_test_cases_pass
2019-11-01 20:05:52 +08:00
0be06a93d6
Fix test cases
2019-11-01 18:38:30 +08:00
d946848d42
Improve testcases for emqx_logger
2019-11-01 18:21:46 +08:00
1a901942f7
Merge pull request #3007 from emqx/improve-connection
...
Improve the 'connection', 'channel' and 'zone' modules
2019-11-01 16:40:20 +08:00
81a507c6fa
Merge pull request #3012 from emqx/add_more_test_cases
...
Add more test cases
2019-11-01 16:40:00 +08:00
b3731aaff4
Merge pull request #3010 from emqx/test_cases_zhou
...
Add test cases and fix bugs
2019-11-01 16:29:00 +08:00
c5ad674dd7
Add test cases and fix bugs
2019-11-01 15:48:28 +08:00
2b1b58fc66
Add the new 'emqx_limiter' module
2019-11-01 08:10:58 +08:00
6f30dca4ba
Add more option APIs
2019-11-01 08:10:26 +08:00
d256387cee
Ensure the 'inc_sent/1', 'inc_recv/1' to return 'ok'
2019-11-01 08:09:45 +08:00
30adfc18e6
Remove 'gc_state' and 'pub_stats' from channel's state
2019-11-01 08:08:38 +08:00
605a03453e
Remove the 'emqx_time' module and use 'erlang:system_time/1'
2019-11-01 08:07:34 +08:00
223163d5b9
Remove the 'emqx_oom' module
2019-11-01 08:00:35 +08:00
4c9dda105f
Add 'active_n' option for WebSocket listener
2019-11-01 08:00:11 +08:00
971a361ea9
Add more test cases for emqx_logger and fix bug for emqx_logger
2019-10-29 14:27:47 +08:00
3405dbaf5c
Ordered messaging via multiple gen_rpc clients
2019-10-28 21:01:53 +08:00
f7d3c01308
Merge branch 'develop' into clean_acl_cache
2019-10-28 18:02:41 +08:00
c1d768ff74
Add API for clean and get acl cache
2019-10-28 17:53:53 +08:00
ebef0ec554
Add zone_options module
2019-10-28 07:51:09 +08:00
c713d619da
Add more test cases ( #2992 )
...
* Add more test cases for emqx_stats and emqx_os_mon
Fix test case error for emqx_ws_connection
* Add more test cases for emqx_sys_mon
* Update erlang otp to 22.1 for travis ci
* Delete readable=false for make ct
* Add unset_all_env for emqx_zone and update test cases
2019-10-24 15:41:26 +08:00
1dfbe8e166
Fix WS badmatch
2019-10-22 09:11:42 +08:00
fca7a7e761
Merge branch 'connection-test-using-meck' into develop
2019-10-21 19:53:53 +08:00
cb77b229b8
Add testcase for emqx_logger_formatter
2019-10-21 18:35:32 +08:00
7117dde879
Add more test cases for connection, channel and session modules
2019-10-21 17:14:50 +08:00
26eab630b3
Add test cases for emqx_channel module
2019-10-20 19:20:38 +08:00
aecda09b9a
Add more test cases
2019-10-19 20:18:34 +08:00
cd4adbada0
Add more test cases for connection, channel and session modules
2019-10-18 18:53:31 +08:00
53dda48833
Fix the 'function_clause' error when session is undefined
2019-10-14 17:01:41 +08:00
a1877f3f42
Return the '{enter, connected}' event first
2019-10-14 13:04:49 +08:00
6233aa7d46
Ensure the 'conn_state' be 'disconnected' after socket closed
2019-10-12 19:14:33 +08:00
932821360f
Merge branch 'new-connection-module' into develop
2019-10-12 17:08:48 +08:00
cce0dbd3cf
Improve the connection, ws_connection and channel modules
2019-10-12 17:05:37 +08:00
47a192ee34
Avoid process crash report for arbitrary exit reason
2019-10-12 14:48:39 +08:00
ebea3cc392
Defend the ssl upgrade failure
2019-10-12 09:34:28 +08:00
7512d6cb03
Check topic level for publish packet and optimize the handling of rap
2019-10-12 09:33:47 +08:00
0c37c65a59
Add a new type 'sockstate/0'
2019-10-10 13:59:34 +08:00
e718fa8249
Rewrite the 'emqx_connection' module using a raw erlang process
2019-10-08 17:59:11 +08:00
ddd68e600d
Fix missing cases
2019-09-29 15:32:53 +08:00
fe2a72c664
Add 'state' field to channel info
2019-09-29 11:47:31 +08:00
977b551bbf
Fix the test cases for session, channel and connection modules
2019-09-29 10:53:59 +08:00
8ab682151d
Improve the connection and channel modules
...
- Rename the 'client_id' field to 'clientid'
- Support publish stats in channel module
- Update test cases for frame and channel modules
2019-09-29 10:22:02 +08:00
7b1a80c265
Rename 'mailbox_len' to 'message_queue_len'
2019-09-27 20:26:54 +08:00
89b03eb9a6
Add function specs
2019-09-24 17:08:06 +08:00
609f442ea9
Add function 'get_counters/1'
2019-09-24 17:07:32 +08:00
20ddd498fc
Rename the 'client_id' field to 'clientid'
2019-09-24 17:06:25 +08:00
98b7e3d948
Rename the type 'client()' to 'client_info()'
...
- Rename tye type 'client()' to 'client_info()'
- Rename the 'client' field of channel to 'client_info'
- Fix the function specs
2019-09-21 15:27:05 +08:00
eb0826ef3f
Fix testcases for new object field protocol
2019-09-21 12:37:08 +08:00
18edf5cec3
Add protocol in client object
2019-09-21 12:20:20 +08:00
ab9d7232a9
Reset peerport
2019-09-20 22:57:01 +08:00
464746e9a5
Add peerport
2019-09-20 22:42:07 +08:00
0bd69ba059
Fix connack reason code when crash
2019-09-20 22:30:16 +08:00
b29ceb9f6b
Fix connack reason code when crash
2019-09-20 22:27:02 +08:00
d0908bc70f
Improve the pipeline error msg
2019-09-20 21:40:15 +08:00
9e1f1b22c3
Fix typo
2019-09-20 21:35:02 +08:00
1decab9369
Fix channel crash before CONNECT
2019-09-20 21:30:18 +08:00
db1cf4469b
Fix crash
2019-09-20 20:27:08 +08:00
b72a82e50b
Merge pull request #2919 from emqx/fix-test-cases
...
Add 'unregister_channel/1' function and test cases
2019-09-20 19:57:47 +08:00
d0a8086d73
Add 'unregister_channel/1' function and test cases
2019-09-20 19:42:59 +08:00
4d214fb6e2
Fix session not saved after maybe_resume_session
2019-09-20 18:28:44 +08:00
f0a1ffc3b1
Fix test case
2019-09-20 17:58:31 +08:00
6aac73f51f
Fix the test case 't_handle_disconnect'
2019-09-20 16:48:21 +08:00
a9daa3c821
Fix the merge conflicts
2019-09-20 16:38:02 +08:00
b5c9def06a
Add testcases for print and usage
2019-09-20 16:18:24 +08:00
1a3261b186
Merge branch 'develop' into remove-protocol-module
2019-09-20 16:17:44 +08:00
24bfaa768d
Call emqx_flapping:detect and generate alarm when flapping is detected
2019-09-20 15:01:51 +08:00
a9dd94b2b5
Improve mechanism of waiting for session to expire
2019-09-20 15:01:51 +08:00
bd33441720
Fix the type specs for cmd usage
2019-09-20 14:55:11 +08:00
3202ed2392
Improve the 'channel' module and add more test cases
...
- Rename the 'Client' field to 'ClientInfo'
- Remove the 'expiry_interval' from session record
- Add more test cases for emqx_zone module
- Add more test cases for emqx_banned module
- Add more test cases for emqx_message module
- Remove 'sockname', 'conn_mod' fields from type 'client'
2019-09-20 14:38:16 +08:00
81e2f47126
Add test cases for emqx_ctl module
2019-09-20 13:47:05 +08:00
3d6b96d321
Add function 'get_flags/1' for test
2019-09-19 11:19:10 +08:00
65cb9dbf38
Add test cases for 'reason/1'
2019-09-19 11:16:13 +08:00
3705f4f929
Rewrite the test cases for extended modules
2019-09-19 11:04:29 +08:00
1d429dad8d
Update the 'attrs/1' and 'handle_timeout/3' functions
2019-09-18 20:01:22 +08:00
981afd38e3
Rewrite the 'presence' extended module
2019-09-18 19:58:12 +08:00
8404fce6a6
Remove the function 'update_expiry_interval/2'
2019-09-18 19:49:34 +08:00
a313d1c722
Improve the 'open_session/3' API
2019-09-18 19:48:55 +08:00
94c324d7a3
Rename 'get|set_property' fuctions to 'get|set'
2019-09-18 19:47:44 +08:00
cc79802d6c
Add function 'get_caps/3'
2019-09-18 19:46:18 +08:00
ad7e0ae436
Use 'peerhost' to replace 'peername'
2019-09-18 19:44:28 +08:00
c8acd55afa
Export type 'opts/0'
2019-09-18 19:19:42 +08:00
50f392b295
Add more functions
2019-09-18 19:18:56 +08:00
00f3a2f939
Use 'peerhost' to replace 'peername'
2019-09-18 19:17:30 +08:00
decdce2ae2
Fix unused variable
2019-09-16 18:54:34 +08:00
600cd11f1f
Rename connection to conninfo
2019-09-16 17:22:50 +08:00
1667cbd359
Fix test cases
2019-09-16 16:05:06 +08:00
fc553b8cee
Merge pull request #2803 from emqx/fix_msg_expiry
...
Fix Message-Expiry-Interval not working
2019-09-16 14:45:22 +08:00
4764a7707c
Rewrite the emqx_packet module and improve channel pipeline ( #2903 )
...
Add use_username_as_clientid/1 function and Improve function 'pipeline/3'
2019-09-16 14:17:36 +08:00
681ae511a8
Introduce the 'strict_mode' option and validate MQTT header ( #2898 )
...
Introduce the 'strict_mode' option and validate MQTT header
2019-09-16 14:02:31 +08:00
35822ff97a
Fix handling for MQTT spec ( #2892 )
...
Fix invalid QoS and protocol name, fix handling for Topic-Alias-Maximum and Maximum-Packet-Size, and send DISCONNECT Packet to client when the session is taken over
2019-09-16 13:51:50 +08:00
59309e6c11
Add print and usage APIs for CLI ( #2893 )
2019-09-12 09:35:05 +08:00
80621ec9be
Fix the test cases for emqx_banned, emqx_flapping modules
...
- Remove the 'is_enabled/1' function of 'emqx_banned' module
- Remove the 'is_enabled/1' function of 'emqx_flapping' module
- Add 'enable_acl/1', 'enable_banned/1' and 'enable_flapping_detect/1'
2019-09-11 09:14:58 +08:00
fa516626a6
Inlining is enabled for encode, decode functions.
2019-09-11 09:13:42 +08:00
594153c0fb
Merge branch 'boot' into develop
2019-09-10 16:26:20 +08:00
2bf951d953
Fix the spec of function 'is_enabled/1'
2019-09-10 16:24:38 +08:00
a3daa533e7
Add a test case for the new flapping module
2019-09-10 16:20:56 +08:00
0a1679b122
Implement a new flapping module ( #2884 )
2019-09-10 15:21:08 +08:00
88321fe6fe
Remove the emqx_config module
...
- Remove the emqx_config module
- Move get_env/1, get_env/2 to emqx module
2019-09-09 10:18:10 +08:00
6972cbb36e
Fix the operator precedence bug
2019-09-06 19:04:11 +08:00
b97f04ceae
Add emqx_boot module
2019-09-06 17:37:50 +08:00
6e18f8543d
Add emqx_boot module
2019-09-06 17:36:13 +08:00
5a3645c97e
Remove proto_ver field stored in the headers of message
2019-09-06 14:51:52 +08:00
3038bd4570
Add support for logger per module filtering ( #2873 )
...
Add mfa to the meta data to suppor the Erlang Logger's per module / per app filtering
2019-09-06 11:03:47 +08:00
066763248c
Fix dup flag
2019-09-05 18:35:29 +08:00
de44a89c21
Fix the issue that protocol is undefined
2019-09-05 18:28:17 +08:00
1e4c51f080
Send DISCONNECT on packet parse error
2019-09-05 18:16:15 +08:00
cc4ee065a4
Remove debug print
2019-09-05 16:16:19 +08:00
983973c841
Fix set_chan_stats incorrect
2019-09-05 15:59:18 +08:00
451f0451ce
Add type/1, qos/1 functions
2019-09-05 15:00:54 +08:00
847375d2fb
Improve connection and channel modules ( #2860 )
...
Improve the connection and channel modules
2019-09-05 14:17:15 +08:00
811e85f8b7
Merge pull request #2841 from emqx/init_stats
...
Set stats at connection time
2019-09-05 14:03:51 +08:00
2d6c7e41a5
Remove emqx_cli module
2019-09-02 09:04:34 +08:00
62f0f0ccbc
Add more test cases for 'emqx_misc' module
2019-08-28 14:29:44 +08:00
08ab350fec
Move the 'pipeline' function to 'emqx_misc' module
2019-08-28 14:29:44 +08:00
783e29d6f7
Add test case for emqx_mod_rewrite
2019-08-28 11:19:51 +08:00
a4e9142979
Updat app file
2019-08-27 09:27:25 +08:00
98072dd3d1
Set stats at connection time
2019-08-26 16:43:08 +08:00
29d49b4073
Fix get connected_at is undefined
2019-08-23 20:37:04 +08:00
5cfd8b74bc
Fix a bug that crash when protocol is undefined
2019-08-23 17:29:48 +08:00
9c171f5d9c
Fix a bug that session terminates immediately when received DISCONNECT packet
2019-08-23 16:08:26 +08:00
970d243d94
Fix function clause
2019-08-23 15:23:00 +08:00
7151ae9823
Merge pull request #2836 from emqx/fix-discard
...
Fix case clause error
2019-08-23 15:18:24 +08:00
710302f377
Fix case clause error
2019-08-23 14:52:11 +08:00
ebc1bd77a9
Send the will message immediately when the network connection is closed by the client ( #2834 )
...
Send the will message immediately when the network connection is closed by the client
2019-08-23 14:41:52 +08:00
738145677a
Handle the 'discard' cast.
2019-08-23 14:31:33 +08:00
9f7cc80c1a
Merge pull request #2833 from emqx/update_code
...
Update emqx_channel.erl
2019-08-23 14:09:42 +08:00
82b9a7c301
Improve session takeover ( #2831 )
...
Implement the session takover/resumption across nodes
2019-08-23 14:09:00 +08:00
44d53ecb33
Update emqx_channel.erl
2019-08-23 13:48:17 +08:00
f3a92f35f6
Handle will message correctly
2019-08-23 13:37:35 +08:00
cff120c6d0
Handle session expiry interval correctly
2019-08-23 13:37:35 +08:00
8710df31b2
Monitor cluster partition event ( #2814 )
2019-08-23 09:42:55 +08:00
c69a2b1b48
Ensure session expiration ( #2825 )
...
Ensure session expiration
2019-08-23 09:35:29 +08:00
41e9dad70a
Rename `reason` field to `stop_reason`
2019-08-22 23:24:16 +08:00
7454e46934
Fix compile error
2019-08-22 16:59:13 +08:00
8b03371a4a
Improve the keepalive, connection, channel and session modules ( #2813 )
2019-08-22 16:38:25 +08:00
bf942e4bec
Handle the retained flag correctly ( #2811 )
...
Handle the retained flag correctly
2019-08-22 16:21:27 +08:00
201428279b
Merge pull request #2817 from emqx/test_emqx_config
...
Remove redundant code and add test case
2019-08-22 16:13:50 +08:00
3f20bcf58f
Relace emqx_client with emqtt
2019-08-22 14:27:29 +08:00
94c56b5e31
Remove redundant code and add test case
2019-08-21 14:12:34 +08:00
749ef823ab
Refix code about mqtt spec ( #2806 )
...
Refix code about mqtt spec
2019-08-19 10:50:52 +08:00
f2b552e29e
Ensure stats timer
2019-08-19 09:43:58 +08:00
ae33b6037e
Fix the test suites.
2019-08-17 14:39:04 +08:00
52b2f31ced
Merge branch 'improve-channel-design-again' into develop
2019-08-17 14:09:26 +08:00
f26505d40a
Implement session takeover and resumption.
...
- Implement session takeover
- Remove `init_proc_mng_policy/1' from emqx_misc module
- Remove `conn_proc_mng_policy/1' from emqx_misc module
- Add `emqx_oom' module to monitor OOM of channel process
2019-08-17 13:37:48 +08:00
c1fd5f89f1
Make codes compliance with mqtt protocol specifications ( #2790 )
...
* Make codes compliance with mqtt protocol specifications
* Fix test case
* Remove emqx_protocol:puback/4
2019-08-17 09:15:43 +08:00
fa1adf5cfb
Fix Message-Expiry-Interval not working
2019-08-16 18:27:22 +08:00
2e26cd244a
Improve test coverage ( #2799 )
...
* Improve test coverage
* Improve test coverage for emqx_cm
* Improve test coverage for emqx_cm_registry
* Fix emqx_client_SUITE
2019-08-16 18:25:49 +08:00
d63eccd8b8
Add test cases for emqx_keepalive module ( #2784 )
...
* Improve the keepalive module
2019-08-16 18:24:39 +08:00
79744af681
Wrapper proper test cases into common test cases ( #2785 )
...
* Wrapper proper test cases into common test cases
* Improve test cases for reason code module (#2789 )
* Split 3 proper tests into 3 ct cases
* Improve test cases for client, rpc and request-response
* Add psk suites to increase coverage
* Add sys test cases
2019-08-16 18:07:12 +08:00
8e401968f2
Add testcase for emqx_mod_sup
2019-08-16 17:48:37 +08:00
b2ddcb26e2
Testcase logf ( #2800 )
...
* Add test cases for logger formatter
* Remove the unregister API
2019-08-16 15:11:38 +08:00
444972968f
Improve emqx_mqtt_props module and add test cases
2019-08-12 14:29:38 +08:00
c2cd43ee18
Fix attrs
2019-08-10 00:37:45 +08:00
0c24bfd78c
Make emqx_tracer more reliable
2019-08-09 19:59:39 +08:00
f6d6f7f04d
Fix test case
2019-08-09 19:45:43 +08:00
77616f4721
Add hook client.disconnected
2019-08-09 19:25:14 +08:00
a19777c2e6
Add hook message.acked
2019-08-09 19:12:56 +08:00
a93f8c6788
Fix auth fail
2019-08-09 17:37:55 +08:00
31cc446818
Mountpoint support %c and %u
2019-08-09 16:54:49 +08:00
91a8dbda56
Fix conflicts
2019-08-09 16:41:11 +08:00
d8bcb1b26f
Don't check cpu util on Alpine that uses libc-musl
2019-08-09 16:10:30 +08:00
6e0a269ff6
Wrap `os:type` for cpu:sup call
2019-08-09 16:04:38 +08:00
439c481e35
Remove the trap_exit process_flag ( #2737 )
2019-08-09 16:02:50 +08:00
68bf72ce04
Fix crashes when auth failed ( #2736 )
2019-08-09 16:02:04 +08:00
cca725db5f
Add specs for emqx_logger
2019-08-09 15:47:20 +08:00
3032731a2d
Publish will msg when abnormal terminate
2019-08-09 15:28:47 +08:00
03744ead30
Ensure the 'CONNACK' and 'DISCONNECT' packets delivered.
2019-08-09 15:09:17 +08:00
52a85d9bb9
Export name/1
2019-08-09 15:09:17 +08:00
a324965240
Add more test cases for emqx_protocol module
2019-08-09 14:29:49 +08:00
abb4b07665
Add session proper test cases ( #2768 )
...
* Add session proper test cases
* Remove useless mockers
2019-08-09 14:15:34 +08:00
61ee889113
Fix client bug
2019-08-09 13:40:07 +08:00
916afc1c74
Add test cases for emqx_protocol module
...
- Add emqx_session:info/2 for unit tests
- Add emqx_protocol:set/3 for unit tests
- Fix the `check_sub/3` of emqx_mqtt_caps
2019-08-09 11:33:52 +08:00
a2d5b834da
Improve emqx_pmon module and add more test cases
2019-08-08 22:42:45 +08:00
6513a32d37
Merge pull request #2766 from emqx/improve-mqtt-caps-module
...
Improve mqtt caps module
2019-08-08 22:35:32 +08:00
f70da696f0
Fix the badmatch error
2019-08-08 22:33:40 +08:00
1707c7a7b7
Remove replayq from app.src list
2019-08-08 17:08:19 +08:00
0d65deb9d3
Fix not registering channels in time
2019-08-08 16:59:17 +08:00
bd061415c9
Rewrite the emqx_mqtt_caps module and add test cases
...
- Rename `mqtt_retain_available` to `retain_available`
- Rename `mqtt_wildcard_subscription` to `wildcard_subscription`
- Rename `mqtt_shared_subscription` to `shared_subscription`
- Add `emqx_zone:unset_env/2` API for unit test
2019-08-08 14:11:26 +08:00
bfd027cf8b
Rewrite the mqtt_caps module
2019-08-07 14:01:50 +08:00
96b341fde5
Add proper tests for base62 ( #2761 )
...
* Add proper tests for base62
* Delete useless comment
2019-08-07 09:24:03 +08:00
f60f127681
Improve the moudules and fix the bugs found in new test cases
...
- Fix the bug that emqx_mountpoint:unmount/2 will throw exception
- Add emqx_banned:info/1 for test cases
- Rename macro TRIE in emqx_trie module to TRIE_TAB
- Rename macro TRIE_NODE in emqx_trie module to TRIE_NODE_TAB
- Rename macro ROUTE in emqx_router module to ROUTE_TAB
2019-08-06 09:05:55 +08:00
4afa02ee48
Update all the test cases
2019-08-06 09:04:37 +08:00
f8e28e39ed
Improve the channel modules and fix the extension mods
2019-08-02 18:04:38 +08:00
32795321f5
Improve the rewrite mod using the new hooks
2019-08-02 11:14:42 +08:00
cf9caf3c32
Add conn/0 type
2019-08-02 11:14:42 +08:00
2fdda99d6d
Improve the pipeline design of protocol and session
2019-08-02 11:14:42 +08:00
ef9cbe51eb
Fix conflict
2019-08-02 10:41:46 +08:00
c95a89ed1e
Merge branch 'nchannel' into develop
2019-07-31 14:03:48 +08:00
0a6468cf48
Introduce the 'pipeline' design pattern
...
- Introduce the 'pipeline' design pattern in emqx_protocol module
- Reame the '{dispatch, ...' to '{deliver, ...' in emqx_broker module
- Rename type 'credentials' to 'client'
2019-07-31 08:09:47 +08:00
b32156bd68
Rename the type 'credentials' to 'client'
2019-07-31 08:08:11 +08:00
41dfbd4165
Add 'packets.pubrec.inuse' counter
2019-07-30 19:12:42 +08:00
c880668419
Register channel in this module
2019-07-30 19:11:21 +08:00
51fb4e33d6
Rename 'Credentials' to 'Client'
2019-07-30 19:10:38 +08:00
20a7ed6f53
RPC batch
2019-07-29 09:35:06 +08:00
c55ada3526
Improve the types
2019-07-27 23:24:38 +08:00
d99c9daf76
Replace credentials with client
2019-07-27 23:22:02 +08:00
b0e2b7db0c
Support inter-node messages via RPC cast
2019-07-27 12:59:07 +08:00
11fdf101f0
Configurable rpc client number
2019-07-26 15:13:58 +08:00
32b2a01d68
Fix function_clause error and improve ws channel
2019-07-26 00:18:25 +08:00
64148ac0e8
Improve the 'info/1', 'attrs/1' and 'stats/1' APIs
2019-07-25 09:26:36 +08:00
b4a0a1c228
Fix whitespace
2019-07-25 09:26:02 +08:00
5b3a61b799
Merge the connection and session tabs into channel tab
2019-07-25 09:25:45 +08:00
a0a2375810
Update the .app file
2019-07-25 09:25:00 +08:00
2de4bb0b8f
Improve the channel modules and add 'attrs/1' API
2019-07-25 09:24:10 +08:00
c091e89796
Remove the unnecessary include/emqx_client.hrl
2019-07-23 10:56:14 +08:00
6b84eb0595
Rewrite the channel, protocol and session modules.
2019-07-22 17:08:53 +08:00
0569388f0f
Fix websocket still send willmsg even after disconnect is received
2019-07-20 19:02:49 +08:00
4559b5023e
Fix heartbeat interval
2019-07-20 16:20:53 +08:00
721e7c4804
Fix session termiated without ws_channel
2019-07-20 14:24:15 +08:00
0c54d899da
Trap and handle exit in channel and ws_channel
2019-07-20 13:19:13 +08:00
05b660ff50
Unlink session when exit message has been forwarded to session ( #2703 )
...
* Unlink session when exit message has been forwarded to session
* Readjust possition of emqx_protocol:session
2019-07-20 13:05:34 +08:00
eb68ce77b6
Fix the ws channel terminating crash when session pid is undefined
2019-07-19 17:36:50 +08:00
391e39c3b6
Disable the useless error log info
2019-07-19 17:36:50 +08:00
0c14484b0a
Disable the useless error log info
2019-07-19 17:36:50 +08:00
953d320667
Implement better websocket exit mechanism
2019-07-19 17:36:50 +08:00
86333802b9
Add configuration for sys_heartbeat
2019-07-19 17:33:24 +08:00
4603ea17ef
Better gen_rpc performance
2019-07-19 17:31:15 +08:00
eb7ae13ae9
Better exit reason in websocket channel
2019-07-16 01:33:15 +08:00
1fc0f61fbb
Fix the websocket normal exit bug
2019-07-16 01:09:42 +08:00
7b27d49a40
Add new metric 'channel.gc.cnt'
2019-07-14 08:59:38 +08:00
7472e531b1
Remove log handler for alarms
2019-07-11 13:27:03 +08:00
1bf68f4807
Change clear alarms to info log
2019-07-11 11:15:23 +08:00
bf89646d93
Fix typo
2019-07-11 09:43:52 +08:00
234037aee1
Fix will message mechanism for websocket channel
2019-07-11 09:43:52 +08:00
c13e194838
Fix the check_subacl bug when enable_acl is set to false
2019-07-11 09:25:20 +08:00
5867b2e763
Fix idle_timeout crash
2019-07-11 09:17:23 +08:00
6ab9527603
Optimize to_map for performance
2019-07-05 23:14:27 +08:00
70be888f3b
Compat windows ( #2665 )
2019-07-05 23:10:13 +08:00
61d64cbb83
Fix the issue that emqx_session:attrs/1 returns wrong value
2019-07-05 22:54:57 +08:00
f4a753f683
Remove the debug print of batch deliver
2019-07-02 14:50:13 +08:00
8c37ea3f38
Fix conflict
2019-07-02 14:02:42 +08:00
42da51e1c5
Implement batch delivery for the new channel design
...
- Implement a new emqx_channel module
- Improve the emqx_frame:serialize/2 API
- Improve the emqx_connection, emqx_ws_connection modules
2019-07-02 13:40:52 +08:00
177dc44155
Define 'Otherwise' macro
2019-07-02 13:39:23 +08:00
3ad5700442
Support getting the history of alarms
2019-06-29 12:38:57 +08:00
96fff39535
Change default logger level to warning
2019-06-28 21:34:21 +08:00
0e2e4e73ca
Clean staled sesssions
2019-06-26 20:04:32 +08:00
9df6345a6c
Remove bridge functions from emqx ( #2652 )
...
* Remove bridge functions from emqx
2019-06-26 19:33:17 +08:00
0b116bc208
Fix the massages order when batch dispatching
2019-06-26 19:32:15 +08:00
9ee0a4d171
Fix the function_clause error when publishing QoS2 message
2019-06-25 17:35:58 +08:00
67b7266438
Rename TimerInterval to Interval
2019-06-25 15:58:09 +08:00
f32a415a83
Merge branch 'channel3'
2019-06-25 15:55:31 +08:00
4974eab20e
Improve the channel design
2019-06-25 14:53:45 +08:00
c4eb283517
Add spec for validate/1 function
2019-06-25 14:50:51 +08:00
242a1ae453
Use emqx_mqtt:qos() type
2019-06-25 14:47:42 +08:00
72331d8ad0
Move emqx_mqtt_types module to emqx_mqtt
2019-06-25 14:46:21 +08:00
fb54fe0fad
Improve export_type attr
2019-06-25 14:45:23 +08:00
795fe4e0bc
Add 'PUBLISH_PACKET(QoS, Topic, PacketId)' macro
2019-06-25 14:29:26 +08:00
475cabde4d
Fix issue#2619 ( #2646 )
...
* Fix issue#2619
Prior to this change, websocket connection would not be disconnected
when dataframe type is other frametype. However, in mqtt spec, it
shoud be disconnected.
This change fix this inconsistent behaviour with mqtt 5.0
2019-06-21 21:21:49 +08:00
481458d8ec
Add plugin type
2019-06-21 19:52:53 +08:00
0c7c4ee417
Using fixed topic for system message of alarm ( #2647 )
...
* Using fixed topic for system message of alarm
2019-06-21 19:51:58 +08:00
37eef7b72a
Add 'auth.mqtt.anonymous' metric ( #2631 )
...
* Add 'auth.mqtt.anonymous' metric
2019-06-21 19:21:26 +08:00
138d7727fa
Compact windows platform which has no cpu_sup util function. ( #2629 )
...
* Compact windows platform which has no cpu_sup util function.
* Fix wrong os type clause
* Do not start timer when platform is windows
2019-06-20 11:45:44 +08:00
1d23d7de86
Optimize test workflow ( #2642 )
...
* Optimize test suites workflow
* Better format of makefile
* Fix protocol suite
* Add emqx_access_SUITE
2019-06-20 11:44:44 +08:00
bcae452e42
Fix the flapping bug
...
Prior to this change, the banned until value will not be set
correctly because of wrong spell of config entry name .
This change fix this bug
2019-06-20 10:59:42 +08:00
ffbb598a73
Increase time precision for emqx_mod_presence
2019-06-20 09:50:05 +08:00
3877c4db1a
Merge branch 'channel2' into channel3
2019-06-18 16:49:26 +08:00
7774b85f81
Implement the channel architecture
2019-06-18 15:03:51 +08:00
09dd65b9fa
Add logger header validation
2019-06-18 14:37:32 +08:00
7092748266
Improve log messages using logger header
2019-06-18 14:37:32 +08:00
c64751a53c
Support module level logger header
2019-06-18 14:37:32 +08:00
21162f88b8
Update copyright
2019-06-18 14:27:06 +08:00
d065847665
Remove session record
2019-06-16 10:28:23 +08:00
3f1b788fe8
Remove unused PSK TAB macro
2019-06-14 16:58:46 +08:00
19822c15bd
Add websocket_info to match {stop, Reason} msg
2019-06-14 16:22:57 +08:00
1d88f8fd9e
Improve the emqx_connection, emqx_ws_connection and emqx_frame modules ( #2611 )
...
* Adopt channel architecture and improve the MQTT frame parser
* Update the test cases for emqx_channel, emqx_protocol
- Improve emqx_client to Use the new emqx_frame:parse/2
- Update the ct suites for emqx_channel, emqx_ws_channel
* Fix test case
2019-06-14 12:44:27 +08:00
d3e7d1f0c9
Fix websocket bug ( #2615 )
...
Fix websocket bug.
Prior to this change, websocket connection would be closed directly
without sending connack packet when acl check fails.
This change fix this bug.
2019-06-14 11:33:44 +08:00
a3103cec7b
Revert "Fix websocket bug. Prior to this change, websocket connection would be closed directly without sending connack packet when acl check fails."
...
This reverts commit e73c4c64d0
2019-06-12 15:51:20 +08:00
e73c4c64d0
Fix websocket bug.
...
Prior to this change, websocket connection would be closed directly
without sending connack packet when acl check fails.
This change fix this bug.
2019-06-12 15:49:48 +08:00
76525cc703
Fix acl deny action logic ( #2613 )
2019-06-12 15:49:18 +08:00
3462bbd619
Fix retain in will message ( #2607 )
...
* Fix retain in will message
* Only handle retain available flag in MQTT v5
2019-06-12 15:43:52 +08:00
de978d4771
Update the test cases for emqx_channel, emqx_protocol
...
- Improve emqx_client to Use the new emqx_frame:parse/2
- Update the ct suites for emqx_channel, emqx_ws_channel
2019-06-12 10:31:44 +08:00
d386b27e8a
Adopt channel architecture and improve the MQTT frame parser
2019-06-11 23:18:38 +08:00
f801ff1e53
Optimize metrics using counters and persistent_term ( #2597 )
...
* Optimize emqx_metrics module using persistent_term and counters in OTP 22
2019-06-05 23:16:35 +08:00
f46205daff
Restart mnesia application
2019-06-05 11:50:09 +08:00
f3fcd16dee
Fix wrong default value in protocol module
2019-06-03 16:25:04 +08:00
e7cd32edb7
Update esockd deps and fix compile warning
2019-05-31 15:21:59 +08:00
47f9d0e90f
Adjust format
2019-05-31 11:16:50 +08:00
365832f945
Use new ranch api to elimate warning log for deprecated apis
2019-05-31 11:16:50 +08:00
9715234626
Optimize the emqx_zone module using persistent_term
...
- Don't reload the zone options for updating persistent_term is
expensive
- Use '{?MODULE, Zone, Key}' as the key to avoid name collision
2019-05-31 08:53:42 +08:00
be7de756c6
Stop alarm before emqx stops
2019-05-28 17:11:31 +08:00
0857b976ed
Better zone ( #2548 )
2019-05-25 22:29:23 +08:00
87ffa77ade
Fix lookup_session_pids return data type error
2019-05-25 22:28:34 +08:00
54f2a768a8
Rm start logger:set_primary_config
2019-05-23 10:51:21 +08:00
1c83270184
Add case clause for emqx_sn and emqx_coap plugin
2019-05-21 11:19:52 +08:00
caa582a028
Revert the PR #2355
...
- Add anonymous field for credentials
2019-05-15 15:04:27 +08:00
1a92f3259f
Enable cert_as_username to pass value to username_as_clientid ( #2536 )
2019-05-15 10:20:04 +08:00
79c1b7eb78
Put sockname to credentials ( #2532 )
...
* Add sockname to credentials
* Explicit credentials type define
2019-05-14 10:22:30 +08:00
97cca1a5ba
Set {active, N} for ssl connection ( #2531 )
2019-05-13 10:18:01 +08:00
311f1e6df1
Merge pull request #2521 from emqx/develop-3.2
2019-05-09 11:16:14 +08:00
fc6f54602d
Fix plugin load bug
2019-05-08 14:23:12 +08:00
7e0ac5bd34
Fix bad config type of long_gc ( #2504 )
2019-05-08 10:19:49 +08:00
a1eb7ca7d2
Adapt max-heap-size to Arch-32 systems
...
The erlang:process_flag(max_heap_size, MaxHeapSize) can only set a MaxHeapSize of `small integer`, which is smaller than 2^59 on 64-bit systems, and 2^27 on 32-bit systems.
2019-05-07 17:27:06 +08:00
b4c659fb54
Add suboptions for stats ( #2507 )
2019-05-06 19:17:54 +08:00
3ece73b912
Reuse plugin filter logic to adapt to emqx rebar3 release
2019-05-06 13:34:55 +08:00
ea83d2087c
Optimize log configuration
2019-05-05 14:35:43 +08:00
c5524e99c6
Rm emqx_rate_limiter module
2019-04-25 14:29:20 +08:00
eaa1deab20
Refactor flapping code ( #2476 )
...
* Refactor flapping code
2019-04-24 10:42:26 +08:00
bcbb4b68e9
Add flapping detect feature
2019-04-19 16:34:33 +08:00
5680b191ee
Extend status api
2019-04-18 14:12:06 +08:00
94aa173858
Fix bugs of keepalive value init of emqx_client ( #2443 )
...
Fix bugs of keepalive value init of emqx_client
2019-04-17 10:43:20 +08:00
f1616c33d9
Convert value of attribute table to map
2019-04-13 10:35:59 +08:00
81ef5b9b8d
Support cookie based auth
2019-04-12 19:25:22 +08:00
4d2bc48822
Redesign ensure_start and ensure_stop api of bridge
2019-04-11 18:17:30 +08:00
4fc81cef85
Change log level unexpected info in client ( #2422 )
...
Change log level for unexpected info in client and rejust code format in emqx_bridge
2019-04-11 12:20:32 +08:00
6a4c318acb
Update metrics when session process terminates
2019-04-11 10:08:26 +08:00
a53320069b
Fix trace logger level not work ( #2408 )
...
* Fix trace logger level not work #2385
2019-04-10 09:14:53 +08:00
eb7b1797c2
Provide bridge handler to extense emqx_bridge
2019-04-09 19:03:07 +08:00
627ea0afe8
Add `is_bridge_exist` api in emqx_bridge_sup
2019-04-09 11:40:36 +08:00
8cfd080a97
Fix gen_statem:reply/2 bug in emqx_client module
...
Prior to this change, the arguments passed to gen_statem:reply is bad
args, first arg should be a tuple, but it is a pid. So it would
trigger crash.
This change fix this bug.
2019-04-08 11:50:28 +08:00
7e6255d4ee
Set default websocket idle timeout to 2 hour
2019-04-04 17:42:52 +08:00
e917c025d0
Fix LOG on line 231
2019-04-04 17:38:36 +08:00
aad2d7378e
Put peername into messsage headers ( #2390 )
...
* Put peername into the message.heaers
2019-04-04 13:41:03 +08:00
287c5582a9
Fix compilation warning
2019-04-03 20:49:45 +08:00
15f8d3208f
Fix message dropped
...
Prior to this change, when store_qos0 option is set to false, the hook
`message.dropped` would not be triggered. It is wrong design and when
the ignore_loop is enabled or nl is set to 1, the hook
`message.dropped` also would not be triggered.
2019-04-03 20:33:58 +08:00
2306789755
Remove bin_key_map/1 ( #2393 )
...
* Remove bin_key_map/1
* Fix Travis-CI failure
2019-04-03 19:41:21 +08:00
55d2d1d278
Allow boolean flag for loaded plugins
...
This is to simplify config templating
2019-04-03 19:35:24 +08:00
60c2b8bc08
Add more functions to read fields of 'message' record
...
- Add id/1, topic/1, from/1, payload/1 and timestamp/1 functions
- Improve the test cases
2019-04-02 15:15:13 +08:00
2d2520627a
Fix topic 'datatype' to 'datetime'
2019-04-01 11:37:22 +08:00
0c64da6da7
Change default log level from info to critical when shutdown
2019-03-29 10:57:52 +08:00
b6fa4d2a3f
Fix bridge subscribe bugs
2019-03-29 10:19:11 +08:00
f14a56eb17
Fix acl bug in subscribe
2019-03-28 14:04:04 +08:00
114b28f973
Delete function clause which would reply {error,standing_by}
2019-03-28 11:47:29 +08:00
0d6b937127
Support proxy protocol of websocket ( #2372 )
...
Support proxy protocol of websocket
2019-03-28 10:34:48 +08:00
24f8c3a391
Fix drain the session process mailbox handling err
2019-03-28 10:32:03 +08:00
6e3c4b0855
Fix conflict
2019-03-27 13:59:26 +08:00
a3fd8846a5
Bin key map ( #2362 )
...
Suppport nested bin-key map
2019-03-27 11:12:28 +08:00
e6d90d5758
Improve mountpoint ( #2363 )
2019-03-27 11:10:51 +08:00
0fbf771543
Readjust log level into error when got unexpected message
2019-03-27 11:07:58 +08:00
c223f62c5a
Put cn/dn of client cert into credentials ( #2357 )
...
Put cn/dn of client cert into credentials
2019-03-27 10:20:12 +08:00
2534b8dc64
Support to pass ws compressing options ( #2356 )
...
Add new config entries about websocket
2019-03-27 10:19:35 +08:00
f5c426a2f2
Add missed case for monitors ( #2353 )
2019-03-27 10:18:51 +08:00
58e1b4d485
Readjust log level and unify log format
2019-03-26 22:18:31 +08:00
f0fa9a9252
Add a function converting message to binary-key map ( #2360 )
2019-03-26 10:35:10 +08:00
8d92d58b6c
Fix allow_anonymous behavoir error ( #2355 )
...
EMQ should allow the anonymous connection if the allow_anonymous option is true, although it has one or more auth plugins started.
2019-03-26 10:25:51 +08:00
9e7b3a9209
Update emqx_types.erl
2019-03-22 16:27:23 +08:00
bd304572c9
Delete acl_mod and auth_mod
2019-03-22 16:18:42 +08:00
c7a317afaf
Add one more connack reason code
2019-03-22 15:43:21 +08:00
fc2df9aff5
Adapt to new export style
2019-03-22 14:58:24 +08:00
e386778aca
Fix typo
2019-03-22 11:31:26 +08:00
dba16aeea5
Add 'remove_header/2', 'get_headers/1' functions
...
- Adopt new 'export' style
- Add 'remove_header/2', 'get_headers/1' functions
- Remove 'remove_topic_alias/1' function
2019-03-22 11:31:26 +08:00
ba719a896d
Call 'tokens/1' instead of 'words/1'
2019-03-22 11:31:26 +08:00
a4550a8fc4
Add emqx_topic:tokens/1 function
2019-03-22 11:31:26 +08:00
513d2bcaaa
Fix reload ACL failed ( #2344 )
...
The original `reload_acl` function only parse the ACL file, not compile and rehook to 'client.check_acl'
2019-03-22 10:21:16 +08:00
416bc75d5d
Sort plugin list
2019-03-22 01:02:30 +08:00
865ef864db
Get the plugins list through -emqx_plugin module attributes
2019-03-22 00:03:53 +08:00
b79bf13ae7
Rename result -> auth_result
2019-03-22 00:03:34 +08:00
998684fc4e
Fix badmatch error in the batch_process of session
2019-03-21 17:40:02 +08:00
36927f01e7
Add type definition for auth_result
2019-03-21 16:54:50 +08:00
e7320620c0
Fix alarm report bug ( #2332 )
2019-03-21 16:53:46 +08:00
3a2f6d5a6c
Fix badmatch bug for reload_acl
2019-03-21 16:51:57 +08:00
5a401c44fd
Clear dup flag if message published first ( #2337 )
2019-03-21 10:13:41 +08:00
8a73c62f66
Fix followed packet parse failure ( #2333 )
...
To fix issue#2303(https://github.com/emqx/emqx/issues/2303 )
It will report the following error, when a connection sends a TCP frame contained many of MQTT packet and followed a split MQTT packet.
2019-03-20 10:14:52 +08:00
a95ebcd7d6
Fix typo
2019-03-17 00:23:44 +08:00
88c32b2c41
Fix emqx_rpc badargs bug
2019-03-16 21:27:41 +08:00
763115e149
Delegate serialize fun into sendfun
2019-03-16 21:15:10 +08:00
a72a914fb8
Fix issue #2312 ( #2313 )
...
* Fix SSL option parser
* Fix bridge disconnect log formatting
* Set no headers if new headers is undefined
2019-03-16 19:28:57 +08:00
29f4faa7dd
Add badtcp clause to handle gen_rpc ( #2314 )
2019-03-16 18:23:18 +08:00
901bbdedd6
Add some auth error codes
2019-03-16 16:30:25 +08:00
749494c277
Change default internal-rules to #{}
2019-03-16 13:08:11 +08:00
2912d9a41b
Rename is_super -> is_superuser
2019-03-16 12:51:45 +08:00
a7adb79f17
Allow empty zone in credentials
2019-03-16 12:25:39 +08:00
02fe8560e2
Improve emqx_hooks and credentials ( #2309 )
...
* Improve emqx_hooks and credentials
1. Modify the return modes of emqx hooks.
Change the return value of hook functions to:
- ok: stop the hook chain and return ok
- {error, Reason}: stop the hook chain and return error
- continue: continue the hook chain
And the return value of emqx_hooks:run/2 is changed to:
- ok
- {error, Reason}
And the return value of emqx_hooks:run/3:
- {ok, Acc}
- {error, Reason, Acc}
2. Treat password as a member of credentials.
Password should be wrapped in the `credentials` data-structure, as the
username/password pair together consists of an authentication method.
There can be some methods using some other credential data (e.g.
a JWT token), and these credential data should also be wrapped in the
the `credentials` data-structure.
An event `client.authenticate` is triggered when an user logs in:
```erlang
emqx_hooks:run('client.authenticate', [], Credentials)
```
A `default callback` that deny/allow any user (according to the
`allow_anonymous` config) should be appended to the end of the
callback chain.
The `credentails` is passed through all of the callbacks, and
can be changed over in this process.
* Refactor emqx hooks return mode
* Remove password from PState
2019-03-16 10:43:53 +08:00
f2df92fef2
Unload emqx_alarm_handler before unloading plugins when shuting down ( #2316 )
...
emqx_alarm_handler publishes mqtt messages,
having it running while plugins are shutdown triggered some
annoying crashes
2019-03-15 17:11:24 +08:00
56718e35cb
Add emqx_topic:tokens/1 function ( #2305 )
...
* Add emqx_topic:tokens/1 function
2019-03-13 23:31:44 +08:00
111b66121c
Support TLS/DTLS PSK ( #2297 )
...
* Improve filter functions for emqx-hook
* Add PSK hook
* Reset hook args for filter functions
2019-03-13 22:24:19 +08:00
48450d1d37
Move request response out of emqx client ( #2293 )
...
* Delete response_topic_prefix
The Response-Infomation in CONNACK was misinterpreated, it should
not be a broker's global config, instead, it should be per-client
or even per-session prefix/suffix mechanism
* Delete request-response code from emqx_client
* Add request-response test code
* meck as default dependency --- temp workaround for dep-vsn-check
2019-03-13 11:27:25 +08:00
b51747f03e
Export find_plugin
2019-03-12 22:45:50 +08:00
f166b81702
Use broker_sys_interval instead of sys_interval
2019-03-12 10:15:13 +08:00
252b376e48
Use keep_state_and_data in emqx_client to avoid unnecessary var binding
2019-03-05 04:04:20 +01:00
656429fcc1
Move emqx_client should_ping function to internal block
2019-03-05 03:57:20 +01:00
a056a4cbde
Eliminate {error, inflight_full} from publish call to emqx_client
...
Prior to this change, if a emqx_client:publish/? caller sends in
QoS=1/2 messages too fast, emqx_client may return
`{error, inflight_full}` which could put put the caller to an
awkward situation: there seem to be no ohter option except for
putting self to a sleep-n-retry infinite loop.
In this change, a new gen_statm state 'inflight_full' is introduced
as a sub-state of 'connected'. When emqx_client is in 'inflight_full'
state, it postpone all publish calls (for QoS=1/2) until inflight
window size shrinks.
2019-03-05 03:47:33 +01:00
22aa7d4668
Rm acl_deny_action_ct test case
2019-02-28 22:19:19 +08:00
da755b88c7
Add monitors and alarm handler ( #2266 )
...
* Add monitors and alarm handler
2019-02-28 18:25:17 +08:00
f1d751dd95
Fix compile fail
2019-02-28 17:06:40 +08:00
b1ca0120a2
Move bridge modules out of bridge directory ( #2273 )
2019-02-28 17:04:39 +08:00
c8e2840126
Merge fix conflicts
2019-02-28 17:02:39 +08:00
42932d7b5d
Format code
2019-02-28 16:57:40 +08:00
df97eb0007
Review code
2019-02-28 16:56:44 +08:00
8792f7e02b
Review code
2019-02-28 16:56:04 +08:00
814fd3fc9e
Fix test case
2019-02-28 16:36:47 +08:00
055d0ad98e
Fix typo
2019-02-28 15:39:11 +08:00
7efd7b3ec0
Rename portal to bridge
2019-02-28 15:31:54 +08:00
771f8c052a
Merge branch 'develop' into introduce-new-bridge-impl
2019-02-28 15:14:40 +08:00
3e0fa87209
Remove the io:format
2019-02-28 15:09:13 +08:00
e3bc8e4f0a
Support batch delivery
...
- Upgrade the emqx_session module to support batch delivery
- Update emqx_protocol:deliver/2 to support batch delivery
- Update some test cases
2019-02-28 15:09:13 +08:00
08204fc7a8
Improve the emqx_connection module using gen_statem behaviour ( #2235 )
2019-02-28 15:08:29 +08:00
16165ce935
Use conn_mod instead of socktype
2019-02-28 11:32:05 +08:00
d18f4ba550
Fix wrong config entries
2019-02-28 11:18:12 +08:00
911a813891
Fix copyright and unify log method
2019-02-28 11:18:12 +08:00
9dbc34c376
Ack replayq and allow retry in tests
2019-02-28 11:17:27 +08:00
75163e21f3
Reverse intensity/period in bridge SupFlag
2019-02-28 11:17:27 +08:00
Feng Lee