forked/ustreamer
1
0
Fork 0
mirror of https://github.com/pikvm/ustreamer.git synced 2026-03-03 22:31:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

improved slowdown logic

Browse Source
This commit is contained in:
Devaev Maxim
2021-01-11 13:41:05 +03:00
parent 1e8a06b924
commit d95a6ad0b0
1 changed files with 15 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
src/ustreamer/stream.c
View File

@@ -118,19 +118,23 @@ void stream_loop(stream_s *stream) {
}
}
if (atomic_load(&RUN(stop))) {
break;
if (stream->slowdown) {
for (unsigned slc = 0;
slc < 10
&& !atomic_load(&RUN(stop))
&& !atomic_load(&RUN(video->has_clients))
// has_clients синков НЕ обновляются в реальном времени
&& (stream->sink == NULL || !stream->sink->has_clients)
# ifdef WITH_OMX
&& (RUN(h264) == NULL || /*RUN(h264->sink) == NULL ||*/ !RUN(h264->sink->has_clients))
# endif
; ++slc) {
usleep(100000);
}
}
if (
stream->slowdown
&& !atomic_load(&RUN(video->has_clients))
&& (stream->sink == NULL || !stream->sink->has_clients)
# ifdef WITH_OMX
&& (RUN(h264) == NULL || /*RUN(h264->sink) == NULL ||*/ !RUN(h264->sink->has_clients))
# endif
) {
usleep(1000000);
if (atomic_load(&RUN(stop))) {
break;
}
bool has_read;