From 5e896e79cba717f3b647df3a3f199ae0d3029b73 Mon Sep 17 00:00:00 2001
From: Paul Gregoire <mondain@gmail.com>
Date: Sat, 10 Feb 2024 11:19:12 -0800
Subject: [PATCH] Reduce rtmp max poll time
---
.../main/java/org/red5/server/net/rtmp/RTMPConnection.java | 4 ++--
server/src/main/server/conf/red5.properties | 2 +-
2 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/common/src/main/java/org/red5/server/net/rtmp/RTMPConnection.java b/common/src/main/java/org/red5/server/net/rtmp/RTMPConnection.java
index c1464300..ef393282 100755
--- a/common/src/main/java/org/red5/server/net/rtmp/RTMPConnection.java
+++ b/common/src/main/java/org/red5/server/net/rtmp/RTMPConnection.java
@@ -299,7 +299,7 @@ public abstract class RTMPConnection extends BaseConnection implements IStreamCa
/**
* Maximum time in milliseconds to wait for a message.
*/
- private long maxPollTimeout = 10000L;
+ private long maxPollTimeout = 1000L;
/**
* Bandwidth limit type / enforcement. (0=hard,1=soft,2=dynamic)
@@ -1443,7 +1443,7 @@ public abstract class RTMPConnection extends BaseConnection implements IStreamCa
try {
do {
// DTS appears to be off only by < 10ms
- Packet p = receivedPacketQueue.poll(maxPollTimeout, TimeUnit.MILLISECONDS); // wait for a packet up to 10 seconds
+ Packet p = receivedPacketQueue.poll(maxPollTimeout, TimeUnit.MILLISECONDS); // wait for packet with timeout
if (p != null) {
if (isTrace) {
log.trace("Handle received packet: {}", p);
diff --git a/server/src/main/server/conf/red5.properties b/server/src/main/server/conf/red5.properties
index 36242b41..ee5852f2 100644
--- a/server/src/main/server/conf/red5.properties
+++ b/server/src/main/server/conf/red5.properties
@@ -24,7 +24,7 @@ rtmp.ping_interval=1000
rtmp.max_inactivity=60000
rtmp.max_handshake_time=5000
# maximum time to wait for a message while polling in milliseconds
-rtmp.max_poll_time=10000
+rtmp.max_poll_time=1000
rtmp.tcp_nodelay=true
rtmp.tcp_keepalive=false
rtmp.default_server_bandwidth=10000000
--
GitLab