yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity
1,979 Commits 393 Branches 684 Tags 74 MiB
Commit Graph

591 Commits

Author SHA1 Message Date
Frank Feng 9c9633ab27 just to make it more readable 2016-03-05 23:12:25 +08:00
Frank Feng d6b4ff654a add 'sys' flag to message 2016-03-05 21:16:16 +08:00
Feng 652f5f5767 fix issue #450. Print a hint if the auth_username module is not enabled 2016-03-03 11:12:08 +08:00
Feng cf4dfe632f Issue #460 - Timer Tick at interval of (Keepalive * 1.5)/2 2016-03-01 18:59:12 +08:00
Feng d1bb0e04fd fix syntax error 2016-02-28 23:49:10 +08:00
Feng e40775f1f1 fix issue #438 2016-02-21 10:06:14 +08:00
Feng Lee 5695ba178c cli common tests 2016-02-17 23:52:04 +08:00
Feng Lee 369c5e86c5 fix issue #438 - Bridge emqttd broker to another emqttd broker & emqttd to mosquitto bridge 2016-02-17 21:15:34 +08:00
Feng 955d8e37fd router_pool/1 2016-02-16 03:03:16 +08:00
Feng 757d1f5fc5 Merge branch 'master' into 0.16 2016-02-16 02:56:59 +08:00
Feng 6930439158 -compile(export_all) 2016-02-16 02:54:29 +08:00
Feng 8ba6c5bbb6 foreach 2016-02-16 02:17:14 +08:00
Feng e605dcb111 fix spec of wildcard/1 2016-02-16 02:16:55 +08:00
Feng 87a2f2680c rm priority flag 2016-02-16 02:16:30 +08:00
Feng 3d2cb93ebd rm -ifdef(TEST) 2016-02-16 02:16:14 +08:00
Feng 3561680697 rm lager:error log 2016-02-16 02:15:52 +08:00
Feng 9cb0fe3f0a more test cases 2016-02-14 01:50:51 +08:00
Feng dfdad8bcb6 refactor the router and pubsub 2016-02-14 01:48:49 +08:00
Feng 0d21e5c911 fix issue #440 - mqtt_message record: add 'sender' field 2016-02-14 00:35:42 +08:00
Feng 150c103cfa replace emqttd_opts:g/3 with proplists:get_value/3 2016-02-13 18:36:33 +08:00
Feng 541af6256d replace emqttd_opts:g/3 with proplists:get_value/3 2016-02-13 18:36:09 +08:00
Feng 49a979a25e replace emqttd_opts:g/3 with proplists:get_value/3 2016-02-13 18:35:53 +08:00
Feng 1b61ef0856 rm g/2, g/3 2016-02-13 18:35:10 +08:00
Feng 890de0c60a is_queue/1, -ifdef(TEST). 2016-02-13 18:34:28 +08:00
Feng 3c53cf2b09 merge zenmq_trie, zenmq_mnesia, zenmq_boot 2016-02-13 14:26:40 +08:00
Feng bd1e618cc8 rewrite emqttd_node module 2016-02-11 15:55:10 +08:00
Feng 767c4ccc6e fix issue #449 - Improve the CLI of cluster 2016-02-11 15:54:35 +08:00
Feng 44d598fd87 rm reg_name/2, seed_now/0 functions 2016-02-11 15:53:23 +08:00
Feng 89052d8e6e add emqttd_time module, fix comments and format 2016-02-11 15:52:59 +08:00
Feng 1560386ab2 Fix delete/1, add lookup/1 2016-02-11 15:42:29 +08:00
Feng 3f047a1d16 add emqttd_time module 2016-02-11 14:33:42 +08:00
Feng 9dda709aa1 move running_nodes/0 to emqttd_mnesia and improve some functions 2016-02-11 14:31:42 +08:00
Feng a5116c7fa6 emqttd_time to replace emqttd_util 2016-02-11 14:30:08 +08:00
Feng 8aad88e825 fix issue #449 - Improve the design of cluster 2016-02-11 01:42:09 +08:00
Feng e030454466 if only one core, the router will not work 2016-02-06 16:35:33 +08:00
Feng 94c3e69b44 Licensed under the Apache, Version 2.0 2016-02-05 14:26:17 +08:00
Feng 1e852ded91 0.16 - support static subscriptions 2016-02-02 13:36:52 +08:00
Feng 5306463b7e updated copyright 2016-02-01 11:59:44 +08:00
Feng f65676c232 fix plen/2 - return 0 2016-01-25 14:46:30 +08:00
Feng d8c116a502 add now_to_ms/0, now_to_ms/1 functions 2016-01-25 12:59:41 +08:00
Feng 83d64308c5 plen/2 spec 2016-01-24 14:15:34 +08:00
Feng 8934d8ecad stop/1, emqttd:seed_now/0 2016-01-24 13:43:42 +08:00
Feng 0b686da281 iolist_to_binary(Name) 2016-01-24 13:42:59 +08:00
Feng 22a282e39e emqttd:seed_now/0 to replace random:seed(now()) 2016-01-24 13:42:22 +08:00
Feng fb32c509ce -spec stats/1 2016-01-23 22:52:50 +08:00
Feng 4ebdbd75a3 add out/2, plen/1 2016-01-23 22:04:36 +08:00
Feng 166e085fff add client_connected/3 2016-01-21 15:37:25 +08:00
Feng 7193bf4f20 rm bin/1 2016-01-21 12:46:43 +08:00
Feng 4934bf54c0 add passwd_hash/2 api 2016-01-20 15:38:51 +08:00
Feng b5c514b39c fix dispatch 2016-01-20 15:38:24 +08:00
Feng 284abc7388 fix reverse_route stats 2016-01-17 20:03:47 +08:00
Feng 51c5ea1f96 fix route, reverse_route stats 2016-01-17 20:02:44 +08:00
Feng 4f9d429478 fix pubsub, sessions, trace commands 2016-01-17 20:02:13 +08:00
Feng a983361121 fix issue#428 - Username/Password Authentication: support to configure default users 2016-01-17 20:01:36 +08:00
Feng 1cbdc5e9e4 use emqttd:reg_name/2 to replace name/1 2016-01-17 20:00:46 +08:00
Feng 5bfd3a784e setstats after route table changed 2016-01-17 20:00:23 +08:00
Feng 43165a5e8a use emqttd:reg_name/2 to replace name/1 2016-01-17 19:59:33 +08:00
Feng 0a29c8760e add reg_name/2 function 2016-01-17 19:59:05 +08:00
Feng 2544786c56 add_routes([], _Pid) 2016-01-16 10:40:37 +08:00
Feng 21cb2bea6e 2016 2016-01-15 13:43:22 +08:00
Feng b46c8d2f0f Move github wiki to redthedocs 2016-01-14 17:20:01 +08:00
Feng 4e474ee8b9 fix issue #427 - Optimization for Route ETS insertion 2016-01-12 14:10:50 +08:00
Feng 3745d7a24b router pool sup 2016-01-12 14:09:31 +08:00
Feng ba5541c768 Move the aging code to router 2016-01-12 14:02:21 +08:00
Feng 20ede24d83 fix issue #427 - Optimization for Route ETS insertion 2016-01-12 14:01:28 +08:00
Feng 6e3ae6412d -type topic() :: binary(). 2016-01-12 13:58:24 +08:00
Feng 78f2a83a82 0.15 2016-01-07 13:21:14 +08:00
Feng 1809d0960d ~p 2016-01-02 17:01:24 +08:00
Feng 32b1448204 0.14.1 2015-12-28 20:20:24 +08:00
Feng 4a175bfc68 fix spec 2015-12-28 20:18:31 +08:00
Feng 4ec480af0b fix spec 2015-12-28 20:17:18 +08:00
Feng e6e77953f1 delete 2015-12-27 21:56:31 +08:00
Feng 2dd8c3d778 remove trap_exit flag, and fix issue #413 2015-12-23 23:20:05 +08:00
Feng 78dd1f8838 fix issue #413 2015-12-23 22:33:49 +08:00
Feng 6ec5eccd69 fix issue #411 2015-12-17 17:30:49 +08:00
Feng be390d42ac stop 2015-12-17 14:12:45 +08:00
Feng 7ffa25c655 destroy 2015-12-17 14:12:35 +08:00
Feng fe82fde717 subscription 2015-12-17 12:38:13 +08:00
Feng e37b00a9e4 fix subscriptions cli 2015-12-16 11:04:51 +08:00
Feng 7cd5367f3b binary 2015-12-16 11:04:20 +08:00
Feng d3ee464789 topics, subscriptions 2015-12-16 10:22:37 +08:00
Feng b172a78fcd lookup/2, tune_qos 2015-12-16 10:18:28 +08:00
Feng 787a427fda fix load/1 return 2015-12-10 21:30:26 +08:00
Feng ab556b6bda rm subscriptions from sess_info 2015-12-10 16:49:58 +08:00
Feng 11bdcf1017 fix already_exists 2015-12-10 15:55:24 +08:00
Feng 2dd6d160f3 format 2015-12-10 15:04:13 +08:00
Feng 26893c764c serilize 2015-12-10 14:09:05 +08:00
Feng Lee e1e09599ef Merge branch '0.14' of github.com:emqtt/emqttd into 0.14 2015-12-09 15:41:37 +08:00
Feng Lee 05bf24b33b serializer 2015-12-09 15:41:03 +08:00
Feng 00f362fabc publish(To, ... 2015-12-07 21:35:06 +08:00
Feng 3a8ada21e0 dispatch 2015-12-07 21:30:58 +08:00
Feng 3d8e91bc20 comment io:format 2015-12-07 21:30:45 +08:00
Feng 9e0fe19c25 qos 2015-12-07 21:20:35 +08:00
Feng fd6a350d9c dispatch 2015-12-07 21:19:12 +08:00
Feng df5daaac5b dispatch 2015-12-07 21:17:30 +08:00
Feng af02965555 comment start_tracelog 2015-12-07 18:38:07 +08:00
Feng fe69fd95c8 {read_concurrency, true} 2015-12-07 17:12:45 +08:00
Feng 4cde27d724 read_concurrency 2015-12-07 14:33:23 +08:00
Feng 8f22b0ffbc route 2015-12-07 00:22:40 +08:00
Feng f4d09c973d remove mnesia index 2015-12-06 20:32:03 +08:00
Feng c29fd68dd5 storage_properties 2015-12-06 20:30:59 +08:00
Feng a261f3c678 emqtt log 2015-12-06 12:03:05 +08:00
Feng Lee 17896c7e77 fix issue #161 - Feature Request - Log Topics 2015-12-06 11:28:05 +08:00
Feng b0ada8ae56 fmt 2015-12-05 20:06:41 +08:00
Feng e3cd170683 0.14 2015-12-05 15:43:49 +08:00
Feng 855152f653 spec/1 2015-12-05 02:18:06 +08:00
Feng 0c13490092 os:timestamp 2015-12-05 02:13:22 +08:00
Feng 1ca477ffa1 monitors 2015-12-05 02:12:27 +08:00
Feng Lee d6a528e0f7 0.14 refactor 2015-12-04 23:53:42 +08:00
Feng 812779004f new pubsub 2015-12-04 17:36:09 +08:00
Feng cfaa0c5e40 0.14 2015-12-03 22:28:39 +08:00
Feng 4deb96dc91 0.14 2015-12-03 21:17:07 +08:00
Feng 86460cdebc 0.14 2015-12-03 21:15:25 +08:00
Feng 392b008a43 TODO: subscriptions 2015-12-03 13:14:32 +08:00
Feng 80117c1e8a rewrite pubsub, router 2015-12-03 12:56:13 +08:00
Feng db8b7c9d82 0.14 2015-12-02 18:01:51 +08:00
Feng 16f23406a4 0.14 2015-12-02 18:01:26 +08:00
Feng 0b1540f1db comment process_flag(priority, high) 2015-11-28 11:26:53 +08:00
Feng e78d4fc39b fix issue #383 2015-11-27 22:36:12 +08:00
Feng df8414dbdc 0.13.1 2015-11-27 21:01:18 +08:00
Feng 2d1066517f Msg = 2015-11-14 14:44:25 +08:00
Feng Lee e05f0cb5b1 Merge pull request #382 from emqtt/chat 
QOS0/1/2, Pooler Error
 2015-11-14 10:46:45 +08:00
Feng 860183f931 chat 2015-11-12 13:07:46 +08:00
Feng 9effc2fad7 monitors 2015-11-11 12:18:13 +08:00
Feng 4fb018203e fix issue #377 2015-11-11 09:46:23 +08:00
Feng 7d54cd8e5d rate limit log 2015-11-08 14:42:38 +08:00
Feng e25856e9a1 fix issue #374 2015-11-07 23:09:31 +08:00
Feng 21a5f3ee33 hibernate 2015-11-07 22:45:57 +08:00
Feng 64a34b216c format 2015-11-07 20:46:31 +08:00
Feng Lee bdea67cf2c Merge pull request #371 from emqtt/0.13 
fix issue #357 - Cannot kick transient client out when clientId colli…
 2015-11-06 21:31:12 +08:00
Feng 59b401c506 fix issue #357 - Cannot kick transient client out when clientId collision 2015-11-06 21:26:46 +08:00
Feng 38fb211719 Merge branch 'master' of github.com:emqtt/emqttd 2015-11-06 12:30:27 +08:00
Feng d227ba3ced warning 2015-11-06 12:30:07 +08:00
Feng 4e0220ae81 ok 2015-11-05 12:40:06 +08:00
Feng 22889f552c fix issue #163 - Protocol Compliant - Session Present Flag 2015-11-05 12:29:29 +08:00
Feng 8491467bbb support 'and', 'or' 2015-11-04 21:42:17 +08:00
Feng d09721301e conflict 2015-11-04 10:22:49 +08:00
Feng 9bad2bf65b support Seq 2015-11-03 12:52:27 +08:00
Feng ea564ec8ef mod 2015-11-02 20:34:23 +08:00
Feng ecc0f052ef reply 2015-11-02 15:51:34 +08:00
Feng cff4ca0296 vsn 2015-11-02 15:51:24 +08:00
Feng 3c69d1a5c1 fix log 2015-11-02 15:00:43 +08:00
Feng 83d4801fe8 disc_copies 2015-11-01 20:45:13 +08:00
Feng 4b26291cb9 client(State) 2015-11-01 20:44:21 +08:00
Feng c7f0e33674 rate limit 2015-11-01 16:03:32 +08:00
Feng cf95c5e1b9 0.13 refactor 2015-10-31 18:43:04 +08:00
Feng 3f41a6c241 peername 2015-10-31 15:08:25 +08:00
Feng f9027ed1f4 fix issue #367 - Fix the order of emqttd_app:start_server/1 2015-10-31 15:07:50 +08:00
Feng b9962d697c 0.13.0 2015-10-30 21:23:17 +08:00
Feng 4ed62d018e refactor log 2015-10-30 21:20:37 +08:00
Feng Lee 19930b6382 refactor protocol 2015-10-30 18:00:23 +08:00
Feng f6636a9783 refactor client 2015-10-30 16:03:25 +08:00
Feng f4cf90ae91 refactor client 2015-10-30 16:00:11 +08:00
Feng Lee 565c8abb3a improve suback 2015-10-26 16:30:39 +08:00
Feng 47710c36aa port_command 2015-10-26 09:25:57 +08:00
Feng 976c7653f3 use esockd_rate_limiter 2015-10-26 09:25:40 +08:00
Feng f58f42196a 0.12.4 2015-10-26 09:21:24 +08:00
Feng 2af91ea140 link with client 2015-10-26 09:21:03 +08:00
Feng fb9f1bf8e4 rate_limit 2015-10-26 09:20:13 +08:00
Feng 59ca283eb0 gen_server 2015-10-23 18:06:35 +08:00
Feng fd7276c587 0.12.3 2015-10-22 10:31:29 +08:00
Feng 8bddc3e327 comment binary 2015-10-22 10:31:03 +08:00
Feng 52d63125d3 improve log and fix issue #353 2015-10-21 21:36:56 +08:00
Feng 86ea9c844f fix issue #350 2015-10-21 21:18:36 +08:00
Feng 7530bfb5fa ets:insert 2015-10-19 09:45:36 +08:00
Feng 6faf488701 ets:insert 2015-10-19 09:45:31 +08:00
Feng 67ebff26ce 0.12.2 2015-10-16 15:07:25 +08:00
Feng a35d51ea24 fix issue #346 2015-10-16 14:58:51 +08:00
Feng fae3e1e32f AckFun 2015-10-15 18:59:51 +08:00
Feng Lee 221124d7b2 fix issue #266 - will not count publish 2015-10-14 19:07:41 +08:00
Feng Lee e3b5c6be4e PUBLISH_PACKET 2015-10-14 18:56:43 +08:00
Feng 3dd42b65cf /status 2015-10-13 23:03:02 +08:00
Feng a16e527975 0.12.1 refactor 2015-10-13 21:09:13 +08:00
Feng 05ff1ab002 gen_event 2015-10-13 21:08:56 +08:00
Feng ebf203a931 refactor metrics 2015-10-13 21:05:11 +08:00
Feng 6a66ca90b1 concat 2015-10-13 21:04:15 +08:00
Feng 5daeac083c spec 2015-10-13 21:03:25 +08:00
Feng 43523f2a1c received/sent metrics 2015-10-13 21:03:01 +08:00
Feng d3e39ae9a3 src/emqttd_mod_rewrite.erl 2015-10-13 21:01:53 +08:00
Feng a055a0a0c8 IS_PUBSUB 2015-10-13 20:56:10 +08:00
Feng 192dc85304 id 2015-10-13 20:55:33 +08:00
Feng 063f59f846 fix process_info 2015-10-12 21:07:05 +08:00
Feng d4a434176a sysmon 2015-10-12 21:06:47 +08:00
Feng 6209d47aae name 2015-10-12 21:06:18 +08:00
Feng 4825591565 name 2015-10-12 21:06:01 +08:00
Feng deaf220343 sysmon 2015-10-12 21:05:37 +08:00
Feng 47e3e826dc 0.12.1 2015-10-12 21:03:01 +08:00
Feng Lee 20cfc2754c broker 2015-10-11 21:10:47 +08:00
Feng 8eb54cc2c3 fix issue #68 - /# topics will not match #, +/# 2015-10-11 15:27:56 +08:00
Feng 87b5245494 rm space 2015-10-11 04:02:33 +08:00
Feng 13001396de cli 2015-10-11 03:03:07 +08:00
Feng b9b75fdb65 add 'dist' module 2015-10-11 02:48:32 +08:00
Feng 6bc3e70f46 export node_name/1 2015-10-10 20:12:24 +08:00
Feng 7af13af848 warning 2015-10-10 19:56:43 +08:00
Feng aad1f3547f allow to override command 2015-10-10 19:47:38 +08:00
Feng Lee b59a8664eb fix issue #282 - emqttd_sm optimized 2015-10-10 14:32:33 +08:00
Feng Lee f57e6b43db critical -> error 2015-10-10 13:36:06 +08:00
Feng Lee fa84a2595b critical -> error 2015-10-10 13:30:50 +08:00
Feng Lee 1935b414c7 issue #282 - improve sm 2015-10-10 13:12:00 +08:00
Feng Lee d63f043566 fix timer 2015-10-10 11:53:31 +08:00
Feng 5977c44996 fix issue #182 - etained message expiration 2015-10-10 00:04:07 +08:00
Feng 0a5d1f9e3e {local, ?MODULE} 2015-10-10 00:01:07 +08:00
Feng 24336d006f 0.12.0 2015-10-08 14:54:31 +08:00
Feng d5a400c308 fix issue #292 - async sub/unsub 2015-10-04 19:48:50 +08:00
Feng 78288e8088 improve keepalie 2015-10-04 19:43:58 +08:00
Feng a6770e3727 mnesia 2015-10-01 16:10:21 +08:00
Feng 1fab8084e1 rm cli 2015-10-01 11:23:37 +08:00
Feng 354ae6f398 sort 2015-10-01 11:23:24 +08:00
Feng 14d2de3b05 MODUEL as pool name 2015-10-01 11:22:57 +08:00
Feng e7b6778a43 rm cli 2015-10-01 11:22:33 +08:00
Feng d7ca17b336 dump 2015-10-01 11:22:18 +08:00
Feng af14bf9329 rm cli 2015-10-01 11:22:01 +08:00
Feng b946f3df9b new ctl 2015-10-01 11:21:43 +08:00
Feng dcca96b6ae MODULE as pool name 2015-10-01 11:21:27 +08:00
Feng 95928f6f75 rm cli 2015-10-01 11:20:41 +08:00
Feng b539a719a8 rm cli 2015-10-01 11:20:22 +08:00
Feng bafff792fa useradd, userdel cli 2015-10-01 11:20:01 +08:00
Feng d3ce7dcae1 emqttd_ctl 2015-10-01 11:19:24 +08:00
Feng 91bd0c654c cli 2015-10-01 11:17:35 +08:00
Feng Lee e09148b040 cli 2015-09-30 03:06:17 +08:00
Feng Lee 470d5644ef priority, high 2015-09-29 17:31:10 +08:00
Feng Lee f15e8bc630 print ack timout 2015-09-29 12:10:55 +08:00
Feng Lee f57affa2b3 fix MFArgs 2015-09-29 11:27:48 +08:00
Feng 86a1f7f7d4 fix issue #264 2015-09-29 10:10:30 +08:00
Feng dfc3194d53 env 2015-09-29 10:09:21 +08:00
Feng Lee 23095af55f fix issue #318 2015-09-28 21:45:44 +08:00
Feng Lee d7cdc477b4 fix issue #311 2015-09-24 22:38:08 +08:00
Feng Lee 4df2e5b552 0.11.0 2015-09-22 14:51:08 +08:00
Feng Lee ba9534a683 fix issue #306 2015-09-21 21:11:42 +08:00
Feng Lee fddbdd1bb9 copy schema 2015-09-19 11:42:36 +08:00
Feng Lee 22170b6c6d timer:seconds 2015-09-19 09:47:17 +08:00
Feng Lee 4c8b18389f Merge pull request #301 from emqtt/dev-feng 
Fix issue #284
 2015-09-18 10:42:30 +08:00
Feng Lee 7e06163587 Merge pull request #300 from emqtt/issue#292 
Issue#292
 2015-09-18 10:32:07 +08:00
Feng 74d0ef9a95 fix issue #297 - support variable 2015-09-18 10:09:10 +08:00
Feng Lee 107c317e11 10000 2015-09-16 22:19:02 +08:00
Feng Lee 3e899ab7a2 fix issue #284 - the stupid list_to_atom... 2015-09-16 22:11:17 +08:00
Feng Lee 12b4bc9697 misc 2015-09-16 21:52:18 +08:00
Feng 9c53d2d3ba session/1 api 2015-09-16 00:05:48 +08:00
Feng ea70389cf7 ignore duplicated subscriptions 2015-09-11 14:18:30 +08:00
Feng ac9eb43e5e 0.10.4 2015-09-11 10:50:08 +08:00
Feng 6a1159ed3f SESSION_TIMEOUT 2015-09-10 16:17:26 +08:00
Feng fa25d60893 fix issue#280 2015-09-10 11:18:30 +08:00
Feng e6f358a6dd warning 2015-08-31 13:19:59 +08:00
Feng Lee 587cf4609a 0.10.3 2015-08-30 10:38:07 +08:00
Feng Lee 5117d88b7a warning 2015-08-30 10:23:26 +08:00
Feng 35bc96807e Merge branch 'master' into dev-feng 2015-08-27 19:54:26 +08:00
Feng 07b717104b emqttd_ws_client:subscribe/2 api 2015-08-26 21:47:21 +08:00
Feng 0f73dbf4a8 0.10.2 2015-08-25 23:44:40 +08:00
Feng 4698d040fd fix issue #262 2015-08-25 13:49:28 +08:00
Feng b08c39db52 stop_listeners 2015-08-24 22:20:32 +08:00