正在显示
1 个修改的文件
包含
1 行增加
和
4 行删除
@@ -1039,10 +1039,7 @@ int SrsProtocol::do_send_messages(SrsSharedPtrMessage** msgs, int nb_msgs) | @@ -1039,10 +1039,7 @@ int SrsProtocol::do_send_messages(SrsSharedPtrMessage** msgs, int nb_msgs) | ||
1039 | iov[0].iov_len = nbh; | 1039 | iov[0].iov_len = nbh; |
1040 | 1040 | ||
1041 | // payload iov | 1041 | // payload iov |
1042 | - int payload_size = pend - p; | ||
1043 | - if (payload_size > out_chunk_size) { | ||
1044 | - payload_size = out_chunk_size; | ||
1045 | - } | 1042 | + int payload_size = srs_min(out_chunk_size, pend - p); |
1046 | iov[1].iov_base = p; | 1043 | iov[1].iov_base = p; |
1047 | iov[1].iov_len = payload_size; | 1044 | iov[1].iov_len = payload_size; |
1048 | 1045 |
-
请 注册 或 登录 后发表评论