diff options
Diffstat (limited to 'src')
-rw-r--r-- | src/Makefile | 6 | ||||
-rw-r--r-- | src/ejabberd.cfg | 20 | ||||
-rw-r--r-- | src/ejabberd.erl | 2 | ||||
-rw-r--r-- | src/ejabberd.hrl | 2 | ||||
-rw-r--r-- | src/ejabberd_auth.erl | 11 | ||||
-rw-r--r-- | src/ejabberd_c2s.erl | 14 | ||||
-rw-r--r-- | src/ejabberd_config.erl | 1 | ||||
-rw-r--r-- | src/ejabberd_s2s_in.erl | 14 | ||||
-rw-r--r-- | src/ejabberd_s2s_out.erl | 42 | ||||
-rw-r--r-- | src/gen_mod.erl | 58 | ||||
-rw-r--r-- | src/jlib.erl | 36 | ||||
-rw-r--r-- | src/mod_configure.erl | 9 | ||||
-rw-r--r-- | src/mod_disco.erl | 21 | ||||
-rw-r--r-- | src/mod_echo.erl | 14 | ||||
-rw-r--r-- | src/mod_offline.erl | 6 | ||||
-rw-r--r-- | src/mod_private.erl | 7 | ||||
-rw-r--r-- | src/mod_register.erl | 11 | ||||
-rw-r--r-- | src/mod_roster.erl | 7 | ||||
-rw-r--r-- | src/mod_stats.erl | 7 | ||||
-rw-r--r-- | src/mod_time.erl | 7 | ||||
-rw-r--r-- | src/mod_vcard.erl | 18 | ||||
-rw-r--r-- | src/mod_version.erl | 7 |
22 files changed, 233 insertions, 87 deletions
diff --git a/src/Makefile b/src/Makefile index 6bee2bb33..08073153e 100644 --- a/src/Makefile +++ b/src/Makefile @@ -8,7 +8,8 @@ LIBDIRS = -L/usr/lib/erlang/lib/erl_interface-3.3.0/lib ERLSHLIBS = expat_erl.so all: $(ERLSHLIBS) - erl -make + erl -s make all report -noinput -s erlang halt + etags *.erl $(ERLSHLIBS): %.so: %.c gcc -Wall $(INCLUDES) $(LIBDIRS) \ @@ -18,3 +19,6 @@ $(ERLSHLIBS): %.so: %.c -lei \ -o $@ -fpic -shared \ +clean: + rm -f *.beam + diff --git a/src/ejabberd.cfg b/src/ejabberd.cfg index c616cbfb4..a949a7cf8 100644 --- a/src/ejabberd.cfg +++ b/src/ejabberd.cfg @@ -22,17 +22,17 @@ ]}. {modules, [ - {mod_register, [one_queue]}, - {mod_roster, [one_queue]}, - {mod_configure, [one_queue]}, - {mod_disco, [one_queue]}, - {mod_stats, [one_queue]}, - {mod_vcard, [one_queue]}, + {mod_register, []}, + {mod_roster, []}, + {mod_configure, []}, + {mod_disco, []}, + {mod_stats, []}, + {mod_vcard, []}, {mod_offline, []}, - {mod_echo, []}, - {mod_private, [one_queue]}, - {mod_time, [one_queue]}, - {mod_version, [one_queue]} + {mod_echo, [{host, "echo.e.localhost"}]}, + {mod_private, []}, + {mod_time, [{iqdisc, no_queue}]}, + {mod_version, []} ]}. diff --git a/src/ejabberd.erl b/src/ejabberd.erl index be9deb6a3..4a2b34404 100644 --- a/src/ejabberd.erl +++ b/src/ejabberd.erl @@ -61,7 +61,7 @@ load_modules() -> ok; Modules -> lists:foreach(fun({Module, Args}) -> - apply(Module, start, Args) + gen_mod:start_module(Module, Args) end, Modules) end. diff --git a/src/ejabberd.hrl b/src/ejabberd.hrl index 5e453fd5b..c05f766df 100644 --- a/src/ejabberd.hrl +++ b/src/ejabberd.hrl @@ -19,7 +19,7 @@ -endif. -define(ERROR_MSG(Format, Args), - error_logger:format("D(~p:~p:~p) : "++Format++"~n", + error_logger:format("E(~p:~p:~p): "++Format++"~n", [self(),?MODULE,?LINE]++Args)). diff --git a/src/ejabberd_auth.erl b/src/ejabberd_auth.erl index 809d3dfd8..7715a01ff 100644 --- a/src/ejabberd_auth.erl +++ b/src/ejabberd_auth.erl @@ -26,7 +26,12 @@ is_user_exists/1]). %% gen_server callbacks --export([init/1, handle_call/3, handle_cast/2, handle_info/2, terminate/2]). +-export([init/1, + handle_call/3, + handle_cast/2, + code_change/3, + handle_info/2, + terminate/2]). -record(state, {}). @@ -78,6 +83,10 @@ handle_call(Request, From, State) -> handle_cast(Msg, State) -> {noreply, State}. + +code_change(OldVsn, State, Extra) -> + {ok, State}. + %%---------------------------------------------------------------------- %% Func: handle_info/2 %% Returns: {noreply, State} | diff --git a/src/ejabberd_c2s.erl b/src/ejabberd_c2s.erl index 0f168f323..c1f7ebc5d 100644 --- a/src/ejabberd_c2s.erl +++ b/src/ejabberd_c2s.erl @@ -20,6 +20,9 @@ % handle_sync_event/4, handle_info/3, terminate/3]). % -export([init/1, wait_for_stream/2, wait_for_auth/2, session_established/2, + handle_event/3, + handle_sync_event/4, + code_change/4, handle_info/3, terminate/3]). @@ -88,8 +91,6 @@ init([Socket]) -> %% {next_state, NextStateName, NextStateData, Timeout} | %% {stop, Reason, NewStateData} %%---------------------------------------------------------------------- -state_name(Event, StateData) -> - {next_state, state_name, StateData}. wait_for_stream({xmlstreamstart, Name, Attrs}, StateData) -> % TODO @@ -212,9 +213,9 @@ session_established(closed, StateData) -> %% {stop, Reason, NewStateData} | %% {stop, Reason, Reply, NewStateData} %%---------------------------------------------------------------------- -state_name(Event, From, StateData) -> - Reply = ok, - {reply, Reply, state_name, StateData}. +%state_name(Event, From, StateData) -> +% Reply = ok, +% {reply, Reply, state_name, StateData}. %%---------------------------------------------------------------------- %% Func: handle_event/3 @@ -238,6 +239,9 @@ handle_sync_event(Event, From, StateName, StateData) -> Reply = ok, {reply, Reply, StateName, StateData}. +code_change(OldVsn, StateName, StateData, Extra) -> + {ok, StateName, StateData}. + %%---------------------------------------------------------------------- %% Func: handle_info/3 %% Returns: {next_state, NextStateName, NextStateData} | diff --git a/src/ejabberd_config.erl b/src/ejabberd_config.erl index 40dc97bf2..51a78592c 100644 --- a/src/ejabberd_config.erl +++ b/src/ejabberd_config.erl @@ -38,6 +38,7 @@ load_file(File) -> {ok, Terms} -> lists:foreach(fun process_term/1, Terms); {error, Reason} -> + ?ERROR_MSG("~p", [Reason]), exit(file:format_error(Reason)) end. diff --git a/src/ejabberd_s2s_in.erl b/src/ejabberd_s2s_in.erl index 6f7d02007..782788ace 100644 --- a/src/ejabberd_s2s_in.erl +++ b/src/ejabberd_s2s_in.erl @@ -21,6 +21,9 @@ wait_for_key/2, wait_for_verification/2, stream_established/2, + handle_event/3, + handle_sync_event/4, + code_change/4, handle_info/3, terminate/3]). @@ -89,8 +92,6 @@ init([Socket]) -> %% {next_state, NextStateName, NextStateData, Timeout} | %% {stop, Reason, NewStateData} %%---------------------------------------------------------------------- -state_name(Event, StateData) -> - {next_state, state_name, StateData}. wait_for_stream({xmlstreamstart, Name, Attrs}, StateData) -> % TODO @@ -270,9 +271,9 @@ stream_established(closed, StateData) -> %% {stop, Reason, NewStateData} | %% {stop, Reason, Reply, NewStateData} %%---------------------------------------------------------------------- -state_name(Event, From, StateData) -> - Reply = ok, - {reply, Reply, state_name, StateData}. +%state_name(Event, From, StateData) -> +% Reply = ok, +% {reply, Reply, state_name, StateData}. %%---------------------------------------------------------------------- %% Func: handle_event/3 @@ -296,6 +297,9 @@ handle_sync_event(Event, From, StateName, StateData) -> Reply = ok, {reply, Reply, StateName, StateData}. +code_change(OldVsn, StateName, StateData, Extra) -> + {ok, StateName, StateData}. + %%---------------------------------------------------------------------- %% Func: handle_info/3 %% Returns: {next_state, NextStateName, NextStateData} | diff --git a/src/ejabberd_s2s_out.erl b/src/ejabberd_s2s_out.erl index d83901b1b..683cd784d 100644 --- a/src/ejabberd_s2s_out.erl +++ b/src/ejabberd_s2s_out.erl @@ -21,8 +21,11 @@ wait_for_stream/2, wait_for_validation/2, stream_established/2, + handle_event/3, + handle_sync_event/4, handle_info/3, - terminate/3]). + terminate/3, + code_change/4]). -include("ejabberd.hrl"). @@ -268,9 +271,9 @@ stream_established(closed, StateData) -> %% {stop, Reason, NewStateData} | %% {stop, Reason, Reply, NewStateData} %%---------------------------------------------------------------------- -state_name(Event, From, StateData) -> - Reply = ok, - {reply, Reply, state_name, StateData}. +%state_name(Event, From, StateData) -> +% Reply = ok, +% {reply, Reply, state_name, StateData}. %%---------------------------------------------------------------------- %% Func: handle_event/3 @@ -294,6 +297,9 @@ handle_sync_event(Event, From, StateName, StateData) -> Reply = ok, {reply, Reply, StateName, StateData}. +code_change(OldVsn, StateName, StateData, Extra) -> + {ok, StateName, StateData}. + %%---------------------------------------------------------------------- %% Func: handle_info/3 %% Returns: {next_state, NextStateName, NextStateData} | @@ -400,20 +406,20 @@ bounce_messages(Reason) -> ok end. -is_key_packet({xmlelement, Name, Attrs, Els}) when Name == "db:result" -> - {key, - xml:get_attr_s("to", Attrs), - xml:get_attr_s("from", Attrs), - xml:get_attr_s("id", Attrs), - xml:get_cdata(Els)}; -is_key_packet({xmlelement, Name, Attrs, Els}) when Name == "db:verify" -> - {verify, - xml:get_attr_s("to", Attrs), - xml:get_attr_s("from", Attrs), - xml:get_attr_s("id", Attrs), - xml:get_cdata(Els)}; -is_key_packet(_) -> - false. +%is_key_packet({xmlelement, Name, Attrs, Els}) when Name == "db:result" -> +% {key, +% xml:get_attr_s("to", Attrs), +% xml:get_attr_s("from", Attrs), +% xml:get_attr_s("id", Attrs), +% xml:get_cdata(Els)}; +%is_key_packet({xmlelement, Name, Attrs, Els}) when Name == "db:verify" -> +% {verify, +% xml:get_attr_s("to", Attrs), +% xml:get_attr_s("from", Attrs), +% xml:get_attr_s("id", Attrs), +% xml:get_cdata(Els)}; +%is_key_packet(_) -> +% false. is_verify_res({xmlelement, Name, Attrs, Els}) when Name == "db:result" -> {result, diff --git a/src/gen_mod.erl b/src/gen_mod.erl new file mode 100644 index 000000000..6978dbe37 --- /dev/null +++ b/src/gen_mod.erl @@ -0,0 +1,58 @@ +%%%---------------------------------------------------------------------- +%%% File : gen_mod.erl +%%% Author : Alexey Shchepin <alexey@sevcom.net> +%%% Purpose : +%%% Created : 24 Jan 2003 by Alexey Shchepin <alexey@sevcom.net> +%%% Id : $Id$ +%%%---------------------------------------------------------------------- + +-module(gen_mod). +-author('alexey@sevcom.net'). +-vsn('$Revision$ '). + +-export([start_module/2, + stop_module/1, + get_opt/2, + get_opt/3]). + +-export([behaviour_info/1]). + +-include("ejabberd.hrl"). + + +behaviour_info(callbacks) -> + [{start, 1}, + {stop, 0}]; +behaviour_info(Other) -> + undefined. + + +start_module(Module, Opts) -> + case catch Module:start(Opts) of + {'EXIT', Reason} -> + ?ERROR_MSG("~p", [Reason]); + _ -> + ok + end. + +stop_module(Module) -> + Module:stop(). + + +get_opt(Opt, Opts) -> + case lists:keysearch(Opt, 1, Opts) of + false -> + % TODO: replace with more appropriate function + [] = {undefined_option, Opt}; + {value, {_, Val}} -> + Val + end. + +get_opt(Opt, Opts, Default) -> + case lists:keysearch(Opt, 1, Opts) of + false -> + Default; + {value, {_, Val}} -> + Val + end. + diff --git a/src/jlib.erl b/src/jlib.erl index 3cf7ed577..c15bc06a4 100644 --- a/src/jlib.erl +++ b/src/jlib.erl @@ -19,6 +19,7 @@ remove_attr/2, string_to_jid/1, jid_to_string/1, + is_nodename/1, tolower/1, jid_tolower/1, jid_remove_resource/1, @@ -133,6 +134,17 @@ string_to_jid1([$/ | J], "") -> error; string_to_jid1([$/ | J], N) -> string_to_jid3(J, "", lists:reverse(N), ""); +string_to_jid1([C | J], N) + when (C =< 32) or + (C == $") or + (C == $&) or + (C == $') or + (C == $:) or + (C == $<) or + (C == $>) or + (C == 127) + -> + error; string_to_jid1([C | J], N) -> string_to_jid1(J, [C | N]); string_to_jid1([], "") -> @@ -173,6 +185,30 @@ jid_to_string({Node, Server, Resource}) -> S3. +is_nodename([]) -> + false; +is_nodename(J) -> + is_nodename1(J). + +is_nodename1([C | J]) + when (C =< 32) or + (C == $") or + (C == $&) or + (C == $') or + (C == $:) or + (C == $<) or + (C == $>) or + (C == $@) or + (C == $/) or + (C == 127) + -> + false; +is_nodename1([C | J]) -> + is_nodename1(J); +is_nodename1([]) -> + true. + + % TODO: UNICODE support tolower_c(C) when C >= $A, C =< $Z -> diff --git a/src/mod_configure.erl b/src/mod_configure.erl index 2567c9963..405ad470b 100644 --- a/src/mod_configure.erl +++ b/src/mod_configure.erl @@ -10,6 +10,8 @@ -author('alexey@sevcom.net'). -vsn('$Revision$ '). +-behaviour(gen_mod). + -export([start/1, process_local_iq/3, process_sm_iq/3]). @@ -18,11 +20,12 @@ -include("namespaces.hrl"). -start(Type) -> +start(Opts) -> + IQDisc = gen_mod:get_opt(iqdisc, Opts, one_queue), gen_iq_handler:add_iq_handler(ejabberd_local, ?NS_XDATA, - ?MODULE, process_local_iq, Type), + ?MODULE, process_local_iq, IQDisc), gen_iq_handler:add_iq_handler(ejabberd_sm, ?NS_XDATA, - ?MODULE, process_sm_iq, Type), + ?MODULE, process_sm_iq, IQDisc), ok. diff --git a/src/mod_disco.erl b/src/mod_disco.erl index 141feaf1d..56bd4b001 100644 --- a/src/mod_disco.erl +++ b/src/mod_disco.erl @@ -10,6 +10,8 @@ -author('alexey@sevcom.net'). -vsn('$Revision$ '). +-behaviour(gen_mod). + -export([start/1, process_local_iq_items/3, process_local_iq_info/3, @@ -24,23 +26,16 @@ {iq, ID, result, XMLNS, [{xmlelement, "query", [{"xmlns", ?NS_DISCO_INFO}], []}]}). -start(Type) -> +start(Opts) -> + IQDisc = gen_mod:get_opt(iqdisc, Opts, one_queue), gen_iq_handler:add_iq_handler(ejabberd_local, ?NS_DISCO_ITEMS, - ?MODULE, process_local_iq_items, Type), + ?MODULE, process_local_iq_items, IQDisc), gen_iq_handler:add_iq_handler(ejabberd_local, ?NS_DISCO_INFO, - ?MODULE, process_local_iq_info, Type), + ?MODULE, process_local_iq_info, IQDisc), gen_iq_handler:add_iq_handler(ejabberd_sm, ?NS_DISCO_ITEMS, - ?MODULE, process_sm_iq_items, Type), + ?MODULE, process_sm_iq_items, IQDisc), gen_iq_handler:add_iq_handler(ejabberd_sm, ?NS_DISCO_INFO, - ?MODULE, process_sm_iq_info, Type), - %ejabberd_local:register_iq_handler(?NS_DISCO_ITEMS, - % ?MODULE, process_local_iq_items), - %ejabberd_local:register_iq_handler(?NS_DISCO_INFO, - % ?MODULE, process_local_iq_info), - %ejabberd_sm:register_iq_handler(?NS_DISCO_ITEMS, - % ?MODULE, process_sm_iq_items), - %ejabberd_sm:register_iq_handler(?NS_DISCO_INFO, - % ?MODULE, process_sm_iq_info), + ?MODULE, process_sm_iq_info, IQDisc), register_feature("iq"), register_feature("presence"), register_feature("presence-invisible"), diff --git a/src/mod_echo.erl b/src/mod_echo.erl index 06266dd0c..03a25d25e 100644 --- a/src/mod_echo.erl +++ b/src/mod_echo.erl @@ -10,18 +10,22 @@ -author('alexey@sevcom.net'). -vsn('$Revision$ '). --export([start/0, init/0]). +-behaviour(gen_mod). + +-export([start/1, init/1]). -include("ejabberd.hrl"). -include("namespaces.hrl"). -start() -> - spawn(?MODULE, init, []). +start(Opts) -> + %Host = gen_mod:get_opt(host, Opts), + Host = gen_mod:get_opt(host, Opts, "echo." ++ ?MYNAME), + spawn(?MODULE, init, [Host]). -init() -> - ejabberd_router:register_local_route("echo." ++ ?MYNAME), +init(Host) -> + ejabberd_router:register_local_route(Host), loop(). loop() -> diff --git a/src/mod_offline.erl b/src/mod_offline.erl index 42c8973dd..f524735a9 100644 --- a/src/mod_offline.erl +++ b/src/mod_offline.erl @@ -9,7 +9,9 @@ -module(mod_offline). -author('alexey@sevcom.net'). --export([start/0, +-behaviour(gen_mod). + +-export([start/1, store_packet/3, resend_offline_messages/1]). @@ -18,7 +20,7 @@ -record(offline_msg, {user, timestamp, from, to, packet}). -start() -> +start(_) -> mnesia:create_table(offline_msg, [{disc_only_copies, [node()]}, {type, bag}, diff --git a/src/mod_private.erl b/src/mod_private.erl index 1ed49f3db..ef0bc21af 100644 --- a/src/mod_private.erl +++ b/src/mod_private.erl @@ -10,6 +10,8 @@ -author('alexey@sevcom.net'). -vsn('$Revision$ '). +-behaviour(gen_mod). + -export([start/1, process_local_iq/3]). @@ -18,12 +20,13 @@ -record(private_storage, {userns, xml}). -start(Type) -> +start(Opts) -> + IQDisc = gen_mod:get_opt(iqdisc, Opts, one_queue), mnesia:create_table(private_storage, [{disc_only_copies, [node()]}, {attributes, record_info(fields, private_storage)}]), gen_iq_handler:add_iq_handler(ejabberd_local, ?NS_PRIVATE, - ?MODULE, process_local_iq, Type). + ?MODULE, process_local_iq, IQDisc). process_local_iq(From, To, {iq, ID, Type, XMLNS, SubEl}) -> diff --git a/src/mod_register.erl b/src/mod_register.erl index 247b76b71..811e8f029 100644 --- a/src/mod_register.erl +++ b/src/mod_register.erl @@ -10,14 +10,17 @@ -author('alexey@sevcom.net'). -vsn('$Revision$ '). +-behaviour(gen_mod). + -export([start/1, init/0, process_iq/3]). -include("ejabberd.hrl"). -include("namespaces.hrl"). -start(Type) -> +start(Opts) -> + IQDisc = gen_mod:get_opt(iqdisc, Opts, one_queue), gen_iq_handler:add_iq_handler(ejabberd_local, ?NS_REGISTER, - ?MODULE, process_iq, Type), + ?MODULE, process_iq, IQDisc), ok. init() -> @@ -71,8 +74,8 @@ process_iq(From, To, {iq, ID, Type, XMLNS, SubEl}) -> try_register(User, Password) -> - case jlib:string_to_jid(User ++ "@" ++ "x") of - error -> + case jlib:is_nodename(User) of + false -> {error, "406", "Not Acceptable"}; _ -> case ejabberd_auth:try_register(User, Password) of diff --git a/src/mod_roster.erl b/src/mod_roster.erl index 56df1bc48..ea8e48a58 100644 --- a/src/mod_roster.erl +++ b/src/mod_roster.erl @@ -10,7 +10,7 @@ -author('alexey@sevcom.net'). -vsn('$Revision$ '). --export([]). +-behaviour(gen_mod). -export([start/1, process_iq/3, @@ -33,12 +33,13 @@ xattrs = [], xs = []}). -start(Type) -> +start(Opts) -> + IQDisc = gen_mod:get_opt(iqdisc, Opts, one_queue), mnesia:create_table(roster,[{disc_copies, [node()]}, {attributes, record_info(fields, roster)}]), mnesia:add_table_index(roster, user), gen_iq_handler:add_iq_handler(ejabberd_local, ?NS_ROSTER, - ?MODULE, process_local_iq, Type). + ?MODULE, process_local_iq, IQDisc). process_local_iq(From, To, {iq, _, Type, _, _} = IQ) -> case Type of diff --git a/src/mod_stats.erl b/src/mod_stats.erl index a6f4eb62d..e0787ce11 100644 --- a/src/mod_stats.erl +++ b/src/mod_stats.erl @@ -10,14 +10,17 @@ -author('alexey@sevcom.net'). -vsn('$Revision$ '). +-behaviour(gen_mod). + -export([start/1, process_local_iq/3]). -include("namespaces.hrl"). -start(Type) -> +start(Opts) -> + IQDisc = gen_mod:get_opt(iqdisc, Opts, one_queue), gen_iq_handler:add_iq_handler(ejabberd_local, ?NS_STATS, - ?MODULE, process_local_iq, Type). + ?MODULE, process_local_iq, IQDisc). process_local_iq(From, To, {iq, ID, Type, XMLNS, SubEl}) -> diff --git a/src/mod_time.erl b/src/mod_time.erl index d2a6459d5..7837c83c3 100644 --- a/src/mod_time.erl +++ b/src/mod_time.erl @@ -10,6 +10,8 @@ -author('alexey@sevcom.net'). -vsn('$Revision$ '). +-behaviour(gen_mod). + -export([start/1, process_local_iq/3]). @@ -17,9 +19,10 @@ -include("namespaces.hrl"). -start(Type) -> +start(Opts) -> + IQDisc = gen_mod:get_opt(iqdisc, Opts, one_queue), gen_iq_handler:add_iq_handler(ejabberd_local, ?NS_TIME, - ?MODULE, process_local_iq, Type). + ?MODULE, process_local_iq, IQDisc). process_local_iq(From, To, {iq, ID, Type, XMLNS, SubEl}) -> diff --git a/src/mod_vcard.erl b/src/mod_vcard.erl index f35302e46..cba7ee06e 100644 --- a/src/mod_vcard.erl +++ b/src/mod_vcard.erl @@ -10,7 +10,9 @@ -author('alexey@sevcom.net'). -vsn('$Revision$ '). --export([start/1, init/0, +-behaviour(gen_mod). + +-export([start/1, init/1, process_local_iq/3, process_sm_iq/3, reindex_vcards/0]). @@ -35,7 +37,7 @@ -record(vcard, {user, vcard}). -start(Type) -> +start(Opts) -> mnesia:create_table(vcard, [{disc_only_copies, [node()]}, {attributes, record_info(fields, vcard)}]), mnesia:create_table(vcard_search, @@ -53,15 +55,17 @@ start(Type) -> mnesia:add_table_index(vcard_search, lorgname), mnesia:add_table_index(vcard_search, lorgunit), + IQDisc = gen_mod:get_opt(iqdisc, Opts, one_queue), gen_iq_handler:add_iq_handler(ejabberd_local, ?NS_VCARD, - ?MODULE, process_local_iq, Type), + ?MODULE, process_local_iq, IQDisc), gen_iq_handler:add_iq_handler(ejabberd_sm, ?NS_VCARD, - ?MODULE, process_sm_iq, Type), - spawn(?MODULE, init, []). + ?MODULE, process_sm_iq, IQDisc), + Host = gen_mod:get_opt(host, Opts, "vjud." ++ ?MYNAME), + spawn(?MODULE, init, [Host]). -init() -> - ejabberd_router:register_local_route("vjud." ++ ?MYNAME), +init(Host) -> + ejabberd_router:register_local_route(Host), loop(). loop() -> diff --git a/src/mod_version.erl b/src/mod_version.erl index 73b32b95c..0789c2954 100644 --- a/src/mod_version.erl +++ b/src/mod_version.erl @@ -10,6 +10,8 @@ -author('alexey@sevcom.net'). -vsn('$Revision$ '). +-behaviour(gen_mod). + -export([start/1, process_local_iq/3]). @@ -18,9 +20,10 @@ -start(Type) -> +start(Opts) -> + IQDisc = gen_mod:get_opt(iqdisc, Opts, one_queue), gen_iq_handler:add_iq_handler(ejabberd_local, ?NS_VERSION, - ?MODULE, process_local_iq, Type). + ?MODULE, process_local_iq, IQDisc). |