|
|
|
@ -225,20 +225,6 @@ static int rtp_read(URLContext *h, uint8_t *buf, int size) |
|
|
|
|
int len, n; |
|
|
|
|
struct pollfd p[2] = {{s->rtp_fd, POLLIN, 0}, {s->rtcp_fd, POLLIN, 0}}; |
|
|
|
|
|
|
|
|
|
#if 0 |
|
|
|
|
for(;;) { |
|
|
|
|
from_len = sizeof(from); |
|
|
|
|
len = recvfrom (s->rtp_fd, buf, size, 0, |
|
|
|
|
(struct sockaddr *)&from, &from_len); |
|
|
|
|
if (len < 0) { |
|
|
|
|
if (ff_neterrno() == AVERROR(EAGAIN) || |
|
|
|
|
ff_neterrno() == AVERROR(EINTR)) |
|
|
|
|
continue; |
|
|
|
|
return AVERROR(EIO); |
|
|
|
|
} |
|
|
|
|
break; |
|
|
|
|
} |
|
|
|
|
#else |
|
|
|
|
for(;;) { |
|
|
|
|
if (url_interrupt_cb()) |
|
|
|
|
return AVERROR_EXIT; |
|
|
|
@ -277,7 +263,6 @@ static int rtp_read(URLContext *h, uint8_t *buf, int size) |
|
|
|
|
return AVERROR(EIO); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
#endif |
|
|
|
|
return len; |
|
|
|
|
} |
|
|
|
|
|
|
|
|
@ -296,14 +281,6 @@ static int rtp_write(URLContext *h, const uint8_t *buf, int size) |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
ret = ffurl_write(hd, buf, size); |
|
|
|
|
#if 0 |
|
|
|
|
{ |
|
|
|
|
struct timespec ts; |
|
|
|
|
ts.tv_sec = 0; |
|
|
|
|
ts.tv_nsec = 10 * 1000000; |
|
|
|
|
nanosleep(&ts, NULL); |
|
|
|
|
} |
|
|
|
|
#endif |
|
|
|
|
return ret; |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|