kenmirrors/asterisk
1
0
Fork 0
mirror of https://github.com/asterisk/asterisk.git synced 2026-07-28 00:10:25 -07:00
Code Issues Packages Projects Releases Wiki Activity

space out initial registrations (bug #3104)

Browse Source 
git-svn-id: https://origsvn.digium.com/svn/asterisk/branches/v1-0@5428 65c4cc65-6c06-0410-ace0-fbb531ad65f3
This commit is contained in:
Russell Bryant
2005-04-06 17:09:03 +00:00
parent 916f6b627a
commit 17045b502f
1 changed files with 20 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files
channels/chan_sip.c
+20 -12
View File
@@ -9131,19 +9131,31 @@ static void prune_peers(void)
ast_mutex_unlock(&peerl.lock);
}
/* Send all of our registrations, spaced out to avoid suicide*/
static void sip_send_all_registers(void)
{
struct sip_registry *reg;
int ms;
ast_mutex_lock(&regl.lock);
for (reg = regl.registrations; reg; reg = reg->next) {
if (reg->expire > -1)
ast_sched_del(sched, reg->expire);
ms = (rand() >> 12) & 0x1fff;
reg->expire = ast_sched_add(sched, ms, sip_reregister, reg);
}
ast_mutex_unlock(&regl.lock);
}
/*--- sip_do_reload: Reload module */
static int sip_do_reload(void)
{
struct sip_registry *reg;
struct sip_peer *peer;
delete_users();
reload_config();
prune_peers();
/* And start the monitor for the first time */
ast_mutex_lock(&regl.lock);
for (reg = regl.registrations; reg; reg = reg->next)
__sip_do_register(reg);
ast_mutex_unlock(&regl.lock);
sip_send_all_registers();
ast_mutex_lock(&peerl.lock);
for (peer = peerl.peers; peer; peer = peer->next)
sip_poke_peer(peer);
@@ -9179,7 +9191,6 @@ int load_module()
{
int res;
struct sip_peer *peer;
struct sip_registry *reg;
ast_mutex_init(&userl.lock);
ast_mutex_init(&peerl.lock);
@@ -9228,11 +9239,8 @@ int load_module()
sip_poke_peer(peer);
ast_mutex_unlock(&peerl.lock);
ast_mutex_lock(&regl.lock);
for (reg = regl.registrations; reg; reg = reg->next)
__sip_do_register(reg);
ast_mutex_unlock(&regl.lock);
sip_send_all_registers();
/* And start the monitor for the first time */
restart_monitor();
}