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;
 			}
 		}