qemu/audio/ossaudio.c

   1 /*
   2  * QEMU OSS audio driver
   3  *
   4  * Copyright (c) 2003-2005 Vassili Karpov (malc)
   5  *
   6  * Permission is hereby granted, free of charge, to any person obtaining a copy
   7  * of this software and associated documentation files (the "Software"), to deal
   8  * in the Software without restriction, including without limitation the rights
   9  * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
  10  * copies of the Software, and to permit persons to whom the Software is
  11  * furnished to do so, subject to the following conditions:
  12  *
  13  * The above copyright notice and this permission notice shall be included in
  14  * all copies or substantial portions of the Software.
  15  *
  16  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
  17  * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
  18  * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
  19  * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
  20  * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
  21  * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
  22  * THE SOFTWARE.
  23  */
  24 #include <stdlib.h>
  25 #include <sys/mman.h>
  26 #include <sys/types.h>
  27 #include <sys/ioctl.h>
  28 #include <sys/soundcard.h>
  29 #include "qemu-common.h"
  30 #include "qemu/main-loop.h"
  31 #include "qemu/host-utils.h"
  32 #include "audio.h"
  33 #include "trace.h"
  34
  35 #define AUDIO_CAP "oss"
  36 #include "audio_int.h"
  37
  38 #if defined OSS_GETVERSION && defined SNDCTL_DSP_POLICY
  39 #define USE_DSP_POLICY
  40 #endif
  41
  42 typedef struct OSSConf {
  43     int try_mmap;
  44     int nfrags;
  45     int fragsize;
  46     const char *devpath_out;
  47     const char *devpath_in;
  48     int exclusive;
  49     int policy;
  50 } OSSConf;
  51
  52 typedef struct OSSVoiceOut {
  53     HWVoiceOut hw;
  54     void *pcm_buf;
  55     int fd;
  56     int wpos;
  57     int nfrags;
  58     int fragsize;
  59     int mmapped;
  60     int pending;
  61     OSSConf *conf;
  62 } OSSVoiceOut;
  63
  64 typedef struct OSSVoiceIn {
  65     HWVoiceIn hw;
  66     void *pcm_buf;
  67     int fd;
  68     int nfrags;
  69     int fragsize;
  70     OSSConf *conf;
  71 } OSSVoiceIn;
  72
  73 struct oss_params {
  74     int freq;
  75     audfmt_e fmt;
  76     int nchannels;
  77     int nfrags;
  78     int fragsize;
  79 };
  80
  81 static void GCC_FMT_ATTR (2, 3) oss_logerr (int err, const char *fmt, ...)
  82 {
  83     va_list ap;
  84
  85     va_start (ap, fmt);
  86     AUD_vlog (AUDIO_CAP, fmt, ap);
  87     va_end (ap);
  88
  89     AUD_log (AUDIO_CAP, "Reason: %s\n", strerror (err));
  90 }
  91
  92 static void GCC_FMT_ATTR (3, 4) oss_logerr2 (
  93     int err,
  94     const char *typ,
  95     const char *fmt,
  96     ...
  97     )
  98 {
  99     va_list ap;
 100
 101     AUD_log (AUDIO_CAP, "Could not initialize %s\n", typ);
 102
 103     va_start (ap, fmt);
 104     AUD_vlog (AUDIO_CAP, fmt, ap);
 105     va_end (ap);
 106
 107     AUD_log (AUDIO_CAP, "Reason: %s\n", strerror (err));
 108 }
 109
 110 static void oss_anal_close (int *fdp)
 111 {
 112     int err;
 113
 114     qemu_set_fd_handler (*fdp, NULL, NULL, NULL);
 115     err = close (*fdp);
 116     if (err) {
 117         oss_logerr (errno, "Failed to close file(fd=%d)\n", *fdp);
 118     }
 119     *fdp = -1;
 120 }
 121
 122 static void oss_helper_poll_out (void *opaque)
 123 {
 124     (void) opaque;
 125     audio_run ("oss_poll_out");
 126 }
 127
 128 static void oss_helper_poll_in (void *opaque)
 129 {
 130     (void) opaque;
 131     audio_run ("oss_poll_in");
 132 }
 133
 134 static void oss_poll_out (HWVoiceOut *hw)
 135 {
 136     OSSVoiceOut *oss = (OSSVoiceOut *) hw;
 137
 138     qemu_set_fd_handler (oss->fd, NULL, oss_helper_poll_out, NULL);
 139 }
 140
 141 static void oss_poll_in (HWVoiceIn *hw)
 142 {
 143     OSSVoiceIn *oss = (OSSVoiceIn *) hw;
 144
 145     qemu_set_fd_handler (oss->fd, oss_helper_poll_in, NULL, NULL);
 146 }
 147
 148 static int oss_write (SWVoiceOut *sw, void *buf, int len)
 149 {
 150     return audio_pcm_sw_write (sw, buf, len);
 151 }
 152
 153 static int aud_to_ossfmt (audfmt_e fmt, int endianness)
 154 {
 155     switch (fmt) {
 156     case AUD_FMT_S8:
 157         return AFMT_S8;
 158
 159     case AUD_FMT_U8:
 160         return AFMT_U8;
 161
 162     case AUD_FMT_S16:
 163         if (endianness) {
 164             return AFMT_S16_BE;
 165         }
 166         else {
 167             return AFMT_S16_LE;
 168         }
 169
 170     case AUD_FMT_U16:
 171         if (endianness) {
 172             return AFMT_U16_BE;
 173         }
 174         else {
 175             return AFMT_U16_LE;
 176         }
 177
 178     default:
 179         dolog ("Internal logic error: Bad audio format %d\n", fmt);
 180 #ifdef DEBUG_AUDIO
 181         abort ();
 182 #endif
 183         return AFMT_U8;
 184     }
 185 }
 186
 187 static int oss_to_audfmt (int ossfmt, audfmt_e *fmt, int *endianness)
 188 {
 189     switch (ossfmt) {
 190     case AFMT_S8:
 191         *endianness = 0;
 192         *fmt = AUD_FMT_S8;
 193         break;
 194
 195     case AFMT_U8:
 196         *endianness = 0;
 197         *fmt = AUD_FMT_U8;
 198         break;
 199
 200     case AFMT_S16_LE:
 201         *endianness = 0;
 202         *fmt = AUD_FMT_S16;
 203         break;
 204
 205     case AFMT_U16_LE:
 206         *endianness = 0;
 207         *fmt = AUD_FMT_U16;
 208         break;
 209
 210     case AFMT_S16_BE:
 211         *endianness = 1;
 212         *fmt = AUD_FMT_S16;
 213         break;
 214
 215     case AFMT_U16_BE:
 216         *endianness = 1;
 217         *fmt = AUD_FMT_U16;
 218         break;
 219
 220     default:
 221         dolog ("Unrecognized audio format %d\n", ossfmt);
 222         return -1;
 223     }
 224
 225     return 0;
 226 }
 227
 228 #if defined DEBUG_MISMATCHES || defined DEBUG
 229 static void oss_dump_info (struct oss_params *req, struct oss_params *obt)
 230 {
 231     dolog ("parameter | requested value | obtained value\n");
 232     dolog ("format    |      %10d |     %10d\n", req->fmt, obt->fmt);
 233     dolog ("channels  |      %10d |     %10d\n",
 234            req->nchannels, obt->nchannels);
 235     dolog ("frequency |      %10d |     %10d\n", req->freq, obt->freq);
 236     dolog ("nfrags    |      %10d |     %10d\n", req->nfrags, obt->nfrags);
 237     dolog ("fragsize  |      %10d |     %10d\n",
 238            req->fragsize, obt->fragsize);
 239 }
 240 #endif
 241
 242 #ifdef USE_DSP_POLICY
 243 static int oss_get_version (int fd, int *version, const char *typ)
 244 {
 245     if (ioctl (fd, OSS_GETVERSION, &version)) {
 246 #if defined(__FreeBSD__) || defined(__FreeBSD_kernel__)
 247         /*
 248          * Looks like atm (20100109) FreeBSD knows OSS_GETVERSION
 249          * since 7.x, but currently only on the mixer device (or in
 250          * the Linuxolator), and in the native version that part of
 251          * the code is in fact never reached so the ioctl fails anyway.
 252          * Until this is fixed, just check the errno and if its what
 253          * FreeBSD's sound drivers return atm assume they are new enough.
 254          */
 255         if (errno == EINVAL) {
 256             *version = 0x040000;
 257             return 0;
 258         }
 259 #endif
 260         oss_logerr2 (errno, typ, "Failed to get OSS version\n");
 261         return -1;
 262     }
 263     return 0;
 264 }
 265 #endif
 266
 267 static int oss_open (int in, struct oss_params *req,
 268                      struct oss_params *obt, int *pfd, OSSConf* conf)
 269 {
 270     int fd;
 271     int oflags = conf->exclusive ? O_EXCL : 0;
 272     audio_buf_info abinfo;
 273     int fmt, freq, nchannels;
 274     int setfragment = 1;
 275     const char *dspname = in ? conf->devpath_in : conf->devpath_out;
 276     const char *typ = in ? "ADC" : "DAC";
 277
 278     /* Kludge needed to have working mmap on Linux */
 279     oflags |= conf->try_mmap ? O_RDWR : (in ? O_RDONLY : O_WRONLY);
 280
 281     fd = open (dspname, oflags | O_NONBLOCK);
 282     if (-1 == fd) {
 283         oss_logerr2 (errno, typ, "Failed to open `%s'\n", dspname);
 284         return -1;
 285     }
 286
 287     freq = req->freq;
 288     nchannels = req->nchannels;
 289     fmt = req->fmt;
 290
 291     if (ioctl (fd, SNDCTL_DSP_SAMPLESIZE, &fmt)) {
 292         oss_logerr2 (errno, typ, "Failed to set sample size %d\n", req->fmt);
 293         goto err;
 294     }
 295
 296     if (ioctl (fd, SNDCTL_DSP_CHANNELS, &nchannels)) {
 297         oss_logerr2 (errno, typ, "Failed to set number of channels %d\n",
 298                      req->nchannels);
 299         goto err;
 300     }
 301
 302     if (ioctl (fd, SNDCTL_DSP_SPEED, &freq)) {
 303         oss_logerr2 (errno, typ, "Failed to set frequency %d\n", req->freq);
 304         goto err;
 305     }
 306
 307     if (ioctl (fd, SNDCTL_DSP_NONBLOCK, NULL)) {
 308         oss_logerr2 (errno, typ, "Failed to set non-blocking mode\n");
 309         goto err;
 310     }
 311
 312 #ifdef USE_DSP_POLICY
 313     if (conf->policy >= 0) {
 314         int version;
 315
 316         if (!oss_get_version (fd, &version, typ)) {
 317             trace_oss_version(version);
 318
 319             if (version >= 0x040000) {
 320                 int policy = conf->policy;
 321                 if (ioctl (fd, SNDCTL_DSP_POLICY, &policy)) {
 322                     oss_logerr2 (errno, typ,
 323                                  "Failed to set timing policy to %d\n",
 324                                  conf->policy);
 325                     goto err;
 326                 }
 327                 setfragment = 0;
 328             }
 329         }
 330     }
 331 #endif
 332
 333     if (setfragment) {
 334         int mmmmssss = (req->nfrags << 16) | ctz32 (req->fragsize);
 335         if (ioctl (fd, SNDCTL_DSP_SETFRAGMENT, &mmmmssss)) {
 336             oss_logerr2 (errno, typ, "Failed to set buffer length (%d, %d)\n",
 337                          req->nfrags, req->fragsize);
 338             goto err;
 339         }
 340     }
 341
 342     if (ioctl (fd, in ? SNDCTL_DSP_GETISPACE : SNDCTL_DSP_GETOSPACE, &abinfo)) {
 343         oss_logerr2 (errno, typ, "Failed to get buffer length\n");
 344         goto err;
 345     }
 346
 347     if (!abinfo.fragstotal || !abinfo.fragsize) {
 348         AUD_log (AUDIO_CAP, "Returned bogus buffer information(%d, %d) for %s\n",
 349                  abinfo.fragstotal, abinfo.fragsize, typ);
 350         goto err;
 351     }
 352
 353     obt->fmt = fmt;
 354     obt->nchannels = nchannels;
 355     obt->freq = freq;
 356     obt->nfrags = abinfo.fragstotal;
 357     obt->fragsize = abinfo.fragsize;
 358     *pfd = fd;
 359
 360 #ifdef DEBUG_MISMATCHES
 361     if ((req->fmt != obt->fmt) ||
 362         (req->nchannels != obt->nchannels) ||
 363         (req->freq != obt->freq) ||
 364         (req->fragsize != obt->fragsize) ||
 365         (req->nfrags != obt->nfrags)) {
 366         dolog ("Audio parameters mismatch\n");
 367         oss_dump_info (req, obt);
 368     }
 369 #endif
 370
 371 #ifdef DEBUG
 372     oss_dump_info (req, obt);
 373 #endif
 374     return 0;
 375
 376  err:
 377     oss_anal_close (&fd);
 378     return -1;
 379 }
 380
 381 static void oss_write_pending (OSSVoiceOut *oss)
 382 {
 383     HWVoiceOut *hw = &oss->hw;
 384
 385     if (oss->mmapped) {
 386         return;
 387     }
 388
 389     while (oss->pending) {
 390         int samples_written;
 391         ssize_t bytes_written;
 392         int samples_till_end = hw->samples - oss->wpos;
 393         int samples_to_write = audio_MIN (oss->pending, samples_till_end);
 394         int bytes_to_write = samples_to_write << hw->info.shift;
 395         void *pcm = advance (oss->pcm_buf, oss->wpos << hw->info.shift);
 396
 397         bytes_written = write (oss->fd, pcm, bytes_to_write);
 398         if (bytes_written < 0) {
 399             if (errno != EAGAIN) {
 400                 oss_logerr (errno, "failed to write %d bytes\n",
 401                             bytes_to_write);
 402             }
 403             break;
 404         }
 405
 406         if (bytes_written & hw->info.align) {
 407             dolog ("misaligned write asked for %d, but got %zd\n",
 408                    bytes_to_write, bytes_written);
 409             return;
 410         }
 411
 412         samples_written = bytes_written >> hw->info.shift;
 413         oss->pending -= samples_written;
 414         oss->wpos = (oss->wpos + samples_written) % hw->samples;
 415         if (bytes_written - bytes_to_write) {
 416             break;
 417         }
 418     }
 419 }
 420
 421 static int oss_run_out (HWVoiceOut *hw, int live)
 422 {
 423     OSSVoiceOut *oss = (OSSVoiceOut *) hw;
 424     int err, decr;
 425     struct audio_buf_info abinfo;
 426     struct count_info cntinfo;
 427     int bufsize;
 428
 429     bufsize = hw->samples << hw->info.shift;
 430
 431     if (oss->mmapped) {
 432         int bytes, pos;
 433
 434         err = ioctl (oss->fd, SNDCTL_DSP_GETOPTR, &cntinfo);
 435         if (err < 0) {
 436             oss_logerr (errno, "SNDCTL_DSP_GETOPTR failed\n");
 437             return 0;
 438         }
 439
 440         pos = hw->rpos << hw->info.shift;
 441         bytes = audio_ring_dist (cntinfo.ptr, pos, bufsize);
 442         decr = audio_MIN (bytes >> hw->info.shift, live);
 443     }
 444     else {
 445         err = ioctl (oss->fd, SNDCTL_DSP_GETOSPACE, &abinfo);
 446         if (err < 0) {
 447             oss_logerr (errno, "SNDCTL_DSP_GETOPTR failed\n");
 448             return 0;
 449         }
 450
 451         if (abinfo.bytes > bufsize) {
 452             trace_oss_invalid_available_size(abinfo.bytes, bufsize);
 453             abinfo.bytes = bufsize;
 454         }
 455
 456         if (abinfo.bytes < 0) {
 457             trace_oss_invalid_available_size(abinfo.bytes, bufsize);
 458             return 0;
 459         }
 460
 461         decr = audio_MIN (abinfo.bytes >> hw->info.shift, live);
 462         if (!decr) {
 463             return 0;
 464         }
 465     }
 466
 467     decr = audio_pcm_hw_clip_out (hw, oss->pcm_buf, decr, oss->pending);
 468     oss->pending += decr;
 469     oss_write_pending (oss);
 470
 471     return decr;
 472 }
 473
 474 static void oss_fini_out (HWVoiceOut *hw)
 475 {
 476     int err;
 477     OSSVoiceOut *oss = (OSSVoiceOut *) hw;
 478
 479     ldebug ("oss_fini\n");
 480     oss_anal_close (&oss->fd);
 481
 482     if (oss->pcm_buf) {
 483         if (oss->mmapped) {
 484             err = munmap (oss->pcm_buf, hw->samples << hw->info.shift);
 485             if (err) {
 486                 oss_logerr (errno, "Failed to unmap buffer %p, size %d\n",
 487                             oss->pcm_buf, hw->samples << hw->info.shift);
 488             }
 489         }
 490         else {
 491             g_free (oss->pcm_buf);
 492         }
 493         oss->pcm_buf = NULL;
 494     }
 495 }
 496
 497 static int oss_init_out(HWVoiceOut *hw, struct audsettings *as,
 498                         void *drv_opaque)
 499 {
 500     OSSVoiceOut *oss = (OSSVoiceOut *) hw;
 501     struct oss_params req, obt;
 502     int endianness;
 503     int err;
 504     int fd;
 505     audfmt_e effective_fmt;
 506     struct audsettings obt_as;
 507     OSSConf *conf = drv_opaque;
 508
 509     oss->fd = -1;
 510
 511     req.fmt = aud_to_ossfmt (as->fmt, as->endianness);
 512     req.freq = as->freq;
 513     req.nchannels = as->nchannels;
 514     req.fragsize = conf->fragsize;
 515     req.nfrags = conf->nfrags;
 516
 517     if (oss_open (0, &req, &obt, &fd, conf)) {
 518         return -1;
 519     }
 520
 521     err = oss_to_audfmt (obt.fmt, &effective_fmt, &endianness);
 522     if (err) {
 523         oss_anal_close (&fd);
 524         return -1;
 525     }
 526
 527     obt_as.freq = obt.freq;
 528     obt_as.nchannels = obt.nchannels;
 529     obt_as.fmt = effective_fmt;
 530     obt_as.endianness = endianness;
 531
 532     audio_pcm_init_info (&hw->info, &obt_as);
 533     oss->nfrags = obt.nfrags;
 534     oss->fragsize = obt.fragsize;
 535
 536     if (obt.nfrags * obt.fragsize & hw->info.align) {
 537         dolog ("warning: Misaligned DAC buffer, size %d, alignment %d\n",
 538                obt.nfrags * obt.fragsize, hw->info.align + 1);
 539     }
 540
 541     hw->samples = (obt.nfrags * obt.fragsize) >> hw->info.shift;
 542
 543     oss->mmapped = 0;
 544     if (conf->try_mmap) {
 545         oss->pcm_buf = mmap (
 546             NULL,
 547             hw->samples << hw->info.shift,
 548             PROT_READ | PROT_WRITE,
 549             MAP_SHARED,
 550             fd,
 551             0
 552             );
 553         if (oss->pcm_buf == MAP_FAILED) {
 554             oss_logerr (errno, "Failed to map %d bytes of DAC\n",
 555                         hw->samples << hw->info.shift);
 556         }
 557         else {
 558             int err;
 559             int trig = 0;
 560             if (ioctl (fd, SNDCTL_DSP_SETTRIGGER, &trig) < 0) {
 561                 oss_logerr (errno, "SNDCTL_DSP_SETTRIGGER 0 failed\n");
 562             }
 563             else {
 564                 trig = PCM_ENABLE_OUTPUT;
 565                 if (ioctl (fd, SNDCTL_DSP_SETTRIGGER, &trig) < 0) {
 566                     oss_logerr (
 567                         errno,
 568                         "SNDCTL_DSP_SETTRIGGER PCM_ENABLE_OUTPUT failed\n"
 569                         );
 570                 }
 571                 else {
 572                     oss->mmapped = 1;
 573                 }
 574             }
 575
 576             if (!oss->mmapped) {
 577                 err = munmap (oss->pcm_buf, hw->samples << hw->info.shift);
 578                 if (err) {
 579                     oss_logerr (errno, "Failed to unmap buffer %p size %d\n",
 580                                 oss->pcm_buf, hw->samples << hw->info.shift);
 581                 }
 582             }
 583         }
 584     }
 585
 586     if (!oss->mmapped) {
 587         oss->pcm_buf = audio_calloc (
 588             AUDIO_FUNC,
 589             hw->samples,
 590             1 << hw->info.shift
 591             );
 592         if (!oss->pcm_buf) {
 593             dolog (
 594                 "Could not allocate DAC buffer (%d samples, each %d bytes)\n",
 595                 hw->samples,
 596                 1 << hw->info.shift
 597                 );
 598             oss_anal_close (&fd);
 599             return -1;
 600         }
 601     }
 602
 603     oss->fd = fd;
 604     oss->conf = conf;
 605     return 0;
 606 }
 607
 608 static int oss_ctl_out (HWVoiceOut *hw, int cmd, ...)
 609 {
 610     int trig;
 611     OSSVoiceOut *oss = (OSSVoiceOut *) hw;
 612
 613     switch (cmd) {
 614     case VOICE_ENABLE:
 615         {
 616             va_list ap;
 617             int poll_mode;
 618
 619             va_start (ap, cmd);
 620             poll_mode = va_arg (ap, int);
 621             va_end (ap);
 622
 623             ldebug ("enabling voice\n");
 624             if (poll_mode) {
 625                 oss_poll_out (hw);
 626                 poll_mode = 0;
 627             }
 628             hw->poll_mode = poll_mode;
 629
 630             if (!oss->mmapped) {
 631                 return 0;
 632             }
 633
 634             audio_pcm_info_clear_buf (&hw->info, oss->pcm_buf, hw->samples);
 635             trig = PCM_ENABLE_OUTPUT;
 636             if (ioctl (oss->fd, SNDCTL_DSP_SETTRIGGER, &trig) < 0) {
 637                 oss_logerr (
 638                     errno,
 639                     "SNDCTL_DSP_SETTRIGGER PCM_ENABLE_OUTPUT failed\n"
 640                     );
 641                 return -1;
 642             }
 643         }
 644         break;
 645
 646     case VOICE_DISABLE:
 647         if (hw->poll_mode) {
 648             qemu_set_fd_handler (oss->fd, NULL, NULL, NULL);
 649             hw->poll_mode = 0;
 650         }
 651
 652         if (!oss->mmapped) {
 653             return 0;
 654         }
 655
 656         ldebug ("disabling voice\n");
 657         trig = 0;
 658         if (ioctl (oss->fd, SNDCTL_DSP_SETTRIGGER, &trig) < 0) {
 659             oss_logerr (errno, "SNDCTL_DSP_SETTRIGGER 0 failed\n");
 660             return -1;
 661         }
 662         break;
 663     }
 664     return 0;
 665 }
 666
 667 static int oss_init_in(HWVoiceIn *hw, struct audsettings *as, void *drv_opaque)
 668 {
 669     OSSVoiceIn *oss = (OSSVoiceIn *) hw;
 670     struct oss_params req, obt;
 671     int endianness;
 672     int err;
 673     int fd;
 674     audfmt_e effective_fmt;
 675     struct audsettings obt_as;
 676     OSSConf *conf = drv_opaque;
 677
 678     oss->fd = -1;
 679
 680     req.fmt = aud_to_ossfmt (as->fmt, as->endianness);
 681     req.freq = as->freq;
 682     req.nchannels = as->nchannels;
 683     req.fragsize = conf->fragsize;
 684     req.nfrags = conf->nfrags;
 685     if (oss_open (1, &req, &obt, &fd, conf)) {
 686         return -1;
 687     }
 688
 689     err = oss_to_audfmt (obt.fmt, &effective_fmt, &endianness);
 690     if (err) {
 691         oss_anal_close (&fd);
 692         return -1;
 693     }
 694
 695     obt_as.freq = obt.freq;
 696     obt_as.nchannels = obt.nchannels;
 697     obt_as.fmt = effective_fmt;
 698     obt_as.endianness = endianness;
 699
 700     audio_pcm_init_info (&hw->info, &obt_as);
 701     oss->nfrags = obt.nfrags;
 702     oss->fragsize = obt.fragsize;
 703
 704     if (obt.nfrags * obt.fragsize & hw->info.align) {
 705         dolog ("warning: Misaligned ADC buffer, size %d, alignment %d\n",
 706                obt.nfrags * obt.fragsize, hw->info.align + 1);
 707     }
 708
 709     hw->samples = (obt.nfrags * obt.fragsize) >> hw->info.shift;
 710     oss->pcm_buf = audio_calloc (AUDIO_FUNC, hw->samples, 1 << hw->info.shift);
 711     if (!oss->pcm_buf) {
 712         dolog ("Could not allocate ADC buffer (%d samples, each %d bytes)\n",
 713                hw->samples, 1 << hw->info.shift);
 714         oss_anal_close (&fd);
 715         return -1;
 716     }
 717
 718     oss->fd = fd;
 719     oss->conf = conf;
 720     return 0;
 721 }
 722
 723 static void oss_fini_in (HWVoiceIn *hw)
 724 {
 725     OSSVoiceIn *oss = (OSSVoiceIn *) hw;
 726
 727     oss_anal_close (&oss->fd);
 728
 729     g_free(oss->pcm_buf);
 730     oss->pcm_buf = NULL;
 731 }
 732
 733 static int oss_run_in (HWVoiceIn *hw)
 734 {
 735     OSSVoiceIn *oss = (OSSVoiceIn *) hw;
 736     int hwshift = hw->info.shift;
 737     int i;
 738     int live = audio_pcm_hw_get_live_in (hw);
 739     int dead = hw->samples - live;
 740     size_t read_samples = 0;
 741     struct {
 742         int add;
 743         int len;
 744     } bufs[2] = {
 745         { .add = hw->wpos, .len = 0 },
 746         { .add = 0,        .len = 0 }
 747     };
 748
 749     if (!dead) {
 750         return 0;
 751     }
 752
 753     if (hw->wpos + dead > hw->samples) {
 754         bufs[0].len = (hw->samples - hw->wpos) << hwshift;
 755         bufs[1].len = (dead - (hw->samples - hw->wpos)) << hwshift;
 756     }
 757     else {
 758         bufs[0].len = dead << hwshift;
 759     }
 760
 761     for (i = 0; i < 2; ++i) {
 762         ssize_t nread;
 763
 764         if (bufs[i].len) {
 765             void *p = advance (oss->pcm_buf, bufs[i].add << hwshift);
 766             nread = read (oss->fd, p, bufs[i].len);
 767
 768             if (nread > 0) {
 769                 if (nread & hw->info.align) {
 770                     dolog ("warning: Misaligned read %zd (requested %d), "
 771                            "alignment %d\n", nread, bufs[i].add << hwshift,
 772                            hw->info.align + 1);
 773                 }
 774                 read_samples += nread >> hwshift;
 775                 hw->conv (hw->conv_buf + bufs[i].add, p, nread >> hwshift);
 776             }
 777
 778             if (bufs[i].len - nread) {
 779                 if (nread == -1) {
 780                     switch (errno) {
 781                     case EINTR:
 782                     case EAGAIN:
 783                         break;
 784                     default:
 785                         oss_logerr (
 786                             errno,
 787                             "Failed to read %d bytes of audio (to %p)\n",
 788                             bufs[i].len, p
 789                             );
 790                         break;
 791                     }
 792                 }
 793                 break;
 794             }
 795         }
 796     }
 797
 798     hw->wpos = (hw->wpos + read_samples) % hw->samples;
 799     return read_samples;
 800 }
 801
 802 static int oss_read (SWVoiceIn *sw, void *buf, int size)
 803 {
 804     return audio_pcm_sw_read (sw, buf, size);
 805 }
 806
 807 static int oss_ctl_in (HWVoiceIn *hw, int cmd, ...)
 808 {
 809     OSSVoiceIn *oss = (OSSVoiceIn *) hw;
 810
 811     switch (cmd) {
 812     case VOICE_ENABLE:
 813         {
 814             va_list ap;
 815             int poll_mode;
 816
 817             va_start (ap, cmd);
 818             poll_mode = va_arg (ap, int);
 819             va_end (ap);
 820
 821             if (poll_mode) {
 822                 oss_poll_in (hw);
 823                 poll_mode = 0;
 824             }
 825             hw->poll_mode = poll_mode;
 826         }
 827         break;
 828
 829     case VOICE_DISABLE:
 830         if (hw->poll_mode) {
 831             hw->poll_mode = 0;
 832             qemu_set_fd_handler (oss->fd, NULL, NULL, NULL);
 833         }
 834         break;
 835     }
 836     return 0;
 837 }
 838
 839 static OSSConf glob_conf = {
 840     .try_mmap = 0,
 841     .nfrags = 4,
 842     .fragsize = 4096,
 843     .devpath_out = "/dev/dsp",
 844     .devpath_in = "/dev/dsp",
 845     .exclusive = 0,
 846     .policy = 5
 847 };
 848
 849 static void *oss_audio_init (void)
 850 {
 851     OSSConf *conf = g_malloc(sizeof(OSSConf));
 852     *conf = glob_conf;
 853
 854     if (access(conf->devpath_in, R_OK | W_OK) < 0 ||
 855         access(conf->devpath_out, R_OK | W_OK) < 0) {
 856         g_free(conf);
 857         return NULL;
 858     }
 859     return conf;
 860 }
 861
 862 static void oss_audio_fini (void *opaque)
 863 {
 864     g_free(opaque);
 865 }
 866
 867 static struct audio_option oss_options[] = {
 868     {
 869         .name  = "FRAGSIZE",
 870         .tag   = AUD_OPT_INT,
 871         .valp  = &glob_conf.fragsize,
 872         .descr = "Fragment size in bytes"
 873     },
 874     {
 875         .name  = "NFRAGS",
 876         .tag   = AUD_OPT_INT,
 877         .valp  = &glob_conf.nfrags,
 878         .descr = "Number of fragments"
 879     },
 880     {
 881         .name  = "MMAP",
 882         .tag   = AUD_OPT_BOOL,
 883         .valp  = &glob_conf.try_mmap,
 884         .descr = "Try using memory mapped access"
 885     },
 886     {
 887         .name  = "DAC_DEV",
 888         .tag   = AUD_OPT_STR,
 889         .valp  = &glob_conf.devpath_out,
 890         .descr = "Path to DAC device"
 891     },
 892     {
 893         .name  = "ADC_DEV",
 894         .tag   = AUD_OPT_STR,
 895         .valp  = &glob_conf.devpath_in,
 896         .descr = "Path to ADC device"
 897     },
 898     {
 899         .name  = "EXCLUSIVE",
 900         .tag   = AUD_OPT_BOOL,
 901         .valp  = &glob_conf.exclusive,
 902         .descr = "Open device in exclusive mode (vmix wont work)"
 903     },
 904 #ifdef USE_DSP_POLICY
 905     {
 906         .name  = "POLICY",
 907         .tag   = AUD_OPT_INT,
 908         .valp  = &glob_conf.policy,
 909         .descr = "Set the timing policy of the device, -1 to use fragment mode",
 910     },
 911 #endif
 912     { /* End of list */ }
 913 };
 914
 915 static struct audio_pcm_ops oss_pcm_ops = {
 916     .init_out = oss_init_out,
 917     .fini_out = oss_fini_out,
 918     .run_out  = oss_run_out,
 919     .write    = oss_write,
 920     .ctl_out  = oss_ctl_out,
 921
 922     .init_in  = oss_init_in,
 923     .fini_in  = oss_fini_in,
 924     .run_in   = oss_run_in,
 925     .read     = oss_read,
 926     .ctl_in   = oss_ctl_in
 927 };
 928
 929 struct audio_driver oss_audio_driver = {
 930     .name           = "oss",
 931     .descr          = "OSS http://www.opensound.com",
 932     .options        = oss_options,
 933     .init           = oss_audio_init,
 934     .fini           = oss_audio_fini,
 935     .pcm_ops        = &oss_pcm_ops,
 936     .can_be_default = 1,
 937     .max_voices_out = INT_MAX,
 938     .max_voices_in  = INT_MAX,
 939     .voice_size_out = sizeof (OSSVoiceOut),
 940     .voice_size_in  = sizeof (OSSVoiceIn)
 941 };