Commit Graph

1095 Commits

Author SHA1 Message Date
HeeeJianBo
4c8b43e05d Improve impletament of emqttd_topic:match/2 2017-12-27 15:11:55 +08:00
HeeeJianBo
d5c54276e2 Fix issue #1398 2017-12-27 14:55:36 +08:00
Feng Lee
bcec25092b Merge version 2.3.2 to X edition 2017-12-26 21:09:24 +08:00
Feng Lee
db954aeb6d Support X.509 certificate based authentication with HAProxy 2017-12-15 19:23:50 +08:00
Feng Lee
6f64eb469c Remove emqttd_ssl.erl 2017-12-07 17:58:24 +08:00
Feng Lee
b98007659e Merge the master branch 2017-12-07 17:57:18 +08:00
Feng Lee
73836939c8 Support for TLS with client certificate based authentication 2017-12-07 17:42:32 +08:00
Feng Lee
6e5134a8b2 Merge with the enterprise edition 2017-12-07 16:24:48 +08:00
Feng Lee
f1640f5b85 Merge emq24 to X branch 2017-12-07 11:02:44 +08:00
Feng Lee
9f1c3a5899 Compatible with esockd 4.x 2017-12-06 14:42:26 +08:00
turtled
bcf345efbe Fix compile fail 2017-12-06 10:27:55 +08:00
turtled
ddf2965651 Rm emqttd.app.src 2017-12-06 10:26:19 +08:00
turtled
24f05adb1a Fix compile fail 2017-12-06 10:19:46 +08:00
Feng Lee
c3c5589452 Version 2.3.2 2017-12-06 10:01:42 +08:00
Feng Lee
51533dbe9e Shutdown the connection if an error occurred when sending data 2017-12-05 23:41:40 +08:00
turtled
a42fcb2c39 Fix conflicts 2017-12-05 16:34:18 +08:00
HuangDan
b8e0a4d5c4 Bump version to 2.3.1 2017-12-03 00:43:42 +08:00
Feng Lee
0fe530a502 Depends on the develop branch of mochiweb 2017-12-02 18:00:56 +08:00
Feng Lee
4915195b1e Fix issue #1335 - Forward real client IP using a reverse proxy for websocket 2017-12-02 17:59:16 +08:00
HeeeJianBo
70570dd943 Merge branch 'develop' into ws_proxy 2017-12-01 22:22:20 +08:00
HeeeJianBo
5006dbba6e Add ws/wss proxy cofingurations for getting client original ip address 2017-12-01 22:12:27 +08:00
Feng Lee
c308037b1a Remove the unnecessary transactions to optimize session management 2017-12-01 17:16:59 +08:00
Feng Lee
d2a4e2c615 Should not exit arbitrarily if clientid conflicts in mnesia 2017-12-01 15:46:42 +08:00
Feng Lee
d9500412bf Update the topic's statistics 2017-12-01 09:10:46 +08:00
Feng Lee
ee5c33d0bd Fix the 'no function clause' exception for issue #1293 2017-11-29 22:23:59 +08:00
Feng Lee
26fb809dbe Fix issue#1293 - the retained flags should be propagated for bridge. 2017-11-29 14:09:46 +08:00
Feng Lee
223f3d4da5 Remove RPC configurations 2017-11-22 16:44:00 +08:00
Feng Lee
38c33e9c8b Merge with emqx 2017-11-21 22:41:05 +08:00
Feng Lee
845c5eddc1 Merge with emqx 2017-11-21 22:41:02 +08:00
Feng Lee
e52c303014 Merge develop to X 2017-11-21 14:25:35 +08:00
Feng Lee
2cec86eba7 Merge with version 2.3.0 2017-11-21 14:14:12 +08:00
Feng Lee
db3a54e31a Fast close the invalid websocket in init/1 function 2017-11-20 14:15:51 +08:00
Feng Lee
14771cdaee Fix issue #1340 - erlang:demonitor/1 the reference when erasing the monitor 2017-11-20 10:10:32 +08:00
Feng Lee
6028d6e83e Show local route 2017-11-19 14:25:54 +08:00
Feng Lee
945f925136 Refactor the subscription_list function 2017-11-19 01:15:22 +08:00
turtled
8462fa8e89 Display local route 2017-11-18 17:21:13 +08:00
Feng Lee
f01deec950 Update the 'api/v2/subscriptions' API 2017-11-18 13:23:51 +08:00
Feng Lee
1d0e17b89c Improve the print of 'subscriptions' CLI 2017-11-18 12:25:00 +08:00
Feng Lee
d58b8bed3c Fix the 'subscriptions add <ClientId> <Topic> <Qos>' CLI 2017-11-18 11:48:44 +08:00
Feng Lee
405d5d9d29 Fix the 'subscriptions' CLI 2017-11-18 11:17:19 +08:00
Feng Lee
11a41166d2 Fix the function spec: '{error, any()}' -> '{error, term()}' 2017-11-17 21:13:20 +08:00
Feng Lee
62d4f9f031 Bump version to 2.3.0 2017-11-17 20:53:07 +08:00
Feng Lee
8f00e28576 Improve the pubsub design and fix the race-condition issue 2017-11-17 20:51:51 +08:00
HeeeJianBo
cae743803b Improve the process logic of DUP flag (#1319). 2017-11-03 17:49:52 +08:00
HeeeJianBo
279b96f146 Fix issue #1319, reset DUP=0 when recv DUP=1 PUBLISH Message 2017-11-02 09:48:37 +08:00
Feng Lee
49d91cf694 Rename 'message.offline' hook to 'message.dropped' 2017-10-31 15:19:53 +08:00
HeeeJianBo
84d8eae37e Fixed issue #1314. re-sent retained messages when create/replace Subscription
- re-sent message when create a new Subscription relationship
- re-sent message when replace an existed Subscription with different Qos
2017-10-31 13:23:54 +08:00
turtled
586c3a243a Fix retained message is not sent for Subscribe to existing topic 2017-10-28 22:07:06 +08:00
HuangDan
c87c49ede0 Updated trace logging level 2017-10-21 14:49:56 +08:00
HuangDan
c43cae4348 Bug fixed for users api 2017-10-11 20:08:01 +08:00
Feng Lee
2354a3dd5d Fix the building errors 2017-10-10 15:50:40 +08:00
turtled
5d30ceccd1 Fix passwd_hash return type error 2017-10-10 14:15:53 +08:00
Feng Lee
735211fd02 Merge with EMQ X project 2017-10-09 23:29:05 +08:00
Feng Lee
4b8cd18f5d Merge with EMQ X project 2017-10-09 19:43:06 +08:00
turtled
54534967bd Fix Dashboard not showing data 2017-10-09 18:08:46 +08:00
turtled
88c77cf4c2 Auth failure not publish the will message 2017-10-09 18:07:09 +08:00
turtled
d9f14dacaf Fix dashboard not showing data bug 2017-09-25 14:59:58 +08:00
turtled
e57121a660 Fix string:split undefined issue 2017-09-12 21:34:43 +08:00
turtled
f6025404e3 Update clean_acl_cache API 2017-09-12 10:57:04 +08:00
turtled
ee9fc5cb0e Review code 2017-09-09 21:21:30 +08:00
turtled
424aea2878 Review code 2017-09-09 21:00:17 +08:00
turtled
8091c07d3c Review code 2017-09-09 20:55:57 +08:00
turtled
85f9a8cb70 Fix read plugin configuration not find schema file 2017-09-08 23:23:48 +08:00
turtled
7260b17cb5 Plugins configuration insert to ets table 2017-09-06 17:17:29 +08:00
turtled
d3f52898ee Add Hot configuration plugin 2017-09-05 16:52:07 +08:00
turtled
ed29c3273d Review code 2017-08-21 16:16:28 +08:00
turtled
9a4a6885d9 Update api list 2017-08-21 15:09:45 +08:00
turtled
5bec24d19b Update modify_config url 2017-08-18 23:28:33 +08:00
turtled
f6b9ce84e5 Update kick_client API 2017-08-18 11:44:11 +08:00
turtled
9e6c63b91b REST API add modify_config/config_list 2017-08-17 15:51:20 +08:00
turtled
d50ce9f6c0 Fix compile warning 2017-08-16 12:10:46 +08:00
turtled
4ff7d4eead Fix ctl set env fail 2017-08-16 11:25:11 +08:00
turtled
34e5d746d1 Fix compile fail 2017-08-15 12:33:09 +08:00
turtled
303db5ccbd Add clean_acl_cache API 2017-08-15 12:18:31 +08:00
Feng Lee
f978bae86a TODO: How to persist the configuration 2017-08-14 09:32:39 +08:00
turtled
64af3271c2 Fix rest_api get monitoring/nodes error 2017-08-12 22:00:33 +08:00
Feng Lee
f28db8b4c7 Format code 2017-08-12 12:51:02 +08:00
HuangDan
9b61fea1d1 Update auth spec 2017-08-11 15:40:33 +08:00
turtled
f11967288e Add emqttd_broker info API 2017-08-11 14:56:56 +08:00
turtled
f4381155f8 Format code 2017-08-11 09:53:06 +08:00
turtled
701ee3e8dc Add CLI set/get env 2017-08-10 18:19:20 +08:00
turtled
7c1ee6610d Add http management APIs 2017-08-09 10:14:29 +08:00
Feng Lee
1c63bdd90d APIs for hot reload of configuration 2017-08-07 18:28:32 +08:00
Feng Lee
88f84a4a0c Support to configure keepalive backoff 2017-08-07 18:27:16 +08:00
Feng Lee
925e35dcbd Remove the fullsweep_after option 2017-08-07 12:15:52 +08:00
Feng Lee
8325056061 Authorize HTTP Publish API with clientId 2017-07-26 13:16:46 +08:00
Feng Lee
f25661d3cd Merge pull request #887 from chimit/master
Add ClientId parameter into the auth on HTTP Publish
2017-07-26 13:02:02 +08:00
Feng Lee
c4464954b0 Fix the 'case clause matching' exception 2017-07-24 09:34:22 +08:00
Feng Lee
6b0571d76c Fix the undefined error 2017-07-23 20:49:58 +08:00
Feng Lee
15a081c9bb Improve the Autocluster design 2017-07-23 18:07:53 +08:00
Feng Lee
081717be92 Add autocluster lock 2017-07-21 15:44:38 +08:00
Feng Lee
c1bce429d9 Load plugins after autocluster 2017-07-21 13:07:04 +08:00
Feng Lee
96777a4da8 Start listeners after autocluster 2017-07-21 12:43:28 +08:00
Feng Lee
7f22265e31 Use global:trans/2 to clean routes and sessions 2017-07-20 14:22:18 +08:00
Feng Lee
d6d08d6d5e Ensure to start ekka 2017-07-18 18:49:38 +08:00
Feng Lee
437b26718b Call ekka_autocluster:bootstrap/0 to build the cluster 2017-07-18 18:40:03 +08:00
turtled
2b54745f69 v2.3 2017-07-10 15:28:13 +08:00
turtleDeng
523dd9c8b0 Merge pull request #1145 from emqtt/master
Merge emq22
2017-07-10 13:07:32 +08:00
turtled
081f5dbe6e Format code 2017-07-08 08:51:44 +08:00
Feng Lee
e3d414089f Fix the usage of listeners restart/stop CLI 2017-07-07 09:19:30 +08:00
turtled
e42e71dcf7 Format code 2017-07-07 08:56:07 +08:00
HuangDan
4b63b2c098 Format code 2017-07-06 22:15:34 +08:00
HuangDan
3488d14776 Add 'undefined' from a record field's type 2017-07-06 18:59:54 +08:00
HuangDan
55b77af044 Merge branch 'develop' of https://github.com/emqtt/emqttd into develop 2017-07-06 17:53:31 +08:00
HuangDan
e675959d57 Fix received/1 and sent/1 function spec 2017-07-06 17:28:49 +08:00
HuangDan
53145bbbba Update subscriptions/1 function spec 2017-07-06 17:01:27 +08:00
turtled
87d2a7ca85 Review code 2017-07-06 16:17:36 +08:00
turtled
7054d2c575 Rename reopen -> restart 2017-07-06 16:05:02 +08:00
turtled
5433af4c92 Add reopen/close ctl command 2017-07-06 14:49:17 +08:00
turtled
a427a53a30 Fix error exit code from emqttd_ctl 2017-07-06 11:25:05 +08:00
turtled
934287b926 Fix error exit code from emqttd_ctl 2017-07-06 10:52:27 +08:00
turtled
88797062a4 Add function restart_listener 2017-07-01 17:51:55 +08:00
Feng Lee
8a804c56f3 Monitor/Unmonitor membership events 2017-06-28 15:51:24 +08:00
Feng Lee
cc6696f8cb Tune the log level 2017-06-25 07:11:36 +08:00
Feng Lee
50c312e736 Merge master branch 2017-06-22 12:53:33 +08:00
Feng Lee
0b58719342 Monitor changes of membership 2017-06-22 12:50:55 +08:00
turtled
ae36a8c8c2 Update spec #1106 2017-06-21 10:11:34 +08:00
Feng Lee
1f3bab2bcb Integrate with ekka library, use ekka:subscribe/1 to replace mnesia:subscribe/1 2017-06-16 16:02:36 +08:00
Feng Lee
1e205720cc Refactor: rename 'tick_tref' field to 'ticker' 2017-06-16 16:01:27 +08:00
Feng Lee
adfd34852b Register 'fun emqttd:reboot/0' 2017-06-16 14:52:40 +08:00
Feng Lee
9b646d8cbc Integrage with 'ekka' library 2017-06-16 12:30:09 +08:00
turtled
37b625aa57 Format code 2017-06-13 21:13:57 +08:00
turtled
88d466eb1a remove from cluster, delete the node in extra_db_nodes 2017-06-13 21:02:38 +08:00
turtled
bbcc082a0d Add stop api listener function 2017-06-13 11:15:26 +08:00
turtled
f18051c340 Add stop api listener function 2017-06-13 11:06:35 +08:00
Feng Lee
fa138882a3 Merge the updates of test case 2017-06-13 10:51:56 +08:00
Feng Lee
79c2fa631e Fix the issue that we cannot remove a down node from the cluster 2017-06-13 10:35:22 +08:00
Feng Lee
a5cac277c1 Add cluster_nodes/1 function 2017-06-13 10:33:56 +08:00
HuangDan
c0bb20c2d9 Remove bridge command qos option 2017-06-12 22:52:23 +08:00
Feng Lee
53f5188cbb Fix the race condition issue caused by unregister_session/1 2017-06-12 19:13:58 +08:00
turtled
4888702712 Remove bridge command qos option 2017-06-12 15:13:54 +08:00
turtled
1a8cc2e146 Add http to listen on port 8080 for the http REST API 2017-06-09 14:54:03 +08:00
turtled
0f7a66f810 Force gc call emit_stats 2017-05-26 16:44:44 +08:00
turtled
dc2e6ab53c Hash type add bcrypt 2017-05-26 12:31:07 +08:00
turtled
c64f172174 Emq-WebSocket-Protocol -> EMQ-WebSocket-Protocol 2017-05-19 16:55:14 +08:00
Feng Lee
0ffa2d00d0 Add a 'websocket_protocol_header' option to fix the missing 'Sec-Websocket-Protocol' header of WeChat WebSocket Connection 2017-05-19 16:41:27 +08:00
turtled
94402f4297 Format code 2017-05-19 10:24:36 +08:00
turtled
96562dfc59 Format code 2017-05-19 10:22:07 +08:00
turtled
9c5ce15f46 Fixed http publish API missing params 2017-05-19 10:13:01 +08:00
turtled
8d4ec32d1a Fixed http publish API missing params 2017-05-19 10:09:34 +08:00
turtled
798c60f269 Rollback code 2017-05-19 09:26:52 +08:00
turtled
61fa9f3f89 Cli listeners start add flag --backlog 2017-05-18 16:44:46 +08:00
turtled
3e1c69dff1 Add cli listeners start|stop 2017-05-18 16:35:49 +08:00
turtled
caaf66311d Cli show all usage 2017-05-18 09:24:15 +08:00
turtled
95232189cd Invalid params 2017-05-17 17:15:21 +08:00
turtled
1f2cd40237 Invalid params 2017-05-17 17:12:19 +08:00
turtled
8853e43275 cli query -> show 2017-05-17 16:37:55 +08:00
turtled
d5ccb9f92f Cli command support --format=json output 2017-05-17 16:27:18 +08:00
turtled
06d291e354 Update Cli command 2017-05-17 10:18:09 +08:00
turtled
2d6104fbd9 Ctl use clique 2017-05-11 16:02:38 +08:00
turtled
161e5a2b5b Http publish mochiweb_request:parse_post(Req) -> Req:recv_body 2017-05-08 18:13:52 +08:00
HuangDan
73d84bef5e Update SUITE conf 2017-05-05 14:53:06 +08:00
turtled
cdbcc84d23 emqttd.app.src add bcrypt 2017-04-27 09:22:02 +08:00
turtled
ba0c08517f v2.2 2017-04-25 10:41:43 +08:00
Feng Lee
87d3bb1419 Merge branch 'emq22' into emq20 2017-04-25 08:59:05 +08:00
huangdan
7388be0180 Merge pull request #1009 from emqtt/develop
Change subscription to subscriptions
2017-04-20 14:08:23 +08:00
HuangDan
1cfa25861f Change subscription to subscriptions 2017-04-20 14:06:56 +08:00
huangdan
a091d3a112 Merge pull request #1007 from emqtt/develop
Version 2.1.2
2017-04-20 11:21:05 +08:00
huangdan
dcecd7d8ae Version 2.1.2 2017-04-20 11:19:26 +08:00
Feng Lee
3c9cde59c7 Merge pull request #1004 from emqtt/develop
Fix crash caused by duplicated PUBREC packet
2017-04-20 10:15:30 +08:00
turtled
7ca6cbadcf Duplicated PUBACK Packet 2017-04-18 17:32:00 +08:00
turtled
9d3676884c Fix duplicate send pubrec packet 2017-04-18 17:19:04 +08:00
turtled
aa360d4378 Fix duplicate send pubrec packet 2017-04-18 16:44:19 +08:00
Feng Lee
7bbc3adfcb Merge pull request #1002 from emqtt/develop
Fix sessions list command
2017-04-17 10:02:38 +08:00
HuangDan
9157f824e5 Fix sessions list command 2017-04-15 23:52:54 +08:00
huangdan
455a978c96 Merge pull request #996 from emqtt/develop
Fix the subscrptions print
2017-04-13 15:10:57 +08:00
HuangDan
0cbca5f4c0 Fix the subscrptions print 2017-04-13 15:09:48 +08:00
huangdan
bc280701cd Merge pull request #994 from emqtt/develop
Version 2.1.1
2017-04-13 10:26:10 +08:00
huangdan
b10938c90a Version 2.1.1 2017-04-13 10:24:50 +08:00
turtled
ca676880a8 Support bcrypt 2017-04-11 16:39:52 +08:00
turtled
7d618e78ff support bcrypt 2017-04-11 16:02:21 +08:00
turtleDeng
6f02d775e4 Merge pull request #991 from emqtt/develop
Support HEAD method for health check
2017-04-10 22:16:22 -05:00
turtled
5476288ab3 Merge branch 'develop' of https://github.com/emqtt/emqttd into develop 2017-04-11 09:40:46 +08:00
turtled
43cc90ceae bridge message qos default 0 2017-04-11 09:40:31 +08:00
Feng Lee
e6df089ecb Fix issue #984 - support HEAD method for health check 2017-04-10 13:37:50 +08:00
turtleDeng
b839fdc275 Merge pull request #986 from emqtt/emq20
merge emq20 branch code
2017-04-10 12:40:26 +08:00
turtled
45ca461fd9 Add ignore self publish message 2017-03-30 14:41:29 +08:00
turtled
5c866d91b4 support cascading multiple acl modules 2017-03-30 09:43:35 +08:00
Feng Lee
ca8e7e6423 Merge branch 'develop' into emq20 2017-03-29 17:39:36 +08:00
Feng Lee
43207f86ea Use stop/2 to count the shutdown reasons 2017-03-29 17:38:43 +08:00
Feng Lee
9240a0355a Fix issue #963 - shutdown if session process exited 2017-03-29 16:36:17 +08:00
Feng Lee
300bfce372 Merge pull request #964 from emqtt/develop
Fix issue #963 - shutdown if session process exited
2017-03-29 16:31:51 +08:00
turtled
4f0bd74f87 #777 2017-03-29 15:28:24 +08:00
J Phani Mahesh
2f01400f38
correct licence in app.src 2017-03-24 15:58:51 +05:30
Feng Lee
440307081b Check if the node is in cluster before remove 2017-03-23 18:37:04 +08:00
Feng Lee
f194f92418 Shutdown the connection if no more data received 2017-03-23 16:30:23 +08:00
Feng Lee
3c8de09ba3 Rename the env 'queue' to 'mqueue' 2017-03-23 15:20:32 +08:00
Feng Lee
06100ae6d5 Define 'MQueue' macro 2017-03-23 15:15:45 +08:00
Feng Lee
690f27a8b4 Support 'mount point' 2017-03-23 15:10:24 +08:00
Feng Lee
496d046d52 Improve the mqueue design 2017-03-23 15:07:06 +08:00
Feng Lee
0d617c17e0 Use the emqttd_protocol:init/4 API 2017-03-23 15:06:14 +08:00
Feng Lee
0b13cd78e6 Version 2.2 2017-03-22 10:48:24 +08:00
Feng Lee
2e6e97b006 Fix the syntax error 2017-03-13 16:30:41 +08:00
Feng Lee
82bb7766ac Add env, maintainers, licenses properties 2017-03-13 15:55:00 +08:00
Feng Lee
d099d0b53c Add emqttd_gc:maybe_force_gc/3 API and tune the min hibernate interval 2017-03-13 15:36:58 +08:00
Feng Lee
05396f0ade Add pbkdf2 dependencies and fix the building errors 2017-03-13 13:30:49 +08:00
Feng Lee
90e46325df Fix the crash caused by keepalive:start/3 2017-03-13 12:42:02 +08:00
Feng Lee
bb91bc04c6 Merge pull request #941 from callbay/issue#935
Fix Issue#935
2017-03-13 11:41:22 +08:00
Frank Feng
6472457342 Match {error,einval} 2017-03-12 23:06:57 +08:00
huangpengju
61a71e7559 update emqttd_auth_mod.erl code format 2017-03-12 11:49:26 +08:00
Feng Lee
bd8b446a54 Merge pull request #938 from emqtt/pbkdf2
Support pbkdf2 hash
2017-03-10 08:21:14 +08:00
huangpengju
b5ff80499a Update emqttd_auth_mod.erl 2017-03-09 09:29:31 +08:00
huangpj
fba79b3e25 support pbkdf2 2017-03-08 18:01:59 +08:00
Feng Lee
e008d149d3 Update comments and misc fix 2017-03-06 18:57:29 +08:00
Feng Lee
7c90e08f57 Fix the subscrptions print 2017-03-06 18:48:29 +08:00
Feng Lee
14d28d59bd Rename the 'Timestamp' variable to 'TS' 2017-03-06 18:47:50 +08:00
Feng Lee
f2a818a4a4 Rename the PUBSUB macro to PS 2017-03-06 18:46:09 +08:00
Feng Lee
dae3d22bef Remove the io:format line 2017-03-06 18:43:44 +08:00
buxizhizhoum
93719a13f3 Edit the note of tick timer 2017-03-03 22:05:26 +08:00
J Phani Mahesh
a71a061305
add app.src,rebar.lock, ignores for rebar3
Having src/emqttd.app.src allows rebar family of build tools
(rebar2, and rebar3) to be used to compile emqttd. This is important
to allow plugins to be written using rebar3, to lock dependencies.

rebar.lock contains references to commits or hashes of dependencies
and is used by rebar3 to allow repeatable builds.

This is important since without it, updates to dependencies are
silently pulled and it is impractical to replicate a build properly.

However, this adds an additional maintenance effort. Periodically,
the lock file must be updated using rebar3 upgrade, and app.src
must be updated when adding new dependencies.

Note that erlang.mk does not respect dependency locking currently,
and does not benefit from rebar.lock.

_build is used by rebar3 and mix for storing built artifacts.
2017-02-27 14:19:04 +05:30
Feng
1e91c0e220 Format code 2017-02-23 23:01:20 +08:00
Feng
440011da9a Rename 'Pkt' to 'PktCnt', 'Msg' to 'MsgCnt' 2017-02-23 23:00:55 +08:00
Feng Lee
edd99dc5ed Disable the force GC if conn_force_gc_count = 0 2017-02-23 18:53:16 +08:00
Feng Lee
1e36750288 Use emqttd_gc:reset_conn_gc_count/2 API 2017-02-23 17:40:50 +08:00
Feng Lee
5ef4fce141 Handle the {ok, I} return 2017-02-23 17:26:29 +08:00
Feng Lee
e972103f74 Fix the 'spawn_opt' options 2017-02-23 17:25:44 +08:00
Feng Lee
73847b96fc Add 'FULLSWEEP_OPTS' macro 2017-02-23 17:16:55 +08:00
Feng Lee
7d65ad42ad Add '[{fullsweep_after, 10}]' opts and 'force_gc_count' to tune the memory usage 2017-02-23 16:56:16 +08:00
Feng Lee
ab76e7978b Add emqttd_gc module 2017-02-23 16:53:09 +08:00
Feng Lee
2d9dbe4729 Support to hook 'tag' function 2017-02-23 11:55:52 +08:00
Feng
365bfb9e80 Replace emqttd_misc:inc_stats/1 with inc_stats/1 2017-02-22 23:08:22 +08:00
Feng
239cf1b5fc Add '{backoff, 1000, 1000, 10000}' to return of init/1 2017-02-22 23:07:27 +08:00
Feng
b8084f2989 Remove inc_stats/1 function 2017-02-22 22:24:23 +08:00
Feng Lee
5d5de51f89 Change the gen_server:start_link to gen_server2 2017-02-22 18:47:14 +08:00
Feng Lee
5543b72243 Force to GC the Websocket Process 2017-02-22 18:41:02 +08:00
Feng Lee
f955614f9d Remove the io:format line 2017-02-22 18:40:17 +08:00
Feng Lee
39abdb8b41 Remove 'enable_stats' from 'INFO_KEYS', and remove io:format line 2017-02-22 17:52:55 +08:00
Feng Lee
88c2b4eaa3 Use the new emqttd_parser API to parse Websocket frame 2017-02-22 15:43:24 +08:00
Feng Lee
b4936726fd Remove the random:seed/1 to fix the build warnings 2017-02-22 15:36:06 +08:00
Feng
f4c4e5635c Improve the 'enable_stats' design of client, session 2017-02-22 12:10:52 +08:00
Feng
700ec7aaef Add 'proto_stats' record 2017-02-22 10:01:39 +08:00
Feng
6c50a59cad Rename macro 'MAX_PACKET_LEN' to 'MAX_PACKET_SIZE' 2017-02-22 00:32:22 +08:00
Feng
418fb37ca0 Add max_packet_size() type 2017-02-22 00:31:47 +08:00
Feng
d33a41b28b Remove unused fields: connname, peerhost, peerport 2017-02-22 00:31:09 +08:00
Feng Lee
17953a4716 Rename 'MAX_LEN' to 'MAX_PACKET_LEN' 2017-02-21 20:11:09 +08:00
Feng Lee
4d2d6fa0d6 Change the default max_len to infinity 2017-02-21 20:10:38 +08:00
Feng Lee
7e98650233 Improve the emqttd_parser design 2017-02-21 20:10:17 +08:00
Feng Lee
498915e5b3 Hibernate after a packet sent 2017-02-21 19:26:50 +08:00
Feng Lee
3cdf2377c8 Use gen_server2 to reduce the CPU/memory usage 2017-02-21 18:45:40 +08:00
Feng Lee
cabd1af23a Hiberate after subscribe, unsubscribe and resume 2017-02-20 16:45:53 +08:00
turtled
a7ed2c402b fix #885 2017-02-18 15:03:41 +08:00
Feng Lee
79217fdade Remove the 'infinity' timeout 2017-02-18 14:14:24 +08:00
Feng Lee
726f829df5 Fix the error caused by emqttd:env/1 2017-02-16 18:59:53 +08:00
turtled
5419266724 emqttd_hook -> emqttd_hooks, syslog 2017-02-16 18:33:57 +08:00
Feng Lee
a5ba86fd1a Update rebar.config 2017-02-16 11:46:21 +08:00
Feng Lee
bad855bdd9 Improve the session design, support tune_qos, enable_stats 2017-02-16 11:46:06 +08:00
Feng Lee
a345b3682b Rename emqttd_hook to emqttd_hooks 2017-02-16 11:39:48 +08:00
Feng Lee
45a379f112 Replace 'size/1' with 'byte_size/1', serialize to output iolist 2017-02-16 11:38:40 +08:00
Feng Lee
d69d769797 Upgrade copyright info 2017-02-16 11:36:57 +08:00
Feng Lee
78c8856eda Update copyright info 2017-02-16 11:36:24 +08:00