external/srs
1
0
Fork 0
mirror of https://github.com/ossrs/srs.git synced 2025-03-09 15:49:59 +00:00
Code Issues Releases Wiki Activity

SRS5: Test: Add blackbox test for SRT.

Browse source 
PICK 62963b206f
This commit is contained in:
winlin 2023-01-05 09:03:12 +08:00
parent fe086dfc31
commit 232de03c56
2 changed files with 130 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

14
trunk/3rdparty/srs-bench/blackbox/util.go vendored
View file

@ -163,6 +163,8 @@ func (v *SRSPortAllocator) Allocate() int {
if _, ok := v.ports.LoadOrStore(port, true); !ok {
return port
}
time.Sleep(time.Duration(rand.Int()%1000) * time.Microsecond)
}
panic("Allocate port failed")
@ -395,6 +397,8 @@ type SRSServer interface {
RTMPPort() int
// HTTPPort is the HTTP stream port.
HTTPPort() int
// SRTPort is the SRT UDP port.
SRTPort() int
}
// srsServer is a SRS server instance.
@ -421,6 +425,8 @@ type srsServer struct {
apiListen int
// HTTP server listen port.
httpListen int
// SRT UDP server listen port.
srtListen int
// The envs from user.
envs []string
@ -446,12 +452,14 @@ func NewSRSServer(opts ...func(v *srsServer)) SRSServer {
v.rtmpListen = allocator.Allocate()
v.apiListen = allocator.Allocate()
v.httpListen = allocator.Allocate()
v.srtListen = allocator.Allocate()
// Do cleanup.
v.process.onDispose = func(ctx context.Context, bs *backendService) error {
allocator.Free(v.rtmpListen)
allocator.Free(v.apiListen)
allocator.Free(v.httpListen)
allocator.Free(v.srtListen)
pidFile := path.Join(v.workDir, v.srsRelativePidFile)
if _, err := os.Stat(pidFile); err == nil {
@ -491,6 +499,10 @@ func (v *srsServer) HTTPPort() int {
return v.httpListen
}
func (v *srsServer) SRTPort() int {
return v.srtListen
}
func (v *srsServer) WorkDir() string {
return v.workDir
}
@ -531,6 +543,8 @@ func (v *srsServer) Run(ctx context.Context, cancel context.CancelFunc) error {
fmt.Sprintf("SRS_LISTEN=%v", v.rtmpListen),
// Setup the HTTP sever listen port.
fmt.Sprintf("SRS_HTTP_SERVER_LISTEN=%v", v.httpListen),
// Setup the SRT server listen port.
fmt.Sprintf("SRS_SRT_SERVER_LISTEN=%v", v.srtListen),
}
// Rewrite envs by case.
if v.envs != nil {