winlin

merge from feilong, consumer directly sleep when paused.

@@ -525,6 +525,11 @@ int SrsConsumer::dump_packets(SrsMessageArray* msgs, int& count) @@ -525,6 +525,11 @@ int SrsConsumer::dump_packets(SrsMessageArray* msgs, int& count)
525 #ifdef SRS_PERF_QUEUE_COND_WAIT 525 #ifdef SRS_PERF_QUEUE_COND_WAIT
526 void SrsConsumer::wait(int nb_msgs, int duration) 526 void SrsConsumer::wait(int nb_msgs, int duration)
527 { 527 {
  528 + if (paused) {
  529 + st_usleep(SRS_CONSTS_RTMP_PULSE_TIMEOUT_US);
  530 + return;
  531 + }
  532 +
528 mw_min_msgs = nb_msgs; 533 mw_min_msgs = nb_msgs;
529 mw_duration = duration; 534 mw_duration = duration;
530 535