cdr.h File Reference

Call Detail Record API. More...

#include <sys/time.h>
#include "asterisk/channel.h"
#include "asterisk/utils.h"

Include dependency graph for cdr.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Data Structures
struct	ast_cdr
Defines
#define	AST_CDR_ANSWERED   (1 << 3)
#define	AST_CDR_BILLING   (2)
#define	AST_CDR_BUSY   (1 << 1)
#define	AST_CDR_DOCUMENTATION   (3)
#define	AST_CDR_FAILED   (1 << 0)
#define	AST_CDR_FLAG_CHILD   (1 << 3)
#define	AST_CDR_FLAG_KEEP_VARS   (1 << 0)
#define	AST_CDR_FLAG_LOCKED   (1 << 2)
#define	AST_CDR_FLAG_POST_DISABLED   (1 << 4)
#define	AST_CDR_FLAG_POSTED   (1 << 1)
#define	AST_CDR_NOANSWER   (1 << 2)
#define	AST_CDR_NULL   0
#define	AST_CDR_OMIT   (1)
#define	AST_MAX_ACCOUNT_CODE   20
#define	AST_MAX_USER_FIELD   256
Typedefs
typedef int(*	ast_cdrbe )(struct ast_cdr *cdr)
Functions
struct ast_cdr *	ast_cdr_alloc (void)
	Allocate a CDR record Returns a malloc'd ast_cdr structure, returns NULL on error (malloc failure).
int	ast_cdr_amaflags2int (const char *flag)
void	ast_cdr_answer (struct ast_cdr *cdr)
struct ast_cdr *	ast_cdr_append (struct ast_cdr *cdr, struct ast_cdr *newcdr)
int	ast_cdr_appenduserfield (struct ast_channel *chan, const char *userfield)
void	ast_cdr_busy (struct ast_cdr *cdr)
int	ast_cdr_copy_vars (struct ast_cdr *to_cdr, struct ast_cdr *from_cdr)
void	ast_cdr_detach (struct ast_cdr *cdr)
char *	ast_cdr_disp2str (int disposition)
int	ast_cdr_disposition (struct ast_cdr *cdr, int cause)
struct ast_cdr *	ast_cdr_dup (struct ast_cdr *cdr)
	Duplicate a record Returns a malloc'd ast_cdr structure, returns NULL on error (malloc failure).
void	ast_cdr_end (struct ast_cdr *cdr)
int	ast_cdr_engine_init (void)
void	ast_cdr_engine_reload (void)
void	ast_cdr_engine_term (void)
void	ast_cdr_failed (struct ast_cdr *cdr)
char *	ast_cdr_flags2str (int flags)
void	ast_cdr_free (struct ast_cdr *cdr)
	Free a CDR record.
void	ast_cdr_free_vars (struct ast_cdr *cdr, int recur)
void	ast_cdr_getvar (struct ast_cdr *cdr, const char *name, char **ret, char *workspace, int workspacelen, int recur)
int	ast_cdr_init (struct ast_cdr *cdr, struct ast_channel *chan)
	Initialize based on a channel.
void	ast_cdr_noanswer (struct ast_cdr *cdr)
int	ast_cdr_register (char *name, char *desc, ast_cdrbe be)
void	ast_cdr_reset (struct ast_cdr *cdr, struct ast_flags *flags)
int	ast_cdr_serialize_variables (struct ast_cdr *cdr, char *buf, size_t size, char delim, char sep, int recur)
int	ast_cdr_setaccount (struct ast_channel *chan, const char *account)
int	ast_cdr_setamaflags (struct ast_channel *chan, const char *amaflags)
void	ast_cdr_setapp (struct ast_cdr *cdr, char *app, char *data)
int	ast_cdr_setcid (struct ast_cdr *cdr, struct ast_channel *chan)
void	ast_cdr_setdestchan (struct ast_cdr *cdr, char *chan)
int	ast_cdr_setuserfield (struct ast_channel *chan, const char *userfield)
int	ast_cdr_setvar (struct ast_cdr *cdr, const char *name, const char *value, int recur)
void	ast_cdr_start (struct ast_cdr *cdr)
void	ast_cdr_submit_batch (int shutdown)
void	ast_cdr_unregister (char *name)
int	ast_cdr_update (struct ast_channel *chan)
Variables
char	ast_default_accountcode [AST_MAX_ACCOUNT_CODE]
int	ast_default_amaflags

---

Detailed Description

Call Detail Record API.

Definition in file cdr.h.

---

Define Documentation

#define AST_CDR_ANSWERED   (1 << 3)

Definition at line 37 of file cdr.h.

Referenced by ast_cdr_answer(), ast_cdr_disp2str(), and ast_cdr_init().

#define AST_CDR_BILLING   (2)

Definition at line 41 of file cdr.h.

Referenced by ast_cdr_amaflags2int(), and ast_cdr_flags2str().

#define AST_CDR_BUSY   (1 << 1)

Definition at line 35 of file cdr.h.

Referenced by ast_cdr_busy(), and ast_cdr_disp2str().

#define AST_CDR_DOCUMENTATION   (3)

Definition at line 42 of file cdr.h.

Referenced by ast_cdr_amaflags2int(), and ast_cdr_flags2str().

#define AST_CDR_FAILED   (1 << 0)

Definition at line 34 of file cdr.h.

Referenced by ast_cdr_disp2str(), ast_cdr_failed(), and post_cdr().

#define AST_CDR_FLAG_CHILD   (1 << 3)

Definition at line 30 of file cdr.h.

Referenced by ast_cdr_fork().

#define AST_CDR_FLAG_KEEP_VARS   (1 << 0)

Definition at line 27 of file cdr.h.

Referenced by ast_cdr_fork(), ast_cdr_reset(), and forkcdr_exec().

#define AST_CDR_FLAG_LOCKED   (1 << 2)

Definition at line 29 of file cdr.h.

Referenced by ast_cdr_appenduserfield(), ast_cdr_busy(), ast_cdr_failed(), ast_cdr_fork(), ast_cdr_init(), ast_cdr_noanswer(), ast_cdr_reset(), ast_cdr_setaccount(), ast_cdr_setamaflags(), ast_cdr_setapp(), ast_cdr_setcid(), ast_cdr_setdestchan(), ast_cdr_setuserfield(), ast_cdr_start(), and ast_cdr_update().

#define AST_CDR_FLAG_POST_DISABLED   (1 << 4)

Definition at line 31 of file cdr.h.

Referenced by ast_cdr_detach(), and ast_cdr_free().

#define AST_CDR_FLAG_POSTED   (1 << 1)

Definition at line 28 of file cdr.h.

Referenced by ast_cdr_answer(), ast_cdr_busy(), ast_cdr_end(), ast_cdr_failed(), ast_cdr_free(), ast_cdr_noanswer(), ast_cdr_reset(), ast_cdr_setapp(), ast_cdr_setdestchan(), ast_cdr_start(), disa_exec(), and post_cdr().

#define AST_CDR_NOANSWER   (1 << 2)

Definition at line 36 of file cdr.h.

Referenced by ast_cdr_disp2str(), and ast_cdr_noanswer().

#define AST_CDR_NULL   0

Definition at line 33 of file cdr.h.

Referenced by ast_cdr_disp2str(), ast_cdr_init(), and ast_cdr_reset().

#define AST_CDR_OMIT   (1)

