Sophie

Sophie

distrib > Mageia > 3 > i586 > media > core-release-src > by-pkgid > 1b95dae9c6d5d53dc96c43c3ccc9e83e > files > 2

ejabberd-2.1.11-8.mga3.src.rpm

From 30037ec8a73263f0d0524b2e1409736838cbb33b Mon Sep 17 00:00:00 2001
From: Sergei Golovan <sgolovan@nes.ru>
Date: Tue, 16 Feb 2010 16:07:37 +0300
Subject: [PATCH 02/11] Fixed delays in s2s connections.

Patch by Sergei Golovan increases timeouts in S2S and removes horrible 5-minute
delay between remote server connection attempts after a falure (in case of
server is down it would be reasonable, but what happens much more often is a
network split when the delay is inadmissible).
---
 src/ejabberd_s2s_in.erl  | 2 +-
 src/ejabberd_s2s_out.erl | 5 +++--
 2 files changed, 4 insertions(+), 3 deletions(-)

diff --git a/src/ejabberd_s2s_in.erl b/src/ejabberd_s2s_in.erl
index 1597ec7..7d411cd 100644
--- a/src/ejabberd_s2s_in.erl
+++ b/src/ejabberd_s2s_in.erl
@@ -414,7 +414,7 @@ stream_established({xmlstreamelement, El}, StateData) ->
             case {ejabberd_s2s:allow_host(LTo, LFrom),
                   lists:member(LTo, ejabberd_router:dirty_get_all_domains())} of
                 {true, true} ->
-		    ejabberd_s2s_out:terminate_if_waiting_delay(LTo, LFrom),
+		    %%ejabberd_s2s_out:terminate_if_waiting_delay(LTo, LFrom),
 		    ejabberd_s2s_out:start(LTo, LFrom,
 					   {verify, self(),
 					    Key, StateData#state.streamid}),
diff --git a/src/ejabberd_s2s_out.erl b/src/ejabberd_s2s_out.erl
index 65711fa..cab413f 100644
--- a/src/ejabberd_s2s_out.erl
+++ b/src/ejabberd_s2s_out.erl
@@ -93,7 +93,7 @@
 						 [From, Host, Type])).
 -endif.
 
--define(FSMTIMEOUT, 30000).
+-define(FSMTIMEOUT, 60000).
 
 %% We do not block on send anymore.
 -define(TCP_SEND_TIMEOUT, 15000).
@@ -245,7 +245,8 @@ open_socket(init, StateData) ->
 		    NewStateData = StateData#state{bridge={Mod, Fun}},
 		    {next_state, relay_to_bridge, NewStateData};
 		_ ->
-		    wait_before_reconnect(StateData)
+		    %%wait_before_reconnect(StateData)
+		    {stop, normal, StateData}
 	    end
     end;
 open_socket(closed, StateData) ->
-- 
1.7.11.5