chiark / gitweb /
spot changes to playing track via monitor list
[disorder] / server / normalize.c
CommitLineData
6d2d327c
RK
1/*
2 * This file is part of DisOrder
3 * Copyright (C) 2007 Richard Kettlewell
4 *
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.
9 *
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.
14 *
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
18 * USA
19 */
20/** @file server/disorder-normalize.c
21 * @brief Convert "raw" format output to the configured format
22 *
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.
26 */
27
28#include <config.h>
29#include "types.h"
30
31#include <locale.h>
32#include <errno.h>
33#include <unistd.h>
34#include <syslog.h>
35#include <string.h>
36#include <sys/types.h>
37#include <sys/wait.h>
38
39#include "syscalls.h"
40#include "log.h"
41#include "configuration.h"
42#include "speaker-protocol.h"
43
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
48 */
49static void copy(int infd, int outfd, size_t n) {
62234e45 50 char buffer[4096];
51 ssize_t written;
6d2d327c
RK
52
53 while(n > 0) {
62234e45 54 const ssize_t readden = read(infd, buffer,
55 n > sizeof buffer ? sizeof buffer : n);
56 if(readden < 0) {
6d2d327c
RK
57 if(errno == EINTR)
58 continue;
59 else
60 fatal(errno, "read error");
61 }
62234e45 62 if(readden == 0)
6d2d327c 63 fatal(0, "unexpected EOF");
62234e45 64 n -= readden;
65 written = 0;
66 while(written < readden) {
67 const ssize_t w = write(outfd, buffer + written, readden - written);
6d2d327c
RK
68 if(w < 0)
69 fatal(errno, "write error");
62234e45 70 written += w;
6d2d327c
RK
71 }
72 }
73}
74
75static void soxargs(const char ***pp, char **qq,
76 const struct stream_header *header) {
77 *(*pp)++ = "-t.raw";
78 *(*pp)++ = "-s";
79 *qq += sprintf((char *)(*(*pp)++ = *qq), "-r%d", header->rate) + 1;
80 *qq += sprintf((char *)(*(*pp)++ = *qq), "-c%d", header->channels) + 1;
81 /* sox 12.17.9 insists on -b etc; CVS sox insists on -<n> etc; both are
82 * deployed! */
83 switch(config->sox_generation) {
84 case 0:
85 if(header->bits != 8
86 && header->endian != ENDIAN_NATIVE)
87 *(*pp)++ = "-x";
88 switch(header->bits) {
89 case 8: *(*pp)++ = "-b"; break;
90 case 16: *(*pp)++ = "-w"; break;
91 case 32: *(*pp)++ = "-l"; break;
92 case 64: *(*pp)++ = "-d"; break;
93 default: fatal(0, "cannot handle sample size %d", header->bits);
94 }
95 break;
96 case 1:
97 if(header->bits != 8
98 && header->endian != ENDIAN_NATIVE)
99 switch(header->endian) {
100 case ENDIAN_BIG: *(*pp)++ = "-B"; break;
101 case ENDIAN_LITTLE: *(*pp)++ = "-L"; break;
102 }
103 if(header->bits % 8)
104 fatal(0, "cannot handle sample size %d", header->bits);
105 *qq += sprintf((char *)(*(*pp)++ = *qq), "-%d", header->bits / 8) + 1;
106 break;
107 default:
108 fatal(0, "unknown sox_generation %ld", config->sox_generation);
109 }
110}
111
112int main(int argc, char attribute((unused)) **argv) {
113 struct stream_header header, latest_format;
114 int n, p[2], outfd = -1;
115 pid_t pid = -1;
116
117 set_progname(argv);
118 if(!setlocale(LC_CTYPE, ""))
119 fatal(errno, "error calling setlocale");
120 if(argc > 1)
121 fatal(0, "not intended to be invoked by users");
122 if(config_read())
123 fatal(0, "cannot read configuration");
124 if(!isatty(2)) {
125 openlog(progname, LOG_PID, LOG_DAEMON);
126 log_default = &log_syslog;
127 }
128 memset(&latest_format, 0, sizeof latest_format);
129 for(;;) {
130 if((n = read(0, &header, sizeof header)) < 0)
131 fatal(errno, "read error");
132 else if(n == 0)
133 exit(0);
134 else if((size_t)n < sizeof header)
135 fatal(0, "short header");
136 /* Sanity check the header */
137 if(header.rate < 100 || header.rate > 1000000)
138 fatal(0, "implausible rate %"PRId32"Hz (%#"PRIx32")",
139 header.rate, header.rate);
140 if(header.channels < 1 || header.channels > 2)
141 fatal(0, "unsupported channel count %d", header.channels);
142 if(header.bits % 8 || !header.bits || header.bits > 64)
143 fatal(0, "unsupported sample size %d bits", header.bits);
144 if(header.endian != ENDIAN_BIG && header.endian != ENDIAN_LITTLE)
145 fatal(0, "unsupported byte order %x", header.bits);
146 /* Skip empty chunks regardless of their alleged format */
147 if(header.nbytes == 0)
148 continue;
149 /* If the format has changed we stop/start the converter */
150 if(!formats_equal(&header, &latest_format)) {
151 if(pid != -1) {
152 /* There's a running converter, stop it */
153 xclose(outfd);
154 if(waitpid(pid, &n, 0) < 0)
155 fatal(errno, "error calling waitpid");
156 if(n)
157 fatal(0, "sox failed: %#x", n);
158 pid = -1;
159 outfd = -1;
160 }
161 if(!formats_equal(&header, &config->sample_format)) {
162 const char *av[32], **pp = av;
163 char argbuf[1024], *q = argbuf;
164
165 /* Input format doesn't match target, need to start a converter */
166 *pp++ = "sox";
167 soxargs(&pp, &q, &header);
168 *pp++ = "-"; /* stdin */
169 soxargs(&pp, &q, &config->sample_format);
170 *pp++ = "-"; /* stdout */
171 *pp = 0;
172 /* This pipe will be sox's stdin */
173 xpipe(p);
174 if(!(pid = xfork())) {
175 exitfn = _exit;
176 xdup2(p[0], 0);
177 xclose(p[0]);
178 xclose(p[1]);
179 execvp(av[0], (char **)av);
180 fatal(errno, "sox");
181 }
182 xclose(p[0]);
183 outfd = p[1];
184 } else
185 /* Input format matches output, can just copy bytes */
186 outfd = 1;
187 /* Remember current format for next iteration */
188 latest_format = header;
189 }
190 /* Convert or copy this chunk */
191 copy(0, outfd, header.nbytes);
192 }
193 if(outfd != -1)
194 xclose(outfd);
195 return 0;
196}
197
198/*
199Local Variables:
200c-basic-offset:2
201comment-column:40
202fill-column:79
203indent-tabs-mode:nil
204End:
205*/