summaryrefslogtreecommitdiff
path: root/internal/ioriotng.go
diff options
context:
space:
mode:
authorPaul Buetow <paul@buetow.org>2024-02-16 21:52:02 +0200
committerPaul Buetow <paul@buetow.org>2024-02-16 21:52:02 +0200
commitc3d14a993d02062ee37c257848cf5f9268fc8fd3 (patch)
treefe21e63a163f4fd3e8f8ff63b60dbbfc358da138 /internal/ioriotng.go
parent01059c9390150a4e9b78db6c6399e02729121331 (diff)
it's actually the Pid + TGid
Diffstat (limited to 'internal/ioriotng.go')
-rw-r--r--internal/ioriotng.go12
1 files changed, 6 insertions, 6 deletions
diff --git a/internal/ioriotng.go b/internal/ioriotng.go
index 8ab9371..2ab2b33 100644
--- a/internal/ioriotng.go
+++ b/internal/ioriotng.go
@@ -64,11 +64,11 @@ func Run(flags flags.Flags) {
switch types.OpId(raw[0]) {
case types.OPENAT_ENTER_OP_ID:
ev := readRaw(raw, syncpool.OpenEnterEvent.Get().(*types.OpenatEnterEvent))
- enterOpen[ev.Tid] = ev
+ enterOpen[ev.PidTGid] = ev
case types.OPENAT_EXIT_OP_ID:
ev := readRaw(raw, syncpool.FdEvent.Get().(*types.FdEvent))
- enterEv, ok := enterOpen[ev.Tid]
+ enterEv, ok := enterOpen[ev.PidTGid]
if !ok {
fmt.Println("Dropping", ev)
syncpool.FdEvent.Put(ev)
@@ -77,17 +77,17 @@ func Run(flags flags.Flags) {
duration := float64(ev.Time-enterEv.Time) / float64(1_000_000)
fmt.Println(duration, "ms", enterEv, ev)
- delete(enterOpen, ev.Tid)
+ delete(enterOpen, ev.PidTGid)
syncpool.FdEvent.Put(ev)
syncpool.OpenEnterEvent.Put(enterEv)
case types.CLOSE_ENTER_OP_ID:
ev := readRaw(raw, syncpool.FdEvent.Get().(*types.FdEvent))
- enterFd[ev.Tid] = ev
+ enterFd[ev.PidTGid] = ev
case types.CLOSE_EXIT_OP_ID:
ev := readRaw(raw, syncpool.NullEvent.Get().(*types.NullEvent))
- enterEv, ok := enterFd[ev.Tid]
+ enterEv, ok := enterFd[ev.PidTGid]
if !ok {
fmt.Println("Dropping", ev)
syncpool.NullEvent.Put(ev)
@@ -96,7 +96,7 @@ func Run(flags flags.Flags) {
duration := float64(ev.Time-enterEv.Time) / float64(1_000_000)
fmt.Println(duration, "ms", enterEv, ev)
- delete(enterFd, ev.Tid)
+ delete(enterFd, ev.PidTGid)
syncpool.NullEvent.Put(ev)
syncpool.FdEvent.Put(enterEv)