Sat Nov 1 06:28:54 2008

Asterisk developer's documentation

---

chan_local.c File Reference

Local Proxy Channel. More...

#include "asterisk.h"
#include <stdio.h>
#include <string.h>
#include <unistd.h>
#include <sys/socket.h>
#include <errno.h>
#include <stdlib.h>
#include <fcntl.h>
#include <netdb.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <sys/signal.h>
#include "asterisk/lock.h"
#include "asterisk/channel.h"
#include "asterisk/config.h"
#include "asterisk/logger.h"
#include "asterisk/module.h"
#include "asterisk/pbx.h"
#include "asterisk/options.h"
#include "asterisk/sched.h"
#include "asterisk/io.h"
#include "asterisk/rtp.h"
#include "asterisk/acl.h"
#include "asterisk/callerid.h"
#include "asterisk/file.h"
#include "asterisk/cli.h"
#include "asterisk/app.h"
#include "asterisk/musiconhold.h"
#include "asterisk/manager.h"
#include "asterisk/stringfields.h"
#include "asterisk/devicestate.h"

Include dependency graph for chan_local.c:

Go to the source code of this file.

Data Structures
struct	local_pvt
Defines
#define	IS_OUTBOUND(a, b)   (a == b->chan ? 1 : 0)
#define	LOCAL_ALREADY_MASQED   (1 << 2)
#define	LOCAL_CANCEL_QUEUE   (1 << 1)
#define	LOCAL_GLARE_DETECT   (1 << 0)
#define	LOCAL_LAUNCHED_PBX   (1 << 3)
#define	LOCAL_NO_OPTIMIZATION   (1 << 4)
Functions
static	AST_LIST_HEAD_STATIC (locals, local_pvt)
	AST_MODULE_INFO_STANDARD (ASTERISK_GPL_KEY,"Local Proxy Channel (Note: used internally by other modules)")
static void	check_bridge (struct local_pvt *p, int isoutbound)
static int	load_module (void)
	Load module into PBX, register channel.
static struct local_pvt *	local_alloc (const char *data, int format)
	Create a call structure.
static int	local_answer (struct ast_channel *ast)
static int	local_call (struct ast_channel *ast, char *dest, int timeout)
	Initiate new call, part of PBX interface dest is the dial string.
static int	local_devicestate (void *data)
	Adds devicestate to local channels.
static int	local_digit_begin (struct ast_channel *ast, char digit)
static int	local_digit_end (struct ast_channel *ast, char digit, unsigned int duration)
static int	local_fixup (struct ast_channel *oldchan, struct ast_channel *newchan)
static int	local_hangup (struct ast_channel *ast)
	Hangup a call through the local proxy channel.
static int	local_indicate (struct ast_channel *ast, int condition, const void *data, size_t datalen)
static struct ast_channel *	local_new (struct local_pvt *p, int state)
	Start new local channel.
static struct local_pvt *	local_pvt_destroy (struct local_pvt *pvt)
static int	local_queue_frame (struct local_pvt *p, int isoutbound, struct ast_frame *f, struct ast_channel *us, int us_locked)
static struct ast_frame *	local_read (struct ast_channel *ast)
static struct ast_channel *	local_request (const char *type, int format, void *data, int *cause)
	Part of PBX interface.
static int	local_sendhtml (struct ast_channel *ast, int subclass, const char *data, int datalen)
static int	local_sendtext (struct ast_channel *ast, const char *text)
static int	local_write (struct ast_channel *ast, struct ast_frame *f)
static int	locals_show (int fd, int argc, char **argv)
	CLI command "local show channels".
static int	unload_module (void)
	Unload the local proxy channel from Asterisk.
Variables
static struct ast_cli_entry	cli_local []
static struct ast_channel_tech	local_tech
static char	show_locals_usage []
static const char	tdesc [] = "Local Proxy Channel Driver"

---

Detailed Description

Local Proxy Channel.

Author:

Mark Spencer <markster@digium.com>

Definition in file chan_local.c.

---

Define Documentation

#define IS_OUTBOUND	(	a,
		b		)	(a == b->chan ? 1 : 0)

Definition at line 67 of file chan_local.c.

#define LOCAL_ALREADY_MASQED   (1 << 2)

Already masqueraded

Definition at line 120 of file chan_local.c.

Referenced by check_bridge(), and local_write().

