RepoMirrors/ffmpeg
1
0
Fork 0
mirror of https://git.ffmpeg.org/ffmpeg.git synced 2024-12-25 00:32:31 +00:00
Code Issues Projects Releases Wiki Activity

Revert "avformat/udp: Fix temporary buffer race"

Browse Source 
This is not needed

This reverts commit 7b2f67ea77.
This commit is contained in:
Michael Niedermayer 2024-07-21 21:37:50 +02:00
parent 4acb9b7d10
commit 55af81b5a4
No known key found for this signature in database
GPG Key ID: B18E8928B3948D64
1 changed files with 7 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
libavformat/udp.c
View File

@ -107,8 +107,7 @@ typedef struct UDPContext {
pthread_cond_t cond; pthread_cond_t cond;
int thread_started; int thread_started;
#endif #endif
uint8_t tmp_rx[UDP_MAX_PKT_SIZE+4]; uint8_t tmp[UDP_MAX_PKT_SIZE+4];
uint8_t tmp_tx[UDP_MAX_PKT_SIZE+4];
int remaining_in_dg; int remaining_in_dg;
char *localaddr; char *localaddr;
int timeout; int timeout;
@ -505,7 +504,7 @@ static void *circular_buffer_task_rx( void *_URLContext)
see "General Information" / "Thread Cancelation Overview" see "General Information" / "Thread Cancelation Overview"
in Single Unix. */ in Single Unix. */
pthread_setcancelstate(PTHREAD_CANCEL_ENABLE, &old_cancelstate); pthread_setcancelstate(PTHREAD_CANCEL_ENABLE, &old_cancelstate);
len = recvfrom(s->udp_fd, s->tmp_rx+4, sizeof(s->tmp_rx)-4, 0, (struct sockaddr *)&addr, &addr_len); len = recvfrom(s->udp_fd, s->tmp+4, sizeof(s->tmp)-4, 0, (struct sockaddr *)&addr, &addr_len);
pthread_setcancelstate(PTHREAD_CANCEL_DISABLE, &old_cancelstate); pthread_setcancelstate(PTHREAD_CANCEL_DISABLE, &old_cancelstate);
pthread_mutex_lock(&s->mutex); pthread_mutex_lock(&s->mutex);
if (len < 0) { if (len < 0) {
@ -517,7 +516,7 @@ static void *circular_buffer_task_rx( void *_URLContext)
} }
if (ff_ip_check_source_lists(&addr, &s->filters)) if (ff_ip_check_source_lists(&addr, &s->filters))
continue; continue;
AV_WL32(s->tmp_rx, len); AV_WL32(s->tmp, len);
if (av_fifo_can_write(s->fifo) < len + 4) { if (av_fifo_can_write(s->fifo) < len + 4) {
/* No Space left */ /* No Space left */
@ -533,7 +532,7 @@ static void *circular_buffer_task_rx( void *_URLContext)
goto end; goto end;
} }
} }
av_fifo_write(s->fifo, s->tmp_rx, len + 4); av_fifo_write(s->fifo, s->tmp, len + 4);
pthread_cond_signal(&s->cond); pthread_cond_signal(&s->cond);
} }
@ -582,9 +581,9 @@ static void *circular_buffer_task_tx( void *_URLContext)
len = AV_RL32(tmp); len = AV_RL32(tmp);
av_assert0(len >= 0); av_assert0(len >= 0);
av_assert0(len <= sizeof(s->tmp_tx)); av_assert0(len <= sizeof(s->tmp));
av_fifo_read(s->fifo, s->tmp_tx, len); av_fifo_read(s->fifo, s->tmp, len);
pthread_mutex_unlock(&s->mutex); pthread_mutex_unlock(&s->mutex);
@ -608,7 +607,7 @@ static void *circular_buffer_task_tx( void *_URLContext)
target_timestamp = start_timestamp + sent_bits * 1000000 / s->bitrate; target_timestamp = start_timestamp + sent_bits * 1000000 / s->bitrate;
} }
p = s->tmp_tx; p = s->tmp;
while (len) { while (len) {
int ret; int ret;
av_assert0(len > 0); av_assert0(len > 0);