diff --git a/src/emqttd_pool_sup.erl b/src/emqttd_pool_sup.erl index bc8f59562..fa1d6aace 100644 --- a/src/emqttd_pool_sup.erl +++ b/src/emqttd_pool_sup.erl @@ -36,7 +36,7 @@ spec(ChildId, Args) -> {ChildId, {?MODULE, start_link, Args}, transient, infinity, supervisor, [?MODULE]}. --spec(start_link(atom(), atom(), mfa()) -> {ok, pid()} | {error, any()}). +-spec(start_link(atom() | tuple(), atom(), mfa()) -> {ok, pid()} | {error, any()}). start_link(Pool, Type, MFA) -> Schedulers = erlang:system_info(schedulers), start_link(Pool, Type, Schedulers, MFA). diff --git a/src/emqttd_router.erl b/src/emqttd_router.erl index 3da32b845..e4a42b85d 100644 --- a/src/emqttd_router.erl +++ b/src/emqttd_router.erl @@ -109,7 +109,7 @@ add_route(Topic, Node) when is_binary(Topic), is_atom(Node) -> add_route(#mqtt_route{topic = Topic, node = Node}). %% @doc Add Routes --spec(add_routes([mqtt_route()]) -> ok | {errory, Reason :: any()}). +-spec(add_routes([mqtt_route()]) -> ok | {error, Reason :: any()}). add_routes(Routes) -> AddFun = fun() -> [add_route_(Route) || Route <- Routes] end, case mnesia:is_transaction() of