#define LOCAL_CANCEL_QUEUE   (1 << 1)

Cancel queue

Definition at line 119 of file chan_local.c.

Referenced by local_hangup(), and local_queue_frame().

#define LOCAL_GLARE_DETECT   (1 << 0)

Detect glare on hangup

Definition at line 118 of file chan_local.c.

Referenced by local_hangup(), and local_queue_frame().

#define LOCAL_LAUNCHED_PBX   (1 << 3)

PBX was launched

Definition at line 121 of file chan_local.c.

Referenced by local_call(), and local_hangup().

#define LOCAL_NO_OPTIMIZATION   (1 << 4)

Do not optimize using masquerading

Definition at line 122 of file chan_local.c.

Referenced by check_bridge(), and local_alloc().

---

Function Documentation

static AST_LIST_HEAD_STATIC	(	locals	,
		local_pvt
	)			[static]

AST_MODULE_INFO_STANDARD	(	ASTERISK_GPL_KEY	,
		"Local Proxy Channel (Note: used internally by other modules)"
	)

static void check_bridge	(	struct local_pvt *	p,
		int	isoutbound
	)			[static]

Definition at line 237 of file chan_local.c.

References ast_channel::_bridge, ast_channel::_softhangup, ast_bridged_channel(), ast_channel_masquerade(), AST_LIST_EMPTY, ast_mutex_trylock(), ast_mutex_unlock(), ast_set_flag, ast_test_flag, local_pvt::chan, LOCAL_ALREADY_MASQED, LOCAL_NO_OPTIMIZATION, ast_channel::lock, ast_channel::monitor, and local_pvt::owner.

Referenced by local_write().

{
   struct ast_channel_monitor *tmp;
   if (ast_test_flag(p, LOCAL_ALREADY_MASQED) || ast_test_flag(p, LOCAL_NO_OPTIMIZATION) || !p->chan || !p->owner || (p->chan->_bridge != ast_bridged_channel(p->chan)))
      return;

   /* only do the masquerade if we are being called on the outbound channel,
      if it has been bridged to another channel and if there are no pending
      frames on the owner channel (because they would be transferred to the
      outbound channel during the masquerade)
   */
   if (isoutbound && p->chan->_bridge /* Not ast_bridged_channel!  Only go one step! */ && AST_LIST_EMPTY(&p->owner->readq)) {
      /* Masquerade bridged channel into owner */
      /* Lock everything we need, one by one, and give up if
         we can't get everything.  Remember, we'll get another
         chance in just a little bit */
      if (!ast_mutex_trylock(&(p->chan->_bridge)->lock)) {
         if (!p->chan->_bridge->_softhangup) {
            if (!ast_mutex_trylock(&p->owner->lock)) {
               if (!p->owner->_softhangup) {
                  if(p->owner->monitor && !p->chan->_bridge->monitor) {
                     /* If a local channel is being monitored, we don't want a masquerade
                      * to cause the monitor to go away. Since the masquerade swaps the monitors,
                      * pre-swapping the monitors before the masquerade will ensure that the monitor
                      * ends up where it is expected.
                      */
                     tmp = p->owner->monitor;
                     p->owner->monitor = p->chan->_bridge->monitor;
                     p->chan->_bridge->monitor = tmp;
                  }
                  ast_channel_masquerade(p->owner, p->chan->_bridge);
                  ast_set_flag(p, LOCAL_ALREADY_MASQED);
               }
               ast_mutex_unlock(&p->owner->lock);
            }
            ast_mutex_unlock(&(p->chan->_bridge)->lock);
         }
      }
   /* We only allow masquerading in one 'direction'... it's important to preserve the state
      (group variables, etc.) that live on p->chan->_bridge (and were put there by the dialplan)
      when the local channels go away.
   */
#if 0
   } else if (!isoutbound && p->owner && p->owner->_bridge && p->chan && AST_LIST_EMPTY(&p->chan->readq)) {
      /* Masquerade bridged channel into chan */
      if (!ast_mutex_trylock(&(p->owner->_bridge)->lock)) {
         if (!p->owner->_bridge->_softhangup) {
            if (!ast_mutex_trylock(&p->chan->lock)) {
               if (!p->chan->_softhangup) {
                  ast_channel_masquerade(p->chan, p->owner->_bridge);
                  ast_set_flag(p, LOCAL_ALREADY_MASQED);
               }
               ast_mutex_unlock(&p->chan->lock);
            }
         }
         ast_mutex_unlock(&(p->owner->_bridge)->lock);
      }
#endif
   }
}

