xref: /freebsd/sys/dev/sound/pcm/feeder_rate.c (revision 792251295cdf6c3e1cbb1aa6291434539632912f)
1 /*-
2  * SPDX-License-Identifier: BSD-2-Clause
3  *
4  * Copyright (c) 2005-2009 Ariff Abdullah <ariff@FreeBSD.org>
5  * All rights reserved.
6  *
7  * Redistribution and use in source and binary forms, with or without
8  * modification, are permitted provided that the following conditions
9  * are met:
10  * 1. Redistributions of source code must retain the above copyright
11  *    notice, this list of conditions and the following disclaimer.
12  * 2. Redistributions in binary form must reproduce the above copyright
13  *    notice, this list of conditions and the following disclaimer in the
14  *    documentation and/or other materials provided with the distribution.
15  *
16  * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
17  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
18  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
19  * ARE DISCLAIMED.  IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE
20  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
21  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
22  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
23  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
24  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
25  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
26  * SUCH DAMAGE.
27  */
28 
29 /*
30  * feeder_rate: (Codename: Z Resampler), which means any effort to create
31  *              future replacement for this resampler are simply absurd unless
32  *              the world decide to add new alphabet after Z.
33  *
34  * FreeBSD bandlimited sinc interpolator, technically based on
35  * "Digital Audio Resampling" by Julius O. Smith III
36  *  - http://ccrma.stanford.edu/~jos/resample/
37  *
38  * The Good:
39  * + all out fixed point integer operations, no soft-float or anything like
40  *   that.
41  * + classic polyphase converters with high quality coefficient's polynomial
42  *   interpolators.
43  * + fast, faster, or the fastest of its kind.
44  * + compile time configurable.
45  * + etc etc..
46  *
47  * The Bad:
48  * - The z, z_, and Z_ . Due to mental block (or maybe just 0x7a69), I
49  *   couldn't think of anything simpler than that (feeder_rate_xxx is just
50  *   too long). Expect possible clashes with other zitizens (any?).
51  */
52 
53 #ifdef _KERNEL
54 #ifdef HAVE_KERNEL_OPTION_HEADERS
55 #include "opt_snd.h"
56 #endif
57 #include <dev/sound/pcm/sound.h>
58 #include <dev/sound/pcm/pcm.h>
59 #include "feeder_if.h"
60 
61 #define SND_USE_FXDIV
62 #include "snd_fxdiv_gen.h"
63 #endif
64 
65 #include "feeder_rate_gen.h"
66 
67 #if !defined(_KERNEL) && defined(SND_DIAGNOSTIC)
68 #undef Z_DIAGNOSTIC
69 #define Z_DIAGNOSTIC		1
70 #elif defined(_KERNEL)
71 #undef Z_DIAGNOSTIC
72 #endif
73 
74 #ifndef Z_QUALITY_DEFAULT
75 #define Z_QUALITY_DEFAULT	Z_QUALITY_LINEAR
76 #endif
77 
78 #define Z_RESERVOIR		2048
79 #define Z_RESERVOIR_MAX		131072
80 
81 #define Z_SINC_MAX		0x3fffff
82 #define Z_SINC_DOWNMAX		48		/* 384000 / 8000 */
83 
84 #ifdef _KERNEL
85 #define Z_POLYPHASE_MAX		183040		/* 286 taps, 640 phases */
86 #else
87 #define Z_POLYPHASE_MAX		1464320		/* 286 taps, 5120 phases */
88 #endif
89 
90 #define Z_RATE_DEFAULT		48000
91 
92 #define Z_RATE_MIN		FEEDRATE_RATEMIN
93 #define Z_RATE_MAX		FEEDRATE_RATEMAX
94 #define Z_ROUNDHZ		FEEDRATE_ROUNDHZ
95 #define Z_ROUNDHZ_MIN		FEEDRATE_ROUNDHZ_MIN
96 #define Z_ROUNDHZ_MAX		FEEDRATE_ROUNDHZ_MAX
97 
98 #define Z_RATE_SRC		FEEDRATE_SRC
99 #define Z_RATE_DST		FEEDRATE_DST
100 #define Z_RATE_QUALITY		FEEDRATE_QUALITY
101 #define Z_RATE_CHANNELS		FEEDRATE_CHANNELS
102 
103 #define Z_PARANOID		1
104 
105 #define Z_MULTIFORMAT		1
106 
107 #ifdef _KERNEL
108 #undef Z_USE_ALPHADRIFT
109 #define Z_USE_ALPHADRIFT	1
110 #endif
111 
112 #define Z_FACTOR_MIN		1
113 #define Z_FACTOR_MAX		Z_MASK
114 #define Z_FACTOR_SAFE(v)	(!((v) < Z_FACTOR_MIN || (v) > Z_FACTOR_MAX))
115 
116 struct z_info;
117 
118 typedef void (*z_resampler_t)(struct z_info *, uint8_t *);
119 
120 struct z_info {
121 	int32_t rsrc, rdst;	/* original source / destination rates */
122 	int32_t src, dst;	/* rounded source / destination rates */
123 	int32_t channels;	/* total channels */
124 	int32_t bps;		/* bytes-per-sample */
125 	int32_t quality;	/* resampling quality */
126 
127 	int32_t z_gx, z_gy;	/* interpolation / decimation ratio */
128 	int32_t z_alpha;	/* output sample time phase / drift */
129 	uint8_t *z_delay;	/* FIR delay line / linear buffer */
130 	int32_t *z_coeff;	/* FIR coefficients */
131 	int32_t *z_dcoeff;	/* FIR coefficients differences */
132 	int32_t *z_pcoeff;	/* FIR polyphase coefficients */
133 	int32_t z_scale;	/* output scaling */
134 	int32_t z_dx;		/* input sample drift increment */
135 	int32_t z_dy;		/* output sample drift increment */
136 #ifdef Z_USE_ALPHADRIFT
137 	int32_t z_alphadrift;	/* alpha drift rate */
138 	int32_t z_startdrift;	/* buffer start position drift rate */
139 #endif
140 	int32_t z_mask;		/* delay line full length mask */
141 	int32_t z_size;		/* half width of FIR taps */
142 	int32_t z_full;		/* full size of delay line */
143 	int32_t z_alloc;	/* largest allocated full size of delay line */
144 	int32_t z_start;	/* buffer processing start position */
145 	int32_t z_pos;		/* current position for the next feed */
146 #ifdef Z_DIAGNOSTIC
147 	uint32_t z_cycle;	/* output cycle, purely for statistical */
148 #endif
149 	int32_t z_maxfeed;	/* maximum feed to avoid 32bit overflow */
150 
151 	z_resampler_t z_resample;
152 };
153 
154 int feeder_rate_min = Z_RATE_MIN;
155 int feeder_rate_max = Z_RATE_MAX;
156 int feeder_rate_round = Z_ROUNDHZ;
157 int feeder_rate_quality = Z_QUALITY_DEFAULT;
158 
159 static int feeder_rate_polyphase_max = Z_POLYPHASE_MAX;
160 
161 #ifdef _KERNEL
162 static char feeder_rate_presets[] = FEEDER_RATE_PRESETS;
163 SYSCTL_STRING(_hw_snd, OID_AUTO, feeder_rate_presets, CTLFLAG_RD,
164     &feeder_rate_presets, 0, "compile-time rate presets");
165 SYSCTL_INT(_hw_snd, OID_AUTO, feeder_rate_polyphase_max, CTLFLAG_RWTUN,
166     &feeder_rate_polyphase_max, 0, "maximum allowable polyphase entries");
167 
168 static int
sysctl_hw_snd_feeder_rate_min(SYSCTL_HANDLER_ARGS)169 sysctl_hw_snd_feeder_rate_min(SYSCTL_HANDLER_ARGS)
170 {
171 	int err, val;
172 
173 	val = feeder_rate_min;
174 	err = sysctl_handle_int(oidp, &val, 0, req);
175 
176 	if (err != 0 || req->newptr == NULL || val == feeder_rate_min)
177 		return (err);
178 
179 	if (!(Z_FACTOR_SAFE(val) && val < feeder_rate_max))
180 		return (EINVAL);
181 
182 	feeder_rate_min = val;
183 
184 	return (0);
185 }
186 SYSCTL_PROC(_hw_snd, OID_AUTO, feeder_rate_min,
187     CTLTYPE_INT | CTLFLAG_RWTUN | CTLFLAG_MPSAFE, 0, sizeof(int),
188     sysctl_hw_snd_feeder_rate_min, "I",
189     "minimum allowable rate");
190 
191 static int
sysctl_hw_snd_feeder_rate_max(SYSCTL_HANDLER_ARGS)192 sysctl_hw_snd_feeder_rate_max(SYSCTL_HANDLER_ARGS)
193 {
194 	int err, val;
195 
196 	val = feeder_rate_max;
197 	err = sysctl_handle_int(oidp, &val, 0, req);
198 
199 	if (err != 0 || req->newptr == NULL || val == feeder_rate_max)
200 		return (err);
201 
202 	if (!(Z_FACTOR_SAFE(val) && val > feeder_rate_min))
203 		return (EINVAL);
204 
205 	feeder_rate_max = val;
206 
207 	return (0);
208 }
209 SYSCTL_PROC(_hw_snd, OID_AUTO, feeder_rate_max,
210     CTLTYPE_INT | CTLFLAG_RWTUN | CTLFLAG_MPSAFE, 0, sizeof(int),
211     sysctl_hw_snd_feeder_rate_max, "I",
212     "maximum allowable rate");
213 
214 static int
sysctl_hw_snd_feeder_rate_round(SYSCTL_HANDLER_ARGS)215 sysctl_hw_snd_feeder_rate_round(SYSCTL_HANDLER_ARGS)
216 {
217 	int err, val;
218 
219 	val = feeder_rate_round;
220 	err = sysctl_handle_int(oidp, &val, 0, req);
221 
222 	if (err != 0 || req->newptr == NULL || val == feeder_rate_round)
223 		return (err);
224 
225 	if (val < Z_ROUNDHZ_MIN || val > Z_ROUNDHZ_MAX)
226 		return (EINVAL);
227 
228 	feeder_rate_round = val - (val % Z_ROUNDHZ);
229 
230 	return (0);
231 }
232 SYSCTL_PROC(_hw_snd, OID_AUTO, feeder_rate_round,
233     CTLTYPE_INT | CTLFLAG_RWTUN | CTLFLAG_MPSAFE, 0, sizeof(int),
234     sysctl_hw_snd_feeder_rate_round, "I",
235     "sample rate converter rounding threshold");
236 
237 static int
sysctl_hw_snd_feeder_rate_quality(SYSCTL_HANDLER_ARGS)238 sysctl_hw_snd_feeder_rate_quality(SYSCTL_HANDLER_ARGS)
239 {
240 	struct snddev_info *d;
241 	struct pcm_channel *c;
242 	struct pcm_feeder *f;
243 	int i, err, val;
244 
245 	val = feeder_rate_quality;
246 	err = sysctl_handle_int(oidp, &val, 0, req);
247 
248 	if (err != 0 || req->newptr == NULL || val == feeder_rate_quality)
249 		return (err);
250 
251 	if (val < Z_QUALITY_MIN || val > Z_QUALITY_MAX)
252 		return (EINVAL);
253 
254 	feeder_rate_quality = val;
255 
256 	/*
257 	 * Traverse all available channels on each device and try to
258 	 * set resampler quality if and only if it is exist as
259 	 * part of feeder chains and the channel is idle.
260 	 */
261 	bus_topo_lock();
262 	for (i = 0; pcm_devclass != NULL &&
263 	    i < devclass_get_maxunit(pcm_devclass); i++) {
264 		d = devclass_get_softc(pcm_devclass, i);
265 		if (!PCM_REGISTERED(d))
266 			continue;
267 		PCM_LOCK(d);
268 		PCM_WAIT(d);
269 		PCM_ACQUIRE(d);
270 		CHN_FOREACH(c, d, channels.pcm) {
271 			CHN_LOCK(c);
272 			f = feeder_find(c, FEEDER_RATE);
273 			if (f == NULL || f->data == NULL || CHN_STARTED(c)) {
274 				CHN_UNLOCK(c);
275 				continue;
276 			}
277 			(void)FEEDER_SET(f, FEEDRATE_QUALITY, val);
278 			CHN_UNLOCK(c);
279 		}
280 		PCM_RELEASE(d);
281 		PCM_UNLOCK(d);
282 	}
283 	bus_topo_unlock();
284 
285 	return (0);
286 }
287 SYSCTL_PROC(_hw_snd, OID_AUTO, feeder_rate_quality,
288     CTLTYPE_INT | CTLFLAG_RWTUN | CTLFLAG_MPSAFE, 0, sizeof(int),
289     sysctl_hw_snd_feeder_rate_quality, "I",
290     "sample rate converter quality ("__XSTRING(Z_QUALITY_MIN)"=low .. "
291     __XSTRING(Z_QUALITY_MAX)"=high)");
292 #endif	/* _KERNEL */
293 
294 /*
295  * Resampler type.
296  */
297 #define Z_IS_ZOH(i)		((i)->quality == Z_QUALITY_ZOH)
298 #define Z_IS_LINEAR(i)		((i)->quality == Z_QUALITY_LINEAR)
299 #define Z_IS_SINC(i)		((i)->quality > Z_QUALITY_LINEAR)
300 
301 /*
302  * Macroses for accurate sample time drift calculations.
303  *
304  * gy2gx : given the amount of output, return the _exact_ required amount of
305  *         input.
306  * gx2gy : given the amount of input, return the _maximum_ amount of output
307  *         that will be generated.
308  * drift : given the amount of input and output, return the elapsed
309  *         sample-time.
310  */
311 #define _Z_GCAST(x)		((uint64_t)(x))
312 
313 #if defined(__i386__)
314 /*
315  * This is where i386 being beaten to a pulp. Fortunately this function is
316  * rarely being called and if it is, it will decide the best (hopefully)
317  * fastest way to do the division. If we can ensure that everything is dword
318  * aligned, letting the compiler to call udivdi3 to do the division can be
319  * faster compared to this.
320  *
321  * amd64 is the clear winner here, no question about it.
322  */
323 static __inline uint32_t
Z_DIV(uint64_t v,uint32_t d)324 Z_DIV(uint64_t v, uint32_t d)
325 {
326 	uint32_t hi, lo, quo, rem;
327 
328 	hi = v >> 32;
329 	lo = v & 0xffffffff;
330 
331 	/*
332 	 * As much as we can, try to avoid long division like a plague.
333 	 */
334 	if (hi == 0)
335 		quo = lo / d;
336 	else
337 		__asm("divl %2"
338 		    : "=a" (quo), "=d" (rem)
339 		    : "r" (d), "0" (lo), "1" (hi));
340 
341 	return (quo);
342 }
343 #else
344 #define Z_DIV(x, y)		((x) / (y))
345 #endif
346 
347 #define _Z_GY2GX(i, a, v)						\
348 	Z_DIV(((_Z_GCAST((i)->z_gx) * (v)) + ((i)->z_gy - (a) - 1)),	\
349 	(i)->z_gy)
350 
351 #define _Z_GX2GY(i, a, v)						\
352 	Z_DIV(((_Z_GCAST((i)->z_gy) * (v)) + (a)), (i)->z_gx)
353 
354 #define _Z_DRIFT(i, x, y)						\
355 	((_Z_GCAST((i)->z_gy) * (x)) - (_Z_GCAST((i)->z_gx) * (y)))
356 
357 #define z_gy2gx(i, v)		_Z_GY2GX(i, (i)->z_alpha, v)
358 #define z_gx2gy(i, v)		_Z_GX2GY(i, (i)->z_alpha, v)
359 #define z_drift(i, x, y)	_Z_DRIFT(i, x, y)
360 
361 /*
362  * Macroses for SINC coefficients table manipulations.. whatever.
363  */
364 #define Z_SINC_COEFF_IDX(i)	((i)->quality - Z_QUALITY_LINEAR - 1)
365 
366 #define Z_SINC_LEN(i)							\
367 	((int32_t)(((uint64_t)z_coeff_tab[Z_SINC_COEFF_IDX(i)].len <<	\
368 	    Z_SHIFT) / (i)->z_dy))
369 
370 #define Z_SINC_BASE_LEN(i)						\
371 	((z_coeff_tab[Z_SINC_COEFF_IDX(i)].len - 1) >> (Z_DRIFT_SHIFT - 1))
372 
373 /*
374  * Macroses for linear delay buffer operations. Alignment is not
375  * really necessary since we're not using true circular buffer, but it
376  * will help us guard against possible trespasser. To be honest,
377  * the linear block operations does not need guarding at all due to
378  * accurate drifting!
379  */
380 #define z_align(i, v)		((v) & (i)->z_mask)
381 #define z_next(i, o, v)		z_align(i, (o) + (v))
382 #define z_prev(i, o, v)		z_align(i, (o) - (v))
383 #define z_fetched(i)		(z_align(i, (i)->z_pos - (i)->z_start) - 1)
384 #define z_free(i)		((i)->z_full - (i)->z_pos)
385 
386 /*
387  * Macroses for Bla Bla .. :)
388  */
389 #define z_copy(src, dst, sz)	(void)memcpy(dst, src, sz)
390 #define z_feed(...)		FEEDER_FEED(__VA_ARGS__)
391 
392 static __inline uint32_t
z_min(uint32_t x,uint32_t y)393 z_min(uint32_t x, uint32_t y)
394 {
395 
396 	return ((x < y) ? x : y);
397 }
398 
399 static int32_t
z_gcd(int32_t x,int32_t y)400 z_gcd(int32_t x, int32_t y)
401 {
402 	int32_t w;
403 
404 	while (y != 0) {
405 		w = x % y;
406 		x = y;
407 		y = w;
408 	}
409 
410 	return (x);
411 }
412 
413 static int32_t
z_roundpow2(int32_t v)414 z_roundpow2(int32_t v)
415 {
416 	int32_t i;
417 
418 	i = 1;
419 
420 	/*
421 	 * Let it overflow at will..
422 	 */
423 	while (i > 0 && i < v)
424 		i <<= 1;
425 
426 	return (i);
427 }
428 
429 /*
430  * Zero Order Hold, the worst of the worst, an insult against quality,
431  * but super fast.
432  */
433 static void
z_feed_zoh(struct z_info * info,uint8_t * dst)434 z_feed_zoh(struct z_info *info, uint8_t *dst)
435 {
436 	uint32_t cnt;
437 	uint8_t *src;
438 
439 	cnt = info->channels * info->bps;
440 	src = info->z_delay + (info->z_start * cnt);
441 
442 	/*
443 	 * This is a bit faster than doing bcopy() since we're dealing
444 	 * with possible unaligned samples.
445 	 */
446 	do {
447 		*dst++ = *src++;
448 	} while (--cnt != 0);
449 }
450 
451 /*
452  * Linear Interpolation. This at least sounds better (perceptually) and fast,
453  * but without any proper filtering which means aliasing still exist and
454  * could become worst with a right sample. Interpolation centered within
455  * Z_LINEAR_ONE between the present and previous sample and everything is
456  * done with simple 32bit scaling arithmetic.
457  */
458 #define Z_DECLARE_LINEAR(SIGN, BIT, ENDIAN)					\
459 static void									\
460 z_feed_linear_##SIGN##BIT##ENDIAN(struct z_info *info, uint8_t *dst)		\
461 {										\
462 	int32_t z;								\
463 	intpcm_t x, y;								\
464 	uint32_t ch;								\
465 	uint8_t *sx, *sy;							\
466 										\
467 	z = ((uint32_t)info->z_alpha * info->z_dx) >> Z_LINEAR_UNSHIFT;		\
468 										\
469 	sx = info->z_delay + (info->z_start * info->channels *			\
470 	    PCM_##BIT##_BPS);							\
471 	sy = sx - (info->channels * PCM_##BIT##_BPS);				\
472 										\
473 	ch = info->channels;							\
474 										\
475 	do {									\
476 		x = pcm_sample_read(sx, AFMT_##SIGN##BIT##_##ENDIAN);		\
477 		y = pcm_sample_read(sy, AFMT_##SIGN##BIT##_##ENDIAN);		\
478 		x = Z_LINEAR_INTERPOLATE_##BIT(z, x, y);			\
479 		pcm_sample_write(dst, x, AFMT_##SIGN##BIT##_##ENDIAN);		\
480 		sx += PCM_##BIT##_BPS;						\
481 		sy += PCM_##BIT##_BPS;						\
482 		dst += PCM_##BIT##_BPS;						\
483 	} while (--ch != 0);							\
484 }
485 
486 /*
487  * Userland clipping diagnostic check, not enabled in kernel compilation.
488  * While doing sinc interpolation, unrealistic samples like full scale sine
489  * wav will clip, but for other things this will not make any noise at all.
490  * Everybody should learn how to normalized perceived loudness of their own
491  * music/sounds/samples (hint: ReplayGain).
492  */
493 #ifdef Z_DIAGNOSTIC
494 #define Z_CLIP_CHECK(v, BIT)	do {					\
495 	if ((v) > PCM_S##BIT##_MAX) {					\
496 		fprintf(stderr, "Overflow: v=%jd, max=%jd\n",		\
497 		    (intmax_t)(v), (intmax_t)PCM_S##BIT##_MAX);		\
498 	} else if ((v) < PCM_S##BIT##_MIN) {				\
499 		fprintf(stderr, "Underflow: v=%jd, min=%jd\n",		\
500 		    (intmax_t)(v), (intmax_t)PCM_S##BIT##_MIN);		\
501 	}								\
502 } while (0)
503 #else
504 #define Z_CLIP_CHECK(...)
505 #endif
506 
507 /*
508  * Sine Cardinal (SINC) Interpolation. Scaling is done in 64 bit, so
509  * there's no point to hold the plate any longer. All samples will be
510  * shifted to a full 32 bit, scaled and restored during write for
511  * maximum dynamic range (only for downsampling).
512  */
513 #define _Z_SINC_ACCUMULATE(SIGN, BIT, ENDIAN, adv)			\
514 	c += z >> Z_SHIFT;						\
515 	z &= Z_MASK;							\
516 	coeff = Z_COEFF_INTERPOLATE(z, z_coeff[c], z_dcoeff[c]);	\
517 	x = pcm_sample_read(p, AFMT_##SIGN##BIT##_##ENDIAN);		\
518 	v += Z_NORM_##BIT((intpcm64_t)x * coeff);			\
519 	z += info->z_dy;						\
520 	p adv##= info->channels * PCM_##BIT##_BPS
521 
522 /*
523  * XXX GCC4 optimization is such a !@#$%, need manual unrolling.
524  */
525 #if defined(__GNUC__) && __GNUC__ >= 4
526 #define Z_SINC_ACCUMULATE(...)	do {					\
527 	_Z_SINC_ACCUMULATE(__VA_ARGS__);				\
528 	_Z_SINC_ACCUMULATE(__VA_ARGS__);				\
529 } while (0)
530 #define Z_SINC_ACCUMULATE_DECR		2
531 #else
532 #define Z_SINC_ACCUMULATE(...)	do {					\
533 	_Z_SINC_ACCUMULATE(__VA_ARGS__);				\
534 } while (0)
535 #define Z_SINC_ACCUMULATE_DECR		1
536 #endif
537 
538 #define Z_DECLARE_SINC(SIGN, BIT, ENDIAN)					\
539 static void									\
540 z_feed_sinc_##SIGN##BIT##ENDIAN(struct z_info *info, uint8_t *dst)		\
541 {										\
542 	intpcm64_t v;								\
543 	intpcm_t x;								\
544 	uint8_t *p;								\
545 	int32_t coeff, z, *z_coeff, *z_dcoeff;					\
546 	uint32_t c, center, ch, i;						\
547 										\
548 	z_coeff = info->z_coeff;						\
549 	z_dcoeff = info->z_dcoeff;						\
550 	center = z_prev(info, info->z_start, info->z_size);			\
551 	ch = info->channels * PCM_##BIT##_BPS;					\
552 	dst += ch;								\
553 										\
554 	do {									\
555 		dst -= PCM_##BIT##_BPS;						\
556 		ch -= PCM_##BIT##_BPS;						\
557 		v = 0;								\
558 		z = info->z_alpha * info->z_dx;					\
559 		c = 0;								\
560 		p = info->z_delay + (z_next(info, center, 1) *			\
561 		    info->channels * PCM_##BIT##_BPS) + ch;			\
562 		for (i = info->z_size; i != 0; i -= Z_SINC_ACCUMULATE_DECR) 	\
563 			Z_SINC_ACCUMULATE(SIGN, BIT, ENDIAN, +);		\
564 		z = info->z_dy - (info->z_alpha * info->z_dx);			\
565 		c = 0;								\
566 		p = info->z_delay + (center * info->channels *			\
567 		    PCM_##BIT##_BPS) + ch;					\
568 		for (i = info->z_size; i != 0; i -= Z_SINC_ACCUMULATE_DECR) 	\
569 			Z_SINC_ACCUMULATE(SIGN, BIT, ENDIAN, -);		\
570 		if (info->z_scale != Z_ONE)					\
571 			v = Z_SCALE_##BIT(v, info->z_scale);			\
572 		else								\
573 			v >>= Z_COEFF_SHIFT - Z_GUARD_BIT_##BIT;		\
574 		Z_CLIP_CHECK(v, BIT);						\
575 		pcm_sample_write(dst, pcm_clamp(v, AFMT_##SIGN##BIT##_##ENDIAN),\
576 		    AFMT_##SIGN##BIT##_##ENDIAN);				\
577 	} while (ch != 0);							\
578 }
579 
580 #define Z_DECLARE_SINC_POLYPHASE(SIGN, BIT, ENDIAN)				\
581 static void									\
582 z_feed_sinc_polyphase_##SIGN##BIT##ENDIAN(struct z_info *info, uint8_t *dst)	\
583 {										\
584 	intpcm64_t v;								\
585 	intpcm_t x;								\
586 	uint8_t *p;								\
587 	int32_t ch, i, start, *z_pcoeff;					\
588 										\
589 	ch = info->channels * PCM_##BIT##_BPS;					\
590 	dst += ch;								\
591 	start = z_prev(info, info->z_start, (info->z_size << 1) - 1) * ch;	\
592 										\
593 	do {									\
594 		dst -= PCM_##BIT##_BPS;						\
595 		ch -= PCM_##BIT##_BPS;						\
596 		v = 0;								\
597 		p = info->z_delay + start + ch;					\
598 		z_pcoeff = info->z_pcoeff +					\
599 		    ((info->z_alpha * info->z_size) << 1);			\
600 		for (i = info->z_size; i != 0; i--) {				\
601 			x = pcm_sample_read(p, AFMT_##SIGN##BIT##_##ENDIAN);	\
602 			v += Z_NORM_##BIT((intpcm64_t)x * *z_pcoeff);		\
603 			z_pcoeff++;						\
604 			p += info->channels * PCM_##BIT##_BPS;			\
605 			x = pcm_sample_read(p, AFMT_##SIGN##BIT##_##ENDIAN);	\
606 			v += Z_NORM_##BIT((intpcm64_t)x * *z_pcoeff);		\
607 			z_pcoeff++;						\
608 			p += info->channels * PCM_##BIT##_BPS;			\
609 		}								\
610 		if (info->z_scale != Z_ONE)					\
611 			v = Z_SCALE_##BIT(v, info->z_scale);			\
612 		else								\
613 			v >>= Z_COEFF_SHIFT - Z_GUARD_BIT_##BIT;		\
614 		Z_CLIP_CHECK(v, BIT);						\
615 		pcm_sample_write(dst, pcm_clamp(v, AFMT_##SIGN##BIT##_##ENDIAN),\
616 		    AFMT_##SIGN##BIT##_##ENDIAN);				\
617 	} while (ch != 0);							\
618 }
619 
620 #define Z_DECLARE(SIGN, BIT, ENDIAN)					\
621 	Z_DECLARE_LINEAR(SIGN, BIT, ENDIAN)				\
622 	Z_DECLARE_SINC(SIGN, BIT, ENDIAN)				\
623 	Z_DECLARE_SINC_POLYPHASE(SIGN, BIT, ENDIAN)
624 
625 #if BYTE_ORDER == LITTLE_ENDIAN || defined(SND_FEEDER_MULTIFORMAT)
626 Z_DECLARE(S, 16, LE)
627 Z_DECLARE(S, 32, LE)
628 #endif
629 #if BYTE_ORDER == BIG_ENDIAN || defined(SND_FEEDER_MULTIFORMAT)
630 Z_DECLARE(S, 16, BE)
631 Z_DECLARE(S, 32, BE)
632 #endif
633 #ifdef SND_FEEDER_MULTIFORMAT
634 Z_DECLARE(S,  8, NE)
635 Z_DECLARE(S, 24, LE)
636 Z_DECLARE(S, 24, BE)
637 Z_DECLARE(U,  8, NE)
638 Z_DECLARE(U, 16, LE)
639 Z_DECLARE(U, 24, LE)
640 Z_DECLARE(U, 32, LE)
641 Z_DECLARE(U, 16, BE)
642 Z_DECLARE(U, 24, BE)
643 Z_DECLARE(U, 32, BE)
644 Z_DECLARE(F, 32, LE)
645 Z_DECLARE(F, 32, BE)
646 #endif
647 
648 enum {
649 	Z_RESAMPLER_ZOH,
650 	Z_RESAMPLER_LINEAR,
651 	Z_RESAMPLER_SINC,
652 	Z_RESAMPLER_SINC_POLYPHASE,
653 	Z_RESAMPLER_LAST
654 };
655 
656 #define Z_RESAMPLER_IDX(i)						\
657 	(Z_IS_SINC(i) ? Z_RESAMPLER_SINC : (i)->quality)
658 
659 #define Z_RESAMPLER_ENTRY(SIGN, BIT, ENDIAN)					\
660 	{									\
661 	    AFMT_##SIGN##BIT##_##ENDIAN,					\
662 	    {									\
663 		[Z_RESAMPLER_ZOH]    = z_feed_zoh,				\
664 		[Z_RESAMPLER_LINEAR] = z_feed_linear_##SIGN##BIT##ENDIAN,	\
665 		[Z_RESAMPLER_SINC]   = z_feed_sinc_##SIGN##BIT##ENDIAN,		\
666 		[Z_RESAMPLER_SINC_POLYPHASE]   =				\
667 		    z_feed_sinc_polyphase_##SIGN##BIT##ENDIAN			\
668 	    }									\
669 	}
670 
671 static const struct {
672 	uint32_t format;
673 	z_resampler_t resampler[Z_RESAMPLER_LAST];
674 } z_resampler_tab[] = {
675 #if BYTE_ORDER == LITTLE_ENDIAN || defined(SND_FEEDER_MULTIFORMAT)
676 	Z_RESAMPLER_ENTRY(S, 16, LE),
677 	Z_RESAMPLER_ENTRY(S, 32, LE),
678 #endif
679 #if BYTE_ORDER == BIG_ENDIAN || defined(SND_FEEDER_MULTIFORMAT)
680 	Z_RESAMPLER_ENTRY(S, 16, BE),
681 	Z_RESAMPLER_ENTRY(S, 32, BE),
682 #endif
683 #ifdef SND_FEEDER_MULTIFORMAT
684 	Z_RESAMPLER_ENTRY(S,  8, NE),
685 	Z_RESAMPLER_ENTRY(S, 24, LE),
686 	Z_RESAMPLER_ENTRY(S, 24, BE),
687 	Z_RESAMPLER_ENTRY(U,  8, NE),
688 	Z_RESAMPLER_ENTRY(U, 16, LE),
689 	Z_RESAMPLER_ENTRY(U, 24, LE),
690 	Z_RESAMPLER_ENTRY(U, 32, LE),
691 	Z_RESAMPLER_ENTRY(U, 16, BE),
692 	Z_RESAMPLER_ENTRY(U, 24, BE),
693 	Z_RESAMPLER_ENTRY(U, 32, BE),
694 	Z_RESAMPLER_ENTRY(F, 32, LE),
695 	Z_RESAMPLER_ENTRY(F, 32, BE),
696 #endif
697 };
698 
699 #define Z_RESAMPLER_TAB_SIZE						\
700 	((int32_t)(sizeof(z_resampler_tab) / sizeof(z_resampler_tab[0])))
701 
702 static void
z_resampler_reset(struct z_info * info)703 z_resampler_reset(struct z_info *info)
704 {
705 
706 	info->src = info->rsrc - (info->rsrc % ((feeder_rate_round > 0 &&
707 	    info->rsrc > feeder_rate_round) ? feeder_rate_round : 1));
708 	info->dst = info->rdst - (info->rdst % ((feeder_rate_round > 0 &&
709 	    info->rdst > feeder_rate_round) ? feeder_rate_round : 1));
710 	info->z_gx = 1;
711 	info->z_gy = 1;
712 	info->z_alpha = 0;
713 	info->z_resample = NULL;
714 	info->z_size = 1;
715 	info->z_coeff = NULL;
716 	info->z_dcoeff = NULL;
717 	free(info->z_pcoeff, M_DEVBUF);
718 	info->z_pcoeff = NULL;
719 	info->z_scale = Z_ONE;
720 	info->z_dx = Z_FULL_ONE;
721 	info->z_dy = Z_FULL_ONE;
722 #ifdef Z_DIAGNOSTIC
723 	info->z_cycle = 0;
724 #endif
725 	if (info->quality < Z_QUALITY_MIN)
726 		info->quality = Z_QUALITY_MIN;
727 	else if (info->quality > Z_QUALITY_MAX)
728 		info->quality = Z_QUALITY_MAX;
729 }
730 
731 #ifdef Z_PARANOID
732 static int32_t
z_resampler_sinc_len(struct z_info * info)733 z_resampler_sinc_len(struct z_info *info)
734 {
735 	int32_t c, z, len, lmax;
736 
737 	if (!Z_IS_SINC(info))
738 		return (1);
739 
740 	/*
741 	 * A rather careful (or useless) way to calculate filter length.
742 	 * Z_SINC_LEN() itself is accurate enough to do its job. Extra
743 	 * sanity checking is not going to hurt though..
744 	 */
745 	c = 0;
746 	z = info->z_dy;
747 	len = 0;
748 	lmax = z_coeff_tab[Z_SINC_COEFF_IDX(info)].len;
749 
750 	do {
751 		c += z >> Z_SHIFT;
752 		z &= Z_MASK;
753 		z += info->z_dy;
754 	} while (c < lmax && ++len > 0);
755 
756 	if (len != Z_SINC_LEN(info)) {
757 #ifdef _KERNEL
758 		printf("%s(): sinc l=%d != Z_SINC_LEN=%d\n",
759 		    __func__, len, Z_SINC_LEN(info));
760 #else
761 		fprintf(stderr, "%s(): sinc l=%d != Z_SINC_LEN=%d\n",
762 		    __func__, len, Z_SINC_LEN(info));
763 		return (-1);
764 #endif
765 	}
766 
767 	return (len);
768 }
769 #else
770 #define z_resampler_sinc_len(i)		(Z_IS_SINC(i) ? Z_SINC_LEN(i) : 1)
771 #endif
772 
773 #define Z_POLYPHASE_COEFF_SHIFT		0
774 
775 /*
776  * Pick suitable polynomial interpolators based on filter oversampled ratio
777  * (2 ^ Z_DRIFT_SHIFT).
778  */
779 #if !(defined(Z_COEFF_INTERP_ZOH) || defined(Z_COEFF_INTERP_LINEAR) ||		\
780     defined(Z_COEFF_INTERP_QUADRATIC) || defined(Z_COEFF_INTERP_HERMITE) ||	\
781     defined(Z_COEFF_INTER_BSPLINE) || defined(Z_COEFF_INTERP_OPT32X) ||		\
782     defined(Z_COEFF_INTERP_OPT16X) || defined(Z_COEFF_INTERP_OPT8X) ||		\
783     defined(Z_COEFF_INTERP_OPT4X) || defined(Z_COEFF_INTERP_OPT2X))
784 #if Z_DRIFT_SHIFT >= 6
785 #define Z_COEFF_INTERP_BSPLINE		1
786 #elif Z_DRIFT_SHIFT >= 5
787 #define Z_COEFF_INTERP_OPT32X		1
788 #elif Z_DRIFT_SHIFT == 4
789 #define Z_COEFF_INTERP_OPT16X		1
790 #elif Z_DRIFT_SHIFT == 3
791 #define Z_COEFF_INTERP_OPT8X		1
792 #elif Z_DRIFT_SHIFT == 2
793 #define Z_COEFF_INTERP_OPT4X		1
794 #elif Z_DRIFT_SHIFT == 1
795 #define Z_COEFF_INTERP_OPT2X		1
796 #else
797 #error "Z_DRIFT_SHIFT screwed!"
798 #endif
799 #endif
800 
801 /*
802  * In classic polyphase mode, the actual coefficients for each phases need to
803  * be calculated based on default prototype filters. For highly oversampled
804  * filter, linear or quadradatic interpolator should be enough. Anything less
805  * than that require 'special' interpolators to reduce interpolation errors.
806  *
807  * "Polynomial Interpolators for High-Quality Resampling of Oversampled Audio"
808  *    by Olli Niemitalo
809  *    - http://www.student.oulu.fi/~oniemita/dsp/deip.pdf
810  *
811  */
812 static int32_t
z_coeff_interpolate(int32_t z,int32_t * z_coeff)813 z_coeff_interpolate(int32_t z, int32_t *z_coeff)
814 {
815 	int32_t coeff;
816 #if defined(Z_COEFF_INTERP_ZOH)
817 
818 	/* 1-point, 0th-order (Zero Order Hold) */
819 	z = z;
820 	coeff = z_coeff[0];
821 #elif defined(Z_COEFF_INTERP_LINEAR)
822 	int32_t zl0, zl1;
823 
824 	/* 2-point, 1st-order Linear */
825 	zl0 = z_coeff[0];
826 	zl1 = z_coeff[1] - z_coeff[0];
827 
828 	coeff = Z_RSHIFT((int64_t)zl1 * z, Z_SHIFT) + zl0;
829 #elif defined(Z_COEFF_INTERP_QUADRATIC)
830 	int32_t zq0, zq1, zq2;
831 
832 	/* 3-point, 2nd-order Quadratic */
833 	zq0 = z_coeff[0];
834 	zq1 = z_coeff[1] - z_coeff[-1];
835 	zq2 = z_coeff[1] + z_coeff[-1] - (z_coeff[0] << 1);
836 
837 	coeff = Z_RSHIFT((Z_RSHIFT((int64_t)zq2 * z, Z_SHIFT) +
838 	    zq1) * z, Z_SHIFT + 1) + zq0;
839 #elif defined(Z_COEFF_INTERP_HERMITE)
840 	int32_t zh0, zh1, zh2, zh3;
841 
842 	/* 4-point, 3rd-order Hermite */
843 	zh0 = z_coeff[0];
844 	zh1 = z_coeff[1] - z_coeff[-1];
845 	zh2 = (z_coeff[-1] << 1) - (z_coeff[0] * 5) + (z_coeff[1] << 2) -
846 	    z_coeff[2];
847 	zh3 = z_coeff[2] - z_coeff[-1] + ((z_coeff[0] - z_coeff[1]) * 3);
848 
849 	coeff = Z_RSHIFT((Z_RSHIFT((Z_RSHIFT((int64_t)zh3 * z, Z_SHIFT) +
850 	    zh2) * z, Z_SHIFT) + zh1) * z, Z_SHIFT + 1) + zh0;
851 #elif defined(Z_COEFF_INTERP_BSPLINE)
852 	int32_t zb0, zb1, zb2, zb3;
853 
854 	/* 4-point, 3rd-order B-Spline */
855 	zb0 = Z_RSHIFT(0x15555555LL * (((int64_t)z_coeff[0] << 2) +
856 	    z_coeff[-1] + z_coeff[1]), 30);
857 	zb1 = z_coeff[1] - z_coeff[-1];
858 	zb2 = z_coeff[-1] + z_coeff[1] - (z_coeff[0] << 1);
859 	zb3 = Z_RSHIFT(0x15555555LL * (((z_coeff[0] - z_coeff[1]) * 3) +
860 	    z_coeff[2] - z_coeff[-1]), 30);
861 
862 	coeff = (Z_RSHIFT((Z_RSHIFT((Z_RSHIFT((int64_t)zb3 * z, Z_SHIFT) +
863 	    zb2) * z, Z_SHIFT) + zb1) * z, Z_SHIFT) + zb0 + 1) >> 1;
864 #elif defined(Z_COEFF_INTERP_OPT32X)
865 	int32_t zoz, zoe1, zoe2, zoe3, zoo1, zoo2, zoo3;
866 	int32_t zoc0, zoc1, zoc2, zoc3, zoc4, zoc5;
867 
868 	/* 6-point, 5th-order Optimal 32x */
869 	zoz = z - (Z_ONE >> 1);
870 	zoe1 = z_coeff[1] + z_coeff[0];
871 	zoe2 = z_coeff[2] + z_coeff[-1];
872 	zoe3 = z_coeff[3] + z_coeff[-2];
873 	zoo1 = z_coeff[1] - z_coeff[0];
874 	zoo2 = z_coeff[2] - z_coeff[-1];
875 	zoo3 = z_coeff[3] - z_coeff[-2];
876 
877 	zoc0 = Z_RSHIFT((0x1ac2260dLL * zoe1) + (0x0526cdcaLL * zoe2) +
878 	    (0x00170c29LL * zoe3), 30);
879 	zoc1 = Z_RSHIFT((0x14f8a49aLL * zoo1) + (0x0d6d1109LL * zoo2) +
880 	    (0x008cd4dcLL * zoo3), 30);
881 	zoc2 = Z_RSHIFT((-0x0d3e94a4LL * zoe1) + (0x0bddded4LL * zoe2) +
882 	    (0x0160b5d0LL * zoe3), 30);
883 	zoc3 = Z_RSHIFT((-0x0de10cc4LL * zoo1) + (0x019b2a7dLL * zoo2) +
884 	    (0x01cfe914LL * zoo3), 30);
885 	zoc4 = Z_RSHIFT((0x02aa12d7LL * zoe1) + (-0x03ff1bb3LL * zoe2) +
886 	    (0x015508ddLL * zoe3), 30);
887 	zoc5 = Z_RSHIFT((0x051d29e5LL * zoo1) + (-0x028e7647LL * zoo2) +
888 	    (0x0082d81aLL * zoo3), 30);
889 
890 	coeff = Z_RSHIFT((Z_RSHIFT((Z_RSHIFT((Z_RSHIFT((Z_RSHIFT(
891 	    (int64_t)zoc5 * zoz, Z_SHIFT) +
892 	    zoc4) * zoz, Z_SHIFT) + zoc3) * zoz, Z_SHIFT) +
893 	    zoc2) * zoz, Z_SHIFT) + zoc1) * zoz, Z_SHIFT) + zoc0;
894 #elif defined(Z_COEFF_INTERP_OPT16X)
895 	int32_t zoz, zoe1, zoe2, zoe3, zoo1, zoo2, zoo3;
896 	int32_t zoc0, zoc1, zoc2, zoc3, zoc4, zoc5;
897 
898 	/* 6-point, 5th-order Optimal 16x */
899 	zoz = z - (Z_ONE >> 1);
900 	zoe1 = z_coeff[1] + z_coeff[0];
901 	zoe2 = z_coeff[2] + z_coeff[-1];
902 	zoe3 = z_coeff[3] + z_coeff[-2];
903 	zoo1 = z_coeff[1] - z_coeff[0];
904 	zoo2 = z_coeff[2] - z_coeff[-1];
905 	zoo3 = z_coeff[3] - z_coeff[-2];
906 
907 	zoc0 = Z_RSHIFT((0x1ac2260dLL * zoe1) + (0x0526cdcaLL * zoe2) +
908 	    (0x00170c29LL * zoe3), 30);
909 	zoc1 = Z_RSHIFT((0x14f8a49aLL * zoo1) + (0x0d6d1109LL * zoo2) +
910 	    (0x008cd4dcLL * zoo3), 30);
911 	zoc2 = Z_RSHIFT((-0x0d3e94a4LL * zoe1) + (0x0bddded4LL * zoe2) +
912 	    (0x0160b5d0LL * zoe3), 30);
913 	zoc3 = Z_RSHIFT((-0x0de10cc4LL * zoo1) + (0x019b2a7dLL * zoo2) +
914 	    (0x01cfe914LL * zoo3), 30);
915 	zoc4 = Z_RSHIFT((0x02aa12d7LL * zoe1) + (-0x03ff1bb3LL * zoe2) +
916 	    (0x015508ddLL * zoe3), 30);
917 	zoc5 = Z_RSHIFT((0x051d29e5LL * zoo1) + (-0x028e7647LL * zoo2) +
918 	    (0x0082d81aLL * zoo3), 30);
919 
920 	coeff = Z_RSHIFT((Z_RSHIFT((Z_RSHIFT((Z_RSHIFT((Z_RSHIFT(
921 	    (int64_t)zoc5 * zoz, Z_SHIFT) +
922 	    zoc4) * zoz, Z_SHIFT) + zoc3) * zoz, Z_SHIFT) +
923 	    zoc2) * zoz, Z_SHIFT) + zoc1) * zoz, Z_SHIFT) + zoc0;
924 #elif defined(Z_COEFF_INTERP_OPT8X)
925 	int32_t zoz, zoe1, zoe2, zoe3, zoo1, zoo2, zoo3;
926 	int32_t zoc0, zoc1, zoc2, zoc3, zoc4, zoc5;
927 
928 	/* 6-point, 5th-order Optimal 8x */
929 	zoz = z - (Z_ONE >> 1);
930 	zoe1 = z_coeff[1] + z_coeff[0];
931 	zoe2 = z_coeff[2] + z_coeff[-1];
932 	zoe3 = z_coeff[3] + z_coeff[-2];
933 	zoo1 = z_coeff[1] - z_coeff[0];
934 	zoo2 = z_coeff[2] - z_coeff[-1];
935 	zoo3 = z_coeff[3] - z_coeff[-2];
936 
937 	zoc0 = Z_RSHIFT((0x1aa9b47dLL * zoe1) + (0x053d9944LL * zoe2) +
938 	    (0x0018b23fLL * zoe3), 30);
939 	zoc1 = Z_RSHIFT((0x14a104d1LL * zoo1) + (0x0d7d2504LL * zoo2) +
940 	    (0x0094b599LL * zoo3), 30);
941 	zoc2 = Z_RSHIFT((-0x0d22530bLL * zoe1) + (0x0bb37a2cLL * zoe2) +
942 	    (0x016ed8e0LL * zoe3), 30);
943 	zoc3 = Z_RSHIFT((-0x0d744b1cLL * zoo1) + (0x01649591LL * zoo2) +
944 	    (0x01dae93aLL * zoo3), 30);
945 	zoc4 = Z_RSHIFT((0x02a7ee1bLL * zoe1) + (-0x03fbdb24LL * zoe2) +
946 	    (0x0153ed07LL * zoe3), 30);
947 	zoc5 = Z_RSHIFT((0x04cf9b6cLL * zoo1) + (-0x0266b378LL * zoo2) +
948 	    (0x007a7c26LL * zoo3), 30);
949 
950 	coeff = Z_RSHIFT((Z_RSHIFT((Z_RSHIFT((Z_RSHIFT((Z_RSHIFT(
951 	    (int64_t)zoc5 * zoz, Z_SHIFT) +
952 	    zoc4) * zoz, Z_SHIFT) + zoc3) * zoz, Z_SHIFT) +
953 	    zoc2) * zoz, Z_SHIFT) + zoc1) * zoz, Z_SHIFT) + zoc0;
954 #elif defined(Z_COEFF_INTERP_OPT4X)
955 	int32_t zoz, zoe1, zoe2, zoe3, zoo1, zoo2, zoo3;
956 	int32_t zoc0, zoc1, zoc2, zoc3, zoc4, zoc5;
957 
958 	/* 6-point, 5th-order Optimal 4x */
959 	zoz = z - (Z_ONE >> 1);
960 	zoe1 = z_coeff[1] + z_coeff[0];
961 	zoe2 = z_coeff[2] + z_coeff[-1];
962 	zoe3 = z_coeff[3] + z_coeff[-2];
963 	zoo1 = z_coeff[1] - z_coeff[0];
964 	zoo2 = z_coeff[2] - z_coeff[-1];
965 	zoo3 = z_coeff[3] - z_coeff[-2];
966 
967 	zoc0 = Z_RSHIFT((0x1a8eda43LL * zoe1) + (0x0556ee38LL * zoe2) +
968 	    (0x001a3784LL * zoe3), 30);
969 	zoc1 = Z_RSHIFT((0x143d863eLL * zoo1) + (0x0d910e36LL * zoo2) +
970 	    (0x009ca889LL * zoo3), 30);
971 	zoc2 = Z_RSHIFT((-0x0d026821LL * zoe1) + (0x0b837773LL * zoe2) +
972 	    (0x017ef0c6LL * zoe3), 30);
973 	zoc3 = Z_RSHIFT((-0x0cef1502LL * zoo1) + (0x01207a8eLL * zoo2) +
974 	    (0x01e936dbLL * zoo3), 30);
975 	zoc4 = Z_RSHIFT((0x029fe643LL * zoe1) + (-0x03ef3fc8LL * zoe2) +
976 	    (0x014f5923LL * zoe3), 30);
977 	zoc5 = Z_RSHIFT((0x043a9d08LL * zoo1) + (-0x02154febLL * zoo2) +
978 	    (0x00670dbdLL * zoo3), 30);
979 
980 	coeff = Z_RSHIFT((Z_RSHIFT((Z_RSHIFT((Z_RSHIFT((Z_RSHIFT(
981 	    (int64_t)zoc5 * zoz, Z_SHIFT) +
982 	    zoc4) * zoz, Z_SHIFT) + zoc3) * zoz, Z_SHIFT) +
983 	    zoc2) * zoz, Z_SHIFT) + zoc1) * zoz, Z_SHIFT) + zoc0;
984 #elif defined(Z_COEFF_INTERP_OPT2X)
985 	int32_t zoz, zoe1, zoe2, zoe3, zoo1, zoo2, zoo3;
986 	int32_t zoc0, zoc1, zoc2, zoc3, zoc4, zoc5;
987 
988 	/* 6-point, 5th-order Optimal 2x */
989 	zoz = z - (Z_ONE >> 1);
990 	zoe1 = z_coeff[1] + z_coeff[0];
991 	zoe2 = z_coeff[2] + z_coeff[-1];
992 	zoe3 = z_coeff[3] + z_coeff[-2];
993 	zoo1 = z_coeff[1] - z_coeff[0];
994 	zoo2 = z_coeff[2] - z_coeff[-1];
995 	zoo3 = z_coeff[3] - z_coeff[-2];
996 
997 	zoc0 = Z_RSHIFT((0x19edb6fdLL * zoe1) + (0x05ebd062LL * zoe2) +
998 	    (0x00267881LL * zoe3), 30);
999 	zoc1 = Z_RSHIFT((0x1223af76LL * zoo1) + (0x0de3dd6bLL * zoo2) +
1000 	    (0x00d683cdLL * zoo3), 30);
1001 	zoc2 = Z_RSHIFT((-0x0c3ee068LL * zoe1) + (0x0a5c3769LL * zoe2) +
1002 	    (0x01e2aceaLL * zoe3), 30);
1003 	zoc3 = Z_RSHIFT((-0x0a8ab614LL * zoo1) + (-0x0019522eLL * zoo2) +
1004 	    (0x022cefc7LL * zoo3), 30);
1005 	zoc4 = Z_RSHIFT((0x0276187dLL * zoe1) + (-0x03a801e8LL * zoe2) +
1006 	    (0x0131d935LL * zoe3), 30);
1007 	zoc5 = Z_RSHIFT((0x02c373f5LL * zoo1) + (-0x01275f83LL * zoo2) +
1008 	    (0x0018ee79LL * zoo3), 30);
1009 
1010 	coeff = Z_RSHIFT((Z_RSHIFT((Z_RSHIFT((Z_RSHIFT((Z_RSHIFT(
1011 	    (int64_t)zoc5 * zoz, Z_SHIFT) +
1012 	    zoc4) * zoz, Z_SHIFT) + zoc3) * zoz, Z_SHIFT) +
1013 	    zoc2) * zoz, Z_SHIFT) + zoc1) * zoz, Z_SHIFT) + zoc0;
1014 #else
1015 #error "Interpolation type screwed!"
1016 #endif
1017 
1018 #if Z_POLYPHASE_COEFF_SHIFT > 0
1019 	coeff = Z_RSHIFT(coeff, Z_POLYPHASE_COEFF_SHIFT);
1020 #endif
1021 	return (coeff);
1022 }
1023 
1024 static int
z_resampler_build_polyphase(struct z_info * info)1025 z_resampler_build_polyphase(struct z_info *info)
1026 {
1027 	int32_t alpha, c, i, z, idx;
1028 
1029 	/* Let this be here first. */
1030 	free(info->z_pcoeff, M_DEVBUF);
1031 	info->z_pcoeff = NULL;
1032 
1033 	if (feeder_rate_polyphase_max < 1)
1034 		return (ENOTSUP);
1035 
1036 	if (((int64_t)info->z_size * info->z_gy * 2) >
1037 	    feeder_rate_polyphase_max) {
1038 #ifndef _KERNEL
1039 		fprintf(stderr, "Polyphase entries exceed: [%d/%d] %jd > %d\n",
1040 		    info->z_gx, info->z_gy,
1041 		    (intmax_t)info->z_size * info->z_gy * 2,
1042 		    feeder_rate_polyphase_max);
1043 #endif
1044 		return (E2BIG);
1045 	}
1046 
1047 	info->z_pcoeff = malloc(sizeof(int32_t) *
1048 	    info->z_size * info->z_gy * 2, M_DEVBUF, M_NOWAIT | M_ZERO);
1049 	if (info->z_pcoeff == NULL)
1050 		return (ENOMEM);
1051 
1052 	for (alpha = 0; alpha < info->z_gy; alpha++) {
1053 		z = alpha * info->z_dx;
1054 		c = 0;
1055 		for (i = info->z_size; i != 0; i--) {
1056 			c += z >> Z_SHIFT;
1057 			z &= Z_MASK;
1058 			idx = (alpha * info->z_size * 2) +
1059 			    (info->z_size * 2) - i;
1060 			info->z_pcoeff[idx] =
1061 			    z_coeff_interpolate(z, info->z_coeff + c);
1062 			z += info->z_dy;
1063 		}
1064 		z = info->z_dy - (alpha * info->z_dx);
1065 		c = 0;
1066 		for (i = info->z_size; i != 0; i--) {
1067 			c += z >> Z_SHIFT;
1068 			z &= Z_MASK;
1069 			idx = (alpha * info->z_size * 2) + i - 1;
1070 			info->z_pcoeff[idx] =
1071 			    z_coeff_interpolate(z, info->z_coeff + c);
1072 			z += info->z_dy;
1073 		}
1074 	}
1075 
1076 #ifndef _KERNEL
1077 	fprintf(stderr, "Polyphase: [%d/%d] %d entries\n",
1078 	    info->z_gx, info->z_gy, info->z_size * info->z_gy * 2);
1079 #endif
1080 
1081 	return (0);
1082 }
1083 
1084 static int
z_resampler_setup(struct pcm_feeder * f)1085 z_resampler_setup(struct pcm_feeder *f)
1086 {
1087 	struct z_info *info;
1088 	int64_t gy2gx_max, gx2gy_max;
1089 	uint32_t format;
1090 	int32_t align, i, z_scale;
1091 	int adaptive;
1092 
1093 	info = f->data;
1094 	z_resampler_reset(info);
1095 
1096 	if (info->src == info->dst)
1097 		return (0);
1098 
1099 	/* Shrink by greatest common divisor. */
1100 	i = z_gcd(info->src, info->dst);
1101 	info->z_gx = info->src / i;
1102 	info->z_gy = info->dst / i;
1103 
1104 	/* Too big, or too small. Bail out. */
1105 	if (!(Z_FACTOR_SAFE(info->z_gx) && Z_FACTOR_SAFE(info->z_gy)))
1106 		return (EINVAL);
1107 
1108 	format = f->desc.in;
1109 	adaptive = 0;
1110 	z_scale = 0;
1111 
1112 	/*
1113 	 * Setup everything: filter length, conversion factor, etc.
1114 	 */
1115 	if (Z_IS_SINC(info)) {
1116 		/*
1117 		 * Downsampling, or upsampling scaling factor. As long as the
1118 		 * factor can be represented by a fraction of 1 << Z_SHIFT,
1119 		 * we're pretty much in business. Scaling is not needed for
1120 		 * upsampling, so we just slap Z_ONE there.
1121 		 */
1122 		if (info->z_gx > info->z_gy)
1123 			/*
1124 			 * If the downsampling ratio is beyond sanity,
1125 			 * enable semi-adaptive mode. Although handling
1126 			 * extreme ratio is possible, the result of the
1127 			 * conversion is just pointless, unworthy,
1128 			 * nonsensical noises, etc.
1129 			 */
1130 			if ((info->z_gx / info->z_gy) > Z_SINC_DOWNMAX)
1131 				z_scale = Z_ONE / Z_SINC_DOWNMAX;
1132 			else
1133 				z_scale = ((uint64_t)info->z_gy << Z_SHIFT) /
1134 				    info->z_gx;
1135 		else
1136 			z_scale = Z_ONE;
1137 
1138 		/*
1139 		 * This is actually impossible, unless anything above
1140 		 * overflow.
1141 		 */
1142 		if (z_scale < 1)
1143 			return (E2BIG);
1144 
1145 		/*
1146 		 * Calculate sample time/coefficients index drift. It is
1147 		 * a constant for upsampling, but downsampling require
1148 		 * heavy duty filtering with possible too long filters.
1149 		 * If anything goes wrong, revisit again and enable
1150 		 * adaptive mode.
1151 		 */
1152 z_setup_adaptive_sinc:
1153 		free(info->z_pcoeff, M_DEVBUF);
1154 		info->z_pcoeff = NULL;
1155 
1156 		if (adaptive == 0) {
1157 			info->z_dy = z_scale << Z_DRIFT_SHIFT;
1158 			if (info->z_dy < 1)
1159 				return (E2BIG);
1160 			info->z_scale = z_scale;
1161 		} else {
1162 			info->z_dy = Z_FULL_ONE;
1163 			info->z_scale = Z_ONE;
1164 		}
1165 
1166 		/* Smallest drift increment. */
1167 		info->z_dx = info->z_dy / info->z_gy;
1168 
1169 		/*
1170 		 * Overflow or underflow. Try adaptive, let it continue and
1171 		 * retry.
1172 		 */
1173 		if (info->z_dx < 1) {
1174 			if (adaptive == 0) {
1175 				adaptive = 1;
1176 				goto z_setup_adaptive_sinc;
1177 			}
1178 			return (E2BIG);
1179 		}
1180 
1181 		/*
1182 		 * Round back output drift.
1183 		 */
1184 		info->z_dy = info->z_dx * info->z_gy;
1185 
1186 		for (i = 0; i < Z_COEFF_TAB_SIZE; i++) {
1187 			if (Z_SINC_COEFF_IDX(info) != i)
1188 				continue;
1189 			/*
1190 			 * Calculate required filter length and guard
1191 			 * against possible abusive result. Note that
1192 			 * this represents only 1/2 of the entire filter
1193 			 * length.
1194 			 */
1195 			info->z_size = z_resampler_sinc_len(info);
1196 
1197 			/*
1198 			 * Multiple of 2 rounding, for better accumulator
1199 			 * performance.
1200 			 */
1201 			info->z_size &= ~1;
1202 
1203 			if (info->z_size < 2 || info->z_size > Z_SINC_MAX) {
1204 				if (adaptive == 0) {
1205 					adaptive = 1;
1206 					goto z_setup_adaptive_sinc;
1207 				}
1208 				return (E2BIG);
1209 			}
1210 			info->z_coeff = z_coeff_tab[i].coeff + Z_COEFF_OFFSET;
1211 			info->z_dcoeff = z_coeff_tab[i].dcoeff;
1212 			break;
1213 		}
1214 
1215 		if (info->z_coeff == NULL || info->z_dcoeff == NULL)
1216 			return (EINVAL);
1217 	} else if (Z_IS_LINEAR(info)) {
1218 		/*
1219 		 * Don't put much effort if we're doing linear interpolation.
1220 		 * Just center the interpolation distance within Z_LINEAR_ONE,
1221 		 * and be happy about it.
1222 		 */
1223 		info->z_dx = Z_LINEAR_FULL_ONE / info->z_gy;
1224 	}
1225 
1226 	/*
1227 	 * We're safe for now, lets continue.. Look for our resampler
1228 	 * depending on configured format and quality.
1229 	 */
1230 	for (i = 0; i < Z_RESAMPLER_TAB_SIZE; i++) {
1231 		int ridx;
1232 
1233 		if (AFMT_ENCODING(format) != z_resampler_tab[i].format)
1234 			continue;
1235 		if (Z_IS_SINC(info) && adaptive == 0 &&
1236 		    z_resampler_build_polyphase(info) == 0)
1237 			ridx = Z_RESAMPLER_SINC_POLYPHASE;
1238 		else
1239 			ridx = Z_RESAMPLER_IDX(info);
1240 		info->z_resample = z_resampler_tab[i].resampler[ridx];
1241 		break;
1242 	}
1243 
1244 	if (info->z_resample == NULL)
1245 		return (EINVAL);
1246 
1247 	info->bps = AFMT_BPS(format);
1248 	align = info->channels * info->bps;
1249 
1250 	/*
1251 	 * Calculate largest value that can be fed into z_gy2gx() and
1252 	 * z_gx2gy() without causing (signed) 32bit overflow. z_gy2gx() will
1253 	 * be called early during feeding process to determine how much input
1254 	 * samples that is required to generate requested output, while
1255 	 * z_gx2gy() will be called just before samples filtering /
1256 	 * accumulation process based on available samples that has been
1257 	 * calculated using z_gx2gy().
1258 	 *
1259 	 * Now that is damn confusing, I guess ;-) .
1260 	 */
1261 	gy2gx_max = (((uint64_t)info->z_gy * INT32_MAX) - info->z_gy + 1) /
1262 	    info->z_gx;
1263 
1264 	if ((gy2gx_max * align) > SND_FXDIV_MAX)
1265 		gy2gx_max = SND_FXDIV_MAX / align;
1266 
1267 	if (gy2gx_max < 1)
1268 		return (E2BIG);
1269 
1270 	gx2gy_max = (((uint64_t)info->z_gx * INT32_MAX) - info->z_gy) /
1271 	    info->z_gy;
1272 
1273 	if (gx2gy_max > INT32_MAX)
1274 		gx2gy_max = INT32_MAX;
1275 
1276 	if (gx2gy_max < 1)
1277 		return (E2BIG);
1278 
1279 	/*
1280 	 * Ensure that z_gy2gx() at its largest possible calculated value
1281 	 * (alpha = 0) will not cause overflow further late during z_gx2gy()
1282 	 * stage.
1283 	 */
1284 	if (z_gy2gx(info, gy2gx_max) > _Z_GCAST(gx2gy_max))
1285 		return (E2BIG);
1286 
1287 	info->z_maxfeed = gy2gx_max * align;
1288 
1289 #ifdef Z_USE_ALPHADRIFT
1290 	info->z_startdrift = z_gy2gx(info, 1);
1291 	info->z_alphadrift = z_drift(info, info->z_startdrift, 1);
1292 #endif
1293 
1294 	i = z_gy2gx(info, 1);
1295 	info->z_full = z_roundpow2((info->z_size << 1) + i);
1296 
1297 	/*
1298 	 * Too big to be true, and overflowing left and right like mad ..
1299 	 */
1300 	if ((info->z_full * align) < 1) {
1301 		if (adaptive == 0 && Z_IS_SINC(info)) {
1302 			adaptive = 1;
1303 			goto z_setup_adaptive_sinc;
1304 		}
1305 		return (E2BIG);
1306 	}
1307 
1308 	/*
1309 	 * Increase full buffer size if its too small to reduce cyclic
1310 	 * buffer shifting in main conversion/feeder loop.
1311 	 */
1312 	while (info->z_full < Z_RESERVOIR_MAX &&
1313 	    (info->z_full - (info->z_size << 1)) < Z_RESERVOIR)
1314 		info->z_full <<= 1;
1315 
1316 	/* Initialize buffer position. */
1317 	info->z_mask = info->z_full - 1;
1318 	info->z_start = z_prev(info, info->z_size << 1, 1);
1319 	info->z_pos = z_next(info, info->z_start, 1);
1320 
1321 	/*
1322 	 * Allocate or reuse delay line buffer, whichever makes sense.
1323 	 */
1324 	i = info->z_full * align;
1325 	if (i < 1)
1326 		return (E2BIG);
1327 
1328 	if (info->z_delay == NULL || info->z_alloc < i ||
1329 	    i <= (info->z_alloc >> 1)) {
1330 		free(info->z_delay, M_DEVBUF);
1331 		info->z_delay = malloc(i, M_DEVBUF, M_NOWAIT | M_ZERO);
1332 		if (info->z_delay == NULL)
1333 			return (ENOMEM);
1334 		info->z_alloc = i;
1335 	}
1336 
1337 	/*
1338 	 * Zero out head of buffer to avoid pops and clicks.
1339 	 */
1340 	memset(info->z_delay, sndbuf_zerodata(f->desc.out),
1341 	    info->z_pos * align);
1342 
1343 #ifdef Z_DIAGNOSTIC
1344 	/*
1345 	 * XXX Debuging mess !@#$%^
1346 	 */
1347 #define dumpz(x)	fprintf(stderr, "\t%12s = %10u : %-11d\n",	\
1348 			    "z_"__STRING(x), (uint32_t)info->z_##x,	\
1349 			    (int32_t)info->z_##x)
1350 	fprintf(stderr, "\n%s():\n", __func__);
1351 	fprintf(stderr, "\tchannels=%d, bps=%d, format=0x%08x, quality=%d\n",
1352 	    info->channels, info->bps, format, info->quality);
1353 	fprintf(stderr, "\t%d (%d) -> %d (%d), ",
1354 	    info->src, info->rsrc, info->dst, info->rdst);
1355 	fprintf(stderr, "[%d/%d]\n", info->z_gx, info->z_gy);
1356 	fprintf(stderr, "\tminreq=%d, ", z_gy2gx(info, 1));
1357 	if (adaptive != 0)
1358 		z_scale = Z_ONE;
1359 	fprintf(stderr, "factor=0x%08x/0x%08x (%f)\n",
1360 	    z_scale, Z_ONE, (double)z_scale / Z_ONE);
1361 	fprintf(stderr, "\tbase_length=%d, ", Z_SINC_BASE_LEN(info));
1362 	fprintf(stderr, "adaptive=%s\n", (adaptive != 0) ? "YES" : "NO");
1363 	dumpz(size);
1364 	dumpz(alloc);
1365 	if (info->z_alloc < 1024)
1366 		fprintf(stderr, "\t%15s%10d Bytes\n",
1367 		    "", info->z_alloc);
1368 	else if (info->z_alloc < (1024 << 10))
1369 		fprintf(stderr, "\t%15s%10d KBytes\n",
1370 		    "", info->z_alloc >> 10);
1371 	else if (info->z_alloc < (1024 << 20))
1372 		fprintf(stderr, "\t%15s%10d MBytes\n",
1373 		    "", info->z_alloc >> 20);
1374 	else
1375 		fprintf(stderr, "\t%15s%10d GBytes\n",
1376 		    "", info->z_alloc >> 30);
1377 	fprintf(stderr, "\t%12s   %10d (min output samples)\n",
1378 	    "",
1379 	    (int32_t)z_gx2gy(info, info->z_full - (info->z_size << 1)));
1380 	fprintf(stderr, "\t%12s   %10d (min allocated output samples)\n",
1381 	    "",
1382 	    (int32_t)z_gx2gy(info, (info->z_alloc / align) -
1383 	    (info->z_size << 1)));
1384 	fprintf(stderr, "\t%12s = %10d\n",
1385 	    "z_gy2gx()", (int32_t)z_gy2gx(info, 1));
1386 	fprintf(stderr, "\t%12s = %10d -> z_gy2gx() -> %d\n",
1387 	    "Max", (int32_t)gy2gx_max, (int32_t)z_gy2gx(info, gy2gx_max));
1388 	fprintf(stderr, "\t%12s = %10d\n",
1389 	    "z_gx2gy()", (int32_t)z_gx2gy(info, 1));
1390 	fprintf(stderr, "\t%12s = %10d -> z_gx2gy() -> %d\n",
1391 	    "Max", (int32_t)gx2gy_max, (int32_t)z_gx2gy(info, gx2gy_max));
1392 	dumpz(maxfeed);
1393 	dumpz(full);
1394 	dumpz(start);
1395 	dumpz(pos);
1396 	dumpz(scale);
1397 	fprintf(stderr, "\t%12s   %10f\n", "",
1398 	    (double)info->z_scale / Z_ONE);
1399 	dumpz(dx);
1400 	fprintf(stderr, "\t%12s   %10f\n", "",
1401 	    (double)info->z_dx / info->z_dy);
1402 	dumpz(dy);
1403 	fprintf(stderr, "\t%12s   %10d (drift step)\n", "",
1404 	    info->z_dy >> Z_SHIFT);
1405 	fprintf(stderr, "\t%12s   %10d (scaling differences)\n", "",
1406 	    (z_scale << Z_DRIFT_SHIFT) - info->z_dy);
1407 	fprintf(stderr, "\t%12s = %u bytes\n",
1408 	    "intpcm32_t", sizeof(intpcm32_t));
1409 	fprintf(stderr, "\t%12s = 0x%08x, smallest=%.16lf\n",
1410 	    "Z_ONE", Z_ONE, (double)1.0 / (double)Z_ONE);
1411 #endif
1412 
1413 	return (0);
1414 }
1415 
1416 static int
z_resampler_set(struct pcm_feeder * f,int what,int32_t value)1417 z_resampler_set(struct pcm_feeder *f, int what, int32_t value)
1418 {
1419 	struct z_info *info;
1420 	int32_t oquality;
1421 
1422 	info = f->data;
1423 
1424 	switch (what) {
1425 	case Z_RATE_SRC:
1426 		if (value < feeder_rate_min || value > feeder_rate_max)
1427 			return (E2BIG);
1428 		if (value == info->rsrc)
1429 			return (0);
1430 		info->rsrc = value;
1431 		break;
1432 	case Z_RATE_DST:
1433 		if (value < feeder_rate_min || value > feeder_rate_max)
1434 			return (E2BIG);
1435 		if (value == info->rdst)
1436 			return (0);
1437 		info->rdst = value;
1438 		break;
1439 	case Z_RATE_QUALITY:
1440 		if (value < Z_QUALITY_MIN || value > Z_QUALITY_MAX)
1441 			return (EINVAL);
1442 		if (value == info->quality)
1443 			return (0);
1444 		/*
1445 		 * If we failed to set the requested quality, restore
1446 		 * the old one. We cannot afford leaving it broken since
1447 		 * passive feeder chains like vchans never reinitialize
1448 		 * itself.
1449 		 */
1450 		oquality = info->quality;
1451 		info->quality = value;
1452 		if (z_resampler_setup(f) == 0)
1453 			return (0);
1454 		info->quality = oquality;
1455 		break;
1456 	case Z_RATE_CHANNELS:
1457 		if (value < SND_CHN_MIN || value > SND_CHN_MAX)
1458 			return (EINVAL);
1459 		if (value == info->channels)
1460 			return (0);
1461 		info->channels = value;
1462 		break;
1463 	default:
1464 		return (EINVAL);
1465 	}
1466 
1467 	return (z_resampler_setup(f));
1468 }
1469 
1470 static int
z_resampler_get(struct pcm_feeder * f,int what)1471 z_resampler_get(struct pcm_feeder *f, int what)
1472 {
1473 	struct z_info *info;
1474 
1475 	info = f->data;
1476 
1477 	switch (what) {
1478 	case Z_RATE_SRC:
1479 		return (info->rsrc);
1480 	case Z_RATE_DST:
1481 		return (info->rdst);
1482 	case Z_RATE_QUALITY:
1483 		return (info->quality);
1484 	case Z_RATE_CHANNELS:
1485 		return (info->channels);
1486 	}
1487 
1488 	return (-1);
1489 }
1490 
1491 static int
z_resampler_init(struct pcm_feeder * f)1492 z_resampler_init(struct pcm_feeder *f)
1493 {
1494 	struct z_info *info;
1495 	int ret;
1496 
1497 	if (f->desc.in != f->desc.out)
1498 		return (EINVAL);
1499 
1500 	info = malloc(sizeof(*info), M_DEVBUF, M_NOWAIT | M_ZERO);
1501 	if (info == NULL)
1502 		return (ENOMEM);
1503 
1504 	info->rsrc = Z_RATE_DEFAULT;
1505 	info->rdst = Z_RATE_DEFAULT;
1506 	info->quality = feeder_rate_quality;
1507 	info->channels = AFMT_CHANNEL(f->desc.in);
1508 
1509 	f->data = info;
1510 
1511 	ret = z_resampler_setup(f);
1512 	if (ret != 0) {
1513 		free(info->z_pcoeff, M_DEVBUF);
1514 		free(info->z_delay, M_DEVBUF);
1515 		free(info, M_DEVBUF);
1516 		f->data = NULL;
1517 	}
1518 
1519 	return (ret);
1520 }
1521 
1522 static int
z_resampler_free(struct pcm_feeder * f)1523 z_resampler_free(struct pcm_feeder *f)
1524 {
1525 	struct z_info *info;
1526 
1527 	info = f->data;
1528 	free(info->z_pcoeff, M_DEVBUF);
1529 	free(info->z_delay, M_DEVBUF);
1530 	free(info, M_DEVBUF);
1531 
1532 	f->data = NULL;
1533 
1534 	return (0);
1535 }
1536 
1537 static uint32_t
z_resampler_feed_internal(struct pcm_feeder * f,struct pcm_channel * c,uint8_t * b,uint32_t count,void * source)1538 z_resampler_feed_internal(struct pcm_feeder *f, struct pcm_channel *c,
1539     uint8_t *b, uint32_t count, void *source)
1540 {
1541 	struct z_info *info;
1542 	int32_t alphadrift, startdrift, reqout, ocount, reqin, align;
1543 	int32_t fetch, fetched, start, cp;
1544 	uint8_t *dst;
1545 
1546 	info = f->data;
1547 	if (info->z_resample == NULL)
1548 		return (z_feed(f->source, c, b, count, source));
1549 
1550 	/*
1551 	 * Calculate sample size alignment and amount of sample output.
1552 	 * We will do everything in sample domain, but at the end we
1553 	 * will jump back to byte domain.
1554 	 */
1555 	align = info->channels * info->bps;
1556 	ocount = SND_FXDIV(count, align);
1557 	if (ocount == 0)
1558 		return (0);
1559 
1560 	/*
1561 	 * Calculate amount of input samples that is needed to generate
1562 	 * exact amount of output.
1563 	 */
1564 	reqin = z_gy2gx(info, ocount) - z_fetched(info);
1565 
1566 #ifdef Z_USE_ALPHADRIFT
1567 	startdrift = info->z_startdrift;
1568 	alphadrift = info->z_alphadrift;
1569 #else
1570 	startdrift = _Z_GY2GX(info, 0, 1);
1571 	alphadrift = z_drift(info, startdrift, 1);
1572 #endif
1573 
1574 	dst = b;
1575 
1576 	do {
1577 		if (reqin != 0) {
1578 			fetch = z_min(z_free(info), reqin);
1579 			if (fetch == 0) {
1580 				/*
1581 				 * No more free spaces, so wind enough
1582 				 * samples back to the head of delay line
1583 				 * in byte domain.
1584 				 */
1585 				fetched = z_fetched(info);
1586 				start = z_prev(info, info->z_start,
1587 				    (info->z_size << 1) - 1);
1588 				cp = (info->z_size << 1) + fetched;
1589 				z_copy(info->z_delay + (start * align),
1590 				    info->z_delay, cp * align);
1591 				info->z_start =
1592 				    z_prev(info, info->z_size << 1, 1);
1593 				info->z_pos =
1594 				    z_next(info, info->z_start, fetched + 1);
1595 				fetch = z_min(z_free(info), reqin);
1596 #ifdef Z_DIAGNOSTIC
1597 				if (1) {
1598 					static uint32_t kk = 0;
1599 					fprintf(stderr,
1600 					    "Buffer Move: "
1601 					    "start=%d fetched=%d cp=%d "
1602 					    "cycle=%u [%u]\r",
1603 					    start, fetched, cp, info->z_cycle,
1604 					    ++kk);
1605 				}
1606 				info->z_cycle = 0;
1607 #endif
1608 			}
1609 			if (fetch != 0) {
1610 				/*
1611 				 * Fetch in byte domain and jump back
1612 				 * to sample domain.
1613 				 */
1614 				fetched = SND_FXDIV(z_feed(f->source, c,
1615 				    info->z_delay + (info->z_pos * align),
1616 				    fetch * align, source), align);
1617 				/*
1618 				 * Prepare to convert fetched buffer,
1619 				 * or mark us done if we cannot fulfill
1620 				 * the request.
1621 				 */
1622 				reqin -= fetched;
1623 				info->z_pos += fetched;
1624 				if (fetched != fetch)
1625 					reqin = 0;
1626 			}
1627 		}
1628 
1629 		reqout = z_min(z_gx2gy(info, z_fetched(info)), ocount);
1630 		if (reqout != 0) {
1631 			ocount -= reqout;
1632 
1633 			/*
1634 			 * Drift.. drift.. drift..
1635 			 *
1636 			 * Notice that there are 2 methods of doing the drift
1637 			 * operations: The former is much cleaner (in a sense
1638 			 * of mathematical readings of my eyes), but slower
1639 			 * due to integer division in z_gy2gx(). Nevertheless,
1640 			 * both should give the same exact accurate drifting
1641 			 * results, so the later is favourable.
1642 			 */
1643 			do {
1644 				info->z_resample(info, dst);
1645 				info->z_alpha += alphadrift;
1646 				if (info->z_alpha < info->z_gy)
1647 					info->z_start += startdrift;
1648 				else {
1649 					info->z_start += startdrift - 1;
1650 					info->z_alpha -= info->z_gy;
1651 				}
1652 				dst += align;
1653 #ifdef Z_DIAGNOSTIC
1654 				info->z_cycle++;
1655 #endif
1656 			} while (--reqout != 0);
1657 		}
1658 	} while (reqin != 0 && ocount != 0);
1659 
1660 	/*
1661 	 * Back to byte domain..
1662 	 */
1663 	return (dst - b);
1664 }
1665 
1666 static int
z_resampler_feed(struct pcm_feeder * f,struct pcm_channel * c,uint8_t * b,uint32_t count,void * source)1667 z_resampler_feed(struct pcm_feeder *f, struct pcm_channel *c, uint8_t *b,
1668     uint32_t count, void *source)
1669 {
1670 	uint32_t feed, maxfeed, left;
1671 
1672 	/*
1673 	 * Split count to smaller chunks to avoid possible 32bit overflow.
1674 	 */
1675 	maxfeed = ((struct z_info *)(f->data))->z_maxfeed;
1676 	left = count;
1677 
1678 	do {
1679 		feed = z_resampler_feed_internal(f, c, b,
1680 		    z_min(maxfeed, left), source);
1681 		b += feed;
1682 		left -= feed;
1683 	} while (left != 0 && feed != 0);
1684 
1685 	return (count - left);
1686 }
1687 
1688 static kobj_method_t feeder_rate_methods[] = {
1689 	KOBJMETHOD(feeder_init,		z_resampler_init),
1690 	KOBJMETHOD(feeder_free,		z_resampler_free),
1691 	KOBJMETHOD(feeder_set,		z_resampler_set),
1692 	KOBJMETHOD(feeder_get,		z_resampler_get),
1693 	KOBJMETHOD(feeder_feed,		z_resampler_feed),
1694 	KOBJMETHOD_END
1695 };
1696 
1697 FEEDER_DECLARE(feeder_rate, FEEDER_RATE);
1698