mirror of
https://github.com/aler9/gortsplib
synced 2025-10-05 07:06:58 +08:00
server: if TCP frames are written before the PLAY response, queue and send them anyway, like UDP already does
This commit is contained in:
@@ -425,6 +425,7 @@ func (sc *ServerConn) frameModeDisable() {
|
||||
sc.tcpFrameEnabled = false
|
||||
sc.tcpFrameWriteBuffer.Close()
|
||||
<-sc.tcpBackgroundWriteDone
|
||||
sc.tcpFrameWriteBuffer.Reset()
|
||||
|
||||
} else {
|
||||
for _, track := range sc.setuppedTracks {
|
||||
@@ -443,6 +444,7 @@ func (sc *ServerConn) frameModeDisable() {
|
||||
sc.tcpFrameEnabled = false
|
||||
sc.tcpFrameWriteBuffer.Close()
|
||||
<-sc.tcpBackgroundWriteDone
|
||||
sc.tcpFrameWriteBuffer.Reset()
|
||||
|
||||
} else {
|
||||
for _, track := range sc.setuppedTracks {
|
||||
@@ -1065,7 +1067,6 @@ func (sc *ServerConn) handleRequestOuter(req *base.Request) error {
|
||||
res.Write(sc.bw)
|
||||
|
||||
// start background write
|
||||
sc.tcpFrameWriteBuffer.Reset()
|
||||
sc.tcpBackgroundWriteDone = make(chan struct{})
|
||||
go sc.tcpBackgroundWrite()
|
||||
|
||||
|
@@ -272,7 +272,7 @@ y++U32uuSFiXDcSLarfIsE992MEJLSAynbF1Rsgsr3gXbGiuToJRyxbIeVy7gwzD
|
||||
-----END RSA PRIVATE KEY-----
|
||||
`)
|
||||
|
||||
func TestServerPublishReadHighLevel(t *testing.T) {
|
||||
func TestServerHighLevelPublishRead(t *testing.T) {
|
||||
for _, ca := range []struct {
|
||||
encrypted bool
|
||||
publisherSoft string
|
||||
|
@@ -518,7 +518,7 @@ func TestServerPublishRecordErrorPartialTracks(t *testing.T) {
|
||||
require.Equal(t, "not all announced tracks have been setup", err.Error())
|
||||
}
|
||||
|
||||
func TestServerPublishFrames(t *testing.T) {
|
||||
func TestServerPublish(t *testing.T) {
|
||||
for _, proto := range []string{
|
||||
"udp",
|
||||
"tcp",
|
||||
@@ -711,7 +711,7 @@ func TestServerPublishFrames(t *testing.T) {
|
||||
}
|
||||
}
|
||||
|
||||
func TestServerPublishFramesErrorWrongProtocol(t *testing.T) {
|
||||
func TestServerPublishErrorWrongProtocol(t *testing.T) {
|
||||
conf := ServerConf{
|
||||
UDPRTPAddress: "127.0.0.1:8000",
|
||||
UDPRTCPAddress: "127.0.0.1:8001",
|
||||
|
@@ -291,7 +291,7 @@ func TestServerReadSetupErrorTrackTwice(t *testing.T) {
|
||||
require.Equal(t, "track 0 has already been setup", err.Error())
|
||||
}
|
||||
|
||||
func TestServerReadFrames(t *testing.T) {
|
||||
func TestServerRead(t *testing.T) {
|
||||
for _, proto := range []string{
|
||||
"udp",
|
||||
"tcp",
|
||||
@@ -324,6 +324,9 @@ func TestServerReadFrames(t *testing.T) {
|
||||
}
|
||||
|
||||
onPlay := func(ctx *ServerConnPlayCtx) (*base.Response, error) {
|
||||
conn.WriteFrame(0, StreamTypeRTP, []byte{0x01, 0x02, 0x03, 0x04})
|
||||
conn.WriteFrame(0, StreamTypeRTCP, []byte{0x05, 0x06, 0x07, 0x08})
|
||||
|
||||
return &base.Response{
|
||||
StatusCode: base.StatusOK,
|
||||
}, nil
|
||||
@@ -386,6 +389,14 @@ func TestServerReadFrames(t *testing.T) {
|
||||
err = th.Read(res.Header["Transport"])
|
||||
require.NoError(t, err)
|
||||
|
||||
l1, err := net.ListenPacket("udp", "localhost:35466")
|
||||
require.NoError(t, err)
|
||||
defer l1.Close()
|
||||
|
||||
l2, err := net.ListenPacket("udp", "localhost:35467")
|
||||
require.NoError(t, err)
|
||||
defer l2.Close()
|
||||
|
||||
err = base.Request{
|
||||
Method: base.Play,
|
||||
URL: base.MustParseURL("rtsp://localhost:8554/teststream"),
|
||||
@@ -399,14 +410,36 @@ func TestServerReadFrames(t *testing.T) {
|
||||
require.NoError(t, err)
|
||||
require.Equal(t, base.StatusOK, res.StatusCode)
|
||||
|
||||
// server -> client
|
||||
if proto == "udp" {
|
||||
time.Sleep(1 * time.Second)
|
||||
|
||||
l1, err := net.ListenPacket("udp", "localhost:35467")
|
||||
buf := make([]byte, 2048)
|
||||
n, _, err := l1.ReadFrom(buf)
|
||||
require.NoError(t, err)
|
||||
defer l1.Close()
|
||||
require.Equal(t, []byte{0x01, 0x02, 0x03, 0x04}, buf[:n])
|
||||
|
||||
l1.WriteTo([]byte{0x01, 0x02, 0x03, 0x04}, &net.UDPAddr{
|
||||
buf = make([]byte, 2048)
|
||||
n, _, err = l2.ReadFrom(buf)
|
||||
require.NoError(t, err)
|
||||
require.Equal(t, []byte{0x05, 0x06, 0x07, 0x08}, buf[:n])
|
||||
|
||||
} else {
|
||||
var f base.InterleavedFrame
|
||||
f.Payload = make([]byte, 2048)
|
||||
err := f.Read(bconn.Reader)
|
||||
require.NoError(t, err)
|
||||
require.Equal(t, StreamTypeRTP, f.StreamType)
|
||||
require.Equal(t, []byte{0x01, 0x02, 0x03, 0x04}, f.Payload)
|
||||
|
||||
f.Payload = make([]byte, 2048)
|
||||
err = f.Read(bconn.Reader)
|
||||
require.NoError(t, err)
|
||||
require.Equal(t, StreamTypeRTCP, f.StreamType)
|
||||
require.Equal(t, []byte{0x05, 0x06, 0x07, 0x08}, f.Payload)
|
||||
}
|
||||
|
||||
// client -> server (RTCP)
|
||||
if proto == "udp" {
|
||||
l2.WriteTo([]byte{0x01, 0x02, 0x03, 0x04}, &net.UDPAddr{
|
||||
IP: net.ParseIP("127.0.0.1"),
|
||||
Port: th.ServerPorts[1],
|
||||
})
|
||||
|
Reference in New Issue
Block a user