ebpf/ebpftracer/netcore.go

package ebpftracer

import (
	"bufio"
	"bytes"
	"errors"
	"io"
	"log"
	"os"
	"strconv"
	"strings"

	"debug/dwarf"
	"debug/elf"
	debugelf "debug/elf"
	"fmt"

	"github.com/cilium/ebpf/link"
)

const (
	// goServeHTTP           = "net/http.serverHandler.ServeHTTP"
	// binPath           = "/root/code/jdk8u/build/linux-x86_64-normal-server-release/jdk/lib/amd64/libnio.so"
	netcoresymbolsocketRead0 = "SystemNative_Receive"
)

type MemoryMap struct {
	Start, End uint64
}

func ReadFirstLineOfMapsFile(pid string) (*MemoryMap, error) {
	file, err := os.Open(fmt.Sprintf("/proc/%s/maps", pid))
	if err != nil {
		return nil, err
	}
	defer file.Close()

	scanner := bufio.NewScanner(file)
	if scanner.Scan() {
		fields := strings.Fields(scanner.Text())
		addresses := strings.Split(fields[0], "-")
		if len(addresses) != 2 {
			return nil, errors.New("unexpected format in /proc/<pid>/maps")
		}

		start, err := strconv.ParseUint(addresses[0], 16, 64)
		if err != nil {
			return nil, err
		}

		end, err := strconv.ParseUint(addresses[1], 16, 64)
		if err != nil {
			return nil, err
		}

		return &MemoryMap{
			Start: start,
			End:   end,
		}, nil
	}

	if err := scanner.Err(); err != nil {
		return nil, err
	}

	return nil, errors.New("empty /proc/<pid>/maps")
}

func (t *Tracer) getFunctionOffsetDBG(libPath, functionName string) (elf.Symbol, error) {
	dwarfFile, err := elf.Open(libPath)
	dwarfData, err := dwarfFile.DWARF()
	if err != nil {
		log.Fatal(err)
	}

	type uprobesDef struct {
		Name       string
		Offset     uint64
		EntAddress uint64
		RetAddress uint64
	}

	listEntry := make(map[dwarf.Offset]uprobesDef)
	SpecListEntry := []dwarf.Entry{}

	entryReader := dwarfData.Reader()

	for {
		entry, err := entryReader.Next()
		if err == io.EOF {
			// We've reached the end of DWARF entries
			break
		}
		if err != nil {
			log.Fatalf("Error reading entry: %v", err)
		}
		if entry == nil {
			log.Println("Warning: a nil entry was returned with no error")
			break
		}
		if entry.Tag == dwarf.TagSubprogram {
			// fmt.Printf("entry address: %x, %d\n", entry.Offset, entry.Children)
			funName, _ := entry.Val(dwarf.AttrName).(string)
			if functionName == funName {
				entAddress, _ := entry.Val(dwarf.AttrLowpc).(uint64)
				retAddress, _ := entry.Val(dwarf.AttrHighpc).(uint64)
				fmt.Printf("Function %s address: %x, %x, %x\n", funName, entAddress, entry.Offset, retAddress)
				uprobes := uprobesDef{}
				uprobes.EntAddress = entAddress
				uprobes.RetAddress = retAddress
				uprobes.Offset = uint64(entry.Offset)
				uprobes.Name = funName

				listEntry[entry.Offset] = uprobes
			}

			specAddr, _ := entry.Val(dwarf.AttrSpecification).(dwarf.Offset)
			lowpc := entry.Val(dwarf.AttrLowpc)
			if lowpc != nil && specAddr > 0 && lowpc.(uint64) > 0 {
				// fmt.Printf("AttrSpecification address: %x, %x\n", specAddr, entry.Offset)
				SpecListEntry = append(SpecListEntry, *entry)
			}
		}
	}

	for _, v := range SpecListEntry {
		specAddr, _ := v.Val(dwarf.AttrSpecification).(dwarf.Offset)
		// fmt.Printf("SpecListEntrySpecListEntrySpecListEntry Attach Function: %x\n", specAddr)
		_, ok := listEntry[specAddr]
		if ok {
			vv := listEntry[specAddr]
			entAddr := v.Val(dwarf.AttrLowpc)
			if entAddr != nil {
				vv.EntAddress = entAddr.(uint64)
			}
			retAddr := v.Val(dwarf.AttrHighpc)
			if retAddr != nil {
				switch retAddr.(type) {
				case uint64:
					vv.RetAddress = uint64(retAddr.(uint64))
				case int64:
					vv.RetAddress = uint64(retAddr.(int64))
				default:
					fmt.Println("Unknown type")
				}
			}
			listEntry[specAddr] = vv
		}
	}

	for _, v := range listEntry {
		sSize := v.RetAddress
		if v.RetAddress > v.EntAddress {
			sSize = v.RetAddress - v.EntAddress
		}
		symbol := elf.Symbol{}
		symbol.Name = v.Name
		symbol.Value = v.EntAddress
		symbol.Size = 180
		fmt.Printf("Need Attach Function %s address: %x, %x, %d\n", v.Name, v.EntAddress, v.RetAddress, sSize)
		return symbol, nil
	}
	return elf.Symbol{}, fmt.Errorf("function %s not found", functionName)
}

