Skip to content

Commit

Permalink
tetragon: Remove getDefaultObserverSensors function
Browse files Browse the repository at this point in the history
It's no longer needed, moving it to be directly getDefaultObserver
function and not to return any sensor objects.

Signed-off-by: Jiri Olsa <jolsa@kernel.org>
  • Loading branch information
olsajiri committed Sep 28, 2023
1 parent 76f6f93 commit f540ca1
Showing 1 changed file with 7 additions and 16 deletions.
23 changes: 7 additions & 16 deletions pkg/observer/observertesthelper/observer_test_helper.go
Original file line number Diff line number Diff line change
Expand Up @@ -212,9 +212,8 @@ func newDefaultObserver(oo *testObserverOptions) *observer.Observer {
return observer.NewObserver(oo.config)
}

func getDefaultObserverSensors(tb testing.TB, ctx context.Context, base *sensors.Sensor, opts ...TestOption) (*observer.Observer, []*sensors.Sensor, error) {
func getDefaultObserver(tb testing.TB, ctx context.Context, base *sensors.Sensor, opts ...TestOption) (*observer.Observer, error) {
var cnfSensor *sensors.Sensor
var ret []*sensors.Sensor

testutils.CaptureLog(tb, logger.GetLogger().(*logrus.Logger))

Expand All @@ -235,33 +234,32 @@ func getDefaultObserverSensors(tb testing.TB, ctx context.Context, base *sensors
}

if err := loadExporter(tb, ctx, obs, &o.exporter, &o.observer); err != nil {
return nil, ret, err
return nil, err
}

var tp tracingpolicy.TracingPolicy
if o.observer.config != "" {
var err error
tp, err = tracingpolicy.PolicyFromYAMLFilename(o.observer.config)
if err != nil {
return nil, ret, fmt.Errorf("failed to parse tracingpolicy: %w", err)
return nil, fmt.Errorf("failed to parse tracingpolicy: %w", err)
}
}
if tp != nil {
var err error
cnfSensor, err = sensors.GetMergedSensorFromParserPolicy(tp)
if err != nil {
return nil, ret, err
return nil, err
}
ret = append(ret, cnfSensor)
}

if err := loadSensor(tb, base, cnfSensor); err != nil {
return nil, ret, err
return nil, err
}

exportFname, err := testutils.GetExportFilename(tb)
if err != nil {
return nil, ret, err
return nil, err
}
saveInitInfo(o, exportFname)

Expand All @@ -283,16 +281,9 @@ func getDefaultObserverSensors(tb testing.TB, ctx context.Context, base *sensors
testDone(tb, obs)
})

ret = append(ret, base)

obs.PerfConfig = bpf.DefaultPerfEventConfig()
obs.PerfConfig.MapName = filepath.Join(bpf.MapPrefixPath(), "tcpmon_map")
return obs, ret, nil
}

func getDefaultObserver(tb testing.TB, ctx context.Context, base *sensors.Sensor, opts ...TestOption) (*observer.Observer, error) {
obs, _, err := getDefaultObserverSensors(tb, ctx, base, opts...)
return obs, err
return obs, nil
}

func GetDefaultObserverWithWatchers(tb testing.TB, ctx context.Context, base *sensors.Sensor, opts ...TestOption) (*observer.Observer, error) {
Expand Down

0 comments on commit f540ca1

Please sign in to comment.