}
if (switch_core_inthash_delete(jb->node_hash, node->packet.header.seq)) {
- if (jb->type != SJB_VIDEO || node->packet.header.m) {
+ if (node->packet.header.m && jb->type == SJB_VIDEO) {
jb->complete_frames--;
}
}
switch_core_inthash_insert(jb->node_hash, node->packet.header.seq, node);
- jb->complete_frames++;
+ if (packet->header.m && jb->type == SJB_VIDEO) {
+ jb->complete_frames++;
+ }
if (jb->node_hash_ts) {
switch_core_inthash_insert(jb->node_hash_ts, node->packet.header.ts, node);
} else {
if (jb->write_init || jb->type == SJB_TEXT || jb->type == SJB_AUDIO) {
jb_debug(jb, 2, "WRITE frame ts: %u complete=%u/%u n:%u\n", ntohl(node->packet.header.ts), jb->complete_frames , jb->frame_len, jb->visible_nodes);
+ jb->complete_frames++;
} else {
jb->highest_wrote_ts = packet->header.ts;
}
if (jb->type == SJB_TEXT || jb->type == SJB_AUDIO ||
(jb->read_init && htons(node->packet.header.seq) >= htons(jb->highest_read_seq) && (ntohl(node->packet.header.ts) > ntohl(jb->highest_read_ts)))) {
+
+ if (jb->type == SJB_TEXT || jb->type == SJB_AUDIO) {
+ jb->complete_frames--;
+ }
jb_debug(jb, 2, "READ frame ts: %u complete=%u/%u n:%u\n", ntohl(node->packet.header.ts), jb->complete_frames , jb->frame_len, jb->visible_nodes);
jb->highest_read_ts = node->packet.header.ts;
} else if (!jb->read_init) {