func (t *Tracer) AttachNetCoreNetReadUprobes(pid uint32) ([]link.Link, error) {
	if t.DisableL7Tracing() {
		return nil, nil
	}
	libPath := "/data/NET8/CoreAoT/bin/Debug/net8.0/linux-x64/publish/CoreAoT"
	var links []link.Link
	ex, err := link.OpenExecutable(libPath)

	// 获取函数的偏移量
	functionSym, err := t.getFunctionOffsetDBG(libPath+".dbg", netcoresymbolsocketRead0)

	l, err := ex.Uprobe(functionSym.Name, t.uprobes["SystemNative_Receive"], &link.UprobeOptions{Address: functionSym.Value, Offset: 113})
	if err != nil {
		fmt.Println("failed to attach SystemNative_Receive uprobe", err, functionSym)
		return nil, err
	}

	links = append(links, l)

	if len(links) == 0 {
		return nil, nil
	}
	fmt.Println("netcore uprobes attached, pid is ", pid)
	return links, nil
}

func (t *Tracer) AttachNetCoreNetWriteUprobes(pid uint32) ([]link.Link, error) {
	if t.DisableL7Tracing() {
		return nil, nil
	}
	//
	//if pid != 251719 {
	//	return nil
	//}

	var libnetSo = "/data/roger/han/libmylib.so"
	var sys = "asmnop"
	var links []link.Link
	ex, err := link.OpenExecutable(libnetSo)
	if err != nil {
		return nil, err
	}
	opt := link.UprobeOptions{
		Offset: 16,
		PID:    int(pid),
	}
	upread02, err := ex.Uprobe(sys, t.uprobes["netcore_asmnop"], &opt)
	if err != nil {
		return nil, err
	}
	links = append(links, upread02)

	if len(links) == 0 {
		return nil, nil
	}
	fmt.Println("netcore client uprobes attached", pid)

	return links, nil
}

func contains(array []string, str string) bool {
	for _, v := range array {
		if v == str {
			return true
		}
	}
	return false
}

func SplitByteByDelimiter(data []byte) []byte {
	pre := data[:4]
	data = data[4:]
	// 查找两个字节序列的位置
	index1 := bytes.Index(data, []byte{0x55, 0x48, 0x83, 0xEC})
	index2 := bytes.Index(data, []byte{0x55, 0x48, 0x81, 0xEC})

	// 如果两个都没有找到，返回 nil
	if index1 == -1 && index2 == -1 {
		return nil
	}

	// 确定哪个字节序列在前
	var startIndex int
	if index1 == -1 {
		// 只有index2找到了
		startIndex = index2
	} else if index2 == -1 {
		// 只有index1找到了
		startIndex = index1
	} else {
		// 两个都找到了，选择较小的那个
		startIndex = min(index1, index2)
	}

	// 返回从开始到选定的起始位置之前的数据
	return append(pre, data[:startIndex]...)
}

