Method perfEventReader

user/module/imodule.go:223–278

(errChan chan error, em *ebpf.Map)

}

func (this *Module) perfEventReader(errChan chan error, em *ebpf.Map) {
    // 这里对原ebpf包代码做了修改 以此控制是否让内核发生栈空间数据和寄存器数据
    // 用于进行堆栈回溯 以后可以细分栈数据与寄存器数据
    // 每个 模块都是 Clone 得到的 map 虽然名字相同 但是 fd不同 所以可以正常区分

    eopt := this.getExtraOptions(em)

    var rd *perf.Reader
    var err error

    rd, err = perf.NewReaderWithOptions(em, this.getPerCPUBuffer(), perf.ReaderOptions{}, eopt)
    if err != nil {
        errChan <- fmt.Errorf("creating %s reader dns: %s", em.String(), err)
        return
    }
    // 可能存在多种类型的reader 添加到reader列表 异常时便于一起安全关闭
    this.reader = append(this.reader, rd)
    go func() {
        for {
            // 先判断ctx正不正常
            select {
            case _ = <-this.ctx.Done():
                this.logger.Printf("%s\tperfEventReader received close signal from context.Done().", this.child.Name())
                return
            default:
            }

            record, err := rd.ReadWithExtraOptions(&eopt)

            if err != nil {
                if errors.Is(err, perf.ErrClosed) {
                    return
                }
                errChan <- fmt.Errorf("%s\treading from perf event reader: %s", this.child.Name(), err)
                return
            }

            if record.LostSamples != 0 {
                this.TotalLost += record.LostSamples
                this.logger.Printf("%s\tperf event ring buffer full, dropped %d samples, record_type:%d", this.child.Name(), record.LostSamples, record.RecordType)
                continue
            }

            // 只做简单的准备 数据解析不要在这个部分做
            var e event.IEventStruct
            e, err = this.child.PrePare(em, record)
            if err != nil {
                this.logger.Printf("%s\tthis.child.decode error:%v", this.child.Name(), err)
                continue
            }
            // 准备完成将数据交给 processor 处理
            // 从而加快读取环形缓冲区的数据 减缓数据丢失的概率
            this.processor.Write(e)
        }
    }()
}

func (this *Module) PrePare(em *ebpf.Map, rec perf.Record) (event event.IEventStruct, err error) {