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

Diff for /src/usr.bin/aucat/Attic/sock.c between version 1.58 and 1.59

version 1.58, 2011/05/02 22:20:18 version 1.59, 2011/05/02 22:32:29
Line 752 
Line 752 
 sock_setpar(struct sock *f)  sock_setpar(struct sock *f)
 {  {
         struct amsg_par *p = &f->rmsg.u.par;          struct amsg_par *p = &f->rmsg.u.par;
         unsigned min, max, rate;          unsigned min, max, rate, pchan, rchan, appbufsz;
   
           rchan = ntohs(p->rchan);
           pchan = ntohs(p->pchan);
           appbufsz = ntohl(p->appbufsz);
           rate = ntohl(p->rate);
   
         if (AMSG_ISSET(p->bits)) {          if (AMSG_ISSET(p->bits)) {
                 if (p->bits < BITS_MIN || p->bits > BITS_MAX) {                  if (p->bits < BITS_MIN || p->bits > BITS_MAX) {
 #ifdef DEBUG  #ifdef DEBUG
Line 799 
Line 804 
                 f->rpar.le = f->wpar.le = p->le ? 1 : 0;                  f->rpar.le = f->wpar.le = p->le ? 1 : 0;
         if (AMSG_ISSET(p->msb))          if (AMSG_ISSET(p->msb))
                 f->rpar.msb = f->wpar.msb = p->msb ? 1 : 0;                  f->rpar.msb = f->wpar.msb = p->msb ? 1 : 0;
         if (AMSG_ISSET(p->rchan) && (f->mode & MODE_RECMASK)) {          if (AMSG_ISSET(rchan) && (f->mode & MODE_RECMASK)) {
                 if (p->rchan < 1)                  if (rchan < 1)
                         p->rchan = 1;                          rchan = 1;
                 if (p->rchan > NCHAN_MAX)                  if (rchan > NCHAN_MAX)
                         p->rchan = NCHAN_MAX;                          rchan = NCHAN_MAX;
                 f->wpar.cmin = f->opt->wpar.cmin;                  f->wpar.cmin = f->opt->wpar.cmin;
                 f->wpar.cmax = f->opt->wpar.cmin + p->rchan - 1;                  f->wpar.cmax = f->opt->wpar.cmin + rchan - 1;
                 if (f->wpar.cmax > f->opt->wpar.cmax)                  if (f->wpar.cmax > f->opt->wpar.cmax)
                         f->wpar.cmax = f->opt->wpar.cmax;                          f->wpar.cmax = f->opt->wpar.cmax;
 #ifdef DEBUG  #ifdef DEBUG
Line 819 
Line 824 
                 }                  }
 #endif  #endif
         }          }
         if (AMSG_ISSET(p->pchan) && (f->mode & MODE_PLAY)) {          if (AMSG_ISSET(pchan) && (f->mode & MODE_PLAY)) {
                 if (p->pchan < 1)                  if (pchan < 1)
                         p->pchan = 1;                          pchan = 1;
                 if (p->pchan > NCHAN_MAX)                  if (pchan > NCHAN_MAX)
                         p->pchan = NCHAN_MAX;                          pchan = NCHAN_MAX;
                 f->rpar.cmin = f->opt->rpar.cmin;                  f->rpar.cmin = f->opt->rpar.cmin;
                 f->rpar.cmax = f->opt->rpar.cmin + p->pchan - 1;                  f->rpar.cmax = f->opt->rpar.cmin + pchan - 1;
                 if (f->rpar.cmax > f->opt->rpar.cmax)                  if (f->rpar.cmax > f->opt->rpar.cmax)
                         f->rpar.cmax = f->opt->rpar.cmax;                          f->rpar.cmax = f->opt->rpar.cmax;
 #ifdef DEBUG  #ifdef DEBUG
Line 839 
Line 844 
                 }                  }
 #endif  #endif
         }          }
         if (AMSG_ISSET(p->rate)) {          if (AMSG_ISSET(rate)) {
                 if (p->rate < RATE_MIN)                  if (rate < RATE_MIN)
                         p->rate = RATE_MIN;                          rate = RATE_MIN;
                 if (p->rate > RATE_MAX)                  if (rate > RATE_MAX)
                         p->rate = RATE_MAX;                          rate = RATE_MAX;
                 f->round = dev_roundof(f->dev, p->rate);                  f->round = dev_roundof(f->dev, rate);
                 f->rpar.rate = f->wpar.rate = p->rate;                  f->rpar.rate = f->wpar.rate = rate;
                 if (!AMSG_ISSET(p->appbufsz)) {                  if (!AMSG_ISSET(appbufsz)) {
                         p->appbufsz = f->dev->bufsz / f->dev->round * f->round;                          appbufsz = f->dev->bufsz / f->dev->round * f->round;
 #ifdef DEBUG  #ifdef DEBUG
                         if (debug_level >= 3) {                          if (debug_level >= 3) {
                                 sock_dbg(f);                                  sock_dbg(f);
                                 dbg_puts(": using ");                                  dbg_puts(": using ");
                                 dbg_putu(p->appbufsz);                                  dbg_putu(appbufsz);
                                 dbg_puts(" fr app buffer size\n");                                  dbg_puts(" fr app buffer size\n");
                         }                          }
 #endif  #endif
Line 861 
Line 866 
                 if (debug_level >= 3) {                  if (debug_level >= 3) {
                         sock_dbg(f);                          sock_dbg(f);
                         dbg_puts(": using ");                          dbg_puts(": using ");
                         dbg_putu(p->rate);                          dbg_putu(rate);
                         dbg_puts("Hz sample rate, ");                          dbg_puts("Hz sample rate, ");
                         dbg_putu(f->round);                          dbg_putu(f->round);
                         dbg_puts(" fr block size\n");                          dbg_puts(" fr block size\n");
Line 894 
Line 899 
                 }                  }
 #endif  #endif
         }          }
         if (AMSG_ISSET(p->appbufsz)) {          if (AMSG_ISSET(appbufsz)) {
                 rate = (f->mode & MODE_PLAY) ? f->rpar.rate : f->wpar.rate;                  rate = (f->mode & MODE_PLAY) ? f->rpar.rate : f->wpar.rate;
                 min = 1;                  min = 1;
                 max = 1 + rate / f->dev->round;                  max = 1 + rate / f->dev->round;
                 min *= f->round;                  min *= f->round;
                 max *= f->round;                  max *= f->round;
                 p->appbufsz += f->round - 1;                  appbufsz += f->round - 1;
                 p->appbufsz -= p->appbufsz % f->round;                  appbufsz -= appbufsz % f->round;
                 if (p->appbufsz < min)                  if (appbufsz < min)
                         p->appbufsz = min;                          appbufsz = min;
                 if (p->appbufsz > max)                  if (appbufsz > max)
                         p->appbufsz = max;                          appbufsz = max;
                 f->bufsz = p->appbufsz;                  f->bufsz = appbufsz;
 #ifdef DEBUG  #ifdef DEBUG
                 if (debug_level >= 3) {                  if (debug_level >= 3) {
                         sock_dbg(f);                          sock_dbg(f);
Line 980 
Line 985 
 sock_hello(struct sock *f)  sock_hello(struct sock *f)
 {  {
         struct amsg_hello *p = &f->rmsg.u.hello;          struct amsg_hello *p = &f->rmsg.u.hello;
           unsigned mode;
   
           mode = ntohs(p->mode);
 #ifdef DEBUG  #ifdef DEBUG
         if (debug_level >= 3) {          if (debug_level >= 3) {
                 sock_dbg(f);                  sock_dbg(f);
                 dbg_puts(": hello from <");                  dbg_puts(": hello from <");
                 dbg_puts(p->who);                  dbg_puts(p->who);
                 dbg_puts(">, mode = ");                  dbg_puts(">, mode = ");
                 dbg_putx(p->mode);                  dbg_putx(mode);
                 dbg_puts(", ver ");                  dbg_puts(", ver ");
                 dbg_putu(p->version);                  dbg_putu(p->version);
                 dbg_puts("\n");                  dbg_puts("\n");
Line 1004 
Line 1011 
 #endif  #endif
                 return 0;                  return 0;
         }          }
         switch (p->mode) {          switch (mode) {
         case MODE_MIDIIN:          case MODE_MIDIIN:
         case MODE_MIDIOUT:          case MODE_MIDIOUT:
         case MODE_MIDIOUT | MODE_MIDIIN:          case MODE_MIDIOUT | MODE_MIDIIN:
Line 1017 
Line 1024 
                 if (debug_level >= 1) {                  if (debug_level >= 1) {
                         sock_dbg(f);                          sock_dbg(f);
                         dbg_puts(": ");                          dbg_puts(": ");
                         dbg_putx(p->mode);                          dbg_putx(mode);
                         dbg_puts(": unsupported mode\n");                          dbg_puts(": unsupported mode\n");
                 }                  }
 #endif  #endif
Line 1028 
Line 1035 
                 return 0;                  return 0;
         if (!dev_ref(f->opt->dev))          if (!dev_ref(f->opt->dev))
                 return 0;                  return 0;
         if ((p->mode & MODE_REC) && (f->opt->mode & MODE_MON)) {          if ((mode & MODE_REC) && (f->opt->mode & MODE_MON)) {
                 p->mode &= ~MODE_REC;                  mode &= ~MODE_REC;
                 p->mode |= MODE_MON;                  mode |= MODE_MON;
         }          }
         f->dev = f->opt->dev;          f->dev = f->opt->dev;
         f->mode = (p->mode & f->opt->mode) & f->dev->mode;          f->mode = (mode & f->opt->mode) & f->dev->mode;
 #ifdef DEBUG  #ifdef DEBUG
         if (debug_level >= 3) {          if (debug_level >= 3) {
                 sock_dbg(f);                  sock_dbg(f);
Line 1042 
Line 1049 
                 dbg_puts("\n");                  dbg_puts("\n");
         }          }
 #endif  #endif
         if (f->mode != p->mode) {          if (f->mode != mode) {
 #ifdef DEBUG  #ifdef DEBUG
                 if (debug_level >= 1) {                  if (debug_level >= 1) {
                         sock_dbg(f);                          sock_dbg(f);
Line 1080 
Line 1087 
 {  {
         struct amsg *m = &f->rmsg;          struct amsg *m = &f->rmsg;
         struct abuf *obuf;          struct abuf *obuf;
           unsigned size, ctl;
   
         switch (m->cmd) {          switch (ntohl(m->cmd)) {
         case AMSG_DATA:          case AMSG_DATA:
 #ifdef DEBUG  #ifdef DEBUG
                 if (debug_level >= 4) {                  if (debug_level >= 4) {
Line 1121 
Line 1129 
                         aproc_del(f->pipe.file.rproc);                          aproc_del(f->pipe.file.rproc);
                         return 0;                          return 0;
                 }                  }
                 if (m->u.data.size % obuf->bpf != 0) {                  size = ntohl(m->u.data.size);
                   if (size % obuf->bpf != 0) {
 #ifdef DEBUG  #ifdef DEBUG
                         if (debug_level >= 1) {                          if (debug_level >= 1) {
                                 sock_dbg(f);                                  sock_dbg(f);
Line 1132 
Line 1141 
                         return 0;                          return 0;
                 }                  }
                 f->rstate = SOCK_RDATA;                  f->rstate = SOCK_RDATA;
                 f->rtodo = m->u.data.size / obuf->bpf;                  f->rtodo = size / obuf->bpf;
 #ifdef DEBUG  #ifdef DEBUG
                 if (debug_level >= 2 &&                  if (debug_level >= 2 &&
                     f->pstate != SOCK_MIDI && f->rtodo > f->rmax) {                      f->pstate != SOCK_MIDI && f->rtodo > f->rmax) {
Line 1210 
Line 1219 
                 else                  else
                         f->pstate = SOCK_STOP;                          f->pstate = SOCK_STOP;
                 AMSG_INIT(m);                  AMSG_INIT(m);
                 m->cmd = AMSG_STOP;                  m->cmd = htonl(AMSG_STOP);
                 f->rstate = SOCK_RRET;                  f->rstate = SOCK_RRET;
                 f->rtodo = sizeof(struct amsg);                  f->rtodo = sizeof(struct amsg);
                 break;                  break;
Line 1256 
Line 1265 
                         return 0;                          return 0;
                 }                  }
                 AMSG_INIT(m);                  AMSG_INIT(m);
                 m->cmd = AMSG_GETPAR;                  m->cmd = htonl(AMSG_GETPAR);
                 m->u.par.legacy_mode = f->mode;                  m->u.par.legacy_mode = f->mode;
                 if (f->mode & MODE_PLAY) {                  if (f->mode & MODE_PLAY) {
                         m->u.par.bits = f->rpar.bits;                          m->u.par.bits = f->rpar.bits;
Line 1264 
Line 1273 
                         m->u.par.sig = f->rpar.sig;                          m->u.par.sig = f->rpar.sig;
                         m->u.par.le = f->rpar.le;                          m->u.par.le = f->rpar.le;
                         m->u.par.msb = f->rpar.msb;                          m->u.par.msb = f->rpar.msb;
                         m->u.par.rate = f->rpar.rate;                          m->u.par.rate = htonl(f->rpar.rate);
                         m->u.par.pchan = f->rpar.cmax - f->rpar.cmin + 1;                          m->u.par.pchan = htons(f->rpar.cmax - f->rpar.cmin + 1);
                 }                  }
                 if (f->mode & MODE_RECMASK) {                  if (f->mode & MODE_RECMASK) {
                         m->u.par.bits = f->wpar.bits;                          m->u.par.bits = f->wpar.bits;
Line 1273 
Line 1282 
                         m->u.par.sig = f->wpar.sig;                          m->u.par.sig = f->wpar.sig;
                         m->u.par.le = f->wpar.le;                          m->u.par.le = f->wpar.le;
                         m->u.par.msb = f->wpar.msb;                          m->u.par.msb = f->wpar.msb;
                         m->u.par.rate = f->wpar.rate;                          m->u.par.rate = htonl(f->wpar.rate);
                         m->u.par.rchan = f->wpar.cmax - f->wpar.cmin + 1;                          m->u.par.rchan = htons(f->wpar.cmax - f->wpar.cmin + 1);
                 }                  }
                 m->u.par.appbufsz = f->bufsz;                  m->u.par.appbufsz = htonl(f->bufsz);
                 m->u.par.bufsz =                  m->u.par.bufsz = htonl(
                     f->bufsz + (f->dev->bufsz / f->dev->round) * f->round;                          f->bufsz + (f->dev->bufsz / f->dev->round) * f->round);
                 m->u.par.round = f->round;                  m->u.par.round = htonl(f->round);
                 f->rstate = SOCK_RRET;                  f->rstate = SOCK_RRET;
                 f->rtodo = sizeof(struct amsg);                  f->rtodo = sizeof(struct amsg);
                 break;                  break;
Line 1301 
Line 1310 
                         aproc_del(f->pipe.file.rproc);                          aproc_del(f->pipe.file.rproc);
                         return 0;                          return 0;
                 }                  }
                 if (m->u.vol.ctl > MIDI_MAXCTL) {                  ctl = ntohl(m->u.vol.ctl);
                   if (ctl > MIDI_MAXCTL) {
 #ifdef DEBUG  #ifdef DEBUG
                         if (debug_level >= 1) {                          if (debug_level >= 1) {
                                 sock_dbg(f);                                  sock_dbg(f);
Line 1311 
Line 1321 
                         aproc_del(f->pipe.file.rproc);                          aproc_del(f->pipe.file.rproc);
                         return 0;                          return 0;
                 }                  }
                 sock_setvol(f, m->u.vol.ctl);                  sock_setvol(f, ctl);
                 if (f->slot >= 0)                  if (f->slot >= 0)
                         ctl_slotvol(f->dev->midi, f->slot, m->u.vol.ctl);                          ctl_slotvol(f->dev->midi, f->slot, ctl);
                 f->rtodo = sizeof(struct amsg);                  f->rtodo = sizeof(struct amsg);
                 f->rstate = SOCK_RMSG;                  f->rstate = SOCK_RMSG;
                 break;                  break;
Line 1363 
Line 1373 
                         return 0;                          return 0;
                 }                  }
                 AMSG_INIT(m);                  AMSG_INIT(m);
                 m->cmd = AMSG_ACK;                  m->cmd = htonl(AMSG_ACK);
                 f->rstate = SOCK_RRET;                  f->rstate = SOCK_RRET;
                 f->rtodo = sizeof(struct amsg);                  f->rtodo = sizeof(struct amsg);
                 break;                  break;
Line 1420 
Line 1430 
                 }                  }
 #endif  #endif
                 AMSG_INIT(&f->wmsg);                  AMSG_INIT(&f->wmsg);
                 f->wmsg.cmd = AMSG_POS;                  f->wmsg.cmd = htonl(AMSG_POS);
                 f->wmsg.u.ts.delta = f->startpos;                  f->wmsg.u.ts.delta = htonl(f->startpos);
                 f->rmax += f->startpos;                  f->rmax += f->startpos;
                 f->wtodo = sizeof(struct amsg);                  f->wtodo = sizeof(struct amsg);
                 f->wstate = SOCK_WMSG;                  f->wstate = SOCK_WMSG;
Line 1444 
Line 1454 
                 f->wmax += f->delta;                  f->wmax += f->delta;
                 f->rmax += f->delta;                  f->rmax += f->delta;
                 AMSG_INIT(&f->wmsg);                  AMSG_INIT(&f->wmsg);
                 f->wmsg.cmd = AMSG_MOVE;                  f->wmsg.cmd = htonl(AMSG_MOVE);
                 f->wmsg.u.ts.delta = f->delta;                  f->wmsg.u.ts.delta = htonl(f->delta);
                 f->wtodo = sizeof(struct amsg);                  f->wtodo = sizeof(struct amsg);
                 f->wstate = SOCK_WMSG;                  f->wstate = SOCK_WMSG;
                 f->delta = 0;                  f->delta = 0;
Line 1466 
Line 1476 
                 }                  }
 #endif  #endif
                 AMSG_INIT(&f->wmsg);                  AMSG_INIT(&f->wmsg);
                 f->wmsg.cmd = AMSG_SETVOL;                  f->wmsg.cmd = htonl(AMSG_SETVOL);
                 f->wmsg.u.vol.ctl = f->vol;                  f->wmsg.u.vol.ctl = htonl(f->vol);
                 f->wtodo = sizeof(struct amsg);                  f->wtodo = sizeof(struct amsg);
                 f->wstate = SOCK_WMSG;                  f->wstate = SOCK_WMSG;
                 f->lastvol = f->vol;                  f->lastvol = f->vol;
Line 1514 
Line 1524 
                         size *= ibuf->bpf;                          size *= ibuf->bpf;
                 }                  }
                 AMSG_INIT(&f->wmsg);                  AMSG_INIT(&f->wmsg);
                 f->wmsg.cmd = AMSG_DATA;                  f->wmsg.cmd = htonl(AMSG_DATA);
                 f->wmsg.u.data.size = size;                  f->wmsg.u.data.size = htonl(size);
                 f->wtodo = sizeof(struct amsg);                  f->wtodo = sizeof(struct amsg);
                 f->wstate = SOCK_WMSG;                  f->wstate = SOCK_WMSG;
                 return 1;                  return 1;
Line 1648 
Line 1658 
         case SOCK_WMSG:          case SOCK_WMSG:
                 if (!sock_wmsg(f, &f->wmsg, &f->wtodo))                  if (!sock_wmsg(f, &f->wmsg, &f->wtodo))
                         return 0;                          return 0;
                 if (f->wmsg.cmd != AMSG_DATA) {                  if (ntohl(f->wmsg.cmd) != AMSG_DATA) {
                         f->wstate = SOCK_WIDLE;                          f->wstate = SOCK_WIDLE;
                         f->wtodo = 0xdeadbeef;                          f->wtodo = 0xdeadbeef;
                         break;                          break;
Line 1657 
Line 1667 
                  * XXX: why not set f->wtodo in sock_wmsg() ?                   * XXX: why not set f->wtodo in sock_wmsg() ?
                  */                   */
                 f->wstate = SOCK_WDATA;                  f->wstate = SOCK_WDATA;
                 f->wtodo = f->wmsg.u.data.size /                  f->wtodo = ntohl(f->wmsg.u.data.size) /
                     LIST_FIRST(&f->pipe.file.wproc->ins)->bpf;                      LIST_FIRST(&f->pipe.file.wproc->ins)->bpf;
                 /* PASSTHROUGH */                  /* PASSTHROUGH */
         case SOCK_WDATA:          case SOCK_WDATA:
Legend:
Removed from v.1.58  
changed lines
  Added in v.1.59