blob: 7417588450cd746fc5a3e01e31b187a67da3f893 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
|
// Copyright 2025 syzkaller project authors. All rights reserved.
// Use of this source code is governed by Apache 2 LICENSE that can be found in the LICENSE file.
package aflow
type Action interface {
verify(*verifyContext)
execute(*Context) error
}
type pipeline struct {
// These actions are invoked sequentially,
// but dataflow across actions is specified by their use
// of variables in args/instructions/prompts.
actions []Action
}
func Pipeline(actions ...Action) *pipeline {
return &pipeline{
actions: actions,
}
}
func (p *pipeline) execute(ctx *Context) error {
for _, sub := range p.actions {
if err := sub.execute(ctx); err != nil {
return err
}
}
return nil
}
func (p *pipeline) verify(ctx *verifyContext) {
for _, a := range p.actions {
a.verify(ctx)
}
}
|
