app.h File Reference

00039 {
00040    int res,to,fto;
00041    /* XXX Merge with full version? XXX */
00042    if (maxlen)
00043       s[0] = '\0';
00044    if (prompt) {
00045       res = ast_streamfile(c, prompt, c->language);
00046       if (res < 0)
00047          return res;
00048    }
00049    fto = c->pbx ? c->pbx->rtimeout * 1000 : 6000;
00050    to = c->pbx ? c->pbx->dtimeout * 1000 : 2000;
00051 
00052    if (timeout > 0) fto = to = timeout;
00053    if (timeout < 0) fto = to = 1000000000;
00054    res = ast_readstring(c, s, maxlen, to, fto, "#");
00055    return res;
00056 }

00060 {
00061    int res,to,fto;
00062    if (prompt) {
00063       res = ast_streamfile(c, prompt, c->language);
00064       if (res < 0)
00065          return res;
00066    }
00067    fto = 6000;
00068    to = 2000;
00069    if (timeout > 0) fto = to = timeout;
00070    if (timeout < 0) fto = to = 1000000000;
00071    res = ast_readstring_full(c, s, maxlen, to, fto, "#", audiofd, ctrlfd);
00072    return res;
00073 }

00076 {
00077    int res;
00078    struct ast_filestream *writer;
00079    int rfmt;
00080    int totalms=0, total;
00081    
00082    struct ast_frame *f;
00083    struct ast_dsp *sildet;
00084    /* Play prompt if requested */
00085    if (prompt) {
00086       res = ast_streamfile(c, prompt, c->language);
00087       if (res < 0)
00088          return res;
00089       res = ast_waitstream(c,"");
00090       if (res < 0)
00091          return res;
00092    }
00093    rfmt = c->readformat;
00094    res = ast_set_read_format(c, AST_FORMAT_SLINEAR);
00095    if (res < 0) {
00096       ast_log(LOG_WARNING, "Unable to set to linear mode, giving up\n");
00097       return -1;
00098    }
00099    sildet = ast_dsp_new();
00100    if (!sildet) {
00101       ast_log(LOG_WARNING, "Unable to create silence detector :(\n");
00102       return -1;
00103    }
00104    writer = ast_writefile(dest, dstfmt, "Voice file", 0, 0, 0666);
00105    if (!writer) {
00106       ast_log(LOG_WARNING, "Unable to open file '%s' in format '%s' for writing\n", dest, dstfmt);
00107       ast_dsp_free(sildet);
00108       return -1;
00109    }
00110    for(;;) {
00111       if ((res = ast_waitfor(c, 2000)) < 0) {
00112          ast_log(LOG_NOTICE, "Waitfor failed while recording file '%s' format '%s'\n", dest, dstfmt);
00113          break;
00114       }
00115       if (res) {
00116          f = ast_read(c);
00117          if (!f) {
00118             ast_log(LOG_NOTICE, "Hungup while recording file '%s' format '%s'\n", dest, dstfmt);
00119             break;
00120          }
00121          if ((f->frametype == AST_FRAME_DTMF) && (f->subclass == '#')) {
00122             /* Ended happily with DTMF */
00123             ast_frfree(f);
00124             break;
00125          } else if (f->frametype == AST_FRAME_VOICE) {
00126             ast_dsp_silence(sildet, f, &total); 
00127             if (total > silence) {
00128                /* Ended happily with silence */
00129                ast_frfree(f);
00130                break;
00131             }
00132             totalms += f->samples / 8;
00133             if (totalms > maxsec * 1000) {
00134                /* Ended happily with too much stuff */
00135                ast_log(LOG_NOTICE, "Constraining voice on '%s' to %d seconds\n", c->name, maxsec);
00136                ast_frfree(f);
00137                break;
00138             }
00139          }
00140          ast_frfree(f);
00141       }
00142    }
00143    res = ast_set_read_format(c, rfmt);
00144    if (res)
00145       ast_log(LOG_WARNING, "Unable to restore read format on '%s'\n", c->name);
00146    ast_dsp_free(sildet);
00147    ast_closestream(writer);
00148    return 0;
00149 }

