fix ssh logging
Ensure correct formatting and add a log level to all output.
This commit is contained in:
parent
060a3bc6d2
commit
3c30f04e0e
|
@ -152,7 +152,7 @@ func (c *Communicator) Connect(o terraform.UIOutput) (err error) {
|
|||
}
|
||||
}
|
||||
|
||||
log.Printf("connecting to TCP connection for SSH")
|
||||
log.Printf("[DEBUG] connecting to TCP connection for SSH")
|
||||
c.conn, err = c.config.connection()
|
||||
if err != nil {
|
||||
// Explicitly set this to the REAL nil. Connection() can return
|
||||
|
@ -163,11 +163,11 @@ func (c *Communicator) Connect(o terraform.UIOutput) (err error) {
|
|||
// http://golang.org/doc/faq#nil_error
|
||||
c.conn = nil
|
||||
|
||||
log.Printf("connection error: %s", err)
|
||||
log.Printf("[ERROR] connection error: %s", err)
|
||||
return err
|
||||
}
|
||||
|
||||
log.Printf("handshaking with SSH")
|
||||
log.Printf("[DEBUG] handshaking with SSH")
|
||||
host := fmt.Sprintf("%s:%d", c.connInfo.Host, c.connInfo.Port)
|
||||
sshConn, sshChan, req, err := ssh.NewClientConn(c.conn, host, c.config.config)
|
||||
if err != nil {
|
||||
|
@ -272,7 +272,7 @@ func (c *Communicator) Start(cmd *remote.Cmd) error {
|
|||
}
|
||||
}
|
||||
|
||||
log.Printf("starting remote command: %s", cmd.Command)
|
||||
log.Printf("[DEBUG] starting remote command: %s", cmd.Command)
|
||||
err = session.Start(strings.TrimSpace(cmd.Command) + "\n")
|
||||
if err != nil {
|
||||
return err
|
||||
|
@ -293,7 +293,7 @@ func (c *Communicator) Start(cmd *remote.Cmd) error {
|
|||
}
|
||||
|
||||
cmd.SetExitStatus(exitStatus, err)
|
||||
log.Printf("remote command exited with '%d': %s", exitStatus, cmd.Command)
|
||||
log.Printf("[DEBUG] remote command exited with '%d': %s", exitStatus, cmd.Command)
|
||||
}()
|
||||
|
||||
return nil
|
||||
|
@ -375,7 +375,7 @@ func (c *Communicator) UploadScript(path string, input io.Reader) error {
|
|||
|
||||
// UploadDir implementation of communicator.Communicator interface
|
||||
func (c *Communicator) UploadDir(dst string, src string) error {
|
||||
log.Printf("Uploading dir '%s' to '%s'", src, dst)
|
||||
log.Printf("[DEBUG] Uploading dir '%s' to '%s'", src, dst)
|
||||
scpFunc := func(w io.Writer, r *bufio.Reader) error {
|
||||
uploadEntries := func() error {
|
||||
f, err := os.Open(src)
|
||||
|
@ -393,7 +393,7 @@ func (c *Communicator) UploadDir(dst string, src string) error {
|
|||
}
|
||||
|
||||
if src[len(src)-1] != '/' {
|
||||
log.Printf("No trailing slash, creating the source directory name")
|
||||
log.Printf("[DEBUG] No trailing slash, creating the source directory name")
|
||||
return scpUploadDirProtocol(filepath.Base(src), w, r, uploadEntries)
|
||||
}
|
||||
// Trailing slash, so only upload the contents
|
||||
|
@ -404,7 +404,7 @@ func (c *Communicator) UploadDir(dst string, src string) error {
|
|||
}
|
||||
|
||||
func (c *Communicator) newSession() (session *ssh.Session, err error) {
|
||||
log.Println("opening new ssh session")
|
||||
log.Println("[DEBUG] opening new ssh session")
|
||||
if c.client == nil {
|
||||
err = errors.New("client not available")
|
||||
} else {
|
||||
|
@ -412,7 +412,7 @@ func (c *Communicator) newSession() (session *ssh.Session, err error) {
|
|||
}
|
||||
|
||||
if err != nil {
|
||||
log.Printf("ssh session open error: '%s', attempting reconnect", err)
|
||||
log.Printf("[WARN] ssh session open error: '%s', attempting reconnect", err)
|
||||
if err := c.Connect(nil); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
@ -457,7 +457,7 @@ func (c *Communicator) scpSession(scpCommand string, f func(io.Writer, *bufio.Re
|
|||
|
||||
// Start the sink mode on the other side
|
||||
// TODO(mitchellh): There are probably issues with shell escaping the path
|
||||
log.Println("Starting remote scp process: ", scpCommand)
|
||||
log.Println("[DEBUG] Starting remote scp process: ", scpCommand)
|
||||
if err := session.Start(scpCommand); err != nil {
|
||||
return err
|
||||
}
|
||||
|
@ -465,7 +465,7 @@ func (c *Communicator) scpSession(scpCommand string, f func(io.Writer, *bufio.Re
|
|||
// Call our callback that executes in the context of SCP. We ignore
|
||||
// EOF errors if they occur because it usually means that SCP prematurely
|
||||
// ended on the other side.
|
||||
log.Println("Started SCP session, beginning transfers...")
|
||||
log.Println("[DEBUG] Started SCP session, beginning transfers...")
|
||||
if err := f(stdinW, stdoutR); err != nil && err != io.EOF {
|
||||
return err
|
||||
}
|
||||
|
@ -473,19 +473,19 @@ func (c *Communicator) scpSession(scpCommand string, f func(io.Writer, *bufio.Re
|
|||
// Close the stdin, which sends an EOF, and then set w to nil so that
|
||||
// our defer func doesn't close it again since that is unsafe with
|
||||
// the Go SSH package.
|
||||
log.Println("SCP session complete, closing stdin pipe.")
|
||||
log.Println("[DEBUG] SCP session complete, closing stdin pipe.")
|
||||
stdinW.Close()
|
||||
stdinW = nil
|
||||
|
||||
// Wait for the SCP connection to close, meaning it has consumed all
|
||||
// our data and has completed. Or has errored.
|
||||
log.Println("Waiting for SSH session to complete.")
|
||||
log.Println("[DEBUG] Waiting for SSH session to complete.")
|
||||
err = session.Wait()
|
||||
if err != nil {
|
||||
if exitErr, ok := err.(*ssh.ExitError); ok {
|
||||
// Otherwise, we have an ExitErorr, meaning we can just read
|
||||
// the exit status
|
||||
log.Printf(exitErr.String())
|
||||
log.Printf("[ERROR] %s", exitErr)
|
||||
|
||||
// If we exited with status 127, it means SCP isn't available.
|
||||
// Return a more descriptive error for that.
|
||||
|
@ -499,7 +499,11 @@ func (c *Communicator) scpSession(scpCommand string, f func(io.Writer, *bufio.Re
|
|||
return err
|
||||
}
|
||||
|
||||
log.Printf("scp stderr (length %d): %s", stderr.Len(), stderr.String())
|
||||
scpErr := stderr.String()
|
||||
if len(scpErr) > 0 {
|
||||
log.Printf("[ERROR] scp stderr: %q", stderr)
|
||||
}
|
||||
|
||||
return nil
|
||||
}
|
||||
|
||||
|
@ -536,7 +540,7 @@ func scpUploadFile(dst string, src io.Reader, w io.Writer, r *bufio.Reader, size
|
|||
defer os.Remove(tf.Name())
|
||||
defer tf.Close()
|
||||
|
||||
log.Println("Copying input data into temporary file so we can read the length")
|
||||
log.Println("[DEBUG] Copying input data into temporary file so we can read the length")
|
||||
if _, err := io.Copy(tf, src); err != nil {
|
||||
return err
|
||||
}
|
||||
|
@ -562,7 +566,7 @@ func scpUploadFile(dst string, src io.Reader, w io.Writer, r *bufio.Reader, size
|
|||
}
|
||||
|
||||
// Start the protocol
|
||||
log.Println("Beginning file upload...")
|
||||
log.Println("[DEBUG] Beginning file upload...")
|
||||
fmt.Fprintln(w, "C0644", size, dst)
|
||||
if err := checkSCPStatus(r); err != nil {
|
||||
return err
|
||||
|
@ -581,7 +585,7 @@ func scpUploadFile(dst string, src io.Reader, w io.Writer, r *bufio.Reader, size
|
|||
}
|
||||
|
||||
func scpUploadDirProtocol(name string, w io.Writer, r *bufio.Reader, f func() error) error {
|
||||
log.Printf("SCP: starting directory upload: %s", name)
|
||||
log.Printf("[DEBUG] SCP: starting directory upload: %s", name)
|
||||
fmt.Fprintln(w, "D0755 0", name)
|
||||
err := checkSCPStatus(r)
|
||||
if err != nil {
|
||||
|
|
Loading…
Reference in New Issue