Method tryCopyWithoutCache

pkg/control/scp.go:104–140

(user string)

}

func (cc *ScpController) tryCopyWithoutCache(user string) {
	combinations := config.GenerateCombination(cc.destIP, user, cc.configuration)
	launchers := launcher.NewScpLaunchersByCombinations(combinations, cc.source, cc.destination,
		cc.recursive, cc.sshTimeout)
	connectors := make([]launcher.Connector, len(launchers))
	for i, l := range launchers {
		connectors[i] = l
	}
	hitLaunchers := ConcurrencyTryToConnect(cc.concurrency, connectors)
	if len(hitLaunchers) > 0 {
		utils.Infoln("Login succeeded. The cache will be added.")
		hitLauncher := hitLaunchers[0].(*launcher.ScpLauncher)
		newServerCache := launcher.GetConfigFromSSHConnector(&hitLauncher.SSHConnector)
		if cc.cacheIsFound {
			newServerCache.Alias = cc.configuration.ServerLists[cc.cacheIndex].Alias
			utils.Infoln("The old cache will be deleted.")
			cc.configuration.ServerLists = append(
				cc.configuration.ServerLists[:cc.cacheIndex], cc.configuration.ServerLists[cc.cacheIndex+1:]...)
		}
		cc.configuration.ServerLists = append(cc.configuration.ServerLists, *newServerCache)
		if err := config.UpdateConfig(cc.configuration); err == nil {
			utils.Infoln("Cache added.")
			if cc.sshTimeout > sshClientTimeoutWhenLogin {
				hitLauncher.SSHTimeout = cc.sshTimeout
			} else {
				hitLauncher.SSHTimeout = sshClientTimeoutWhenLogin
			}
			if !hitLauncher.Launch() {
				utils.Errorf("Login failed.\n")
			}
		} else {
			utils.Errorf("Cache added failed.\n\n")
		}
	} else {
		utils.Errorf("There is no password combination that can log in.\n")
	}
}

// NewScpController creates a new ScpController for the given source, destination, and configuration.
func NewScpController(source string, destination string, configuration *config.MainConfig) *ScpController {