svn commit: r933266 - /mina/sshd/trunk/sshd-core/src/main/java/org/apache/sshd/server/session/ServerSession.java

[gn...@apache.org]

Author: gnodet
Date: Mon Apr 12 14:59:38 2010
New Revision: 933266

URL: http://svn.apache.org/viewvc?rev=933266&view=rev
Log:
[sshd] minor reformat

Modified:
    mina/sshd/trunk/sshd-core/src/main/java/org/apache/sshd/server/session/ServerSession.java

Modified: mina/sshd/trunk/sshd-core/src/main/java/org/apache/sshd/server/session/ServerSession.java
URL: http://svn.apache.org/viewvc/mina/sshd/trunk/sshd-core/src/main/java/org/apache/sshd/server/session/ServerSession.java?rev=933266&r1=933265&r2=933266&view=diff
==============================================================================
--- mina/sshd/trunk/sshd-core/src/main/java/org/apache/sshd/server/session/ServerSession.java (original)
+++ mina/sshd/trunk/sshd-core/src/main/java/org/apache/sshd/server/session/ServerSession.java Mon Apr 12 14:59:38 2010
@@ -83,7 +83,7 @@ public class ServerSession extends Abstr
         authTimeout = getIntProperty(FactoryManager.AUTH_TIMEOUT, authTimeout);
         tcpipForward = new TcpipForwardSupport(this);
         agentForward = new AgentForwardSupport(this);
-        x11Forward = new X11ForwardSupport (this);
+        x11Forward = new X11ForwardSupport(this);
         log.info("Session created...");
         sendServerIdentification();
         sendKexInit();
@@ -94,7 +94,7 @@ public class ServerSession extends Abstr
         unscheduleAuthTimer();
         tcpipForward.close();
         agentForward.close();
-        x11Forward.close ();
+        x11Forward.close();
         return super.close(immediately);
     }
 
@@ -435,7 +435,7 @@ public class ServerSession extends Abstr
                         Buffer buf = createBuffer(SshConstants.Message.SSH_MSG_CHANNEL_OPEN_FAILURE, 0);
                         buf.putInt(id);
                         if (future.getException() instanceof OpenChannelException) {
-                            buf.putInt(((OpenChannelException)future.getException()).getReasonCode());
+                            buf.putInt(((OpenChannelException) future.getException()).getReasonCode());
                             buf.putString(future.getException().getMessage());
                         } else {
                             buf.putInt(0);
@@ -455,7 +455,7 @@ public class ServerSession extends Abstr
         String req = buffer.getString();
         boolean wantReply = buffer.getBoolean();
         if (req.equals("keepalive@openssh.com")) {
-          // Relatively standard KeepAlive directive, just wants failure
+            // Relatively standard KeepAlive directive, just wants failure
         } else if (req.equals("no-more-sessions@openssh.com")) {
             allowMoreSessions = false;
         } else if (req.equals("tcpip-forward")) {
@@ -465,10 +465,10 @@ public class ServerSession extends Abstr
             tcpipForward.cancel(buffer, wantReply);
             return;
         } else {
-            log.info("Received SSH_MSG_GLOBAL_REQUEST {}" ,req);
+            log.info("Received SSH_MSG_GLOBAL_REQUEST {}", req);
             log.error("Unknown global request: {}", req);
         }
-        if (wantReply){
+        if (wantReply) {
             buffer = createBuffer(SshConstants.Message.SSH_MSG_REQUEST_FAILURE, 0);
             writePacket(buffer);
         }