func (t *Tracer) AttachNetCoreNetThreadUprobes(pid uint32) []link.Link {
	// uprobes := []tracer.Uprobe{}
	libPath := "/data/NET8/CoreAoT/bin/Debug/net8.0/linux-x64/publish/CoreAoT"
	binFile, err := os.Open(libPath + ".dbg")
	binFile2, err := os.Open(libPath)
	if err != nil {
		return nil
	}

	// cache := map[string]interface{}{}
	// 解析 elf 文件
	elfFile, _ := debugelf.NewFile(binFile)
	elfFile2, _ := debugelf.NewFile(binFile2)
	// 获取所有符号表
	symbols, _ := elfFile.Symbols()

	ex, err := link.OpenExecutable(libPath)

	words := []string{
		"Microsoft_AspNetCore_Server_Kestrel_Core_Microsoft_AspNetCore_Server_Kestrel_Core_Internal_HttpConnectionMiddleware_1<System___Canon>__OnConnectionAsync", "Microsoft_AspNetCore_Server_Kestrel_Transport_Sockets_Microsoft_AspNetCore_Server_Kestrel_Transport_Sockets_Internal_SocketConnection__DoSend_d__28__MoveNext", "System_Net_Http_System_Net_Http_HttpClient__SendAsync_2",
		"System_Net_Http_System_Net_Http_HttpConnection__SendAsync_d__57__MoveNext",
		"Microsoft_AspNetCore_Server_Kestrel_Transport_Sockets_Microsoft_AspNetCore_Server_Kestrel_Transport_Sockets_Internal_SocketConnection__Start"}

	wordsType := map[string]string{
		"Microsoft_AspNetCore_Server_Kestrel_Core_Microsoft_AspNetCore_Server_Kestrel_Core_Internal_HttpConnectionMiddleware_1<System___Canon>__OnConnectionAsync":      "OnConnectionAsync",
		"Microsoft_AspNetCore_Server_Kestrel_Transport_Sockets_Microsoft_AspNetCore_Server_Kestrel_Transport_Sockets_Internal_SocketConnection__DoSend_d__28__MoveNext": "DoSend",
		"System_Net_Http_System_Net_Http_HttpClient__SendAsync_2":                                                                                      "SendAsync1",
		"System_Net_Http_System_Net_Http_HttpConnection__SendAsync_d__57__MoveNext":                                                                    "SendAsync2",
		"Microsoft_AspNetCore_Server_Kestrel_Transport_Sockets_Microsoft_AspNetCore_Server_Kestrel_Transport_Sockets_Internal_SocketConnection__Start": "SocketConnectionStart"}

	textSection := elfFile2.Section("__managedcode")
	textSectionData, err := textSection.Data()

	if err != nil {
		fmt.Println("failed to read text section", err)
		return nil
	}

	if textSection == nil {
		fmt.Println("no text section", nil)
		return nil
	}
	textSectionLen := uint64(len(textSectionData) - 1)
	fmt.Printf("textSectionLen %x, %x, %x\n", textSectionLen, textSection.Addr, textSection.Size)

	var links []link.Link

	for _, sym := range symbols {
		exists := contains(words, sym.Name)
		if exists {
			fmt.Println("dddddddd:", sym.Name, sym.Value, sym.Size, sym.Info, sym)
			address := sym.Value

			sStart := sym.Value - textSection.Addr
			sEnd := sStart + sym.Size
			if sym.Size == 0 {
				sEnd = sStart + 5000
			}
			if sEnd > textSectionLen {
				fmt.Println("no text section333", nil)
				continue
			}
			sBytes := textSectionData[sStart:sEnd]
			if sym.Size == 0 {
				sBytes = SplitByteByDelimiter(sBytes)
			}

			fmt.Printf("dddddddd+++++: %s, %x, %d, %x, %s\n", sym.Name, sym.Value, sym.Size, address, wordsType[sym.Name])

			l, err := ex.Uprobe("", t.uprobes[wordsType[sym.Name]+"Start"], &link.UprobeOptions{Address: address})
			if err != nil {
				fmt.Println("failed to attach uprobe", err, wordsType[sym.Name])
				// return nil
			}

			links = append(links, l)
			returnOffsets := getReturnOffsets(elfFile.Machine, sBytes)
			for _, offset := range returnOffsets {
				fmt.Printf("dddddddd----: %s, %x, %d, %x\n", sym.Name, sym.Value, sym.Size, offset)
				l, err := ex.Uprobe("", t.uprobes[wordsType[sym.Name]+"End"], &link.UprobeOptions{Address: address, Offset: uint64(offset)})
				if err != nil {
					fmt.Println("failed to attach uprobe", err, wordsType[sym.Name])
					// return nil
				}
				links = append(links, l)
			}

		}
	}
	if len(links) == 0 {
		return nil
	}
	fmt.Println("netcore uprobes OnConnectionAsyncStart attached, pid is ", pid)
	return links
}

// func (t *Tracer) AttachNetCoreNetOnConnectionAsyncStartUprobes(pid uint32, insID utils.ID) []link.Link {
// 	if t.disableL7Tracing {
// 		return nil
// 	}