AMA Flags

Definition at line 40 of file cdr.h.

Referenced by ast_cdr_amaflags2int(), and ast_cdr_flags2str().

#define AST_MAX_ACCOUNT_CODE   20

Definition at line 45 of file cdr.h.

#define AST_MAX_USER_FIELD   256

Definition at line 44 of file cdr.h.

---

Typedef Documentation

typedef int(* ast_cdrbe)(struct ast_cdr *cdr)

Definition at line 106 of file cdr.h.

---

Function Documentation

struct ast_cdr* ast_cdr_alloc

(

void

)

[read]

Allocate a CDR record Returns a malloc'd ast_cdr structure, returns NULL on error (malloc failure).

Definition at line 455 of file cdr.c.

References malloc.

Referenced by __agent_start_monitoring(), __ast_pbx_run(), __ast_request_and_dial(), ast_cdr_dup(), ast_feature_request_and_dial(), ast_pbx_outgoing_app(), ast_pbx_outgoing_cdr_failed(), ast_pbx_outgoing_exten(), and start_monitor_exec().

{
   struct ast_cdr *cdr;

   cdr = malloc(sizeof(*cdr));
   if (cdr)
      memset(cdr, 0, sizeof(*cdr));

   return cdr;
}

int ast_cdr_amaflags2int

(

const char *

flag

)

Convert a string to a detail record AMA flag

Parameters:

flag

string form of flag Converts the string form of the flag to the binary form. Returns the binary form of the flag

Definition at line 809 of file cdr.c.

References AST_CDR_BILLING, AST_CDR_DOCUMENTATION, and AST_CDR_OMIT.

Referenced by ast_cdr_setamaflags(), build_device(), build_gateway(), build_peer(), build_user(), set_config(), and setup_zap().

{
   if (!strcasecmp(flag, "default"))
      return 0;
   if (!strcasecmp(flag, "omit"))
      return AST_CDR_OMIT;
   if (!strcasecmp(flag, "billing"))
      return AST_CDR_BILLING;
   if (!strcasecmp(flag, "documentation"))
      return AST_CDR_DOCUMENTATION;
   return -1;
}

void ast_cdr_answer

(

struct ast_cdr *

cdr

)

Answer a call

Parameters:

cdr

the cdr you wish to associate with the call Starts all CDR stuff necessary for doing CDR when answering a call

Definition at line 483 of file cdr.c.

References ast_cdr::answer, AST_CDR_ANSWERED, AST_CDR_FLAG_POSTED, ast_log(), ast_strlen_zero(), ast_test_flag, ast_cdr::channel, ast_cdr::disposition, LOG_WARNING, and ast_cdr::next.

Referenced by ast_answer(), and ast_read().

{
   char *chan; 

   while (cdr) {
      chan = !ast_strlen_zero(cdr->channel) ? cdr->channel : "<unknown>";
      if (ast_test_flag(cdr, AST_CDR_FLAG_POSTED))
         ast_log(LOG_WARNING, "CDR on channel '%s' already posted\n", chan);
      if (cdr->disposition < AST_CDR_ANSWERED)
         cdr->disposition = AST_CDR_ANSWERED;
      if (ast_tvzero(cdr->answer))
         cdr->answer = ast_tvnow();
      cdr = cdr->next;
   }
}

struct ast_cdr* ast_cdr_append	(	struct ast_cdr *	cdr,
		struct ast_cdr *	newcdr
	)			[read]

Definition at line 891 of file cdr.c.

References ast_cdr::next.

Referenced by ast_cdr_fork(), and attempt_transfer().

{
   struct ast_cdr *ret;

   if (cdr) {
      ret = cdr;

      while (cdr->next)
         cdr = cdr->next;
      cdr->next = newcdr;
   } else {
      ret = newcdr;
   }

   return ret;
}

int ast_cdr_appenduserfield	(	struct ast_channel *	chan,
		const char *	userfield
	)

Definition at line 760 of file cdr.c.

References AST_CDR_FLAG_LOCKED, ast_test_flag, ast_channel::cdr, ast_cdr::next, and ast_cdr::userfield.

Referenced by action_setcdruserfield(), appendcdruserfield_exec(), and ast_bridge_call().

{
   struct ast_cdr *cdr = chan->cdr;

   while (cdr) {
      int len = strlen(cdr->userfield);

      if (!ast_test_flag(cdr, AST_CDR_FLAG_LOCKED))
         strncpy(cdr->userfield+len, userfield, sizeof(cdr->userfield) - len - 1);

      cdr = cdr->next;
   }

   return 0;
}

void ast_cdr_busy

(

struct ast_cdr *

cdr

)

Busy a call

Parameters:

cdr

the cdr you wish to associate with the call Returns nothing important

Definition at line 499 of file cdr.c.

References AST_CDR_BUSY, AST_CDR_FLAG_LOCKED, AST_CDR_FLAG_POSTED, ast_log(), ast_strlen_zero(), ast_test_flag, ast_cdr::channel, ast_cdr::disposition, LOG_WARNING, and ast_cdr::next.

Referenced by ast_cdr_disposition(), ring_entry(), and wait_for_answer().

{
   char *chan; 

   while (cdr) {
      if (!ast_test_flag(cdr, AST_CDR_FLAG_LOCKED)) {
         chan = !ast_strlen_zero(cdr->channel) ? cdr->channel : "<unknown>";
         if (ast_test_flag(cdr, AST_CDR_FLAG_POSTED))
            ast_log(LOG_WARNING, "CDR on channel '%s' already posted\n", chan);
         if (cdr->disposition < AST_CDR_BUSY)
            cdr->disposition = AST_CDR_BUSY;
      }
      cdr = cdr->next;
   }
}

int ast_cdr_copy_vars	(	struct ast_cdr *	to_cdr,
		struct ast_cdr *	from_cdr
	)

Definition at line 326 of file cdr.c.

References AST_LIST_INSERT_HEAD, AST_LIST_TRAVERSE, ast_strlen_zero(), ast_var_assign(), ast_var_name(), ast_var_value(), var, and ast_cdr::varshead.

Referenced by ast_cdr_dup().

{
   struct ast_var_t *variables, *newvariable = NULL;
   struct varshead *headpa, *headpb;
   char *var, *val;
   int x = 0;

   headpa = &from_cdr->varshead;
   headpb = &to_cdr->varshead;

   AST_LIST_TRAVERSE(headpa,variables,entries) {
      if (variables &&
          (var = ast_var_name(variables)) && (val = ast_var_value(variables)) &&
          !ast_strlen_zero(var) && !ast_strlen_zero(val)) {
         newvariable = ast_var_assign(var, val);
         AST_LIST_INSERT_HEAD(headpb, newvariable, entries);
         x++;
      }
   }

   return x;
}

void ast_cdr_detach

(

struct ast_cdr *

cdr

)

Detaches the detail record for posting (and freeing) either now or at a later time in bulk with other records during batch mode operation

Parameters:

cdr

Which CDR to detach from the channel thread Prevents the channel thread from blocking on the CDR handling Returns nothing

Definition at line 1006 of file cdr.c.

