Lines Matching refs:err

41 …aSSHContext(ctx context.Context, addr string, user string, passwd string, cmd string) (err error) {
44 	if err := RunCmdViaSSHContextNoRetry(ctx, addr, user, passwd, cmd); err != nil {
45 		if errors.Is(err, context.Canceled) {
46 			return err
48 		logrus.Errorf("exec cmd via SSH at %s failed: %v, try again...", addr, err)
54 …textNoRetry(ctx context.Context, addr string, user string, passwd string, cmd string) (err error) {
56 	client, err := newSSHClient(addr, user, passwd)
57 	if err != nil {
58 		logrus.Errorf("new SSH client to %s err: %v", addr, err)
59 		return err
62 	session, err := client.NewSession()
63 	if err != nil {
64 		return err
69 			err = ctx.Err()
82 	stdin, err := session.StdinPipe()
83 	if err != nil {
84 		return err
87 	stdout, err := session.StdoutPipe()
88 	if err != nil {
89 		return err
91 	stderr, err := session.StderrPipe()
92 	if err != nil {
93 		return err
95 	if err := session.Shell(); err != nil {
96 		return err
114 	c, err := newSSHClient(addr, user, passwd)
115 	if err != nil {
116 		logrus.Errorf("new SSH client to %s err: %v", addr, err)
117 		return err
120 	client, err := sftp.NewClient(c)
121 	if err != nil {
122 		logrus.Errorf("new SFTP client to %s err: %v", addr, err)
123 		return err
130 		if src, err = client.Open(remoteFile); err != nil {
131 			return fmt.Errorf("open remote file %s at %s err: %v", remoteFile, addr, err)
136 		if dst, err = os.Create(localFile); err != nil {
137 			return fmt.Errorf("create local file err: %v", err)
142 		if src, err = os.Open(localFile); err != nil {
143 			return fmt.Errorf("open local file err: %v", err)
148 		if dst, err = client.Create(remoteFile); err != nil {
149 			return fmt.Errorf("create remote file %s at %s err: %v", remoteFile, addr, err)
155 	n, err := io.CopyBuffer(dst, src, make([]byte, 32*1024*1024))
156 	if err != nil {
157 		logrus.Errorf("%s %s at %s %s %s err: %v", verb, remoteFile, addr, prep, localFile, err)
158 		return err