1 /* public domain */ 2 #include "qemu/osdep.h" 3 #include "qemu-common.h" 4 #include "audio.h" 5 6 #include <pulse/pulseaudio.h> 7 8 #define AUDIO_CAP "pulseaudio" 9 #include "audio_int.h" 10 #include "audio_pt_int.h" 11 12 typedef struct { 13 int samples; 14 char *server; 15 char *sink; 16 char *source; 17 } PAConf; 18 19 typedef struct { 20 PAConf conf; 21 pa_threaded_mainloop *mainloop; 22 pa_context *context; 23 } paaudio; 24 25 typedef struct { 26 HWVoiceOut hw; 27 int done; 28 int live; 29 int decr; 30 int rpos; 31 pa_stream *stream; 32 void *pcm_buf; 33 struct audio_pt pt; 34 paaudio *g; 35 } PAVoiceOut; 36 37 typedef struct { 38 HWVoiceIn hw; 39 int done; 40 int dead; 41 int incr; 42 int wpos; 43 pa_stream *stream; 44 void *pcm_buf; 45 struct audio_pt pt; 46 const void *read_data; 47 size_t read_index, read_length; 48 paaudio *g; 49 } PAVoiceIn; 50 51 static void qpa_audio_fini(void *opaque); 52 53 static void GCC_FMT_ATTR (2, 3) qpa_logerr (int err, const char *fmt, ...) 54 { 55 va_list ap; 56 57 va_start (ap, fmt); 58 AUD_vlog (AUDIO_CAP, fmt, ap); 59 va_end (ap); 60 61 AUD_log (AUDIO_CAP, "Reason: %s\n", pa_strerror (err)); 62 } 63 64 #ifndef PA_CONTEXT_IS_GOOD 65 static inline int PA_CONTEXT_IS_GOOD(pa_context_state_t x) 66 { 67 return 68 x == PA_CONTEXT_CONNECTING || 69 x == PA_CONTEXT_AUTHORIZING || 70 x == PA_CONTEXT_SETTING_NAME || 71 x == PA_CONTEXT_READY; 72 } 73 #endif 74 75 #ifndef PA_STREAM_IS_GOOD 76 static inline int PA_STREAM_IS_GOOD(pa_stream_state_t x) 77 { 78 return 79 x == PA_STREAM_CREATING || 80 x == PA_STREAM_READY; 81 } 82 #endif 83 84 #define CHECK_SUCCESS_GOTO(c, rerror, expression, label) \ 85 do { \ 86 if (!(expression)) { \ 87 if (rerror) { \ 88 *(rerror) = pa_context_errno ((c)->context); \ 89 } \ 90 goto label; \ 91 } \ 92 } while (0) 93 94 #define CHECK_DEAD_GOTO(c, stream, rerror, label) \ 95 do { \ 96 if (!(c)->context || !PA_CONTEXT_IS_GOOD (pa_context_get_state((c)->context)) || \ 97 !(stream) || !PA_STREAM_IS_GOOD (pa_stream_get_state ((stream)))) { \ 98 if (((c)->context && pa_context_get_state ((c)->context) == PA_CONTEXT_FAILED) || \ 99 ((stream) && pa_stream_get_state ((stream)) == PA_STREAM_FAILED)) { \ 100 if (rerror) { \ 101 *(rerror) = pa_context_errno ((c)->context); \ 102 } \ 103 } else { \ 104 if (rerror) { \ 105 *(rerror) = PA_ERR_BADSTATE; \ 106 } \ 107 } \ 108 goto label; \ 109 } \ 110 } while (0) 111 112 static int qpa_simple_read (PAVoiceIn *p, void *data, size_t length, int *rerror) 113 { 114 paaudio *g = p->g; 115 116 pa_threaded_mainloop_lock (g->mainloop); 117 118 CHECK_DEAD_GOTO (g, p->stream, rerror, unlock_and_fail); 119 120 while (length > 0) { 121 size_t l; 122 123 while (!p->read_data) { 124 int r; 125 126 r = pa_stream_peek (p->stream, &p->read_data, &p->read_length); 127 CHECK_SUCCESS_GOTO (g, rerror, r == 0, unlock_and_fail); 128 129 if (!p->read_data) { 130 pa_threaded_mainloop_wait (g->mainloop); 131 CHECK_DEAD_GOTO (g, p->stream, rerror, unlock_and_fail); 132 } else { 133 p->read_index = 0; 134 } 135 } 136 137 l = p->read_length < length ? p->read_length : length; 138 memcpy (data, (const uint8_t *) p->read_data+p->read_index, l); 139 140 data = (uint8_t *) data + l; 141 length -= l; 142 143 p->read_index += l; 144 p->read_length -= l; 145 146 if (!p->read_length) { 147 int r; 148 149 r = pa_stream_drop (p->stream); 150 p->read_data = NULL; 151 p->read_length = 0; 152 p->read_index = 0; 153 154 CHECK_SUCCESS_GOTO (g, rerror, r == 0, unlock_and_fail); 155 } 156 } 157 158 pa_threaded_mainloop_unlock (g->mainloop); 159 return 0; 160 161 unlock_and_fail: 162 pa_threaded_mainloop_unlock (g->mainloop); 163 return -1; 164 } 165 166 static int qpa_simple_write (PAVoiceOut *p, const void *data, size_t length, int *rerror) 167 { 168 paaudio *g = p->g; 169 170 pa_threaded_mainloop_lock (g->mainloop); 171 172 CHECK_DEAD_GOTO (g, p->stream, rerror, unlock_and_fail); 173 174 while (length > 0) { 175 size_t l; 176 int r; 177 178 while (!(l = pa_stream_writable_size (p->stream))) { 179 pa_threaded_mainloop_wait (g->mainloop); 180 CHECK_DEAD_GOTO (g, p->stream, rerror, unlock_and_fail); 181 } 182 183 CHECK_SUCCESS_GOTO (g, rerror, l != (size_t) -1, unlock_and_fail); 184 185 if (l > length) { 186 l = length; 187 } 188 189 r = pa_stream_write (p->stream, data, l, NULL, 0LL, PA_SEEK_RELATIVE); 190 CHECK_SUCCESS_GOTO (g, rerror, r >= 0, unlock_and_fail); 191 192 data = (const uint8_t *) data + l; 193 length -= l; 194 } 195 196 pa_threaded_mainloop_unlock (g->mainloop); 197 return 0; 198 199 unlock_and_fail: 200 pa_threaded_mainloop_unlock (g->mainloop); 201 return -1; 202 } 203 204 static void *qpa_thread_out (void *arg) 205 { 206 PAVoiceOut *pa = arg; 207 HWVoiceOut *hw = &pa->hw; 208 209 if (audio_pt_lock(&pa->pt, __func__)) { 210 return NULL; 211 } 212 213 for (;;) { 214 int decr, to_mix, rpos; 215 216 for (;;) { 217 if (pa->done) { 218 goto exit; 219 } 220 221 if (pa->live > 0) { 222 break; 223 } 224 225 if (audio_pt_wait(&pa->pt, __func__)) { 226 goto exit; 227 } 228 } 229 230 decr = to_mix = audio_MIN (pa->live, pa->g->conf.samples >> 2); 231 rpos = pa->rpos; 232 233 if (audio_pt_unlock(&pa->pt, __func__)) { 234 return NULL; 235 } 236 237 while (to_mix) { 238 int error; 239 int chunk = audio_MIN (to_mix, hw->samples - rpos); 240 struct st_sample *src = hw->mix_buf + rpos; 241 242 hw->clip (pa->pcm_buf, src, chunk); 243 244 if (qpa_simple_write (pa, pa->pcm_buf, 245 chunk << hw->info.shift, &error) < 0) { 246 qpa_logerr (error, "pa_simple_write failed\n"); 247 return NULL; 248 } 249 250 rpos = (rpos + chunk) % hw->samples; 251 to_mix -= chunk; 252 } 253 254 if (audio_pt_lock(&pa->pt, __func__)) { 255 return NULL; 256 } 257 258 pa->rpos = rpos; 259 pa->live -= decr; 260 pa->decr += decr; 261 } 262 263 exit: 264 audio_pt_unlock(&pa->pt, __func__); 265 return NULL; 266 } 267 268 static int qpa_run_out (HWVoiceOut *hw, int live) 269 { 270 int decr; 271 PAVoiceOut *pa = (PAVoiceOut *) hw; 272 273 if (audio_pt_lock(&pa->pt, __func__)) { 274 return 0; 275 } 276 277 decr = audio_MIN (live, pa->decr); 278 pa->decr -= decr; 279 pa->live = live - decr; 280 hw->rpos = pa->rpos; 281 if (pa->live > 0) { 282 audio_pt_unlock_and_signal(&pa->pt, __func__); 283 } 284 else { 285 audio_pt_unlock(&pa->pt, __func__); 286 } 287 return decr; 288 } 289 290 static int qpa_write (SWVoiceOut *sw, void *buf, int len) 291 { 292 return audio_pcm_sw_write (sw, buf, len); 293 } 294 295 /* capture */ 296 static void *qpa_thread_in (void *arg) 297 { 298 PAVoiceIn *pa = arg; 299 HWVoiceIn *hw = &pa->hw; 300 301 if (audio_pt_lock(&pa->pt, __func__)) { 302 return NULL; 303 } 304 305 for (;;) { 306 int incr, to_grab, wpos; 307 308 for (;;) { 309 if (pa->done) { 310 goto exit; 311 } 312 313 if (pa->dead > 0) { 314 break; 315 } 316 317 if (audio_pt_wait(&pa->pt, __func__)) { 318 goto exit; 319 } 320 } 321 322 incr = to_grab = audio_MIN (pa->dead, pa->g->conf.samples >> 2); 323 wpos = pa->wpos; 324 325 if (audio_pt_unlock(&pa->pt, __func__)) { 326 return NULL; 327 } 328 329 while (to_grab) { 330 int error; 331 int chunk = audio_MIN (to_grab, hw->samples - wpos); 332 void *buf = advance (pa->pcm_buf, wpos); 333 334 if (qpa_simple_read (pa, buf, 335 chunk << hw->info.shift, &error) < 0) { 336 qpa_logerr (error, "pa_simple_read failed\n"); 337 return NULL; 338 } 339 340 hw->conv (hw->conv_buf + wpos, buf, chunk); 341 wpos = (wpos + chunk) % hw->samples; 342 to_grab -= chunk; 343 } 344 345 if (audio_pt_lock(&pa->pt, __func__)) { 346 return NULL; 347 } 348 349 pa->wpos = wpos; 350 pa->dead -= incr; 351 pa->incr += incr; 352 } 353 354 exit: 355 audio_pt_unlock(&pa->pt, __func__); 356 return NULL; 357 } 358 359 static int qpa_run_in (HWVoiceIn *hw) 360 { 361 int live, incr, dead; 362 PAVoiceIn *pa = (PAVoiceIn *) hw; 363 364 if (audio_pt_lock(&pa->pt, __func__)) { 365 return 0; 366 } 367 368 live = audio_pcm_hw_get_live_in (hw); 369 dead = hw->samples - live; 370 incr = audio_MIN (dead, pa->incr); 371 pa->incr -= incr; 372 pa->dead = dead - incr; 373 hw->wpos = pa->wpos; 374 if (pa->dead > 0) { 375 audio_pt_unlock_and_signal(&pa->pt, __func__); 376 } 377 else { 378 audio_pt_unlock(&pa->pt, __func__); 379 } 380 return incr; 381 } 382 383 static int qpa_read (SWVoiceIn *sw, void *buf, int len) 384 { 385 return audio_pcm_sw_read (sw, buf, len); 386 } 387 388 static pa_sample_format_t audfmt_to_pa (audfmt_e afmt, int endianness) 389 { 390 int format; 391 392 switch (afmt) { 393 case AUD_FMT_S8: 394 case AUD_FMT_U8: 395 format = PA_SAMPLE_U8; 396 break; 397 case AUD_FMT_S16: 398 case AUD_FMT_U16: 399 format = endianness ? PA_SAMPLE_S16BE : PA_SAMPLE_S16LE; 400 break; 401 case AUD_FMT_S32: 402 case AUD_FMT_U32: 403 format = endianness ? PA_SAMPLE_S32BE : PA_SAMPLE_S32LE; 404 break; 405 default: 406 dolog ("Internal logic error: Bad audio format %d\n", afmt); 407 format = PA_SAMPLE_U8; 408 break; 409 } 410 return format; 411 } 412 413 static audfmt_e pa_to_audfmt (pa_sample_format_t fmt, int *endianness) 414 { 415 switch (fmt) { 416 case PA_SAMPLE_U8: 417 return AUD_FMT_U8; 418 case PA_SAMPLE_S16BE: 419 *endianness = 1; 420 return AUD_FMT_S16; 421 case PA_SAMPLE_S16LE: 422 *endianness = 0; 423 return AUD_FMT_S16; 424 case PA_SAMPLE_S32BE: 425 *endianness = 1; 426 return AUD_FMT_S32; 427 case PA_SAMPLE_S32LE: 428 *endianness = 0; 429 return AUD_FMT_S32; 430 default: 431 dolog ("Internal logic error: Bad pa_sample_format %d\n", fmt); 432 return AUD_FMT_U8; 433 } 434 } 435 436 static void context_state_cb (pa_context *c, void *userdata) 437 { 438 paaudio *g = userdata; 439 440 switch (pa_context_get_state(c)) { 441 case PA_CONTEXT_READY: 442 case PA_CONTEXT_TERMINATED: 443 case PA_CONTEXT_FAILED: 444 pa_threaded_mainloop_signal (g->mainloop, 0); 445 break; 446 447 case PA_CONTEXT_UNCONNECTED: 448 case PA_CONTEXT_CONNECTING: 449 case PA_CONTEXT_AUTHORIZING: 450 case PA_CONTEXT_SETTING_NAME: 451 break; 452 } 453 } 454 455 static void stream_state_cb (pa_stream *s, void * userdata) 456 { 457 paaudio *g = userdata; 458 459 switch (pa_stream_get_state (s)) { 460 461 case PA_STREAM_READY: 462 case PA_STREAM_FAILED: 463 case PA_STREAM_TERMINATED: 464 pa_threaded_mainloop_signal (g->mainloop, 0); 465 break; 466 467 case PA_STREAM_UNCONNECTED: 468 case PA_STREAM_CREATING: 469 break; 470 } 471 } 472 473 static void stream_request_cb (pa_stream *s, size_t length, void *userdata) 474 { 475 paaudio *g = userdata; 476 477 pa_threaded_mainloop_signal (g->mainloop, 0); 478 } 479 480 static pa_stream *qpa_simple_new ( 481 paaudio *g, 482 const char *name, 483 pa_stream_direction_t dir, 484 const char *dev, 485 const pa_sample_spec *ss, 486 const pa_channel_map *map, 487 const pa_buffer_attr *attr, 488 int *rerror) 489 { 490 int r; 491 pa_stream *stream; 492 493 pa_threaded_mainloop_lock (g->mainloop); 494 495 stream = pa_stream_new (g->context, name, ss, map); 496 if (!stream) { 497 goto fail; 498 } 499 500 pa_stream_set_state_callback (stream, stream_state_cb, g); 501 pa_stream_set_read_callback (stream, stream_request_cb, g); 502 pa_stream_set_write_callback (stream, stream_request_cb, g); 503 504 if (dir == PA_STREAM_PLAYBACK) { 505 r = pa_stream_connect_playback (stream, dev, attr, 506 PA_STREAM_INTERPOLATE_TIMING 507 #ifdef PA_STREAM_ADJUST_LATENCY 508 |PA_STREAM_ADJUST_LATENCY 509 #endif 510 |PA_STREAM_AUTO_TIMING_UPDATE, NULL, NULL); 511 } else { 512 r = pa_stream_connect_record (stream, dev, attr, 513 PA_STREAM_INTERPOLATE_TIMING 514 #ifdef PA_STREAM_ADJUST_LATENCY 515 |PA_STREAM_ADJUST_LATENCY 516 #endif 517 |PA_STREAM_AUTO_TIMING_UPDATE); 518 } 519 520 if (r < 0) { 521 goto fail; 522 } 523 524 pa_threaded_mainloop_unlock (g->mainloop); 525 526 return stream; 527 528 fail: 529 pa_threaded_mainloop_unlock (g->mainloop); 530 531 if (stream) { 532 pa_stream_unref (stream); 533 } 534 535 *rerror = pa_context_errno (g->context); 536 537 return NULL; 538 } 539 540 static int qpa_init_out(HWVoiceOut *hw, struct audsettings *as, 541 void *drv_opaque) 542 { 543 int error; 544 pa_sample_spec ss; 545 pa_buffer_attr ba; 546 struct audsettings obt_as = *as; 547 PAVoiceOut *pa = (PAVoiceOut *) hw; 548 paaudio *g = pa->g = drv_opaque; 549 550 ss.format = audfmt_to_pa (as->fmt, as->endianness); 551 ss.channels = as->nchannels; 552 ss.rate = as->freq; 553 554 /* 555 * qemu audio tick runs at 100 Hz (by default), so processing 556 * data chunks worth 10 ms of sound should be a good fit. 557 */ 558 ba.tlength = pa_usec_to_bytes (10 * 1000, &ss); 559 ba.minreq = pa_usec_to_bytes (5 * 1000, &ss); 560 ba.maxlength = -1; 561 ba.prebuf = -1; 562 563 obt_as.fmt = pa_to_audfmt (ss.format, &obt_as.endianness); 564 565 pa->stream = qpa_simple_new ( 566 g, 567 "qemu", 568 PA_STREAM_PLAYBACK, 569 g->conf.sink, 570 &ss, 571 NULL, /* channel map */ 572 &ba, /* buffering attributes */ 573 &error 574 ); 575 if (!pa->stream) { 576 qpa_logerr (error, "pa_simple_new for playback failed\n"); 577 goto fail1; 578 } 579 580 audio_pcm_init_info (&hw->info, &obt_as); 581 hw->samples = g->conf.samples; 582 pa->pcm_buf = audio_calloc(__func__, hw->samples, 1 << hw->info.shift); 583 pa->rpos = hw->rpos; 584 if (!pa->pcm_buf) { 585 dolog ("Could not allocate buffer (%d bytes)\n", 586 hw->samples << hw->info.shift); 587 goto fail2; 588 } 589 590 if (audio_pt_init(&pa->pt, qpa_thread_out, hw, AUDIO_CAP, __func__)) { 591 goto fail3; 592 } 593 594 return 0; 595 596 fail3: 597 g_free (pa->pcm_buf); 598 pa->pcm_buf = NULL; 599 fail2: 600 if (pa->stream) { 601 pa_stream_unref (pa->stream); 602 pa->stream = NULL; 603 } 604 fail1: 605 return -1; 606 } 607 608 static int qpa_init_in(HWVoiceIn *hw, struct audsettings *as, void *drv_opaque) 609 { 610 int error; 611 pa_sample_spec ss; 612 struct audsettings obt_as = *as; 613 PAVoiceIn *pa = (PAVoiceIn *) hw; 614 paaudio *g = pa->g = drv_opaque; 615 616 ss.format = audfmt_to_pa (as->fmt, as->endianness); 617 ss.channels = as->nchannels; 618 ss.rate = as->freq; 619 620 obt_as.fmt = pa_to_audfmt (ss.format, &obt_as.endianness); 621 622 pa->stream = qpa_simple_new ( 623 g, 624 "qemu", 625 PA_STREAM_RECORD, 626 g->conf.source, 627 &ss, 628 NULL, /* channel map */ 629 NULL, /* buffering attributes */ 630 &error 631 ); 632 if (!pa->stream) { 633 qpa_logerr (error, "pa_simple_new for capture failed\n"); 634 goto fail1; 635 } 636 637 audio_pcm_init_info (&hw->info, &obt_as); 638 hw->samples = g->conf.samples; 639 pa->pcm_buf = audio_calloc(__func__, hw->samples, 1 << hw->info.shift); 640 pa->wpos = hw->wpos; 641 if (!pa->pcm_buf) { 642 dolog ("Could not allocate buffer (%d bytes)\n", 643 hw->samples << hw->info.shift); 644 goto fail2; 645 } 646 647 if (audio_pt_init(&pa->pt, qpa_thread_in, hw, AUDIO_CAP, __func__)) { 648 goto fail3; 649 } 650 651 return 0; 652 653 fail3: 654 g_free (pa->pcm_buf); 655 pa->pcm_buf = NULL; 656 fail2: 657 if (pa->stream) { 658 pa_stream_unref (pa->stream); 659 pa->stream = NULL; 660 } 661 fail1: 662 return -1; 663 } 664 665 static void qpa_fini_out (HWVoiceOut *hw) 666 { 667 void *ret; 668 PAVoiceOut *pa = (PAVoiceOut *) hw; 669 670 audio_pt_lock(&pa->pt, __func__); 671 pa->done = 1; 672 audio_pt_unlock_and_signal(&pa->pt, __func__); 673 audio_pt_join(&pa->pt, &ret, __func__); 674 675 if (pa->stream) { 676 pa_stream_unref (pa->stream); 677 pa->stream = NULL; 678 } 679 680 audio_pt_fini(&pa->pt, __func__); 681 g_free (pa->pcm_buf); 682 pa->pcm_buf = NULL; 683 } 684 685 static void qpa_fini_in (HWVoiceIn *hw) 686 { 687 void *ret; 688 PAVoiceIn *pa = (PAVoiceIn *) hw; 689 690 audio_pt_lock(&pa->pt, __func__); 691 pa->done = 1; 692 audio_pt_unlock_and_signal(&pa->pt, __func__); 693 audio_pt_join(&pa->pt, &ret, __func__); 694 695 if (pa->stream) { 696 pa_stream_unref (pa->stream); 697 pa->stream = NULL; 698 } 699 700 audio_pt_fini(&pa->pt, __func__); 701 g_free (pa->pcm_buf); 702 pa->pcm_buf = NULL; 703 } 704 705 static int qpa_ctl_out (HWVoiceOut *hw, int cmd, ...) 706 { 707 PAVoiceOut *pa = (PAVoiceOut *) hw; 708 pa_operation *op; 709 pa_cvolume v; 710 paaudio *g = pa->g; 711 712 #ifdef PA_CHECK_VERSION /* macro is present in 0.9.16+ */ 713 pa_cvolume_init (&v); /* function is present in 0.9.13+ */ 714 #endif 715 716 switch (cmd) { 717 case VOICE_VOLUME: 718 { 719 SWVoiceOut *sw; 720 va_list ap; 721 722 va_start (ap, cmd); 723 sw = va_arg (ap, SWVoiceOut *); 724 va_end (ap); 725 726 v.channels = 2; 727 v.values[0] = ((PA_VOLUME_NORM - PA_VOLUME_MUTED) * sw->vol.l) / UINT32_MAX; 728 v.values[1] = ((PA_VOLUME_NORM - PA_VOLUME_MUTED) * sw->vol.r) / UINT32_MAX; 729 730 pa_threaded_mainloop_lock (g->mainloop); 731 732 op = pa_context_set_sink_input_volume (g->context, 733 pa_stream_get_index (pa->stream), 734 &v, NULL, NULL); 735 if (!op) 736 qpa_logerr (pa_context_errno (g->context), 737 "set_sink_input_volume() failed\n"); 738 else 739 pa_operation_unref (op); 740 741 op = pa_context_set_sink_input_mute (g->context, 742 pa_stream_get_index (pa->stream), 743 sw->vol.mute, NULL, NULL); 744 if (!op) { 745 qpa_logerr (pa_context_errno (g->context), 746 "set_sink_input_mute() failed\n"); 747 } else { 748 pa_operation_unref (op); 749 } 750 751 pa_threaded_mainloop_unlock (g->mainloop); 752 } 753 } 754 return 0; 755 } 756 757 static int qpa_ctl_in (HWVoiceIn *hw, int cmd, ...) 758 { 759 PAVoiceIn *pa = (PAVoiceIn *) hw; 760 pa_operation *op; 761 pa_cvolume v; 762 paaudio *g = pa->g; 763 764 #ifdef PA_CHECK_VERSION 765 pa_cvolume_init (&v); 766 #endif 767 768 switch (cmd) { 769 case VOICE_VOLUME: 770 { 771 SWVoiceIn *sw; 772 va_list ap; 773 774 va_start (ap, cmd); 775 sw = va_arg (ap, SWVoiceIn *); 776 va_end (ap); 777 778 v.channels = 2; 779 v.values[0] = ((PA_VOLUME_NORM - PA_VOLUME_MUTED) * sw->vol.l) / UINT32_MAX; 780 v.values[1] = ((PA_VOLUME_NORM - PA_VOLUME_MUTED) * sw->vol.r) / UINT32_MAX; 781 782 pa_threaded_mainloop_lock (g->mainloop); 783 784 op = pa_context_set_source_output_volume (g->context, 785 pa_stream_get_index (pa->stream), 786 &v, NULL, NULL); 787 if (!op) { 788 qpa_logerr (pa_context_errno (g->context), 789 "set_source_output_volume() failed\n"); 790 } else { 791 pa_operation_unref(op); 792 } 793 794 op = pa_context_set_source_output_mute (g->context, 795 pa_stream_get_index (pa->stream), 796 sw->vol.mute, NULL, NULL); 797 if (!op) { 798 qpa_logerr (pa_context_errno (g->context), 799 "set_source_output_mute() failed\n"); 800 } else { 801 pa_operation_unref (op); 802 } 803 804 pa_threaded_mainloop_unlock (g->mainloop); 805 } 806 } 807 return 0; 808 } 809 810 /* common */ 811 static PAConf glob_conf = { 812 .samples = 4096, 813 }; 814 815 static void *qpa_audio_init (void) 816 { 817 paaudio *g = g_malloc(sizeof(paaudio)); 818 g->conf = glob_conf; 819 g->mainloop = NULL; 820 g->context = NULL; 821 822 g->mainloop = pa_threaded_mainloop_new (); 823 if (!g->mainloop) { 824 goto fail; 825 } 826 827 g->context = pa_context_new (pa_threaded_mainloop_get_api (g->mainloop), 828 g->conf.server); 829 if (!g->context) { 830 goto fail; 831 } 832 833 pa_context_set_state_callback (g->context, context_state_cb, g); 834 835 if (pa_context_connect (g->context, g->conf.server, 0, NULL) < 0) { 836 qpa_logerr (pa_context_errno (g->context), 837 "pa_context_connect() failed\n"); 838 goto fail; 839 } 840 841 pa_threaded_mainloop_lock (g->mainloop); 842 843 if (pa_threaded_mainloop_start (g->mainloop) < 0) { 844 goto unlock_and_fail; 845 } 846 847 for (;;) { 848 pa_context_state_t state; 849 850 state = pa_context_get_state (g->context); 851 852 if (state == PA_CONTEXT_READY) { 853 break; 854 } 855 856 if (!PA_CONTEXT_IS_GOOD (state)) { 857 qpa_logerr (pa_context_errno (g->context), 858 "Wrong context state\n"); 859 goto unlock_and_fail; 860 } 861 862 /* Wait until the context is ready */ 863 pa_threaded_mainloop_wait (g->mainloop); 864 } 865 866 pa_threaded_mainloop_unlock (g->mainloop); 867 868 return g; 869 870 unlock_and_fail: 871 pa_threaded_mainloop_unlock (g->mainloop); 872 fail: 873 AUD_log (AUDIO_CAP, "Failed to initialize PA context"); 874 qpa_audio_fini(g); 875 return NULL; 876 } 877 878 static void qpa_audio_fini (void *opaque) 879 { 880 paaudio *g = opaque; 881 882 if (g->mainloop) { 883 pa_threaded_mainloop_stop (g->mainloop); 884 } 885 886 if (g->context) { 887 pa_context_disconnect (g->context); 888 pa_context_unref (g->context); 889 } 890 891 if (g->mainloop) { 892 pa_threaded_mainloop_free (g->mainloop); 893 } 894 895 g_free(g); 896 } 897 898 struct audio_option qpa_options[] = { 899 { 900 .name = "SAMPLES", 901 .tag = AUD_OPT_INT, 902 .valp = &glob_conf.samples, 903 .descr = "buffer size in samples" 904 }, 905 { 906 .name = "SERVER", 907 .tag = AUD_OPT_STR, 908 .valp = &glob_conf.server, 909 .descr = "server address" 910 }, 911 { 912 .name = "SINK", 913 .tag = AUD_OPT_STR, 914 .valp = &glob_conf.sink, 915 .descr = "sink device name" 916 }, 917 { 918 .name = "SOURCE", 919 .tag = AUD_OPT_STR, 920 .valp = &glob_conf.source, 921 .descr = "source device name" 922 }, 923 { /* End of list */ } 924 }; 925 926 static struct audio_pcm_ops qpa_pcm_ops = { 927 .init_out = qpa_init_out, 928 .fini_out = qpa_fini_out, 929 .run_out = qpa_run_out, 930 .write = qpa_write, 931 .ctl_out = qpa_ctl_out, 932 933 .init_in = qpa_init_in, 934 .fini_in = qpa_fini_in, 935 .run_in = qpa_run_in, 936 .read = qpa_read, 937 .ctl_in = qpa_ctl_in 938 }; 939 940 static struct audio_driver pa_audio_driver = { 941 .name = "pa", 942 .descr = "http://www.pulseaudio.org/", 943 .options = qpa_options, 944 .init = qpa_audio_init, 945 .fini = qpa_audio_fini, 946 .pcm_ops = &qpa_pcm_ops, 947 .can_be_default = 1, 948 .max_voices_out = INT_MAX, 949 .max_voices_in = INT_MAX, 950 .voice_size_out = sizeof (PAVoiceOut), 951 .voice_size_in = sizeof (PAVoiceIn), 952 .ctl_caps = VOICE_VOLUME_CAP 953 }; 954 955 static void register_audio_pa(void) 956 { 957 audio_driver_register(&pa_audio_driver); 958 } 959 type_init(register_audio_pa); 960