forked/ustreamer
1
0
Fork 0
mirror of https://github.com/pikvm/ustreamer.git synced 2026-04-19 21:16:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactoring

Browse Source
This commit is contained in:
Devaev Maxim
2021-01-09 15:08:34 +03:00
parent 1e6c3b9708
commit cc06f2abad
1 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
src/ustreamer/stream.c
View File

@@ -80,7 +80,7 @@ void stream_loop(stream_s *stream) {
# ifdef WITH_OMX # ifdef WITH_OMX
if (stream->h264_sink) { if (stream->h264_sink) {
stream->h264 = _h264_stream_init(stream->h264_sink, stream->h264_bitrate, stream->h264_gop); RUN(h264) = _h264_stream_init(stream->h264_sink, stream->h264_bitrate, stream->h264_gop);
} }
# endif # endif
@@ -185,8 +185,8 @@ void stream_loop(stream_s *stream) {
LOG_DEBUG("Assigned new frame in buffer %d to worker %s", buf_index, ready_wr->name); LOG_DEBUG("Assigned new frame in buffer %d to worker %s", buf_index, ready_wr->name);
# ifdef WITH_OMX # ifdef WITH_OMX
if (stream->h264) { if (RUN(h264)) {
_h264_stream_process(stream->h264, &hw->raw); _h264_stream_process(RUN(h264), &hw->raw);
} }
# endif # endif
} }
@@ -219,8 +219,8 @@ void stream_loop(stream_s *stream) {
} }
# ifdef WITH_OMX # ifdef WITH_OMX
if (stream->h264) { if (RUN(h264)) {
_h264_stream_destroy(stream->h264); _h264_stream_destroy(RUN(h264));
} }
# endif # endif
} }
@@ -246,8 +246,8 @@ static workers_pool_s *_stream_init_loop(stream_s *stream) {
memsink_server_put(stream->jpeg_sink, stream->blank); memsink_server_put(stream->jpeg_sink, stream->blank);
} }
# ifdef WITH_OMX # ifdef WITH_OMX
if (stream->h264) { if (RUN(h264)) {
_h264_stream_process(stream->h264, stream->blank); _h264_stream_process(RUN(h264), stream->blank);
} }
# endif # endif
} }