2 * This file is part of DisOrder
3 * Copyright (C) 2007 Richard Kettlewell
5 * This program is free software; you can redistribute it and/or modify
6 * it under the terms of the GNU General Public License as published by
7 * the Free Software Foundation; either version 2 of the License, or
8 * (at your option) any later version.
10 * This program is distributed in the hope that it will be useful, but
11 * WITHOUT ANY WARRANTY; without even the implied warranty of
12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
13 * General Public License for more details.
15 * You should have received a copy of the GNU General Public License
16 * along with this program; if not, write to the Free Software
17 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307
20 /** @file server/disorder-normalize.c
21 * @brief Convert "raw" format output to the configured format
23 * Currently we invoke sox even for trivial conversions such as byte-swapping.
24 * Ideally we would do all conversion including resampling in this one process
25 * and eliminate the dependency on sox.
36 #include <sys/types.h>
41 #include "configuration.h"
42 #include "speaker-protocol.h"
44 /** @brief Copy bytes from one file descriptor to another
45 * @param infd File descriptor read from
46 * @param outfd File descriptor to write to
47 * @param n Number of bytes to copy
49 static void copy(int infd, int outfd, size_t n) {
50 char buffer[4096], *ptr;
54 r = read(infd, buffer, sizeof buffer);
59 fatal(errno, "read error");
62 fatal(0, "unexpected EOF");
66 w = write(outfd, ptr, r - (ptr - buffer));
68 fatal(errno, "write error");
74 static void soxargs(const char ***pp, char **qq,
75 const struct stream_header *header) {
78 *qq += sprintf((char *)(*(*pp)++ = *qq), "-r%d", header->rate) + 1;
79 *qq += sprintf((char *)(*(*pp)++ = *qq), "-c%d", header->channels) + 1;
80 /* sox 12.17.9 insists on -b etc; CVS sox insists on -<n> etc; both are
82 switch(config->sox_generation) {
85 && header->endian != ENDIAN_NATIVE)
87 switch(header->bits) {
88 case 8: *(*pp)++ = "-b"; break;
89 case 16: *(*pp)++ = "-w"; break;
90 case 32: *(*pp)++ = "-l"; break;
91 case 64: *(*pp)++ = "-d"; break;
92 default: fatal(0, "cannot handle sample size %d", header->bits);
97 && header->endian != ENDIAN_NATIVE)
98 switch(header->endian) {
99 case ENDIAN_BIG: *(*pp)++ = "-B"; break;
100 case ENDIAN_LITTLE: *(*pp)++ = "-L"; break;
103 fatal(0, "cannot handle sample size %d", header->bits);
104 *qq += sprintf((char *)(*(*pp)++ = *qq), "-%d", header->bits / 8) + 1;
107 fatal(0, "unknown sox_generation %ld", config->sox_generation);
111 int main(int argc, char attribute((unused)) **argv) {
112 struct stream_header header, latest_format;
113 int n, p[2], outfd = -1;
117 if(!setlocale(LC_CTYPE, ""))
118 fatal(errno, "error calling setlocale");
120 fatal(0, "not intended to be invoked by users");
122 fatal(0, "cannot read configuration");
124 openlog(progname, LOG_PID, LOG_DAEMON);
125 log_default = &log_syslog;
127 memset(&latest_format, 0, sizeof latest_format);
129 if((n = read(0, &header, sizeof header)) < 0)
130 fatal(errno, "read error");
133 else if((size_t)n < sizeof header)
134 fatal(0, "short header");
135 /* Sanity check the header */
136 if(header.rate < 100 || header.rate > 1000000)
137 fatal(0, "implausible rate %"PRId32"Hz (%#"PRIx32")",
138 header.rate, header.rate);
139 if(header.channels < 1 || header.channels > 2)
140 fatal(0, "unsupported channel count %d", header.channels);
141 if(header.bits % 8 || !header.bits || header.bits > 64)
142 fatal(0, "unsupported sample size %d bits", header.bits);
143 if(header.endian != ENDIAN_BIG && header.endian != ENDIAN_LITTLE)
144 fatal(0, "unsupported byte order %x", header.bits);
145 /* Skip empty chunks regardless of their alleged format */
146 if(header.nbytes == 0)
148 /* If the format has changed we stop/start the converter */
149 if(!formats_equal(&header, &latest_format)) {
151 /* There's a running converter, stop it */
153 if(waitpid(pid, &n, 0) < 0)
154 fatal(errno, "error calling waitpid");
156 fatal(0, "sox failed: %#x", n);
160 if(!formats_equal(&header, &config->sample_format)) {
161 const char *av[32], **pp = av;
162 char argbuf[1024], *q = argbuf;
164 /* Input format doesn't match target, need to start a converter */
166 soxargs(&pp, &q, &header);
167 *pp++ = "-"; /* stdin */
168 soxargs(&pp, &q, &config->sample_format);
169 *pp++ = "-"; /* stdout */
171 /* This pipe will be sox's stdin */
173 if(!(pid = xfork())) {
178 execvp(av[0], (char **)av);
184 /* Input format matches output, can just copy bytes */
186 /* Remember current format for next iteration */
187 latest_format = header;
189 /* Convert or copy this chunk */
190 copy(0, outfd, header.nbytes);