Method readEvents

user/module/imodule.go:157–179

()

}

func (this *Module) readEvents() error {
    var errChan = make(chan error, 8)
    // 随时记录读取事件过程中的异常情况
    go func() {
        for {
            select {
            case err := <-errChan:
                this.logger.Printf("%s\treadEvents error:%v", this.child.Name(), err)
            }
        }
    }()
    // 读取之前从eBPF程序中解析预设的map的事件数据
    for _, ebpfMap := range this.child.Events() {
        switch {
        case ebpfMap.Type() == ebpf.PerfEventArray:
            this.perfEventReader(errChan, ebpfMap)
        default:
            return fmt.Errorf("%s\tNot support mapType:%s , mapinfo:%s", this.child.Name(), ebpfMap.Type().String(), ebpfMap.String())
        }
    }

    return nil
}

func (this *Module) getExtraOptions(em *ebpf.Map) perf.ExtraPerfOptions {
    // 这里可以考虑在一开始的时候就完成初始化