// 	var links []link.Link
// 	ex, err := link.OpenExecutable(libPath)

// 	// 获取函数的偏移量
// 	// memoryMap, _ := ReadFirstLineOfMapsFile(strconv.Itoa(int(pid)))

// 	var addr uint64 = 0x96d700 // Microsoft_AspNetCore_Server_Kestrel_Core_Microsoft_AspNetCore_Server_Kestrel_Core_Internal_HttpConnectionMiddleware_1<System___Canon>__OnConnectionAsync 入口处
// 	// var addr uint64 = 0x96dc15

// 	l, err := ex.Uprobe("", t.uprobes["OnConnectionAsyncStart"], &link.UprobeOptions{Address: addr})
// 	if err != nil {
// 		fmt.Println("failed to attach OnConnectionAsyncStart uprobe", err)
// 		return nil
// 	}

// 	links = append(links, l)

// 	if len(links) == 0 {
// 		return nil
// 	}
// 	fmt.Println("netcore uprobes OnConnectionAsyncStart attached, pid is ", pid)
// 	return links
// }

// func (t *Tracer) AttachNetCoreNetOnConnectionAsyncEndUprobes(pid uint32, insID utils.ID) []link.Link {
// 	if t.disableL7Tracing {
// 		return nil
// 	}

// 	var links []link.Link
// 	ex, err := link.OpenExecutable(libPath)

// 	// 获取函数的偏移量
// 	// memoryMap, _ := ReadFirstLineOfMapsFile(strconv.Itoa(int(pid)))

// 	var addr uint64 = 0x96dcbf

// 	l, err := ex.Uprobe("", t.uprobes["OnConnectionAsyncEnd"], &link.UprobeOptions{Address: addr})
// 	if err != nil {
// 		fmt.Println("failed to attach OnConnectionAsyncEnd uprobe", err)
// 		return nil
// 	}

// 	links = append(links, l)

// 	if len(links) == 0 {
// 		return nil
// 	}
// 	fmt.Println("netcore uprobes OnConnectionAsyncEnd attached, pid is ", pid)
// 	return links
// }

// func (t *Tracer) AttachNetCoreNetDoSendStartUprobes(pid uint32, insID utils.ID) []link.Link {
// 	if t.disableL7Tracing {
// 		return nil
// 	}

// 	var links []link.Link
// 	ex, err := link.OpenExecutable(libPath)

// 	// 获取函数的偏移量
// 	// memoryMap, _ := ReadFirstLineOfMapsFile(strconv.Itoa(int(pid)))

// 	var addr uint64 = 0x260b40 // Microsoft_AspNetCore_Server_Kestrel_Transport_Sockets_Microsoft_AspNetCore_Server_Kestrel_Transport_Sockets_Internal_SocketConnection__DoSend_d__28__MoveNext 入口处

// 	l, err := ex.Uprobe("", t.uprobes["DoSendStart"], &link.UprobeOptions{Address: addr})
// 	if err != nil {
// 		fmt.Println("failed to attach DoSendStart uprobe", err)
// 		return nil
// 	}

// 	links = append(links, l)

// 	if len(links) == 0 {
// 		return nil
// 	}
// 	fmt.Println("netcore uprobes DoSendStart attached, pid is ", pid)
// 	return links
// }

// func (t *Tracer) AttachNetCoreNetDoSendEndUprobes(pid uint32, insID utils.ID) []link.Link {
// 	if t.disableL7Tracing {
// 		return nil
// 	}

// 	var links []link.Link
// 	ex, _ := link.OpenExecutable(libPath)

// 	// 获取函数的偏移量
// 	// memoryMap, _ := ReadFirstLineOfMapsFile(strconv.Itoa(int(pid)))

// 	var addrArray = []uint64{0x26125d, 0x261295, 0x2612fd, 0x261396, 0x2613f4}

// 	for _, addr := range addrArray {
// 		l, err := ex.Uprobe("", t.uprobes["DoSendEnd"], &link.UprobeOptions{Address: addr})
// 		if err != nil {
// 			fmt.Println("failed to attach DoSendEnd uprobe", err)
// 			return nil
// 		}

// 		links = append(links, l)
// 	}

// 	if len(links) == 0 {
// 		return nil
// 	}
// 	fmt.Println("netcore uprobes DoSendEnd attached, pid is ", pid)
// 	return links
// }

