winlin

refine the ingest log

@@ -129,7 +129,8 @@ int SrsIngester::parse_engines(SrsConfDirective* vhost, SrsConfDirective* ingest @@ -129,7 +129,8 @@ int SrsIngester::parse_engines(SrsConfDirective* vhost, SrsConfDirective* ingest
129 if ((ret = initialize_ffmpeg(ffmpeg, vhost, ingest, engine)) != ERROR_SUCCESS) { 129 if ((ret = initialize_ffmpeg(ffmpeg, vhost, ingest, engine)) != ERROR_SUCCESS) {
130 srs_freep(ffmpeg); 130 srs_freep(ffmpeg);
131 if (ret != ERROR_ENCODER_LOOP) { 131 if (ret != ERROR_ENCODER_LOOP) {
132 - srs_error("invalid ingest engine: %s %s", ingest->arg0().c_str(), engine->arg0().c_str()); 132 + srs_error("invalid ingest engine: %s %s, ret=%d",
  133 + ingest->arg0().c_str(), engine->arg0().c_str(), ret);
133 } 134 }
134 return ret; 135 return ret;
135 } 136 }
@@ -223,7 +224,7 @@ int SrsIngester::initialize_ffmpeg(SrsFFMPEG* ffmpeg, SrsConfDirective* vhost, S @@ -223,7 +224,7 @@ int SrsIngester::initialize_ffmpeg(SrsFFMPEG* ffmpeg, SrsConfDirective* vhost, S
223 output = srs_string_replace(output, "[port]", port); 224 output = srs_string_replace(output, "[port]", port);
224 if (output.empty()) { 225 if (output.empty()) {
225 ret = ERROR_ENCODER_NO_OUTPUT; 226 ret = ERROR_ENCODER_NO_OUTPUT;
226 - srs_trace("empty ingest output url. ret=%d", ret); 227 + srs_trace("empty output url, ingest=%s. ret=%d", ingest->arg0().c_str(), ret);
227 return ret; 228 return ret;
228 } 229 }
229 230
@@ -267,7 +268,7 @@ int SrsIngester::initialize_ffmpeg(SrsFFMPEG* ffmpeg, SrsConfDirective* vhost, S @@ -267,7 +268,7 @@ int SrsIngester::initialize_ffmpeg(SrsFFMPEG* ffmpeg, SrsConfDirective* vhost, S
267 std::string input_type = _srs_config->get_ingest_input_type(ingest); 268 std::string input_type = _srs_config->get_ingest_input_type(ingest);
268 if (input_type.empty()) { 269 if (input_type.empty()) {
269 ret = ERROR_ENCODER_NO_INPUT; 270 ret = ERROR_ENCODER_NO_INPUT;
270 - srs_trace("empty ingest intput type. ret=%d", ret); 271 + srs_trace("empty intput type, ingest=%s. ret=%d", ingest->arg0().c_str(), ret);
271 return ret; 272 return ret;
272 } 273 }
273 274
@@ -275,7 +276,7 @@ int SrsIngester::initialize_ffmpeg(SrsFFMPEG* ffmpeg, SrsConfDirective* vhost, S @@ -275,7 +276,7 @@ int SrsIngester::initialize_ffmpeg(SrsFFMPEG* ffmpeg, SrsConfDirective* vhost, S
275 std::string input_url = _srs_config->get_ingest_input_url(ingest); 276 std::string input_url = _srs_config->get_ingest_input_url(ingest);
276 if (input_url.empty()) { 277 if (input_url.empty()) {
277 ret = ERROR_ENCODER_NO_INPUT; 278 ret = ERROR_ENCODER_NO_INPUT;
278 - srs_trace("empty ingest intput url. ret=%d", ret); 279 + srs_trace("empty intput url, ingest=%s. ret=%d", ingest->arg0().c_str(), ret);
279 return ret; 280 return ret;
280 } 281 }
281 282
@@ -289,7 +290,7 @@ int SrsIngester::initialize_ffmpeg(SrsFFMPEG* ffmpeg, SrsConfDirective* vhost, S @@ -289,7 +290,7 @@ int SrsIngester::initialize_ffmpeg(SrsFFMPEG* ffmpeg, SrsConfDirective* vhost, S
289 std::string input_url = _srs_config->get_ingest_input_url(ingest); 290 std::string input_url = _srs_config->get_ingest_input_url(ingest);
290 if (input_url.empty()) { 291 if (input_url.empty()) {
291 ret = ERROR_ENCODER_NO_INPUT; 292 ret = ERROR_ENCODER_NO_INPUT;
292 - srs_trace("empty ingest intput url. ret=%d", ret); 293 + srs_trace("empty intput url, ingest=%s. ret=%d", ingest->arg0().c_str(), ret);
293 return ret; 294 return ret;
294 } 295 }
295 296
@@ -301,13 +302,16 @@ int SrsIngester::initialize_ffmpeg(SrsFFMPEG* ffmpeg, SrsConfDirective* vhost, S @@ -301,13 +302,16 @@ int SrsIngester::initialize_ffmpeg(SrsFFMPEG* ffmpeg, SrsConfDirective* vhost, S
301 } 302 }
302 } else { 303 } else {
303 ret = ERROR_ENCODER_INPUT_TYPE; 304 ret = ERROR_ENCODER_INPUT_TYPE;
304 - srs_error("invalid ingest type=%s, ret=%d", input_type.c_str(), ret); 305 + srs_error("invalid ingest=%s type=%s, ret=%d",
  306 + ingest->arg0().c_str(), input_type.c_str(), ret);
305 } 307 }
306 308
307 std::string vcodec = _srs_config->get_engine_vcodec(engine); 309 std::string vcodec = _srs_config->get_engine_vcodec(engine);
308 std::string acodec = _srs_config->get_engine_acodec(engine); 310 std::string acodec = _srs_config->get_engine_acodec(engine);
309 // whatever the engine config, use copy as default. 311 // whatever the engine config, use copy as default.
310 - if (!engine || !_srs_config->get_engine_enabled(engine) || vcodec.empty() || acodec.empty()) { 312 + if (!engine || vcodec.empty() || acodec.empty()
  313 + || !_srs_config->get_engine_enabled(engine)
  314 + ) {
311 if ((ret = ffmpeg->initialize_copy()) != ERROR_SUCCESS) { 315 if ((ret = ffmpeg->initialize_copy()) != ERROR_SUCCESS) {
312 return ret; 316 return ret;
313 } 317 }
@@ -317,6 +321,9 @@ int SrsIngester::initialize_ffmpeg(SrsFFMPEG* ffmpeg, SrsConfDirective* vhost, S @@ -317,6 +321,9 @@ int SrsIngester::initialize_ffmpeg(SrsFFMPEG* ffmpeg, SrsConfDirective* vhost, S
317 } 321 }
318 } 322 }
319 323
  324 + srs_trace("parse success, ingest=%s, vhost=%s",
  325 + ingest->arg0().c_str(), vhost->arg0().c_str());
  326 +
320 return ret; 327 return ret;
321 } 328 }
322 329