static int load_module

(

void

)

[static]

Load module into PBX, register channel.

Definition at line 768 of file chan_local.c.

References ast_channel_register(), ast_cli_register_multiple(), ast_log(), cli_local, local_tech, and LOG_ERROR.

{
   /* Make sure we can register our channel type */
   if (ast_channel_register(&local_tech)) {
      ast_log(LOG_ERROR, "Unable to register channel class 'Local'\n");
      return -1;
   }
   ast_cli_register_multiple(cli_local, sizeof(cli_local) / sizeof(struct ast_cli_entry));
   return 0;
}

static struct local_pvt* local_alloc	(	const char *	data,
		int	format
	)			[static]

Create a call structure.

Definition at line 607 of file chan_local.c.

References ast_calloc, ast_exists_extension(), AST_LIST_INSERT_HEAD, AST_LIST_LOCK, AST_LIST_UNLOCK, ast_log(), ast_mutex_init(), ast_set_flag, LOCAL_NO_OPTIMIZATION, local_pvt_destroy(), locals, and LOG_NOTICE.

Referenced by local_request().

{
   struct local_pvt *tmp = NULL;
   char *c = NULL, *opts = NULL;

   if (!(tmp = ast_calloc(1, sizeof(*tmp))))
      return NULL;

   /* Initialize private structure information */
   ast_mutex_init(&tmp->lock);
   ast_copy_string(tmp->exten, data, sizeof(tmp->exten));

   /* Look for options */
   if ((opts = strchr(tmp->exten, '/'))) {
      *opts++ = '\0';
      if (strchr(opts, 'n'))
         ast_set_flag(tmp, LOCAL_NO_OPTIMIZATION);
   }

   /* Look for a context */
   if ((c = strchr(tmp->exten, '@')))
      *c++ = '\0';

   ast_copy_string(tmp->context, c ? c : "default", sizeof(tmp->context));

   tmp->reqformat = format;

#if 0
   /* We can't do this check here, because we don't know the CallerID yet, and
    * the CallerID could potentially affect what step is actually taken (or
    * even if that step exists). */
   if (!ast_exists_extension(NULL, tmp->context, tmp->exten, 1, NULL)) {
      ast_log(LOG_NOTICE, "No such extension/context %s@%s creating local channel\n", tmp->exten, tmp->context);
      tmp = local_pvt_destroy(tmp);
   } else {
#endif
      /* Add to list */
      AST_LIST_LOCK(&locals);
      AST_LIST_INSERT_HEAD(&locals, tmp, list);
      AST_LIST_UNLOCK(&locals);
#if 0
   }
#endif
   
   return tmp;
}

static int local_answer

(

struct ast_channel *

ast

)

[static]

Definition at line 215 of file chan_local.c.

References answer, AST_CONTROL_ANSWER, AST_FRAME_CONTROL, ast_log(), ast_mutex_lock(), ast_mutex_unlock(), IS_OUTBOUND, local_queue_frame(), local_pvt::lock, LOG_WARNING, and ast_channel::tech_pvt.

{
   struct local_pvt *p = ast->tech_pvt;
   int isoutbound;
   int res = -1;

   if (!p)
      return -1;

   ast_mutex_lock(&p->lock);
   isoutbound = IS_OUTBOUND(ast, p);
   if (isoutbound) {
      /* Pass along answer since somebody answered us */
      struct ast_frame answer = { AST_FRAME_CONTROL, AST_CONTROL_ANSWER };
      res = local_queue_frame(p, isoutbound, &answer, ast, 1);
   } else
      ast_log(LOG_WARNING, "Huh?  Local is being asked to answer?\n");
   if (!res)
      ast_mutex_unlock(&p->lock);
   return res;
}

static int local_call	(	struct ast_channel *	ast,
		char *	dest,
		int	timeout
	)			[static]

Initiate new call, part of PBX interface dest is the dial string.

Definition at line 460 of file chan_local.c.

