import com.jcraft.jsch.Session; //导入方法依赖的package包/类

private Session startNewSession(boolean acquireChannel) throws JSchException, InterruptedException {

Session newSession = null;

final AtomicBoolean cancelled = new AtomicBoolean(false);

ConnectingProgressHandle.startHandle(env, new Cancellable() {

@Override

public boolean cancel() {

cancelled.set(true);

return true;

}

});

try {

while (!cancelled.get()) {

try {

newSession = jsch.getSession(env.getUser(), env.getHostAddress(), env.getSSHPort());

int serverAliveInterval = Integer.getInteger("jsch.server.alive.interval", 0); // NOI18N

if (serverAliveInterval > 0) {

newSession.setServerAliveInterval(serverAliveInterval);

int serverAliveCount = Integer.getInteger("jsch.server.alive.count", 5); // NOI18N

newSession.setServerAliveCountMax(serverAliveCount);

}

newSession.setUserInfo(userInfo);

for (Entry entry : jschSessionConfig.entrySet()) {

newSession.setConfig(entry.getKey(), entry.getValue());

}

Authentication auth = Authentication.getFor(env);

final String preferredAuthKey = "PreferredAuthentications"; // NOI18N

if (!jschSessionConfig.containsKey(preferredAuthKey)) {

String methods = auth.getAuthenticationMethods().toJschString();

if (methods != null) {

log.finest("Setting auth method list to " + methods); //NOI18N

newSession.setConfig(preferredAuthKey, methods);

}

}

if (USE_JZLIB) {

newSession.setConfig("compression.s2c", "[email protected],zlib,none"); // NOI18N

newSession.setConfig("compression.c2s", "[email protected],zlib,none"); // NOI18N

newSession.setConfig("compression_level", "9"); // NOI18N

}

if (RemoteStatistics.COLLECT_STATISTICS && RemoteStatistics.COLLECT_TRAFFIC) {

newSession.setSocketFactory(MeasurableSocketFactory.getInstance());

}

newSession.connect(auth.getTimeout()*1000);

break;

} catch (JSchException ex) {

if (!UNIT_TEST_MODE) {

String msg = ex.getMessage();

if (msg == null) {

throw ex;

}

if (msg.startsWith("Auth fail") || msg.startsWith("SSH_MSG_DISCONNECT: 2")) { // NOI18N

PasswordManager.getInstance().clearPassword(env);

}

} else {

throw ex;

}

} catch (CancellationException cex) {

cancelled.set(true);

}

}

if (cancelled.get()) {

throw new InterruptedException("StartNewSession was cancelled ..."); // NOI18N

}

// In case of any port-forwarding previously set for this env

// init the new session appropriately

portForwarding.initSession(newSession);

sessions.put(newSession, new AtomicInteger(JSCH_CHANNELS_PER_SESSION - (acquireChannel ? 1 : 0)));

log.log(Level.FINE, "New session [{0}] started.", new Object[]{System.identityHashCode(newSession)}); // NOI18N

} finally {

ConnectingProgressHandle.stopHandle(env);

}

return newSession;

}