References AST_CDR_FLAG_POST_DISABLED, ast_cdr_free(), ast_log(), ast_mutex_lock(), ast_mutex_unlock(), ast_set_flag, batch, batchmode, batchsize, ast_cdr_batch_item::cdr, enabled, ast_cdr_batch::head, init_batch(), LOG_DEBUG, LOG_WARNING, malloc, ast_cdr_batch_item::next, option_debug, post_cdr(), ast_cdr_batch::size, submit_unscheduled_batch(), and ast_cdr_batch::tail.

Referenced by ast_cdr_reset(), ast_hangup(), and ast_pbx_outgoing_cdr_failed().

{
   struct ast_cdr_batch_item *newtail;
   int curr;

   /* maybe they disabled CDR stuff completely, so just drop it */
   if (!enabled) {
      if (option_debug)
         ast_log(LOG_DEBUG, "Dropping CDR !\n");
      ast_set_flag(cdr, AST_CDR_FLAG_POST_DISABLED);
      ast_cdr_free(cdr);
      return;
   }

   /* post stuff immediately if we are not in batch mode, this is legacy behaviour */
   if (!batchmode) {
      post_cdr(cdr);
      ast_cdr_free(cdr);
      return;
   }

   /* otherwise, each CDR gets put into a batch list (at the end) */
   if (option_debug)
      ast_log(LOG_DEBUG, "CDR detaching from this thread\n");

   /* we'll need a new tail for every CDR */
   newtail = malloc(sizeof(*newtail));
   if (!newtail) {
      ast_log(LOG_WARNING, "CDR: out of memory while trying to detach, will try in this thread instead\n");
      post_cdr(cdr);
      ast_cdr_free(cdr);
      return;
   }
   memset(newtail, 0, sizeof(*newtail));

   /* don't traverse a whole list (just keep track of the tail) */
   ast_mutex_lock(&cdr_batch_lock);
   if (!batch)
      init_batch();
   if (!batch->head) {
      /* new batch is empty, so point the head at the new tail */
      batch->head = newtail;
   } else {
      /* already got a batch with something in it, so just append a new tail */
      batch->tail->next = newtail;
   }
   newtail->cdr = cdr;
   batch->tail = newtail;
   curr = batch->size++;
   ast_mutex_unlock(&cdr_batch_lock);

   /* if we have enough stuff to post, then do it */
   if (curr >= (batchsize - 1))
      submit_unscheduled_batch();
}

char* ast_cdr_disp2str

(

int

disposition

)

Disposition to a string

Parameters:

disposition

input binary form Converts the binary form of a disposition to string form. Returns a pointer to the string form

Definition at line 687 of file cdr.c.

References AST_CDR_ANSWERED, AST_CDR_BUSY, AST_CDR_FAILED, AST_CDR_NOANSWER, and AST_CDR_NULL.

Referenced by ast_cdr_getvar(), build_csv_record(), csv_log(), manager_log(), odbc_log(), pgsql_log(), and tds_log().

{
   switch (disposition) {
   case AST_CDR_NULL:
      return "NO ANSWER"; /* by default, for backward compatibility */
   case AST_CDR_NOANSWER:
      return "NO ANSWER";
   case AST_CDR_FAILED:
      return "FAILED";     
   case AST_CDR_BUSY:
      return "BUSY";    
   case AST_CDR_ANSWERED:
      return "ANSWERED";
   }
   return "UNKNOWN";
}

int ast_cdr_disposition	(	struct ast_cdr *	cdr,
		int	cause
	)

Save the result of the call based on the AST_CAUSE_*

Parameters:

	cdr	the cdr you wish to associate with the call Returns nothing important
	cause	the AST_CAUSE_*

Definition at line 547 of file cdr.c.

References AST_CAUSE_BUSY, AST_CAUSE_FAILURE, AST_CAUSE_NORMAL, AST_CAUSE_NOTDEFINED, ast_cdr_busy(), ast_cdr_failed(), ast_log(), LOG_WARNING, and ast_cdr::next.

Referenced by __ast_request_and_dial(), ast_feature_request_and_dial(), ast_pbx_outgoing_app(), and ast_pbx_outgoing_exten().

{
   int res = 0;

   while (cdr) {
      switch(cause) {
      case AST_CAUSE_BUSY:
         ast_cdr_busy(cdr);
         break;
      case AST_CAUSE_FAILURE:
         ast_cdr_failed(cdr);
         break;
      case AST_CAUSE_NORMAL:
         break;
      case AST_CAUSE_NOTDEFINED:
         res = -1;
         break;
      default:
         res = -1;
         ast_log(LOG_WARNING, "Cause not handled\n");
      }
      cdr = cdr->next;
   }
   return res;
}

struct ast_cdr* ast_cdr_dup

(

struct ast_cdr *

cdr

)

[read]

Duplicate a record Returns a malloc'd ast_cdr structure, returns NULL on error (malloc failure).

Duplicate a CDR record

Returns:

Pointer to new CDR record

Definition at line 167 of file cdr.c.

References ast_cdr_alloc(), ast_cdr_copy_vars(), ast_log(), LOG_ERROR, ast_cdr::next, and ast_cdr::varshead.

Referenced by ast_cdr_fork(), and ast_cdr_reset().

{
   struct ast_cdr *newcdr;

   if (!(newcdr = ast_cdr_alloc())) {
      ast_log(LOG_ERROR, "Memory Error!\n");
      return NULL;
   }

   memcpy(newcdr, cdr, sizeof(*newcdr));
   /* The varshead is unusable, volatile even, after the memcpy so we take care of that here */
   memset(&newcdr->varshead, 0, sizeof(newcdr->varshead));
   ast_cdr_copy_vars(newcdr, cdr);
   newcdr->next = NULL;

   return newcdr;
}

void ast_cdr_end

(

struct ast_cdr *

cdr

)

End a call

Parameters:

cdr

the cdr you have associated the call with Registers the end of call time in the cdr structure. Returns nothing important

Definition at line 671 of file cdr.c.

References AST_CDR_FLAG_POSTED, ast_log(), ast_strlen_zero(), ast_test_flag, ast_cdr::channel, ast_cdr::end, LOG_WARNING, ast_cdr::next, and ast_cdr::start.

Referenced by __ast_request_and_dial(), ast_cdr_reset(), ast_feature_request_and_dial(), ast_hangup(), ast_pbx_outgoing_cdr_failed(), and ast_read().

{
   char *chan;

   while (cdr) {
      chan = !ast_strlen_zero(cdr->channel) ? cdr->channel : "<unknown>";
      if (ast_test_flag(cdr, AST_CDR_FLAG_POSTED))
         ast_log(LOG_WARNING, "CDR on channel '%s' already posted\n", chan);
      if (ast_tvzero(cdr->start))
         ast_log(LOG_WARNING, "CDR on channel '%s' has not started\n", chan);
      if (ast_tvzero(cdr->end))
         cdr->end = ast_tvnow();
      cdr = cdr->next;
   }
}

int ast_cdr_engine_init

(

void

)

Load the configuration file cdr.conf and possibly start the CDR scheduling thread

Definition at line 1261 of file cdr.c.

References ast_cli_register(), ast_log(), ast_mutex_lock(), ast_mutex_unlock(), cli_status, do_reload(), init_batch(), LOG_ERROR, and sched_context_create().

Referenced by main().

{
   int res;

   sched = sched_context_create();
   if (!sched) {
      ast_log(LOG_ERROR, "Unable to create schedule context.\n");
      return -1;
   }

   ast_cli_register(&cli_status);

   res = do_reload();
   if (res) {
      ast_mutex_lock(&cdr_batch_lock);
      res = init_batch();
      ast_mutex_unlock(&cdr_batch_lock);
   }

   return res;
}

