diff options
author | marquis <marquis@f38db490-d61c-443f-a65b-d21fe96a405b> | 2010-11-26 18:19:02 +0000 |
---|---|---|
committer | marquis <marquis@f38db490-d61c-443f-a65b-d21fe96a405b> | 2010-11-26 18:19:02 +0000 |
commit | ff5d605970d38eb91ff05d6044428c45fcea4d66 (patch) | |
tree | 5884112e5e034081f63328d6773a9f196053fb37 | |
parent | d42d916c4299c18155ae03b3e650788bd4880304 (diff) |
Fix reloading of peer when a user is requested.
Prevent peer reloading from causing multiple MWI subscriptions to be created when using realtime. This had the effect of sending one NOTIFY for every time a sip peer made a call, in one case eventually overwhelming the phone and causing it to reboot.
(closes issue #18342)
Reported by: nivek
Patches:
issue0018342p1.patch uploaded by nivek (license 636)
Tested by: nivek
Review: https://reviewboard.asterisk.org/r/1029/
git-svn-id: http://svn.digium.com/svn/asterisk/branches/1.8@296352 f38db490-d61c-443f-a65b-d21fe96a405b
-rw-r--r-- | channels/chan_sip.c | 18 |
1 files changed, 13 insertions, 5 deletions
diff --git a/channels/chan_sip.c b/channels/chan_sip.c index 7f9e9bc33..a53bbb87c 100644 --- a/channels/chan_sip.c +++ b/channels/chan_sip.c @@ -1417,7 +1417,7 @@ static void realtime_update_peer(const char *peername, struct ast_sockaddr *addr static void update_peer(struct sip_peer *p, int expire); static struct ast_variable *get_insecure_variable_from_config(struct ast_config *config); static const char *get_name_from_variable(struct ast_variable *var, const char *newpeername); -static struct sip_peer *realtime_peer(const char *peername, struct ast_sockaddr *sin, int devstate_only); +static struct sip_peer *realtime_peer(const char *peername, struct ast_sockaddr *sin, int devstate_only, int which_objects); static char *sip_prune_realtime(struct ast_cli_entry *e, int cmd, struct ast_cli_args *a); /*--- Internal UA client handling (outbound registrations) */ @@ -4395,7 +4395,7 @@ static const char *get_name_from_variable(struct ast_variable *var, const char * * This returns a pointer to a peer and because we use build_peer, we can rest * assured that the refcount is bumped. */ -static struct sip_peer *realtime_peer(const char *newpeername, struct ast_sockaddr *addr, int devstate_only) +static struct sip_peer *realtime_peer(const char *newpeername, struct ast_sockaddr *addr, int devstate_only, int which_objects) { struct sip_peer *peer; struct ast_variable *var = NULL; @@ -4519,11 +4519,19 @@ static struct sip_peer *realtime_peer(const char *newpeername, struct ast_sockad } for (tmp = var; tmp; tmp = tmp->next) { - if (!newpeername && !strcasecmp(tmp->name, "name")) { + if (!strcasecmp(tmp->name, "type") && (!strcasecmp(tmp->value, "peer") && which_objects == FINDUSERS)) { + if (peerlist) { + ast_config_destroy(peerlist); + } else { + ast_variables_destroy(var); + ast_variables_destroy(varregs); + } + return NULL; + } else if (!newpeername && !strcasecmp(tmp->name, "name")) { newpeername = tmp->value; } } - + if (!newpeername) { /* Did not find peer in realtime */ ast_log(LOG_WARNING, "Cannot Determine peer name ip=%s\n", ipaddr); if(peerlist) @@ -4638,7 +4646,7 @@ static struct sip_peer *find_peer(const char *peer, struct ast_sockaddr *addr, i } if (!p && (realtime || devstate_only)) { - p = realtime_peer(peer, addr, devstate_only); + p = realtime_peer(peer, addr, devstate_only, which_objects); if (p) { switch (which_objects) { case FINDUSERS: |