2 * Asterisk -- A telephony toolkit for Linux.
4 * Call Detail Record API
6 * Copyright (C) 1999, Mark Spencer
8 * Mark Spencer <markster@linux-support.net>
10 * This program is free software, distributed under the terms of
11 * the GNU General Public License.
13 * Includes code and algorithms from the Zapata library.
17 #include <asterisk/lock.h>
18 #include <asterisk/channel.h>
19 #include <asterisk/cdr.h>
20 #include <asterisk/logger.h>
21 #include <asterisk/callerid.h>
22 #include <asterisk/causes.h>
28 int ast_default_amaflags = AST_CDR_DOCUMENTATION;
29 char ast_default_accountcode[20] = "";
31 static ast_mutex_t cdrlock = AST_MUTEX_INITIALIZER;
33 static struct ast_cdr_beitem {
37 struct ast_cdr_beitem *next;
41 * We do a lot of checking here in the CDR code to try to be sure we don't ever let a CDR slip
42 * through our fingers somehow. If someone allocates a CDR, it must be completely handled normally
43 * or a WARNING shall be logged, so that we can best keep track of any escape condition where the CDR
44 * isn't properly generated and posted.
47 int ast_cdr_register(char *name, char *desc, ast_cdrbe be)
49 struct ast_cdr_beitem *i;
53 ast_log(LOG_WARNING, "CDR engine '%s' lacks backend\n", name);
56 ast_mutex_lock(&cdrlock);
59 if (!strcasecmp(name, i->name))
63 ast_mutex_unlock(&cdrlock);
65 ast_log(LOG_WARNING, "Already have a CDR backend called '%s'\n", name);
68 i = malloc(sizeof(struct ast_cdr_beitem));
71 memset(i, 0, sizeof(struct ast_cdr_beitem));
72 strncpy(i->name, name, sizeof(i->name) - 1);
73 strncpy(i->desc, desc, sizeof(i->desc) - 1);
75 ast_mutex_lock(&cdrlock);
78 ast_mutex_unlock(&cdrlock);
82 void ast_cdr_unregister(char *name)
84 struct ast_cdr_beitem *i, *prev = NULL;
85 ast_mutex_lock(&cdrlock);
88 if (!strcasecmp(name, i->name)) {
97 ast_mutex_unlock(&cdrlock);
102 void ast_cdr_free(struct ast_cdr *cdr)
106 chan = strlen(cdr->channel) ? cdr->channel : "<unknown>";
108 ast_log(LOG_WARNING, "CDR on channel '%s' not posted\n", chan);
109 if (!cdr->end.tv_sec && !cdr->end.tv_usec)
110 ast_log(LOG_WARNING, "CDR on channel '%s' lacks end\n", chan);
111 if (!cdr->start.tv_sec && !cdr->start.tv_usec)
112 ast_log(LOG_WARNING, "CDR on channel '%s' lacks start\n", chan);
117 struct ast_cdr *ast_cdr_alloc(void)
120 cdr = malloc(sizeof(struct ast_cdr));
122 memset(cdr, 0, sizeof(struct ast_cdr));
127 void ast_cdr_start(struct ast_cdr *cdr)
131 chan = strlen(cdr->channel) ? cdr->channel : "<unknown>";
133 ast_log(LOG_WARNING, "CDR on channel '%s' already posted\n", chan);
134 if (cdr->start.tv_sec || cdr->start.tv_usec)
135 ast_log(LOG_WARNING, "CDR on channel '%s' already started\n", chan);
136 gettimeofday(&cdr->start, NULL);
140 void ast_cdr_answer(struct ast_cdr *cdr)
144 chan = strlen(cdr->channel) ? cdr->channel : "<unknown>";
146 ast_log(LOG_WARNING, "CDR on channel '%s' already posted\n", chan);
147 if (cdr->disposition < AST_CDR_ANSWERED)
148 cdr->disposition = AST_CDR_ANSWERED;
149 if (!cdr->answer.tv_sec && !cdr->answer.tv_usec) {
150 gettimeofday(&cdr->answer, NULL);
155 void ast_cdr_busy(struct ast_cdr *cdr)
159 chan = strlen(cdr->channel) ? cdr->channel : "<unknown>";
161 ast_log(LOG_WARNING, "CDR on channel '%s' already posted\n", chan);
162 if (cdr->disposition < AST_CDR_BUSY)
163 cdr->disposition = AST_CDR_BUSY;
167 void ast_cdr_failed(struct ast_cdr *cdr)
171 chan = strlen(cdr->channel) ? cdr->channel : "<unknown>";
173 ast_log(LOG_WARNING, "CDR on channel '%s' already posted\n", chan);
174 cdr->disposition = AST_CDR_FAILED;
178 int ast_cdr_disposition(struct ast_cdr *cdr, int cause)
186 case AST_CAUSE_FAILURE:
189 case AST_CAUSE_NORMAL:
191 case AST_CAUSE_NOTDEFINED:
196 ast_log(LOG_WARNING, "We don't handle that cause yet\n");
202 void ast_cdr_setdestchan(struct ast_cdr *cdr, char *chann)
206 chan = strlen(cdr->channel) ? cdr->channel : "<unknown>";
208 ast_log(LOG_WARNING, "CDR on channel '%s' already posted\n", chan);
209 strncpy(cdr->dstchannel, chann, sizeof(cdr->dstchannel) - 1);
213 void ast_cdr_setapp(struct ast_cdr *cdr, char *app, char *data)
217 chan = strlen(cdr->channel) ? cdr->channel : "<unknown>";
219 ast_log(LOG_WARNING, "CDR on channel '%s' already posted\n", chan);
222 strncpy(cdr->lastapp, app, sizeof(cdr->lastapp) - 1);
225 strncpy(cdr->lastdata, data, sizeof(cdr->lastdata) - 1);
229 int ast_cdr_setcid(struct ast_cdr *cdr, struct ast_channel *c)
231 char tmp[AST_MAX_EXTENSION] = "";
234 /* Grab source from ANI or normal Caller*ID */
236 strncpy(tmp, c->ani, sizeof(tmp) - 1);
237 else if (c->callerid)
238 strncpy(tmp, c->callerid, sizeof(tmp) - 1);
240 strncpy(cdr->clid, c->callerid, sizeof(cdr->clid) - 1);
243 ast_callerid_parse(tmp, &name, &num);
245 ast_shrink_phone_number(num);
246 strncpy(cdr->src, num, sizeof(cdr->src) - 1);
252 int ast_cdr_init(struct ast_cdr *cdr, struct ast_channel *c)
256 char tmp[AST_MAX_EXTENSION] = "";
258 chan = strlen(cdr->channel) ? cdr->channel : "<unknown>";
259 if (strlen(cdr->channel))
260 ast_log(LOG_WARNING, "CDR already initialized on '%s'\n", chan);
261 strncpy(cdr->channel, c->name, sizeof(cdr->channel) - 1);
262 /* Grab source from ANI or normal Caller*ID */
264 strncpy(tmp, c->ani, sizeof(tmp) - 1);
265 else if (c->callerid)
266 strncpy(tmp, c->callerid, sizeof(tmp) - 1);
268 strncpy(cdr->clid, c->callerid, sizeof(cdr->clid) - 1);
271 ast_callerid_parse(tmp, &name, &num);
273 ast_shrink_phone_number(num);
274 strncpy(cdr->src, num, sizeof(cdr->src) - 1);
277 if (c->_state == AST_STATE_UP)
278 cdr->disposition = AST_CDR_ANSWERED;
280 cdr->disposition = AST_CDR_NOANSWER;
282 cdr->amaflags = c->amaflags;
284 cdr->amaflags = ast_default_amaflags;
285 strncpy(cdr->accountcode, c->accountcode, sizeof(cdr->accountcode) - 1);
286 /* Destination information */
287 strncpy(cdr->dst, c->exten, sizeof(cdr->dst) - 1);
288 strncpy(cdr->dcontext, c->context, sizeof(cdr->dcontext) - 1);
289 /* Unique call identifier */
290 strncpy(cdr->uniqueid, c->uniqueid, sizeof(cdr->uniqueid) - 1);
295 void ast_cdr_end(struct ast_cdr *cdr)
299 chan = strlen(cdr->channel) ? cdr->channel : "<unknown>";
301 ast_log(LOG_WARNING, "CDR on channel '%s' already posted\n", chan);
302 if (!cdr->start.tv_sec && !cdr->start.tv_usec)
303 ast_log(LOG_WARNING, "CDR on channel '%s' has not started\n", chan);
304 if (!cdr->end.tv_sec && !cdr->end.tv_usec)
305 gettimeofday(&cdr->end, NULL);
309 char *ast_cdr_disp2str(int disposition)
311 switch (disposition) {
312 case AST_CDR_NOANSWER:
318 case AST_CDR_ANSWERED:
325 char *ast_cdr_flags2str(int flag)
330 case AST_CDR_BILLING:
332 case AST_CDR_DOCUMENTATION:
333 return "DOCUMENTATION";
338 int ast_cdr_setaccount(struct ast_channel *chan, char *account)
340 struct ast_cdr *cdr = chan->cdr;
342 strncpy(chan->accountcode, account, sizeof(chan->accountcode) - 1);
344 strncpy(cdr->accountcode, chan->accountcode, sizeof(cdr->accountcode) - 1);
348 int ast_cdr_setuserfield(struct ast_channel *chan, char *userfield)
350 struct ast_cdr *cdr = chan->cdr;
353 strncpy(cdr->userfield, userfield, sizeof(cdr->userfield) - 1);
357 int ast_cdr_appenduserfield(struct ast_channel *chan, char *userfield)
359 struct ast_cdr *cdr = chan->cdr;
363 int len = strlen(cdr->userfield);
364 strncpy(cdr->userfield+len, userfield, sizeof(cdr->userfield) - len - 1);
369 int ast_cdr_update(struct ast_channel *c)
371 struct ast_cdr *cdr = c->cdr;
373 char tmp[AST_MAX_EXTENSION] = "";
374 /* Grab source from ANI or normal Caller*ID */
377 strncpy(tmp, c->ani, sizeof(tmp) - 1);
378 else if (c->callerid && strlen(c->callerid))
379 strncpy(tmp, c->callerid, sizeof(tmp) - 1);
380 if (c->callerid && strlen(c->callerid))
381 strncpy(cdr->clid, c->callerid, sizeof(cdr->clid) - 1);
383 strcpy(cdr->clid, "");
386 ast_callerid_parse(tmp, &name, &num);
388 ast_shrink_phone_number(num);
389 strncpy(cdr->src, num, sizeof(cdr->src) - 1);
391 /* Copy account code et-al */
392 strncpy(cdr->accountcode, c->accountcode, sizeof(cdr->accountcode) - 1);
393 /* Destination information */
394 strncpy(cdr->dst, c->exten, sizeof(cdr->dst) - 1);
395 strncpy(cdr->dcontext, c->context, sizeof(cdr->dcontext) - 1);
400 int ast_cdr_amaflags2int(char *flag)
402 if (!strcasecmp(flag, "default"))
404 if (!strcasecmp(flag, "omit"))
406 if (!strcasecmp(flag, "billing"))
407 return AST_CDR_BILLING;
408 if (!strcasecmp(flag, "documentation"))
409 return AST_CDR_DOCUMENTATION;
413 void ast_cdr_post(struct ast_cdr *cdr)
416 struct ast_cdr_beitem *i;
418 chan = strlen(cdr->channel) ? cdr->channel : "<unknown>";
420 ast_log(LOG_WARNING, "CDR on channel '%s' already posted\n", chan);
421 if (!cdr->end.tv_sec && !cdr->end.tv_usec)
422 ast_log(LOG_WARNING, "CDR on channel '%s' lacks end\n", chan);
423 if (!cdr->start.tv_sec && !cdr->start.tv_usec)
424 ast_log(LOG_WARNING, "CDR on channel '%s' lacks start\n", chan);
425 cdr->duration = cdr->end.tv_sec - cdr->start.tv_sec + (cdr->end.tv_usec - cdr->start.tv_usec) / 1000000;
426 if (cdr->answer.tv_sec || cdr->answer.tv_usec) {
427 cdr->billsec = cdr->end.tv_sec - cdr->answer.tv_sec + (cdr->end.tv_usec - cdr->answer.tv_usec) / 1000000;
431 ast_mutex_lock(&cdrlock);
437 ast_mutex_unlock(&cdrlock);
441 void ast_cdr_reset(struct ast_cdr *cdr, int post)
444 /* Post if requested */
449 /* Reset to initial state */
451 memset(&cdr->start, 0, sizeof(cdr->start));
452 memset(&cdr->end, 0, sizeof(cdr->end));
453 memset(&cdr->answer, 0, sizeof(cdr->answer));
457 cdr->disposition = AST_CDR_NOANSWER;