void ast_cdr_engine_reload

(

void

)

Reload the configuration file cdr.conf and start/stop CDR scheduling thread

Definition at line 1290 of file cdr.c.

References do_reload().

Referenced by ast_module_reload().

{
   do_reload();
}

void ast_cdr_engine_term

(

void

)

Submit any remaining CDRs and prepare for shutdown

Definition at line 1285 of file cdr.c.

References ast_cdr_submit_batch(), and batchsafeshutdown.

Referenced by do_reload(), and quit_handler().

{
   ast_cdr_submit_batch(batchsafeshutdown);
}

void ast_cdr_failed

(

struct ast_cdr *

cdr

)

Fail a call

Parameters:

cdr

the cdr you wish to associate with the call Returns nothing important

Definition at line 515 of file cdr.c.

References AST_CDR_FAILED, AST_CDR_FLAG_LOCKED, AST_CDR_FLAG_POSTED, ast_log(), ast_strlen_zero(), ast_test_flag, ast_cdr::channel, ast_cdr::disposition, LOG_WARNING, and ast_cdr::next.

Referenced by __ast_request_and_dial(), ast_cdr_disposition(), ast_feature_request_and_dial(), ast_pbx_outgoing_app(), ast_pbx_outgoing_cdr_failed(), and ast_pbx_outgoing_exten().

{
   char *chan; 

   while (cdr) {
      chan = !ast_strlen_zero(cdr->channel) ? cdr->channel : "<unknown>";
      if (ast_test_flag(cdr, AST_CDR_FLAG_POSTED))
         ast_log(LOG_WARNING, "CDR on channel '%s' already posted\n", chan);
      if (!ast_test_flag(cdr, AST_CDR_FLAG_LOCKED)) {
         if (cdr->disposition < AST_CDR_FAILED)
            cdr->disposition = AST_CDR_FAILED;
      }
      cdr = cdr->next;
   }
}

char* ast_cdr_flags2str

(

int

flag

)

Flags to a string

Parameters:

flags

binary flag Converts binary flags to string flags Returns string with flag name

Converts AMA flag to printable string

Definition at line 705 of file cdr.c.

References AST_CDR_BILLING, AST_CDR_DOCUMENTATION, and AST_CDR_OMIT.

Referenced by _sip_show_peer(), ast_cdr_getvar(), build_csv_record(), csv_log(), manager_log(), sip_show_user(), and tds_log().

{
   switch(flag) {
   case AST_CDR_OMIT:
      return "OMIT";
   case AST_CDR_BILLING:
      return "BILLING";
   case AST_CDR_DOCUMENTATION:
      return "DOCUMENTATION";
   }
   return "Unknown";
}

void ast_cdr_free

(

struct ast_cdr *

cdr

)

Free a CDR record.

Parameters:

cdr

ast_cdr structure to free Returns nothing important

Definition at line 434 of file cdr.c.

References AST_CDR_FLAG_POST_DISABLED, AST_CDR_FLAG_POSTED, ast_cdr_free_vars(), ast_log(), ast_strlen_zero(), ast_test_flag, ast_cdr::channel, ast_cdr::end, free, LOG_NOTICE, ast_cdr::next, and ast_cdr::start.

Referenced by ast_cdr_detach(), do_batch_backend_process(), and nocdr_exec().

{
   char *chan;
   struct ast_cdr *next; 

   while (cdr) {
      next = cdr->next;
      chan = !ast_strlen_zero(cdr->channel) ? cdr->channel : "<unknown>";
      if (!ast_test_flag(cdr, AST_CDR_FLAG_POSTED) && !ast_test_flag(cdr, AST_CDR_FLAG_POST_DISABLED))
         ast_log(LOG_NOTICE, "CDR on channel '%s' not posted\n", chan);
      if (ast_tvzero(cdr->end))
         ast_log(LOG_NOTICE, "CDR on channel '%s' lacks end\n", chan);
      if (ast_tvzero(cdr->start))
         ast_log(LOG_NOTICE, "CDR on channel '%s' lacks start\n", chan);

      ast_cdr_free_vars(cdr, 0);
      free(cdr);
      cdr = next;
   }
}

void ast_cdr_free_vars	(	struct ast_cdr *	cdr,
		int	recur
	)

Definition at line 413 of file cdr.c.

References AST_LIST_EMPTY, AST_LIST_REMOVE_HEAD, ast_var_delete(), ast_cdr::next, and ast_cdr::varshead.

Referenced by ast_cdr_fork(), ast_cdr_free(), and ast_cdr_reset().

{
   struct varshead *headp;
   struct ast_var_t *vardata;

   /* clear variables */
   while (cdr) {
      headp = &cdr->varshead;
      while (!AST_LIST_EMPTY(headp)) {
         vardata = AST_LIST_REMOVE_HEAD(headp, entries);
         ast_var_delete(vardata);
      }

      if (!recur) {
         break;
      }

      cdr = cdr->next;
   }
}

void ast_cdr_getvar	(	struct ast_cdr *	cdr,
		const char *	name,
		char **	ret,
		char *	workspace,
		int	workspacelen,
		int	recur
	)

CDR channel variable retrieval

Definition at line 208 of file cdr.c.

References ast_cdr::accountcode, ast_cdr::amaflags, ast_cdr::answer, ast_cdr_disp2str(), ast_cdr_flags2str(), ast_cdr_getvar_internal(), ast_strlen_zero(), ast_cdr::billsec, ast_cdr::channel, ast_cdr::clid, ast_cdr::dcontext, ast_cdr::disposition, ast_cdr::dst, ast_cdr::dstchannel, ast_cdr::duration, ast_cdr::end, fmt, ast_cdr::lastapp, ast_cdr::lastdata, ast_cdr::src, ast_cdr::start, t, ast_cdr::uniqueid, and ast_cdr::userfield.

Referenced by ast_cdr_serialize_variables(), builtin_function_cdr_read(), and pickup_exec().

