clear the queue when edge republish.

ossrs · Sep 14, 2015 · 704624c · 704624c
1 parent 8be3c87
commit 704624c
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/trunk/src/app/srs_app_edge.cpp b/trunk/src/app/srs_app_edge.cpp
@@ -476,6 +476,8 @@ void SrsEdgeForwarder::stop()
 
     close_underlayer_socket();
 
+    queue->clear();
+
     srs_freep(client);
     srs_freep(io);
     kbps->set_io(NULL, NULL);