winlin

add todo for reload the source components.

@@ -1160,6 +1160,8 @@ int SrsSource::on_reload_vhost_forward(string vhost) @@ -1160,6 +1160,8 @@ int SrsSource::on_reload_vhost_forward(string vhost)
1160 if (_req->vhost != vhost) { 1160 if (_req->vhost != vhost) {
1161 return ret; 1161 return ret;
1162 } 1162 }
  1163 +
  1164 + // TODO: FIXME: maybe should ignore when publish already stopped?
1163 1165
1164 // forwarders 1166 // forwarders
1165 destroy_forwarders(); 1167 destroy_forwarders();
@@ -1181,6 +1183,8 @@ int SrsSource::on_reload_vhost_hls(string vhost) @@ -1181,6 +1183,8 @@ int SrsSource::on_reload_vhost_hls(string vhost)
1181 return ret; 1183 return ret;
1182 } 1184 }
1183 1185
  1186 + // TODO: FIXME: maybe should ignore when publish already stopped?
  1187 +
1184 #ifdef SRS_AUTO_HLS 1188 #ifdef SRS_AUTO_HLS
1185 hls->on_unpublish(); 1189 hls->on_unpublish();
1186 if ((ret = hls->on_publish(_req)) != ERROR_SUCCESS) { 1190 if ((ret = hls->on_publish(_req)) != ERROR_SUCCESS) {
@@ -1200,6 +1204,8 @@ int SrsSource::on_reload_vhost_hds(string vhost) @@ -1200,6 +1204,8 @@ int SrsSource::on_reload_vhost_hds(string vhost)
1200 if (_req->vhost != vhost) { 1204 if (_req->vhost != vhost) {
1201 return ret; 1205 return ret;
1202 } 1206 }
  1207 +
  1208 + // TODO: FIXME: maybe should ignore when publish already stopped?
1203 1209
1204 #ifdef SRS_AUTO_HDS 1210 #ifdef SRS_AUTO_HDS
1205 hds->on_unpublish(); 1211 hds->on_unpublish();
@@ -1221,6 +1227,8 @@ int SrsSource::on_reload_vhost_dvr(string vhost) @@ -1221,6 +1227,8 @@ int SrsSource::on_reload_vhost_dvr(string vhost)
1221 return ret; 1227 return ret;
1222 } 1228 }
1223 1229
  1230 + // TODO: FIXME: maybe should ignore when publish already stopped?
  1231 +
1224 #ifdef SRS_AUTO_DVR 1232 #ifdef SRS_AUTO_DVR
1225 // cleanup dvr 1233 // cleanup dvr
1226 dvr->on_unpublish(); 1234 dvr->on_unpublish();
@@ -1250,6 +1258,8 @@ int SrsSource::on_reload_vhost_transcode(string vhost) @@ -1250,6 +1258,8 @@ int SrsSource::on_reload_vhost_transcode(string vhost)
1250 return ret; 1258 return ret;
1251 } 1259 }
1252 1260
  1261 + // TODO: FIXME: maybe should ignore when publish already stopped?
  1262 +
1253 #ifdef SRS_AUTO_TRANSCODE 1263 #ifdef SRS_AUTO_TRANSCODE
1254 encoder->on_unpublish(); 1264 encoder->on_unpublish();
1255 if ((ret = encoder->on_publish(_req)) != ERROR_SUCCESS) { 1265 if ((ret = encoder->on_publish(_req)) != ERROR_SUCCESS) {
@@ -1270,6 +1280,8 @@ int SrsSource::on_reload_vhost_exec(string vhost) @@ -1270,6 +1280,8 @@ int SrsSource::on_reload_vhost_exec(string vhost)
1270 return ret; 1280 return ret;
1271 } 1281 }
1272 1282
  1283 + // TODO: FIXME: maybe should ignore when publish already stopped?
  1284 +
1273 ng_exec->on_unpublish(); 1285 ng_exec->on_unpublish();
1274 if ((ret = ng_exec->on_publish(_req)) != ERROR_SUCCESS) { 1286 if ((ret = ng_exec->on_publish(_req)) != ERROR_SUCCESS) {
1275 srs_error("start exec failed. ret=%d", ret); 1287 srs_error("start exec failed. ret=%d", ret);