Skip to content

Commit ad923a9

Browse files
committed
Improve README and error message.
1 parent ee3ecc9 commit ad923a9

File tree

3 files changed

+19
-6
lines changed

3 files changed

+19
-6
lines changed

README.md

Lines changed: 12 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,17 @@
11
# proxy-go
22

3-
A RTMP/SRT/WebRTC/WHIP/WHEP/HLS/HTTP-FLV proxy for media server.
3+
An common proxy server for any media servers with RTMP/SRT/HLS/HTTP-FLV and
4+
WebRTC/WHIP/WHEP protocols support.
45

56
## Usage
67

7-
See [SRS Origin Cluster](https://ossrs.io/lts/en-us/docs/v7/doc/origin-cluster) for details.
8+
This is a common proxy for all media servers, to enable you to build a Origin Cluster
9+
for your media server.
10+
11+
However, SRS works with this proxy much better than other media servers, as the proxy
12+
can discover more details from SRS. And this proxy is the official solution to build
13+
an origin cluster for SRS. Please see [SRS Origin Cluster](https://ossrs.io/lts/en-us/docs/v7/doc/origin-cluster)
14+
for details.
15+
16+
William Yang<br/>
17+
June 23, 2025

rtc.go

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -13,6 +13,7 @@ import (
1313
"strconv"
1414
"strings"
1515
stdSync "sync"
16+
"time"
1617

1718
"srs-proxy/errors"
1819
"srs-proxy/logger"
@@ -258,12 +259,13 @@ func (v *srsWebRTCServer) Run(ctx context.Context) error {
258259
n, caddr, err := listener.ReadFromUDP(buf)
259260
if err != nil {
260261
// TODO: If WebRTC server closed unexpectedly, we should notice the main loop to quit.
261-
logger.Wf(ctx, "read from udp failed, err=%+v", err)
262+
logger.Wf(ctx, "WebRTC read from udp failed, err=%+v", err)
263+
time.Sleep(1 * time.Second)
262264
continue
263265
}
264266

265267
if err := v.handleClientUDP(ctx, caddr, buf[:n]); err != nil {
266-
logger.Wf(ctx, "handle udp %vB failed, addr=%v, err=%+v", n, caddr, err)
268+
logger.Wf(ctx, "WebRTC handle udp %vB failed, addr=%v, err=%+v", n, caddr, err)
267269
}
268270
}
269271
}()

srt.go

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -83,12 +83,13 @@ func (v *srsSRTServer) Run(ctx context.Context) error {
8383
n, caddr, err := v.listener.ReadFromUDP(buf)
8484
if err != nil {
8585
// TODO: If SRT server closed unexpectedly, we should notice the main loop to quit.
86-
logger.Wf(ctx, "read from udp failed, err=%+v", err)
86+
logger.Wf(ctx, "SRT read from udp failed, err=%+v", err)
87+
time.Sleep(1 * time.Second)
8788
continue
8889
}
8990

9091
if err := v.handleClientUDP(ctx, caddr, buf[:n]); err != nil {
91-
logger.Wf(ctx, "handle udp %vB failed, addr=%v, err=%+v", n, caddr, err)
92+
logger.Wf(ctx, "SRT handle udp %vB failed, addr=%v, err=%+v", n, caddr, err)
9293
}
9394
}
9495
}()

0 commit comments

Comments
 (0)