{
   struct tm tm;
   time_t t;
   const char *fmt = "%Y-%m-%d %T";
   const char *varbuf;

   *ret = NULL;
   /* special vars (the ones from the struct ast_cdr when requested by name) 
      I'd almost say we should convert all the stringed vals to vars */

   if (!strcasecmp(name, "clid"))
      ast_copy_string(workspace, cdr->clid, workspacelen);
   else if (!strcasecmp(name, "src"))
      ast_copy_string(workspace, cdr->src, workspacelen);
   else if (!strcasecmp(name, "dst"))
      ast_copy_string(workspace, cdr->dst, workspacelen);
   else if (!strcasecmp(name, "dcontext"))
      ast_copy_string(workspace, cdr->dcontext, workspacelen);
   else if (!strcasecmp(name, "channel"))
      ast_copy_string(workspace, cdr->channel, workspacelen);
   else if (!strcasecmp(name, "dstchannel"))
      ast_copy_string(workspace, cdr->dstchannel, workspacelen);
   else if (!strcasecmp(name, "lastapp"))
      ast_copy_string(workspace, cdr->lastapp, workspacelen);
   else if (!strcasecmp(name, "lastdata"))
      ast_copy_string(workspace, cdr->lastdata, workspacelen);
   else if (!strcasecmp(name, "start")) {
      t = cdr->start.tv_sec;
      if (t) {
         localtime_r(&t, &tm);
         strftime(workspace, workspacelen, fmt, &tm);
      }
   } else if (!strcasecmp(name, "answer")) {
      t = cdr->answer.tv_sec;
      if (t) {
         localtime_r(&t, &tm);
         strftime(workspace, workspacelen, fmt, &tm);
      }
   } else if (!strcasecmp(name, "end")) {
      t = cdr->end.tv_sec;
      if (t) {
         localtime_r(&t, &tm);
         strftime(workspace, workspacelen, fmt, &tm);
      }
   } else if (!strcasecmp(name, "duration"))
      snprintf(workspace, workspacelen, "%ld", cdr->duration);
   else if (!strcasecmp(name, "billsec"))
      snprintf(workspace, workspacelen, "%ld", cdr->billsec);
   else if (!strcasecmp(name, "disposition"))
      ast_copy_string(workspace, ast_cdr_disp2str(cdr->disposition), workspacelen);
   else if (!strcasecmp(name, "amaflags"))
      ast_copy_string(workspace, ast_cdr_flags2str(cdr->amaflags), workspacelen);
   else if (!strcasecmp(name, "accountcode"))
      ast_copy_string(workspace, cdr->accountcode, workspacelen);
   else if (!strcasecmp(name, "uniqueid"))
      ast_copy_string(workspace, cdr->uniqueid, workspacelen);
   else if (!strcasecmp(name, "userfield"))
      ast_copy_string(workspace, cdr->userfield, workspacelen);
   else if ((varbuf = ast_cdr_getvar_internal(cdr, name, recur)))
      ast_copy_string(workspace, varbuf, workspacelen);

   if (!ast_strlen_zero(workspace))
      *ret = workspace;
}

int ast_cdr_init	(	struct ast_cdr *	cdr,
		struct ast_channel *	chan
	)

Initialize based on a channel.

Parameters:

	cdr	Call Detail Record to use for channel
	chan	Channel to bind CDR with Initializes a CDR and associates it with a particular channel Return is negligible. (returns 0 by default)

Definition at line 633 of file cdr.c.

References ast_channel::_state, ast_channel::accountcode, ast_cdr::accountcode, ast_channel::amaflags, ast_cdr::amaflags, AST_CDR_ANSWERED, AST_CDR_FLAG_LOCKED, AST_CDR_NULL, ast_log(), AST_MAX_EXTENSION, AST_STATE_UP, ast_strlen_zero(), ast_test_flag, ast_cdr::channel, ast_channel::cid, ast_callerid::cid_ani, ast_callerid::cid_name, ast_callerid::cid_num, ast_cdr::clid, ast_channel::context, ast_cdr::dcontext, ast_cdr::disposition, ast_cdr::dst, ast_channel::exten, LOG_WARNING, ast_channel::name, ast_cdr::next, ast_cdr::src, ast_channel::uniqueid, and ast_cdr::uniqueid.

Referenced by __ast_pbx_run(), __ast_request_and_dial(), ast_feature_request_and_dial(), ast_pbx_outgoing_app(), ast_pbx_outgoing_cdr_failed(), and ast_pbx_outgoing_exten().

{
   char *chan;
   char *num;
   char tmp[AST_MAX_EXTENSION] = "";

   while (cdr) {
      if (!ast_test_flag(cdr, AST_CDR_FLAG_LOCKED)) {
         chan = !ast_strlen_zero(cdr->channel) ? cdr->channel : "<unknown>";
         if (!ast_strlen_zero(cdr->channel)) 
            ast_log(LOG_WARNING, "CDR already initialized on '%s'\n", chan); 
         ast_copy_string(cdr->channel, c->name, sizeof(cdr->channel));
         /* Grab source from ANI or normal Caller*ID */
         num = c->cid.cid_ani ? c->cid.cid_ani : c->cid.cid_num;
         
         if (c->cid.cid_name && num)
            snprintf(tmp, sizeof(tmp), "\"%s\" <%s>", c->cid.cid_name, num);
         else if (c->cid.cid_name)
            ast_copy_string(tmp, c->cid.cid_name, sizeof(tmp));
         else if (num)
            ast_copy_string(tmp, num, sizeof(tmp));
         ast_copy_string(cdr->clid, tmp, sizeof(cdr->clid));
         ast_copy_string(cdr->src, num ? num : "", sizeof(cdr->src));

         cdr->disposition = (c->_state == AST_STATE_UP) ?  AST_CDR_ANSWERED : AST_CDR_NULL;
         cdr->amaflags = c->amaflags ? c->amaflags :  ast_default_amaflags;
         ast_copy_string(cdr->accountcode, c->accountcode, sizeof(cdr->accountcode));
         /* Destination information */
         ast_copy_string(cdr->dst, c->exten, sizeof(cdr->dst));
         ast_copy_string(cdr->dcontext, c->context, sizeof(cdr->dcontext));
         /* Unique call identifier */
         ast_copy_string(cdr->uniqueid, c->uniqueid, sizeof(cdr->uniqueid));
      }
      cdr = cdr->next;
   }
   return 0;
}

void ast_cdr_noanswer

(

struct ast_cdr *

cdr

)

A call wasn't answered

Parameters:

cdr

the cdr you wish to associate with the call Marks the channel disposition as "NO ANSWER"

Definition at line 531 of file cdr.c.

References AST_CDR_FLAG_LOCKED, AST_CDR_FLAG_POSTED, AST_CDR_NOANSWER, ast_log(), ast_strlen_zero(), ast_test_flag, ast_cdr::channel, ast_cdr::disposition, LOG_WARNING, and ast_cdr::next.

Referenced by wait_for_answer().

{
   char *chan; 

   while (cdr) {
      chan = !ast_strlen_zero(cdr->channel) ? cdr->channel : "<unknown>";
      if (ast_test_flag(cdr, AST_CDR_FLAG_POSTED))
         ast_log(LOG_WARNING, "CDR on channel '%s' already posted\n", chan);
      if (!ast_test_flag(cdr, AST_CDR_FLAG_LOCKED)) {
         if (cdr->disposition < AST_CDR_NOANSWER)
            cdr->disposition = AST_CDR_NOANSWER;
      }
      cdr = cdr->next;
   }
}

int ast_cdr_register	(	char *	name,
		char *	desc,
		ast_cdrbe	be
	)

Register a CDR handling engine

Parameters:

	name	name associated with the particular CDR handler
	desc	description of the CDR handler
	be	function pointer to a CDR handler Used to register a Call Detail Record handler. Returns -1 on error, 0 on success.

Register a CDR driver. Each registered CDR driver generates a CDR

Returns:

0 on success, -1 on failure

Definition at line 106 of file cdr.c.

References AST_LIST_INSERT_HEAD, AST_LIST_LOCK, AST_LIST_TRAVERSE, AST_LIST_UNLOCK, ast_log(), ast_cdr_beitem::be, ast_cdr_beitem::desc, list, LOG_WARNING, malloc, and ast_cdr_beitem::name.

Referenced by load_module(), odbc_load_module(), process_my_load_module(), and tds_load_module().

