diff options
| author | Paul Buetow <paul@buetow.org> | 2024-02-19 12:19:11 +0200 |
|---|---|---|
| committer | Paul Buetow <paul@buetow.org> | 2024-02-19 12:19:11 +0200 |
| commit | 4950710f87d8fe65e00d855760ea4b3f71de73e5 (patch) | |
| tree | 4a706891b2068740dafbb1fc479c99b710836a2e /internal/ioriotng.go | |
| parent | db553759bbc60cf6e0ed1c1e40e7567b5838cc61 (diff) | |
refactor open, re-use some code
Diffstat (limited to 'internal/ioriotng.go')
| -rw-r--r-- | internal/ioriotng.go | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/internal/ioriotng.go b/internal/ioriotng.go index 97b46ea..9b7ec2d 100644 --- a/internal/ioriotng.go +++ b/internal/ioriotng.go @@ -62,10 +62,14 @@ func Run(flags flags.Flags) { for raw := range ch { switch OpId(raw[0]) { case OPENAT_ENTER_OP_ID: + fallthrough + case OPEN_ENTER_OP_ID: ev := readRaw(raw, syncpool.OpenEnterEvent.Get().(*OpenatEnterEvent)) enterOpen[ev.PidTGid] = ev case OPENAT_EXIT_OP_ID: + fallthrough + case OPEN_EXIT_OP_ID: ev := readRaw(raw, syncpool.FdEvent.Get().(*FdEvent)) enterEv, ok := enterOpen[ev.PidTGid] if !ok { @@ -117,7 +121,8 @@ func Run(flags flags.Flags) { func readRaw[T any](raw []byte, ev *T) *T { if err := binary.Read(bytes.NewReader(raw), binary.LittleEndian, ev); err != nil { - panic(err) + fmt.Println(ev, raw, len(raw), err) + panic(raw) } return ev } |