Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

creating simmilar experiece as we have in python bcc programs. #205

Open
wants to merge 2 commits into
base: master
Choose a base branch
from
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
24 changes: 24 additions & 0 deletions bcc/module.go
Original file line number Diff line number Diff line change
Expand Up @@ -269,6 +269,30 @@ func (bpf *Module) attachUProbe(evName string, attachType uint32, path string, a
return nil
}

// QuickAttachKretprobe attaches a kretprobe to a function.
func (bpf *Module) QuickAttachKretprobe(fnName string, maxActive int) error {
krName := "kretprobe__" + fnName
evName := "r_" + kprobeRegexp.ReplaceAllString(fnName, "_")
fd, err := bpf.LoadKprobe(krName)
if err != nil {
return err
}

return bpf.attachProbe(evName, BPF_PROBE_RETURN, fnName, fd, maxActive)
}

// QuickAttachKprobe attaches a kprobe to a function.
func (bpf *Module) QuickAttachKprobe(fnName string, maxActive int) error {
kpName := "kprobe__" + fnName
evName := "p_" + kprobeRegexp.ReplaceAllString(fnName, "_")
fd, err := bpf.LoadKprobe(kpName)
if err != nil {
return err
}

return bpf.attachProbe(evName, BPF_PROBE_ENTRY, fnName, fd, maxActive)
}

// AttachKprobe attaches a kprobe fd to a function.
func (bpf *Module) AttachKprobe(fnName string, fd int, maxActive int) error {
evName := "p_" + kprobeRegexp.ReplaceAllString(fnName, "_")
Expand Down
1 change: 1 addition & 0 deletions examples/bcc/quick_perf/.gitignore
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
quick_perf
136 changes: 136 additions & 0 deletions examples/bcc/quick_perf/quick_perf.go
Original file line number Diff line number Diff line change
@@ -0,0 +1,136 @@
// Copyright 2016 Kinvolk
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

package main

import (
"bytes"
"encoding/binary"
"fmt"
"os"
"os/signal"
"unsafe"

bpf "github.com/iovisor/gobpf/bcc"
)

import "C"

const source string = `
#include <uapi/linux/ptrace.h>
#include <bcc/proto.h>

typedef struct {
u32 pid;
uid_t uid;
gid_t gid;
int ret;
char filename[256];
} chown_event_t;

BPF_PERF_OUTPUT(chown_events);
BPF_HASH(chowncall, u64, chown_event_t);

int kprobe__sys_fchownat(struct pt_regs *ctx, int dfd, const char *filename,
uid_t uid, gid_t gid, int flag)
{
u64 pid = bpf_get_current_pid_tgid();
chown_event_t event = {
.pid = pid >> 32,
.uid = uid,
.gid = gid,
};
bpf_probe_read(&event.filename, sizeof(event.filename), (void *)filename);
chowncall.update(&pid, &event);
return 0;
}

int kretprobe__sys_fchownat(struct pt_regs *ctx)
{
int ret = PT_REGS_RC(ctx);
u64 pid = bpf_get_current_pid_tgid();
chown_event_t *eventp = chowncall.lookup(&pid);
if (eventp == 0) {
return 0;
}
chown_event_t event = *eventp;
event.ret = ret;
chown_events.perf_submit(ctx, &event, sizeof(event));
chowncall.delete(&pid);
return 0;
};
`

type chownEvent struct {
Pid uint32
Uid uint32
Gid uint32
ReturnValue int32
Filename [256]byte
}

func main() {
m := bpf.NewModule(source, []string{})
defer m.Close()

syscallName := bpf.GetSyscallFnName("fchownat")

// passing -1 for maxActive signifies to use the default
// according to the kernel kprobes documentation
err := m.QuickAttachKprobe(syscallName, -1)
if err != nil {
fmt.Fprintf(os.Stderr, "Failed to attach kprobe__sys_fchownat: %s\n", err)
os.Exit(1)
}

// passing -1 for maxActive signifies to use the default
// according to the kernel kretprobes documentation
err = m.QuickAttachKretprobe(syscallName, -1)
if err != nil {
fmt.Fprintf(os.Stderr, "Failed to attach kretprobe__sys_fchownat: %s\n", err)
os.Exit(1)
}

table := bpf.NewTable(m.TableId("chown_events"), m)

channel := make(chan []byte)

perfMap, err := bpf.InitPerfMap(table, channel)
if err != nil {
fmt.Fprintf(os.Stderr, "Failed to init perf map: %s\n", err)
os.Exit(1)
}

sig := make(chan os.Signal, 1)
signal.Notify(sig, os.Interrupt, os.Kill)

go func() {
var event chownEvent
for {
data := <-channel
err := binary.Read(bytes.NewBuffer(data), binary.LittleEndian, &event)
if err != nil {
fmt.Printf("failed to decode received data: %s\n", err)
continue
}
filename := (*C.char)(unsafe.Pointer(&event.Filename))
fmt.Printf("uid %d gid %d pid %d called fchownat(2) on %s (return value: %d)\n",
event.Uid, event.Gid, event.Pid, C.GoString(filename), event.ReturnValue)
}
}()

perfMap.Start()
<-sig
perfMap.Stop()
}