fix while sleep time

5 years ago · ed82d60aac
parent 813c83ccc7
commit ed82d60aac
1 changed files with 2 additions and 5 deletions
--- a/trunk/src/app/srs_app_gb28181.cpp
+++ b/trunk/src/app/srs_app_gb28181.cpp
@ -1053,11 +1053,7 @@ srs_error_t SrsGb28181RtmpMuxer::do_cycle()
            rtmp_close();
        }
      
-        if (ps_queue.empty()){
-           srs_cond_timedwait(wait_ps_queue, 20 * SRS_UTIME_MILLISECONDS);
-        }else {
-           srs_cond_timedwait(wait_ps_queue, 10 * SRS_UTIME_MILLISECONDS);
-        }
+        srs_cond_timedwait(wait_ps_queue, 10 * SRS_UTIME_MILLISECONDS);
    }
    
    return err;
@ -1078,6 +1074,7 @@ void SrsGb28181RtmpMuxer::insert_jitterbuffer(SrsPsRtpPacket *pkt)
 {
    recv_rtp_stream_time = srs_get_system_time();
    jitter_buffer->InsertPacket(*pkt, pkt->payload->bytes(), pkt->payload->length(), NULL);
+    srs_cond_signal(wait_ps_queue);
 }

 void SrsGb28181RtmpMuxer::ps_packet_enqueue(SrsPsRtpPacket *pkt)