apps/app_forkcdr.c

   1 /*
   2  * Asterisk -- A telephony toolkit for Linux.
   3  *
   4  * Fork CDR application
   5  * Copyright Anthony Minessale anthmct@yahoo.com
   6  * Development of this app Sponsered/Funded  by TAAN Softworks Corp
   7  *
   8  * This program is free software, distributed under the terms of
   9  * the GNU General Public License
  10  */
  11
  12 #include <asterisk/file.h>
  13 #include <asterisk/logger.h>
  14 #include <asterisk/channel.h>
  15 #include <asterisk/pbx.h>
  16 #include <asterisk/cdr.h>
  17 #include <asterisk/module.h>
  18 #include <stdlib.h>
  19 #include <unistd.h>
  20 #include <string.h>
  21 #include <pthread.h>
  22
  23 static char *tdesc = "Fork The CDR into 2 separate entities.";
  24 static char *app = "ForkCDR";
  25 static char *synopsis =
  26 "Forks the Call Data Record";
  27 static char *descrip =
  28 "  ForkCDR([options]):  Causes the Call Data Record to fork an additional\n"
  29         "cdr record starting from the time of the fork call\n"
  30 "If the option 'v' is passed all cdr variables will be passed along also.\n"
  31 "";
  32
  33
  34 STANDARD_LOCAL_USER;
  35
  36 LOCAL_USER_DECL;
  37
  38
  39 static void ast_cdr_clone(struct ast_cdr *cdr)
  40 {
  41         struct ast_cdr *newcdr = ast_cdr_alloc();
  42         memcpy(newcdr,cdr,sizeof(struct ast_cdr));
  43         ast_cdr_append(cdr,newcdr);
  44         gettimeofday(&newcdr->start, NULL);
  45         memset(&newcdr->answer, 0, sizeof(newcdr->answer));
  46         memset(&newcdr->varshead, 0, sizeof(newcdr->varshead));
  47         ast_cdr_copy_vars(newcdr, cdr);
  48         if (!ast_test_flag(cdr, AST_CDR_FLAG_KEEP_VARS)) {
  49                 ast_cdr_free_vars(cdr, 0);
  50         }
  51         newcdr->disposition = AST_CDR_NOANSWER;
  52         ast_set_flag(cdr, AST_CDR_FLAG_CHILD|AST_CDR_FLAG_LOCKED);
  53 }
  54
  55 static void ast_cdr_fork(struct ast_channel *chan)
  56 {
  57         if(chan && chan->cdr) {
  58                 ast_cdr_clone(chan->cdr);
  59         }
  60 }
  61
  62 static int forkcdr_exec(struct ast_channel *chan, void *data)
  63 {
  64         int res=0;
  65         struct localuser *u;
  66         LOCAL_USER_ADD(u);
  67         ast_set2_flag(chan->cdr, strchr((char *)data, 'v'), AST_CDR_FLAG_KEEP_VARS);
  68
  69         ast_cdr_fork(chan);
  70
  71         LOCAL_USER_REMOVE(u);
  72         return res;
  73 }
  74
  75 int unload_module(void)
  76 {
  77         STANDARD_HANGUP_LOCALUSERS;
  78         return ast_unregister_application(app);
  79 }
  80
  81 int load_module(void)
  82 {
  83         return ast_register_application(app, forkcdr_exec, synopsis, descrip);
  84 }
  85
  86 char *description(void)
  87 {
  88         return tdesc;
  89 }
  90
  91 int usecount(void)
  92 {
  93         int res;
  94         STANDARD_USECOUNT(res);
  95         return res;
  96 }
  97
  98 char *key()
  99 {
 100         return ASTERISK_GPL_KEY;
 101 }