github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-26 13:07:07 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #112975 from pohly/e2e-storage-proxy

Browse Source 
e2e storage: proxy workarounds
This commit is contained in:
Kubernetes Prow Robot 2022-10-11 07:09:02 -07:00 committed by GitHub
commit 4516c7972d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 26 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
test/e2e/storage/drivers/proxy/io.go
View File

@ -17,9 +17,11 @@ limitations under the License.
package proxy package proxy
import ( import (
"encoding/base64"
"fmt" "fmt"
"io" "io"
"k8s.io/klog/v2"
"k8s.io/kubernetes/test/e2e/framework" "k8s.io/kubernetes/test/e2e/framework"
e2epod "k8s.io/kubernetes/test/e2e/framework/pod" e2epod "k8s.io/kubernetes/test/e2e/framework/pod"
"k8s.io/kubernetes/test/e2e/storage/drivers/csi-test/mock/service" "k8s.io/kubernetes/test/e2e/storage/drivers/csi-test/mock/service"
@ -30,6 +32,7 @@ type PodDirIO struct {
Namespace string Namespace string
PodName string PodName string
ContainerName string ContainerName string
Logger *klog.Logger
} }
var _ service.DirIO = PodDirIO{} var _ service.DirIO = PodDirIO{}
@ -64,9 +67,23 @@ func (p PodDirIO) Mkdir(path string) error {
} }
func (p PodDirIO) CreateFile(path string, content io.Reader) error { func (p PodDirIO) CreateFile(path string, content io.Reader) error {
_, stderr, err := p.execute([]string{"dd", "of=" + path}, content) // Piping the content into dd via stdin turned out to be unreliable.
// Sometimes dd would stop after writing zero bytes, without an error
// from ExecWithOptions (reported as
// https://github.com/kubernetes/kubernetes/issues/112834).
//
// Therefore the content is now encoded inside the command itself.
data, err := io.ReadAll(content)
if err != nil { if err != nil {
return fmt.Errorf("dd of=%s: stderr=%q, %v", path, stderr, err) return fmt.Errorf("read content: %v", err)
}
encoded := make([]byte, base64.StdEncoding.EncodedLen(len(data)))
base64.StdEncoding.Encode(encoded, data)
_, stderr, err := p.execute([]string{"sh", "-c", fmt.Sprintf(`base64 -d >'%s' <<EOF
%s
EOF`, path, string(encoded))}, nil)
if err != nil {
return fmt.Errorf("decoding into %q: stderr=%q, %v", path, stderr, err)
} }
return nil return nil
} }
@ -88,7 +105,7 @@ func (p PodDirIO) RemoveAll(path string) error {
} }
func (p PodDirIO) execute(command []string, stdin io.Reader) (string, string, error) { func (p PodDirIO) execute(command []string, stdin io.Reader) (string, string, error) {
return e2epod.ExecWithOptions(p.F, e2epod.ExecOptions{ stdout, stderr, err := e2epod.ExecWithOptions(p.F, e2epod.ExecOptions{
Command: command, Command: command,
Namespace: p.Namespace, Namespace: p.Namespace,
PodName: p.PodName, PodName: p.PodName,
@ -98,4 +115,10 @@ func (p PodDirIO) execute(command []string, stdin io.Reader) (string, string, er
CaptureStderr: true, CaptureStderr: true,
Quiet: true, Quiet: true,
}) })
if p.Logger != nil {
p.Logger.Info("Command completed", "command", command, "stdout", stdout, "stderr", stderr, "err", err)
}
return stdout, stderr, err
} }