// func (t *Tracer) AttachNetCoreNetSendAsync1Uprobes(pid uint32, insID utils.ID) []link.Link {
// 	if t.disableL7Tracing {
// 		return nil
// 	}

// 	var links []link.Link
// 	ex, err := link.OpenExecutable(libPath)

// 	// 获取函数的偏移量
// 	// memoryMap, _ := ReadFirstLineOfMapsFile(strconv.Itoa(int(pid)))

// 	var addr uint64 = 0x32ab70 // System_Net_Http_System_Net_Http_HttpClient__SendAsync_2 入口处

// 	l, err := ex.Uprobe("", t.uprobes["SendAsync1"], &link.UprobeOptions{Address: addr})
// 	if err != nil {
// 		fmt.Println("failed to attach SendAsync1 uprobe", err)
// 		return nil
// 	}

// 	links = append(links, l)

// 	if len(links) == 0 {
// 		return nil
// 	}
// 	fmt.Println("netcore uprobes SendAsync1 attached, pid is ", pid)
// 	return links
// }

// func (t *Tracer) AttachNetCoreNetSendAsync2Uprobes(pid uint32, insID utils.ID) []link.Link {
// 	if t.disableL7Tracing {
// 		return nil
// 	}

// 	var links []link.Link
// 	ex, err := link.OpenExecutable(libPath)

// 	// 获取函数的偏移量
// 	// memoryMap, _ := ReadFirstLineOfMapsFile(strconv.Itoa(int(pid)))

// 	var addr uint64 = 0x34ce90 // System_Net_Http_System_Net_Http_HttpConnection__SendAsync_d__57__MoveNext 入口处

// 	l, err := ex.Uprobe("", t.uprobes["SendAsync2"], &link.UprobeOptions{Address: addr})
// 	if err != nil {
// 		fmt.Println("failed to attach SendAsync2 uprobe", err)
// 		return nil
// 	}

// 	links = append(links, l)

// 	if len(links) == 0 {
// 		return nil
// 	}
// 	fmt.Println("netcore uprobes SendAsync2 attached, pid is ", pid)
// 	return links
// }

// func (t *Tracer) AttachNetCoreNetSendAsync2EndUprobes(pid uint32, insID utils.ID) []link.Link {
// 	if t.disableL7Tracing {
// 		return nil
// 	}

// 	var links []link.Link
// 	ex, _ := link.OpenExecutable(libPath)

// 	// 获取函数的偏移量
// 	// memoryMap, _ := ReadFirstLineOfMapsFile(strconv.Itoa(int(pid)))

// 	var addrArray = []uint64{0x34f56c, 0x34f5af, 0x34f649, 0x34f6e3}

// 	for _, addr := range addrArray {
// 		l, err := ex.Uprobe("", t.uprobes["SendAsync2End"], &link.UprobeOptions{Address: addr})
// 		if err != nil {
// 			fmt.Println("failed to attach SendAsync2End uprobe", err)
// 			return nil
// 		}

// 		links = append(links, l)
// 	}

// 	if len(links) == 0 {
// 		return nil
// 	}
// 	fmt.Println("netcore uprobes SendAsync2End attached, pid is ", pid)
// 	return links
// }

// func (t *Tracer) AttachNetCoreNetSocketConnectionStartStartUprobes(pid uint32, insID utils.ID) []link.Link {
// 	if t.disableL7Tracing {
// 		return nil
// 	}

// 	var links []link.Link
// 	ex, err := link.OpenExecutable(libPath)

// 	var addr uint64 = 0x25c4c0 // Microsoft_AspNetCore_Server_Kestrel_Transport_Sockets_Microsoft_AspNetCore_Server_Kestrel_Transport_Sockets_Internal_SocketConnection__Start 入口处

// 	l, err := ex.Uprobe("", t.uprobes["SocketConnectionStartStart"], &link.UprobeOptions{Address: addr})
// 	if err != nil {
// 		fmt.Println("failed to attach SocketConnectionStartStart uprobe", err)
// 		return nil
// 	}

// 	links = append(links, l)

// 	if len(links) == 0 {
// 		return nil
// 	}
// 	fmt.Println("netcore uprobes SocketConnectionStartStart attached, pid is ", pid)
// 	return links
// }

// func (t *Tracer) AttachNetCoreNetSocketConnectionStartEndUprobes(pid uint32, insID utils.ID) []link.Link {
// 	if t.disableL7Tracing {
// 		return nil
// 	}