References accountcode, ast_calloc, ast_cdr_update(), ast_channel_datastore_inherit(), ast_exists_extension(), AST_LIST_INSERT_TAIL, AST_LIST_TRAVERSE, ast_log(), ast_mutex_lock(), ast_mutex_unlock(), ast_pbx_start(), ast_set_flag, ast_strdup, ast_string_field_set, ast_channel::cdrflags, local_pvt::chan, ast_channel::cid, ast_callerid::cid_ani, ast_callerid::cid_ani2, ast_callerid::cid_dnid, ast_callerid::cid_name, ast_callerid::cid_num, ast_callerid::cid_pres, ast_callerid::cid_rdnis, ast_callerid::cid_tns, ast_callerid::cid_ton, ast_channel::context, ast_channel::exten, language, len, LOCAL_LAUNCHED_PBX, local_pvt::lock, LOG_NOTICE, ast_var_t::name, local_pvt::owner, ast_channel::tech_pvt, ast_var_t::value, and ast_channel::varshead.

{
   struct local_pvt *p = ast->tech_pvt;
   int res;
   struct ast_var_t *varptr = NULL, *new;
   size_t len, namelen;

   if (!p)
      return -1;
   
   ast_mutex_lock(&p->lock);

   /*
    * Note that cid_num and cid_name aren't passed in the ast_channel_alloc
    * call, so it's done here instead.
    */
   p->chan->cid.cid_dnid = ast_strdup(p->owner->cid.cid_dnid);
   p->chan->cid.cid_num = ast_strdup(p->owner->cid.cid_num);
   p->chan->cid.cid_name = ast_strdup(p->owner->cid.cid_name);
   p->chan->cid.cid_rdnis = ast_strdup(p->owner->cid.cid_rdnis);
   p->chan->cid.cid_ani = ast_strdup(p->owner->cid.cid_ani);
   p->chan->cid.cid_pres = p->owner->cid.cid_pres;
   p->chan->cid.cid_ani2 = p->owner->cid.cid_ani2;
   p->chan->cid.cid_ton = p->owner->cid.cid_ton;
   p->chan->cid.cid_tns = p->owner->cid.cid_tns;
   ast_string_field_set(p->chan, language, p->owner->language);
   ast_string_field_set(p->chan, accountcode, p->owner->accountcode);
   ast_cdr_update(p->chan);
   p->chan->cdrflags = p->owner->cdrflags;

   if (!ast_exists_extension(NULL, p->chan->context, p->chan->exten, 1, p->owner->cid.cid_num)) {
      ast_log(LOG_NOTICE, "No such extension/context %s@%s while calling Local channel\n", p->chan->exten, p->chan->context);
      ast_mutex_unlock(&p->lock);
      return -1;
   }

   /* copy the channel variables from the incoming channel to the outgoing channel */
   /* Note that due to certain assumptions, they MUST be in the same order */
   AST_LIST_TRAVERSE(&p->owner->varshead, varptr, entries) {
      namelen = strlen(varptr->name);
      len = sizeof(struct ast_var_t) + namelen + strlen(varptr->value) + 2;
      if ((new = ast_calloc(1, len))) {
         memcpy(new, varptr, len);
         new->value = &(new->name[0]) + namelen + 1;
         AST_LIST_INSERT_TAIL(&p->chan->varshead, new, entries);
      }
   }
   ast_channel_datastore_inherit(p->owner, p->chan);

   /* Start switch on sub channel */
   if (!(res = ast_pbx_start(p->chan)))
      ast_set_flag(p, LOCAL_LAUNCHED_PBX);

   ast_mutex_unlock(&p->lock);
   return res;
}

static int local_devicestate

(

void *

data

)

[static]

Adds devicestate to local channels.

Definition at line 127 of file chan_local.c.

References AST_DEVICE_INVALID, AST_DEVICE_UNKNOWN, ast_exists_extension(), ast_log(), ast_strdupa, local_pvt::context, local_pvt::exten, LOG_DEBUG, LOG_WARNING, and option_debug.

{
   char *exten = ast_strdupa(data);
   char *context = NULL, *opts = NULL;
   int res;

   if (!(context = strchr(exten, '@'))) {
      ast_log(LOG_WARNING, "Someone used Local/%s somewhere without a @context. This is bad.\n", exten);
      return AST_DEVICE_INVALID; 
   }

   *context++ = '\0';

   /* Strip options if they exist */
   if ((opts = strchr(context, '/')))
      *opts = '\0';

   if (option_debug > 2)
      ast_log(LOG_DEBUG, "Checking if extension %s@%s exists (devicestate)\n", exten, context);
   res = ast_exists_extension(NULL, context, exten, 1, NULL);
   if (!res)      
      return AST_DEVICE_INVALID;
   else
      return AST_DEVICE_UNKNOWN;
}

