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

fix sslsocket

This commit is contained in:
Ery Lee 2015-03-02 01:57:54 +08:00
parent f8c3948ca3
commit cc8aeb6a1f
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
apps/emqtt/src/emqtt_client.erl
View File

@ -54,19 +54,20 @@
}). }).
start_link(SockArgs) -> start_link(SockArgs) ->
io:format("start_link: ~p~n", [SockArgs]),
{ok, proc_lib:spawn_link(?MODULE, init, [SockArgs])}. {ok, proc_lib:spawn_link(?MODULE, init, [SockArgs])}.
info(Pid) -> info(Pid) ->
gen_server:call(Pid, info). gen_server:call(Pid, info).
init([SockArgs = {Transport, Sock, _SockFun}]) -> init(SockArgs = {Transport, Sock, _SockFun}) ->
%%TODO: replace emqtt_net?? %%TODO: replace emqtt_net??
{ok, NewSock} = esockd_connection:accept(SockArgs),
{ok, Peername} = emqtt_net:peer_string(Sock), {ok, Peername} = emqtt_net:peer_string(Sock),
{ok, ConnStr} = emqtt_net:connection_string(Sock, inbound), {ok, ConnStr} = emqtt_net:connection_string(Sock, inbound),
lager:info("Connect from ~s", [ConnStr]), lager:info("Connect from ~s", [ConnStr]),
{ok, NewSock} = esockd_connection:accept(SockArgs),
State = control_throttle(#state{transport = Transport, State = control_throttle(#state{transport = Transport,
socket = Sock, socket = NewSock,
peer_name = Peername, peer_name = Peername,
conn_name = ConnStr, conn_name = ConnStr,
await_recv = false, await_recv = false,