torjus/dogtamer
1
0
Fork 0
Code Issues Pull Requests Projects Releases 1 Wiki Activity

Stop logging each dropped packet

Browse Source
This commit is contained in:
Torjus Håkestad
2021-10-18 21:57:10 +02:00
parent 00414e100a
commit fa8b577989
4 changed files with 35 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
server/rtmp.go
View File

@@ -30,7 +30,8 @@ type RTMPClient struct {
keyframeSent bool
bytesSent atomic.Uint64
bytesSent atomic.Uint64
droppedPackets atomic.Uint64
packetsChan chan av.Packet
}
@@ -159,7 +160,12 @@ func (s *Stream) handleBroadcaster(c *rtmp.Conn, nc net.Conn) {
s.bytesSent.Add(uint64(len(pkt.Data)))
continue
default:
logger.Info("Client channel is blocking.", zap.String("client_addr", client.nc.RemoteAddr().String()))
dropped := client.droppedPackets.Inc()
if dropped%1000 == 0 {
logger.Info("Multiple packets to client have been dropped.",
zap.String("client_addr", client.nc.RemoteAddr().String()),
zap.Uint64("dropped_packets", dropped))
}
}
}
}
@@ -177,7 +183,8 @@ func (client *RTMPClient) handleClient() {
"client_addr", client.nc.RemoteAddr().String(),
"stream_name", stream.Name,
"watch_duration", time.Since(client.timestamp),
"bytes_sent", humanize.Bytes(client.bytesSent.Load()))
"bytes_sent", humanize.Bytes(client.bytesSent.Load()),
"dropped_packets", client.droppedPackets.Load())
}()
server.Logger.Infow("Viewer connected.", "stream", stream.Name, "client_addr", client.nc.RemoteAddr().String())