static int local_digit_begin	(	struct ast_channel *	ast,
		char	digit
	)			[static]

Definition at line 380 of file chan_local.c.

References AST_FRAME_DTMF_BEGIN, ast_mutex_lock(), ast_mutex_unlock(), f, IS_OUTBOUND, local_queue_frame(), local_pvt::lock, and ast_channel::tech_pvt.

{
   struct local_pvt *p = ast->tech_pvt;
   int res = -1;
   struct ast_frame f = { AST_FRAME_DTMF_BEGIN, };
   int isoutbound;

   if (!p)
      return -1;

   ast_mutex_lock(&p->lock);
   isoutbound = IS_OUTBOUND(ast, p);
   f.subclass = digit;
   if (!(res = local_queue_frame(p, isoutbound, &f, ast, 0)))
      ast_mutex_unlock(&p->lock);

   return res;
}

static int local_digit_end	(	struct ast_channel *	ast,
		char	digit,
		unsigned int	duration
	)			[static]

Definition at line 399 of file chan_local.c.

References AST_FRAME_DTMF_END, ast_mutex_lock(), ast_mutex_unlock(), f, IS_OUTBOUND, local_queue_frame(), local_pvt::lock, and ast_channel::tech_pvt.

{
   struct local_pvt *p = ast->tech_pvt;
   int res = -1;
   struct ast_frame f = { AST_FRAME_DTMF_END, };
   int isoutbound;

   if (!p)
      return -1;

   ast_mutex_lock(&p->lock);
   isoutbound = IS_OUTBOUND(ast, p);
   f.subclass = digit;
   f.len = duration;
   if (!(res = local_queue_frame(p, isoutbound, &f, ast, 0)))
      ast_mutex_unlock(&p->lock);

   return res;
}

static int local_fixup	(	struct ast_channel *	oldchan,
		struct ast_channel *	newchan
	)			[static]

Definition at line 329 of file chan_local.c.

References ast_log(), ast_mutex_lock(), ast_mutex_unlock(), local_pvt::chan, local_pvt::lock, LOG_WARNING, local_pvt::owner, and ast_channel::tech_pvt.

{
   struct local_pvt *p = newchan->tech_pvt;

   if (!p)
      return -1;

   ast_mutex_lock(&p->lock);

   if ((p->owner != oldchan) && (p->chan != oldchan)) {
      ast_log(LOG_WARNING, "Old channel wasn't %p but was %p/%p\n", oldchan, p->owner, p->chan);
      ast_mutex_unlock(&p->lock);
      return -1;
   }
   if (p->owner == oldchan)
      p->owner = newchan;
   else
      p->chan = newchan;
   ast_mutex_unlock(&p->lock);
   return 0;
}

static int local_hangup

(

struct ast_channel *

ast

)

[static]

Hangup a call through the local proxy channel.

Definition at line 518 of file chan_local.c.

References ast_channel_lock, ast_channel_trylock, ast_channel_unlock, ast_clear_flag, AST_CONTROL_HANGUP, AST_FRAME_CONTROL, ast_hangup(), AST_LIST_LOCK, AST_LIST_REMOVE, AST_LIST_UNLOCK, ast_module_user_remove, ast_mutex_lock(), ast_mutex_trylock(), ast_mutex_unlock(), ast_queue_hangup(), ast_set_flag, ast_test_flag, local_pvt::chan, DEADLOCK_AVOIDANCE, f, IS_OUTBOUND, LOCAL_CANCEL_QUEUE, LOCAL_GLARE_DETECT, LOCAL_LAUNCHED_PBX, local_pvt_destroy(), local_queue_frame(), locals, local_pvt::lock, local_pvt::owner, pbx_builtin_getvar_helper(), pbx_builtin_setvar_helper(), ast_channel::tech_pvt, local_pvt::u_chan, and local_pvt::u_owner.

