diff --git a/src/emqttd_client.erl b/src/emqttd_client.erl index dedfcf1df..c7167c8a7 100644 --- a/src/emqttd_client.erl +++ b/src/emqttd_client.erl @@ -66,7 +66,7 @@ [esockd_net:format(State#client_state.peername) | Args])). 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) -> gen_server2:call(CPid, info). diff --git a/src/emqttd_session.erl b/src/emqttd_session.erl index 31934759f..e8e694530 100644 --- a/src/emqttd_session.erl +++ b/src/emqttd_session.erl @@ -174,8 +174,7 @@ %% @doc Start a Session -spec(start_link(boolean(), {mqtt_client_id(), mqtt_username()}, pid()) -> {ok, pid()} | {error, any()}). start_link(CleanSess, {ClientId, Username}, ClientPid) -> - gen_server2:start_link(?MODULE, [CleanSess, {ClientId, Username}, ClientPid], - [{spawn_opt, ?FULLSWEEP_OPTS}]). %% Tune GC. + gen_server2:start_link(?MODULE, [CleanSess, {ClientId, Username}, ClientPid], []). %%-------------------------------------------------------------------- %% PubSub API @@ -183,7 +182,7 @@ start_link(CleanSess, {ClientId, Username}, ClientPid) -> %% @doc Subscribe topics -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}). -spec(subscribe(pid(), mqtt_packet_id(), [{binary(), [emqttd_topic:option()]}]) -> ok).