00152 {
00153    DIR *dir;
00154    struct dirent *de;
00155    char fn[256];
00156    char tmp[256]="";
00157    char *mb, *cur;
00158    char *context;
00159    int ret;
00160    /* If no mailbox, return immediately */
00161    if (ast_strlen_zero(mailbox))
00162       return 0;
00163    if (strchr(mailbox, ',')) {
00164       strncpy(tmp, mailbox, sizeof(tmp) - 1);
00165       mb = tmp;
00166       ret = 0;
00167       while((cur = strsep(&mb, ","))) {
00168          if (!ast_strlen_zero(cur)) {
00169             if (ast_app_has_voicemail(cur))
00170                return 1; 
00171          }
00172       }
00173       return 0;
00174    }
00175    strncpy(tmp, mailbox, sizeof(tmp) - 1);
00176    context = strchr(tmp, '@');
00177    if (context) {
00178       *context = '\0';
00179       context++;
00180    } else
00181       context = "default";
00182    snprintf(fn, sizeof(fn), "%s/voicemail/%s/%s/INBOX", (char *)ast_config_AST_SPOOL_DIR, context, tmp);
00183    dir = opendir(fn);
00184    if (!dir)
00185       return 0;
00186    while ((de = readdir(dir))) {
00187       if (!strncasecmp(de->d_name, "msg", 3))
00188          break;
00189    }
00190    closedir(dir);
00191    if (de)
00192       return 1;
00193    return 0;
00194 }

00197 {
00198    DIR *dir;
00199    struct dirent *de;
00200    char fn[256];
00201    char tmp[256]="";
00202    char *mb, *cur;
00203    char *context;
00204    int ret;
00205    if (newmsgs)
00206       *newmsgs = 0;
00207    if (oldmsgs)
00208       *oldmsgs = 0;
00209    /* If no mailbox, return immediately */
00210    if (ast_strlen_zero(mailbox))
00211       return 0;
00212    if (strchr(mailbox, ',')) {
00213       int tmpnew, tmpold;
00214       strncpy(tmp, mailbox, sizeof(tmp) - 1);
00215       mb = tmp;
00216       ret = 0;
00217       while((cur = strsep(&mb, ", "))) {
00218          if (!ast_strlen_zero(cur)) {
00219             if (ast_app_messagecount(cur, newmsgs ? &tmpnew : NULL, oldmsgs ? &tmpold : NULL))
00220                return -1;
00221             else {
00222                if (newmsgs)
00223                   *newmsgs += tmpnew; 
00224                if (oldmsgs)
00225                   *oldmsgs += tmpold;
00226             }
00227          }
00228       }
00229       return 0;
00230    }
00231    strncpy(tmp, mailbox, sizeof(tmp) - 1);
00232    context = strchr(tmp, '@');
00233    if (context) {
00234       *context = '\0';
00235       context++;
00236    } else
00237       context = "default";
00238    if (newmsgs) {
00239       snprintf(fn, sizeof(fn), "%s/voicemail/%s/%s/INBOX", (char *)ast_config_AST_SPOOL_DIR, context, tmp);
00240       dir = opendir(fn);
00241       if (dir) {
00242          while ((de = readdir(dir))) {
00243             if ((strlen(de->d_name) > 3) && !strncasecmp(de->d_name, "msg", 3) &&
00244                !strcasecmp(de->d_name + strlen(de->d_name) - 3, "txt"))
00245                   (*newmsgs)++;
00246                
00247          }
00248          closedir(dir);
00249       }
00250    }
00251    if (oldmsgs) {
00252       snprintf(fn, sizeof(fn), "%s/voicemail/%s/%s/Old", (char *)ast_config_AST_SPOOL_DIR, context, tmp);
00253       dir = opendir(fn);
00254       if (dir) {
00255          while ((de = readdir(dir))) {
00256             if ((strlen(de->d_name) > 3) && !strncasecmp(de->d_name, "msg", 3) &&
00257                !strcasecmp(de->d_name + strlen(de->d_name) - 3, "txt"))
00258                   (*oldmsgs)++;
00259                
00260          }
00261          closedir(dir);
00262       }
00263    }
00264    return 0;
00265 }

