channel_pvt.h File Reference

#include <asterisk/channel.h>

Go to the source code of this file.

Data Structures
struct	ast_channel_pvt
Functions
ast_channel *	ast_channel_alloc (int needalertpipe)
	Create a channel structure.
int	ast_queue_frame (struct ast_channel *chan, struct ast_frame *f, int lock)
int	ast_queue_hangup (struct ast_channel *chan, int lock)
int	ast_queue_control (struct ast_channel *chan, int control, int lock)
int	ast_setstate (struct ast_channel *chan, int state)
void	ast_change_name (struct ast_channel *chan, char *newname)
void	ast_channel_free (struct ast_channel *)
	Free a channel structure.

---

Function Documentation

void ast_change_name (  struct ast_channel *  chan, char *  newname )

Definition at line 1866 of file channel.c. References EVENT_FLAG_CALL, manager_event(), ast_channel::name, and ast_channel::uniqueid. { char tmp[256]; strncpy(tmp, chan->name, 256); strncpy(chan->name, newname, sizeof(chan->name) - 1); manager_event(EVENT_FLAG_CALL, "Rename", "Oldname: %s\r\nNewname: %s\r\nUniqueid: %s\r\n", tmp, chan->name, chan->uniqueid); }

struct ast_channel* ast_channel_alloc (  int  needalertpipe  )

