thefoxon/joy4
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

example: add skip interval

Browse Source
This commit is contained in:
nareix 2016-07-17 21:02:24 +08:00
parent cc5d6d4cae
commit a31aaeec9d
1 changed files with 16 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
examples/rtmp_server_channels/main.go
View File

@ -24,6 +24,7 @@ type FrameDropper struct {
lasttime time.Time lasttime time.Time
lastpkttime time.Duration lastpkttime time.Duration
delay time.Duration delay time.Duration
SkipInterval int
} }
func (self *FrameDropper) ModifyPacket(pkt *av.Packet, streams []av.CodecData, videoidx int, audioidx int) (drop bool, err error) { func (self *FrameDropper) ModifyPacket(pkt *av.Packet, streams []av.CodecData, videoidx int, audioidx int) (drop bool, err error) {
@ -50,6 +51,14 @@ func (self *FrameDropper) ModifyPacket(pkt *av.Packet, streams []av.CodecData, v
if self.skipping { if self.skipping {
drop = true drop = true
} }
if self.SkipInterval != 0 && pkt.IsKeyFrame {
if self.n == self.SkipInterval {
self.n = 0
self.skipping = true
}
self.n++
}
} }
if self.Interval != 0 { if self.Interval != 0 {
@ -100,7 +109,13 @@ func main() {
} }
if q := query.Get("delayskip"); q != "" { if q := query.Get("delayskip"); q != "" {
dur, _ := time.ParseDuration(q) dur, _ := time.ParseDuration(q)
filters = append(filters, &FrameDropper{DelaySkip: dur}) skipper := &FrameDropper{DelaySkip: dur}
if q := query.Get("skipinterval"); q != "" {
n := 0
fmt.Sscanf(q, "%d", &n)
skipper.SkipInterval = n
}
filters = append(filters, skipper)
} }
demuxer := &pktque.FilterDemuxer{ demuxer := &pktque.FilterDemuxer{
Filter: filters, Filter: filters,