- gettimeofday(&now, NULL);
- PARA_DEBUG_LOG("rn: %p, pord: %p, session: %p\n", rn, pord, pord->session);
- if (pord->start.tv_sec) {
- struct timeval diff;
- if (tv_diff(&now, &pord->next_chunk, &diff) < 0) {
- long unsigned diff_ms = tv2ms(&diff);
- if (diff_ms > 5) {
- PARA_DEBUG_LOG("too early: %lu ms left\n",
- diff_ms);
- return 1;
- }
- }
+// 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;