1 /* 2 * Copyright (C) 2010 Red Hat, Inc. 3 * 4 * maintained by Gerd Hoffmann <kraxel@redhat.com> 5 * 6 * This program is free software; you can redistribute it and/or 7 * modify it under the terms of the GNU General Public License as 8 * published by the Free Software Foundation; either version 2 or 9 * (at your option) version 3 of the License. 10 * 11 * This program is distributed in the hope that it will be useful, 12 * but WITHOUT ANY WARRANTY; without even the implied warranty of 13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 14 * GNU General Public License for more details. 15 * 16 * You should have received a copy of the GNU General Public License 17 * along with this program; if not, see <http://www.gnu.org/licenses/>. 18 */ 19 20 #include "hw/hw.h" 21 #include "qemu/timer.h" 22 #include "ui/qemu-spice.h" 23 24 #define AUDIO_CAP "spice" 25 #include "audio.h" 26 #include "audio_int.h" 27 28 #define LINE_IN_SAMPLES 1024 29 #define LINE_OUT_SAMPLES 1024 30 31 typedef struct SpiceRateCtl { 32 int64_t start_ticks; 33 int64_t bytes_sent; 34 } SpiceRateCtl; 35 36 typedef struct SpiceVoiceOut { 37 HWVoiceOut hw; 38 SpicePlaybackInstance sin; 39 SpiceRateCtl rate; 40 int active; 41 uint32_t *frame; 42 uint32_t *fpos; 43 uint32_t fsize; 44 } SpiceVoiceOut; 45 46 typedef struct SpiceVoiceIn { 47 HWVoiceIn hw; 48 SpiceRecordInstance sin; 49 SpiceRateCtl rate; 50 int active; 51 uint32_t samples[LINE_IN_SAMPLES]; 52 } SpiceVoiceIn; 53 54 static const SpicePlaybackInterface playback_sif = { 55 .base.type = SPICE_INTERFACE_PLAYBACK, 56 .base.description = "playback", 57 .base.major_version = SPICE_INTERFACE_PLAYBACK_MAJOR, 58 .base.minor_version = SPICE_INTERFACE_PLAYBACK_MINOR, 59 }; 60 61 static const SpiceRecordInterface record_sif = { 62 .base.type = SPICE_INTERFACE_RECORD, 63 .base.description = "record", 64 .base.major_version = SPICE_INTERFACE_RECORD_MAJOR, 65 .base.minor_version = SPICE_INTERFACE_RECORD_MINOR, 66 }; 67 68 static void *spice_audio_init (void) 69 { 70 if (!using_spice) { 71 return NULL; 72 } 73 return &spice_audio_init; 74 } 75 76 static void spice_audio_fini (void *opaque) 77 { 78 /* nothing */ 79 } 80 81 static void rate_start (SpiceRateCtl *rate) 82 { 83 memset (rate, 0, sizeof (*rate)); 84 rate->start_ticks = qemu_clock_get_ns(QEMU_CLOCK_VIRTUAL); 85 } 86 87 static int rate_get_samples (struct audio_pcm_info *info, SpiceRateCtl *rate) 88 { 89 int64_t now; 90 int64_t ticks; 91 int64_t bytes; 92 int64_t samples; 93 94 now = qemu_clock_get_ns(QEMU_CLOCK_VIRTUAL); 95 ticks = now - rate->start_ticks; 96 bytes = muldiv64 (ticks, info->bytes_per_second, get_ticks_per_sec ()); 97 samples = (bytes - rate->bytes_sent) >> info->shift; 98 if (samples < 0 || samples > 65536) { 99 fprintf (stderr, "Resetting rate control (%" PRId64 " samples)\n", samples); 100 rate_start (rate); 101 samples = 0; 102 } 103 rate->bytes_sent += samples << info->shift; 104 return samples; 105 } 106 107 /* playback */ 108 109 static int line_out_init (HWVoiceOut *hw, struct audsettings *as) 110 { 111 SpiceVoiceOut *out = container_of (hw, SpiceVoiceOut, hw); 112 struct audsettings settings; 113 114 settings.freq = SPICE_INTERFACE_PLAYBACK_FREQ; 115 settings.nchannels = SPICE_INTERFACE_PLAYBACK_CHAN; 116 settings.fmt = AUD_FMT_S16; 117 settings.endianness = AUDIO_HOST_ENDIANNESS; 118 119 audio_pcm_init_info (&hw->info, &settings); 120 hw->samples = LINE_OUT_SAMPLES; 121 out->active = 0; 122 123 out->sin.base.sif = &playback_sif.base; 124 qemu_spice_add_interface (&out->sin.base); 125 return 0; 126 } 127 128 static void line_out_fini (HWVoiceOut *hw) 129 { 130 SpiceVoiceOut *out = container_of (hw, SpiceVoiceOut, hw); 131 132 spice_server_remove_interface (&out->sin.base); 133 } 134 135 static int line_out_run (HWVoiceOut *hw, int live) 136 { 137 SpiceVoiceOut *out = container_of (hw, SpiceVoiceOut, hw); 138 int rpos, decr; 139 int samples; 140 141 if (!live) { 142 return 0; 143 } 144 145 decr = rate_get_samples (&hw->info, &out->rate); 146 decr = audio_MIN (live, decr); 147 148 samples = decr; 149 rpos = hw->rpos; 150 while (samples) { 151 int left_till_end_samples = hw->samples - rpos; 152 int len = audio_MIN (samples, left_till_end_samples); 153 154 if (!out->frame) { 155 spice_server_playback_get_buffer (&out->sin, &out->frame, &out->fsize); 156 out->fpos = out->frame; 157 } 158 if (out->frame) { 159 len = audio_MIN (len, out->fsize); 160 hw->clip (out->fpos, hw->mix_buf + rpos, len); 161 out->fsize -= len; 162 out->fpos += len; 163 if (out->fsize == 0) { 164 spice_server_playback_put_samples (&out->sin, out->frame); 165 out->frame = out->fpos = NULL; 166 } 167 } 168 rpos = (rpos + len) % hw->samples; 169 samples -= len; 170 } 171 hw->rpos = rpos; 172 return decr; 173 } 174 175 static int line_out_write (SWVoiceOut *sw, void *buf, int len) 176 { 177 return audio_pcm_sw_write (sw, buf, len); 178 } 179 180 static int line_out_ctl (HWVoiceOut *hw, int cmd, ...) 181 { 182 SpiceVoiceOut *out = container_of (hw, SpiceVoiceOut, hw); 183 184 switch (cmd) { 185 case VOICE_ENABLE: 186 if (out->active) { 187 break; 188 } 189 out->active = 1; 190 rate_start (&out->rate); 191 spice_server_playback_start (&out->sin); 192 break; 193 case VOICE_DISABLE: 194 if (!out->active) { 195 break; 196 } 197 out->active = 0; 198 if (out->frame) { 199 memset (out->fpos, 0, out->fsize << 2); 200 spice_server_playback_put_samples (&out->sin, out->frame); 201 out->frame = out->fpos = NULL; 202 } 203 spice_server_playback_stop (&out->sin); 204 break; 205 case VOICE_VOLUME: 206 { 207 #if ((SPICE_INTERFACE_PLAYBACK_MAJOR >= 1) && (SPICE_INTERFACE_PLAYBACK_MINOR >= 2)) 208 SWVoiceOut *sw; 209 va_list ap; 210 uint16_t vol[2]; 211 212 va_start (ap, cmd); 213 sw = va_arg (ap, SWVoiceOut *); 214 va_end (ap); 215 216 vol[0] = sw->vol.l / ((1ULL << 16) + 1); 217 vol[1] = sw->vol.r / ((1ULL << 16) + 1); 218 spice_server_playback_set_volume (&out->sin, 2, vol); 219 spice_server_playback_set_mute (&out->sin, sw->vol.mute); 220 #endif 221 break; 222 } 223 } 224 225 return 0; 226 } 227 228 /* record */ 229 230 static int line_in_init (HWVoiceIn *hw, struct audsettings *as) 231 { 232 SpiceVoiceIn *in = container_of (hw, SpiceVoiceIn, hw); 233 struct audsettings settings; 234 235 settings.freq = SPICE_INTERFACE_RECORD_FREQ; 236 settings.nchannels = SPICE_INTERFACE_RECORD_CHAN; 237 settings.fmt = AUD_FMT_S16; 238 settings.endianness = AUDIO_HOST_ENDIANNESS; 239 240 audio_pcm_init_info (&hw->info, &settings); 241 hw->samples = LINE_IN_SAMPLES; 242 in->active = 0; 243 244 in->sin.base.sif = &record_sif.base; 245 qemu_spice_add_interface (&in->sin.base); 246 return 0; 247 } 248 249 static void line_in_fini (HWVoiceIn *hw) 250 { 251 SpiceVoiceIn *in = container_of (hw, SpiceVoiceIn, hw); 252 253 spice_server_remove_interface (&in->sin.base); 254 } 255 256 static int line_in_run (HWVoiceIn *hw) 257 { 258 SpiceVoiceIn *in = container_of (hw, SpiceVoiceIn, hw); 259 int num_samples; 260 int ready; 261 int len[2]; 262 uint64_t delta_samp; 263 const uint32_t *samples; 264 265 if (!(num_samples = hw->samples - audio_pcm_hw_get_live_in (hw))) { 266 return 0; 267 } 268 269 delta_samp = rate_get_samples (&hw->info, &in->rate); 270 num_samples = audio_MIN (num_samples, delta_samp); 271 272 ready = spice_server_record_get_samples (&in->sin, in->samples, num_samples); 273 samples = in->samples; 274 if (ready == 0) { 275 static const uint32_t silence[LINE_IN_SAMPLES]; 276 samples = silence; 277 ready = LINE_IN_SAMPLES; 278 } 279 280 num_samples = audio_MIN (ready, num_samples); 281 282 if (hw->wpos + num_samples > hw->samples) { 283 len[0] = hw->samples - hw->wpos; 284 len[1] = num_samples - len[0]; 285 } else { 286 len[0] = num_samples; 287 len[1] = 0; 288 } 289 290 hw->conv (hw->conv_buf + hw->wpos, samples, len[0]); 291 292 if (len[1]) { 293 hw->conv (hw->conv_buf, samples + len[0], len[1]); 294 } 295 296 hw->wpos = (hw->wpos + num_samples) % hw->samples; 297 298 return num_samples; 299 } 300 301 static int line_in_read (SWVoiceIn *sw, void *buf, int size) 302 { 303 return audio_pcm_sw_read (sw, buf, size); 304 } 305 306 static int line_in_ctl (HWVoiceIn *hw, int cmd, ...) 307 { 308 SpiceVoiceIn *in = container_of (hw, SpiceVoiceIn, hw); 309 310 switch (cmd) { 311 case VOICE_ENABLE: 312 if (in->active) { 313 break; 314 } 315 in->active = 1; 316 rate_start (&in->rate); 317 spice_server_record_start (&in->sin); 318 break; 319 case VOICE_DISABLE: 320 if (!in->active) { 321 break; 322 } 323 in->active = 0; 324 spice_server_record_stop (&in->sin); 325 break; 326 case VOICE_VOLUME: 327 { 328 #if ((SPICE_INTERFACE_RECORD_MAJOR >= 2) && (SPICE_INTERFACE_RECORD_MINOR >= 2)) 329 SWVoiceIn *sw; 330 va_list ap; 331 uint16_t vol[2]; 332 333 va_start (ap, cmd); 334 sw = va_arg (ap, SWVoiceIn *); 335 va_end (ap); 336 337 vol[0] = sw->vol.l / ((1ULL << 16) + 1); 338 vol[1] = sw->vol.r / ((1ULL << 16) + 1); 339 spice_server_record_set_volume (&in->sin, 2, vol); 340 spice_server_record_set_mute (&in->sin, sw->vol.mute); 341 #endif 342 break; 343 } 344 } 345 346 return 0; 347 } 348 349 static struct audio_option audio_options[] = { 350 { /* end of list */ }, 351 }; 352 353 static struct audio_pcm_ops audio_callbacks = { 354 .init_out = line_out_init, 355 .fini_out = line_out_fini, 356 .run_out = line_out_run, 357 .write = line_out_write, 358 .ctl_out = line_out_ctl, 359 360 .init_in = line_in_init, 361 .fini_in = line_in_fini, 362 .run_in = line_in_run, 363 .read = line_in_read, 364 .ctl_in = line_in_ctl, 365 }; 366 367 struct audio_driver spice_audio_driver = { 368 .name = "spice", 369 .descr = "spice audio driver", 370 .options = audio_options, 371 .init = spice_audio_init, 372 .fini = spice_audio_fini, 373 .pcm_ops = &audio_callbacks, 374 .max_voices_out = 1, 375 .max_voices_in = 1, 376 .voice_size_out = sizeof (SpiceVoiceOut), 377 .voice_size_in = sizeof (SpiceVoiceIn), 378 #if ((SPICE_INTERFACE_PLAYBACK_MAJOR >= 1) && (SPICE_INTERFACE_PLAYBACK_MINOR >= 2)) 379 .ctl_caps = VOICE_VOLUME_CAP 380 #endif 381 }; 382 383 void qemu_spice_audio_init (void) 384 { 385 spice_audio_driver.can_be_default = 1; 386 } 387