00415 {
00416    struct timeval started, ended;
00417    long elapsed = 0,last_elapsed =0;
00418    char *breaks=NULL;
00419    char *end=NULL;
00420    int blen=2;
00421    int res=0;
00422 
00423    if (stop)
00424       blen += strlen(stop);
00425    if (pause)
00426       blen += strlen(pause);
00427 
00428    if (blen > 2) {
00429       breaks = alloca(blen + 1);
00430       breaks[0] = '\0';
00431       strcat(breaks, stop);
00432       strcat(breaks, pause);
00433    }
00434    if (chan->_state != AST_STATE_UP)
00435       res = ast_answer(chan);
00436 
00437    if (chan)
00438       ast_stopstream(chan);
00439 
00440 
00441    if (file) {
00442       if ((end = strchr(file,':'))) {
00443          if (!strcasecmp(end, ":end")) {
00444             *end = '\0';
00445             end++;
00446          }
00447       }
00448    }
00449 
00450    for (;;) {
00451       gettimeofday(&started,NULL);
00452 
00453       if (chan)
00454          ast_stopstream(chan);
00455       res = ast_streamfile(chan, file, chan->language);
00456       if (!res) {
00457          if (end) {
00458             ast_seekstream(chan->stream, 0, SEEK_END);
00459             end=NULL;
00460          }
00461          res = 1;
00462          if (elapsed) {
00463             ast_stream_fastforward(chan->stream, elapsed);
00464             last_elapsed = elapsed - 200;
00465          }
00466          if (res)
00467             res = ast_waitstream_fr(chan, breaks, fwd, rev, skipms);
00468          else
00469             break;
00470       }
00471 
00472       if (res < 1)
00473          break;
00474 
00475       if (pause != NULL && strchr(pause, res)) {
00476          gettimeofday(&ended, NULL);
00477          elapsed = (((ended.tv_sec * 1000) + ended.tv_usec / 1000) - ((started.tv_sec * 1000) + started.tv_usec / 1000) + last_elapsed);
00478          for(;;) {
00479             if (chan)
00480                ast_stopstream(chan);
00481             res = ast_waitfordigit(chan, 1000);
00482             if (res == 0)
00483                continue;
00484             else if (res == -1 || strchr(pause, res) || (stop && strchr(stop, res)))
00485                break;
00486          }
00487          if (res == *pause) {
00488             res = 0;
00489             continue;
00490          }
00491       }
00492       if (res == -1)
00493          break;
00494 
00495       /* if we get one of our stop chars, return it to the calling function */
00496       if (stop && strchr(stop, res)) {
00497          /* res = 0; */
00498          break;
00499       }
00500    }
00501    if (chan)
00502       ast_stopstream(chan);
00503 
00504    return res;
00505 }

00268 {
00269    char *ptr=NULL;
00270    int res=0;
00271    struct ast_frame f;
00272    if (!between)
00273       between = 100;
00274 
00275    if (peer)
00276       res = ast_autoservice_start(peer);
00277 
00278    if (!res) {
00279       res = ast_waitfor(chan,100);
00280       if (res > -1) {
00281          for (ptr=digits;*ptr;*ptr++) {
00282             if (*ptr == 'w') {
00283                res = ast_safe_sleep(chan, 500);
00284                if (res) 
00285                   break;
00286                continue;
00287             }
00288             memset(&f, 0, sizeof(f));
00289             f.frametype = AST_FRAME_DTMF;
00290             f.subclass = *ptr;
00291             f.src = "ast_dtmf_stream";
00292             if (strchr("0123456789*#abcdABCD",*ptr)==NULL) {
00293                ast_log(LOG_WARNING, "Illegal DTMF character '%c' in string. (0-9*#aAbBcCdD allowed)\n",*ptr);
00294             } else {
00295                res = ast_write(chan, &f);
00296                if (res) 
00297                   break;
00298                /* pause between digits */
00299                res = ast_safe_sleep(chan,between);
00300                if (res) 
00301                   break;
00302             }
00303          }
00304       }
00305       if (peer)
00306          res = ast_autoservice_stop(peer);
00307    }
00308    return res;
00309 }

00384 {
00385    struct linear_state *lin;
00386    char tmpf[256] = "";
00387    int res = -1;
00388    int autoclose = 0;
00389    if (fd < 0) {
00390       if (!filename || ast_strlen_zero(filename))
00391          return -1;
00392       autoclose = 1;
00393       if (filename[0] == '/') 
00394          strncpy(tmpf, filename, sizeof(tmpf) - 1);
00395       else
00396          snprintf(tmpf, sizeof(tmpf), "%s/%s/%s", (char *)ast_config_AST_VAR_DIR, "sounds", filename);
00397       fd = open(tmpf, O_RDONLY);
00398       if (fd < 0){
00399          ast_log(LOG_WARNING, "Unable to open file '%s': %s\n", tmpf, strerror(errno));
00400          return -1;
00401       }
00402    }
00403    lin = malloc(sizeof(struct linear_state));
00404    if (lin) {
00405       memset(lin, 0, sizeof(lin));
00406       lin->fd = fd;
00407       lin->allowoverride = allowoverride;
00408       lin->autoclose = autoclose;
00409       res = ast_activate_generator(chan, &linearstream, lin);
00410    }
00411    return res;
00412 }

