xref: /freebsd/sys/dev/sound/pcm/channel.c (revision 7cc1afc5)
1 /*-
2  * SPDX-License-Identifier: BSD-2-Clause
3  *
4  * Copyright (c) 2005-2009 Ariff Abdullah <ariff@FreeBSD.org>
5  * Portions Copyright (c) Ryan Beasley <ryan.beasley@gmail.com> - GSoC 2006
6  * Copyright (c) 1999 Cameron Grant <cg@FreeBSD.org>
7  * Portions Copyright (c) Luigi Rizzo <luigi@FreeBSD.org> - 1997-99
8  * All rights reserved.
9  *
10  * Redistribution and use in source and binary forms, with or without
11  * modification, are permitted provided that the following conditions
12  * are met:
13  * 1. Redistributions of source code must retain the above copyright
14  *    notice, this list of conditions and the following disclaimer.
15  * 2. Redistributions in binary form must reproduce the above copyright
16  *    notice, this list of conditions and the following disclaimer in the
17  *    documentation and/or other materials provided with the distribution.
18  *
19  * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
20  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
21  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
22  * ARE DISCLAIMED.  IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE
23  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
24  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
25  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
26  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
27  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
28  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
29  * SUCH DAMAGE.
30  */
31 
32 #ifdef HAVE_KERNEL_OPTION_HEADERS
33 #include "opt_snd.h"
34 #endif
35 
36 #include <dev/sound/pcm/sound.h>
37 #include <dev/sound/pcm/vchan.h>
38 
39 #include "feeder_if.h"
40 
41 int report_soft_formats = 1;
42 SYSCTL_INT(_hw_snd, OID_AUTO, report_soft_formats, CTLFLAG_RW,
43 	&report_soft_formats, 0, "report software-emulated formats");
44 
45 int report_soft_matrix = 1;
46 SYSCTL_INT(_hw_snd, OID_AUTO, report_soft_matrix, CTLFLAG_RW,
47 	&report_soft_matrix, 0, "report software-emulated channel matrixing");
48 
49 int chn_latency = CHN_LATENCY_DEFAULT;
50 
51 static int
sysctl_hw_snd_latency(SYSCTL_HANDLER_ARGS)52 sysctl_hw_snd_latency(SYSCTL_HANDLER_ARGS)
53 {
54 	int err, val;
55 
56 	val = chn_latency;
57 	err = sysctl_handle_int(oidp, &val, 0, req);
58 	if (err != 0 || req->newptr == NULL)
59 		return err;
60 	if (val < CHN_LATENCY_MIN || val > CHN_LATENCY_MAX)
61 		err = EINVAL;
62 	else
63 		chn_latency = val;
64 
65 	return err;
66 }
67 SYSCTL_PROC(_hw_snd, OID_AUTO, latency,
68     CTLTYPE_INT | CTLFLAG_RWTUN | CTLFLAG_MPSAFE, 0, sizeof(int),
69     sysctl_hw_snd_latency, "I",
70     "buffering latency (0=low ... 10=high)");
71 
72 int chn_latency_profile = CHN_LATENCY_PROFILE_DEFAULT;
73 
74 static int
sysctl_hw_snd_latency_profile(SYSCTL_HANDLER_ARGS)75 sysctl_hw_snd_latency_profile(SYSCTL_HANDLER_ARGS)
76 {
77 	int err, val;
78 
79 	val = chn_latency_profile;
80 	err = sysctl_handle_int(oidp, &val, 0, req);
81 	if (err != 0 || req->newptr == NULL)
82 		return err;
83 	if (val < CHN_LATENCY_PROFILE_MIN || val > CHN_LATENCY_PROFILE_MAX)
84 		err = EINVAL;
85 	else
86 		chn_latency_profile = val;
87 
88 	return err;
89 }
90 SYSCTL_PROC(_hw_snd, OID_AUTO, latency_profile,
91     CTLTYPE_INT | CTLFLAG_RWTUN | CTLFLAG_MPSAFE, 0, sizeof(int),
92     sysctl_hw_snd_latency_profile, "I",
93     "buffering latency profile (0=aggressive 1=safe)");
94 
95 static int chn_timeout = CHN_TIMEOUT;
96 
97 static int
sysctl_hw_snd_timeout(SYSCTL_HANDLER_ARGS)98 sysctl_hw_snd_timeout(SYSCTL_HANDLER_ARGS)
99 {
100 	int err, val;
101 
102 	val = chn_timeout;
103 	err = sysctl_handle_int(oidp, &val, 0, req);
104 	if (err != 0 || req->newptr == NULL)
105 		return err;
106 	if (val < CHN_TIMEOUT_MIN || val > CHN_TIMEOUT_MAX)
107 		err = EINVAL;
108 	else
109 		chn_timeout = val;
110 
111 	return err;
112 }
113 SYSCTL_PROC(_hw_snd, OID_AUTO, timeout,
114     CTLTYPE_INT | CTLFLAG_RWTUN | CTLFLAG_MPSAFE, 0, sizeof(int),
115     sysctl_hw_snd_timeout, "I",
116     "interrupt timeout (1 - 10) seconds");
117 
118 static int chn_vpc_autoreset = 1;
119 SYSCTL_INT(_hw_snd, OID_AUTO, vpc_autoreset, CTLFLAG_RWTUN,
120 	&chn_vpc_autoreset, 0, "automatically reset channels volume to 0db");
121 
122 static int chn_vol_0db_pcm = SND_VOL_0DB_PCM;
123 
124 static void
chn_vpc_proc(int reset,int db)125 chn_vpc_proc(int reset, int db)
126 {
127 	struct snddev_info *d;
128 	struct pcm_channel *c;
129 	int i;
130 
131 	for (i = 0; pcm_devclass != NULL &&
132 	    i < devclass_get_maxunit(pcm_devclass); i++) {
133 		d = devclass_get_softc(pcm_devclass, i);
134 		if (!PCM_REGISTERED(d))
135 			continue;
136 		PCM_LOCK(d);
137 		PCM_WAIT(d);
138 		PCM_ACQUIRE(d);
139 		CHN_FOREACH(c, d, channels.pcm) {
140 			CHN_LOCK(c);
141 			CHN_SETVOLUME(c, SND_VOL_C_PCM, SND_CHN_T_VOL_0DB, db);
142 			if (reset != 0)
143 				chn_vpc_reset(c, SND_VOL_C_PCM, 1);
144 			CHN_UNLOCK(c);
145 		}
146 		PCM_RELEASE(d);
147 		PCM_UNLOCK(d);
148 	}
149 }
150 
151 static int
sysctl_hw_snd_vpc_0db(SYSCTL_HANDLER_ARGS)152 sysctl_hw_snd_vpc_0db(SYSCTL_HANDLER_ARGS)
153 {
154 	int err, val;
155 
156 	val = chn_vol_0db_pcm;
157 	err = sysctl_handle_int(oidp, &val, 0, req);
158 	if (err != 0 || req->newptr == NULL)
159 		return (err);
160 	if (val < SND_VOL_0DB_MIN || val > SND_VOL_0DB_MAX)
161 		return (EINVAL);
162 
163 	chn_vol_0db_pcm = val;
164 	chn_vpc_proc(0, val);
165 
166 	return (0);
167 }
168 SYSCTL_PROC(_hw_snd, OID_AUTO, vpc_0db,
169     CTLTYPE_INT | CTLFLAG_RWTUN | CTLFLAG_NEEDGIANT, 0, sizeof(int),
170     sysctl_hw_snd_vpc_0db, "I",
171     "0db relative level");
172 
173 static int
sysctl_hw_snd_vpc_reset(SYSCTL_HANDLER_ARGS)174 sysctl_hw_snd_vpc_reset(SYSCTL_HANDLER_ARGS)
175 {
176 	int err, val;
177 
178 	val = 0;
179 	err = sysctl_handle_int(oidp, &val, 0, req);
180 	if (err != 0 || req->newptr == NULL || val == 0)
181 		return (err);
182 
183 	chn_vol_0db_pcm = SND_VOL_0DB_PCM;
184 	chn_vpc_proc(1, SND_VOL_0DB_PCM);
185 
186 	return (0);
187 }
188 SYSCTL_PROC(_hw_snd, OID_AUTO, vpc_reset,
189     CTLTYPE_INT | CTLFLAG_RW | CTLFLAG_NEEDGIANT, 0, sizeof(int),
190     sysctl_hw_snd_vpc_reset, "I",
191     "reset volume on all channels");
192 
193 static int chn_usefrags = 0;
194 static int chn_syncdelay = -1;
195 
196 SYSCTL_INT(_hw_snd, OID_AUTO, usefrags, CTLFLAG_RWTUN,
197 	&chn_usefrags, 0, "prefer setfragments() over setblocksize()");
198 SYSCTL_INT(_hw_snd, OID_AUTO, syncdelay, CTLFLAG_RWTUN,
199 	&chn_syncdelay, 0,
200 	"append (0-1000) millisecond trailing buffer delay on each sync");
201 
202 /**
203  * @brief Channel sync group lock
204  *
205  * Clients should acquire this lock @b without holding any channel locks
206  * before touching syncgroups or the main syncgroup list.
207  */
208 struct mtx snd_pcm_syncgroups_mtx;
209 MTX_SYSINIT(pcm_syncgroup, &snd_pcm_syncgroups_mtx, "PCM channel sync group lock", MTX_DEF);
210 /**
211  * @brief syncgroups' master list
212  *
213  * Each time a channel syncgroup is created, it's added to this list.  This
214  * list should only be accessed with @sa snd_pcm_syncgroups_mtx held.
215  *
216  * See SNDCTL_DSP_SYNCGROUP for more information.
217  */
218 struct pcm_synclist snd_pcm_syncgroups = SLIST_HEAD_INITIALIZER(snd_pcm_syncgroups);
219 
220 static void
chn_lockinit(struct pcm_channel * c,int dir)221 chn_lockinit(struct pcm_channel *c, int dir)
222 {
223 	switch (dir) {
224 	case PCMDIR_PLAY:
225 		c->lock = snd_mtxcreate(c->name, "pcm play channel");
226 		cv_init(&c->intr_cv, "pcmwr");
227 		break;
228 	case PCMDIR_PLAY_VIRTUAL:
229 		c->lock = snd_mtxcreate(c->name, "pcm virtual play channel");
230 		cv_init(&c->intr_cv, "pcmwrv");
231 		break;
232 	case PCMDIR_REC:
233 		c->lock = snd_mtxcreate(c->name, "pcm record channel");
234 		cv_init(&c->intr_cv, "pcmrd");
235 		break;
236 	case PCMDIR_REC_VIRTUAL:
237 		c->lock = snd_mtxcreate(c->name, "pcm virtual record channel");
238 		cv_init(&c->intr_cv, "pcmrdv");
239 		break;
240 	default:
241 		panic("%s(): Invalid direction=%d", __func__, dir);
242 		break;
243 	}
244 
245 	cv_init(&c->cv, "pcmchn");
246 }
247 
248 static void
chn_lockdestroy(struct pcm_channel * c)249 chn_lockdestroy(struct pcm_channel *c)
250 {
251 	CHN_LOCKASSERT(c);
252 
253 	CHN_BROADCAST(&c->cv);
254 	CHN_BROADCAST(&c->intr_cv);
255 
256 	cv_destroy(&c->cv);
257 	cv_destroy(&c->intr_cv);
258 
259 	snd_mtxfree(c->lock);
260 }
261 
262 /**
263  * @brief Determine channel is ready for I/O
264  *
265  * @retval 1 = ready for I/O
266  * @retval 0 = not ready for I/O
267  */
268 static int
chn_polltrigger(struct pcm_channel * c)269 chn_polltrigger(struct pcm_channel *c)
270 {
271 	struct snd_dbuf *bs = c->bufsoft;
272 	u_int delta;
273 
274 	CHN_LOCKASSERT(c);
275 
276 	if (c->flags & CHN_F_MMAP) {
277 		if (sndbuf_getprevtotal(bs) < c->lw)
278 			delta = c->lw;
279 		else
280 			delta = sndbuf_gettotal(bs) - sndbuf_getprevtotal(bs);
281 	} else {
282 		if (c->direction == PCMDIR_PLAY)
283 			delta = sndbuf_getfree(bs);
284 		else
285 			delta = sndbuf_getready(bs);
286 	}
287 
288 	return ((delta < c->lw) ? 0 : 1);
289 }
290 
291 static void
chn_pollreset(struct pcm_channel * c)292 chn_pollreset(struct pcm_channel *c)
293 {
294 
295 	CHN_LOCKASSERT(c);
296 	sndbuf_updateprevtotal(c->bufsoft);
297 }
298 
299 static void
chn_wakeup(struct pcm_channel * c)300 chn_wakeup(struct pcm_channel *c)
301 {
302 	struct snd_dbuf *bs;
303 	struct pcm_channel *ch;
304 
305 	CHN_LOCKASSERT(c);
306 
307 	bs = c->bufsoft;
308 
309 	if (CHN_EMPTY(c, children.busy)) {
310 		if (SEL_WAITING(sndbuf_getsel(bs)) && chn_polltrigger(c))
311 			selwakeuppri(sndbuf_getsel(bs), PRIBIO);
312 		if (c->flags & CHN_F_SLEEPING) {
313 			/*
314 			 * Ok, I can just panic it right here since it is
315 			 * quite obvious that we never allow multiple waiters
316 			 * from userland. I'm too generous...
317 			 */
318 			CHN_BROADCAST(&c->intr_cv);
319 		}
320 	} else {
321 		CHN_FOREACH(ch, c, children.busy) {
322 			CHN_LOCK(ch);
323 			chn_wakeup(ch);
324 			CHN_UNLOCK(ch);
325 		}
326 	}
327 }
328 
329 static int
chn_sleep(struct pcm_channel * c,int timeout)330 chn_sleep(struct pcm_channel *c, int timeout)
331 {
332 	int ret;
333 
334 	CHN_LOCKASSERT(c);
335 	KASSERT((c->flags & CHN_F_SLEEPING) == 0,
336 	    ("%s(): entered with CHN_F_SLEEPING", __func__));
337 
338 	if (c->flags & CHN_F_DEAD)
339 		return (EINVAL);
340 
341 	c->flags |= CHN_F_SLEEPING;
342 	ret = cv_timedwait_sig(&c->intr_cv, c->lock, timeout);
343 	c->flags &= ~CHN_F_SLEEPING;
344 
345 	return ((c->flags & CHN_F_DEAD) ? EINVAL : ret);
346 }
347 
348 /*
349  * chn_dmaupdate() tracks the status of a dma transfer,
350  * updating pointers.
351  */
352 
353 static unsigned int
chn_dmaupdate(struct pcm_channel * c)354 chn_dmaupdate(struct pcm_channel *c)
355 {
356 	struct snd_dbuf *b = c->bufhard;
357 	unsigned int delta, old, hwptr, amt;
358 
359 	KASSERT(sndbuf_getsize(b) > 0, ("bufsize == 0"));
360 	CHN_LOCKASSERT(c);
361 
362 	old = sndbuf_gethwptr(b);
363 	hwptr = chn_getptr(c);
364 	delta = (sndbuf_getsize(b) + hwptr - old) % sndbuf_getsize(b);
365 	sndbuf_sethwptr(b, hwptr);
366 
367 	if (c->direction == PCMDIR_PLAY) {
368 		amt = min(delta, sndbuf_getready(b));
369 		amt -= amt % sndbuf_getalign(b);
370 		if (amt > 0)
371 			sndbuf_dispose(b, NULL, amt);
372 	} else {
373 		amt = min(delta, sndbuf_getfree(b));
374 		amt -= amt % sndbuf_getalign(b);
375 		if (amt > 0)
376 		       sndbuf_acquire(b, NULL, amt);
377 	}
378 	if (snd_verbose > 3 && CHN_STARTED(c) && delta == 0) {
379 		device_printf(c->dev, "WARNING: %s DMA completion "
380 			"too fast/slow ! hwptr=%u, old=%u "
381 			"delta=%u amt=%u ready=%u free=%u\n",
382 			CHN_DIRSTR(c), hwptr, old, delta, amt,
383 			sndbuf_getready(b), sndbuf_getfree(b));
384 	}
385 
386 	return delta;
387 }
388 
389 static void
chn_wrfeed(struct pcm_channel * c)390 chn_wrfeed(struct pcm_channel *c)
391 {
392     	struct snd_dbuf *b = c->bufhard;
393     	struct snd_dbuf *bs = c->bufsoft;
394 	unsigned int amt, want, wasfree;
395 
396 	CHN_LOCKASSERT(c);
397 
398 	if ((c->flags & CHN_F_MMAP) && !(c->flags & CHN_F_CLOSING))
399 		sndbuf_acquire(bs, NULL, sndbuf_getfree(bs));
400 
401 	wasfree = sndbuf_getfree(b);
402 	want = min(sndbuf_getsize(b),
403 	    imax(0, sndbuf_xbytes(sndbuf_getsize(bs), bs, b) -
404 	     sndbuf_getready(b)));
405 	amt = min(wasfree, want);
406 	if (amt > 0)
407 		sndbuf_feed(bs, b, c, c->feeder, amt);
408 
409 	/*
410 	 * Possible xruns. There should be no empty space left in buffer.
411 	 */
412 	if (sndbuf_getready(b) < want)
413 		c->xruns++;
414 
415 	if (sndbuf_getfree(b) < wasfree)
416 		chn_wakeup(c);
417 }
418 
419 #if 0
420 static void
421 chn_wrupdate(struct pcm_channel *c)
422 {
423 
424 	CHN_LOCKASSERT(c);
425 	KASSERT(c->direction == PCMDIR_PLAY, ("%s(): bad channel", __func__));
426 
427 	if ((c->flags & (CHN_F_MMAP | CHN_F_VIRTUAL)) || CHN_STOPPED(c))
428 		return;
429 	chn_dmaupdate(c);
430 	chn_wrfeed(c);
431 	/* tell the driver we've updated the primary buffer */
432 	chn_trigger(c, PCMTRIG_EMLDMAWR);
433 }
434 #endif
435 
436 static void
chn_wrintr(struct pcm_channel * c)437 chn_wrintr(struct pcm_channel *c)
438 {
439 
440 	CHN_LOCKASSERT(c);
441 	/* update pointers in primary buffer */
442 	chn_dmaupdate(c);
443 	/* ...and feed from secondary to primary */
444 	chn_wrfeed(c);
445 	/* tell the driver we've updated the primary buffer */
446 	chn_trigger(c, PCMTRIG_EMLDMAWR);
447 }
448 
449 /*
450  * user write routine - uiomove data into secondary buffer, trigger if necessary
451  * if blocking, sleep, rinse and repeat.
452  *
453  * called externally, so must handle locking
454  */
455 
456 int
chn_write(struct pcm_channel * c,struct uio * buf)457 chn_write(struct pcm_channel *c, struct uio *buf)
458 {
459 	struct snd_dbuf *bs = c->bufsoft;
460 	void *off;
461 	int ret, timeout, sz, t, p;
462 
463 	CHN_LOCKASSERT(c);
464 
465 	ret = 0;
466 	timeout = chn_timeout * hz;
467 
468 	while (ret == 0 && buf->uio_resid > 0) {
469 		sz = min(buf->uio_resid, sndbuf_getfree(bs));
470 		if (sz > 0) {
471 			/*
472 			 * The following assumes that the free space in
473 			 * the buffer can never be less around the
474 			 * unlock-uiomove-lock sequence.
475 			 */
476 			while (ret == 0 && sz > 0) {
477 				p = sndbuf_getfreeptr(bs);
478 				t = min(sz, sndbuf_getsize(bs) - p);
479 				off = sndbuf_getbufofs(bs, p);
480 				CHN_UNLOCK(c);
481 				ret = uiomove(off, t, buf);
482 				CHN_LOCK(c);
483 				sz -= t;
484 				sndbuf_acquire(bs, NULL, t);
485 			}
486 			ret = 0;
487 			if (CHN_STOPPED(c) && !(c->flags & CHN_F_NOTRIGGER)) {
488 				ret = chn_start(c, 0);
489 				if (ret != 0)
490 					c->flags |= CHN_F_DEAD;
491 			}
492 		} else if (c->flags & (CHN_F_NBIO | CHN_F_NOTRIGGER)) {
493 			/**
494 			 * @todo Evaluate whether EAGAIN is truly desirable.
495 			 * 	 4Front drivers behave like this, but I'm
496 			 * 	 not sure if it at all violates the "write
497 			 * 	 should be allowed to block" model.
498 			 *
499 			 * 	 The idea is that, while set with CHN_F_NOTRIGGER,
500 			 * 	 a channel isn't playing, *but* without this we
501 			 * 	 end up with "interrupt timeout / channel dead".
502 			 */
503 			ret = EAGAIN;
504 		} else {
505    			ret = chn_sleep(c, timeout);
506 			if (ret == EAGAIN) {
507 				ret = EINVAL;
508 				c->flags |= CHN_F_DEAD;
509 				device_printf(c->dev, "%s(): %s: "
510 				    "play interrupt timeout, channel dead\n",
511 				    __func__, c->name);
512 			} else if (ret == ERESTART || ret == EINTR)
513 				c->flags |= CHN_F_ABORTING;
514 		}
515 	}
516 
517 	return (ret);
518 }
519 
520 /*
521  * Feed new data from the read buffer. Can be called in the bottom half.
522  */
523 static void
chn_rdfeed(struct pcm_channel * c)524 chn_rdfeed(struct pcm_channel *c)
525 {
526     	struct snd_dbuf *b = c->bufhard;
527     	struct snd_dbuf *bs = c->bufsoft;
528 	unsigned int amt;
529 
530 	CHN_LOCKASSERT(c);
531 
532 	if (c->flags & CHN_F_MMAP)
533 		sndbuf_dispose(bs, NULL, sndbuf_getready(bs));
534 
535 	amt = sndbuf_getfree(bs);
536 	if (amt > 0)
537 		sndbuf_feed(b, bs, c, c->feeder, amt);
538 
539 	amt = sndbuf_getready(b);
540 	if (amt > 0) {
541 		c->xruns++;
542 		sndbuf_dispose(b, NULL, amt);
543 	}
544 
545 	if (sndbuf_getready(bs) > 0)
546 		chn_wakeup(c);
547 }
548 
549 #if 0
550 static void
551 chn_rdupdate(struct pcm_channel *c)
552 {
553 
554 	CHN_LOCKASSERT(c);
555 	KASSERT(c->direction == PCMDIR_REC, ("chn_rdupdate on bad channel"));
556 
557 	if ((c->flags & (CHN_F_MMAP | CHN_F_VIRTUAL)) || CHN_STOPPED(c))
558 		return;
559 	chn_trigger(c, PCMTRIG_EMLDMARD);
560 	chn_dmaupdate(c);
561 	chn_rdfeed(c);
562 }
563 #endif
564 
565 /* read interrupt routine. Must be called with interrupts blocked. */
566 static void
chn_rdintr(struct pcm_channel * c)567 chn_rdintr(struct pcm_channel *c)
568 {
569 
570 	CHN_LOCKASSERT(c);
571 	/* tell the driver to update the primary buffer if non-dma */
572 	chn_trigger(c, PCMTRIG_EMLDMARD);
573 	/* update pointers in primary buffer */
574 	chn_dmaupdate(c);
575 	/* ...and feed from primary to secondary */
576 	chn_rdfeed(c);
577 }
578 
579 /*
580  * user read routine - trigger if necessary, uiomove data from secondary buffer
581  * if blocking, sleep, rinse and repeat.
582  *
583  * called externally, so must handle locking
584  */
585 
586 int
chn_read(struct pcm_channel * c,struct uio * buf)587 chn_read(struct pcm_channel *c, struct uio *buf)
588 {
589 	struct snd_dbuf *bs = c->bufsoft;
590 	void *off;
591 	int ret, timeout, sz, t, p;
592 
593 	CHN_LOCKASSERT(c);
594 
595 	if (CHN_STOPPED(c) && !(c->flags & CHN_F_NOTRIGGER)) {
596 		ret = chn_start(c, 0);
597 		if (ret != 0) {
598 			c->flags |= CHN_F_DEAD;
599 			return (ret);
600 		}
601 	}
602 
603 	ret = 0;
604 	timeout = chn_timeout * hz;
605 
606 	while (ret == 0 && buf->uio_resid > 0) {
607 		sz = min(buf->uio_resid, sndbuf_getready(bs));
608 		if (sz > 0) {
609 			/*
610 			 * The following assumes that the free space in
611 			 * the buffer can never be less around the
612 			 * unlock-uiomove-lock sequence.
613 			 */
614 			while (ret == 0 && sz > 0) {
615 				p = sndbuf_getreadyptr(bs);
616 				t = min(sz, sndbuf_getsize(bs) - p);
617 				off = sndbuf_getbufofs(bs, p);
618 				CHN_UNLOCK(c);
619 				ret = uiomove(off, t, buf);
620 				CHN_LOCK(c);
621 				sz -= t;
622 				sndbuf_dispose(bs, NULL, t);
623 			}
624 			ret = 0;
625 		} else if (c->flags & (CHN_F_NBIO | CHN_F_NOTRIGGER))
626 			ret = EAGAIN;
627 		else {
628    			ret = chn_sleep(c, timeout);
629 			if (ret == EAGAIN) {
630 				ret = EINVAL;
631 				c->flags |= CHN_F_DEAD;
632 				device_printf(c->dev, "%s(): %s: "
633 				    "record interrupt timeout, channel dead\n",
634 				    __func__, c->name);
635 			} else if (ret == ERESTART || ret == EINTR)
636 				c->flags |= CHN_F_ABORTING;
637 		}
638 	}
639 
640 	return (ret);
641 }
642 
643 void
chn_intr_locked(struct pcm_channel * c)644 chn_intr_locked(struct pcm_channel *c)
645 {
646 
647 	CHN_LOCKASSERT(c);
648 
649 	c->interrupts++;
650 
651 	if (c->direction == PCMDIR_PLAY)
652 		chn_wrintr(c);
653 	else
654 		chn_rdintr(c);
655 }
656 
657 void
chn_intr(struct pcm_channel * c)658 chn_intr(struct pcm_channel *c)
659 {
660 
661 	if (CHN_LOCKOWNED(c)) {
662 		chn_intr_locked(c);
663 		return;
664 	}
665 
666 	CHN_LOCK(c);
667 	chn_intr_locked(c);
668 	CHN_UNLOCK(c);
669 }
670 
671 u_int32_t
chn_start(struct pcm_channel * c,int force)672 chn_start(struct pcm_channel *c, int force)
673 {
674 	u_int32_t i, j;
675 	struct snd_dbuf *b = c->bufhard;
676 	struct snd_dbuf *bs = c->bufsoft;
677 	int err;
678 
679 	CHN_LOCKASSERT(c);
680 	/* if we're running, or if we're prevented from triggering, bail */
681 	if (CHN_STARTED(c) || ((c->flags & CHN_F_NOTRIGGER) && !force))
682 		return (EINVAL);
683 
684 	err = 0;
685 
686 	if (force) {
687 		i = 1;
688 		j = 0;
689 	} else {
690 		if (c->direction == PCMDIR_REC) {
691 			i = sndbuf_getfree(bs);
692 			j = (i > 0) ? 1 : sndbuf_getready(b);
693 		} else {
694 			if (sndbuf_getfree(bs) == 0) {
695 				i = 1;
696 				j = 0;
697 			} else {
698 				struct snd_dbuf *pb;
699 
700 				pb = CHN_BUF_PARENT(c, b);
701 				i = sndbuf_xbytes(sndbuf_getready(bs), bs, pb);
702 				j = sndbuf_getalign(pb);
703 			}
704 		}
705 		if (snd_verbose > 3 && CHN_EMPTY(c, children))
706 			device_printf(c->dev, "%s(): %s (%s) threshold "
707 			    "i=%d j=%d\n", __func__, CHN_DIRSTR(c),
708 			    (c->flags & CHN_F_VIRTUAL) ? "virtual" :
709 			    "hardware", i, j);
710 	}
711 
712 	if (i >= j) {
713 		c->flags |= CHN_F_TRIGGERED;
714 		sndbuf_setrun(b, 1);
715 		if (c->flags & CHN_F_CLOSING)
716 			c->feedcount = 2;
717 		else {
718 			c->feedcount = 0;
719 			c->interrupts = 0;
720 			c->xruns = 0;
721 		}
722 		if (c->parentchannel == NULL) {
723 			if (c->direction == PCMDIR_PLAY)
724 				sndbuf_fillsilence_rl(b,
725 				    sndbuf_xbytes(sndbuf_getsize(bs), bs, b));
726 			if (snd_verbose > 3)
727 				device_printf(c->dev,
728 				    "%s(): %s starting! (%s/%s) "
729 				    "(ready=%d force=%d i=%d j=%d "
730 				    "intrtimeout=%u latency=%dms)\n",
731 				    __func__,
732 				    (c->flags & CHN_F_HAS_VCHAN) ?
733 				    "VCHAN PARENT" : "HW", CHN_DIRSTR(c),
734 				    (c->flags & CHN_F_CLOSING) ? "closing" :
735 				    "running",
736 				    sndbuf_getready(b),
737 				    force, i, j, c->timeout,
738 				    (sndbuf_getsize(b) * 1000) /
739 				    (sndbuf_getalign(b) * sndbuf_getspd(b)));
740 		}
741 		err = chn_trigger(c, PCMTRIG_START);
742 	}
743 
744 	return (err);
745 }
746 
747 void
chn_resetbuf(struct pcm_channel * c)748 chn_resetbuf(struct pcm_channel *c)
749 {
750 	struct snd_dbuf *b = c->bufhard;
751 	struct snd_dbuf *bs = c->bufsoft;
752 
753 	c->blocks = 0;
754 	sndbuf_reset(b);
755 	sndbuf_reset(bs);
756 }
757 
758 /*
759  * chn_sync waits until the space in the given channel goes above
760  * a threshold. The threshold is checked against fl or rl respectively.
761  * Assume that the condition can become true, do not check here...
762  */
763 int
chn_sync(struct pcm_channel * c,int threshold)764 chn_sync(struct pcm_channel *c, int threshold)
765 {
766     	struct snd_dbuf *b, *bs;
767 	int ret, count, hcount, minflush, resid, residp, syncdelay, blksz;
768 	u_int32_t cflag;
769 
770 	CHN_LOCKASSERT(c);
771 
772 	if (c->direction != PCMDIR_PLAY)
773 		return (EINVAL);
774 
775 	bs = c->bufsoft;
776 
777 	if ((c->flags & (CHN_F_DEAD | CHN_F_ABORTING)) ||
778 	    (threshold < 1 && sndbuf_getready(bs) < 1))
779 		return (0);
780 
781 	/* if we haven't yet started and nothing is buffered, else start*/
782 	if (CHN_STOPPED(c)) {
783 		if (threshold > 0 || sndbuf_getready(bs) > 0) {
784 			ret = chn_start(c, 1);
785 			if (ret != 0)
786 				return (ret);
787 		} else
788 			return (0);
789 	}
790 
791 	b = CHN_BUF_PARENT(c, c->bufhard);
792 
793 	minflush = threshold + sndbuf_xbytes(sndbuf_getready(b), b, bs);
794 
795 	syncdelay = chn_syncdelay;
796 
797 	if (syncdelay < 0 && (threshold > 0 || sndbuf_getready(bs) > 0))
798 		minflush += sndbuf_xbytes(sndbuf_getsize(b), b, bs);
799 
800 	/*
801 	 * Append (0-1000) millisecond trailing buffer (if needed)
802 	 * for slower / high latency hardwares (notably USB audio)
803 	 * to avoid audible truncation.
804 	 */
805 	if (syncdelay > 0)
806 		minflush += (sndbuf_getalign(bs) * sndbuf_getspd(bs) *
807 		    ((syncdelay > 1000) ? 1000 : syncdelay)) / 1000;
808 
809 	minflush -= minflush % sndbuf_getalign(bs);
810 
811 	if (minflush > 0) {
812 		threshold = min(minflush, sndbuf_getfree(bs));
813 		sndbuf_clear(bs, threshold);
814 		sndbuf_acquire(bs, NULL, threshold);
815 		minflush -= threshold;
816 	}
817 
818 	resid = sndbuf_getready(bs);
819 	residp = resid;
820 	blksz = sndbuf_getblksz(b);
821 	if (blksz < 1) {
822 		device_printf(c->dev,
823 		    "%s(): WARNING: blksz < 1 ! maxsize=%d [%d/%d/%d]\n",
824 		    __func__, sndbuf_getmaxsize(b), sndbuf_getsize(b),
825 		    sndbuf_getblksz(b), sndbuf_getblkcnt(b));
826 		if (sndbuf_getblkcnt(b) > 0)
827 			blksz = sndbuf_getsize(b) / sndbuf_getblkcnt(b);
828 		if (blksz < 1)
829 			blksz = 1;
830 	}
831 	count = sndbuf_xbytes(minflush + resid, bs, b) / blksz;
832 	hcount = count;
833 	ret = 0;
834 
835 	if (snd_verbose > 3)
836 		device_printf(c->dev, "%s(): [begin] timeout=%d count=%d "
837 		    "minflush=%d resid=%d\n", __func__, c->timeout, count,
838 		    minflush, resid);
839 
840 	cflag = c->flags & CHN_F_CLOSING;
841 	c->flags |= CHN_F_CLOSING;
842 	while (count > 0 && (resid > 0 || minflush > 0)) {
843 		ret = chn_sleep(c, c->timeout);
844     		if (ret == ERESTART || ret == EINTR) {
845 			c->flags |= CHN_F_ABORTING;
846 			break;
847 		} else if (ret == 0 || ret == EAGAIN) {
848 			resid = sndbuf_getready(bs);
849 			if (resid == residp) {
850 				--count;
851 				if (snd_verbose > 3)
852 					device_printf(c->dev,
853 					    "%s(): [stalled] timeout=%d "
854 					    "count=%d hcount=%d "
855 					    "resid=%d minflush=%d\n",
856 					    __func__, c->timeout, count,
857 					    hcount, resid, minflush);
858 			} else if (resid < residp && count < hcount) {
859 				++count;
860 				if (snd_verbose > 3)
861 					device_printf(c->dev,
862 					    "%s((): [resume] timeout=%d "
863 					    "count=%d hcount=%d "
864 					    "resid=%d minflush=%d\n",
865 					    __func__, c->timeout, count,
866 					    hcount, resid, minflush);
867 			}
868 			if (minflush > 0 && sndbuf_getfree(bs) > 0) {
869 				threshold = min(minflush,
870 				    sndbuf_getfree(bs));
871 				sndbuf_clear(bs, threshold);
872 				sndbuf_acquire(bs, NULL, threshold);
873 				resid = sndbuf_getready(bs);
874 				minflush -= threshold;
875 			}
876 			residp = resid;
877 		} else
878 			break;
879 	}
880 	c->flags &= ~CHN_F_CLOSING;
881 	c->flags |= cflag;
882 
883 	if (snd_verbose > 3)
884 		device_printf(c->dev,
885 		    "%s(): timeout=%d count=%d hcount=%d resid=%d residp=%d "
886 		    "minflush=%d ret=%d\n",
887 		    __func__, c->timeout, count, hcount, resid, residp,
888 		    minflush, ret);
889 
890     	return (0);
891 }
892 
893 /* called externally, handle locking */
894 int
chn_poll(struct pcm_channel * c,int ev,struct thread * td)895 chn_poll(struct pcm_channel *c, int ev, struct thread *td)
896 {
897 	struct snd_dbuf *bs = c->bufsoft;
898 	int ret;
899 
900 	CHN_LOCKASSERT(c);
901 
902     	if (!(c->flags & (CHN_F_MMAP | CHN_F_TRIGGERED))) {
903 		ret = chn_start(c, 1);
904 		if (ret != 0)
905 			return (0);
906 	}
907 
908 	ret = 0;
909 	if (chn_polltrigger(c)) {
910 		chn_pollreset(c);
911 		ret = ev;
912 	} else
913 		selrecord(td, sndbuf_getsel(bs));
914 
915 	return (ret);
916 }
917 
918 /*
919  * chn_abort terminates a running dma transfer.  it may sleep up to 200ms.
920  * it returns the number of bytes that have not been transferred.
921  *
922  * called from: dsp_close, dsp_ioctl, with channel locked
923  */
924 int
chn_abort(struct pcm_channel * c)925 chn_abort(struct pcm_channel *c)
926 {
927     	int missing = 0;
928     	struct snd_dbuf *b = c->bufhard;
929     	struct snd_dbuf *bs = c->bufsoft;
930 
931 	CHN_LOCKASSERT(c);
932 	if (CHN_STOPPED(c))
933 		return 0;
934 	c->flags |= CHN_F_ABORTING;
935 
936 	c->flags &= ~CHN_F_TRIGGERED;
937 	/* kill the channel */
938 	chn_trigger(c, PCMTRIG_ABORT);
939 	sndbuf_setrun(b, 0);
940 	if (!(c->flags & CHN_F_VIRTUAL))
941 		chn_dmaupdate(c);
942     	missing = sndbuf_getready(bs);
943 
944 	c->flags &= ~CHN_F_ABORTING;
945 	return missing;
946 }
947 
948 /*
949  * this routine tries to flush the dma transfer. It is called
950  * on a close of a playback channel.
951  * first, if there is data in the buffer, but the dma has not yet
952  * begun, we need to start it.
953  * next, we wait for the play buffer to drain
954  * finally, we stop the dma.
955  *
956  * called from: dsp_close, not valid for record channels.
957  */
958 
959 int
chn_flush(struct pcm_channel * c)960 chn_flush(struct pcm_channel *c)
961 {
962     	struct snd_dbuf *b = c->bufhard;
963 
964 	CHN_LOCKASSERT(c);
965 	KASSERT(c->direction == PCMDIR_PLAY, ("chn_flush on bad channel"));
966     	DEB(printf("chn_flush: c->flags 0x%08x\n", c->flags));
967 
968 	c->flags |= CHN_F_CLOSING;
969 	chn_sync(c, 0);
970 	c->flags &= ~CHN_F_TRIGGERED;
971 	/* kill the channel */
972 	chn_trigger(c, PCMTRIG_ABORT);
973 	sndbuf_setrun(b, 0);
974 
975     	c->flags &= ~CHN_F_CLOSING;
976     	return 0;
977 }
978 
979 int
snd_fmtvalid(uint32_t fmt,uint32_t * fmtlist)980 snd_fmtvalid(uint32_t fmt, uint32_t *fmtlist)
981 {
982 	int i;
983 
984 	for (i = 0; fmtlist[i] != 0; i++) {
985 		if (fmt == fmtlist[i] ||
986 		    ((fmt & AFMT_PASSTHROUGH) &&
987 		    (AFMT_ENCODING(fmt) & fmtlist[i])))
988 			return (1);
989 	}
990 
991 	return (0);
992 }
993 
994 static const struct {
995 	char *name, *alias1, *alias2;
996 	uint32_t afmt;
997 } afmt_tab[] = {
998 	{  "alaw",  NULL, NULL, AFMT_A_LAW  },
999 	{ "mulaw",  NULL, NULL, AFMT_MU_LAW },
1000 	{    "u8",   "8", NULL, AFMT_U8     },
1001 	{    "s8",  NULL, NULL, AFMT_S8     },
1002 #if BYTE_ORDER == LITTLE_ENDIAN
1003 	{ "s16le", "s16", "16", AFMT_S16_LE },
1004 	{ "s16be",  NULL, NULL, AFMT_S16_BE },
1005 #else
1006 	{ "s16le",  NULL, NULL, AFMT_S16_LE },
1007 	{ "s16be", "s16", "16", AFMT_S16_BE },
1008 #endif
1009 	{ "u16le",  NULL, NULL, AFMT_U16_LE },
1010 	{ "u16be",  NULL, NULL, AFMT_U16_BE },
1011 	{ "s24le",  NULL, NULL, AFMT_S24_LE },
1012 	{ "s24be",  NULL, NULL, AFMT_S24_BE },
1013 	{ "u24le",  NULL, NULL, AFMT_U24_LE },
1014 	{ "u24be",  NULL, NULL, AFMT_U24_BE },
1015 #if BYTE_ORDER == LITTLE_ENDIAN
1016 	{ "s32le", "s32", "32", AFMT_S32_LE },
1017 	{ "s32be",  NULL, NULL, AFMT_S32_BE },
1018 #else
1019 	{ "s32le",  NULL, NULL, AFMT_S32_LE },
1020 	{ "s32be", "s32", "32", AFMT_S32_BE },
1021 #endif
1022 	{ "u32le",  NULL, NULL, AFMT_U32_LE },
1023 	{ "u32be",  NULL, NULL, AFMT_U32_BE },
1024 	{   "ac3",  NULL, NULL, AFMT_AC3    },
1025 	{    NULL,  NULL, NULL, 0           }
1026 };
1027 
1028 uint32_t
snd_str2afmt(const char * req)1029 snd_str2afmt(const char *req)
1030 {
1031 	int ext;
1032 	int ch;
1033 	int i;
1034 	char b1[8];
1035 	char b2[8];
1036 
1037 	memset(b1, 0, sizeof(b1));
1038 	memset(b2, 0, sizeof(b2));
1039 
1040 	i = sscanf(req, "%5[^:]:%6s", b1, b2);
1041 
1042 	if (i == 1) {
1043 		if (strlen(req) != strlen(b1))
1044 			return (0);
1045 		strlcpy(b2, "2.0", sizeof(b2));
1046 	} else if (i == 2) {
1047 		if (strlen(req) != (strlen(b1) + 1 + strlen(b2)))
1048 			return (0);
1049 	} else
1050 		return (0);
1051 
1052 	i = sscanf(b2, "%d.%d", &ch, &ext);
1053 
1054 	if (i == 0) {
1055 		if (strcasecmp(b2, "mono") == 0) {
1056 			ch = 1;
1057 			ext = 0;
1058 		} else if (strcasecmp(b2, "stereo") == 0) {
1059 			ch = 2;
1060 			ext = 0;
1061 		} else if (strcasecmp(b2, "quad") == 0) {
1062 			ch = 4;
1063 			ext = 0;
1064 		} else
1065 			return (0);
1066 	} else if (i == 1) {
1067 		if (ch < 1 || ch > AFMT_CHANNEL_MAX)
1068 			return (0);
1069 		ext = 0;
1070 	} else if (i == 2) {
1071 		if (ext < 0 || ext > AFMT_EXTCHANNEL_MAX)
1072 			return (0);
1073 		if (ch < 1 || (ch + ext) > AFMT_CHANNEL_MAX)
1074 			return (0);
1075 	} else
1076 		return (0);
1077 
1078 	for (i = 0; afmt_tab[i].name != NULL; i++) {
1079 		if (strcasecmp(afmt_tab[i].name, b1) != 0) {
1080 			if (afmt_tab[i].alias1 == NULL)
1081 				continue;
1082 			if (strcasecmp(afmt_tab[i].alias1, b1) != 0) {
1083 				if (afmt_tab[i].alias2 == NULL)
1084 					continue;
1085 				if (strcasecmp(afmt_tab[i].alias2, b1) != 0)
1086 					continue;
1087 			}
1088 		}
1089 		/* found a match */
1090 		return (SND_FORMAT(afmt_tab[i].afmt, ch + ext, ext));
1091 	}
1092 	/* not a valid format */
1093 	return (0);
1094 }
1095 
1096 uint32_t
snd_afmt2str(uint32_t afmt,char * buf,size_t len)1097 snd_afmt2str(uint32_t afmt, char *buf, size_t len)
1098 {
1099 	uint32_t enc;
1100 	uint32_t ext;
1101 	uint32_t ch;
1102 	int i;
1103 
1104 	if (buf == NULL || len < AFMTSTR_LEN)
1105 		return (0);
1106 
1107 	memset(buf, 0, len);
1108 
1109 	enc = AFMT_ENCODING(afmt);
1110 	ch = AFMT_CHANNEL(afmt);
1111 	ext = AFMT_EXTCHANNEL(afmt);
1112 	/* check there is at least one channel */
1113 	if (ch <= ext)
1114 		return (0);
1115 	for (i = 0; afmt_tab[i].name != NULL; i++) {
1116 		if (enc != afmt_tab[i].afmt)
1117 			continue;
1118 		/* found a match */
1119 		snprintf(buf, len, "%s:%d.%d",
1120 		    afmt_tab[i].name, ch - ext, ext);
1121 		return (SND_FORMAT(enc, ch, ext));
1122 	}
1123 	return (0);
1124 }
1125 
1126 int
chn_reset(struct pcm_channel * c,uint32_t fmt,uint32_t spd)1127 chn_reset(struct pcm_channel *c, uint32_t fmt, uint32_t spd)
1128 {
1129 	int r;
1130 
1131 	CHN_LOCKASSERT(c);
1132 	c->feedcount = 0;
1133 	c->flags &= CHN_F_RESET;
1134 	c->interrupts = 0;
1135 	c->timeout = 1;
1136 	c->xruns = 0;
1137 
1138 	c->flags |= (pcm_getflags(c->dev) & SD_F_BITPERFECT) ?
1139 	    CHN_F_BITPERFECT : 0;
1140 
1141 	r = CHANNEL_RESET(c->methods, c->devinfo);
1142 	if (r == 0 && fmt != 0 && spd != 0) {
1143 		r = chn_setparam(c, fmt, spd);
1144 		fmt = 0;
1145 		spd = 0;
1146 	}
1147 	if (r == 0 && fmt != 0)
1148 		r = chn_setformat(c, fmt);
1149 	if (r == 0 && spd != 0)
1150 		r = chn_setspeed(c, spd);
1151 	if (r == 0)
1152 		r = chn_setlatency(c, chn_latency);
1153 	if (r == 0) {
1154 		chn_resetbuf(c);
1155 		r = CHANNEL_RESETDONE(c->methods, c->devinfo);
1156 	}
1157 	return r;
1158 }
1159 
1160 int
chn_init(struct pcm_channel * c,void * devinfo,int dir,int direction)1161 chn_init(struct pcm_channel *c, void *devinfo, int dir, int direction)
1162 {
1163 	struct feeder_class *fc;
1164 	struct snd_dbuf *b, *bs;
1165 	int i, ret;
1166 
1167 	chn_lockinit(c, dir);
1168 
1169 	b = NULL;
1170 	bs = NULL;
1171 	CHN_INIT(c, children);
1172 	CHN_INIT(c, children.busy);
1173 	c->devinfo = NULL;
1174 	c->feeder = NULL;
1175 	c->latency = -1;
1176 	c->timeout = 1;
1177 
1178 	ret = ENOMEM;
1179 	b = sndbuf_create(c->dev, c->name, "primary", c);
1180 	if (b == NULL)
1181 		goto out;
1182 	bs = sndbuf_create(c->dev, c->name, "secondary", c);
1183 	if (bs == NULL)
1184 		goto out;
1185 
1186 	CHN_LOCK(c);
1187 
1188 	ret = EINVAL;
1189 	fc = feeder_getclass(NULL);
1190 	if (fc == NULL)
1191 		goto out;
1192 	if (chn_addfeeder(c, fc, NULL))
1193 		goto out;
1194 
1195 	/*
1196 	 * XXX - sndbuf_setup() & sndbuf_resize() expect to be called
1197 	 *	 with the channel unlocked because they are also called
1198 	 *	 from driver methods that don't know about locking
1199 	 */
1200 	CHN_UNLOCK(c);
1201 	sndbuf_setup(bs, NULL, 0);
1202 	CHN_LOCK(c);
1203 	c->bufhard = b;
1204 	c->bufsoft = bs;
1205 	c->flags = 0;
1206 	c->feederflags = 0;
1207 	c->sm = NULL;
1208 	c->format = SND_FORMAT(AFMT_U8, 1, 0);
1209 	c->speed = DSP_DEFAULT_SPEED;
1210 
1211 	c->matrix = *feeder_matrix_id_map(SND_CHN_MATRIX_1_0);
1212 	c->matrix.id = SND_CHN_MATRIX_PCMCHANNEL;
1213 
1214 	for (i = 0; i < SND_CHN_T_MAX; i++) {
1215 		c->volume[SND_VOL_C_MASTER][i] = SND_VOL_0DB_MASTER;
1216 	}
1217 
1218 	c->volume[SND_VOL_C_MASTER][SND_CHN_T_VOL_0DB] = SND_VOL_0DB_MASTER;
1219 	c->volume[SND_VOL_C_PCM][SND_CHN_T_VOL_0DB] = chn_vol_0db_pcm;
1220 
1221 	memset(c->muted, 0, sizeof(c->muted));
1222 
1223 	chn_vpc_reset(c, SND_VOL_C_PCM, 1);
1224 
1225 	ret = ENODEV;
1226 	CHN_UNLOCK(c); /* XXX - Unlock for CHANNEL_INIT() malloc() call */
1227 	c->devinfo = CHANNEL_INIT(c->methods, devinfo, b, c, direction);
1228 	CHN_LOCK(c);
1229 	if (c->devinfo == NULL)
1230 		goto out;
1231 
1232 	ret = ENOMEM;
1233 	if ((sndbuf_getsize(b) == 0) && ((c->flags & CHN_F_VIRTUAL) == 0))
1234 		goto out;
1235 
1236 	ret = 0;
1237 	c->direction = direction;
1238 
1239 	sndbuf_setfmt(b, c->format);
1240 	sndbuf_setspd(b, c->speed);
1241 	sndbuf_setfmt(bs, c->format);
1242 	sndbuf_setspd(bs, c->speed);
1243 
1244 	/**
1245 	 * @todo Should this be moved somewhere else?  The primary buffer
1246 	 * 	 is allocated by the driver or via DMA map setup, and tmpbuf
1247 	 * 	 seems to only come into existence in sndbuf_resize().
1248 	 */
1249 	if (c->direction == PCMDIR_PLAY) {
1250 		bs->sl = sndbuf_getmaxsize(bs);
1251 		bs->shadbuf = malloc(bs->sl, M_DEVBUF, M_NOWAIT);
1252 		if (bs->shadbuf == NULL) {
1253 			ret = ENOMEM;
1254 			goto out;
1255 		}
1256 	}
1257 
1258 out:
1259 	CHN_UNLOCK(c);
1260 	if (ret) {
1261 		if (c->devinfo) {
1262 			if (CHANNEL_FREE(c->methods, c->devinfo))
1263 				sndbuf_free(b);
1264 		}
1265 		if (bs)
1266 			sndbuf_destroy(bs);
1267 		if (b)
1268 			sndbuf_destroy(b);
1269 		CHN_LOCK(c);
1270 		c->flags |= CHN_F_DEAD;
1271 		chn_lockdestroy(c);
1272 
1273 		return ret;
1274 	}
1275 
1276 	return 0;
1277 }
1278 
1279 void
chn_kill(struct pcm_channel * c)1280 chn_kill(struct pcm_channel *c)
1281 {
1282 	struct snd_dbuf *b = c->bufhard;
1283 	struct snd_dbuf *bs = c->bufsoft;
1284 
1285 	PCM_BUSYASSERT(c->parentsnddev);
1286 
1287 	if (CHN_STARTED(c)) {
1288 		CHN_LOCK(c);
1289 		chn_trigger(c, PCMTRIG_ABORT);
1290 		CHN_UNLOCK(c);
1291 	}
1292 	while (chn_removefeeder(c) == 0)
1293 		;
1294 	if (CHANNEL_FREE(c->methods, c->devinfo))
1295 		sndbuf_free(b);
1296 	sndbuf_destroy(bs);
1297 	sndbuf_destroy(b);
1298 	CHN_LOCK(c);
1299 	c->flags |= CHN_F_DEAD;
1300 	chn_lockdestroy(c);
1301 	kobj_delete(c->methods, M_DEVBUF);
1302 	free(c, M_DEVBUF);
1303 }
1304 
1305 void
chn_shutdown(struct pcm_channel * c)1306 chn_shutdown(struct pcm_channel *c)
1307 {
1308 	CHN_LOCKASSERT(c);
1309 
1310 	chn_wakeup(c);
1311 	c->flags |= CHN_F_DEAD;
1312 }
1313 
1314 /* release a locked channel and unlock it */
1315 int
chn_release(struct pcm_channel * c)1316 chn_release(struct pcm_channel *c)
1317 {
1318 	PCM_BUSYASSERT(c->parentsnddev);
1319 	CHN_LOCKASSERT(c);
1320 
1321 	c->flags &= ~CHN_F_BUSY;
1322 	c->pid = -1;
1323 	strlcpy(c->comm, CHN_COMM_UNUSED, sizeof(c->comm));
1324 	CHN_UNLOCK(c);
1325 
1326 	return (0);
1327 }
1328 
1329 int
chn_ref(struct pcm_channel * c,int ref)1330 chn_ref(struct pcm_channel *c, int ref)
1331 {
1332 	PCM_BUSYASSERT(c->parentsnddev);
1333 	CHN_LOCKASSERT(c);
1334 	KASSERT((c->refcount + ref) >= 0,
1335 	    ("%s(): new refcount will be negative", __func__));
1336 
1337 	c->refcount += ref;
1338 
1339 	return (c->refcount);
1340 }
1341 
1342 int
chn_setvolume_multi(struct pcm_channel * c,int vc,int left,int right,int center)1343 chn_setvolume_multi(struct pcm_channel *c, int vc, int left, int right,
1344     int center)
1345 {
1346 	int i, ret;
1347 
1348 	ret = 0;
1349 
1350 	for (i = 0; i < SND_CHN_T_MAX; i++) {
1351 		if ((1 << i) & SND_CHN_LEFT_MASK)
1352 			ret |= chn_setvolume_matrix(c, vc, i, left);
1353 		else if ((1 << i) & SND_CHN_RIGHT_MASK)
1354 			ret |= chn_setvolume_matrix(c, vc, i, right) << 8;
1355 		else
1356 			ret |= chn_setvolume_matrix(c, vc, i, center) << 16;
1357 	}
1358 
1359 	return (ret);
1360 }
1361 
1362 int
chn_setvolume_matrix(struct pcm_channel * c,int vc,int vt,int val)1363 chn_setvolume_matrix(struct pcm_channel *c, int vc, int vt, int val)
1364 {
1365 	int i;
1366 
1367 	KASSERT(c != NULL && vc >= SND_VOL_C_MASTER && vc < SND_VOL_C_MAX &&
1368 	    (vc == SND_VOL_C_MASTER || (vc & 1)) &&
1369 	    (vt == SND_CHN_T_VOL_0DB || (vt >= SND_CHN_T_BEGIN &&
1370 	    vt <= SND_CHN_T_END)) && (vt != SND_CHN_T_VOL_0DB ||
1371 	    (val >= SND_VOL_0DB_MIN && val <= SND_VOL_0DB_MAX)),
1372 	    ("%s(): invalid volume matrix c=%p vc=%d vt=%d val=%d",
1373 	    __func__, c, vc, vt, val));
1374 	CHN_LOCKASSERT(c);
1375 
1376 	if (val < 0)
1377 		val = 0;
1378 	if (val > 100)
1379 		val = 100;
1380 
1381 	c->volume[vc][vt] = val;
1382 
1383 	/*
1384 	 * Do relative calculation here and store it into class + 1
1385 	 * to ease the job of feeder_volume.
1386 	 */
1387 	if (vc == SND_VOL_C_MASTER) {
1388 		for (vc = SND_VOL_C_BEGIN; vc <= SND_VOL_C_END;
1389 		    vc += SND_VOL_C_STEP)
1390 			c->volume[SND_VOL_C_VAL(vc)][vt] =
1391 			    SND_VOL_CALC_VAL(c->volume, vc, vt);
1392 	} else if (vc & 1) {
1393 		if (vt == SND_CHN_T_VOL_0DB)
1394 			for (i = SND_CHN_T_BEGIN; i <= SND_CHN_T_END;
1395 			    i += SND_CHN_T_STEP) {
1396 				c->volume[SND_VOL_C_VAL(vc)][i] =
1397 				    SND_VOL_CALC_VAL(c->volume, vc, i);
1398 			}
1399 		else
1400 			c->volume[SND_VOL_C_VAL(vc)][vt] =
1401 			    SND_VOL_CALC_VAL(c->volume, vc, vt);
1402 	}
1403 
1404 	return (val);
1405 }
1406 
1407 int
chn_getvolume_matrix(struct pcm_channel * c,int vc,int vt)1408 chn_getvolume_matrix(struct pcm_channel *c, int vc, int vt)
1409 {
1410 	KASSERT(c != NULL && vc >= SND_VOL_C_MASTER && vc < SND_VOL_C_MAX &&
1411 	    (vt == SND_CHN_T_VOL_0DB ||
1412 	    (vt >= SND_CHN_T_BEGIN && vt <= SND_CHN_T_END)),
1413 	    ("%s(): invalid volume matrix c=%p vc=%d vt=%d",
1414 	    __func__, c, vc, vt));
1415 	CHN_LOCKASSERT(c);
1416 
1417 	return (c->volume[vc][vt]);
1418 }
1419 
1420 int
chn_setmute_multi(struct pcm_channel * c,int vc,int mute)1421 chn_setmute_multi(struct pcm_channel *c, int vc, int mute)
1422 {
1423 	int i, ret;
1424 
1425 	ret = 0;
1426 
1427 	for (i = 0; i < SND_CHN_T_MAX; i++) {
1428 		if ((1 << i) & SND_CHN_LEFT_MASK)
1429 			ret |= chn_setmute_matrix(c, vc, i, mute);
1430 		else if ((1 << i) & SND_CHN_RIGHT_MASK)
1431 			ret |= chn_setmute_matrix(c, vc, i, mute) << 8;
1432 		else
1433 			ret |= chn_setmute_matrix(c, vc, i, mute) << 16;
1434 	}
1435 	return (ret);
1436 }
1437 
1438 int
chn_setmute_matrix(struct pcm_channel * c,int vc,int vt,int mute)1439 chn_setmute_matrix(struct pcm_channel *c, int vc, int vt, int mute)
1440 {
1441 	int i;
1442 
1443 	KASSERT(c != NULL && vc >= SND_VOL_C_MASTER && vc < SND_VOL_C_MAX &&
1444 	    (vc == SND_VOL_C_MASTER || (vc & 1)) &&
1445 	    (vt == SND_CHN_T_VOL_0DB || (vt >= SND_CHN_T_BEGIN && vt <= SND_CHN_T_END)),
1446 	    ("%s(): invalid mute matrix c=%p vc=%d vt=%d mute=%d",
1447 	    __func__, c, vc, vt, mute));
1448 
1449 	CHN_LOCKASSERT(c);
1450 
1451 	mute = (mute != 0);
1452 
1453 	c->muted[vc][vt] = mute;
1454 
1455 	/*
1456 	 * Do relative calculation here and store it into class + 1
1457 	 * to ease the job of feeder_volume.
1458 	 */
1459 	if (vc == SND_VOL_C_MASTER) {
1460 		for (vc = SND_VOL_C_BEGIN; vc <= SND_VOL_C_END;
1461 		    vc += SND_VOL_C_STEP)
1462 			c->muted[SND_VOL_C_VAL(vc)][vt] = mute;
1463 	} else if (vc & 1) {
1464 		if (vt == SND_CHN_T_VOL_0DB) {
1465 			for (i = SND_CHN_T_BEGIN; i <= SND_CHN_T_END;
1466 			    i += SND_CHN_T_STEP) {
1467 				c->muted[SND_VOL_C_VAL(vc)][i] = mute;
1468 			}
1469 		} else {
1470 			c->muted[SND_VOL_C_VAL(vc)][vt] = mute;
1471 		}
1472 	}
1473 	return (mute);
1474 }
1475 
1476 int
chn_getmute_matrix(struct pcm_channel * c,int vc,int vt)1477 chn_getmute_matrix(struct pcm_channel *c, int vc, int vt)
1478 {
1479 	KASSERT(c != NULL && vc >= SND_VOL_C_MASTER && vc < SND_VOL_C_MAX &&
1480 	    (vt == SND_CHN_T_VOL_0DB ||
1481 	    (vt >= SND_CHN_T_BEGIN && vt <= SND_CHN_T_END)),
1482 	    ("%s(): invalid mute matrix c=%p vc=%d vt=%d",
1483 	    __func__, c, vc, vt));
1484 	CHN_LOCKASSERT(c);
1485 
1486 	return (c->muted[vc][vt]);
1487 }
1488 
1489 struct pcmchan_matrix *
chn_getmatrix(struct pcm_channel * c)1490 chn_getmatrix(struct pcm_channel *c)
1491 {
1492 
1493 	KASSERT(c != NULL, ("%s(): NULL channel", __func__));
1494 	CHN_LOCKASSERT(c);
1495 
1496 	if (!(c->format & AFMT_CONVERTIBLE))
1497 		return (NULL);
1498 
1499 	return (&c->matrix);
1500 }
1501 
1502 int
chn_setmatrix(struct pcm_channel * c,struct pcmchan_matrix * m)1503 chn_setmatrix(struct pcm_channel *c, struct pcmchan_matrix *m)
1504 {
1505 
1506 	KASSERT(c != NULL && m != NULL,
1507 	    ("%s(): NULL channel or matrix", __func__));
1508 	CHN_LOCKASSERT(c);
1509 
1510 	if (!(c->format & AFMT_CONVERTIBLE))
1511 		return (EINVAL);
1512 
1513 	c->matrix = *m;
1514 	c->matrix.id = SND_CHN_MATRIX_PCMCHANNEL;
1515 
1516 	return (chn_setformat(c, SND_FORMAT(c->format, m->channels, m->ext)));
1517 }
1518 
1519 /*
1520  * XXX chn_oss_* exists for the sake of compatibility.
1521  */
1522 int
chn_oss_getorder(struct pcm_channel * c,unsigned long long * map)1523 chn_oss_getorder(struct pcm_channel *c, unsigned long long *map)
1524 {
1525 
1526 	KASSERT(c != NULL && map != NULL,
1527 	    ("%s(): NULL channel or map", __func__));
1528 	CHN_LOCKASSERT(c);
1529 
1530 	if (!(c->format & AFMT_CONVERTIBLE))
1531 		return (EINVAL);
1532 
1533 	return (feeder_matrix_oss_get_channel_order(&c->matrix, map));
1534 }
1535 
1536 int
chn_oss_setorder(struct pcm_channel * c,unsigned long long * map)1537 chn_oss_setorder(struct pcm_channel *c, unsigned long long *map)
1538 {
1539 	struct pcmchan_matrix m;
1540 	int ret;
1541 
1542 	KASSERT(c != NULL && map != NULL,
1543 	    ("%s(): NULL channel or map", __func__));
1544 	CHN_LOCKASSERT(c);
1545 
1546 	if (!(c->format & AFMT_CONVERTIBLE))
1547 		return (EINVAL);
1548 
1549 	m = c->matrix;
1550 	ret = feeder_matrix_oss_set_channel_order(&m, map);
1551 	if (ret != 0)
1552 		return (ret);
1553 
1554 	return (chn_setmatrix(c, &m));
1555 }
1556 
1557 #define SND_CHN_OSS_FRONT	(SND_CHN_T_MASK_FL | SND_CHN_T_MASK_FR)
1558 #define SND_CHN_OSS_SURR	(SND_CHN_T_MASK_SL | SND_CHN_T_MASK_SR)
1559 #define SND_CHN_OSS_CENTER_LFE	(SND_CHN_T_MASK_FC | SND_CHN_T_MASK_LF)
1560 #define SND_CHN_OSS_REAR	(SND_CHN_T_MASK_BL | SND_CHN_T_MASK_BR)
1561 
1562 int
chn_oss_getmask(struct pcm_channel * c,uint32_t * retmask)1563 chn_oss_getmask(struct pcm_channel *c, uint32_t *retmask)
1564 {
1565 	struct pcmchan_matrix *m;
1566 	struct pcmchan_caps *caps;
1567 	uint32_t i, format;
1568 
1569 	KASSERT(c != NULL && retmask != NULL,
1570 	    ("%s(): NULL channel or retmask", __func__));
1571 	CHN_LOCKASSERT(c);
1572 
1573 	caps = chn_getcaps(c);
1574 	if (caps == NULL || caps->fmtlist == NULL)
1575 		return (ENODEV);
1576 
1577 	for (i = 0; caps->fmtlist[i] != 0; i++) {
1578 		format = caps->fmtlist[i];
1579 		if (!(format & AFMT_CONVERTIBLE)) {
1580 			*retmask |= DSP_BIND_SPDIF;
1581 			continue;
1582 		}
1583 		m = CHANNEL_GETMATRIX(c->methods, c->devinfo, format);
1584 		if (m == NULL)
1585 			continue;
1586 		if (m->mask & SND_CHN_OSS_FRONT)
1587 			*retmask |= DSP_BIND_FRONT;
1588 		if (m->mask & SND_CHN_OSS_SURR)
1589 			*retmask |= DSP_BIND_SURR;
1590 		if (m->mask & SND_CHN_OSS_CENTER_LFE)
1591 			*retmask |= DSP_BIND_CENTER_LFE;
1592 		if (m->mask & SND_CHN_OSS_REAR)
1593 			*retmask |= DSP_BIND_REAR;
1594 	}
1595 
1596 	/* report software-supported binding mask */
1597 	if (!CHN_BITPERFECT(c) && report_soft_matrix)
1598 		*retmask |= DSP_BIND_FRONT | DSP_BIND_SURR |
1599 		    DSP_BIND_CENTER_LFE | DSP_BIND_REAR;
1600 
1601 	return (0);
1602 }
1603 
1604 void
chn_vpc_reset(struct pcm_channel * c,int vc,int force)1605 chn_vpc_reset(struct pcm_channel *c, int vc, int force)
1606 {
1607 	int i;
1608 
1609 	KASSERT(c != NULL && vc >= SND_VOL_C_BEGIN && vc <= SND_VOL_C_END,
1610 	    ("%s(): invalid reset c=%p vc=%d", __func__, c, vc));
1611 	CHN_LOCKASSERT(c);
1612 
1613 	if (force == 0 && chn_vpc_autoreset == 0)
1614 		return;
1615 
1616 	for (i = SND_CHN_T_BEGIN; i <= SND_CHN_T_END; i += SND_CHN_T_STEP)
1617 		CHN_SETVOLUME(c, vc, i, c->volume[vc][SND_CHN_T_VOL_0DB]);
1618 }
1619 
1620 static u_int32_t
round_pow2(u_int32_t v)1621 round_pow2(u_int32_t v)
1622 {
1623 	u_int32_t ret;
1624 
1625 	if (v < 2)
1626 		v = 2;
1627 	ret = 0;
1628 	while (v >> ret)
1629 		ret++;
1630 	ret = 1 << (ret - 1);
1631 	while (ret < v)
1632 		ret <<= 1;
1633 	return ret;
1634 }
1635 
1636 static u_int32_t
round_blksz(u_int32_t v,int round)1637 round_blksz(u_int32_t v, int round)
1638 {
1639 	u_int32_t ret, tmp;
1640 
1641 	if (round < 1)
1642 		round = 1;
1643 
1644 	ret = min(round_pow2(v), CHN_2NDBUFMAXSIZE >> 1);
1645 
1646 	if (ret > v && (ret >> 1) > 0 && (ret >> 1) >= ((v * 3) >> 2))
1647 		ret >>= 1;
1648 
1649 	tmp = ret - (ret % round);
1650 	while (tmp < 16 || tmp < round) {
1651 		ret <<= 1;
1652 		tmp = ret - (ret % round);
1653 	}
1654 
1655 	return ret;
1656 }
1657 
1658 /*
1659  * 4Front call it DSP Policy, while we call it "Latency Profile". The idea
1660  * is to keep 2nd buffer short so that it doesn't cause long queue during
1661  * buffer transfer.
1662  *
1663  *    Latency reference table for 48khz stereo 16bit: (PLAY)
1664  *
1665  *      +---------+------------+-----------+------------+
1666  *      | Latency | Blockcount | Blocksize | Buffersize |
1667  *      +---------+------------+-----------+------------+
1668  *      |     0   |       2    |   64      |    128     |
1669  *      +---------+------------+-----------+------------+
1670  *      |     1   |       4    |   128     |    512     |
1671  *      +---------+------------+-----------+------------+
1672  *      |     2   |       8    |   512     |    4096    |
1673  *      +---------+------------+-----------+------------+
1674  *      |     3   |      16    |   512     |    8192    |
1675  *      +---------+------------+-----------+------------+
1676  *      |     4   |      32    |   512     |    16384   |
1677  *      +---------+------------+-----------+------------+
1678  *      |     5   |      32    |   1024    |    32768   |
1679  *      +---------+------------+-----------+------------+
1680  *      |     6   |      16    |   2048    |    32768   |
1681  *      +---------+------------+-----------+------------+
1682  *      |     7   |       8    |   4096    |    32768   |
1683  *      +---------+------------+-----------+------------+
1684  *      |     8   |       4    |   8192    |    32768   |
1685  *      +---------+------------+-----------+------------+
1686  *      |     9   |       2    |   16384   |    32768   |
1687  *      +---------+------------+-----------+------------+
1688  *      |    10   |       2    |   32768   |    65536   |
1689  *      +---------+------------+-----------+------------+
1690  *
1691  * Recording need a different reference table. All we care is
1692  * gobbling up everything within reasonable buffering threshold.
1693  *
1694  *    Latency reference table for 48khz stereo 16bit: (REC)
1695  *
1696  *      +---------+------------+-----------+------------+
1697  *      | Latency | Blockcount | Blocksize | Buffersize |
1698  *      +---------+------------+-----------+------------+
1699  *      |     0   |     512    |   32      |    16384   |
1700  *      +---------+------------+-----------+------------+
1701  *      |     1   |     256    |   64      |    16384   |
1702  *      +---------+------------+-----------+------------+
1703  *      |     2   |     128    |   128     |    16384   |
1704  *      +---------+------------+-----------+------------+
1705  *      |     3   |      64    |   256     |    16384   |
1706  *      +---------+------------+-----------+------------+
1707  *      |     4   |      32    |   512     |    16384   |
1708  *      +---------+------------+-----------+------------+
1709  *      |     5   |      32    |   1024    |    32768   |
1710  *      +---------+------------+-----------+------------+
1711  *      |     6   |      16    |   2048    |    32768   |
1712  *      +---------+------------+-----------+------------+
1713  *      |     7   |       8    |   4096    |    32768   |
1714  *      +---------+------------+-----------+------------+
1715  *      |     8   |       4    |   8192    |    32768   |
1716  *      +---------+------------+-----------+------------+
1717  *      |     9   |       2    |   16384   |    32768   |
1718  *      +---------+------------+-----------+------------+
1719  *      |    10   |       2    |   32768   |    65536   |
1720  *      +---------+------------+-----------+------------+
1721  *
1722  * Calculations for other data rate are entirely based on these reference
1723  * tables. For normal operation, Latency 5 seems give the best, well
1724  * balanced performance for typical workload. Anything below 5 will
1725  * eat up CPU to keep up with increasing context switches because of
1726  * shorter buffer space and usually require the application to handle it
1727  * aggressively through possibly real time programming technique.
1728  *
1729  */
1730 #define CHN_LATENCY_PBLKCNT_REF				\
1731 	{{1, 2, 3, 4, 5, 5, 4, 3, 2, 1, 1},		\
1732 	{1, 2, 3, 4, 5, 5, 4, 3, 2, 1, 1}}
1733 #define CHN_LATENCY_PBUFSZ_REF				\
1734 	{{7, 9, 12, 13, 14, 15, 15, 15, 15, 15, 16},	\
1735 	{11, 12, 13, 14, 15, 16, 16, 16, 16, 16, 17}}
1736 
1737 #define CHN_LATENCY_RBLKCNT_REF				\
1738 	{{9, 8, 7, 6, 5, 5, 4, 3, 2, 1, 1},		\
1739 	{9, 8, 7, 6, 5, 5, 4, 3, 2, 1, 1}}
1740 #define CHN_LATENCY_RBUFSZ_REF				\
1741 	{{14, 14, 14, 14, 14, 15, 15, 15, 15, 15, 16},	\
1742 	{15, 15, 15, 15, 15, 16, 16, 16, 16, 16, 17}}
1743 
1744 #define CHN_LATENCY_DATA_REF	192000 /* 48khz stereo 16bit ~ 48000 x 2 x 2 */
1745 
1746 static int
chn_calclatency(int dir,int latency,int bps,u_int32_t datarate,u_int32_t max,int * rblksz,int * rblkcnt)1747 chn_calclatency(int dir, int latency, int bps, u_int32_t datarate,
1748 				u_int32_t max, int *rblksz, int *rblkcnt)
1749 {
1750 	static int pblkcnts[CHN_LATENCY_PROFILE_MAX + 1][CHN_LATENCY_MAX + 1] =
1751 	    CHN_LATENCY_PBLKCNT_REF;
1752 	static int  pbufszs[CHN_LATENCY_PROFILE_MAX + 1][CHN_LATENCY_MAX + 1] =
1753 	    CHN_LATENCY_PBUFSZ_REF;
1754 	static int rblkcnts[CHN_LATENCY_PROFILE_MAX + 1][CHN_LATENCY_MAX + 1] =
1755 	    CHN_LATENCY_RBLKCNT_REF;
1756 	static int  rbufszs[CHN_LATENCY_PROFILE_MAX + 1][CHN_LATENCY_MAX + 1] =
1757 	    CHN_LATENCY_RBUFSZ_REF;
1758 	u_int32_t bufsz;
1759 	int lprofile, blksz, blkcnt;
1760 
1761 	if (latency < CHN_LATENCY_MIN || latency > CHN_LATENCY_MAX ||
1762 	    bps < 1 || datarate < 1 ||
1763 	    !(dir == PCMDIR_PLAY || dir == PCMDIR_REC)) {
1764 		if (rblksz != NULL)
1765 			*rblksz = CHN_2NDBUFMAXSIZE >> 1;
1766 		if (rblkcnt != NULL)
1767 			*rblkcnt = 2;
1768 		printf("%s(): FAILED dir=%d latency=%d bps=%d "
1769 		    "datarate=%u max=%u\n",
1770 		    __func__, dir, latency, bps, datarate, max);
1771 		return CHN_2NDBUFMAXSIZE;
1772 	}
1773 
1774 	lprofile = chn_latency_profile;
1775 
1776 	if (dir == PCMDIR_PLAY) {
1777 		blkcnt = pblkcnts[lprofile][latency];
1778 		bufsz = pbufszs[lprofile][latency];
1779 	} else {
1780 		blkcnt = rblkcnts[lprofile][latency];
1781 		bufsz = rbufszs[lprofile][latency];
1782 	}
1783 
1784 	bufsz = round_pow2(snd_xbytes(1 << bufsz, CHN_LATENCY_DATA_REF,
1785 	    datarate));
1786 	if (bufsz > max)
1787 		bufsz = max;
1788 	blksz = round_blksz(bufsz >> blkcnt, bps);
1789 
1790 	if (rblksz != NULL)
1791 		*rblksz = blksz;
1792 	if (rblkcnt != NULL)
1793 		*rblkcnt = 1 << blkcnt;
1794 
1795 	return blksz << blkcnt;
1796 }
1797 
1798 static int
chn_resizebuf(struct pcm_channel * c,int latency,int blkcnt,int blksz)1799 chn_resizebuf(struct pcm_channel *c, int latency,
1800 					int blkcnt, int blksz)
1801 {
1802 	struct snd_dbuf *b, *bs, *pb;
1803 	int sblksz, sblkcnt, hblksz, hblkcnt, limit = 0, nsblksz, nsblkcnt;
1804 	int ret;
1805 
1806 	CHN_LOCKASSERT(c);
1807 
1808 	if ((c->flags & (CHN_F_MMAP | CHN_F_TRIGGERED)) ||
1809 	    !(c->direction == PCMDIR_PLAY || c->direction == PCMDIR_REC))
1810 		return EINVAL;
1811 
1812 	if (latency == -1) {
1813 		c->latency = -1;
1814 		latency = chn_latency;
1815 	} else if (latency == -2) {
1816 		latency = c->latency;
1817 		if (latency < CHN_LATENCY_MIN || latency > CHN_LATENCY_MAX)
1818 			latency = chn_latency;
1819 	} else if (latency < CHN_LATENCY_MIN || latency > CHN_LATENCY_MAX)
1820 		return EINVAL;
1821 	else {
1822 		c->latency = latency;
1823 	}
1824 
1825 	bs = c->bufsoft;
1826 	b = c->bufhard;
1827 
1828 	if (!(blksz == 0 || blkcnt == -1) &&
1829 	    (blksz < 16 || blksz < sndbuf_getalign(bs) || blkcnt < 2 ||
1830 	    (blksz * blkcnt) > CHN_2NDBUFMAXSIZE))
1831 		return EINVAL;
1832 
1833 	chn_calclatency(c->direction, latency, sndbuf_getalign(bs),
1834 	    sndbuf_getalign(bs) * sndbuf_getspd(bs), CHN_2NDBUFMAXSIZE,
1835 	    &sblksz, &sblkcnt);
1836 
1837 	if (blksz == 0 || blkcnt == -1) {
1838 		if (blkcnt == -1)
1839 			c->flags &= ~CHN_F_HAS_SIZE;
1840 		if (c->flags & CHN_F_HAS_SIZE) {
1841 			blksz = sndbuf_getblksz(bs);
1842 			blkcnt = sndbuf_getblkcnt(bs);
1843 		}
1844 	} else
1845 		c->flags |= CHN_F_HAS_SIZE;
1846 
1847 	if (c->flags & CHN_F_HAS_SIZE) {
1848 		/*
1849 		 * The application has requested their own blksz/blkcnt.
1850 		 * Just obey with it, and let them toast alone. We can
1851 		 * clamp it to the nearest latency profile, but that would
1852 		 * defeat the purpose of having custom control. The least
1853 		 * we can do is round it to the nearest ^2 and align it.
1854 		 */
1855 		sblksz = round_blksz(blksz, sndbuf_getalign(bs));
1856 		sblkcnt = round_pow2(blkcnt);
1857 	}
1858 
1859 	if (c->parentchannel != NULL) {
1860 		pb = c->parentchannel->bufsoft;
1861 		CHN_UNLOCK(c);
1862 		CHN_LOCK(c->parentchannel);
1863 		chn_notify(c->parentchannel, CHN_N_BLOCKSIZE);
1864 		CHN_UNLOCK(c->parentchannel);
1865 		CHN_LOCK(c);
1866 		if (c->direction == PCMDIR_PLAY) {
1867 			limit = (pb != NULL) ?
1868 			    sndbuf_xbytes(sndbuf_getsize(pb), pb, bs) : 0;
1869 		} else {
1870 			limit = (pb != NULL) ?
1871 			    sndbuf_xbytes(sndbuf_getblksz(pb), pb, bs) * 2 : 0;
1872 		}
1873 	} else {
1874 		hblkcnt = 2;
1875 		if (c->flags & CHN_F_HAS_SIZE) {
1876 			hblksz = round_blksz(sndbuf_xbytes(sblksz, bs, b),
1877 			    sndbuf_getalign(b));
1878 			hblkcnt = round_pow2(sndbuf_getblkcnt(bs));
1879 		} else
1880 			chn_calclatency(c->direction, latency,
1881 			    sndbuf_getalign(b),
1882 			    sndbuf_getalign(b) * sndbuf_getspd(b),
1883 			    CHN_2NDBUFMAXSIZE, &hblksz, &hblkcnt);
1884 
1885 		if ((hblksz << 1) > sndbuf_getmaxsize(b))
1886 			hblksz = round_blksz(sndbuf_getmaxsize(b) >> 1,
1887 			    sndbuf_getalign(b));
1888 
1889 		while ((hblksz * hblkcnt) > sndbuf_getmaxsize(b)) {
1890 			if (hblkcnt < 4)
1891 				hblksz >>= 1;
1892 			else
1893 				hblkcnt >>= 1;
1894 		}
1895 
1896 		hblksz -= hblksz % sndbuf_getalign(b);
1897 
1898 #if 0
1899 		hblksz = sndbuf_getmaxsize(b) >> 1;
1900 		hblksz -= hblksz % sndbuf_getalign(b);
1901 		hblkcnt = 2;
1902 #endif
1903 
1904 		CHN_UNLOCK(c);
1905 		if (chn_usefrags == 0 ||
1906 		    CHANNEL_SETFRAGMENTS(c->methods, c->devinfo,
1907 		    hblksz, hblkcnt) != 0)
1908 			sndbuf_setblksz(b, CHANNEL_SETBLOCKSIZE(c->methods,
1909 			    c->devinfo, hblksz));
1910 		CHN_LOCK(c);
1911 
1912 		if (!CHN_EMPTY(c, children)) {
1913 			nsblksz = round_blksz(
1914 			    sndbuf_xbytes(sndbuf_getblksz(b), b, bs),
1915 			    sndbuf_getalign(bs));
1916 			nsblkcnt = sndbuf_getblkcnt(b);
1917 			if (c->direction == PCMDIR_PLAY) {
1918 				do {
1919 					nsblkcnt--;
1920 				} while (nsblkcnt >= 2 &&
1921 				    nsblksz * nsblkcnt >= sblksz * sblkcnt);
1922 				nsblkcnt++;
1923 			}
1924 			sblksz = nsblksz;
1925 			sblkcnt = nsblkcnt;
1926 			limit = 0;
1927 		} else
1928 			limit = sndbuf_xbytes(sndbuf_getblksz(b), b, bs) * 2;
1929 	}
1930 
1931 	if (limit > CHN_2NDBUFMAXSIZE)
1932 		limit = CHN_2NDBUFMAXSIZE;
1933 
1934 #if 0
1935 	while (limit > 0 && (sblksz * sblkcnt) > limit) {
1936 		if (sblkcnt < 4)
1937 			break;
1938 		sblkcnt >>= 1;
1939 	}
1940 #endif
1941 
1942 	while ((sblksz * sblkcnt) < limit)
1943 		sblkcnt <<= 1;
1944 
1945 	while ((sblksz * sblkcnt) > CHN_2NDBUFMAXSIZE) {
1946 		if (sblkcnt < 4)
1947 			sblksz >>= 1;
1948 		else
1949 			sblkcnt >>= 1;
1950 	}
1951 
1952 	sblksz -= sblksz % sndbuf_getalign(bs);
1953 
1954 	if (sndbuf_getblkcnt(bs) != sblkcnt || sndbuf_getblksz(bs) != sblksz ||
1955 	    sndbuf_getsize(bs) != (sblkcnt * sblksz)) {
1956 		ret = sndbuf_remalloc(bs, sblkcnt, sblksz);
1957 		if (ret != 0) {
1958 			device_printf(c->dev, "%s(): Failed: %d %d\n",
1959 			    __func__, sblkcnt, sblksz);
1960 			return ret;
1961 		}
1962 	}
1963 
1964 	/*
1965 	 * Interrupt timeout
1966 	 */
1967 	c->timeout = ((u_int64_t)hz * sndbuf_getsize(bs)) /
1968 	    ((u_int64_t)sndbuf_getspd(bs) * sndbuf_getalign(bs));
1969 	if (c->parentchannel != NULL)
1970 		c->timeout = min(c->timeout, c->parentchannel->timeout);
1971 	if (c->timeout < 1)
1972 		c->timeout = 1;
1973 
1974 	/*
1975 	 * OSSv4 docs: "By default OSS will set the low water level equal
1976 	 * to the fragment size which is optimal in most cases."
1977 	 */
1978 	c->lw = sndbuf_getblksz(bs);
1979 	chn_resetbuf(c);
1980 
1981 	if (snd_verbose > 3)
1982 		device_printf(c->dev, "%s(): %s (%s) timeout=%u "
1983 		    "b[%d/%d/%d] bs[%d/%d/%d] limit=%d\n",
1984 		    __func__, CHN_DIRSTR(c),
1985 		    (c->flags & CHN_F_VIRTUAL) ? "virtual" : "hardware",
1986 		    c->timeout,
1987 		    sndbuf_getsize(b), sndbuf_getblksz(b),
1988 		    sndbuf_getblkcnt(b),
1989 		    sndbuf_getsize(bs), sndbuf_getblksz(bs),
1990 		    sndbuf_getblkcnt(bs), limit);
1991 
1992 	return 0;
1993 }
1994 
1995 int
chn_setlatency(struct pcm_channel * c,int latency)1996 chn_setlatency(struct pcm_channel *c, int latency)
1997 {
1998 	CHN_LOCKASSERT(c);
1999 	/* Destroy blksz/blkcnt, enforce latency profile. */
2000 	return chn_resizebuf(c, latency, -1, 0);
2001 }
2002 
2003 int
chn_setblocksize(struct pcm_channel * c,int blkcnt,int blksz)2004 chn_setblocksize(struct pcm_channel *c, int blkcnt, int blksz)
2005 {
2006 	CHN_LOCKASSERT(c);
2007 	/* Destroy latency profile, enforce blksz/blkcnt */
2008 	return chn_resizebuf(c, -1, blkcnt, blksz);
2009 }
2010 
2011 int
chn_setparam(struct pcm_channel * c,uint32_t format,uint32_t speed)2012 chn_setparam(struct pcm_channel *c, uint32_t format, uint32_t speed)
2013 {
2014 	struct pcmchan_caps *caps;
2015 	uint32_t hwspeed, delta;
2016 	int ret;
2017 
2018 	CHN_LOCKASSERT(c);
2019 
2020 	if (speed < 1 || format == 0 || CHN_STARTED(c))
2021 		return (EINVAL);
2022 
2023 	c->format = format;
2024 	c->speed = speed;
2025 
2026 	caps = chn_getcaps(c);
2027 
2028 	hwspeed = speed;
2029 	RANGE(hwspeed, caps->minspeed, caps->maxspeed);
2030 
2031 	sndbuf_setspd(c->bufhard, CHANNEL_SETSPEED(c->methods, c->devinfo,
2032 	    hwspeed));
2033 	hwspeed = sndbuf_getspd(c->bufhard);
2034 
2035 	delta = (hwspeed > speed) ? (hwspeed - speed) : (speed - hwspeed);
2036 
2037 	if (delta <= feeder_rate_round)
2038 		c->speed = hwspeed;
2039 
2040 	ret = feeder_chain(c);
2041 
2042 	if (ret == 0)
2043 		ret = CHANNEL_SETFORMAT(c->methods, c->devinfo,
2044 		    sndbuf_getfmt(c->bufhard));
2045 
2046 	if (ret == 0)
2047 		ret = chn_resizebuf(c, -2, 0, 0);
2048 
2049 	return (ret);
2050 }
2051 
2052 int
chn_setspeed(struct pcm_channel * c,uint32_t speed)2053 chn_setspeed(struct pcm_channel *c, uint32_t speed)
2054 {
2055 	uint32_t oldformat, oldspeed, format;
2056 	int ret;
2057 
2058 #if 0
2059 	/* XXX force 48k */
2060 	if (c->format & AFMT_PASSTHROUGH)
2061 		speed = AFMT_PASSTHROUGH_RATE;
2062 #endif
2063 
2064 	oldformat = c->format;
2065 	oldspeed = c->speed;
2066 	format = oldformat;
2067 
2068 	ret = chn_setparam(c, format, speed);
2069 	if (ret != 0) {
2070 		if (snd_verbose > 3)
2071 			device_printf(c->dev,
2072 			    "%s(): Setting speed %d failed, "
2073 			    "falling back to %d\n",
2074 			    __func__, speed, oldspeed);
2075 		chn_setparam(c, c->format, oldspeed);
2076 	}
2077 
2078 	return (ret);
2079 }
2080 
2081 int
chn_setformat(struct pcm_channel * c,uint32_t format)2082 chn_setformat(struct pcm_channel *c, uint32_t format)
2083 {
2084 	uint32_t oldformat, oldspeed, speed;
2085 	int ret;
2086 
2087 	/* XXX force stereo */
2088 	if ((format & AFMT_PASSTHROUGH) && AFMT_CHANNEL(format) < 2) {
2089 		format = SND_FORMAT(format, AFMT_PASSTHROUGH_CHANNEL,
2090 		    AFMT_PASSTHROUGH_EXTCHANNEL);
2091 	}
2092 
2093 	oldformat = c->format;
2094 	oldspeed = c->speed;
2095 	speed = oldspeed;
2096 
2097 	ret = chn_setparam(c, format, speed);
2098 	if (ret != 0) {
2099 		if (snd_verbose > 3)
2100 			device_printf(c->dev,
2101 			    "%s(): Format change 0x%08x failed, "
2102 			    "falling back to 0x%08x\n",
2103 			    __func__, format, oldformat);
2104 		chn_setparam(c, oldformat, oldspeed);
2105 	}
2106 
2107 	return (ret);
2108 }
2109 
2110 void
chn_syncstate(struct pcm_channel * c)2111 chn_syncstate(struct pcm_channel *c)
2112 {
2113 	struct snddev_info *d;
2114 	struct snd_mixer *m;
2115 
2116 	d = (c != NULL) ? c->parentsnddev : NULL;
2117 	m = (d != NULL && d->mixer_dev != NULL) ? d->mixer_dev->si_drv1 :
2118 	    NULL;
2119 
2120 	if (d == NULL || m == NULL)
2121 		return;
2122 
2123 	CHN_LOCKASSERT(c);
2124 
2125 	if (c->feederflags & (1 << FEEDER_VOLUME)) {
2126 		uint32_t parent;
2127 		int vol, pvol, left, right, center;
2128 
2129 		if (c->direction == PCMDIR_PLAY &&
2130 		    (d->flags & SD_F_SOFTPCMVOL)) {
2131 			/* CHN_UNLOCK(c); */
2132 			vol = mix_get(m, SOUND_MIXER_PCM);
2133 			parent = mix_getparent(m, SOUND_MIXER_PCM);
2134 			if (parent != SOUND_MIXER_NONE)
2135 				pvol = mix_get(m, parent);
2136 			else
2137 				pvol = 100 | (100 << 8);
2138 			/* CHN_LOCK(c); */
2139 		} else {
2140 			vol = 100 | (100 << 8);
2141 			pvol = vol;
2142 		}
2143 
2144 		if (vol == -1) {
2145 			device_printf(c->dev,
2146 			    "Soft PCM Volume: Failed to read pcm "
2147 			    "default value\n");
2148 			vol = 100 | (100 << 8);
2149 		}
2150 
2151 		if (pvol == -1) {
2152 			device_printf(c->dev,
2153 			    "Soft PCM Volume: Failed to read parent "
2154 			    "default value\n");
2155 			pvol = 100 | (100 << 8);
2156 		}
2157 
2158 		left = ((vol & 0x7f) * (pvol & 0x7f)) / 100;
2159 		right = (((vol >> 8) & 0x7f) * ((pvol >> 8) & 0x7f)) / 100;
2160 		center = (left + right) >> 1;
2161 
2162 		chn_setvolume_multi(c, SND_VOL_C_MASTER, left, right, center);
2163 	}
2164 
2165 	if (c->feederflags & (1 << FEEDER_EQ)) {
2166 		struct pcm_feeder *f;
2167 		int treble, bass, state;
2168 
2169 		/* CHN_UNLOCK(c); */
2170 		treble = mix_get(m, SOUND_MIXER_TREBLE);
2171 		bass = mix_get(m, SOUND_MIXER_BASS);
2172 		/* CHN_LOCK(c); */
2173 
2174 		if (treble == -1)
2175 			treble = 50;
2176 		else
2177 			treble = ((treble & 0x7f) +
2178 			    ((treble >> 8) & 0x7f)) >> 1;
2179 
2180 		if (bass == -1)
2181 			bass = 50;
2182 		else
2183 			bass = ((bass & 0x7f) + ((bass >> 8) & 0x7f)) >> 1;
2184 
2185 		f = chn_findfeeder(c, FEEDER_EQ);
2186 		if (f != NULL) {
2187 			if (FEEDER_SET(f, FEEDEQ_TREBLE, treble) != 0)
2188 				device_printf(c->dev,
2189 				    "EQ: Failed to set treble -- %d\n",
2190 				    treble);
2191 			if (FEEDER_SET(f, FEEDEQ_BASS, bass) != 0)
2192 				device_printf(c->dev,
2193 				    "EQ: Failed to set bass -- %d\n",
2194 				    bass);
2195 			if (FEEDER_SET(f, FEEDEQ_PREAMP, d->eqpreamp) != 0)
2196 				device_printf(c->dev,
2197 				    "EQ: Failed to set preamp -- %d\n",
2198 				    d->eqpreamp);
2199 			if (d->flags & SD_F_EQ_BYPASSED)
2200 				state = FEEDEQ_BYPASS;
2201 			else if (d->flags & SD_F_EQ_ENABLED)
2202 				state = FEEDEQ_ENABLE;
2203 			else
2204 				state = FEEDEQ_DISABLE;
2205 			if (FEEDER_SET(f, FEEDEQ_STATE, state) != 0)
2206 				device_printf(c->dev,
2207 				    "EQ: Failed to set state -- %d\n", state);
2208 		}
2209 	}
2210 }
2211 
2212 int
chn_trigger(struct pcm_channel * c,int go)2213 chn_trigger(struct pcm_channel *c, int go)
2214 {
2215 	struct snddev_info *d = c->parentsnddev;
2216 	int ret;
2217 
2218 	CHN_LOCKASSERT(c);
2219 	if (!PCMTRIG_COMMON(go))
2220 		return (CHANNEL_TRIGGER(c->methods, c->devinfo, go));
2221 
2222 	if (go == c->trigger)
2223 		return (0);
2224 
2225 	ret = CHANNEL_TRIGGER(c->methods, c->devinfo, go);
2226 	if (ret != 0)
2227 		return (ret);
2228 
2229 	switch (go) {
2230 	case PCMTRIG_START:
2231 		if (snd_verbose > 3)
2232 			device_printf(c->dev,
2233 			    "%s() %s: calling go=0x%08x , "
2234 			    "prev=0x%08x\n", __func__, c->name, go,
2235 			    c->trigger);
2236 		if (c->trigger != PCMTRIG_START) {
2237 			c->trigger = go;
2238 			CHN_UNLOCK(c);
2239 			PCM_LOCK(d);
2240 			CHN_INSERT_HEAD(d, c, channels.pcm.busy);
2241 			PCM_UNLOCK(d);
2242 			CHN_LOCK(c);
2243 			chn_syncstate(c);
2244 		}
2245 		break;
2246 	case PCMTRIG_STOP:
2247 	case PCMTRIG_ABORT:
2248 		if (snd_verbose > 3)
2249 			device_printf(c->dev,
2250 			    "%s() %s: calling go=0x%08x , "
2251 			    "prev=0x%08x\n", __func__, c->name, go,
2252 			    c->trigger);
2253 		if (c->trigger == PCMTRIG_START) {
2254 			c->trigger = go;
2255 			CHN_UNLOCK(c);
2256 			PCM_LOCK(d);
2257 			CHN_REMOVE(d, c, channels.pcm.busy);
2258 			PCM_UNLOCK(d);
2259 			CHN_LOCK(c);
2260 		}
2261 		break;
2262 	default:
2263 		break;
2264 	}
2265 
2266 	return (0);
2267 }
2268 
2269 /**
2270  * @brief Queries sound driver for sample-aligned hardware buffer pointer index
2271  *
2272  * This function obtains the hardware pointer location, then aligns it to
2273  * the current bytes-per-sample value before returning.  (E.g., a channel
2274  * running in 16 bit stereo mode would require 4 bytes per sample, so a
2275  * hwptr value ranging from 32-35 would be returned as 32.)
2276  *
2277  * @param c	PCM channel context
2278  * @returns 	sample-aligned hardware buffer pointer index
2279  */
2280 int
chn_getptr(struct pcm_channel * c)2281 chn_getptr(struct pcm_channel *c)
2282 {
2283 	int hwptr;
2284 
2285 	CHN_LOCKASSERT(c);
2286 	hwptr = (CHN_STARTED(c)) ? CHANNEL_GETPTR(c->methods, c->devinfo) : 0;
2287 	return (hwptr - (hwptr % sndbuf_getalign(c->bufhard)));
2288 }
2289 
2290 struct pcmchan_caps *
chn_getcaps(struct pcm_channel * c)2291 chn_getcaps(struct pcm_channel *c)
2292 {
2293 	CHN_LOCKASSERT(c);
2294 	return CHANNEL_GETCAPS(c->methods, c->devinfo);
2295 }
2296 
2297 u_int32_t
chn_getformats(struct pcm_channel * c)2298 chn_getformats(struct pcm_channel *c)
2299 {
2300 	u_int32_t *fmtlist, fmts;
2301 	int i;
2302 
2303 	fmtlist = chn_getcaps(c)->fmtlist;
2304 	fmts = 0;
2305 	for (i = 0; fmtlist[i]; i++)
2306 		fmts |= fmtlist[i];
2307 
2308 	/* report software-supported formats */
2309 	if (!CHN_BITPERFECT(c) && report_soft_formats)
2310 		fmts |= AFMT_CONVERTIBLE;
2311 
2312 	return (AFMT_ENCODING(fmts));
2313 }
2314 
2315 int
chn_notify(struct pcm_channel * c,u_int32_t flags)2316 chn_notify(struct pcm_channel *c, u_int32_t flags)
2317 {
2318 	struct pcm_channel *ch;
2319 	struct pcmchan_caps *caps;
2320 	uint32_t bestformat, bestspeed, besthwformat, *vchanformat, *vchanrate;
2321 	uint32_t vpflags;
2322 	int dirty, err, run, nrun;
2323 
2324 	CHN_LOCKASSERT(c);
2325 
2326 	if (CHN_EMPTY(c, children))
2327 		return (ENODEV);
2328 
2329 	err = 0;
2330 
2331 	/*
2332 	 * If the hwchan is running, we can't change its rate, format or
2333 	 * blocksize
2334 	 */
2335 	run = (CHN_STARTED(c)) ? 1 : 0;
2336 	if (run)
2337 		flags &= CHN_N_VOLUME | CHN_N_TRIGGER;
2338 
2339 	if (flags & CHN_N_RATE) {
2340 		/*
2341 		 * XXX I'll make good use of this someday.
2342 		 *     However this is currently being superseded by
2343 		 *     the availability of CHN_F_VCHAN_DYNAMIC.
2344 		 */
2345 	}
2346 
2347 	if (flags & CHN_N_FORMAT) {
2348 		/*
2349 		 * XXX I'll make good use of this someday.
2350 		 *     However this is currently being superseded by
2351 		 *     the availability of CHN_F_VCHAN_DYNAMIC.
2352 		 */
2353 	}
2354 
2355 	if (flags & CHN_N_VOLUME) {
2356 		/*
2357 		 * XXX I'll make good use of this someday, though
2358 		 *     soft volume control is currently pretty much
2359 		 *     integrated.
2360 		 */
2361 	}
2362 
2363 	if (flags & CHN_N_BLOCKSIZE) {
2364 		/*
2365 		 * Set to default latency profile
2366 		 */
2367 		chn_setlatency(c, chn_latency);
2368 	}
2369 
2370 	if ((flags & CHN_N_TRIGGER) && !(c->flags & CHN_F_VCHAN_DYNAMIC)) {
2371 		nrun = CHN_EMPTY(c, children.busy) ? 0 : 1;
2372 		if (nrun && !run)
2373 			err = chn_start(c, 1);
2374 		if (!nrun && run)
2375 			chn_abort(c);
2376 		flags &= ~CHN_N_TRIGGER;
2377 	}
2378 
2379 	if (flags & CHN_N_TRIGGER) {
2380 		if (c->direction == PCMDIR_PLAY) {
2381 			vchanformat = &c->parentsnddev->pvchanformat;
2382 			vchanrate = &c->parentsnddev->pvchanrate;
2383 		} else {
2384 			vchanformat = &c->parentsnddev->rvchanformat;
2385 			vchanrate = &c->parentsnddev->rvchanrate;
2386 		}
2387 
2388 		/* Dynamic Virtual Channel */
2389 		if (!(c->flags & CHN_F_VCHAN_ADAPTIVE)) {
2390 			bestformat = *vchanformat;
2391 			bestspeed = *vchanrate;
2392 		} else {
2393 			bestformat = 0;
2394 			bestspeed = 0;
2395 		}
2396 
2397 		besthwformat = 0;
2398 		nrun = 0;
2399 		caps = chn_getcaps(c);
2400 		dirty = 0;
2401 		vpflags = 0;
2402 
2403 		CHN_FOREACH(ch, c, children.busy) {
2404 			CHN_LOCK(ch);
2405 			if ((ch->format & AFMT_PASSTHROUGH) &&
2406 			    snd_fmtvalid(ch->format, caps->fmtlist)) {
2407 				bestformat = ch->format;
2408 				bestspeed = ch->speed;
2409 				CHN_UNLOCK(ch);
2410 				vpflags = CHN_F_PASSTHROUGH;
2411 				nrun++;
2412 				break;
2413 			}
2414 			if ((ch->flags & CHN_F_EXCLUSIVE) && vpflags == 0) {
2415 				if (c->flags & CHN_F_VCHAN_ADAPTIVE) {
2416 					bestspeed = ch->speed;
2417 					RANGE(bestspeed, caps->minspeed,
2418 					    caps->maxspeed);
2419 					besthwformat = snd_fmtbest(ch->format,
2420 					    caps->fmtlist);
2421 					if (besthwformat != 0)
2422 						bestformat = besthwformat;
2423 				}
2424 				CHN_UNLOCK(ch);
2425 				vpflags = CHN_F_EXCLUSIVE;
2426 				nrun++;
2427 				continue;
2428 			}
2429 			if (!(c->flags & CHN_F_VCHAN_ADAPTIVE) ||
2430 			    vpflags != 0) {
2431 				CHN_UNLOCK(ch);
2432 				nrun++;
2433 				continue;
2434 			}
2435 			if (ch->speed > bestspeed) {
2436 				bestspeed = ch->speed;
2437 				RANGE(bestspeed, caps->minspeed,
2438 				    caps->maxspeed);
2439 			}
2440 			besthwformat = snd_fmtbest(ch->format, caps->fmtlist);
2441 			if (!(besthwformat & AFMT_VCHAN)) {
2442 				CHN_UNLOCK(ch);
2443 				nrun++;
2444 				continue;
2445 			}
2446 			if (AFMT_CHANNEL(besthwformat) >
2447 			    AFMT_CHANNEL(bestformat))
2448 				bestformat = besthwformat;
2449 			else if (AFMT_CHANNEL(besthwformat) ==
2450 			    AFMT_CHANNEL(bestformat) &&
2451 			    AFMT_BIT(besthwformat) > AFMT_BIT(bestformat))
2452 				bestformat = besthwformat;
2453 			CHN_UNLOCK(ch);
2454 			nrun++;
2455 		}
2456 
2457 		if (bestformat == 0)
2458 			bestformat = c->format;
2459 		if (bestspeed == 0)
2460 			bestspeed = c->speed;
2461 
2462 		if (bestformat != c->format || bestspeed != c->speed)
2463 			dirty = 1;
2464 
2465 		c->flags &= ~(CHN_F_PASSTHROUGH | CHN_F_EXCLUSIVE);
2466 		c->flags |= vpflags;
2467 
2468 		if (nrun && !run) {
2469 			if (dirty) {
2470 				bestspeed = CHANNEL_SETSPEED(c->methods,
2471 				    c->devinfo, bestspeed);
2472 				err = chn_reset(c, bestformat, bestspeed);
2473 			}
2474 			if (err == 0 && dirty) {
2475 				CHN_FOREACH(ch, c, children.busy) {
2476 					CHN_LOCK(ch);
2477 					if (VCHAN_SYNC_REQUIRED(ch))
2478 						vchan_sync(ch);
2479 					CHN_UNLOCK(ch);
2480 				}
2481 			}
2482 			if (err == 0) {
2483 				if (dirty)
2484 					c->flags |= CHN_F_DIRTY;
2485 				err = chn_start(c, 1);
2486 			}
2487 		}
2488 
2489 		if (nrun && run && dirty) {
2490 			chn_abort(c);
2491 			bestspeed = CHANNEL_SETSPEED(c->methods, c->devinfo,
2492 			    bestspeed);
2493 			err = chn_reset(c, bestformat, bestspeed);
2494 			if (err == 0) {
2495 				CHN_FOREACH(ch, c, children.busy) {
2496 					CHN_LOCK(ch);
2497 					if (VCHAN_SYNC_REQUIRED(ch))
2498 						vchan_sync(ch);
2499 					CHN_UNLOCK(ch);
2500 				}
2501 			}
2502 			if (err == 0) {
2503 				c->flags |= CHN_F_DIRTY;
2504 				err = chn_start(c, 1);
2505 			}
2506 		}
2507 
2508 		if (err == 0 && !(bestformat & AFMT_PASSTHROUGH) &&
2509 		    (bestformat & AFMT_VCHAN)) {
2510 			*vchanformat = bestformat;
2511 			*vchanrate = bestspeed;
2512 		}
2513 
2514 		if (!nrun && run) {
2515 			c->flags &= ~(CHN_F_PASSTHROUGH | CHN_F_EXCLUSIVE);
2516 			bestformat = *vchanformat;
2517 			bestspeed = *vchanrate;
2518 			chn_abort(c);
2519 			if (c->format != bestformat || c->speed != bestspeed)
2520 				chn_reset(c, bestformat, bestspeed);
2521 		}
2522 	}
2523 
2524 	return (err);
2525 }
2526 
2527 /**
2528  * @brief Fetch array of supported discrete sample rates
2529  *
2530  * Wrapper for CHANNEL_GETRATES.  Please see channel_if.m:getrates() for
2531  * detailed information.
2532  *
2533  * @note If the operation isn't supported, this function will just return 0
2534  *       (no rates in the array), and *rates will be set to NULL.  Callers
2535  *       should examine rates @b only if this function returns non-zero.
2536  *
2537  * @param c	pcm channel to examine
2538  * @param rates	pointer to array of integers; rate table will be recorded here
2539  *
2540  * @return number of rates in the array pointed to be @c rates
2541  */
2542 int
chn_getrates(struct pcm_channel * c,int ** rates)2543 chn_getrates(struct pcm_channel *c, int **rates)
2544 {
2545 	KASSERT(rates != NULL, ("rates is null"));
2546 	CHN_LOCKASSERT(c);
2547 	return CHANNEL_GETRATES(c->methods, c->devinfo, rates);
2548 }
2549 
2550 /**
2551  * @brief Remove channel from a sync group, if there is one.
2552  *
2553  * This function is initially intended for the following conditions:
2554  *   - Starting a syncgroup (@c SNDCTL_DSP_SYNCSTART ioctl)
2555  *   - Closing a device.  (A channel can't be destroyed if it's still in use.)
2556  *
2557  * @note Before calling this function, the syncgroup list mutex must be
2558  * held.  (Consider pcm_channel::sm protected by the SG list mutex
2559  * whether @c c is locked or not.)
2560  *
2561  * @param c	channel device to be started or closed
2562  * @returns	If this channel was the only member of a group, the group ID
2563  * 		is returned to the caller so that the caller can release it
2564  * 		via free_unr() after giving up the syncgroup lock.  Else it
2565  * 		returns 0.
2566  */
2567 int
chn_syncdestroy(struct pcm_channel * c)2568 chn_syncdestroy(struct pcm_channel *c)
2569 {
2570 	struct pcmchan_syncmember *sm;
2571 	struct pcmchan_syncgroup *sg;
2572 	int sg_id;
2573 
2574 	sg_id = 0;
2575 
2576 	PCM_SG_LOCKASSERT(MA_OWNED);
2577 
2578 	if (c->sm != NULL) {
2579 		sm = c->sm;
2580 		sg = sm->parent;
2581 		c->sm = NULL;
2582 
2583 		KASSERT(sg != NULL, ("syncmember has null parent"));
2584 
2585 		SLIST_REMOVE(&sg->members, sm, pcmchan_syncmember, link);
2586 		free(sm, M_DEVBUF);
2587 
2588 		if (SLIST_EMPTY(&sg->members)) {
2589 			SLIST_REMOVE(&snd_pcm_syncgroups, sg, pcmchan_syncgroup, link);
2590 			sg_id = sg->id;
2591 			free(sg, M_DEVBUF);
2592 		}
2593 	}
2594 
2595 	return sg_id;
2596 }
2597 
2598 #ifdef OSSV4_EXPERIMENT
2599 int
chn_getpeaks(struct pcm_channel * c,int * lpeak,int * rpeak)2600 chn_getpeaks(struct pcm_channel *c, int *lpeak, int *rpeak)
2601 {
2602 	CHN_LOCKASSERT(c);
2603 	return CHANNEL_GETPEAKS(c->methods, c->devinfo, lpeak, rpeak);
2604 }
2605 #endif
2606