diff --git a/src/video_rxtx.cpp b/src/video_rxtx.cpp index 2ed4010a8..3262a06e1 100644 --- a/src/video_rxtx.cpp +++ b/src/video_rxtx.cpp @@ -185,8 +185,9 @@ void *video_rxtx::sender_loop() { shared_ptr tx_frame; tx_frame = compress_pop(m_compression); - if (!tx_frame) - goto exit; + if (!tx_frame) { + break; + } export_video(m_exporter, tx_frame.get()); @@ -194,7 +195,7 @@ void *video_rxtx::sender_loop() { m_frames_sent += 1; } -exit: + check_sender_messages(); return NULL; } diff --git a/src/video_rxtx/h264_rtp.cpp b/src/video_rxtx/h264_rtp.cpp index 023296f0f..3bd003c94 100644 --- a/src/video_rxtx/h264_rtp.cpp +++ b/src/video_rxtx/h264_rtp.cpp @@ -110,8 +110,8 @@ h264_rtp_video_rxtx::~h264_rtp_video_rxtx() void h264_rtp_video_rxtx::join() { - video_rxtx::join(); c_stop_server(m_rtsp_server); + video_rxtx::join(); } static void rtps_server_usage(){