identify the flash and fmle for recv thread.

@@ -95,6 +95,7 @@ SrsRtmpConn::SrsRtmpConn(SrsServer* svr, st_netfd_t c)
     realtime = SRS_PERF_MIN_LATENCY_ENABLED;
     send_min_interval = 0;
     tcp_nodelay = false;
+    client_type = SrsRtmpConnUnknown;
     
     _srs_config->subscribe(this);
 }
@@ -506,6 +507,7 @@ int SrsRtmpConn::stream_service_cycle()
         source->source_id(), source->source_id());
     source->set_cache(enabled_cache);
     
+    client_type = type;
     switch (type) {
         case SrsRtmpConnPlay: {
             srs_verbose("start to play stream %s.", req->stream.c_str());
@@ -828,7 +830,9 @@ int SrsRtmpConn::publishing(SrsSource* source)
         // use isolate thread to recv,
         // @see: https://github.com/ossrs/srs/issues/237
         SrsPublishRecvThread trd(rtmp, req, 
-            st_netfd_fileno(stfd), 0, this, source, true, vhost_is_edge);
+            st_netfd_fileno(stfd), 0, this, source,
+            client_type == SrsRtmpConnFMLEPublish,
+            vhost_is_edge);
 
         srs_info("start to publish stream %s success", req->stream.c_str());
         ret = do_publishing(source, &trd);

@@ -33,6 +33,7 @@ CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 #include <srs_app_st.hpp>
 #include <srs_app_conn.hpp>
 #include <srs_app_reload.hpp>
+#include <srs_rtmp_stack.hpp>
 
 class SrsServer;
 class SrsRtmpServer;
@@ -93,6 +94,8 @@ private:
     int publish_normal_timeout;
     // whether enable the tcp_nodelay.
     bool tcp_nodelay;
+    // The type of client, play or publish.
+    SrsRtmpConnType client_type;
 public:
     SrsRtmpConn(SrsServer* svr, st_netfd_t c);
     virtual ~SrsRtmpConn();