diff --git a/trunk/src/app/srs_app_forward.cpp b/trunk/src/app/srs_app_forward.cpp
old mode 100644
new mode 100755
index aff295c70..4670613b7
--- a/trunk/src/app/srs_app_forward.cpp
+++ b/trunk/src/app/srs_app_forward.cpp
@@ -65,8 +65,6 @@ SrsForwarder::SrsForwarder(SrsSource* s)
 
 SrsForwarder::~SrsForwarder()
 {
-    on_unpublish();
-    
     srs_freep(sdk);
     srs_freep(pthread);
     srs_freep(queue);
diff --git a/trunk/src/app/srs_app_st.cpp b/trunk/src/app/srs_app_st.cpp
old mode 100644
new mode 100755
index ab36243a1..b4e6009c0
--- a/trunk/src/app/srs_app_st.cpp
+++ b/trunk/src/app/srs_app_st.cpp
@@ -567,6 +567,7 @@ void srs_close_stfd(st_netfd_t& stfd)
         // we must ensure the close is ok.
         int err = st_netfd_close(stfd);
         srs_assert(err != -1);
+        stfd = NULL;
     }
 }