summaryrefslogtreecommitdiff
path: root/internal/eventloop.go
diff options
context:
space:
mode:
authorPaul Buetow <paul@buetow.org>2024-02-23 11:02:16 +0200
committerPaul Buetow <paul@buetow.org>2024-02-23 11:02:16 +0200
commit2427ed2b058d057882ca6280c5365a49234e322a (patch)
tree1b3a4a3d9480ed244ec00ce2f203f9a392f7ee72 /internal/eventloop.go
parentaa3b3a508cd9ca6717245376bc01b1a89bfbef91 (diff)
initial RwEvent (read-write event) returning size
Diffstat (limited to 'internal/eventloop.go')
-rw-r--r--internal/eventloop.go4
1 files changed, 2 insertions, 2 deletions
diff --git a/internal/eventloop.go b/internal/eventloop.go
index a754897..5f754a5 100644
--- a/internal/eventloop.go
+++ b/internal/eventloop.go
@@ -98,7 +98,7 @@ func eventLoop(bpfModule *bpf.Module, ch <-chan []byte) {
case WRITE_EXIT_OP_ID:
fallthrough
case WRITEV_EXIT_OP_ID:
- ev := NewNullEvent(raw)
+ ev := NewRwEvent(raw)
enterEv, ok := enterFd[ev.Tid]
if !ok {
ev.Recycle()
@@ -106,7 +106,7 @@ func eventLoop(bpfModule *bpf.Module, ch <-chan []byte) {
}
duration := float64(ev.Time-enterEv.Time) / float64(1_000_000)
if file, ok := openFdMap[enterEv.Fd]; ok {
- fmt.Println(duration, "ms", "wrote", file)
+ fmt.Println(duration, "ms", "wrote", ev.Size, "bytes", file)
}
delete(enterFd, ev.Tid)