{
   struct local_pvt *p = ast->tech_pvt;
   int isoutbound;
   struct ast_frame f = { AST_FRAME_CONTROL, AST_CONTROL_HANGUP };
   struct ast_channel *ochan = NULL;
   int glaredetect = 0, res = 0;

   if (!p)
      return -1;

   while (ast_mutex_trylock(&p->lock)) {
      ast_channel_unlock(ast);
      usleep(1);
      ast_channel_lock(ast);
   }

   isoutbound = IS_OUTBOUND(ast, p);
   if (isoutbound) {
      const char *status = pbx_builtin_getvar_helper(p->chan, "DIALSTATUS");
      if ((status) && (p->owner)) {
         /* Deadlock avoidance */
         while (p->owner && ast_channel_trylock(p->owner)) {
            ast_mutex_unlock(&p->lock);
            if (ast) {
               ast_channel_unlock(ast);
            }
            usleep(1);
            if (ast) {
               ast_channel_lock(ast);
            }
            ast_mutex_lock(&p->lock);
         }
         if (p->owner) {
            pbx_builtin_setvar_helper(p->owner, "CHANLOCALSTATUS", status);
            ast_channel_unlock(p->owner);
         }
      }
      p->chan = NULL;
      ast_clear_flag(p, LOCAL_LAUNCHED_PBX);
      ast_module_user_remove(p->u_chan);
   } else {
      p->owner = NULL;
      ast_module_user_remove(p->u_owner);
      while (p->chan && ast_channel_trylock(p->chan)) {
         DEADLOCK_AVOIDANCE(&p->lock);
      }
      if (p->chan) {
         ast_queue_hangup(p->chan);
         ast_channel_unlock(p->chan);
      }
   }
   
   ast->tech_pvt = NULL;
   
   if (!p->owner && !p->chan) {
      /* Okay, done with the private part now, too. */
      glaredetect = ast_test_flag(p, LOCAL_GLARE_DETECT);
      /* If we have a queue holding, don't actually destroy p yet, but
         let local_queue do it. */
      if (glaredetect)
         ast_set_flag(p, LOCAL_CANCEL_QUEUE);
      ast_mutex_unlock(&p->lock);
      /* Remove from list */
      AST_LIST_LOCK(&locals);
      AST_LIST_REMOVE(&locals, p, list);
      AST_LIST_UNLOCK(&locals);
      /* Grab / release lock just in case */
      ast_mutex_lock(&p->lock);
      ast_mutex_unlock(&p->lock);
      /* And destroy */
      if (!glaredetect) {
         p = local_pvt_destroy(p);
      }
      return 0;
   }
   if (p->chan && !ast_test_flag(p, LOCAL_LAUNCHED_PBX))
      /* Need to actually hangup since there is no PBX */
      ochan = p->chan;
   else
      res = local_queue_frame(p, isoutbound, &f, NULL, 1);
   if (!res)
      ast_mutex_unlock(&p->lock);
   if (ochan)
      ast_hangup(ochan);
   return 0;
}

static int local_indicate	(	struct ast_channel *	ast,
		int	condition,
		const void *	data,
		size_t	datalen
	)			[static]

Definition at line 351 of file chan_local.c.

References AST_CONTROL_HOLD, AST_CONTROL_UNHOLD, AST_FRAME_CONTROL, ast_moh_start(), ast_moh_stop(), ast_mutex_lock(), ast_mutex_unlock(), f, IS_OUTBOUND, local_queue_frame(), local_pvt::lock, and ast_channel::tech_pvt.

{
   struct local_pvt *p = ast->tech_pvt;
   int res = 0;
   struct ast_frame f = { AST_FRAME_CONTROL, };
   int isoutbound;

   if (!p)
      return -1;

   /* If this is an MOH hold or unhold, do it on the Local channel versus real channel */
   if (condition == AST_CONTROL_HOLD) {
      ast_moh_start(ast, data, NULL);
   } else if (condition == AST_CONTROL_UNHOLD) {
      ast_moh_stop(ast);
   } else {
      /* Queue up a frame representing the indication as a control frame */
      ast_mutex_lock(&p->lock);
      isoutbound = IS_OUTBOUND(ast, p);
      f.subclass = condition;
      f.data = (void*)data;
      f.datalen = datalen;
      if (!(res = local_queue_frame(p, isoutbound, &f, ast, 1)))
         ast_mutex_unlock(&p->lock);
   }

   return res;
}

static struct ast_channel* local_new	(	struct local_pvt *	p,
		int	state
	)			[static]

Start new local channel.

Definition at line 655 of file chan_local.c.

