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
Feng Lee