static int ring_drain(RingBuffer *ring, int offset)
{
av_assert2(offset >= -ring_size_of_read_back(ring));
- av_assert2(offset <= -ring_size(ring));
+ av_assert2(offset <= ring_size(ring));
ring->read_pos += offset;
return 0;
}
cond_wakeup_main_fail:
pthread_mutex_destroy(&c->mutex);
mutex_fail:
- ffurl_close(c->inner);
+ ffurl_closep(&c->inner);
url_fail:
ring_destroy(&c->ring);
fifo_fail:
pthread_cond_destroy(&c->cond_wakeup_background);
pthread_cond_destroy(&c->cond_wakeup_main);
pthread_mutex_destroy(&c->mutex);
- ffurl_close(c->inner);
+ ffurl_closep(&c->inner);
ring_destroy(&c->ring);
return 0;