[BACK]Return to aucat.c CVS log [TXT][DIR] Up to [local] / src / usr.bin / aucat

Diff for /src/usr.bin/aucat/aucat.c between version 1.62 and 1.63

version 1.62, 2009/07/25 10:52:18 version 1.63, 2009/08/17 15:07:49
Line 298 
Line 298 
         dev_attach(fa->name, NULL, NULL, 0, buf, &fa->opar, fa->xrun, 0);          dev_attach(fa->name, NULL, NULL, 0, buf, &fa->opar, fa->xrun, 0);
 }  }
   
   /*
    * Open a MIDI device and connect it to the thru box
    */
 void  void
   newmidi(struct farg *fa, int in, int out)
   {
           struct file *dev;
           struct abuf *rbuf = NULL, *wbuf = NULL;
           struct aproc *rproc, *wproc;
   
           dev = (struct file *)miofile_new(&miofile_ops, fa->name, in, out);
           if (dev == NULL) {
                   errx(1, "%s: can't open device",
                       fa->name ? fa->name : "<default>");
           }
           if (in) {
                   rproc = rpipe_new(dev);
                   rbuf = abuf_new(3125, &aparams_none);
                   aproc_setout(rproc, rbuf);
                   aproc_setin(thrubox, rbuf);
           }
           if (out) {
                   wproc = wpipe_new(dev);
                   wbuf = abuf_new(3125, &aparams_none);
                   aproc_setin(wproc, wbuf);
                   aproc_setout(thrubox, wbuf);
                   if (in) {
                           rbuf->duplex = wbuf;
                           wbuf->duplex = rbuf;
                   }
           }
   }
   
   void
 setsig(void)  setsig(void)
 {  {
         struct sigaction sa;          struct sigaction sa;
Line 378 
Line 411 
 {  {
         int c, u_flag, l_flag, n_flag, hdr, xrun, suspend = 0, unit;          int c, u_flag, l_flag, n_flag, hdr, xrun, suspend = 0, unit;
         struct farg *fa;          struct farg *fa;
         struct farglist  ifiles, ofiles, sfiles;          struct farglist ifiles, ofiles, sfiles;
         struct aparams ipar, opar, dipar, dopar;          struct aparams ipar, opar, dipar, dopar;
         char base[PATH_MAX], path[PATH_MAX];          char base[PATH_MAX], path[PATH_MAX];
         unsigned bufsz, mode;          unsigned bufsz, mode;
Line 664 
Line 697 
 int  int
 midicat_main(int argc, char **argv)  midicat_main(int argc, char **argv)
 {  {
         static struct aparams noparams = { 1, 0, 0, 0, 0, 0, 0, 0 };  
         int c, l_flag, unit, fd;          int c, l_flag, unit, fd;
           struct farglist dfiles;
         char base[PATH_MAX], path[PATH_MAX];          char base[PATH_MAX], path[PATH_MAX];
         char *input, *output, *devpath;          char *input, *output;
         struct file *dev, *stdx, *f;          struct farg *fa;
         struct aproc *p, *send, *recv;          struct file *stdx, *f;
           struct aproc *p;
         struct abuf *buf;          struct abuf *buf;
   
         l_flag = 0;          l_flag = 0;
         unit = -1;          unit = -1;
         devpath = NULL;  
         output = NULL;          output = NULL;
         input = NULL;          input = NULL;
           SLIST_INIT(&dfiles);
   
         while ((c = getopt(argc, argv, "i:o:lf:U:")) != -1) {          while ((c = getopt(argc, argv, "i:o:lf:U:")) != -1) {
                 switch (c) {                  switch (c) {
Line 691 
Line 725 
                         output = optarg;                          output = optarg;
                         break;                          break;
                 case 'f':                  case 'f':
                         devpath = optarg;                          farg_add(&dfiles, &aparams_none, &aparams_none,
                               HDR_RAW, 0, 0, optarg);
                         break;                          break;
                 case 'l':                  case 'l':
                         l_flag = 1;                          l_flag = 1;
Line 726 
Line 761 
         setsig();          setsig();
         filelist_init();          filelist_init();
   
           thrubox = thru_new("thru");
           thrubox->refs++;
   
           if ((input || output) && SLIST_EMPTY(&dfiles)) {
                   farg_add(&dfiles, &aparams_none, &aparams_none,
                       0, HDR_RAW, 0, NULL);
           }
   
           while (!SLIST_EMPTY(&dfiles)) {
                   fa = SLIST_FIRST(&dfiles);
                   SLIST_REMOVE_HEAD(&dfiles, entry);
                   newmidi(fa, output || l_flag, input || l_flag);
                   free(fa);
           }
   
         if (l_flag) {          if (l_flag) {
                 thrubox = thru_new("thru");  
                 thrubox->refs++;  
                 snprintf(path, sizeof(path), "%s/%s%u", base,                  snprintf(path, sizeof(path), "%s/%s%u", base,
                     DEFAULT_MIDITHRU, unit);                      DEFAULT_MIDITHRU, unit);
                 listen_new(&listen_ops, path);                  listen_new(&listen_ops, path);
                 if (debug_level == 0 && daemon(0, 0) < 0)                  if (debug_level == 0 && daemon(0, 0) < 0)
                         err(1, "daemon");                          err(1, "daemon");
         }          }
         if (input || output) {  
                 dev = (struct file *)miofile_new(&miofile_ops, devpath,  
                      output ? 1 : 0, input ? 1 : 0);  
                 if (dev == NULL)  
                         errx(1, "%s: can't open device",  
                             devpath ? devpath : "<default>");  
         } else  
                 dev = NULL;  
         if (input) {          if (input) {
                 send = wpipe_new(dev);  
                 send->refs++;  
                 if (strcmp(input, "-") == 0) {                  if (strcmp(input, "-") == 0) {
                         fd = STDIN_FILENO;                          fd = STDIN_FILENO;
                         if (fcntl(fd, F_SETFL, O_NONBLOCK) < 0)                          if (fcntl(fd, F_SETFL, O_NONBLOCK) < 0)
Line 757 
Line 795 
                 }                  }
                 stdx = (struct file *)pipe_new(&pipe_ops, fd, "stdin");                  stdx = (struct file *)pipe_new(&pipe_ops, fd, "stdin");
                 p = rpipe_new(stdx);                  p = rpipe_new(stdx);
                 buf = abuf_new(3125, &noparams);                  buf = abuf_new(3125, &aparams_none);
                 aproc_setout(p, buf);                  aproc_setout(p, buf);
                 aproc_setin(send, buf);                  aproc_setin(thrubox, buf);
         } else          }
                 send = NULL;  
         if (output) {          if (output) {
                 recv = rpipe_new(dev);  
                 recv->refs++;  
                 if (strcmp(output, "-") == 0) {                  if (strcmp(output, "-") == 0) {
                         fd = STDOUT_FILENO;                          fd = STDOUT_FILENO;
                         if (fcntl(fd, F_SETFL, O_NONBLOCK) < 0)                          if (fcntl(fd, F_SETFL, O_NONBLOCK) < 0)
Line 777 
Line 812 
                 }                  }
                 stdx = (struct file *)pipe_new(&pipe_ops, fd, "stdout");                  stdx = (struct file *)pipe_new(&pipe_ops, fd, "stdout");
                 p = wpipe_new(stdx);                  p = wpipe_new(stdx);
                 buf = abuf_new(3125, &noparams);                  buf = abuf_new(3125, &aparams_none);
                 aproc_setin(p, buf);                  aproc_setin(p, buf);
                 aproc_setout(recv, buf);                  aproc_setout(thrubox, buf);
         } else          }
                 recv = NULL;  
   
         /*          /*
          * loop, start processing           * loop, start processing
Line 790 
Line 824 
                 if (quit_flag) {                  if (quit_flag) {
                         break;                          break;
                 }                  }
                   if (!l_flag && LIST_EMPTY(&thrubox->ibuflist))
                           break;
                 if (!file_poll())                  if (!file_poll())
                         break;                          break;
         }          }
Line 815 
Line 851 
                 thrubox = NULL;                  thrubox = NULL;
                 while (file_poll())                  while (file_poll())
                         ; /* nothing */                          ; /* nothing */
         }  
         if (send) {  
         restart_send:  
                 LIST_FOREACH(f, &file_list, entry) {  
                         if (f->rproc && aproc_depend(send, f->rproc)) {  
                                 file_eof(f);  
                                 goto restart_send;  
                         }  
                 }  
                 while (!LIST_EMPTY(&send->ibuflist)) {  
                         if (!file_poll())  
                                 break;  
                 }  
                 send->refs--;  
                 aproc_del(send);  
                 send = NULL;  
         }  
         if (recv) {  
                 if (recv->u.io.file)  
                         file_eof(recv->u.io.file);  
                 while (!LIST_EMPTY(&recv->obuflist)) {  
                         if (!file_poll())  
                                 break;  
                 }  
                 recv->refs--;  
                 aproc_del(recv);  
                 recv = NULL;  
         }          }
         filelist_done();          filelist_done();
         unsetsig();          unsetsig();
Legend:
Removed from v.1.62  
changed lines
  Added in v.1.63