fix bug of mem leak, free the left msgs if send error

winlin
Commit 9ba786d1aaea9220c3571dc973a7b15f6dc0e729 9ba786d1 1 parent befde6ac
trunk/src/app/srs_app_edge.cpp
trunk/src/app/srs_app_forward.cpp
trunk/src/app/srs_app_rtmp_conn.cpp
--- a/trunk/src/app/srs_app_edge.cpp
查看文件 @9ba786d
+++ b/trunk/src/app/srs_app_edge.cpp
查看文件 @9ba786d
@@ -493,7 +493,7 @@ int SrsEdgeForwarder::cycle()
             if ((ret = client->send_and_free_message(msg)) != ERROR_SUCCESS) {
                 srs_error("edge publish forwarder send message to server failed. ret=%d", ret);
-                break;
+                continue;
             }
         }
         // free the array itself.
--- a/trunk/src/app/srs_app_forward.cpp
查看文件 @9ba786d
+++ b/trunk/src/app/srs_app_forward.cpp
查看文件 @9ba786d
@@ -371,7 +371,7 @@ int SrsForwarder::forward()
             if ((ret = client->send_and_free_message(msg)) != ERROR_SUCCESS) {
                 srs_error("forwarder send message to server failed. ret=%d", ret);
-                break;
+                continue;
             }
         }
         // free the array itself.
--- a/trunk/src/app/srs_app_rtmp_conn.cpp
查看文件 @9ba786d
+++ b/trunk/src/app/srs_app_rtmp_conn.cpp
查看文件 @9ba786d
@@ -543,7 +543,7 @@ int SrsRtmpConn::playing(SrsSource* source)
             if ((ret = rtmp->send_and_free_message(msg)) != ERROR_SUCCESS) {
                 srs_error("send message to client failed. ret=%d", ret);
-                break;
+                continue;
             }
         }
         // free the array itself.