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

Remove the fullsweep_after option

This commit is contained in:
Feng Lee 2017-08-07 12:15:52 +08:00
parent ffebce5090
commit 925e35dcbd
2 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/emqttd_client.erl
View File

@ -66,7 +66,7 @@
[esockd_net:format(State#client_state.peername) | Args])). [esockd_net:format(State#client_state.peername) | Args])).
start_link(Conn, Env) -> start_link(Conn, Env) ->
{ok, proc_lib:spawn_opt(?MODULE, init, [[Conn, Env]], [link | ?FULLSWEEP_OPTS])}. {ok, proc_lib:spawn_link(?MODULE, init, [[Conn, Env]])}.
info(CPid) -> info(CPid) ->
gen_server2:call(CPid, info). gen_server2:call(CPid, info).

5
src/emqttd_session.erl
View File

@ -174,8 +174,7 @@
%% @doc Start a Session %% @doc Start a Session
-spec(start_link(boolean(), {mqtt_client_id(), mqtt_username()}, pid()) -> {ok, pid()} | {error, any()}). -spec(start_link(boolean(), {mqtt_client_id(), mqtt_username()}, pid()) -> {ok, pid()} | {error, any()}).
start_link(CleanSess, {ClientId, Username}, ClientPid) -> start_link(CleanSess, {ClientId, Username}, ClientPid) ->
gen_server2:start_link(?MODULE, [CleanSess, {ClientId, Username}, ClientPid], gen_server2:start_link(?MODULE, [CleanSess, {ClientId, Username}, ClientPid], []).
[{spawn_opt, ?FULLSWEEP_OPTS}]). %% Tune GC.
%%-------------------------------------------------------------------- %%--------------------------------------------------------------------
%% PubSub API %% PubSub API
@ -183,7 +182,7 @@ start_link(CleanSess, {ClientId, Username}, ClientPid) ->
%% @doc Subscribe topics %% @doc Subscribe topics
-spec(subscribe(pid(), [{binary(), [emqttd_topic:option()]}]) -> ok). -spec(subscribe(pid(), [{binary(), [emqttd_topic:option()]}]) -> ok).
subscribe(Session, TopicTable) ->%%TODO: the ack function??... subscribe(Session, TopicTable) -> %%TODO: the ack function??...
gen_server2:cast(Session, {subscribe, self(), TopicTable, fun(_) -> ok end}). gen_server2:cast(Session, {subscribe, self(), TopicTable, fun(_) -> ok end}).
-spec(subscribe(pid(), mqtt_packet_id(), [{binary(), [emqttd_topic:option()]}]) -> ok). -spec(subscribe(pid(), mqtt_packet_id(), [{binary(), [emqttd_topic:option()]}]) -> ok).