1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980 |
- package lib
- import (
- "bytes"
- "encoding/binary"
- "fmt"
- "os"
- "strconv"
- "syscall"
- "unsafe"
- "github.com/langgenius/dify-sandbox/internal/static"
- sg "github.com/seccomp/libseccomp-golang"
- )
- //var allow_syscalls = []int{}
- func InitSeccomp() error {
- disabled_syscall, err := strconv.Atoi(os.Getenv("DISABLE_SYSCALL"))
- if err != nil {
- disabled_syscall = -1
- }
- ctx, err := sg.NewFilter(sg.ActKillProcess)
- if err != nil {
- return err
- }
- defer ctx.Release()
- // for i := 0; i < 400; i++ {
- // allow_syscalls = append(allow_syscalls, i)
- // }
- for _, syscall := range static.ALLOW_SYSCALLS {
- if syscall == disabled_syscall {
- continue
- }
- err = ctx.AddRule(sg.ScmpSyscall(syscall), sg.ActAllow)
- if err != nil {
- return err
- }
- }
- reader, writer, err := os.Pipe()
- if err != nil {
- return err
- }
- defer reader.Close()
- defer writer.Close()
- file := os.NewFile(uintptr(writer.Fd()), "pipe")
- ctx.ExportBPF(file)
- // read from pipe
- data := make([]byte, 4096)
- n, err := reader.Read(data)
- if err != nil {
- return err
- }
- // load bpf
- sock_filters := make([]syscall.SockFilter, n/8)
- bytesBuffer := bytes.NewBuffer(data)
- err = binary.Read(bytesBuffer, binary.LittleEndian, &sock_filters)
- if err != nil {
- return err
- }
- bpf := syscall.SockFprog{
- Len: uint16(len(sock_filters)),
- Filter: &sock_filters[0],
- }
- _, _, err2 := syscall.RawSyscall6(syscall.SYS_PRCTL, syscall.PR_SET_SECCOMP, 2, uintptr(unsafe.Pointer(&bpf)), 0, 0, 0)
- if err2 != 0 {
- return fmt.Errorf("prctl failed: %v", err2)
- }
- return nil
- }
|