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 572c2ee23..9fd95fac3
--- a/trunk/src/app/srs_app_forward.cpp
+++ b/trunk/src/app/srs_app_forward.cpp
@@ -68,8 +68,6 @@ SrsForwarder::SrsForwarder(SrsSource* _source)
 
 SrsForwarder::~SrsForwarder()
 {
-    on_unpublish();
-    
     srs_freep(pthread);
     srs_freep(queue);
     srs_freep(jitter);
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 ba818c9d6..22f43b82d
--- a/trunk/src/app/srs_app_st.cpp
+++ b/trunk/src/app/srs_app_st.cpp
@@ -237,6 +237,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;
     }
 }