external/srs
1
0
Fork 0
mirror of https://github.com/ossrs/srs.git synced 2025-03-09 15:49:59 +00:00
Code Issues Releases Wiki Activity

For #1634, refactor encoder process management.

Browse source
This commit is contained in:
winlin 2020-03-11 19:08:36 +08:00
parent 927c0c8e39
commit 66b194cd63
1 changed files with 7 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

12
trunk/src/app/srs_app_encoder.cpp
View file

@ -94,15 +94,17 @@ srs_error_t SrsEncoder::cycle()
srs_error_t err = srs_success; srs_error_t err = srs_success;
while (true) { while (true) {
if ((err = do_cycle()) != srs_success) { // We always check status first.
srs_warn("Encoder: Ignore error, %s", srs_error_desc(err).c_str()); // @see https://github.com/ossrs/srs/issues/1634#issuecomment-597571561
srs_error_reset(err);
}
if ((err = trd->pull()) != srs_success) { if ((err = trd->pull()) != srs_success) {
err = srs_error_wrap(err, "encoder"); err = srs_error_wrap(err, "encoder");
break; break;
} }
if ((err = do_cycle()) != srs_success) {
srs_warn("Encoder: Ignore error, %s", srs_error_desc(err).c_str());
srs_error_reset(err);
}
srs_usleep(SRS_RTMP_ENCODER_CIMS); srs_usleep(SRS_RTMP_ENCODER_CIMS);
} }