From 86b1f3349a595a28b1e78540aa1c15100984a54b Mon Sep 17 00:00:00 2001 From: winlin Date: Fri, 6 Dec 2013 10:23:28 +0800 Subject: [PATCH] fix bug of forward, erase msgs when error --- trunk/src/core/srs_core_forward.cpp | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/trunk/src/core/srs_core_forward.cpp b/trunk/src/core/srs_core_forward.cpp index 36cd5a851..85103f69b 100644 --- a/trunk/src/core/srs_core_forward.cpp +++ b/trunk/src/core/srs_core_forward.cpp @@ -316,6 +316,10 @@ int SrsForwarder::forward() ret = client->send_message(msg); if (ret != ERROR_SUCCESS) { srs_error("forwarder send message to server failed. ret=%d", ret); + + // convert the index to count when error. + i++; + break; } }