From 99e60dab553c5e183dd62a9b95d6fb0195290cc2 Mon Sep 17 00:00:00 2001 From: joestarzxh Date: Sun, 6 Feb 2022 12:16:59 +0800 Subject: [PATCH] =?UTF-8?q?[opt]rtsp=20sub=20=E9=98=BB=E5=A1=9E=E5=8F=91?= =?UTF-8?q?=E9=80=81=E4=BF=AE=E6=94=B9=E4=B8=BA=E5=BC=82=E6=AD=A5=E5=8F=91?= =?UTF-8?q?=E9=80=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- pkg/rtsp/rtsp.go | 3 ++- pkg/rtsp/server_command_session.go | 1 + 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/pkg/rtsp/rtsp.go b/pkg/rtsp/rtsp.go index cdc5126..a4c1e8a 100644 --- a/pkg/rtsp/rtsp.go +++ b/pkg/rtsp/rtsp.go @@ -85,7 +85,8 @@ var ( unpackerItemMaxSize = 1024 - serverCommandSessionReadBufSize = 256 + serverCommandSessionReadBufSize = 256 + serverCommandSessionWriteChanSize = 1024 dummyRtpPacket = []byte{ 0x80, 0x00, 0x00, 0x00, diff --git a/pkg/rtsp/server_command_session.go b/pkg/rtsp/server_command_session.go index f66458e..667139e 100644 --- a/pkg/rtsp/server_command_session.go +++ b/pkg/rtsp/server_command_session.go @@ -67,6 +67,7 @@ func NewServerCommandSession(observer ServerCommandSessionObserver, conn net.Con observer: observer, conn: connection.New(conn, func(option *connection.Option) { option.ReadBufSize = serverCommandSessionReadBufSize + option.WriteChanSize = serverCommandSessionWriteChanSize }), }