{
   struct ast_cdr_beitem *i;

   if (!name)
      return -1;
   if (!be) {
      ast_log(LOG_WARNING, "CDR engine '%s' lacks backend\n", name);
      return -1;
   }

   AST_LIST_LOCK(&be_list);
   AST_LIST_TRAVERSE(&be_list, i, list) {
      if (!strcasecmp(name, i->name))
         break;
   }
   AST_LIST_UNLOCK(&be_list);

   if (i) {
      ast_log(LOG_WARNING, "Already have a CDR backend called '%s'\n", name);
      return -1;
   }

   i = malloc(sizeof(*i));
   if (!i)  
      return -1;

   memset(i, 0, sizeof(*i));
   i->be = be;
   ast_copy_string(i->name, name, sizeof(i->name));
   ast_copy_string(i->desc, desc, sizeof(i->desc));

   AST_LIST_LOCK(&be_list);
   AST_LIST_INSERT_HEAD(&be_list, i, list);
   AST_LIST_UNLOCK(&be_list);

   return 0;
}

void ast_cdr_reset	(	struct ast_cdr *	cdr,
		struct ast_flags *	flags
	)

Reset the detail record, optionally posting it first

Parameters:

	cdr	which cdr to act upon
	flags	|AST_CDR_FLAG_POSTED whether or not to post the cdr first before resetting it |AST_CDR_FLAG_LOCKED whether or not to reset locked CDR's

Definition at line 852 of file cdr.c.

References ast_cdr::answer, ast_cdr_detach(), ast_cdr_dup(), ast_cdr_end(), AST_CDR_FLAG_KEEP_VARS, AST_CDR_FLAG_LOCKED, AST_CDR_FLAG_POSTED, ast_cdr_free_vars(), AST_CDR_NULL, ast_cdr_start(), ast_clear_flag, ast_copy_flags, AST_FLAGS_ALL, ast_set_flag, ast_test_flag, ast_cdr::billsec, ast_cdr::disposition, ast_cdr::duration, ast_cdr::end, ast_cdr::next, and ast_cdr::start.

Referenced by ast_bridge_call_thread(), ast_cdr_fork(), dial_exec_full(), disa_exec(), and pbx_builtin_resetcdr().

{
   struct ast_cdr *dup;
   struct ast_flags flags = { 0 };

   if (_flags)
      ast_copy_flags(&flags, _flags, AST_FLAGS_ALL);

   while (cdr) {
      /* Detach if post is requested */
      if (ast_test_flag(&flags, AST_CDR_FLAG_LOCKED) || !ast_test_flag(cdr, AST_CDR_FLAG_LOCKED)) {
         if (ast_test_flag(&flags, AST_CDR_FLAG_POSTED)) {
            ast_cdr_end(cdr);
            if ((dup = ast_cdr_dup(cdr))) {
               ast_cdr_detach(dup);
            }
            ast_set_flag(cdr, AST_CDR_FLAG_POSTED);
         }

         /* clear variables */
         if (!ast_test_flag(&flags, AST_CDR_FLAG_KEEP_VARS)) {
            ast_cdr_free_vars(cdr, 0);
         }

         /* Reset to initial state */
         ast_clear_flag(cdr, AST_FLAGS_ALL); 
         memset(&cdr->start, 0, sizeof(cdr->start));
         memset(&cdr->end, 0, sizeof(cdr->end));
         memset(&cdr->answer, 0, sizeof(cdr->answer));
         cdr->billsec = 0;
         cdr->duration = 0;
         ast_cdr_start(cdr);
         cdr->disposition = AST_CDR_NULL;
      }
         
      cdr = cdr->next;
   }
}

int ast_cdr_serialize_variables	(	struct ast_cdr *	cdr,
		char *	buf,
		size_t	size,
		char	delim,
		char	sep,
		int	recur
	)

Definition at line 349 of file cdr.c.

References ast_build_string(), ast_cdr_getvar(), AST_LIST_TRAVERSE, ast_log(), ast_strlen_zero(), ast_var_name(), ast_var_value(), LOG_ERROR, ast_cdr::next, total, var, and ast_cdr::varshead.

Referenced by handle_showchan().

{
   struct ast_var_t *variables;
   char *var, *val;
   char *tmp;
   char workspace[256];
   int total = 0, x = 0, i;
   const char *cdrcols[] = { 
      "clid",
      "src",
      "dst",
      "dcontext",
      "channel",
      "dstchannel",
      "lastapp",
      "lastdata",
      "start",
      "answer",
      "end",
      "duration",
      "billsec",
      "disposition",
      "amaflags",
      "accountcode",
      "uniqueid",
      "userfield"
   };

   memset(buf, 0, size);

   for (; cdr; cdr = recur ? cdr->next : NULL) {
      if (++x > 1)
         ast_build_string(&buf, &size, "\n");

      AST_LIST_TRAVERSE(&cdr->varshead, variables, entries) {
         if (variables &&
             (var = ast_var_name(variables)) && (val = ast_var_value(variables)) &&
             !ast_strlen_zero(var) && !ast_strlen_zero(val)) {
            if (ast_build_string(&buf, &size, "level %d: %s%c%s%c", x, var, delim, val, sep)) {
               ast_log(LOG_ERROR, "Data Buffer Size Exceeded!\n");
               break;
            } else
               total++;
         } else 
            break;
      }

      for (i = 0; i < (sizeof(cdrcols) / sizeof(cdrcols[0])); i++) {
         ast_cdr_getvar(cdr, cdrcols[i], &tmp, workspace, sizeof(workspace), 0);
         if (!tmp)
            continue;
         
         if (ast_build_string(&buf, &size, "level %d: %s%c%s%c", x, cdrcols[i], delim, tmp, sep)) {
            ast_log(LOG_ERROR, "Data Buffer Size Exceeded!\n");
            break;
         } else
            total++;
      }
   }

   return total;
}

int ast_cdr_setaccount	(	struct ast_channel *	chan,
		const char *	account
	)

Definition at line 718 of file cdr.c.

References ast_cdr::accountcode, ast_channel::accountcode, AST_CDR_FLAG_LOCKED, ast_test_flag, ast_channel::cdr, and ast_cdr::next.

Referenced by __ast_request_and_dial(), ast_pbx_outgoing_app(), ast_pbx_outgoing_exten(), auth_exec(), builtin_function_cdr_write(), and pbx_builtin_setaccount().

{
   struct ast_cdr *cdr = chan->cdr;

   ast_copy_string(chan->accountcode, account, sizeof(chan->accountcode));
   while (cdr) {
      if (!ast_test_flag(cdr, AST_CDR_FLAG_LOCKED))
         ast_copy_string(cdr->accountcode, chan->accountcode, sizeof(cdr->accountcode));
      cdr = cdr->next;
   }
   return 0;
}

int ast_cdr_setamaflags	(	struct ast_channel *	chan,
		const char *	amaflags
	)

Definition at line 731 of file cdr.c.

References ast_cdr::amaflags, ast_cdr_amaflags2int(), AST_CDR_FLAG_LOCKED, ast_test_flag, ast_channel::cdr, and ast_cdr::next.

Referenced by pbx_builtin_setamaflags().

{
   struct ast_cdr *cdr;
   int newflag;

   newflag = ast_cdr_amaflags2int(flag);
   if (newflag) {
      for (cdr = chan->cdr; cdr; cdr = cdr->next) {
         if (!ast_test_flag(cdr, AST_CDR_FLAG_LOCKED))
            cdr->amaflags = newflag;
      }
   }

   return 0;
}