References ast_channel::amaflags, ast_best_codec(), ast_channel_alloc(), ast_channel_free(), ast_log(), ast_module_user_add, ast_random(), AST_STATE_RING, local_pvt::chan, ast_channel::context, local_pvt::context, ast_channel::exten, local_pvt::exten, fmt, local_tech, LOG_WARNING, ast_channel::nativeformats, local_pvt::owner, ast_channel::priority, ast_channel::rawreadformat, ast_channel::rawwriteformat, ast_channel::readformat, local_pvt::reqformat, t, ast_channel::tech, ast_channel::tech_pvt, local_pvt::u_chan, local_pvt::u_owner, and ast_channel::writeformat.

Referenced by local_request().

{
   struct ast_channel *tmp = NULL, *tmp2 = NULL;
   int randnum = ast_random() & 0xffff, fmt = 0;
   const char *t;
   int ama;

   /* Allocate two new Asterisk channels */
   /* safe accountcode */
   if (p->owner && p->owner->accountcode)
      t = p->owner->accountcode;
   else
      t = "";

   if (p->owner)
      ama = p->owner->amaflags;
   else
      ama = 0;
   if (!(tmp = ast_channel_alloc(1, state, 0, 0, t, p->exten, p->context, ama, "Local/%s@%s-%04x,1", p->exten, p->context, randnum)) 
         || !(tmp2 = ast_channel_alloc(1, AST_STATE_RING, 0, 0, t, p->exten, p->context, ama, "Local/%s@%s-%04x,2", p->exten, p->context, randnum))) {
      if (tmp)
         ast_channel_free(tmp);
      if (tmp2)
         ast_channel_free(tmp2);
      ast_log(LOG_WARNING, "Unable to allocate channel structure(s)\n");
      return NULL;
   } 

   tmp2->tech = tmp->tech = &local_tech;

   tmp->nativeformats = p->reqformat;
   tmp2->nativeformats = p->reqformat;

   /* Determine our read/write format and set it on each channel */
   fmt = ast_best_codec(p->reqformat);
   tmp->writeformat = fmt;
   tmp2->writeformat = fmt;
   tmp->rawwriteformat = fmt;
   tmp2->rawwriteformat = fmt;
   tmp->readformat = fmt;
   tmp2->readformat = fmt;
   tmp->rawreadformat = fmt;
   tmp2->rawreadformat = fmt;

   tmp->tech_pvt = p;
   tmp2->tech_pvt = p;

   p->owner = tmp;
   p->chan = tmp2;
   p->u_owner = ast_module_user_add(p->owner);
   p->u_chan = ast_module_user_add(p->chan);

   ast_copy_string(tmp->context, p->context, sizeof(tmp->context));
   ast_copy_string(tmp2->context, p->context, sizeof(tmp2->context));
   ast_copy_string(tmp2->exten, p->exten, sizeof(tmp->exten));
   tmp->priority = 1;
   tmp2->priority = 1;

   return tmp;
}

static struct local_pvt* local_pvt_destroy

(

struct local_pvt *

pvt

)

[static]

Note:

Assumes the pvt is no longer in the pvts list

Definition at line 156 of file chan_local.c.

References ast_mutex_destroy(), free, and local_pvt::lock.

Referenced by local_alloc(), local_hangup(), local_queue_frame(), and local_request().

{
   ast_mutex_destroy(&pvt->lock);
   free(pvt);
   return NULL;
}

static int local_queue_frame	(	struct local_pvt *	p,
		int	isoutbound,
		struct ast_frame *	f,
		struct ast_channel *	us,
		int	us_locked
	)			[static]

Definition at line 163 of file chan_local.c.

References ast_channel_lock, ast_channel_trylock, ast_channel_unlock, ast_clear_flag, ast_mutex_lock(), ast_mutex_trylock(), ast_mutex_unlock(), ast_queue_frame(), ast_set_flag, ast_test_flag, local_pvt::chan, f, ast_channel::generator, LOCAL_CANCEL_QUEUE, LOCAL_GLARE_DETECT, local_pvt_destroy(), local_pvt::lock, and local_pvt::owner.

Referenced by local_answer(), local_digit_begin(), local_digit_end(), local_hangup(), local_indicate(), local_sendhtml(), local_sendtext(), and local_write().

{
   struct ast_channel *other = NULL;

   /* Recalculate outbound channel */
   other = isoutbound ? p->owner : p->