#include <unistd.h>
#include <sys/mman.h>
#include <fcntl.h>
+#include <math.h>
#include "log.h"
#include "mem.h"
{ "pause-mode", required_argument, 0, 'P' },
{ "socket", required_argument, 0, 's' },
{ "config", required_argument, 0, 'C' },
+ { "monitor", no_argument, 0, 'M' },
{ 0, 0, 0, 0 }
};
fatal(0, "unsupported RTP payload type %d",
header.mpt & 0x7F);
}
+ /* See if packet is silent */
+ const uint16_t *s = p->samples_raw;
+ n = p->nsamples;
+ for(; n > 0; --n)
+ if(*s++)
+ break;
+ if(!n)
+ p->flags |= SILENT;
if(logfp)
fprintf(logfp, "sequence %u timestamp %"PRIx32" length %"PRIx32" end %"PRIx32"\n",
seq, timestamp, p->nsamples, timestamp + p->nsamples);
size_t max_samples,
void attribute((unused)) *userdata) {
size_t samples;
+ int silent = 0;
pthread_mutex_lock(&lock);
/* Get the next packet, junking any that are now in the past */
*bufptr++ = (int16_t)ntohs(*ptr++);
--i;
}
+ silent = !!(p->flags & SILENT);
} else {
/* There is no suitable packet. We introduce 0s up to the next packet, or
* to fill the buffer if there's no next packet or that's too many. The
samples = max_samples;
//info("infill by %zu", samples);
memset(buffer, 0, samples * uaudio_sample_size);
+ silent = 1;
}
/* Debug dump */
if(dump_buffer) {
}
/* Advance timestamp */
next_timestamp += samples;
+ /* If we're getting behind then try to drop just silent packets */
+ if(nsamples > minbuffer && silent) {
+ info("dropping %zu samples (%"PRIu32" > %"PRIu32")",
+ samples, nsamples, minbuffer);
+ samples = 0;
+ }
/* Junk obsolete packets */
playrtp_next_packet();
pthread_mutex_unlock(&lock);
union any_sockaddr mgroup;
const char *dumpfile = 0;
pthread_t ltid;
+ int monitor = 0;
static const int one = 1;
static const struct addrinfo prefs = {
mem_init();
if(!setlocale(LC_CTYPE, "")) fatal(errno, "error calling setlocale");
backend = uaudio_apis[0];
- while((n = getopt_long(argc, argv, "hVdD:m:x:L:R:M:aocC:re:P:", options, 0)) >= 0) {
+ while((n = getopt_long(argc, argv, "hVdD:m:x:L:R:aocC:re:P:M", options, 0)) >= 0) {
switch(n) {
case 'h': help();
case 'V': version("disorder-playrtp");
case 'r': dumpfile = optarg; break;
case 'e': backend = &uaudio_command; uaudio_set("command", optarg); break;
case 'P': uaudio_set("pause-mode", optarg); break;
+ case 'M': monitor = 1; break;
default: fatal(0, "invalid option");
}
}
- if(config_read(0)) fatal(0, "cannot read configuration");
+ if(config_read(0, NULL)) fatal(0, "cannot read configuration");
if(!maxbuffer)
maxbuffer = 2 * minbuffer;
argc -= optind;
if((err = pthread_create(<id, 0, queue_thread, 0)))
fatal(err, "pthread_create queue_thread");
pthread_mutex_lock(&lock);
+ time_t lastlog = 0;
for(;;) {
/* Wait for the buffer to fill up a bit */
playrtp_fill_buffer();
while(nsamples >= minbuffer
|| (nsamples > 0
&& contains(pheap_first(&packets), next_timestamp))) {
+ if(monitor) {
+ time_t now = time(0);
+
+ if(now >= lastlog + 60) {
+ int offset = nsamples - minbuffer;
+ double offtime = (double)offset / (uaudio_rate * uaudio_channels);
+ info("%+d samples off (%d.%02ds, %d bytes)",
+ offset,
+ (int)fabs(offtime) * (offtime < 0 ? -1 : 1),
+ (int)(fabs(offtime) * 100) % 100,
+ offset * uaudio_bits / CHAR_BIT);
+ lastlog = now;
+ }
+ }
//fprintf(stderr, "%8u/%u (%u) PLAYING\n", nsamples, maxbuffer, minbuffer);
pthread_cond_wait(&cond, &lock);
}