You've already forked woodpecker
mirror of
https://github.com/woodpecker-ci/woodpecker.git
synced 2025-11-23 21:44:44 +02:00
44c8921c19
## problem if steps where started concurrent, the stdout pipeline reader war overwritten and you randomly got the wrong command stream from a step. ## change where we have possible race conditions, we now use thread save types e.g. store the command struct and the output reader in sync.Map also a lot of tests where added
52 lines
1.3 KiB
Go
52 lines
1.3 KiB
Go
// Copyright 2025 Woodpecker Authors
|
|
//
|
|
// Licensed under the Apache License, Version 2.0 (the "License");
|
|
// you may not use this file except in compliance with the License.
|
|
// You may obtain a copy of the License at
|
|
//
|
|
// http://www.apache.org/licenses/LICENSE-2.0
|
|
//
|
|
// Unless required by applicable law or agreed to in writing, software
|
|
// distributed under the License is distributed on an "AS IS" BASIS,
|
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
// See the License for the specific language governing permissions and
|
|
// limitations under the License.
|
|
|
|
package local
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"os/exec"
|
|
|
|
"go.woodpecker-ci.org/woodpecker/v3/pipeline/backend/types"
|
|
)
|
|
|
|
// execPlugin use step.Image as exec binary.
|
|
func (e *local) execPlugin(ctx context.Context, step *types.Step, state *workflowState, env []string) error {
|
|
binary, err := exec.LookPath(step.Image)
|
|
if err != nil {
|
|
return fmt.Errorf("lookup plugin binary: %w", err)
|
|
}
|
|
|
|
cmd := exec.CommandContext(ctx, binary)
|
|
cmd.Env = env
|
|
cmd.Dir = state.workspaceDir
|
|
|
|
reader, err := cmd.StdoutPipe()
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
// Get output and redirect Stderr to Stdout
|
|
cmd.Stderr = cmd.Stdout
|
|
|
|
// Save state
|
|
state.stepState.Store(step.UUID, &stepState{
|
|
cmd: cmd,
|
|
output: reader,
|
|
})
|
|
|
|
return cmd.Start()
|
|
}
|