Skip to content

Commit 0183b00

Browse files
committed
Support pcap.
1 parent fad8faf commit 0183b00

File tree

1 file changed

+14
-4
lines changed
  • trunk/3rdparty/srs-bench/pcap

1 file changed

+14
-4
lines changed

trunk/3rdparty/srs-bench/pcap/main.go

+14-4
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,7 @@ import (
77
"fmt"
88
"net"
99
"os"
10+
"strings"
1011
"time"
1112

1213
"github.com/google/gopacket"
@@ -62,9 +63,19 @@ func doMain(ctx context.Context) error {
6263
}
6364
defer f.Close()
6465

65-
r, err := pcapgo.NewNgReader(f, pcapgo.DefaultNgReaderOptions)
66-
if err != nil {
67-
return errors.Wrapf(err, "new reader")
66+
var source *gopacket.PacketSource
67+
if strings.HasSuffix(filename, ".pcap") {
68+
r, err := pcapgo.NewReader(f)
69+
if err != nil {
70+
return errors.Wrapf(err, "new reader")
71+
}
72+
source = gopacket.NewPacketSource(r, r.LinkType())
73+
} else {
74+
r, err := pcapgo.NewNgReader(f, pcapgo.DefaultNgReaderOptions)
75+
if err != nil {
76+
return errors.Wrapf(err, "new reader")
77+
}
78+
source = gopacket.NewPacketSource(r, r.LinkType())
6879
}
6980

7081
// TODO: FIXME: Should start a goroutine to consume bytes from conn.
@@ -76,7 +87,6 @@ func doMain(ctx context.Context) error {
7687

7788
var packetNumber uint64
7889
var previousTime *time.Time
79-
source := gopacket.NewPacketSource(r, r.LinkType())
8090
for packet := range source.Packets() {
8191
packetNumber++
8292

0 commit comments

Comments
 (0)