// 	var links []link.Link
// 	ex, _ := link.OpenExecutable(libPath)

// 	// 获取函数的偏移量
// 	// memoryMap, _ := ReadFirstLineOfMapsFile(strconv.Itoa(int(pid)))

// 	var addrArray = []uint64{0x25c54e, 0x25c5c7}

// 	for _, addr := range addrArray {
// 		l, err := ex.Uprobe("", t.uprobes["SocketConnectionStartEnd"], &link.UprobeOptions{Address: addr})
// 		if err != nil {
// 			fmt.Println("failed to attach SocketConnectionStartEnd uprobe", err)
// 			return nil
// 		}

// 		links = append(links, l)
// 	}

// 	if len(links) == 0 {
// 		return nil
// 	}
// 	fmt.Println("netcore uprobes SocketConnectionStartEnd attached, pid is ", pid)
// 	return links
// }

// func (t *Tracer) AttachNetCoreNetThreadUprobes(pid uint32, insID utils.ID) []link.Link {
// 	if t.disableL7Tracing {
// 		return nil
// 	}

// 	var links []link.Link
// 	ex, err := link.OpenExecutable(libPath)

// 	// 获取函数的偏移量
// 	// memoryMap, _ := ReadFirstLineOfMapsFile(strconv.Itoa(int(pid)))

// 	fmt.Println("netcore uprobes AttachNetCoreNetThreadUprobes hook value, pid is ", functionSym.Value)

// 	var addr uint64 = 0x97b766

// 	l, err := ex.Uprobe("", t.uprobes["AcceptConnectionsAsync"], &link.UprobeOptions{Address: addr})
// 	if err != nil {
// 		fmt.Println("failed to attach AcceptConnectionsAsync uprobe", err)
// 		return nil
// 	}

// 	links = append(links, l)

// 	if len(links) == 0 {
// 		return nil
// 	}
// 	fmt.Println("netcore uprobes AcceptConnectionsAsync attached, pid is ", pid)
// 	return links
// }

// func (t *Tracer) AttachNetCoreNetCreateContextStartUprobes(pid uint32, insID utils.ID) []link.Link {
// 	if t.disableL7Tracing {
// 		return nil
// 	}

// 	var links []link.Link
// 	ex, err := link.OpenExecutable(libPath)

// 	// 获取函数的偏移量
// 	// memoryMap, _ := ReadFirstLineOfMapsFile(strconv.Itoa(int(pid)))

// 	var addr uint64 = 0x97b60a

// 	l, err := ex.Uprobe("", t.uprobes["CreateContextStart"], &link.UprobeOptions{Address: addr})
// 	if err != nil {
// 		fmt.Println("failed to attach CreateContextStart uprobe", err)
// 		return nil
// 	}

// 	links = append(links, l)

// 	if len(links) == 0 {
// 		return nil
// 	}
// 	fmt.Println("netcore uprobes CreateContextStart attached, pid is ", pid)
// 	return links
// }

// func (t *Tracer) AttachNetCoreNetReceiveStartUprobes(pid uint32, insID utils.ID) []link.Link {
// 	if t.disableL7Tracing {
// 		return nil
// 	}

// 	var links []link.Link
// 	ex, err := link.OpenExecutable(libPath)

// 	// 获取函数的偏移量
// 	// memoryMap, _ := ReadFirstLineOfMapsFile(strconv.Itoa(int(pid)))

// 	var addr uint64 = 0xec7d0

// 	l, err := ex.Uprobe("", t.uprobes["ReceiveStart"], &link.UprobeOptions{Address: addr})
// 	if err != nil {
// 		fmt.Println("failed to attach ReceiveStart uprobe", err)
// 		return nil
// 	}

// 	links = append(links, l)

// 	if len(links) == 0 {
// 		return nil
// 	}
// 	fmt.Println("netcore uprobes ReceiveStart attached, pid is ", pid)
// 	return links
// }

// func (t *Tracer) AttachNetCoreNetReceiveEndUprobes(pid uint32, insID utils.ID) []link.Link {
// 	if t.disableL7Tracing {
// 		return nil
// 	}

// 	var links []link.Link
// 	ex, err := link.OpenExecutable(libPath)

// 	// 获取函数的偏移量
// 	// memoryMap, _ := ReadFirstLineOfMapsFile(strconv.Itoa(int(pid)))

// 	var addr uint64 = 0xec86e

