diff --git a/trunk/src/app/srs_app_source.cpp b/trunk/src/app/srs_app_source.cpp
index 3bc7f2598..59e203830 100644
--- a/trunk/src/app/srs_app_source.cpp
+++ b/trunk/src/app/srs_app_source.cpp
@@ -525,6 +525,11 @@ int SrsConsumer::dump_packets(SrsMessageArray* msgs, int& count)
 #ifdef SRS_PERF_QUEUE_COND_WAIT
 void SrsConsumer::wait(int nb_msgs, int duration)
 {
+    if (paused) {
+        st_usleep(SRS_CONSTS_RTMP_PULSE_TIMEOUT_US);
+        return;
+    }
+
     mw_min_msgs = nb_msgs;
     mw_duration = duration;