From 6ac794074ed80dc6bafdc4e018a804c171e95081 Mon Sep 17 00:00:00 2001 From: Sean Bright Date: Wed, 5 Nov 2008 22:19:22 +0000 Subject: [PATCH] Update a couple places to use the new ast_channel_search_locked API call. git-svn-id: https://origsvn.digium.com/svn/asterisk/trunk@154923 65c4cc65-6c06-0410-ace0-fbb531ad65f3 --- apps/app_directed_pickup.c | 54 ++++++++++++++++++++++++-------------------- main/features.c | 25 ++++++++++---------- 2 files changed, 41 insertions(+), 38 deletions(-) diff --git a/apps/app_directed_pickup.c b/apps/app_directed_pickup.c index 2a07d2e..773a27c 100644 --- a/apps/app_directed_pickup.c +++ b/apps/app_directed_pickup.c @@ -172,42 +172,46 @@ static int pickup_by_channel(struct ast_channel *chan, char *pickup) /* Attempt to pick up specified extension with context */ static int pickup_by_exten(struct ast_channel *chan, const char *exten, const char *context) { - int res = -1; - struct ast_channel *target = NULL; - - while ((target = ast_channel_walk_locked(target))) { - if ((!strcasecmp(target->macroexten, exten) || !strcasecmp(target->exten, exten)) && - !strcasecmp(target->dialcontext, context) && - can_pickup(target)) { - res = pickup_do(chan, target); - ast_channel_unlock(target); - break; - } + auto int find_by_exten(struct ast_channel *c); + int find_by_exten(struct ast_channel *c) { + return (!strcasecmp(c->macroexten, exten) || !strcasecmp(c->exten, exten)) && + !strcasecmp(c->dialcontext, context) && + can_pickup(c); + } + + struct ast_channel *target = ast_channel_search_locked(find_by_exten); + + if (target) { + int res = pickup_do(chan, target); ast_channel_unlock(target); + target = NULL; + return res; } - return res; + return -1; } /* Attempt to pick up specified mark */ static int pickup_by_mark(struct ast_channel *chan, const char *mark) { - int res = -1; - const char *tmp = NULL; - struct ast_channel *target = NULL; - - while ((target = ast_channel_walk_locked(target))) { - if ((tmp = pbx_builtin_getvar_helper(target, PICKUPMARK)) && - !strcasecmp(tmp, mark) && - can_pickup(target)) { - res = pickup_do(chan, target); - ast_channel_unlock(target); - break; - } + auto int find_by_mark(struct ast_channel *); + int find_by_mark(struct ast_channel *c) { + const char *tmp; + return (tmp = pbx_builtin_getvar_helper(c, PICKUPMARK)) && + !strcasecmp(tmp, mark) && + can_pickup(c); + } + + struct ast_channel *target = ast_channel_search_locked(find_by_mark); + + if (target) { + int res = pickup_do(chan, target); ast_channel_unlock(target); + target = NULL; + return res; } - return res; + return -1; } /* application entry point for Pickup() */ diff --git a/main/features.c b/main/features.c index f6daef3..16fb8ea 100644 --- a/main/features.c +++ b/main/features.c @@ -3997,20 +3997,18 @@ static int manager_park(struct mansession *s, const struct message *m) */ int ast_pickup_call(struct ast_channel *chan) { - struct ast_channel *cur = NULL; - int res = -1; - - while ((cur = ast_channel_walk_locked(cur)) != NULL) { - if (!cur->pbx && - (cur != chan) && - (chan->pickupgroup & cur->callgroup) && - ((cur->_state == AST_STATE_RINGING) || - (cur->_state == AST_STATE_RING))) { - break; - } - ast_channel_unlock(cur); + auto int find_channel_by_group(struct ast_channel *); + int find_channel_by_group(struct ast_channel *c) { + return !c->pbx && + (c != chan) && + (chan->pickupgroup & c->callgroup) && + ((c->_state == AST_STATE_RINGING) || + (c->_state == AST_STATE_RING)); } + struct ast_channel *cur = ast_channel_search_locked(find_channel_by_group); + if (cur) { + int res = -1; ast_debug(1, "Call pickup on chan '%s' by '%s'\n",cur->name, chan->name); res = ast_answer(chan); if (res) @@ -4022,10 +4020,11 @@ int ast_pickup_call(struct ast_channel *chan) if (res) ast_log(LOG_WARNING, "Unable to masquerade '%s' into '%s'\n", chan->name, cur->name); /* Done */ ast_channel_unlock(cur); + return res; } else { ast_debug(1, "No call pickup possible...\n"); } - return res; + return -1; } static char *app_bridge = "Bridge"; -- 1.7.9.5