正在显示
1 个修改的文件
包含
3 行增加
和
3 行删除
| @@ -750,9 +750,9 @@ int SrsRtmpConn::do_publishing(SrsSource* source, SrsPublishRecvThread* trd) | @@ -750,9 +750,9 @@ int SrsRtmpConn::do_publishing(SrsSource* source, SrsPublishRecvThread* trd) | ||
| 750 | 750 | ||
| 751 | int64_t nb_msgs = 0; | 751 | int64_t nb_msgs = 0; |
| 752 | while (true) { | 752 | while (true) { |
| 753 | - // use small loop to check the error code, interval = 30s/100 = 300ms. | ||
| 754 | - for (int i = 0; i < 100; i++) { | ||
| 755 | - st_usleep(SRS_CONSTS_RTMP_RECV_TIMEOUT_US / 100); | 753 | + // use small loop to check the error code, interval = 30s/43 = 697ms. |
| 754 | + for (int i = 0; i < 43; i++) { | ||
| 755 | + st_usleep(SRS_CONSTS_RTMP_RECV_TIMEOUT_US / 43); | ||
| 756 | 756 | ||
| 757 | // check the thread error code. | 757 | // check the thread error code. |
| 758 | if ((ret = trd->error_code()) != ERROR_SUCCESS) { | 758 | if ((ret = trd->error_code()) != ERROR_SUCCESS) { |
-
请 注册 或 登录 后发表评论