summaryrefslogtreecommitdiff
path: root/libavformat/rtsp.c
diff options
context:
space:
mode:
authorLuca Barbato <lu_zero@gentoo.org>2017-02-20 00:50:34 +0100
committerLuca Barbato <lu_zero@gentoo.org>2017-02-27 13:51:53 +0100
commitb9b82151a1aaa8bbf389853a6142c4e101d80b86 (patch)
treebd4ca1d8201de8e5bc5808b223a0a83c70116228 /libavformat/rtsp.c
parent150e99d694f33ab9ad678834964909aa315d14a1 (diff)
downloadffmpeg-b9b82151a1aaa8bbf389853a6142c4e101d80b86.tar.gz
rtsp: Move the pollfd setup out of the for loop
Diffstat (limited to 'libavformat/rtsp.c')
-rw-r--r--libavformat/rtsp.c56
1 files changed, 28 insertions, 28 deletions
diff --git a/libavformat/rtsp.c b/libavformat/rtsp.c
index e75670867a..e4cbae43a2 100644
--- a/libavformat/rtsp.c
+++ b/libavformat/rtsp.c
@@ -1920,39 +1920,39 @@ static int udp_read_packet(AVFormatContext *s, RTSPStream **prtsp_st,
struct pollfd *p = rt->p;
int *fds = NULL, fdsnum, fdsidx;
+ if (rt->rtsp_hd) {
+ tcp_fd = ffurl_get_file_handle(rt->rtsp_hd);
+ p[max_p].fd = tcp_fd;
+ p[max_p++].events = POLLIN;
+ } else {
+ tcp_fd = -1;
+ }
+ for (i = 0; i < rt->nb_rtsp_streams; i++) {
+ rtsp_st = rt->rtsp_streams[i];
+ if (rtsp_st->rtp_handle) {
+ if (ret = ffurl_get_multi_file_handle(rtsp_st->rtp_handle,
+ &fds, &fdsnum)) {
+ av_log(s, AV_LOG_ERROR, "Unable to recover rtp ports\n");
+ return ret;
+ }
+ if (fdsnum != 2) {
+ av_log(s, AV_LOG_ERROR,
+ "Number of fds %d not supported\n", fdsnum);
+ return AVERROR_INVALIDDATA;
+ }
+ for (fdsidx = 0; fdsidx < fdsnum; fdsidx++) {
+ p[max_p].fd = fds[fdsidx];
+ p[max_p++].events = POLLIN;
+ }
+ av_free(fds);
+ }
+ }
+
for (;;) {
if (ff_check_interrupt(&s->interrupt_callback))
return AVERROR_EXIT;
if (wait_end && wait_end - av_gettime_relative() < 0)
return AVERROR(EAGAIN);
- max_p = 0;
- if (rt->rtsp_hd) {
- tcp_fd = ffurl_get_file_handle(rt->rtsp_hd);
- p[max_p].fd = tcp_fd;
- p[max_p++].events = POLLIN;
- } else {
- tcp_fd = -1;
- }
- for (i = 0; i < rt->nb_rtsp_streams; i++) {
- rtsp_st = rt->rtsp_streams[i];
- if (rtsp_st->rtp_handle) {
- if (ret = ffurl_get_multi_file_handle(rtsp_st->rtp_handle,
- &fds, &fdsnum)) {
- av_log(s, AV_LOG_ERROR, "Unable to recover rtp ports\n");
- return ret;
- }
- if (fdsnum != 2) {
- av_log(s, AV_LOG_ERROR,
- "Number of fds %d not supported\n", fdsnum);
- return AVERROR_INVALIDDATA;
- }
- for (fdsidx = 0; fdsidx < fdsnum; fdsidx++) {
- p[max_p].fd = fds[fdsidx];
- p[max_p++].events = POLLIN;
- }
- av_free(fds);
- }
- }
n = poll(p, max_p, POLL_TIMEOUT_MS);
if (n > 0) {
int j = 1 - (tcp_fd == -1);