This graph shows which files directly or indirectly include this file:
Go to the source code of this file.
Data Structures | |
struct | ast_call_feature |
main call feature structure More... | |
Defines | |
#define | FEATURE_APP_ARGS_LEN 256 |
#define | FEATURE_APP_LEN 64 |
#define | FEATURE_EXTEN_LEN 32 |
#define | FEATURE_MAX_LEN 11 |
#define | FEATURE_SNAME_LEN 32 |
Functions | |
int | ast_bridge_call (struct ast_channel *chan, struct ast_channel *peer, struct ast_bridge_config *config) |
Bridge a call, optionally allowing redirection. | |
int | ast_masq_park_call (struct ast_channel *rchan, struct ast_channel *host, int timeout, int *extout) |
Park a call via a masqueraded channel. | |
int | ast_park_call (struct ast_channel *chan, struct ast_channel *host, int timeout, int *extout) |
Park a call and read back parked location. | |
char * | ast_parking_ext (void) |
Determine system parking extension Returns the call parking extension for drivers that provide special call parking help. | |
int | ast_pickup_call (struct ast_channel *chan) |
Pickup a call. | |
char * | ast_pickup_ext (void) |
Determine system call pickup extension. | |
void | ast_register_feature (struct ast_call_feature *feature) |
register new feature into feature_set | |
void | ast_unregister_feature (struct ast_call_feature *feature) |
unregister feature from feature_set |
Definition in file features.h.
|
Definition at line 29 of file features.h. Referenced by load_config(). |
|
Definition at line 28 of file features.h. Referenced by load_config(). |
|
Definition at line 31 of file features.h. Referenced by load_config(). |
|
Definition at line 27 of file features.h. Referenced by ast_bridge_call(). |
|
Definition at line 30 of file features.h. Referenced by load_config(). |
|
Bridge a call, optionally allowing redirection.
Definition at line 1254 of file res_features.c. References ast_channel::appl, ast_answer(), ast_cdr_appenduserfield(), ast_cdr_setuserfield(), ast_channel_bridge(), ast_channel_setoption(), ast_clear_flag, AST_CONTROL_BUSY, AST_CONTROL_CONGESTION, AST_CONTROL_FLASH, AST_CONTROL_HANGUP, AST_CONTROL_OPTION, AST_CONTROL_RINGING, ast_dtmf_stream(), ast_feature_interpret(), AST_FEATURE_PLAY_WARNING, AST_FRAME_CONTROL, AST_FRAME_DTMF, ast_frfree(), ast_indicate(), ast_log(), AST_OPTION_FLAG_REQUEST, ast_strlen_zero(), ast_channel::cdr, config, ast_channel::data, ast_frame::data, ast_option_header::data, ast_frame::datalen, FEATURE_MAX_LEN, FEATURE_RETURN_PASSDIGITS, FEATURE_RETURN_SUCCESS, FEATURE_SENSE_CHAN, FEATURE_SENSE_PEER, ast_option_header::flag, ast_frame::frametype, free, LOG_DEBUG, LOG_WARNING, monitor_app, ast_channel::name, ast_option_header::option, pbx_builtin_getvar_helper(), pbx_builtin_setvar_helper(), pbx_exec(), pbx_findapp(), set_config_flags(), ast_frame::subclass, and ast_cdr::userfield. Referenced by ast_bridge_call_thread(), builtin_atxfer(), and park_exec(). 01255 { 01256 /* Copy voice back and forth between the two channels. Give the peer 01257 the ability to transfer calls with '#<extension' syntax. */ 01258 struct ast_frame *f; 01259 struct ast_channel *who; 01260 char chan_featurecode[FEATURE_MAX_LEN + 1]=""; 01261 char peer_featurecode[FEATURE_MAX_LEN + 1]=""; 01262 int res; 01263 int diff; 01264 int hasfeatures=0; 01265 int hadfeatures=0; 01266 struct ast_option_header *aoh; 01267 struct timeval start = { 0 , 0 }; 01268 struct ast_bridge_config backup_config; 01269 char *monitor_exec; 01270 01271 memset(&backup_config, 0, sizeof(backup_config)); 01272 01273 config->start_time = ast_tvnow(); 01274 01275 if (chan && peer) { 01276 pbx_builtin_setvar_helper(chan, "BRIDGEPEER", peer->name); 01277 pbx_builtin_setvar_helper(peer, "BRIDGEPEER", chan->name); 01278 } else if (chan) 01279 pbx_builtin_setvar_helper(chan, "BLINDTRANSFER", NULL); 01280 01281 if (monitor_ok) { 01282 if (!monitor_app) { 01283 if (!(monitor_app = pbx_findapp("Monitor"))) 01284 monitor_ok=0; 01285 } 01286 if (monitor_app) { 01287 if ((monitor_exec = pbx_builtin_getvar_helper(chan, "AUTO_MONITOR"))) 01288 pbx_exec(chan, monitor_app, monitor_exec, 1); 01289 else if ((monitor_exec = pbx_builtin_getvar_helper(peer, "AUTO_MONITOR"))) 01290 pbx_exec(peer, monitor_app, monitor_exec, 1); 01291 } 01292 } 01293 01294 set_config_flags(chan, peer, config); 01295 config->firstpass = 1; 01296 01297 /* Answer if need be */ 01298 if (ast_answer(chan)) 01299 return -1; 01300 peer->appl = "Bridged Call"; 01301 peer->data = chan->name; 01302 01303 /* copy the userfield from the B-leg to A-leg if applicable */ 01304 if (chan->cdr && peer->cdr && !ast_strlen_zero(peer->cdr->userfield)) { 01305 char tmp[256]; 01306 if (!ast_strlen_zero(chan->cdr->userfield)) { 01307 snprintf(tmp, sizeof(tmp), "%s;%s", chan->cdr->userfield, peer->cdr->userfield); 01308 ast_cdr_appenduserfield(chan, tmp); 01309 } else 01310 ast_cdr_setuserfield(chan, peer->cdr->userfield); 01311 /* free the peer's cdr without ast_cdr_free complaining */ 01312 free(peer->cdr); 01313 peer->cdr = NULL; 01314 } 01315 for (;;) { 01316 if (config->feature_timer) 01317 start = ast_tvnow(); 01318 01319 res = ast_channel_bridge(chan, peer, config, &f, &who); 01320 01321 if (config->feature_timer) { 01322 /* Update time limit for next pass */ 01323 diff = ast_tvdiff_ms(ast_tvnow(), start); 01324 config->feature_timer -= diff; 01325 if (hasfeatures) { 01326 /* Running on backup config, meaning a feature might be being 01327 activated, but that's no excuse to keep things going 01328 indefinitely! */ 01329 if (backup_config.feature_timer && ((backup_config.feature_timer -= diff) <= 0)) { 01330 ast_log(LOG_DEBUG, "Timed out, realtime this time!\n"); 01331 config->feature_timer = 0; 01332 who = chan; 01333 if (f) 01334 ast_frfree(f); 01335 f = NULL; 01336 res = 0; 01337 } else if (config->feature_timer <= 0) { 01338 /* Not *really* out of time, just out of time for 01339 digits to come in for features. */ 01340 ast_log(LOG_DEBUG, "Timed out for feature!\n"); 01341 if (!ast_strlen_zero(peer_featurecode)) { 01342 ast_dtmf_stream(chan, peer, peer_featurecode, 0); 01343 memset(peer_featurecode, 0, sizeof(peer_featurecode)); 01344 } 01345 if (!ast_strlen_zero(chan_featurecode)) { 01346 ast_dtmf_stream(peer, chan, chan_featurecode, 0); 01347 memset(chan_featurecode, 0, sizeof(chan_featurecode)); 01348 } 01349 if (f) 01350 ast_frfree(f); 01351 hasfeatures = !ast_strlen_zero(chan_featurecode) || !ast_strlen_zero(peer_featurecode); 01352 if (!hasfeatures) { 01353 /* Restore original (possibly time modified) bridge config */ 01354 memcpy(config, &backup_config, sizeof(struct ast_bridge_config)); 01355 memset(&backup_config, 0, sizeof(backup_config)); 01356 } 01357 hadfeatures = hasfeatures; 01358 /* Continue as we were */ 01359 continue; 01360 } 01361 } else { 01362 if (config->feature_timer <=0) { 01363 /* We ran out of time */ 01364 config->feature_timer = 0; 01365 who = chan; 01366 if (f) 01367 ast_frfree(f); 01368 f = NULL; 01369 res = 0; 01370 } 01371 } 01372 } 01373 if (res < 0) { 01374 ast_log(LOG_WARNING, "Bridge failed on channels %s and %s\n", chan->name, peer->name); 01375 return -1; 01376 } 01377 01378 if (!f || ((f->frametype == AST_FRAME_CONTROL) && ((f->subclass == AST_CONTROL_HANGUP) || (f->subclass == AST_CONTROL_BUSY) || 01379 (f->subclass == AST_CONTROL_CONGESTION)))) { 01380 res = -1; 01381 break; 01382 } 01383 if ((f->frametype == AST_FRAME_CONTROL) && (f->subclass == AST_CONTROL_RINGING)) { 01384 if (who == chan) 01385 ast_indicate(peer, AST_CONTROL_RINGING); 01386 else 01387 ast_indicate(chan, AST_CONTROL_RINGING); 01388 } 01389 if ((f->frametype == AST_FRAME_CONTROL) && (f->subclass == -1)) { 01390 if (who == chan) 01391 ast_indicate(peer, -1); 01392 else 01393 ast_indicate(chan, -1); 01394 } 01395 if ((f->frametype == AST_FRAME_CONTROL) && (f->subclass == AST_CONTROL_FLASH)) { 01396 if (who == chan) 01397 ast_indicate(peer, AST_CONTROL_FLASH); 01398 else 01399 ast_indicate(chan, AST_CONTROL_FLASH); 01400 } 01401 if ((f->frametype == AST_FRAME_CONTROL) && (f->subclass == AST_CONTROL_OPTION)) { 01402 aoh = f->data; 01403 /* Forward option Requests */ 01404 if (aoh && (aoh->flag == AST_OPTION_FLAG_REQUEST)) { 01405 if (who == chan) 01406 ast_channel_setoption(peer, ntohs(aoh->option), aoh->data, f->datalen - sizeof(struct ast_option_header), 0); 01407 else 01408 ast_channel_setoption(chan, ntohs(aoh->option), aoh->data, f->datalen - sizeof(struct ast_option_header), 0); 01409 } 01410 } 01411 /* check for '*', if we find it it's time to disconnect */ 01412 if (f && (f->frametype == AST_FRAME_DTMF)) { 01413 char *featurecode; 01414 int sense; 01415 struct ast_channel *other; 01416 01417 hadfeatures = hasfeatures; 01418 /* This cannot overrun because the longest feature is one shorter than our buffer */ 01419 if (who == chan) { 01420 other = peer; 01421 sense = FEATURE_SENSE_CHAN; 01422 featurecode = chan_featurecode; 01423 } else { 01424 other = chan; 01425 sense = FEATURE_SENSE_PEER; 01426 featurecode = peer_featurecode; 01427 } 01428 featurecode[strlen(featurecode)] = f->subclass; 01429 config->feature_timer = backup_config.feature_timer; 01430 res = ast_feature_interpret(chan, peer, config, featurecode, sense); 01431 switch(res) { 01432 case FEATURE_RETURN_PASSDIGITS: 01433 ast_dtmf_stream(other, who, featurecode, 0); 01434 /* Fall through */ 01435 case FEATURE_RETURN_SUCCESS: 01436 memset(featurecode, 0, sizeof(chan_featurecode)); 01437 break; 01438 } 01439 if (res >= FEATURE_RETURN_PASSDIGITS) { 01440 res = 0; 01441 } else { 01442 ast_frfree(f); 01443 break; 01444 } 01445 hasfeatures = !ast_strlen_zero(chan_featurecode) || !ast_strlen_zero(peer_featurecode); 01446 if (hadfeatures && !hasfeatures) { 01447 /* Restore backup */ 01448 memcpy(config, &backup_config, sizeof(struct ast_bridge_config)); 01449 memset(&backup_config, 0, sizeof(struct ast_bridge_config)); 01450 } else if (hasfeatures) { 01451 if (!hadfeatures) { 01452 /* Backup configuration */ 01453 memcpy(&backup_config, config, sizeof(struct ast_bridge_config)); 01454 /* Setup temporary config options */ 01455 config->play_warning = 0; 01456 ast_clear_flag(&(config->features_caller), AST_FEATURE_PLAY_WARNING); 01457 ast_clear_flag(&(config->features_callee), AST_FEATURE_PLAY_WARNING); 01458 config->warning_freq = 0; 01459 config->warning_sound = NULL; 01460 config->end_sound = NULL; 01461 config->start_sound = NULL; 01462 config->firstpass = 0; 01463 } 01464 config->feature_timer = featuredigittimeout; 01465 ast_log(LOG_DEBUG, "Set time limit to %ld\n", config->feature_timer); 01466 } 01467 } 01468 if (f) 01469 ast_frfree(f); 01470 } 01471 return res; 01472 }
|
|
Park a call via a masqueraded channel.
Definition at line 401 of file res_features.c. References ast_channel_alloc(), ast_channel_masquerade(), ast_frfree(), ast_log(), ast_park_call(), ast_read(), ast_channel::context, ast_channel::exten, LOG_WARNING, ast_channel::name, ast_channel::priority, ast_channel::readformat, and ast_channel::writeformat. Referenced by mgcp_ss(), parkandannounce_exec(), skinny_ss(), and ss_thread(). 00402 { 00403 struct ast_channel *chan; 00404 struct ast_frame *f; 00405 00406 /* Make a new, fake channel that we'll use to masquerade in the real one */ 00407 chan = ast_channel_alloc(0); 00408 if (chan) { 00409 /* Let us keep track of the channel name */ 00410 snprintf(chan->name, sizeof (chan->name), "Parked/%s",rchan->name); 00411 00412 /* Make formats okay */ 00413 chan->readformat = rchan->readformat; 00414 chan->writeformat = rchan->writeformat; 00415 ast_channel_masquerade(chan, rchan); 00416 00417 /* Setup the extensions and such */ 00418 ast_copy_string(chan->context, rchan->context, sizeof(chan->context)); 00419 ast_copy_string(chan->exten, rchan->exten, sizeof(chan->exten)); 00420 chan->priority = rchan->priority; 00421 00422 /* Make the masq execute */ 00423 f = ast_read(chan); 00424 if (f) 00425 ast_frfree(f); 00426 ast_park_call(chan, peer, timeout, extout); 00427 } else { 00428 ast_log(LOG_WARNING, "Unable to create parked channel\n"); 00429 return -1; 00430 } 00431 return 0; 00432 }
|
|
Park a call and read back parked location.
Definition at line 278 of file res_features.c. References ast_log(), AST_MAX_EXTENSION, ast_mutex_lock(), exten, LOG_WARNING, malloc, parkeduser::next, parkinglot, and parkeduser::parkingnum. Referenced by ast_masq_park_call(), builtin_blindtransfer(), iax_park_thread(), park_call_exec(), and sip_park_thread(). 00279 { 00280 struct parkeduser *pu, *cur; 00281 int i,x,parking_range; 00282 char exten[AST_MAX_EXTENSION]; 00283 struct ast_context *con; 00284 00285 pu = malloc(sizeof(struct parkeduser)); 00286 if (!pu) { 00287 ast_log(LOG_WARNING, "Out of memory\n"); 00288 return -1; 00289 } 00290 memset(pu, 0, sizeof(struct parkeduser)); 00291 ast_mutex_lock(&parking_lock); 00292 parking_range = parking_stop - parking_start+1; 00293 for (i = 0; i < parking_range; i++) { 00294 x = (i + parking_offset) % parking_range + parking_start; 00295 cur = parkinglot; 00296 while(cur) { 00297 if (cur->parkingnum == x) 00298 break; 00299 cur = cur->next; 00300 } 00301 if (!cur) 00302 break; 00303 } 00304 00305 if (!(i < parking_range)) { 00306 ast_log(LOG_WARNING, "No more parking spaces\n"); 00307 free(pu); 00308 ast_mutex_unlock(&parking_lock); 00309 return -1; 00310 } 00311 if (parkfindnext) 00312 parking_offset = x - parking_start + 1; 00313 chan->appl = "Parked Call"; 00314 chan->data = NULL; 00315 00316 pu->chan = chan; 00317 /* Start music on hold */ 00318 if (chan != peer) { 00319 ast_indicate(pu->chan, AST_CONTROL_HOLD); 00320 ast_moh_start(pu->chan, NULL); 00321 } 00322 pu->start = ast_tvnow(); 00323 pu->parkingnum = x; 00324 if (timeout > 0) 00325 pu->parkingtime = timeout; 00326 else 00327 pu->parkingtime = parkingtime; 00328 if (extout) 00329 *extout = x; 00330 if (peer) 00331 ast_copy_string(pu->peername, peer->name, sizeof(pu->peername)); 00332 00333 /* Remember what had been dialed, so that if the parking 00334 expires, we try to come back to the same place */ 00335 if (!ast_strlen_zero(chan->macrocontext)) 00336 ast_copy_string(pu->context, chan->macrocontext, sizeof(pu->context)); 00337 else 00338 ast_copy_string(pu->context, chan->context, sizeof(pu->context)); 00339 if (!ast_strlen_zero(chan->macroexten)) 00340 ast_copy_string(pu->exten, chan->macroexten, sizeof(pu->exten)); 00341 else 00342 ast_copy_string(pu->exten, chan->exten, sizeof(pu->exten)); 00343 if (chan->macropriority) 00344 pu->priority = chan->macropriority; 00345 else 00346 pu->priority = chan->priority; 00347 pu->next = parkinglot; 00348 parkinglot = pu; 00349 /* If parking a channel directly, don't quiet yet get parking running on it */ 00350 if (peer == chan) 00351 pu->notquiteyet = 1; 00352 ast_mutex_unlock(&parking_lock); 00353 /* Wake up the (presumably select()ing) thread */ 00354 pthread_kill(parking_thread, SIGURG); 00355 if (option_verbose > 1) 00356 ast_verbose(VERBOSE_PREFIX_2 "Parked %s on %d. Will timeout back to extension [%s] %s, %d in %d seconds\n", pu->chan->name, pu->parkingnum, pu->context, pu->exten, pu->priority, (pu->parkingtime/1000)); 00357 00358 manager_event(EVENT_FLAG_CALL, "ParkedCall", 00359 "Exten: %d\r\n" 00360 "Channel: %s\r\n" 00361 "From: %s\r\n" 00362 "Timeout: %ld\r\n" 00363 "CallerID: %s\r\n" 00364 "CallerIDName: %s\r\n" 00365 ,pu->parkingnum, pu->chan->name, peer ? peer->name : "" 00366 ,(long)pu->start.tv_sec + (long)(pu->parkingtime/1000) - (long)time(NULL) 00367 ,(pu->chan->cid.cid_num ? pu->chan->cid.cid_num : "<unknown>") 00368 ,(pu->chan->cid.cid_name ? pu->chan->cid.cid_name : "<unknown>") 00369 ); 00370 00371 if (peer) { 00372 if (adsipark && adsi_available(peer)) { 00373 adsi_announce_park(peer, pu->parkingnum); 00374 } 00375 if (adsipark && adsi_available(peer)) { 00376 adsi_unload_session(peer); 00377 } 00378 } 00379 con = ast_context_find(parking_con); 00380 if (!con) { 00381 con = ast_context_create(NULL, parking_con, registrar); 00382 if (!con) { 00383 ast_log(LOG_ERROR, "Parking context '%s' does not exist and unable to create\n", parking_con); 00384 } 00385 } 00386 if (con) { 00387 snprintf(exten, sizeof(exten), "%d", x); 00388 ast_add_extension2(con, 1, exten, 1, NULL, NULL, parkedcall, strdup(exten), FREE, registrar); 00389 } 00390 if (peer) 00391 ast_say_digits(peer, pu->parkingnum, "", peer->language); 00392 if (pu->notquiteyet) { 00393 /* Wake up parking thread if we're really done */ 00394 ast_moh_start(pu->chan, NULL); 00395 pu->notquiteyet = 0; 00396 pthread_kill(parking_thread, SIGURG); 00397 } 00398 return 0; 00399 }
|
|
Determine system parking extension Returns the call parking extension for drivers that provide special call parking help.
Definition at line 163 of file res_features.c. Referenced by builtin_blindtransfer(), dp_lookup(), get_refer_info(), handle_request_refer(), load_config(), mgcp_ss(), skinny_ss(), socket_read(), and ss_thread(). 00164 { 00165 return parking_ext; 00166 }
|
|
Pickup a call.
Definition at line 1918 of file res_features.c. References ast_channel::_state, ast_answer(), ast_channel_masquerade(), ast_channel_walk_locked(), AST_CONTROL_ANSWER, ast_log(), ast_mutex_unlock(), ast_queue_control(), AST_STATE_RING, AST_STATE_RINGING, ast_channel::callgroup, ast_channel::lock, LOG_DEBUG, LOG_WARNING, ast_channel::name, option_debug, ast_channel::pbx, and ast_channel::pickupgroup. Referenced by cb_events(), handle_request_invite(), mgcp_ss(), monitor_handle_notowned(), skinny_ss(), and ss_thread(). 01919 { 01920 struct ast_channel *cur = NULL; 01921 int res = -1; 01922 01923 while ( (cur = ast_channel_walk_locked(cur)) != NULL) { 01924 if (!cur->pbx && 01925 (cur != chan) && 01926 (chan->pickupgroup & cur->callgroup) && 01927 ((cur->_state == AST_STATE_RINGING) || 01928 (cur->_state == AST_STATE_RING))) { 01929 break; 01930 } 01931 ast_mutex_unlock(&cur->lock); 01932 } 01933 if (cur) { 01934 if (option_debug) 01935 ast_log(LOG_DEBUG, "Call pickup on chan '%s' by '%s'\n",cur->name, chan->name); 01936 res = ast_answer(chan); 01937 if (res) 01938 ast_log(LOG_WARNING, "Unable to answer '%s'\n", chan->name); 01939 res = ast_queue_control(chan, AST_CONTROL_ANSWER); 01940 if (res) 01941 ast_log(LOG_WARNING, "Unable to queue answer on '%s'\n", chan->name); 01942 res = ast_channel_masquerade(cur, chan); 01943 if (res) 01944 ast_log(LOG_WARNING, "Unable to masquerade '%s' into '%s'\n", chan->name, cur->name); /* Done */ 01945 ast_mutex_unlock(&cur->lock); 01946 } else { 01947 if (option_debug) 01948 ast_log(LOG_DEBUG, "No call pickup possible...\n"); 01949 } 01950 return res; 01951 }
|
|
Determine system call pickup extension.
Definition at line 168 of file res_features.c. Referenced by cb_events(), get_destination(), handle_request_invite(), handle_showfeatures(), mgcp_ss(), monitor_handle_notowned(), skinny_ss(), and ss_thread(). 00169 { 00170 return pickup_ext; 00171 }
|
|
register new feature into feature_set
Referenced by load_config(). |
|
unregister feature from feature_set
Definition at line 888 of file res_features.c. References AST_LIST_LOCK, AST_LIST_REMOVE, AST_LIST_UNLOCK, and free. 00889 { 00890 if (!feature) return; 00891 00892 AST_LIST_LOCK(&feature_list); 00893 AST_LIST_REMOVE(&feature_list,feature,feature_entry); 00894 AST_LIST_UNLOCK(&feature_list); 00895 free(feature); 00896 }
|