Welcome to mirror list, hosted at ThFree Co, Russian Federation.

github.com/processone/ejabberd.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMickaël Rémond <mickael.remond@process-one.net>2007-03-13 18:01:27 +0300
committerMickaël Rémond <mickael.remond@process-one.net>2007-03-13 18:01:27 +0300
commita1d0e7d7cb55b3ac9ad834e9b902ad04238a2582 (patch)
treea5e7f5147b05d6d5dc188b7addd5c589f1250d54 /src/ejabberd_service.erl
parent44d3ea9c426d4021954435d5a1d4d58514772244 (diff)
* src/ejabberd_service.erl: Add extra info in the log about which
components is connected and which Erlang process is handling it. This is usefull in context where many types of components are used (Thanks to Jerome Sautret) (EJAB-211). SVN Revision: 743
Diffstat (limited to 'src/ejabberd_service.erl')
-rw-r--r--src/ejabberd_service.erl25
1 files changed, 16 insertions, 9 deletions
diff --git a/src/ejabberd_service.erl b/src/ejabberd_service.erl
index dbc5c1682..6ebea37cd 100644
--- a/src/ejabberd_service.erl
+++ b/src/ejabberd_service.erl
@@ -1,7 +1,7 @@
%%%----------------------------------------------------------------------
%%% File : ejabberd_service.erl
%%% Author : Alexey Shchepin <alexey@sevcom.net>
-%%% Purpose :
+%%% Purpose :
%%% Created : 6 Dec 2002 by Alexey Shchepin <alexey@sevcom.net>
%%% Id : $Id$
%%%----------------------------------------------------------------------
@@ -35,6 +35,7 @@
-record(state, {socket, sockmod, streamid,
hosts, password, access}).
+-record(socket_state, {sockmod, socket, receiver}).
%-define(DBGFSM, true).
@@ -91,9 +92,15 @@ socket_type() ->
%% Returns: {ok, StateName, StateData} |
%% {ok, StateName, StateData, Timeout} |
%% ignore |
-%% {stop, StopReason}
+%% {stop, StopReason}
%%----------------------------------------------------------------------
init([{SockMod, Socket}, Opts]) ->
+ ?INFO_MSG("External service connected on receiver ~p,~n~p:~n~p~n",
+ [Socket#socket_state.receiver,
+ Socket#socket_state.socket,
+ {erlang:port_info(Socket#socket_state.socket),
+ inet:sockname(Socket#socket_state.socket),
+ inet:peername(Socket#socket_state.socket)}]),
Access = case lists:keysearch(access, 1, Opts) of
{value, {_, A}} -> A;
_ -> all
@@ -135,7 +142,7 @@ init([{SockMod, Socket}, Opts]) ->
%% Func: StateName/2
%% Returns: {next_state, NextStateName, NextStateData} |
%% {next_state, NextStateName, NextStateData, Timeout} |
-%% {stop, Reason, NewStateData}
+%% {stop, Reason, NewStateData}
%%----------------------------------------------------------------------
wait_for_stream({xmlstreamstart, _Name, Attrs}, StateData) ->
@@ -172,7 +179,8 @@ wait_for_handshake({xmlstreamelement, El}, StateData) ->
send_text(StateData, "<handshake/>"),
lists:foreach(
fun(H) ->
- ejabberd_router:register_route(H)
+ ejabberd_router:register_route(H),
+ ?INFO_MSG("Route registered for service ~p~n", [H])
end, StateData#state.hosts),
{next_state, stream_established, StateData};
_ ->
@@ -245,7 +253,7 @@ stream_established(closed, StateData) ->
%% {reply, Reply, NextStateName, NextStateData} |
%% {reply, Reply, NextStateName, NextStateData, Timeout} |
%% {stop, Reason, NewStateData} |
-%% {stop, Reason, Reply, NewStateData}
+%% {stop, Reason, Reply, NewStateData}
%%----------------------------------------------------------------------
%state_name(Event, From, StateData) ->
% Reply = ok,
@@ -255,7 +263,7 @@ stream_established(closed, StateData) ->
%% Func: handle_event/3
%% Returns: {next_state, NextStateName, NextStateData} |
%% {next_state, NextStateName, NextStateData, Timeout} |
-%% {stop, Reason, NewStateData}
+%% {stop, Reason, NewStateData}
%%----------------------------------------------------------------------
handle_event(_Event, StateName, StateData) ->
{next_state, StateName, StateData}.
@@ -267,7 +275,7 @@ handle_event(_Event, StateName, StateData) ->
%% {reply, Reply, NextStateName, NextStateData} |
%% {reply, Reply, NextStateName, NextStateData, Timeout} |
%% {stop, Reason, NewStateData} |
-%% {stop, Reason, Reply, NewStateData}
+%% {stop, Reason, Reply, NewStateData}
%%----------------------------------------------------------------------
handle_sync_event(_Event, _From, StateName, StateData) ->
Reply = ok,
@@ -280,7 +288,7 @@ code_change(_OldVsn, StateName, StateData, _Extra) ->
%% Func: handle_info/3
%% Returns: {next_state, NextStateName, NextStateData} |
%% {next_state, NextStateName, NextStateData, Timeout} |
-%% {stop, Reason, NewStateData}
+%% {stop, Reason, NewStateData}
%%----------------------------------------------------------------------
handle_info({send_text, Text}, StateName, StateData) ->
send_text(StateData, Text),
@@ -335,4 +343,3 @@ send_element(StateData, El) ->
new_id() ->
randoms:get_string().
-