// 	l, err := ex.Uprobe("", t.uprobes["ReceiveEnd"], &link.UprobeOptions{Address: addr})
// 	if err != nil {
// 		fmt.Println("failed to attach ReceiveEnd uprobe", err)
// 		return nil
// 	}

// 	links = append(links, l)

// 	if len(links) == 0 {
// 		return nil
// 	}
// 	fmt.Println("netcore uprobes ReceiveEnd attached, pid is ", pid)
// 	return links
// }

// func (t *Tracer) AttachNetCoreNetSendStartUprobes(pid uint32, insID utils.ID) []link.Link {
// 	if t.disableL7Tracing {
// 		return nil
// 	}

// 	var links []link.Link
// 	ex, err := link.OpenExecutable(libPath)

// 	// 获取函数的偏移量
// 	// memoryMap, _ := ReadFirstLineOfMapsFile(strconv.Itoa(int(pid)))

// 	var addr uint64 = 0xeca40

// 	l, err := ex.Uprobe("", t.uprobes["SendStart"], &link.UprobeOptions{Address: addr})
// 	if err != nil {
// 		fmt.Println("failed to attach SendStart uprobe", err)
// 		return nil
// 	}

// 	links = append(links, l)

// 	if len(links) == 0 {
// 		return nil
// 	}
// 	fmt.Println("netcore uprobes SendStart attached, pid is ", pid)
// 	return links
// }

// func (t *Tracer) AttachNetCoreNetSendEndUprobes(pid uint32, insID utils.ID) []link.Link {
// 	if t.disableL7Tracing {
// 		return nil
// 	}

// 	var links []link.Link
// 	ex, err := link.OpenExecutable(libPath)

// 	// 获取函数的偏移量
// 	// memoryMap, _ := ReadFirstLineOfMapsFile(strconv.Itoa(int(pid)))

// 	var addr uint64 = 0xecad1

// 	l, err := ex.Uprobe("", t.uprobes["SendEnd"], &link.UprobeOptions{Address: addr})
// 	if err != nil {
// 		fmt.Println("failed to attach SendEnd uprobe", err)
// 		return nil
// 	}

// 	links = append(links, l)

// 	if len(links) == 0 {
// 		return nil
// 	}
// 	fmt.Println("netcore uprobes SendEnd attached, pid is ", pid)
// 	return links
// }

// func (t *Tracer) AttachNetCoreNetDoReceiveStartUprobes(pid uint32, insID utils.ID) []link.Link {
// 	if t.disableL7Tracing {
// 		return nil
// 	}

// 	var links []link.Link
// 	ex, err := link.OpenExecutable(libPath)

// 	// 获取函数的偏移量
// 	// memoryMap, _ := ReadFirstLineOfMapsFile(strconv.Itoa(int(pid)))

// 	var addr uint64 = 0x260150

// 	l, err := ex.Uprobe("", t.uprobes["DoReceiveStart"], &link.UprobeOptions{Address: addr})
// 	if err != nil {
// 		fmt.Println("failed to attach DoReceiveStart uprobe", err)
// 		return nil
// 	}

// 	links = append(links, l)

// 	if len(links) == 0 {
// 		return nil
// 	}
// 	fmt.Println("netcore uprobes DoReceiveStart attached, pid is ", pid)
// 	return links
// }

// func (t *Tracer) AttachNetCoreNetDoReceiveEndUprobes(pid uint32, insID utils.ID) []link.Link {
// 	if t.disableL7Tracing {
// 		return nil
// 	}

// 	var links []link.Link
// 	ex, _ := link.OpenExecutable(libPath)

// 	// 获取函数的偏移量
// 	// memoryMap, _ := ReadFirstLineOfMapsFile(strconv.Itoa(int(pid)))

// 	var addrArray = []uint64{0x2609ed, 0x260a4f, 0x260aa3, 0x260adb, 0x260b33}

// 	for _, addr := range addrArray {
// 		l, err := ex.Uprobe("", t.uprobes["DoReceiveEnd"], &link.UprobeOptions{Address: addr})
// 		if err != nil {
// 			fmt.Println("failed to attach DoReceiveEnd uprobe", err)
// 			return nil
// 		}

// 		links = append(links, l)
// 	}

// 	if len(links) == 0 {
// 		return nil
// 	}
// 	fmt.Println("netcore uprobes DoReceiveEnd attached, pid is ", pid)
// 	return links
// }