winlin

clear the queue when edge republish.

@@ -476,6 +476,8 @@ void SrsEdgeForwarder::stop() @@ -476,6 +476,8 @@ void SrsEdgeForwarder::stop()
476 476
477 close_underlayer_socket(); 477 close_underlayer_socket();
478 478
  479 + queue->clear();
  480 +
479 srs_freep(client); 481 srs_freep(client);
480 srs_freep(io); 482 srs_freep(io);
481 kbps->set_io(NULL, NULL); 483 kbps->set_io(NULL, NULL);