Create a channel structure. Returns NULL on failure to allocate Definition at line 263 of file channel.c. References ast_default_accountcode, ast_default_amaflags, AST_LIST_HEAD_INIT, AST_LIST_INSERT_HEAD, ast_log(), AST_MAX_FDS, ast_mutex_init, ast_mutex_lock, ast_mutex_unlock, AST_STATE_DOWN, ast_var_assign(), channels, defaultlanguage, free, LOG_WARNING, malloc, and sched_context_create(). Referenced by ast_async_goto(). { struct ast_channel *tmp; struct ast_channel_pvt *pvt; int x; int flags; struct varshead *headp; /* If shutting down, don't allocate any new channels */ if (shutting_down) return NULL; ast_mutex_lock(&chlock); tmp = malloc(sizeof(struct ast_channel)); if (tmp) { memset(tmp, 0, sizeof(struct ast_channel)); pvt = malloc(sizeof(struct ast_channel_pvt)); if (pvt) { memset(pvt, 0, sizeof(struct ast_channel_pvt)); tmp->sched = sched_context_create(); if (tmp->sched) { for (x=0;x<AST_MAX_FDS - 1;x++) tmp->fds[x] = -1; if (needqueue && pipe(pvt->alertpipe)) { ast_log(LOG_WARNING, "Alert pipe creation failed!\n"); free(pvt); free(tmp); tmp = NULL; pvt = NULL; } else { /* Make sure we've got it done right if they don't */ if (needqueue) { flags = fcntl(pvt->alertpipe[0], F_GETFL); fcntl(pvt->alertpipe[0], F_SETFL, flags | O_NONBLOCK); flags = fcntl(pvt->alertpipe[1], F_GETFL); fcntl(pvt->alertpipe[1], F_SETFL, flags | O_NONBLOCK); } else pvt->alertpipe[0] = pvt->alertpipe[1] = -1; #ifdef ZAPTEL_OPTIMIZATIONS tmp->timingfd = open("/dev/zap/timer", O_RDWR); #else tmp->timingfd = -1; #endif /* Always watch the alertpipe */ tmp->fds[AST_MAX_FDS-1] = pvt->alertpipe[0]; /* And timing pipe */ tmp->fds[AST_MAX_FDS-2] = tmp->timingfd; strncpy(tmp->name, "**Unknown**", sizeof(tmp->name)-1); tmp->pvt = pvt; /* Initial state */ tmp->_state = AST_STATE_DOWN; tmp->stack = -1; tmp->streamid = -1; tmp->appl = NULL; tmp->data = NULL; tmp->fin = 0; tmp->fout = 0; snprintf(tmp->uniqueid, sizeof(tmp->uniqueid), "%li.%d", (long)time(NULL), uniqueint++); headp=&tmp->varshead; ast_mutex_init(&tmp->lock); AST_LIST_HEAD_INIT(headp); tmp->vars=ast_var_assign("tempvar","tempval"); AST_LIST_INSERT_HEAD(headp,tmp->vars,entries); strncpy(tmp->context, "default", sizeof(tmp->context)-1); strncpy(tmp->language, defaultlanguage, sizeof(tmp->language)-1); strncpy(tmp->exten, "s", sizeof(tmp->exten)-1); tmp->priority=1; tmp->amaflags = ast_default_amaflags; strncpy(tmp->accountcode, ast_default_accountcode, sizeof(tmp->accountcode)-1); tmp->next = channels; channels= tmp; } } else { ast_log(LOG_WARNING, "Unable to create schedule context\n"); free(tmp); tmp = NULL; } } else { ast_log(LOG_WARNING, "Out of memory\n"); free(tmp); tmp = NULL; } } else ast_log(LOG_WARNING, "Out of memory\n"); ast_mutex_unlock(&chlock); return tmp; }

void ast_channel_free (  struct ast_channel *   )

Free a channel structure. Definition at line 489 of file channel.c. References ast_channel_pvt::alertpipe, ast_channel::ani, AST_CHANNEL_NAME, ast_device_state_changed(), ast_frfree(), AST_LIST_EMPTY, AST_LIST_FIRST, AST_LIST_REMOVE_HEAD, ast_log(), ast_mutex_destroy, ast_mutex_lock, ast_mutex_unlock, ast_translator_free_path(), ast_var_delete(), ast_channel::callerid, channels, ast_channel::dnid, free, ast_channel::lock, LOG_WARNING, ast_channel::monitor, ast_channel::name, ast_frame::next, ast_channel::next, ast_channel::pbx, ast_channel_pvt::pvt, ast_channel::pvt, ast_channel::rdnis, ast_channel_pvt::readq, ast_channel_pvt::readtrans, ast_channel_monitor::stop, ast_channel::timingfd, and ast_channel_pvt::writetrans. Referenced by ast_hangup(). { struct ast_channel *last=NULL, *cur; int fd; struct ast_var_t *vardata; struct ast_frame *f, *fp; struct varshead *headp; char name[AST_CHANNEL_NAME]; headp=&chan->varshead; ast_mutex_lock(&chlock); cur = channels; while(cur) { if (cur == chan) { if (last) last->next = cur->next; else channels = cur->next; break; } last = cur; cur = cur->next; } if (!cur) ast_log(LOG_WARNING, "Unable to find channel in list\n"); if (chan->pvt->pvt) ast_log(LOG_WARNING, "Channel '%s' may not have been hung up properly\n", chan->name); strncpy(name, chan->name, sizeof(name)-1); /* Stop monitoring */ if (chan->monitor) { chan->monitor->stop( chan, 0 ); } /* Free translatosr */ if (chan->pvt->readtrans) ast_translator_free_path(chan->pvt->readtrans); if (chan->pvt->writetrans) ast_translator_free_path(chan->pvt->writetrans); if (chan->pbx) ast_log(LOG_WARNING, "PBX may not have been terminated properly on '%s'\n", chan->name); if (chan->dnid) free(chan->dnid); if (chan->callerid) free(chan->callerid); if (chan->ani) free(chan->ani); if (chan->rdnis) free(chan->rdnis); ast_mutex_destroy(&chan->lock); /* Close pipes if appropriate */ if ((fd = chan->pvt->alertpipe[0]) > -1) close(fd); if ((fd = chan->pvt->alertpipe[1]) > -1) close(fd); if ((fd = chan->timingfd) > -1) close(fd); f = chan->pvt->readq; chan->pvt->readq = NULL; while(f) { fp = f; f = f->next; ast_frfree(fp); } /* loop over the variables list, freeing all data and deleting list items */ /* no need to lock the list, as the channel is already locked */ while (!AST_LIST_EMPTY(headp)) { /* List Deletion. */ vardata = AST_LIST_FIRST(headp); AST_LIST_REMOVE_HEAD(headp, entries); // printf("deleting var %s=%s\n",ast_var_name(vardata),ast_var_value(vardata)); ast_var_delete(vardata); } free(chan->pvt); chan->pvt = NULL; free(chan); ast_mutex_unlock(&chlock); ast_device_state_changed(name); }

int ast_queue_control (  struct ast_channel *  chan, int  control, int  lock )

Definition at line 409 of file channel.c. References AST_FRAME_CONTROL, ast_queue_frame(), and ast_frame::subclass. { struct ast_frame f = { AST_FRAME_CONTROL, }; f.subclass = control; return ast_queue_frame(chan, &f, lock); }

int ast_queue_frame (  struct ast_channel *  chan, struct ast_frame *  f, int  lock )

Queue an outgoing frame, locking if necessary Definition at line 352 of file channel.c. References ast_channel_pvt::alertpipe, AST_FRAME_VOICE, ast_frdup(), ast_frfree(), ast_log(), ast_mutex_lock, ast_mutex_unlock, ast_channel::blocker, ast_channel::blocking, CRASH, ast_frame::frametype, ast_channel::lock, LOG_DEBUG, LOG_WARNING, ast_channel::name, ast_frame::next, ast_channel::pvt, and ast_channel_pvt::readq. Referenced by ast_channel_masquerade(), ast_dsp_process(), ast_queue_control(), ast_queue_hangup(), and ast_softhangup_nolock(). { struct ast_frame *f; struct ast_frame *prev, *cur; int blah = 1; int qlen = 0; /* Build us a copy and free the original one */ f = ast_frdup(fin); if (!f) { ast_log(LOG_WARNING, "Unable to duplicate frame\n"); return -1; } if (lock) ast_mutex_lock(&chan->lock); prev = NULL; cur = chan->pvt->readq; while(cur) { prev = cur; cur = cur->next; qlen++; } /* Allow up to 96 voice frames outstanding, and up to 128 total frames */ if (((fin->frametype == AST_FRAME_VOICE) && (qlen > 96)) || (qlen > 128)) { if (fin->frametype != AST_FRAME_VOICE) { ast_log(LOG_WARNING, "Exceptionally long queue length queuing to %s\n", chan->name); CRASH; } else { ast_log(LOG_DEBUG, "Dropping voice to exceptionally long queue on %s\n", chan->name); ast_frfree(f); if (lock) ast_mutex_unlock(&chan->lock); return 0; } } if (prev) prev->next = f; else chan->pvt->readq = f; if (chan->pvt->alertpipe[1] > -1) { if (write(chan->pvt->alertpipe[1], &blah, sizeof(blah)) != sizeof(blah)) ast_log(LOG_WARNING, "Unable to write to alert pipe on %s, frametype/subclass %d/%d (qlen = %d): %s!\n", chan->name, f->frametype, f->subclass, qlen, strerror(errno)); } else if (chan->blocking) { pthread_kill(chan->blocker, SIGURG); } if (lock) ast_mutex_unlock(&chan->lock); return 0; }

int ast_queue_hangup (  struct ast_channel *  chan, int  lock )

Definition at line 402 of file channel.c. References ast_channel::_softhangup, AST_CONTROL_HANGUP, AST_FRAME_CONTROL, ast_queue_frame(), and AST_SOFTHANGUP_DEV. { struct ast_frame f = { AST_FRAME_CONTROL, AST_CONTROL_HANGUP }; chan->_softhangup |= AST_SOFTHANGUP_DEV; return ast_queue_frame(chan, &f, lock); }

int ast_setstate (  struct ast_channel *  chan, int  state )

Change the state of a channel Definition at line 2096 of file channel.c. References ast_channel::_state, ast_device_state_changed(), ast_state2str(), AST_STATE_DOWN, ast_channel::callerid, EVENT_FLAG_CALL, manager_event(), ast_channel::name, and ast_channel::uniqueid. Referenced by ast_answer(), ast_async_goto(), and ast_read(). { if (chan->_state != state) { int oldstate = chan->_state; chan->_state = state; if (oldstate == AST_STATE_DOWN) { ast_device_state_changed(chan->name); manager_event(EVENT_FLAG_CALL, "Newchannel", "Channel: %s\r\n" "State: %s\r\n" "Callerid: %s\r\n" "Uniqueid: %s\r\n", chan->name, ast_state2str(chan->_state), chan->callerid ? chan->callerid : "<unknown>", chan->uniqueid); } else { manager_event(EVENT_FLAG_CALL, "Newstate", "Channel: %s\r\n" "State: %s\r\n" "Callerid: %s\r\n" "Uniqueid: %s\r\n", chan->name, ast_state2str(chan->_state), chan->callerid ? chan->callerid : "<unknown>", chan->uniqueid); } } return 0; }

---