mirror of
https://github.com/containers/podman.git
synced 2025-06-25 12:20:42 +08:00
Merge pull request #18921 from fangpenlin/fix-18907-set-correct-cwd-for-poststop-hook-exe
Fixes #18907, pass in correct cwd value for hooks exe
This commit is contained in:
@ -2094,7 +2094,17 @@ func (c *Container) postDeleteHooks(ctx context.Context) error {
|
|||||||
hook := hook
|
hook := hook
|
||||||
logrus.Debugf("container %s: invoke poststop hook %d, path %s", c.ID(), i, hook.Path)
|
logrus.Debugf("container %s: invoke poststop hook %d, path %s", c.ID(), i, hook.Path)
|
||||||
var stderr, stdout bytes.Buffer
|
var stderr, stdout bytes.Buffer
|
||||||
hookErr, err := exec.Run(ctx, &hook, state, &stdout, &stderr, exec.DefaultPostKillTimeout) //nolint:staticcheck
|
hookErr, err := exec.RunWithOptions(
|
||||||
|
ctx,
|
||||||
|
exec.RunOptions{
|
||||||
|
Hook: &hook,
|
||||||
|
Dir: c.bundlePath(),
|
||||||
|
State: state,
|
||||||
|
Stdout: &stdout,
|
||||||
|
Stderr: &stderr,
|
||||||
|
PostKillTimeout: exec.DefaultPostKillTimeout,
|
||||||
|
},
|
||||||
|
)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
logrus.Warnf("Container %s: poststop hook %d: %v", c.ID(), i, err)
|
logrus.Warnf("Container %s: poststop hook %d: %v", c.ID(), i, err)
|
||||||
if hookErr != err {
|
if hookErr != err {
|
||||||
@ -2223,7 +2233,15 @@ func (c *Container) setupOCIHooks(ctx context.Context, config *spec.Spec) (map[s
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
hookErr, err := exec.RuntimeConfigFilter(ctx, allHooks["precreate"], config, exec.DefaultPostKillTimeout) //nolint:staticcheck
|
hookErr, err := exec.RuntimeConfigFilterWithOptions(
|
||||||
|
ctx,
|
||||||
|
exec.RuntimeConfigFilterOptions{
|
||||||
|
Hooks: allHooks["precreate"],
|
||||||
|
Dir: c.bundlePath(),
|
||||||
|
Config: config,
|
||||||
|
PostKillTimeout: exec.DefaultPostKillTimeout,
|
||||||
|
},
|
||||||
|
)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
logrus.Warnf("Container %s: precreate hook: %v", c.ID(), err)
|
logrus.Warnf("Container %s: precreate hook: %v", c.ID(), err)
|
||||||
if hookErr != nil && hookErr != err {
|
if hookErr != nil && hookErr != err {
|
||||||
|
@ -6,6 +6,7 @@ import (
|
|||||||
"os"
|
"os"
|
||||||
"path/filepath"
|
"path/filepath"
|
||||||
"runtime"
|
"runtime"
|
||||||
|
"strings"
|
||||||
"testing"
|
"testing"
|
||||||
|
|
||||||
"github.com/containers/storage/pkg/idtools"
|
"github.com/containers/storage/pkg/idtools"
|
||||||
@ -142,6 +143,7 @@ func TestPostDeleteHooks(t *testing.T) {
|
|||||||
|
|
||||||
statePath := filepath.Join(dir, "state")
|
statePath := filepath.Join(dir, "state")
|
||||||
copyPath := filepath.Join(dir, "copy")
|
copyPath := filepath.Join(dir, "copy")
|
||||||
|
cwdPath := filepath.Join(dir, "cwd")
|
||||||
c := Container{
|
c := Container{
|
||||||
runtime: &Runtime{},
|
runtime: &Runtime{},
|
||||||
config: &ContainerConfig{
|
config: &ContainerConfig{
|
||||||
@ -169,6 +171,10 @@ func TestPostDeleteHooks(t *testing.T) {
|
|||||||
Path: hookPath,
|
Path: hookPath,
|
||||||
Args: []string{"sh", "-c", fmt.Sprintf("cp %s %s", statePath, copyPath)},
|
Args: []string{"sh", "-c", fmt.Sprintf("cp %s %s", statePath, copyPath)},
|
||||||
},
|
},
|
||||||
|
rspec.Hook{
|
||||||
|
Path: hookPath,
|
||||||
|
Args: []string{"sh", "-c", fmt.Sprintf("pwd >%s", cwdPath)},
|
||||||
|
},
|
||||||
},
|
},
|
||||||
},
|
},
|
||||||
},
|
},
|
||||||
@ -188,6 +194,11 @@ func TestPostDeleteHooks(t *testing.T) {
|
|||||||
assert.Regexp(t, stateRegexp, string(content))
|
assert.Regexp(t, stateRegexp, string(content))
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
content, err := os.ReadFile(cwdPath)
|
||||||
|
if err != nil {
|
||||||
|
t.Fatal(err)
|
||||||
|
}
|
||||||
|
assert.Equal(t, strings.TrimSuffix(string(content), "\n"), dir)
|
||||||
}
|
}
|
||||||
|
|
||||||
func init() {
|
func init() {
|
||||||
|
Reference in New Issue
Block a user