-compile(export_all)
This commit is contained in:
parent
3d7d473f35
commit
6930439158
|
@ -18,10 +18,6 @@
|
||||||
|
|
||||||
-export([apply_module_attributes/1, all_module_attributes/1]).
|
-export([apply_module_attributes/1, all_module_attributes/1]).
|
||||||
|
|
||||||
-ifdef(TEST).
|
|
||||||
-compile(export_all).
|
|
||||||
-endif.
|
|
||||||
|
|
||||||
%% only {F, Args}...
|
%% only {F, Args}...
|
||||||
apply_module_attributes(Name) ->
|
apply_module_attributes(Name) ->
|
||||||
[{Module, [apply(Module, F, Args) || {F, Args} <- Attrs]} ||
|
[{Module, [apply(Module, F, Args) || {F, Args} <- Attrs]} ||
|
||||||
|
|
|
@ -28,10 +28,6 @@
|
||||||
|
|
||||||
-export([format/1]).
|
-export([format/1]).
|
||||||
|
|
||||||
-ifdef(TEST).
|
|
||||||
-compile(export_all).
|
|
||||||
-endif.
|
|
||||||
|
|
||||||
%% @doc Make a message
|
%% @doc Make a message
|
||||||
-spec make(From, Topic, Payload) -> mqtt_message() when
|
-spec make(From, Topic, Payload) -> mqtt_message() when
|
||||||
From :: atom() | binary(),
|
From :: atom() | binary(),
|
||||||
|
|
|
@ -30,9 +30,6 @@
|
||||||
%% Schema and tables
|
%% Schema and tables
|
||||||
-export([copy_schema/1, delete_schema/0, del_schema_copy/1,
|
-export([copy_schema/1, delete_schema/0, del_schema_copy/1,
|
||||||
create_table/2, copy_table/1, copy_table/2]).
|
create_table/2, copy_table/1, copy_table/2]).
|
||||||
-ifdef(TEST).
|
|
||||||
-compile(export_all).
|
|
||||||
-endif.
|
|
||||||
|
|
||||||
%%--------------------------------------------------------------------
|
%%--------------------------------------------------------------------
|
||||||
%% Start and init mnesia
|
%% Start and init mnesia
|
||||||
|
|
|
@ -27,10 +27,6 @@
|
||||||
|
|
||||||
-record(state, {topics, stored = false}).
|
-record(state, {topics, stored = false}).
|
||||||
|
|
||||||
-ifdef(TEST).
|
|
||||||
-compile(export_all).
|
|
||||||
-endif.
|
|
||||||
|
|
||||||
load(Opts) ->
|
load(Opts) ->
|
||||||
Topics = [{iolist_to_binary(Topic), QoS} || {Topic, QoS} <- Opts, ?IS_QOS(QoS)],
|
Topics = [{iolist_to_binary(Topic), QoS} || {Topic, QoS} <- Opts, ?IS_QOS(QoS)],
|
||||||
State = #state{topics = Topics, stored = lists:member(stored, Opts)},
|
State = #state{topics = Topics, stored = lists:member(stored, Opts)},
|
||||||
|
|
|
@ -26,10 +26,6 @@
|
||||||
|
|
||||||
-export([format/1]).
|
-export([format/1]).
|
||||||
|
|
||||||
-ifdef(TEST).
|
|
||||||
-compile(export_all).
|
|
||||||
-endif.
|
|
||||||
|
|
||||||
%% @doc Protocol name of version
|
%% @doc Protocol name of version
|
||||||
-spec protocol_name(mqtt_vsn()) -> binary().
|
-spec protocol_name(mqtt_vsn()) -> binary().
|
||||||
protocol_name(Ver) when Ver =:= ?MQTT_PROTO_V31; Ver =:= ?MQTT_PROTO_V311 ->
|
protocol_name(Ver) when Ver =:= ?MQTT_PROTO_V31; Ver =:= ?MQTT_PROTO_V311 ->
|
||||||
|
|
|
@ -43,10 +43,6 @@
|
||||||
-export([init/1, handle_call/3, handle_cast/2, handle_info/2,
|
-export([init/1, handle_call/3, handle_cast/2, handle_info/2,
|
||||||
terminate/2, code_change/3]).
|
terminate/2, code_change/3]).
|
||||||
|
|
||||||
-ifdef(TEST).
|
|
||||||
-compile(export_all).
|
|
||||||
-endif.
|
|
||||||
|
|
||||||
-record(state, {pool, id, statsfun}).
|
-record(state, {pool, id, statsfun}).
|
||||||
|
|
||||||
-define(ROUTER, emqttd_router).
|
-define(ROUTER, emqttd_router).
|
||||||
|
|
|
@ -31,10 +31,6 @@
|
||||||
%% Supervisor callbacks
|
%% Supervisor callbacks
|
||||||
-export([init/1]).
|
-export([init/1]).
|
||||||
|
|
||||||
-ifdef(TEST).
|
|
||||||
-compile(export_all).
|
|
||||||
-endif.
|
|
||||||
|
|
||||||
start_link() ->
|
start_link() ->
|
||||||
supervisor:start_link({local, ?MODULE}, ?MODULE, [emqttd_broker:env(pubsub)]).
|
supervisor:start_link({local, ?MODULE}, ?MODULE, [emqttd_broker:env(pubsub)]).
|
||||||
|
|
||||||
|
|
|
@ -45,10 +45,6 @@
|
||||||
-export([init/1, handle_call/3, handle_cast/2, handle_info/2,
|
-export([init/1, handle_call/3, handle_cast/2, handle_info/2,
|
||||||
terminate/2, code_change/3]).
|
terminate/2, code_change/3]).
|
||||||
|
|
||||||
-ifdef(TEST).
|
|
||||||
-compile(export_all).
|
|
||||||
-endif.
|
|
||||||
|
|
||||||
-record(aging, {topics, time, tref}).
|
-record(aging, {topics, time, tref}).
|
||||||
|
|
||||||
-record(state, {pool, id, aging :: #aging{}, statsfun}).
|
-record(state, {pool, id, aging :: #aging{}, statsfun}).
|
||||||
|
|
Loading…
Reference in New Issue