mirror of https://github.com/ericonr/sndio.git
152 lines
2.8 KiB
C
152 lines
2.8 KiB
C
#include <errno.h>
|
|
#include <fcntl.h>
|
|
#include <poll.h>
|
|
#include <stdio.h>
|
|
#include <string.h>
|
|
#include <stdlib.h>
|
|
#include <unistd.h>
|
|
#include <sndio.h>
|
|
#include "tools.h"
|
|
|
|
void cb(void *, int);
|
|
void usage(void);
|
|
|
|
unsigned char *buf;
|
|
struct sio_par par;
|
|
char *xstr[] = SIO_XSTRINGS;
|
|
|
|
unsigned long long playpos = 0, writepos = 0;
|
|
int tick = 0;
|
|
|
|
void
|
|
cb(void *addr, int delta)
|
|
{
|
|
unsigned int bytes;
|
|
|
|
bytes = delta * par.bps * par.pchan;
|
|
/* fprintf(stderr, "advanced by %d\n", bytes); */
|
|
playpos += bytes;
|
|
tick = 1;
|
|
}
|
|
|
|
void
|
|
usage(void)
|
|
{
|
|
fprintf(stderr,
|
|
"usage: play [-b size] [-c nchan] [-e enc] [-r rate]\n");
|
|
}
|
|
|
|
int
|
|
main(int argc, char **argv)
|
|
{
|
|
int ch;
|
|
struct sio_hdl *hdl;
|
|
ssize_t n, len;
|
|
size_t bufsz;
|
|
|
|
/*
|
|
* defaults parameters
|
|
*/
|
|
sio_initpar(&par);
|
|
par.sig = 1;
|
|
par.bits = 16;
|
|
par.pchan = 2;
|
|
par.rate = 48000;
|
|
|
|
while ((ch = getopt(argc, argv, "r:c:e:b:x:")) != -1) {
|
|
switch(ch) {
|
|
case 'r':
|
|
if (sscanf(optarg, "%u", &par.rate) != 1) {
|
|
fprintf(stderr, "%s: bad rate\n", optarg);
|
|
exit(1);
|
|
}
|
|
break;
|
|
case 'c':
|
|
if (sscanf(optarg, "%u", &par.pchan) != 1) {
|
|
fprintf(stderr, "%s: bad channels\n", optarg);
|
|
exit(1);
|
|
}
|
|
break;
|
|
case 'e':
|
|
if (!strtoenc(&par, optarg)) {
|
|
fprintf(stderr, "%s: bad encoding\n", optarg);
|
|
exit(1);
|
|
}
|
|
break;
|
|
case 'b':
|
|
if (sscanf(optarg, "%u", &par.appbufsz) != 1) {
|
|
fprintf(stderr, "%s: bad buf size\n", optarg);
|
|
exit(1);
|
|
}
|
|
break;
|
|
case 'x':
|
|
for (par.xrun = 0;; par.xrun++) {
|
|
if (par.xrun == sizeof(xstr) / sizeof(char *)) {
|
|
fprintf(stderr,
|
|
"%s: bad xrun mode\n", optarg);
|
|
exit(1);
|
|
}
|
|
if (strcmp(xstr[par.xrun], optarg) == 0)
|
|
break;
|
|
}
|
|
break;
|
|
default:
|
|
usage();
|
|
exit(1);
|
|
break;
|
|
}
|
|
}
|
|
|
|
hdl = sio_open(SIO_DEVANY, SIO_PLAY, 0);
|
|
if (hdl == NULL) {
|
|
fprintf(stderr, "sio_open() failed\n");
|
|
exit(1);
|
|
}
|
|
sio_onmove(hdl, cb, NULL);
|
|
if (!sio_setpar(hdl, &par)) {
|
|
fprintf(stderr, "sio_setpar() failed\n");
|
|
exit(1);
|
|
}
|
|
if (!sio_getpar(hdl, &par)) {
|
|
fprintf(stderr, "sio_getpar() failed\n");
|
|
exit(1);
|
|
}
|
|
bufsz = par.bps * par.pchan * par.round;
|
|
buf = malloc(bufsz);
|
|
if (buf == NULL) {
|
|
fprintf(stderr, "failed to allocate %zu bytes\n", bufsz);
|
|
exit(1);
|
|
}
|
|
fprintf(stderr, "%zu bytes buffer, max latency %u frames\n",
|
|
bufsz, par.bufsz);
|
|
if (!sio_start(hdl)) {
|
|
fprintf(stderr, "sio_start() failed\n");
|
|
exit(1);
|
|
}
|
|
for (;;) {
|
|
len = read(STDIN_FILENO, buf, bufsz);
|
|
if (len < 0) {
|
|
perror("stdin");
|
|
exit(1);
|
|
}
|
|
if (len == 0) {
|
|
fprintf(stderr, "eof\n");
|
|
break;
|
|
}
|
|
n = sio_write(hdl, buf, len);
|
|
if (n == 0) {
|
|
fprintf(stderr, "sio_write: failed\n");
|
|
exit(1);
|
|
}
|
|
writepos += n;
|
|
if (tick) {
|
|
fprintf(stderr,
|
|
"playpos = %lld, writepos = %lld, latency = %lld\n",
|
|
playpos, writepos, writepos - playpos);
|
|
tick = 0;
|
|
}
|
|
}
|
|
sio_close(hdl);
|
|
return 0;
|
|
}
|