int stat[TS_MAX_PACKET_SIZE];
int i;
int best_score = 0;
+ int best_score2 = 0;
memset(stat, 0, packet_size * sizeof(*stat));
best_score = stat[x];
if (index)
*index = x;
+ } else if (stat[x] > best_score2) {
+ best_score2 = stat[x];
}
}
}
- return best_score;
+ return best_score - best_score2;
}
/* autodetect fec presence. Must have at least 1024 bytes */
return 0;
is_start = packet[1] & 0x40;
tss = ts->pids[pid];
- if (ts->auto_guess && tss == NULL && is_start) {
+ if (ts->auto_guess && !tss && is_start) {
add_pes_stream(ts, pid, -1);
tss = ts->pids[pid];
}
}
}
- if (!has_payload && tss->type != MPEGTS_PCR)
- return 0;
p = packet + 4;
if (has_adaptation) {
+ int64_t pcr_h;
+ int pcr_l;
+ if (parse_pcr(&pcr_h, &pcr_l, packet) == 0)
+ tss->last_pcr = pcr_h * 300 + pcr_l;
/* skip adaptation field */
p += p[0] + 1;
}
/* if past the end of packet, ignore */
p_end = packet + TS_PACKET_SIZE;
- if (p > p_end || (p == p_end && tss->type != MPEGTS_PCR))
+ if (p >= p_end || !has_payload)
return 0;
pos = avio_tell(ts->stream->pb);
} else {
int ret;
- int64_t pcr_h;
- int pcr_l;
- if (parse_pcr(&pcr_h, &pcr_l, packet) == 0)
- tss->last_pcr = pcr_h * 300 + pcr_l;
// Note: The position here points actually behind the current packet.
if (tss->type == MPEGTS_PES) {
if ((ret = tss->u.pes_filter.pes_cb(tss, p, p_end - p, is_start,