yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

merge emqttc

This commit is contained in:
Ery Lee 2015-03-04 22:11:17 +08:00
parent ecaf3a13af bb2e8c9653
commit 9512b18c53
3 changed files with 32 additions and 31 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

48
TODO
View File

@ -2,33 +2,7 @@
===== =====
merge emqttc code... merge emqttc code...
0.6.0
0.2.2
=====
merge pull request#26
0.2.0
=====
1. project structure...
2. apps, deps, plugins,
3. rel...
4. mochiweb: http publish...
5 cluster...
6. support MQTT3.1.1...
7. python, java test code
8. emqtt_cm to manager clientId, clientPid...
????
{ok, {{simple_one_for_one_terminate, 0, 1},
[{client, {emqtt_client, start_link, []},
temporary, 5000, worker, [emqtt_client]}]}}.
fucking stupid..... esockd locked
0.2.1
===== =====
one million connections test... one million connections test...
@ -41,3 +15,23 @@ full test cases...
spawn_link to replace 'spawn' and 'link' spawn_link to replace 'spawn' and 'link'
=======
## ACL
## Authentication with clientId
## SSL/TLS Socket
## $SYS/topics and Broker statistics...
## Cluster
## Bridge
## Websocket
## MQTT over Websocket
## Mnesia
Create Schema...

2
apps/emqtt/src/emqtt_net.erl
View File

@ -194,7 +194,7 @@ getopts(Sock, Options) when is_port(Sock) ->
setopts(Sock, Options) when is_port(Sock) -> setopts(Sock, Options) when is_port(Sock) ->
inet:setopts(Sock, Options). inet:setopts(Sock, Options).
sockname(Sock) when is_port(Sock) -> inet:sockname(Sock). sockname(Sock) when is_port(Sock) -> inet:sockname(Sock).
peer_string(Sock) -> peer_string(Sock) ->
case peername(Sock) of case peername(Sock) of

13
doc/design.md
View File

@ -22,9 +22,16 @@ Router to register queues
## Topic Tree ## Topic Tree
## Offline Message
## ACL
## Authentication with clientId
## SSL/TLS Socket
## $SYS/topics and Broker statistics...
## Cluster ## Cluster
## Bridge ## Bridge
## Offline Message