diff --git a/trunk/src/core/srs_core_forward.cpp b/trunk/src/core/srs_core_forward.cpp index 83ee661cb..6580f1cbc 100644 --- a/trunk/src/core/srs_core_forward.cpp +++ b/trunk/src/core/srs_core_forward.cpp @@ -110,6 +110,8 @@ int SrsForwarder::on_publish(SrsRequest* req, std::string forward_server) source_ep.c_str(), dest_ep.c_str(), tc_url.c_str(), stream_name.c_str()); + // TODO: seems bug when republish and reforward. + // start forward if ((ret = open_socket()) != ERROR_SUCCESS) { return ret;