Commit Graph

707 Commits

Author SHA1 Message Date
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
Feng Lee fa8882b499 Support client, session stats 2017-02-16 11:36:08 +08:00
Feng Lee d91e49a5a5 Change the restart strategy of the top supervisor 2017-02-16 11:35:33 +08:00
Feng Lee d5ac9f0dcb Update protocol_name/1, type_name/1 functions for MQTT 5 2017-02-16 11:33:50 +08:00
Feng Lee bbbfafb759 Update protocol_name/1, type_name/1 functions for MQTT 5 2017-02-16 11:33:27 +08:00
Feng Lee 67566ca372 Add dropped/1 function 2017-02-16 11:32:24 +08:00
Feng Lee a5ac32b49b add 'packets/puback/missed', 'packets/pubrec/missed', 'packets/pubrel/missed', 'packets/pubcomp/missed' metrics 2017-02-16 11:31:46 +08:00
Feng Lee 6b22fb0a0c Remove the 'DOWN' client from emqttd_stats 2017-02-16 11:30:43 +08:00
Feng Lee 2021667021 Add 'local_session/0 function, change reg_session/3 unreg_session/1 functions 2017-02-16 11:29:55 +08:00
Feng Lee 5a49196a07 Update copyright info and format code 2017-02-16 11:28:35 +08:00
Feng Lee a54076cf0a Change the 'Env' 2017-02-16 11:25:44 +08:00
Feng Lee 90ff296ebe Improve the module and support statistics 2017-02-16 11:25:10 +08:00
Feng Lee 23e49c317d Improve the module and support statistics 2017-02-16 11:24:46 +08:00
Feng Lee dbcd79fb74 Move the 'MQTT_SOCKOPTS' macro to include/emqttd_protocol.hrl 2017-02-16 11:22:48 +08:00
Feng Lee 1222746b79 Update copyright and format code 2017-02-16 11:21:31 +08:00
Feng Lee d93caa7c9e Update copyright and format code 2017-02-16 11:19:02 +08:00
Feng Lee 640c9287c2 Rename now_to_secs, now_to_ms functions 2017-02-16 11:18:37 +08:00
Feng Lee 796d5df1c0 Upgrade parse/2 function 2017-02-16 11:17:57 +08:00
Feng Lee 0019fb2b49 Change the message timestamp to 'os:timestamp()' 2017-02-16 11:10:47 +08:00
Feng Lee 9e0b2ed57b Update copyright and change the format of -type, -callback 2017-02-16 11:07:47 +08:00
Feng Lee cae247be97 Rename 'emqttd_hook' module to 'emqttd_hooks' 2017-02-16 10:56:53 +08:00
Feng Lee 0bc071d792 Add emqttd_misc module 2017-02-16 10:48:31 +08:00
Feng Lee 08100525a5 Add inflight module and test suite 2017-02-16 10:44:00 +08:00
Feng a59d5bb459 Rename the emqttd_time APIs 2017-02-15 22:05:28 +08:00
Drew Varner 8e60b8f00a Remove gen_logger references 2017-01-23 20:02:02 -05:00
Lei Chen 4606eaeb58 delete a comma. 2017-01-16 16:27:10 +08:00
Lei Chen ff6acbf293 Client unsubscribe hook does not handle 'stop' value.
Insert a statement to prevent calling emqttd_session:unsubscribe() if hook returns stop.
2017-01-16 16:24:19 +08:00
Feng Lee 0cd4afaa8e Merge pull request #855 from emqtt/emq20
Copyright (c) 2016-2017
2017-01-12 10:49:06 +08:00
黄丹 101532980b Update emqttd_pmon.erl
Copyright (c) 2016-2017
2017-01-11 21:38:34 +08:00
Feng Lee 6af4badc0a Merge pull request #854 from emqtt/emq20
Copyright (c) 2012-2017
2017-01-11 21:12:52 +08:00
huangdan 8092543efb Copyright (c) 2012-2017 2017-01-11 19:34:48 +08:00
Chimit 06ca13531e Change "ok" message to uppercase 2016-12-27 17:21:27 +08:00
turtled 737a89d5e8 rm net_adm:ping 2016-12-14 18:09:41 +08:00
turtled 15a2b265be fixed cluster fail 2016-12-13 16:57:18 +08:00
turtled 696647f2cf fixed #413 2016-12-13 15:57:22 +08:00
Feng Lee 8c1f5d7ec1 Unauthorized 2016-12-13 10:27:05 +08:00
Feng Lee ed730f6827 Fix issue#814 - Cannot remove a 'DOWN' node from the cluster 2016-12-12 19:25:49 +08:00
huangdan fa99cdcaa5 Local Subscription Routes show 2016-12-08 19:34:38 +08:00
huangdan 470a933938 Shared Subscription CLI 2016-12-08 18:06:48 +08:00
Feng Lee 7abc667f7d iolist_size/1 2016-12-07 19:15:44 +08:00
Feng Lee 49ebed5b0b iolist_size 2016-12-07 18:37:47 +08:00
turtled c59f43cdd2 Merge branch 'emq20' of https://github.com/emqtt/emqttd into emq20 2016-12-05 15:00:22 +08:00
turtled 0206785577 fix ws metrics 2016-12-05 15:00:09 +08:00
Feng Lee d62593a9c6 kickout 2016-12-02 09:17:06 +08:00
Feng Lee 2181bd7850 unload 2016-12-01 19:12:45 +08:00
turtled 281ab7b929 fixed stop appliaction error log 2016-12-01 17:05:08 +08:00
Feng Lee 8116357d07 Merge branch 'emq20' of https://github.com/emqtt/emqttd into emq20 2016-12-01 15:18:29 +08:00
Feng Lee fc14f4a3b6 rename route table 2016-12-01 15:18:05 +08:00
turtled 0b93391050 fix issue#151 2016-12-01 10:39:14 +08:00
turtled 3db876781b handshake_timeout change 2016-11-03 11:04:57 +08:00
Feng eb9c11f321 remove modules 2016-10-31 20:26:56 +08:00
黄丹 031a288b50 Update emqttd_pubsub.erl
modify table name
2016-10-31 20:22:09 +08:00
turtled b82e67b081 fixed emqtt/emqttd#739 2016-10-31 14:42:22 +08:00
Feng 611ca0dca4 move modules to plugins 2016-10-31 10:46:22 +08:00
huangdan a87f4917ae subscriptions cmd 2016-10-18 18:06:35 +08:00
huangdan d2d425dc7e sessions cmd 2016-10-18 17:14:36 +08:00
Feng c41f2c97f3 fix print subscription 2016-10-18 11:02:30 +08:00
Feng 5461cc357a dump subscriptions 2016-10-18 10:56:41 +08:00
Feng ce02ec7816 emq_auth_username 2016-10-18 10:45:36 +08:00
Feng Lee 507bca6f52 fix stop_listener/1 2016-10-17 12:41:14 +08:00
Feng Lee e85ad35d35 move to emqtt/emq_auth_clientid plugin 2016-10-15 17:36:40 +08:00
Feng Lee bf075a125b move to emqtt/emq_auth_username plugin 2016-10-15 17:36:19 +08:00
Feng Lee b0917e665c etc/acl.conf 2016-10-15 13:49:51 +08:00
Feng Lee 12d362a674 support .config suffix 2016-10-14 17:40:20 +08:00
Feng Lee f977f9a908 start https listener 2016-10-14 16:21:50 +08:00
Feng Lee 7ac3416d51 modules 2016-10-14 14:25:21 +08:00
Feng Lee 1a8136d551 move to emqtt/emq_mod_rewrite 2016-10-14 13:00:59 +08:00
Feng Lee 73659208a1 allow_anonymous 2016-10-13 19:09:49 +08:00
Feng Lee a01f642606 mqtt listeners 2016-10-13 17:37:32 +08:00
Feng Lee 1f50175c6f rm emqttd_plugins:init/0 2016-10-12 19:42:10 +08:00
Feng Lee 0e4b7cf768 rm src/emqttd.app.src 2016-10-11 14:46:35 +08:00
Feng Lee 14ba1e1c89 emqttd:env 2016-10-11 10:09:29 +08:00
Feng Lee 113bfc73a8 env 2016-10-11 10:01:39 +08:00
Feng Lee d88a4093a5 emqttd:env 2016-10-11 09:49:24 +08:00
Feng Lee 2bcffab28a replace 'emqttd:conf' with 'emqttd:env' 2016-10-11 09:46:28 +08:00
Feng c0c79e8171 rm gen_conf and emqttd_conf 2016-10-11 09:09:29 +08:00
Feng Lee 99632bfbb6 rm gen_conf 2016-10-09 09:35:57 +08:00
Feng 2e9bc16136 emqttd_plugins:init/0 2016-10-02 14:36:54 +08:00
Feng daa87206a7 random 2016-10-01 09:43:21 +08:00
Feng 6b3d67c515 fix random:seed/1 warning 2016-09-30 16:13:50 +08:00
Feng f510ab894f remove is_superuser/2 callback 2016-09-30 10:23:04 +08:00
Feng 8d48e8d2e2 Support 'is_superuser/2 callback 2016-09-28 22:45:20 +08:00
Feng d0218deb88 Add hooks: session.created, session.terminated 2016-09-28 22:43:58 +08:00
Feng 66ca65733a emqttd:run_hooks/2, emqttd_hook:run/2 2016-09-23 15:29:12 +08:00
Feng 1bb1799d34 local subscription, shared subscription 2016-09-18 14:08:57 +08:00
Feng 7d9ad96021 refactor emqttd_conf 2016-09-09 22:52:17 +08:00
turtled 61d8b2d907 fixed emqttd_ctl bridges list error 2016-09-09 21:49:57 +08:00
Feng Lee 7e41bc9091 improve conf design 2016-09-09 20:30:00 +08:00