Merge branch '2.0release' into develop

@@ -167,7 +167,7 @@ PROTOCOL_OBJS="${MODULE_OBJS[@]}"
 if [ $SRS_EXPORT_LIBRTMP_PROJECT = NO ]; then
 if [ $SRS_EXPORT_LIBRTMP_PROJECT = NO ]; then
     MODULE_ID="APP" 
     MODULE_ID="APP" 
     MODULE_DEPENDS=("CORE" "KERNEL" "PROTOCOL") 
     MODULE_DEPENDS=("CORE" "KERNEL" "PROTOCOL") 
-    ModuleLibIncs=(${LibSTRoot} ${LibHttpParserRoot} ${SRS_OBJS_DIR})
+    ModuleLibIncs=(${LibSTRoot} ${LibHttpParserRoot} ${LibSSLRoot} ${SRS_OBJS_DIR})
     MODULE_FILES=("srs_app_server" "srs_app_conn" "srs_app_rtmp_conn" "srs_app_source" 
     MODULE_FILES=("srs_app_server" "srs_app_conn" "srs_app_rtmp_conn" "srs_app_source" 
             "srs_app_refer" "srs_app_hls" "srs_app_forward" "srs_app_encoder" "srs_app_http_stream"
             "srs_app_refer" "srs_app_hls" "srs_app_forward" "srs_app_encoder" "srs_app_http_stream"
             "srs_app_thread" "srs_app_bandwidth" "srs_app_st" "srs_app_log" "srs_app_config" 
             "srs_app_thread" "srs_app_bandwidth" "srs_app_st" "srs_app_log" "srs_app_config" 
@@ -200,7 +200,7 @@ LIBS_OBJS="${MODULE_OBJS[@]}"
 if [ $SRS_EXPORT_LIBRTMP_PROJECT = NO ]; then
 if [ $SRS_EXPORT_LIBRTMP_PROJECT = NO ]; then
     MODULE_ID="MAIN" 
     MODULE_ID="MAIN" 
     MODULE_DEPENDS=("CORE" "KERNEL" "PROTOCOL" "APP")
     MODULE_DEPENDS=("CORE" "KERNEL" "PROTOCOL" "APP")
-    ModuleLibIncs=(${LibSTRoot} ${SRS_OBJS_DIR} ${LibGperfRoot} ${LibHttpParserRoot})
+    ModuleLibIncs=(${LibSTRoot} ${SRS_OBJS_DIR} ${LibGperfRoot} ${LibHttpParserRoot} ${LibSSLRoot})
     MODULE_FILES=("srs_main_server" "srs_main_ingest_hls")
     MODULE_FILES=("srs_main_server" "srs_main_ingest_hls")
     # add each modules for main
     # add each modules for main
     for SRS_MODULE in ${SRS_MODULES[*]}; do
     for SRS_MODULE in ${SRS_MODULES[*]}; do

@@ -455,14 +455,6 @@ int SrsRtmpConn::stream_service_cycle()
         case SrsRtmpConnPlay: {
         case SrsRtmpConnPlay: {
             srs_verbose("start to play stream %s.", req->stream.c_str());
             srs_verbose("start to play stream %s.", req->stream.c_str());
             
             
-            if (vhost_is_edge) {
-                // notice edge to start for the first client.
-                if ((ret = source->on_edge_start_play()) != ERROR_SUCCESS) {
-                    srs_error("notice edge start play stream failed. ret=%d", ret);
-                    return ret;
-                }
-            }
-            
             // response connection start play
             // response connection start play
             if ((ret = rtmp->start_play(res->stream_id)) != ERROR_SUCCESS) {
             if ((ret = rtmp->start_play(res->stream_id)) != ERROR_SUCCESS) {
                 srs_error("start to play stream failed. ret=%d", ret);
                 srs_error("start to play stream failed. ret=%d", ret);
@@ -482,13 +474,6 @@ int SrsRtmpConn::stream_service_cycle()
         case SrsRtmpConnFMLEPublish: {
         case SrsRtmpConnFMLEPublish: {
             srs_verbose("FMLE start to publish stream %s.", req->stream.c_str());
             srs_verbose("FMLE start to publish stream %s.", req->stream.c_str());
             
             
-            if (vhost_is_edge) {
-                if ((ret = source->on_edge_start_publish()) != ERROR_SUCCESS) {
-                    srs_error("notice edge start publish stream failed. ret=%d", ret);
-                    return ret;
-                }
-            }
-            
             if ((ret = rtmp->start_fmle_publish(res->stream_id)) != ERROR_SUCCESS) {
             if ((ret = rtmp->start_fmle_publish(res->stream_id)) != ERROR_SUCCESS) {
                 srs_error("start to publish stream failed. ret=%d", ret);
                 srs_error("start to publish stream failed. ret=%d", ret);
                 return ret;
                 return ret;
@@ -511,13 +496,6 @@ int SrsRtmpConn::stream_service_cycle()
         case SrsRtmpConnFlashPublish: {
         case SrsRtmpConnFlashPublish: {
             srs_verbose("flash start to publish stream %s.", req->stream.c_str());
             srs_verbose("flash start to publish stream %s.", req->stream.c_str());
             
             
-            if (vhost_is_edge) {
-                if ((ret = source->on_edge_start_publish()) != ERROR_SUCCESS) {
-                    srs_error("notice edge start publish stream failed. ret=%d", ret);
-                    return ret;
-                }
-            }
-            
             if ((ret = rtmp->start_flash_publish(res->stream_id)) != ERROR_SUCCESS) {
             if ((ret = rtmp->start_flash_publish(res->stream_id)) != ERROR_SUCCESS) {
                 srs_error("flash start to publish stream failed. ret=%d", ret);
                 srs_error("flash start to publish stream failed. ret=%d", ret);
                 return ret;
                 return ret;
@@ -596,6 +574,14 @@ int SrsRtmpConn::playing(SrsSource* source)
     }
     }
     SrsAutoFree(SrsConsumer, consumer);
     SrsAutoFree(SrsConsumer, consumer);
     srs_verbose("consumer created success.");
     srs_verbose("consumer created success.");
+
+    if (_srs_config->get_vhost_is_edge(req->vhost)) {
+        // notice edge to start for the first client.
+        if ((ret = source->on_edge_start_play()) != ERROR_SUCCESS) {
+            srs_error("notice edge start play stream failed. ret=%d", ret);
+            return ret;
+        }
+    }
     
     
     // use isolate thread to recv, 
     // use isolate thread to recv, 
     // @see: https://github.com/simple-rtmp-server/srs/issues/217
     // @see: https://github.com/simple-rtmp-server/srs/issues/217
@@ -874,6 +860,11 @@ int SrsRtmpConn::do_publishing(SrsSource* source, SrsPublishRecvThread* trd)
             return ret;
             return ret;
         }
         }
         srs_verbose("hls on_publish success.");
         srs_verbose("hls on_publish success.");
+    } else {
+        if ((ret = source->on_edge_start_publish()) != ERROR_SUCCESS) {
+            srs_error("notice edge start publish stream failed. ret=%d", ret);
+            return ret;
+        }
     }
     }
 
 
     // start isolate recv thread.
     // start isolate recv thread.