* \sa receiver receiver_node
*/
struct private_ortp_recv_data {
-
/**
*
*
char tmpbuf[CHUNK_SIZE + 3];
unsigned chunk_time;
-// PARA_DEBUG_LOG("rn: %p, pord: %p, session: %p\n", rn, pord, pord->session);
+// PARA_INFO_LOG("rn: %p, pord: %p, session: %p\n", rn, pord, pord->session);
+ t->ret = -E_ORTP_RECV_EOF;
+ if (rn->output_eof && *rn->output_eof) {
+ rn->eof = 1;
+ return;
+ }
t->ret = 1;
if (pord->start.tv_sec)
if (tv_diff(&s->now, &pord->next_chunk, NULL) < 0)
compute_next_chunk(chunk_time, pord);
return;
err_out:
+ rn->eof = 1;
freemsg(mp);
- return;
}
static void ortp_shutdown(void)