bump tcptracer-bpf version

probe/endpoint/ebpf.go

@@ -80,7 +80,7 @@ func newEbpfTracker() (*EbpfTracker, error) {
 		openConnections: map[fourTuple]ebpfConnection{},
 	}
 
-	tracer, err := tracer.NewTracer(tracker.tcpEventCbV4, tracker.tcpEventCbV6, tracker.lostCb)
+	tracer, err := tracer.NewTracer(tracker)
 	if err != nil {
 		return nil, err
 	}
@@ -91,7 +91,8 @@ func newEbpfTracker() (*EbpfTracker, error) {
 	return tracker, nil
 }
 
-func (t *EbpfTracker) tcpEventCbV4(e tracer.TcpV4) {
+// TCPEventV4 handles IPv4 TCP events from the eBPF tracer
+func (t *EbpfTracker) TCPEventV4(e tracer.TcpV4) {
 	if t.lastTimestampV4 > e.Timestamp {
 		// A kernel bug can cause the timestamps to be wrong (e.g. on Ubuntu with Linux 4.4.0-47.68)
 		// Upgrading the kernel will fix the problem. For further info see:
@@ -111,15 +112,24 @@ func (t *EbpfTracker) tcpEventCbV4(e tracer.TcpV4) {
 	}
 }
 
-func (t *EbpfTracker) tcpEventCbV6(e tracer.TcpV6) {
+// TCPEventV6 handles IPv6 TCP events from the eBPF tracer. This is
+// currently a no-op.
+func (t *EbpfTracker) TCPEventV6(e tracer.TcpV6) {
 	// TODO: IPv6 not supported in Scope
 }
 
-func (t *EbpfTracker) lostCb(count uint64) {
+// LostV4 handles IPv4 TCP event misses from the eBPF tracer.
+func (t *EbpfTracker) LostV4(count uint64) {
 	log.Errorf("tcp tracer lost %d events. Stopping the eBPF tracker", count)
 	t.stop()
 }
 
+// LostV6 handles IPv4 TCP event misses from the eBPF tracer. This is
+// currently a no-op.
+func (t *EbpfTracker) LostV6(count uint64) {
+	// TODO: IPv6 not supported in Scope
+}
+
 func tupleFromPidFd(pid int, fd int) (tuple fourTuple, netns string, ok bool) {
 	// read /proc/$pid/ns/net
 	//

probe/endpoint/ebpf_test.go

@@ -210,11 +210,11 @@ func TestInvalidTimeStampDead(t *testing.T) {
 		openConnections: map[fourTuple]ebpfConnection{},
 	}
 	event.Timestamp = 0
-	mockEbpfTracker.tcpEventCbV4(event)
+	mockEbpfTracker.TCPEventV4(event)
 	event2 := event
 	event2.SPort = 1
 	event2.Timestamp = 2
-	mockEbpfTracker.tcpEventCbV4(event2)
+	mockEbpfTracker.TCPEventV4(event2)
 	mockEbpfTracker.walkConnections(func(e ebpfConnection) {
 		cnt++
 	})
@@ -226,7 +226,7 @@ func TestInvalidTimeStampDead(t *testing.T) {
 	}
 	cnt = 0
 	event.Timestamp = 1
-	mockEbpfTracker.tcpEventCbV4(event)
+	mockEbpfTracker.TCPEventV4(event)
 	mockEbpfTracker.walkConnections(func(e ebpfConnection) {
 		cnt++
 	})