package/gortsplib
1
0
Fork 0
mirror of https://github.com/aler9/gortsplib synced 2025-10-05 23:26:54 +08:00
Code Issues Packages Projects Releases Wiki Activity

ServerConn: add trackID to OnSetup

Browse Source
This commit is contained in:
aler9
2021-01-06 19:37:38 +01:00
parent f455a7b6c1
commit 0fa011bf1a
5 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
examples/server-tls.go
View File

@@ -74,7 +74,7 @@ func handleConn(conn *gortsplib.ServerConn) {
} }
// called after receiving a SETUP request. // called after receiving a SETUP request.
onSetup := func(req *base.Request, th *headers.Transport) (*base.Response, error) { onSetup := func(req *base.Request, th *headers.Transport, trackID int) (*base.Response, error) {
return &base.Response{ return &base.Response{
StatusCode: base.StatusOK, StatusCode: base.StatusOK,
Header: base.Header{ Header: base.Header{

2
examples/server-udp.go
View File

@@ -73,7 +73,7 @@ func handleConn(conn *gortsplib.ServerConn) {
} }
// called after receiving a SETUP request. // called after receiving a SETUP request.
onSetup := func(req *base.Request, th *headers.Transport) (*base.Response, error) { onSetup := func(req *base.Request, th *headers.Transport, trackID int) (*base.Response, error) {
return &base.Response{ return &base.Response{
StatusCode: base.StatusOK, StatusCode: base.StatusOK,
Header: base.Header{ Header: base.Header{

2
examples/server.go
View File

@@ -73,7 +73,7 @@ func handleConn(conn *gortsplib.ServerConn) {
} }
// called after receiving a SETUP request. // called after receiving a SETUP request.
onSetup := func(req *base.Request, th *headers.Transport) (*base.Response, error) { onSetup := func(req *base.Request, th *headers.Transport, trackID int) (*base.Response, error) {
return &base.Response{ return &base.Response{
StatusCode: base.StatusOK, StatusCode: base.StatusOK,
Header: base.Header{ Header: base.Header{

2
serverconf_test.go
View File

@@ -142,7 +142,7 @@ func (ts *testServ) handleConn(conn *ServerConn) {
}, nil }, nil
} }
onSetup := func(req *base.Request, th *headers.Transport) (*base.Response, error) { onSetup := func(req *base.Request, th *headers.Transport, trackID int) (*base.Response, error) {
return &base.Response{ return &base.Response{
StatusCode: base.StatusOK, StatusCode: base.StatusOK,
Header: base.Header{ Header: base.Header{

4
serverconn.go
View File

@@ -99,7 +99,7 @@ type ServerConnReadHandlers struct {
OnAnnounce func(req *base.Request, tracks Tracks) (*base.Response, error) OnAnnounce func(req *base.Request, tracks Tracks) (*base.Response, error)
// called after receiving a SETUP request. // called after receiving a SETUP request.
OnSetup func(req *base.Request, th *headers.Transport) (*base.Response, error) OnSetup func(req *base.Request, th *headers.Transport, trackID int) (*base.Response, error)
// called after receiving a PLAY request. // called after receiving a PLAY request.
OnPlay func(req *base.Request) (*base.Response, error) OnPlay func(req *base.Request) (*base.Response, error)
@@ -444,7 +444,7 @@ func (sc *ServerConn) handleRequest(req *base.Request) (*base.Response, error) {
} }
} }
res, err := sc.readHandlers.OnSetup(req, th) res, err := sc.readHandlers.OnSetup(req, th, trackID)
if res.StatusCode == 200 { if res.StatusCode == 200 {
sc.tracksProtocol = &th.Protocol sc.tracksProtocol = &th.Protocol