mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-08-04 01:40:07 +00:00
fix nil pointer in addons test
This commit is contained in:
parent
3a15a374ba
commit
00144659ec
@ -399,16 +399,17 @@ func writeRemoteFile(sshClient *ssh.Client, data, dir, fileName string, mode os.
|
|||||||
defer session.Close()
|
defer session.Close()
|
||||||
|
|
||||||
fileSize := len(data)
|
fileSize := len(data)
|
||||||
go func() {
|
pipe, err := session.StdinPipe()
|
||||||
// ignore errors here. scp whould return errors if something goes wrong.
|
if err != nil {
|
||||||
pipe, _ := session.StdinPipe()
|
return err
|
||||||
|
}
|
||||||
defer pipe.Close()
|
defer pipe.Close()
|
||||||
|
if err := session.Start(fmt.Sprintf("scp -t %s", dir)); err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
fmt.Fprintf(pipe, "C%#o %d %s\n", mode, fileSize, fileName)
|
fmt.Fprintf(pipe, "C%#o %d %s\n", mode, fileSize, fileName)
|
||||||
io.Copy(pipe, strings.NewReader(data))
|
io.Copy(pipe, strings.NewReader(data))
|
||||||
fmt.Fprint(pipe, "\x00")
|
fmt.Fprint(pipe, "\x00")
|
||||||
}()
|
pipe.Close()
|
||||||
if err := session.Run(fmt.Sprintf("scp -t %s", dir)); err != nil {
|
return session.Wait()
|
||||||
return err
|
|
||||||
}
|
|
||||||
return nil
|
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user