limit the user-space buffer size to 128KB, 128MB for 1k publishers.

@@ -429,7 +429,8 @@ void SrsPublishRecvThread::set_socket_buffer(int sleep_ms)
     // sleep 800ms for small bytes, the buffer should set to:
     // sleep 800ms for small bytes, the buffer should set to:
     //      800*1000/8=100000B(about 128KB).
     //      800*1000/8=100000B(about 128KB).
     //      2000*3000/8=750000B(about 732KB).
     //      2000*3000/8=750000B(about 732KB).
-    int kbps = 3000;
+    //      2000*5000/8=1250000B(about 1220KB).
+    int kbps = 5000;
     int socket_buffer_size = sleep_ms * kbps / 8;
     int socket_buffer_size = sleep_ms * kbps / 8;
 
 
     // socket recv buffer, system will double it.
     // socket recv buffer, system will double it.

@@ -28,8 +28,13 @@ CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 #include <srs_kernel_utility.hpp>
 #include <srs_kernel_utility.hpp>
 #include <srs_core_performance.hpp>
 #include <srs_core_performance.hpp>
 
 
-// the default recv buffer size
-#define SRS_DEFAULT_RECV_BUFFER_SIZE 32768
+// the default recv buffer size, 128KB.
+#define SRS_DEFAULT_RECV_BUFFER_SIZE 131072
+
+// limit user-space buffer to 256KB, for 3Mbps stream delivery.
+//      800*2000/8=200000B(about 195KB).
+// @remark it's ok for higher stream, the buffer is ok for one chunk is 256KB.
+#define SRS_MAX_SOCKET_BUFFER 262144
 
 
 // the max header size,
 // the max header size,
 // @see SrsProtocol::read_message_header().
 // @see SrsProtocol::read_message_header().
@@ -100,15 +105,21 @@ SrsFastBuffer::SrsFastBuffer()
 
 
 void SrsFastBuffer::set_buffer(int buffer_size)
 void SrsFastBuffer::set_buffer(int buffer_size)
 {
 {
+    // the user-space buffer size limit to a max value.
+    int nb_max_buf = srs_min(buffer_size, SRS_MAX_SOCKET_BUFFER);
+    if (nb_max_buf < buffer_size) {
+        srs_warn("limit the user-space buffer from %d to %d", buffer_size, nb_max_buf);
+    }
+
     // only realloc when buffer changed bigger
     // only realloc when buffer changed bigger
-    if (buffer_size <= nb_buffer) {
+    if (nb_max_buf <= nb_buffer) {
         return;
         return;
     }
     }
     
     
     int start = p - buffer;
     int start = p - buffer;
     int cap = end - p;
     int cap = end - p;
     
     
-    char* buf = new char[buffer_size];
+    char* buf = new char[nb_max_buf];
     if (cap > 0) {
     if (cap > 0) {
         memcpy(buf, buffer, nb_buffer);
         memcpy(buf, buffer, nb_buffer);
     }
     }