TheArchive/tailscale
1
0
Fork 0
mirror of https://github.com/tailscale/tailscale.git synced 2025-04-16 11:41:39 +00:00
Code Issues Packages Projects Releases Wiki Activity

tstest/natlab/vnet: flush and sync pcap file after every packet

Browse Source 
So that we can view the pcap as we debug interactively.

Updates #13038

Signed-off-by: Maisem Ali <maisem@tailscale.com>
This commit is contained in:
Maisem Ali 2024-08-24 11:36:59 -07:00 committed by Maisem Ali
parent 978306565d
commit 31b5239a2f
1 changed files with 14 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
tstest/natlab/vnet/pcap.go
View File

@ -21,6 +21,15 @@ type pcapWriter struct {
w *pcapgo.NgWriter w *pcapgo.NgWriter
} }
func do(fs ...func() error) error {
for _, f := range fs {
if err := f(); err != nil {
return err
}
}
return nil
}
func (p *pcapWriter) WritePacket(ci gopacket.CaptureInfo, data []byte) error { func (p *pcapWriter) WritePacket(ci gopacket.CaptureInfo, data []byte) error {
if p == nil { if p == nil {
return nil return nil
@ -30,7 +39,11 @@ func (p *pcapWriter) WritePacket(ci gopacket.CaptureInfo, data []byte) error {
if p.w == nil { if p.w == nil {
return io.ErrClosedPipe return io.ErrClosedPipe
} }
return p.w.WritePacket(ci, data) return do(
func() error { return p.w.WritePacket(ci, data) },
p.w.Flush,
p.f.Sync,
)
} }
func (p *pcapWriter) AddInterface(i pcapgo.NgInterface) (int, error) { func (p *pcapWriter) AddInterface(i pcapgo.NgInterface) (int, error) {