--- /dev/null
+#! /usr/bin/perl -w
+use strict;
+
+our $last;
+my %start = ();
+my %end = ();
+while(<>) {
+ if(/sequence (\d+) timestamp (\w+) length (\w+) end (\w+)/) {
+ my $seq = $1;
+ my $timestamp = hex($2);
+ my $length = hex($3);
+ my $end = hex($4);
+
+ if(defined $last) {
+ if($seq < $last) {
+ print "$seq < $last\n";
+ } elsif($seq != $last + 1) {
+ printf "%u when %u expected, missed %d\n",
+ $seq, $last + 1, $seq - $last;
+ }
+ }
+ if(exists $start{$seq}) {
+ print "$seq: duplicate";
+ }
+ $start{$seq} = $timestamp;
+ $end{$seq} = $end;
+ if(exists $start{$seq-1}) {
+ if($end{$seq-1} != $start{$seq}) {
+ printf "%u ends at %x but %u starts at %x (delta=%d)\n",
+ $seq-1, $end{$seq-1}, $seq, $start{$seq},
+ $start{$seq}-$end{$seq-1};
+ }
+ }
+
+
+ $last = $seq;
+ }
+}
/** @brief RTP socket */
static int rtpfd;
+/** @brief Log output */
+static FILE *logfp;
+
/** @brief Output device */
static const char *device;
}
}
/* Ignore too-short packets */
- if((size_t)n <= sizeof (struct rtp_header))
+ if((size_t)n <= sizeof (struct rtp_header)) {
+ info("ignored a short packet");
continue;
+ }
p->timestamp = ntohl(packet.header.timestamp);
/* Ignore packets in the past */
if(active && lt(p->timestamp, next_timestamp)) {
fatal(0, "unsupported RTP payload type %d",
packet.header.mpt & 0x7F);
}
+ if(logfp)
+ fprintf(logfp, "sequence %u timestamp %"PRIx32" length %"PRIx32" end %"PRIx32"\n",
+ ntohs(packet.header.seq),
+ p->timestamp, p->nsamples, p->timestamp + p->nsamples);
pthread_mutex_lock(&lock);
/* Stop reading if we've reached the maximum.
*
* This is rather unsatisfactory: it means that if packets get heavily
* out of order then we guarantee dropouts. But for now... */
- while(nsamples >= maxbuffer)
- pthread_cond_wait(&cond, &lock);
+ if(nsamples >= maxbuffer) {
+ info("buffer full");
+ while(nsamples >= maxbuffer)
+ pthread_cond_wait(&cond, &lock);
+ }
for(pp = &packets;
*pp && lt((*pp)->timestamp, p->timestamp);
pp = &(*pp)->next)
next_timestamp += samples_available;
samplesOut += samples_available;
samplesOutLeft -= samples_available;
- /* TODO log infill */
} else {
/* There's no next packet at all */
info("infilled by %zu", samplesOutLeft);
next_timestamp += samplesOutLeft;
samplesOut += samplesOutLeft;
samplesOutLeft = 0;
- /* TODO log infill */
}
}
++ab;
mem_init();
if(!setlocale(LC_CTYPE, "")) fatal(errno, "error calling setlocale");
- while((n = getopt_long(argc, argv, "hVdD:m:b:x:", options, 0)) >= 0) {
+ while((n = getopt_long(argc, argv, "hVdD:m:b:x:L:", options, 0)) >= 0) {
switch(n) {
case 'h': help();
case 'V': version();
case 'm': minbuffer = 2 * atol(optarg); break;
case 'b': readahead = 2 * atol(optarg); break;
case 'x': maxbuffer = 2 * atol(optarg); break;
+ case 'L': logfp = fopen(optarg, "w"); break;
default: fatal(0, "invalid option");
}
}