void ast_cdr_setapp	(	struct ast_cdr *	cdr,
		char *	app,
		char *	data
	)

Set the last executed application

Parameters:

	cdr	which cdr to act upon
	app	the name of the app you wish to change it to
	data	the data you want in the data field of app you set it to Changes the value of the last executed app Returns nothing

Definition at line 587 of file cdr.c.

References AST_CDR_FLAG_LOCKED, AST_CDR_FLAG_POSTED, ast_log(), ast_strlen_zero(), ast_test_flag, ast_cdr::channel, ast_cdr::lastapp, ast_cdr::lastdata, LOG_WARNING, and ast_cdr::next.

Referenced by __ast_request_and_dial(), ast_feature_request_and_dial(), and pbx_exec().

{
   char *chan; 

   while (cdr) {
      if (!ast_test_flag(cdr, AST_CDR_FLAG_LOCKED)) {
         chan = !ast_strlen_zero(cdr->channel) ? cdr->channel : "<unknown>";
         if (ast_test_flag(cdr, AST_CDR_FLAG_POSTED))
            ast_log(LOG_WARNING, "CDR on channel '%s' already posted\n", chan);
         if (!app)
            app = "";
         ast_copy_string(cdr->lastapp, app, sizeof(cdr->lastapp));
         if (!data)
            data = "";
         ast_copy_string(cdr->lastdata, data, sizeof(cdr->lastdata));
      }
      cdr = cdr->next;
   }
}

int ast_cdr_setcid	(	struct ast_cdr *	cdr,
		struct ast_channel *	chan
	)

Initialize based on a channel

Parameters:

	cdr	Call Detail Record to use for channel
	chan	Channel to bind CDR with Initializes a CDR and associates it with a particular channel Return is negligible. (returns 0 by default)

Definition at line 607 of file cdr.c.

References AST_CDR_FLAG_LOCKED, AST_MAX_EXTENSION, ast_test_flag, ast_channel::cid, ast_callerid::cid_ani, ast_callerid::cid_name, ast_callerid::cid_num, ast_cdr::clid, ast_cdr::next, and ast_cdr::src.

Referenced by ast_set_callerid().

{
   char tmp[AST_MAX_EXTENSION] = "";
   char *num;

   while (cdr) {
      if (!ast_test_flag(cdr, AST_CDR_FLAG_LOCKED)) {
         /* Grab source from ANI or normal Caller*ID */
         num = c->cid.cid_ani ? c->cid.cid_ani : c->cid.cid_num;
         
         if (c->cid.cid_name && num)
            snprintf(tmp, sizeof(tmp), "\"%s\" <%s>", c->cid.cid_name, num);
         else if (c->cid.cid_name)
            ast_copy_string(tmp, c->cid.cid_name, sizeof(tmp));
         else if (num)
            ast_copy_string(tmp, num, sizeof(tmp));
         ast_copy_string(cdr->clid, tmp, sizeof(cdr->clid));
         ast_copy_string(cdr->src, num ? num : "", sizeof(cdr->src));
      }
      cdr = cdr->next;
   }

   return 0;
}

void ast_cdr_setdestchan	(	struct ast_cdr *	cdr,
		char *	chan
	)

Set the destination channel, if there was one

Parameters:

	cdr	Which cdr it's applied to
	chan	Channel to which dest will be Sets the destination channel the CDR is applied to Returns nothing

Definition at line 573 of file cdr.c.

References AST_CDR_FLAG_LOCKED, AST_CDR_FLAG_POSTED, ast_log(), ast_strlen_zero(), ast_test_flag, ast_cdr::channel, ast_cdr::dstchannel, LOG_WARNING, and ast_cdr::next.

Referenced by ast_bridge_call_thread(), dial_exec_full(), and try_calling().

{
   char *chan; 

   while (cdr) {
      chan = !ast_strlen_zero(cdr->channel) ? cdr->channel : "<unknown>";
      if (ast_test_flag(cdr, AST_CDR_FLAG_POSTED))
         ast_log(LOG_WARNING, "CDR on channel '%s' already posted\n", chan);
      if (!ast_test_flag(cdr, AST_CDR_FLAG_LOCKED))
         ast_copy_string(cdr->dstchannel, chann, sizeof(cdr->dstchannel));
      cdr = cdr->next;
   }
}

int ast_cdr_setuserfield	(	struct ast_channel *	chan,
		const char *	userfield
	)

Definition at line 747 of file cdr.c.

References AST_CDR_FLAG_LOCKED, ast_test_flag, ast_channel::cdr, ast_cdr::next, and ast_cdr::userfield.

Referenced by __agent_start_monitoring(), action_setcdruserfield(), ast_bridge_call(), builtin_function_cdr_write(), handle_request_info(), setcdruserfield_exec(), and start_monitor_exec().

{
   struct ast_cdr *cdr = chan->cdr;

   while (cdr) {
      if (!ast_test_flag(cdr, AST_CDR_FLAG_LOCKED)) 
         ast_copy_string(cdr->userfield, userfield, sizeof(cdr->userfield));
      cdr = cdr->next;
   }

   return 0;
}

int ast_cdr_setvar	(	struct ast_cdr *	cdr,
		const char *	name,
		const char *	value,
		int	recur
	)

Set a CDR channel variable

Note:

You can't set the CDR variables that belong to the actual CDR record, like "billsec".

Definition at line 277 of file cdr.c.

References AST_LIST_INSERT_HEAD, AST_LIST_REMOVE_CURRENT, AST_LIST_TRAVERSE_SAFE_BEGIN, AST_LIST_TRAVERSE_SAFE_END, ast_log(), ast_var_assign(), ast_var_delete(), ast_var_name(), LOG_ERROR, ast_cdr::next, and ast_cdr::varshead.

Referenced by builtin_function_cdr_write().

{
   struct ast_var_t *newvariable;
   struct varshead *headp;
   const char *read_only[] = { "clid", "src", "dst", "dcontext", "channel", "dstchannel",
                "lastapp", "lastdata", "start", "answer", "end", "duration",
                "billsec", "disposition", "amaflags", "accountcode", "uniqueid",
                "userfield", NULL };
   int x;
   
   for(x = 0; read_only[x]; x++) {
      if (!strcasecmp(name, read_only[x])) {
         ast_log(LOG_ERROR, "Attempt to set a read-only variable!.\n");
         return -1;
      }
   }

   if (!cdr) {
      ast_log(LOG_ERROR, "Attempt to set a variable on a nonexistent CDR record.\n");
      return -1;
   }

   while (cdr) {
      headp = &cdr->varshead;
      AST_LIST_TRAVERSE_SAFE_BEGIN(headp, newvariable, entries) {
         if (!strcasecmp(ast_var_name(newvariable), name)) {
            /* there is already such a variable, delete it */
            AST_LIST_REMOVE_CURRENT(headp, entries);
            ast_var_delete(newvariable);
            break;
         }
      }
      AST_LIST_TRAVERSE_SAFE_END;

      if (value) {
         newvariable = ast_var_assign(name, value);
         AST_LIST_INSERT_HEAD(headp, newvariable, entries);
      }

      if (!recur) {
         break;
      }

      cdr = cdr->next;
   }

   return 0;
}

void ast_cdr_start

(

struct ast_cdr *

cdr

)

Start a call

Parameters:

cdr

the cdr you wish to associate with the call Starts all CDR stuff necessary for monitoring a call Returns nothing important

Definition at line 466 of file cdr.c.

References AST_CDR_FLAG_LOCKED, AST_CDR_FLAG_POSTED, ast_log(), ast_strlen_zero(), ast_test_flag, ast_cdr::channel, LOG_WARNING, ast_cdr::next, and ast_cdr::start.

Referenced by __ast_pbx_run(), __ast_request_and_dial(), ast_cdr_reset(), ast_feature_request_and_dial(), ast_pbx_outgoing_app(), ast_pbx_outgoing_cdr_failed(), and ast_pbx_outgoing_exten().

{
   char *chan; 

   while (cdr) {
      if (!ast_test_flag(cdr, AST_CDR_FLAG_LOCKED)) {
         chan = !ast_strlen_zero(cdr->channel) ? cdr->channel : "<unknown>";
         if (ast_test_flag(cdr, AST_CDR_FLAG_POSTED))
            ast_log(LOG_WARNING, "CDR on channel '%s' already posted\n", chan);
         if (!ast_tvzero(cdr->start))
            ast_log(LOG_WARNING, "CDR on channel '%s' already started\n", chan);
         cdr->start = ast_tvnow();
      }
      cdr = cdr->next;
   }
}

void ast_cdr_submit_batch

(

int

shutdown

)

Spawns (possibly) a new thread to submit a batch of CDRs to the backend engines

Parameters:

shutdown

Whether or not we are shutting down Blocks the asterisk shutdown procedures until the CDR data is submitted. Returns nothing

Definition at line 948 of file cdr.c.

References ast_log(), ast_mutex_lock(), ast_mutex_unlock(), ast_pthread_create, AST_PTHREADT_NULL, batch, batchscheduleronly, do_batch_backend_process(), ast_cdr_batch::head, LOG_DEBUG, LOG_WARNING, option_debug, and reset_batch().

Referenced by ast_cdr_engine_term(), and submit_scheduled_batch().

{
   struct ast_cdr_batch_item *oldbatchitems = NULL;
   pthread_attr_t attr;
   pthread_t batch_post_thread = AST_PTHREADT_NULL;

   /* if there's no batch, or no CDRs in the batch, then there's nothing to do */
   if (!batch || !batch->head)
      return;

   /* move the old CDRs aside, and prepare a new CDR batch */
   ast_mutex_lock(&cdr_batch_lock);
   oldbatchitems = batch->head;
   reset_batch();
   ast_mutex_unlock(&cdr_batch_lock);

   /* if configured, spawn a new thread to post these CDRs,
      also try to save as much as possible if we are shutting down safely */
   if (batchscheduleronly || shutdown) {
      if (option_debug)
         ast_log(LOG_DEBUG, "CDR single-threaded batch processing begins now\n");
      do_batch_backend_process(oldbatchitems);
   } else {
      pthread_attr_init(&attr);
      pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);
      if (ast_pthread_create(&batch_post_thread, &attr, do_batch_backend_process, oldbatchitems)) {
         ast_log(LOG_WARNING, "CDR processing thread could not detach, now trying in this thread\n");
         do_batch_backend_process(oldbatchitems);
      } else {
         if (option_debug)
            ast_log(LOG_DEBUG, "CDR multi-threaded batch processing begins now\n");
      }
      pthread_attr_destroy(&attr);
   }
}

void ast_cdr_unregister

(

char *

name

)

Unregister a CDR handling engine

Parameters:

name

name of CDR handler to unregister Unregisters a CDR by it's name

unregister a CDR driver

Definition at line 146 of file cdr.c.

References AST_LIST_LOCK, AST_LIST_REMOVE_CURRENT, AST_LIST_TRAVERSE_SAFE_BEGIN, AST_LIST_TRAVERSE_SAFE_END, AST_LIST_UNLOCK, ast_verbose(), free, list, ast_cdr_beitem::name, option_verbose, and VERBOSE_PREFIX_2.

Referenced by my_unload_module(), odbc_unload_module(), tds_unload_module(), and unload_module().

{
   struct ast_cdr_beitem *i = NULL;

   AST_LIST_LOCK(&be_list);
   AST_LIST_TRAVERSE_SAFE_BEGIN(&be_list, i, list) {
      if (!strcasecmp(name, i->name)) {
         AST_LIST_REMOVE_CURRENT(&be_list, list);
         if (option_verbose > 1)
            ast_verbose(VERBOSE_PREFIX_2 "Unregistered '%s' CDR backend\n", name);
         free(i);
         break;
      }
   }
   AST_LIST_TRAVERSE_SAFE_END;
   AST_LIST_UNLOCK(&be_list);
}

int ast_cdr_update

(

struct ast_channel *

chan

)

Definition at line 776 of file cdr.c.

References ast_channel::accountcode, ast_cdr::accountcode, AST_CDR_FLAG_LOCKED, ast_check_hangup(), AST_MAX_EXTENSION, ast_strlen_zero(), ast_test_flag, ast_channel::cdr, ast_channel::cid, ast_callerid::cid_ani, ast_callerid::cid_name, ast_callerid::cid_num, ast_cdr::clid, ast_channel::context, ast_cdr::dcontext, ast_cdr::dst, ast_channel::exten, ast_channel::macrocontext, ast_channel::macroexten, ast_cdr::next, and ast_cdr::src.

Referenced by __ast_pbx_run(), __ast_request_and_dial(), ast_feature_request_and_dial(), ast_parseable_goto(), and cb_events().

{
   struct ast_cdr *cdr = c->cdr;
   char *num;
   char tmp[AST_MAX_EXTENSION] = "";

   while (cdr) {
      if (!ast_test_flag(cdr, AST_CDR_FLAG_LOCKED)) {
         num = c->cid.cid_ani ? c->cid.cid_ani : c->cid.cid_num;
         
         if (c->cid.cid_name && num)
            snprintf(tmp, sizeof(tmp), "\"%s\" <%s>", c->cid.cid_name, num);
         else if (c->cid.cid_name)
            ast_copy_string(tmp, c->cid.cid_name, sizeof(tmp));
         else if (num)
            ast_copy_string(tmp, num, sizeof(tmp));
         ast_copy_string(cdr->clid, tmp, sizeof(cdr->clid));
         ast_copy_string(cdr->src, num ? num : "", sizeof(cdr->src));

         /* Copy account code et-al */ 
         ast_copy_string(cdr->accountcode, c->accountcode, sizeof(cdr->accountcode));
         if (!ast_check_hangup(c)) {
            /* Destination information */ /* XXX privilege macro* ? */
            ast_copy_string(cdr->dst, (ast_strlen_zero(c->macroexten)) ? c->exten : c->macroexten, sizeof(cdr->dst));
            ast_copy_string(cdr->dcontext, (ast_strlen_zero(c->macrocontext)) ? c->context : c->macrocontext, sizeof(cdr->dcontext));
         }
      }
      cdr = cdr->next;
   }

   return 0;
}

---

Variable Documentation

char ast_default_accountcode[AST_MAX_ACCOUNT_CODE]

Definition at line 58 of file cdr.c.

Referenced by ast_channel_alloc().

int ast_default_amaflags

Default AMA flag for billing records (CDR's)

Definition at line 57 of file cdr.c.

Referenced by ast_channel_alloc().