00733 {
00734    char d = 0, *fmts;
00735    char comment[256];
00736    int x, fmtcnt=1, res=-1,outmsg=0;
00737    struct ast_frame *f;
00738    struct ast_filestream *others[MAX_OTHER_FORMATS];
00739    struct ast_filestream *realfiles[MAX_OTHER_FORMATS];
00740    char *sfmt[MAX_OTHER_FORMATS];
00741    char *stringp=NULL;
00742    time_t start, end;
00743    struct ast_dsp *sildet;    /* silence detector dsp */
00744    int totalsilence = 0;
00745    int dspsilence = 0;
00746    int gotsilence = 0;     /* did we timeout for silence? */
00747    int rfmt=0; 
00748    char prependfile[80];
00749    
00750    if (silencethreshold < 0)
00751       silencethreshold = global_silence_threshold;
00752 
00753    if (maxsilence < 0)
00754       maxsilence = global_maxsilence;
00755 
00756    /* barf if no pointer passed to store duration in */
00757    if (duration == NULL) {
00758       ast_log(LOG_WARNING, "Error play_and_prepend called without duration pointer\n");
00759       return -1;
00760    }
00761 
00762    ast_log(LOG_DEBUG,"play_and_prepend: %s, %s, '%s'\n", playfile ? playfile : "<None>", recordfile, fmt);
00763    snprintf(comment,sizeof(comment),"Playing %s, Recording to: %s on %s\n", playfile ? playfile : "<None>", recordfile, chan->name);
00764 
00765    if (playfile || beep) { 
00766       if (!beep)
00767          d = ast_play_and_wait(chan, playfile);
00768       if (d > -1)
00769          d = ast_streamfile(chan, "beep",chan->language);
00770       if (!d)
00771          d = ast_waitstream(chan,"");
00772       if (d < 0)
00773          return -1;
00774    }
00775    strncpy(prependfile, recordfile, sizeof(prependfile) -1);   
00776    strncat(prependfile, "-prepend", sizeof(prependfile) - strlen(prependfile) - 1);
00777          
00778    fmts = ast_strdupa(fmt);
00779    
00780    stringp=fmts;
00781    strsep(&stringp, "|");
00782    ast_log(LOG_DEBUG,"Recording Formats: sfmts=%s\n", fmts);   
00783    sfmt[0] = ast_strdupa(fmts);
00784    
00785    while((fmt = strsep(&stringp, "|"))) {
00786       if (fmtcnt > MAX_OTHER_FORMATS - 1) {
00787          ast_log(LOG_WARNING, "Please increase MAX_OTHER_FORMATS in app_voicemail.c\n");
00788          break;
00789       }
00790       sfmt[fmtcnt++] = ast_strdupa(fmt);
00791    }
00792 
00793    time(&start);
00794    end=start;  /* pre-initialize end to be same as start in case we never get into loop */
00795    for (x=0;x<fmtcnt;x++) {
00796       others[x] = ast_writefile(prependfile, sfmt[x], comment, O_TRUNC, 0, 0700);
00797       ast_verbose( VERBOSE_PREFIX_3 "x=%i, open writing:  %s format: %s, %p\n", x, prependfile, sfmt[x], others[x]);
00798       if (!others[x]) {
00799          break;
00800       }
00801    }
00802    
00803    sildet = ast_dsp_new(); /* Create the silence detector */
00804    if (!sildet) {
00805       ast_log(LOG_WARNING, "Unable to create silence detector :(\n");
00806       return -1;
00807    }
00808    ast_dsp_set_threshold(sildet, silencethreshold);
00809 
00810    if (maxsilence > 0) {
00811       rfmt = chan->readformat;
00812       res = ast_set_read_format(chan, AST_FORMAT_SLINEAR);
00813       if (res < 0) {
00814          ast_log(LOG_WARNING, "Unable to set to linear mode, giving up\n");
00815          return -1;
00816       }
00817    }
00818                   
00819    if (x == fmtcnt) {
00820    /* Loop forever, writing the packets we read to the writer(s), until
00821       we read a # or get a hangup */
00822       f = NULL;
00823       for(;;) {
00824          res = ast_waitfor(chan, 2000);
00825          if (!res) {
00826             ast_log(LOG_DEBUG, "One waitfor failed, trying another\n");
00827             /* Try one more time in case of masq */
00828             res = ast_waitfor(chan, 2000);
00829             if (!res) {
00830                ast_log(LOG_WARNING, "No audio available on %s??\n", chan->name);
00831                res = -1;
00832             }
00833          }
00834          
00835          if (res < 0) {
00836             f = NULL;
00837             break;
00838          }
00839          f = ast_read(chan);
00840          if (!f)
00841             break;
00842          if (f->frametype == AST_FRAME_VOICE) {
00843             /* write each format */
00844             for (x=0;x<fmtcnt;x++) {
00845                if (!others[x])
00846                   break;
00847                res = ast_writestream(others[x], f);
00848             }
00849             
00850             /* Silence Detection */
00851             if (maxsilence > 0) {
00852                dspsilence = 0;
00853                ast_dsp_silence(sildet, f, &dspsilence);
00854                if (dspsilence)
00855                   totalsilence = dspsilence;
00856                else
00857                   totalsilence = 0;
00858                
00859                if (totalsilence > maxsilence) {
00860                /* Ended happily with silence */
00861                if (option_verbose > 2) 
00862                   ast_verbose( VERBOSE_PREFIX_3 "Recording automatically stopped after a silence of %d seconds\n", totalsilence/1000);
00863                ast_frfree(f);
00864                gotsilence = 1;
00865                outmsg=2;
00866                break;
00867                }
00868             }
00869             /* Exit on any error */
00870             if (res) {
00871                ast_log(LOG_WARNING, "Error writing frame\n");
00872                ast_frfree(f);
00873                break;
00874             }
00875          } else if (f->frametype == AST_FRAME_VIDEO) {
00876             /* Write only once */
00877             ast_writestream(others[0], f);
00878          } else if (f->frametype == AST_FRAME_DTMF) {
00879             /* stop recording with any digit */
00880             if (option_verbose > 2) 
00881                ast_verbose( VERBOSE_PREFIX_3 "User ended message by pressing %c\n", f->subclass);
00882             res = 't';
00883             outmsg = 2;
00884             ast_frfree(f);
00885             break;
00886          }
00887          if (maxtime) {
00888             time(&end);
00889             if (maxtime < (end - start)) {
00890                if (option_verbose > 2)
00891                   ast_verbose( VERBOSE_PREFIX_3 "Took too long, cutting it short...\n");
00892                res = 't';
00893                outmsg=2;
00894                ast_frfree(f);
00895                break;
00896             }
00897          }
00898          ast_frfree(f);
00899       }
00900       if (end == start) time(&end);
00901       if (!f) {
00902          if (option_verbose > 2) 
00903             ast_verbose( VERBOSE_PREFIX_3 "User hung up\n");
00904          res = -1;
00905          outmsg=1;
00906 #if 0
00907          /* delete all the prepend files */
00908          for (x=0;x<fmtcnt;x++) {
00909             if (!others[x])
00910                break;
00911             ast_closestream(others[x]);
00912             ast_filedelete(prependfile, sfmt[x]);
00913          }
00914 #endif
00915       }
00916    } else {
00917       ast_log(LOG_WARNING, "Error creating writestream '%s', format '%s'\n", prependfile, sfmt[x]); 
00918    }
00919    *duration = end - start;
00920 #if 0
00921    if (outmsg > 1) {
00922 #else
00923    if (outmsg) {
00924 #endif
00925       struct ast_frame *fr;
00926       for (x=0;x<fmtcnt;x++) {
00927          snprintf(comment, sizeof(comment), "Opening the real file %s.%s\n", recordfile, sfmt[x]);
00928          realfiles[x] = ast_readfile(recordfile, sfmt[x], comment, O_RDONLY, 0, 0);
00929          if (!others[x] || !realfiles[x])
00930             break;
00931          if (totalsilence)
00932             ast_stream_rewind(others[x], totalsilence-200);
00933          else
00934             ast_stream_rewind(others[x], 200);
00935          ast_truncstream(others[x]);
00936          /* add the original file too */
00937          while ((fr = ast_readframe(realfiles[x]))) {
00938             ast_writestream(others[x],fr);
00939          }
00940          ast_closestream(others[x]);
00941          ast_closestream(realfiles[x]);
00942          ast_filerename(prependfile, recordfile, sfmt[x]);
00943 #if 0
00944          ast_verbose("Recording Format: sfmts=%s, prependfile %s, recordfile %s\n", sfmt[x],prependfile,recordfile);
00945 #endif
00946          ast_filedelete(prependfile, sfmt[x]);
00947       }
00948    }
00949    if (rfmt) {
00950       if (ast_set_read_format(chan, rfmt)) {
00951          ast_log(LOG_WARNING, "Unable to restore format %s to channel '%s'\n", ast_getformatname(rfmt), chan->name);
00952       }
00953    }
00954    if (outmsg) {
00955       if (outmsg > 1) {
00956          /* Let them know it worked */
00957          ast_streamfile(chan, "auth-thankyou", chan->language);
00958          ast_waitstream(chan, "");
00959       }
00960    }  
00961    return res;
00962 }

00522 {
00523    char d, *fmts;
00524    char comment[256];
00525    int x, fmtcnt=1, res=-1,outmsg=0;
00526    struct ast_frame *f;
00527    struct ast_filestream *others[MAX_OTHER_FORMATS];
00528    char *sfmt[MAX_OTHER_FORMATS];
00529    char *stringp=NULL;
00530    time_t start, end;
00531    struct ast_dsp *sildet;    /* silence detector dsp */
00532    int totalsilence = 0;
00533    int dspsilence = 0;
00534    int gotsilence = 0;     /* did we timeout for silence? */
00535    int rfmt=0;
00536 
00537    if (silencethreshold < 0)
00538       silencethreshold = global_silence_threshold;
00539 
00540    if (maxsilence < 0)
00541       maxsilence = global_maxsilence;
00542 
00543    /* barf if no pointer passed to store duration in */
00544    if (duration == NULL) {
00545       ast_log(LOG_WARNING, "Error play_and_record called without duration pointer\n");
00546       return -1;
00547    }
00548 
00549    ast_log(LOG_DEBUG,"play_and_record: %s, %s, '%s'\n", playfile ? playfile : "<None>", recordfile, fmt);
00550    snprintf(comment,sizeof(comment),"Playing %s, Recording to: %s on %s\n", playfile ? playfile : "<None>", recordfile, chan->name);
00551 
00552    if (playfile) {
00553       d = ast_play_and_wait(chan, playfile);
00554       if (d > -1)
00555          d = ast_streamfile(chan, "beep",chan->language);
00556       if (!d)
00557          d = ast_waitstream(chan,"");
00558       if (d < 0)
00559          return -1;
00560    }
00561 
00562    fmts = ast_strdupa(fmt);
00563 
00564    stringp=fmts;
00565    strsep(&stringp, "|");
00566    ast_log(LOG_DEBUG,"Recording Formats: sfmts=%s\n", fmts);
00567    sfmt[0] = ast_strdupa(fmts);
00568 
00569    while((fmt = strsep(&stringp, "|"))) {
00570       if (fmtcnt > MAX_OTHER_FORMATS - 1) {
00571          ast_log(LOG_WARNING, "Please increase MAX_OTHER_FORMATS in app_voicemail.c\n");
00572          break;
00573       }
00574       sfmt[fmtcnt++] = ast_strdupa(fmt);
00575    }
00576 
00577    time(&start);
00578    end=start;  /* pre-initialize end to be same as start in case we never get into loop */
00579    for (x=0;x<fmtcnt;x++) {
00580       others[x] = ast_writefile(recordfile, sfmt[x], comment, O_TRUNC, 0, 0700);
00581       ast_verbose( VERBOSE_PREFIX_3 "x=%i, open writing:  %s format: %s, %p\n", x, recordfile, sfmt[x], others[x]);
00582 
00583       if (!others[x]) {
00584          break;
00585       }
00586    }
00587 
00588    sildet = ast_dsp_new(); /* Create the silence detector */
00589    if (!sildet) {
00590       ast_log(LOG_WARNING, "Unable to create silence detector :(\n");
00591       return -1;
00592    }
00593    ast_dsp_set_threshold(sildet, silencethreshold);
00594    
00595    if (maxsilence > 0) {
00596       rfmt = chan->readformat;
00597       res = ast_set_read_format(chan, AST_FORMAT_SLINEAR);
00598       if (res < 0) {
00599          ast_log(LOG_WARNING, "Unable to set to linear mode, giving up\n");
00600          return -1;
00601       }
00602    }
00603 
00604    if (x == fmtcnt) {
00605    /* Loop forever, writing the packets we read to the writer(s), until
00606       we read a # or get a hangup */
00607       f = NULL;
00608       for(;;) {
00609          res = ast_waitfor(chan, 2000);
00610          if (!res) {
00611             ast_log(LOG_DEBUG, "One waitfor failed, trying another\n");
00612             /* Try one more time in case of masq */
00613             res = ast_waitfor(chan, 2000);
00614             if (!res) {
00615                ast_log(LOG_WARNING, "No audio available on %s??\n", chan->name);
00616                res = -1;
00617             }
00618          }
00619 
00620          if (res < 0) {
00621             f = NULL;
00622             break;
00623          }
00624          f = ast_read(chan);
00625          if (!f)
00626             break;
00627          if (f->frametype == AST_FRAME_VOICE) {
00628             /* write each format */
00629             for (x=0;x<fmtcnt;x++) {
00630                res = ast_writestream(others[x], f);
00631             }
00632 
00633             /* Silence Detection */
00634             if (maxsilence > 0) {
00635                dspsilence = 0;
00636                ast_dsp_silence(sildet, f, &dspsilence);
00637                if (dspsilence)
00638                   totalsilence = dspsilence;
00639                else
00640                   totalsilence = 0;
00641 
00642                if (totalsilence > maxsilence) {
00643                /* Ended happily with silence */
00644                                         if (option_verbose > 2)
00645                                                 ast_verbose( VERBOSE_PREFIX_3 "Recording automatically stopped after a silence of %d seconds\n", totalsilence/1000);
00646                ast_frfree(f);
00647                gotsilence = 1;
00648                outmsg=2;
00649                break;
00650                }
00651             }
00652             /* Exit on any error */
00653             if (res) {
00654                ast_log(LOG_WARNING, "Error writing frame\n");
00655                ast_frfree(f);
00656                break;
00657             }
00658          } else if (f->frametype == AST_FRAME_VIDEO) {
00659             /* Write only once */
00660             ast_writestream(others[0], f);
00661          } else if (f->frametype == AST_FRAME_DTMF) {
00662             if (f->subclass == '#') {
00663                if (option_verbose > 2)
00664                   ast_verbose( VERBOSE_PREFIX_3 "User ended message by pressing %c\n", f->subclass);
00665                res = '#';
00666                outmsg = 2;
00667                ast_frfree(f);
00668                break;
00669             }
00670          }
00671             if (f->subclass == '0') {
00672             /* Check for a '0' during message recording also, in case caller wants operator */
00673                if (option_verbose > 2)
00674                   ast_verbose(VERBOSE_PREFIX_3 "User cancelled by pressing %c\n", f->subclass);
00675                res = '0';
00676                outmsg = 0;
00677                ast_frfree(f);
00678                break;
00679             }
00680          if (maxtime) {
00681             time(&end);
00682             if (maxtime < (end - start)) {
00683                if (option_verbose > 2)
00684                   ast_verbose( VERBOSE_PREFIX_3 "Took too long, cutting it short...\n");
00685                outmsg = 2;
00686                res = 't';
00687                ast_frfree(f);
00688                break;
00689             }
00690          }
00691          ast_frfree(f);
00692       }
00693       if (end == start) time(&end);
00694       if (!f) {
00695          if (option_verbose > 2)
00696             ast_verbose( VERBOSE_PREFIX_3 "User hung up\n");
00697          res = -1;
00698          outmsg=1;
00699       }
00700    } else {
00701       ast_log(LOG_WARNING, "Error creating writestream '%s', format '%s'\n", recordfile, sfmt[x]);
00702    }
00703 
00704    *duration = end - start;
00705 
00706    for (x=0;x<fmtcnt;x++) {
00707       if (!others[x])
00708          break;
00709       if (totalsilence)
00710          ast_stream_rewind(others[x], totalsilence-200);
00711       else
00712          ast_stream_rewind(others[x], 200);
00713       ast_truncstream(others[x]);
00714       ast_closestream(others[x]);
00715    }
00716    if (rfmt) {
00717       if (ast_set_read_format(chan, rfmt)) {
00718          ast_log(LOG_WARNING, "Unable to restore format %s to channel '%s'\n", ast_getformatname(rfmt), chan->name);
00719       }
00720    }
00721    if (outmsg) {
00722       if (outmsg > 1) {
00723       /* Let them know recording is stopped */
00724          ast_streamfile(chan, "auth-thankyou", chan->language);
00725          ast_waitstream(chan, "");
00726       }
00727    }
00728 
00729    return res;
00730 }

00508 {
00509    int d;
00510    d = ast_streamfile(chan, fn, chan->language);
00511    if (d)
00512       return d;
00513    d = ast_waitstream(chan, AST_DIGIT_ANY);
00514    ast_stopstream(chan);
00515    return d;
00516 }

00183 {
00184    /* XXX This function needs some optimization work XXX */
00185    pid_t pid;
00186    int x;
00187    int res;
00188    struct rusage rusage;
00189    int status;
00190    void (*prev_handler) = signal(SIGCHLD, null_sig_handler);
00191    pid = fork();
00192    if (pid == 0) {
00193       /* Close file descriptors and launch system command */
00194       for (x=STDERR_FILENO + 1; x<4096;x++) {
00195          close(x);
00196       }
00197       res = execl("/bin/sh", "/bin/sh", "-c", s, NULL);
00198       exit(1);
00199    } else if (pid > 0) {
00200       for(;;) {
00201          res = wait4(pid, &status, 0, &rusage);
00202          if (res > -1) {
00203             if (WIFEXITED(status))
00204                res = WEXITSTATUS(status);
00205             else
00206                res = -1;
00207             break;
00208          } else {
00209             if (errno != EINTR) 
00210                break;
00211          }
00212       }
00213    } else {
00214       ast_log(LOG_WARNING, "Fork failed: %s\n", strerror(errno));
00215       res = -1;
00216    }
00217    signal(SIGCHLD, prev_handler);
00218    return res;
00219 }

Functions
int	ast_app_getdata (struct ast_channel c, char prompt, char *s, int maxlen, int timeout)
	Plays a stream and gets DTMF data from a channel. More...
int	ast_app_getdata_full (struct ast_channel c, char prompt, char *s, int maxlen, int timeout, int audiofd, int ctrlfd)
int	ast_app_getvoice (struct ast_channel c, char dest, char dstfmt, char prompt, int silence, int maxsec)
	Record voice (after playing prompt if specified), waiting for silence (in ms) up to a given timeout (in s) or '#'. More...
int	ast_app_has_voicemail (const char *mailbox)
	Determine if a given mailbox has any voicemail. More...
int	ast_app_messagecount (const char mailbox, int newmsgs, int *oldmsgs)
	Determine number of new/old messages in a mailbox. More...
int	ast_safe_system (const char *s)
	Safely spawn an external program while closingn file descriptors. More...
int	ast_dtmf_stream (struct ast_channel chan, struct ast_channel peer, char *digits, int between)
	Send DTMF to chan (optionally entertain peer). More...
int	ast_linear_stream (struct ast_channel chan, const char filename, int fd, int allowoverride)
	Stream a filename (or file descriptor) as a generator. More...
int	ast_control_streamfile (struct ast_channel chan, char file, char fwd, char rev, char stop, char pause, int skipms)
	Stream a file with fast forward, pause, reverse. More...
int	ast_play_and_wait (struct ast_channel chan, char fn)
	Play a stream and wait for a digit, returning the digit that was pressed. More...
int	ast_play_and_record (struct ast_channel chan, char playfile, char recordfile, int maxtime_sec, char fmt, int *duration, int silencethreshold, int maxsilence_ms)
	Record a file for a max amount of time (in seconds), in a given list of formats separated by '\|', outputting the duration of the recording, and with a maximum. More...
int	ast_play_and_prepend (struct ast_channel chan, char playfile, char recordfile, int maxtime_sec, char fmt, int *duration, int beep, int silencethreshold, int maxsilence_ms)
	Record a message and prepend the message to the given record file after playing the optional playfile (or a beep), storing the duration in 'duration' and with a maximum. More...

app.h File Reference

Functions

Function Documentation