February 2008 - jboss-remoting-commits

JBoss Remoting SVN: r3466 - remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core.

by jboss-remoting-commits＠lists.jboss.org

Author: david.lloyd(a)jboss.com Date: 2008-02-21 11:12:31 -0500 (Thu, 21 Feb 2008) New Revision: 3466 Modified: remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/CoreSession.java Log: Fix an NPE on client connections Modified: remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/CoreSession.java =================================================================== --- remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/CoreSession.java 2008-02-21 16:08:55 UTC (rev 3465) +++ remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/CoreSession.java 2008-02-21 16:12:31 UTC (rev 3466) @@ -106,7 +106,7 @@ } state.requireTransitionExclusive(State.NEW, State.CONNECTING); try { - protocolHandlerFactory.createHandler(protocolContext, remoteUri, attributeMap); + protocolHandler = protocolHandlerFactory.createHandler(protocolContext, remoteUri, attributeMap); } finally { state.releaseExclusive(); }

16 years, 9 months

1
0
0 / 0

JBoss Remoting SVN: r3465 - in remoting3/trunk: util/src/main/java/org/jboss/cx/remoting/core/util and 1 other directory.

by jboss-remoting-commits＠lists.jboss.org

Author: david.lloyd(a)jboss.com Date: 2008-02-21 11:08:55 -0500 (Thu, 21 Feb 2008) New Revision: 3465 Modified: remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppConnection.java remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppProtocolSupport.java remoting3/trunk/util/src/main/java/org/jboss/cx/remoting/core/util/AtomicStateMachine.java Log: Improve handling of errors on connect Modified: remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppConnection.java =================================================================== --- remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppConnection.java 2008-02-21 15:38:16 UTC (rev 3464) +++ remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppConnection.java 2008-02-21 16:08:55 UTC (rev 3465) @@ -77,6 +77,7 @@ private IoSession ioSession; private String remoteName; private ProtocolContext protocolContext; + private IOException failureReason; /** * The negotiated protocol version. Value is set to {@code min(PROTOCOL_VERSION, remote PROTOCOL_VERSION)}. @@ -106,6 +107,8 @@ UP, /** Session is shutting down or closed */ CLOSED, + /** Session failed to connect */ + FAILED, } private final AtomicStateMachine<State> state = AtomicStateMachine.start(State.NEW); @@ -336,11 +339,13 @@ output.commit(); } - public boolean waitForUp() throws IOException { - while (! state.in(State.UP, State.CLOSED)) { + public void waitForUp() throws IOException { + while (! state.in(State.UP, State.FAILED)) { state.waitForAny(); } - return state.in(State.UP); + if (state.in(State.FAILED)) { + throw failureReason; + } } private void close() { @@ -349,6 +354,13 @@ protocolContext.closeSession(); } + private void fail(IOException reason) { + if (state.transitionExclusive(State.FAILED)) { + failureReason = reason; + state.releaseExclusive(); + } + } + private static IoBuffer newBuffer(final int initialSize, final boolean autoexpand) { return IoBuffer.allocate(initialSize + 4).setAutoExpand(autoexpand).skip(4); } @@ -589,7 +601,24 @@ } public void sessionClosed() { - close(); + State current = state.getStateExclusive(); + try { + switch (current) { + case AWAITING_CLIENT_AUTH_REQUEST: + case AWAITING_CLIENT_RESPONSE: + case AWAITING_CLIENT_VERSION: + case AWAITING_SERVER_CHALLENGE: + case AWAITING_SERVER_VERSION: + case NEW: + fail(new IOException("Unexpected session close")); + return; + default: + close(); + return; + } + } finally { + state.releaseExclusive(); + } } public void sessionIdle(IdleStatus idleStatus) { @@ -597,7 +626,11 @@ public void exceptionCaught(Throwable throwable) { log.error(throwable, "Exception from JRPP connection handler"); - close(); + if (throwable instanceof IOException) { + fail((IOException)throwable); + } else { + fail(new IOException("Unexpected exception from handler: " + throwable.toString())); + } } private ContextIdentifier readCtxtId(MessageInput input) throws IOException { @@ -656,6 +689,7 @@ output.commit(); saslServerFilter.startEncryption(ioSession); state.requireTransition(State.AWAITING_CLIENT_RESPONSE, State.UP); + protocolContext.openSession(remoteName); } } catch (SaslException ex) { final IoBuffer buffer = newBuffer(100, true); @@ -699,6 +733,7 @@ write(output, MessageType.AUTH_SUCCESS); output.commit(); state.requireTransition(State.UP); + protocolContext.openSession(remoteName); } else { state.requireTransition(State.AWAITING_CLIENT_RESPONSE); } @@ -749,6 +784,7 @@ SaslClientFilter saslClientFilter = getSaslClientFilter(); saslClientFilter.startEncryption(ioSession); state.requireTransition(State.AWAITING_SERVER_CHALLENGE, State.UP); + protocolContext.openSession(remoteName); return; } case AUTH_FAILED: { Modified: remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppProtocolSupport.java =================================================================== --- remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppProtocolSupport.java 2008-02-21 15:38:16 UTC (rev 3464) +++ remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppProtocolSupport.java 2008-02-21 16:08:55 UTC (rev 3465) @@ -150,6 +150,7 @@ } }); future.awaitUninterruptibly(); + jrppConnection.waitForUp(); return jrppConnection.getProtocolHandler(); } Modified: remoting3/trunk/util/src/main/java/org/jboss/cx/remoting/core/util/AtomicStateMachine.java =================================================================== --- remoting3/trunk/util/src/main/java/org/jboss/cx/remoting/core/util/AtomicStateMachine.java 2008-02-21 15:38:16 UTC (rev 3464) +++ remoting3/trunk/util/src/main/java/org/jboss/cx/remoting/core/util/AtomicStateMachine.java 2008-02-21 16:08:55 UTC (rev 3465) @@ -81,6 +81,19 @@ } } + public boolean transitionExclusive(final T state) { + if (state == null) { + throw new NullPointerException("state is null"); + } + writeLock.lock(); + if (this.state == state) { + return false; + } + this.state = state; + cond.signalAll(); + return true; + } + /** * Release a held state. Must be called from the same thread that is holding the state. */

16 years, 9 months

1
0
0 / 0

JBoss Remoting SVN: r3464 - in remoting3/trunk: srp/src/main/java/org/jboss/cx/remoting/core/security/sasl and 1 other directory.

by jboss-remoting-commits＠lists.jboss.org

Author: david.lloyd(a)jboss.com Date: 2008-02-21 10:38:16 -0500 (Thu, 21 Feb 2008) New Revision: 3464 Modified: remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppConnection.java remoting3/trunk/srp/src/main/java/org/jboss/cx/remoting/core/security/sasl/SrpSaslClientImpl.java remoting3/trunk/srp/src/main/java/org/jboss/cx/remoting/core/security/sasl/SrpSaslServerImpl.java Log: Use 'password' verifier mode by default; fix bug where authentication always fails; clean up error messages Modified: remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppConnection.java =================================================================== --- remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppConnection.java 2008-02-21 15:17:59 UTC (rev 3463) +++ remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppConnection.java 2008-02-21 15:38:16 UTC (rev 3464) @@ -194,6 +194,7 @@ defaultProps.put(Sasl.POLICY_NODICTIONARY, "true"); defaultProps.put(Sasl.POLICY_NOACTIVE, "true"); defaultProps.put(Sasl.QOP, "auth-conf"); + defaultProps.put("org.jboss.cx.remoting.sasl.srp.verifier", "password"); return defaultProps; } @@ -208,13 +209,14 @@ if (callback instanceof NameCallback) { ((NameCallback)callback).setName("anonymous"); } else if (callback instanceof PasswordCallback) { - ((PasswordCallback)callback).setPassword(new char[0]); + ((PasswordCallback)callback).setPassword("password".toCharArray()); } else if (callback instanceof RealmCallback) { continue; } else if (callback instanceof AuthorizeCallback) { ((AuthorizeCallback)callback).setAuthorized(true); + } else { + throw new UnsupportedCallbackException(callback, "Default anonymous server callback handler cannot support this callback type: " + callback.getClass().getName()); } - throw new UnsupportedCallbackException(callback, "Default anonymous server callback handler cannot support this callback type"); } } }; @@ -231,11 +233,11 @@ if (callback instanceof NameCallback) { ((NameCallback)callback).setName("anonymous"); } else if (callback instanceof PasswordCallback) { - ((PasswordCallback)callback).setPassword(new char[0]); + ((PasswordCallback)callback).setPassword("password".toCharArray()); } else if (callback instanceof RealmCallback) { ((RealmCallback)callback).setText("default"); } else { - throw new UnsupportedCallbackException(callback, "Default anonymous client callback handler cannot support this callback type"); + throw new UnsupportedCallbackException(callback, "Default anonymous client callback handler cannot support this callback type: " + callback.getClass().getName()); } } } Modified: remoting3/trunk/srp/src/main/java/org/jboss/cx/remoting/core/security/sasl/SrpSaslClientImpl.java =================================================================== --- remoting3/trunk/srp/src/main/java/org/jboss/cx/remoting/core/security/sasl/SrpSaslClientImpl.java 2008-02-21 15:17:59 UTC (rev 3463) +++ remoting3/trunk/srp/src/main/java/org/jboss/cx/remoting/core/security/sasl/SrpSaslClientImpl.java 2008-02-21 15:38:16 UTC (rev 3464) @@ -155,7 +155,7 @@ throw new SaslException("Callback handler provided an empty value for SRP password"); } } catch (Exception e) { - throw new SaslException("Failed to handle callbacks for SRP", e); + throw new SaslException("Failed to handle callbacks for SRP: " + e.getMessage(), e); } if (authorizationId == null) { authorizationId = ""; Modified: remoting3/trunk/srp/src/main/java/org/jboss/cx/remoting/core/security/sasl/SrpSaslServerImpl.java =================================================================== --- remoting3/trunk/srp/src/main/java/org/jboss/cx/remoting/core/security/sasl/SrpSaslServerImpl.java 2008-02-21 15:17:59 UTC (rev 3463) +++ remoting3/trunk/srp/src/main/java/org/jboss/cx/remoting/core/security/sasl/SrpSaslServerImpl.java 2008-02-21 15:38:16 UTC (rev 3464) @@ -227,13 +227,13 @@ // Catch this first, because SaslException extends IOException throw e; } catch (IOException e) { - throw new SaslException("Failed to handle callbacks for SRP", e); + throw new SaslException("Authentication failed (I/O exception: " + e.getMessage() + ")", e); } catch (UnsupportedCallbackException e) { - throw new SaslException("Failed to handle callbacks for SRP (unsupported callback type)", e); + throw new SaslException("Authentication failed (callback unsupported: " + e.getMessage() + ")", e); } catch (NoSuchAlgorithmException e) { - throw new SaslException("Failed to handle callbacks for SRP (no such algorithm)", e); + throw new SaslException("Authentication failed (no such algorithm: " + e.getMessage() + ")", e); } catch (Base64DecodingException e) { - throw new SaslException("Failed to handle callbacks for SRP (Base64 decode failed)", e); + throw new SaslException("Authentication failed (Base64 decode failed: " + e.getMessage() + ")", e); } final BigInteger N = verifier.getSafePrime(); @@ -372,9 +372,9 @@ } catch (SaslException e) { throw e; } catch (IOException e) { - throw new SaslException("Authorization failed (I/O exception)", e); + throw new SaslException("Authorization failed (I/O exception: " + e.getMessage() + ")", e); } catch (UnsupportedCallbackException e) { - throw new SaslException("Authorization failed (callback unsupported)", e); + throw new SaslException("Authorization failed (callback unsupported: " + e.getMessage() + ")", e); } authorizationId = authorizeCallback.getAuthorizedID(); if (authorizationId == null || ! authorizeCallback.isAuthorized()) {

16 years, 9 months

1
0
0 / 0

JBoss Remoting SVN: r3463 - in remoting3/trunk: api/src/main/java/org/jboss/cx/remoting/spi/protocol and 5 other directories.

by jboss-remoting-commits＠lists.jboss.org

Author: david.lloyd(a)jboss.com Date: 2008-02-21 10:17:59 -0500 (Thu, 21 Feb 2008) New Revision: 3463 Modified: remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/CommonKeys.java remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/Endpoint.java remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/spi/protocol/ProtocolContext.java remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/CoreEndpoint.java remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/CoreInboundRequest.java remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/CoreOutboundContext.java remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/CoreSession.java remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/CoreStream.java remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/LocalProtocol.java remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/stream/InputStreamStreamSerializerFactory.java remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppConnection.java remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppProtocolSupport.java remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppServer.java remoting3/trunk/standalone/src/main/java/org/jboss/cx/remoting/Remoting.java remoting3/trunk/util/src/main/java/org/jboss/cx/remoting/core/util/AttributeHashMap.java remoting3/trunk/util/src/main/java/org/jboss/cx/remoting/core/util/AttributeMap.java remoting3/trunk/util/src/main/java/org/jboss/cx/remoting/core/util/IoUtil.java remoting3/trunk/util/src/main/java/org/jboss/cx/remoting/core/util/MessageInput.java remoting3/trunk/util/src/main/java/org/jboss/cx/remoting/core/util/ServiceURI.java Log: Clean up imports Modified: remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/CommonKeys.java =================================================================== --- remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/CommonKeys.java 2008-02-21 15:15:06 UTC (rev 3462) +++ remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/CommonKeys.java 2008-02-21 15:17:59 UTC (rev 3463) @@ -1,15 +1,13 @@ package org.jboss.cx.remoting; -import org.jboss.cx.remoting.core.util.AttributeKey; - +import java.util.List; import java.util.Map; import java.util.Set; -import java.util.List; +import org.jboss.cx.remoting.core.util.AttributeKey; +import static org.jboss.cx.remoting.core.util.AttributeKey.key; import javax.security.auth.callback.CallbackHandler; -import static org.jboss.cx.remoting.core.util.AttributeKey.key; - /** * A set of attribute keys that are common across various protocols. */ Modified: remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/Endpoint.java =================================================================== --- remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/Endpoint.java 2008-02-21 15:15:06 UTC (rev 3462) +++ remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/Endpoint.java 2008-02-21 15:17:59 UTC (rev 3463) @@ -2,11 +2,11 @@ import java.net.URI; import java.util.concurrent.ConcurrentMap; +import org.jboss.cx.remoting.core.util.AttributeMap; import org.jboss.cx.remoting.spi.Discovery; import org.jboss.cx.remoting.spi.Registration; import org.jboss.cx.remoting.spi.protocol.ProtocolRegistration; import org.jboss.cx.remoting.spi.protocol.ProtocolRegistrationSpec; -import org.jboss.cx.remoting.core.util.AttributeMap; /** * A potential participant in a JBoss Remoting communications relationship. Modified: remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/spi/protocol/ProtocolContext.java =================================================================== --- remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/spi/protocol/ProtocolContext.java 2008-02-21 15:15:06 UTC (rev 3462) +++ remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/spi/protocol/ProtocolContext.java 2008-02-21 15:17:59 UTC (rev 3463) @@ -6,8 +6,8 @@ import org.jboss.cx.remoting.ServiceLocator; import org.jboss.cx.remoting.core.util.ByteInput; import org.jboss.cx.remoting.core.util.ByteOutput; +import org.jboss.cx.remoting.core.util.MessageInput; import org.jboss.cx.remoting.core.util.MessageOutput; -import org.jboss.cx.remoting.core.util.MessageInput; /** * Modified: remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/CoreEndpoint.java =================================================================== --- remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/CoreEndpoint.java 2008-02-21 15:15:06 UTC (rev 3462) +++ remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/CoreEndpoint.java 2008-02-21 15:17:59 UTC (rev 3463) @@ -20,8 +20,8 @@ import org.jboss.cx.remoting.ServiceLocator; import org.jboss.cx.remoting.Session; import org.jboss.cx.remoting.core.util.AtomicStateMachine; +import org.jboss.cx.remoting.core.util.AttributeMap; import org.jboss.cx.remoting.core.util.CollectionUtil; -import org.jboss.cx.remoting.core.util.AttributeMap; import org.jboss.cx.remoting.spi.Discovery; import org.jboss.cx.remoting.spi.Registration; import org.jboss.cx.remoting.spi.protocol.ProtocolContext; Modified: remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/CoreInboundRequest.java =================================================================== --- remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/CoreInboundRequest.java 2008-02-21 15:15:06 UTC (rev 3462) +++ remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/CoreInboundRequest.java 2008-02-21 15:17:59 UTC (rev 3463) @@ -5,8 +5,8 @@ import org.jboss.cx.remoting.RequestCancelHandler; import org.jboss.cx.remoting.RequestContext; import org.jboss.cx.remoting.RequestListener; +import org.jboss.cx.remoting.core.util.AtomicStateMachine; import org.jboss.cx.remoting.log.Logger; -import org.jboss.cx.remoting.core.util.AtomicStateMachine; import org.jboss.cx.remoting.spi.protocol.RequestIdentifier; /** Modified: remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/CoreOutboundContext.java =================================================================== --- remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/CoreOutboundContext.java 2008-02-21 15:15:06 UTC (rev 3462) +++ remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/CoreOutboundContext.java 2008-02-21 15:17:59 UTC (rev 3463) @@ -7,9 +7,9 @@ import org.jboss.cx.remoting.RemoteExecutionException; import org.jboss.cx.remoting.RemotingException; import org.jboss.cx.remoting.RequestCompletionHandler; -import org.jboss.cx.remoting.log.Logger; import org.jboss.cx.remoting.core.util.AtomicStateMachine; import org.jboss.cx.remoting.core.util.CollectionUtil; +import org.jboss.cx.remoting.log.Logger; import org.jboss.cx.remoting.spi.protocol.ContextIdentifier; import org.jboss.cx.remoting.spi.protocol.RequestIdentifier; Modified: remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/CoreSession.java =================================================================== --- remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/CoreSession.java 2008-02-21 15:15:06 UTC (rev 3462) +++ remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/CoreSession.java 2008-02-21 15:17:59 UTC (rev 3463) @@ -4,32 +4,32 @@ import java.io.InputStream; import java.io.ObjectInputStream; import java.io.ObjectOutputStream; +import java.io.ObjectStreamClass; import java.io.OutputStream; -import java.io.ObjectStreamClass; import java.lang.ref.WeakReference; +import java.net.URI; import java.util.ArrayList; +import java.util.HashMap; import java.util.List; import java.util.Map; -import java.util.HashMap; import java.util.concurrent.ConcurrentMap; import java.util.concurrent.Executor; -import java.net.URI; import org.jboss.cx.remoting.ContextSource; import org.jboss.cx.remoting.RemoteExecutionException; import org.jboss.cx.remoting.RemotingException; import org.jboss.cx.remoting.RequestListener; import org.jboss.cx.remoting.ServiceLocator; import org.jboss.cx.remoting.Session; -import org.jboss.cx.remoting.log.Logger; import org.jboss.cx.remoting.core.stream.DefaultStreamDetector; import org.jboss.cx.remoting.core.util.AtomicStateMachine; +import org.jboss.cx.remoting.core.util.AttributeMap; +import org.jboss.cx.remoting.core.util.ByteInput; +import org.jboss.cx.remoting.core.util.ByteOutput; import org.jboss.cx.remoting.core.util.CollectionUtil; -import org.jboss.cx.remoting.core.util.ByteOutput; -import org.jboss.cx.remoting.core.util.ByteInput; -import org.jboss.cx.remoting.spi.protocol.ContextIdentifier; import org.jboss.cx.remoting.core.util.MessageInput; import org.jboss.cx.remoting.core.util.MessageOutput; -import org.jboss.cx.remoting.core.util.AttributeMap; +import org.jboss.cx.remoting.log.Logger; +import org.jboss.cx.remoting.spi.protocol.ContextIdentifier; import org.jboss.cx.remoting.spi.protocol.ProtocolContext; import org.jboss.cx.remoting.spi.protocol.ProtocolHandler; import org.jboss.cx.remoting.spi.protocol.ProtocolHandlerFactory; Modified: remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/CoreStream.java =================================================================== --- remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/CoreStream.java 2008-02-21 15:15:06 UTC (rev 3462) +++ remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/CoreStream.java 2008-02-21 15:17:59 UTC (rev 3463) @@ -2,9 +2,9 @@ import java.io.IOException; import java.util.concurrent.Executor; +import org.jboss.cx.remoting.core.util.MessageInput; +import org.jboss.cx.remoting.core.util.MessageOutput; import org.jboss.cx.remoting.log.Logger; -import org.jboss.cx.remoting.core.util.MessageOutput; -import org.jboss.cx.remoting.core.util.MessageInput; import org.jboss.cx.remoting.spi.protocol.ProtocolHandler; import org.jboss.cx.remoting.spi.protocol.StreamIdentifier; import org.jboss.cx.remoting.spi.stream.RemoteStreamSerializer; Modified: remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/LocalProtocol.java =================================================================== --- remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/LocalProtocol.java 2008-02-21 15:15:06 UTC (rev 3462) +++ remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/LocalProtocol.java 2008-02-21 15:17:59 UTC (rev 3463) @@ -10,12 +10,12 @@ import org.jboss.cx.remoting.RemoteExecutionException; import org.jboss.cx.remoting.RemotingException; import org.jboss.cx.remoting.ServiceLocator; +import org.jboss.cx.remoting.core.util.AttributeMap; import org.jboss.cx.remoting.core.util.CollectionUtil; +import org.jboss.cx.remoting.core.util.MessageInput; +import org.jboss.cx.remoting.core.util.MessageOutput; import org.jboss.cx.remoting.log.Logger; -import org.jboss.cx.remoting.core.util.MessageOutput; import org.jboss.cx.remoting.spi.protocol.ContextIdentifier; -import org.jboss.cx.remoting.core.util.MessageInput; -import org.jboss.cx.remoting.core.util.AttributeMap; import org.jboss.cx.remoting.spi.protocol.ProtocolContext; import org.jboss.cx.remoting.spi.protocol.ProtocolHandler; import org.jboss.cx.remoting.spi.protocol.ProtocolHandlerFactory; Modified: remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/stream/InputStreamStreamSerializerFactory.java =================================================================== --- remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/stream/InputStreamStreamSerializerFactory.java 2008-02-21 15:15:06 UTC (rev 3462) +++ remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/stream/InputStreamStreamSerializerFactory.java 2008-02-21 15:17:59 UTC (rev 3463) @@ -3,9 +3,9 @@ import java.io.IOException; import java.io.InputStream; import java.util.LinkedList; -import org.jboss.cx.remoting.log.Logger; import org.jboss.cx.remoting.core.util.MessageInput; import org.jboss.cx.remoting.core.util.MessageOutput; +import org.jboss.cx.remoting.log.Logger; import org.jboss.cx.remoting.spi.stream.RemoteStreamSerializer; import org.jboss.cx.remoting.spi.stream.StreamContext; import org.jboss.cx.remoting.spi.stream.StreamSerializer; Modified: remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppConnection.java =================================================================== --- remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppConnection.java 2008-02-21 15:15:06 UTC (rev 3462) +++ remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppConnection.java 2008-02-21 15:17:59 UTC (rev 3463) @@ -1,17 +1,15 @@ package org.jboss.cx.remoting.jrpp; -import static java.lang.Math.min; import java.io.IOException; import java.io.ObjectInput; import java.io.ObjectOutput; -import java.util.Set; -import java.util.Map; -import java.util.HashMap; -import java.util.List; +import static java.lang.Math.min; import java.util.Enumeration; -import java.util.LinkedHashSet; +import java.util.HashMap; import java.util.HashSet; -import java.util.Collections; +import java.util.List; +import java.util.Map; +import java.util.Set; import java.util.concurrent.Executor; import org.apache.mina.common.AttributeKey; import org.apache.mina.common.IdleStatus; @@ -20,15 +18,14 @@ import org.apache.mina.filter.sasl.SaslClientFilter; import org.apache.mina.filter.sasl.SaslServerFilter; import org.apache.mina.handler.multiton.SingleSessionIoHandler; +import org.jboss.cx.remoting.CommonKeys; import org.jboss.cx.remoting.RemoteExecutionException; import org.jboss.cx.remoting.ServiceLocator; -import org.jboss.cx.remoting.CommonKeys; -import org.jboss.cx.remoting.log.Logger; import org.jboss.cx.remoting.core.util.AtomicStateMachine; +import org.jboss.cx.remoting.core.util.AttributeMap; import org.jboss.cx.remoting.core.util.CollectionUtil; import org.jboss.cx.remoting.core.util.MessageInput; import org.jboss.cx.remoting.core.util.MessageOutput; -import org.jboss.cx.remoting.core.util.AttributeMap; import org.jboss.cx.remoting.jrpp.id.IdentifierManager; import org.jboss.cx.remoting.jrpp.id.JrppContextIdentifier; import org.jboss.cx.remoting.jrpp.id.JrppRequestIdentifier; @@ -36,6 +33,7 @@ import org.jboss.cx.remoting.jrpp.id.JrppStreamIdentifier; import org.jboss.cx.remoting.jrpp.mina.IoBufferByteInput; import org.jboss.cx.remoting.jrpp.mina.IoBufferByteOutput; +import org.jboss.cx.remoting.log.Logger; import org.jboss.cx.remoting.spi.protocol.ContextIdentifier; import org.jboss.cx.remoting.spi.protocol.ProtocolContext; import org.jboss.cx.remoting.spi.protocol.ProtocolHandler; @@ -44,18 +42,18 @@ import org.jboss.cx.remoting.spi.protocol.ServiceIdentifier; import org.jboss.cx.remoting.spi.protocol.StreamIdentifier; -import javax.security.auth.callback.CallbackHandler; import javax.security.auth.callback.Callback; -import javax.security.auth.callback.UnsupportedCallbackException; +import javax.security.auth.callback.CallbackHandler; import javax.security.auth.callback.NameCallback; import javax.security.auth.callback.PasswordCallback; +import javax.security.auth.callback.UnsupportedCallbackException; +import javax.security.sasl.AuthorizeCallback; +import javax.security.sasl.RealmCallback; import javax.security.sasl.Sasl; -import javax.security.sasl.SaslException; import javax.security.sasl.SaslClient; +import javax.security.sasl.SaslException; import javax.security.sasl.SaslServer; -import javax.security.sasl.RealmCallback; import javax.security.sasl.SaslServerFactory; -import javax.security.sasl.AuthorizeCallback; /** * @@ -177,7 +175,7 @@ return mechanisms; } - private String[] getClientMechanisms(final AttributeMap attributeMap, final Map<String, ?> saslProps) { + private String[] getClientMechanisms(final AttributeMap attributeMap) { final List<String> list = attributeMap.get(CommonKeys.SASL_CLIENT_MECHANISMS); if (list != null) { return list.toArray(new String[list.size()]); @@ -321,7 +319,7 @@ private void sendAuthRequest() throws IOException { final CallbackHandler callbackHandler = getClientCallbackHandler(attributeMap); final Map<String, ?> saslProps = getSaslProperties(attributeMap); - final String[] clientMechs = getClientMechanisms(attributeMap, saslProps); + final String[] clientMechs = getClientMechanisms(attributeMap); final String authorizationId = getAuthorizationId(attributeMap, protocolContext); final SaslClient saslClient = Sasl.createSaslClient(clientMechs, authorizationId, "jrpp", remoteName, saslProps, callbackHandler); final SaslClientFilter saslClientFilter = getSaslClientFilter(); @@ -758,7 +756,7 @@ oldClientFilter.destroy(); final CallbackHandler callbackHandler = getClientCallbackHandler(attributeMap); final Map<String, ?> saslProps = getSaslProperties(attributeMap); - final String[] clientMechs = getClientMechanisms(attributeMap, saslProps); + final String[] clientMechs = getClientMechanisms(attributeMap); final String authorizationId = getAuthorizationId(attributeMap, protocolContext); final SaslClient saslClient = Sasl.createSaslClient(clientMechs, authorizationId, "jrpp", remoteName, saslProps, callbackHandler); final SaslClientFilter saslClientFilter = getSaslClientFilter(); Modified: remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppProtocolSupport.java =================================================================== --- remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppProtocolSupport.java 2008-02-21 15:15:06 UTC (rev 3462) +++ remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppProtocolSupport.java 2008-02-21 15:17:59 UTC (rev 3463) @@ -1,15 +1,15 @@ package org.jboss.cx.remoting.jrpp; import java.io.IOException; +import java.net.InetSocketAddress; import java.net.SocketAddress; import java.net.URI; -import java.net.InetSocketAddress; import java.util.concurrent.Executor; +import org.apache.mina.common.ConnectFuture; import org.apache.mina.common.IoConnector; +import org.apache.mina.common.IoProcessor; import org.apache.mina.common.IoSession; -import org.apache.mina.common.ConnectFuture; import org.apache.mina.common.IoSessionInitializer; -import org.apache.mina.common.IoProcessor; import org.apache.mina.filter.logging.LoggingFilter; import org.apache.mina.filter.sasl.SaslClientFilter; import org.apache.mina.filter.sasl.SaslMessageSender; Modified: remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppServer.java =================================================================== --- remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppServer.java 2008-02-21 15:15:06 UTC (rev 3462) +++ remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppServer.java 2008-02-21 15:17:59 UTC (rev 3463) @@ -1,22 +1,22 @@ package org.jboss.cx.remoting.jrpp; +import java.io.IOException; import java.net.SocketAddress; import java.util.concurrent.Executor; -import java.io.IOException; -import org.apache.mina.transport.socket.nio.NioSocketAcceptor; import org.apache.mina.common.IoAcceptor; import org.apache.mina.common.IoHandler; +import org.apache.mina.common.IoProcessor; import org.apache.mina.common.IoSession; -import org.apache.mina.common.IoProcessor; import org.apache.mina.filter.logging.LoggingFilter; +import org.apache.mina.filter.sasl.SaslMessageSender; import org.apache.mina.filter.sasl.SaslServerFilter; -import org.apache.mina.filter.sasl.SaslMessageSender; -import org.apache.mina.handler.multiton.SingleSessionIoHandlerFactory; import org.apache.mina.handler.multiton.SingleSessionIoHandler; import org.apache.mina.handler.multiton.SingleSessionIoHandlerDelegate; +import org.apache.mina.handler.multiton.SingleSessionIoHandlerFactory; +import org.apache.mina.transport.socket.nio.NioSocketAcceptor; +import org.jboss.cx.remoting.core.util.AttributeMap; import org.jboss.cx.remoting.jrpp.mina.FramingIoFilter; import org.jboss.cx.remoting.spi.protocol.ProtocolServerContext; -import org.jboss.cx.remoting.core.util.AttributeMap; /** * Modified: remoting3/trunk/standalone/src/main/java/org/jboss/cx/remoting/Remoting.java =================================================================== --- remoting3/trunk/standalone/src/main/java/org/jboss/cx/remoting/Remoting.java 2008-02-21 15:15:06 UTC (rev 3462) +++ remoting3/trunk/standalone/src/main/java/org/jboss/cx/remoting/Remoting.java 2008-02-21 15:17:59 UTC (rev 3463) @@ -1,20 +1,20 @@ package org.jboss.cx.remoting; +import java.io.IOException; import java.net.URI; -import java.io.IOException; -import org.jboss.cx.remoting.log.Logger; import org.jboss.cx.remoting.core.CoreEndpointProvider; +import org.jboss.cx.remoting.core.util.AttributeHashMap; import org.jboss.cx.remoting.core.util.AttributeMap; -import org.jboss.cx.remoting.core.util.AttributeHashMap; +import org.jboss.cx.remoting.log.Logger; import org.jboss.cx.remoting.spi.EndpointProvider; import org.jboss.cx.remoting.spi.wrapper.ContextSourceWrapper; import org.jboss.cx.remoting.spi.wrapper.SessionWrapper; +import javax.security.auth.callback.Callback; import javax.security.auth.callback.CallbackHandler; -import javax.security.auth.callback.Callback; -import javax.security.auth.callback.UnsupportedCallbackException; import javax.security.auth.callback.NameCallback; import javax.security.auth.callback.PasswordCallback; +import javax.security.auth.callback.UnsupportedCallbackException; /** * Modified: remoting3/trunk/util/src/main/java/org/jboss/cx/remoting/core/util/AttributeHashMap.java =================================================================== --- remoting3/trunk/util/src/main/java/org/jboss/cx/remoting/core/util/AttributeHashMap.java 2008-02-21 15:15:06 UTC (rev 3462) +++ remoting3/trunk/util/src/main/java/org/jboss/cx/remoting/core/util/AttributeHashMap.java 2008-02-21 15:17:59 UTC (rev 3463) @@ -1,9 +1,9 @@ package org.jboss.cx.remoting.core.util; -import java.util.Set; import java.util.Collection; import java.util.Iterator; import java.util.Map; +import java.util.Set; import java.util.concurrent.ConcurrentMap; /** Modified: remoting3/trunk/util/src/main/java/org/jboss/cx/remoting/core/util/AttributeMap.java =================================================================== --- remoting3/trunk/util/src/main/java/org/jboss/cx/remoting/core/util/AttributeMap.java 2008-02-21 15:15:06 UTC (rev 3462) +++ remoting3/trunk/util/src/main/java/org/jboss/cx/remoting/core/util/AttributeMap.java 2008-02-21 15:17:59 UTC (rev 3463) @@ -1,7 +1,7 @@ package org.jboss.cx.remoting.core.util; +import java.util.Collection; import java.util.Set; -import java.util.Collection; /** * Modified: remoting3/trunk/util/src/main/java/org/jboss/cx/remoting/core/util/IoUtil.java =================================================================== --- remoting3/trunk/util/src/main/java/org/jboss/cx/remoting/core/util/IoUtil.java 2008-02-21 15:15:06 UTC (rev 3462) +++ remoting3/trunk/util/src/main/java/org/jboss/cx/remoting/core/util/IoUtil.java 2008-02-21 15:17:59 UTC (rev 3463) @@ -2,7 +2,6 @@ import java.nio.ByteBuffer; import java.nio.CharBuffer; -import java.io.OutputStream; /** * Modified: remoting3/trunk/util/src/main/java/org/jboss/cx/remoting/core/util/MessageInput.java =================================================================== --- remoting3/trunk/util/src/main/java/org/jboss/cx/remoting/core/util/MessageInput.java 2008-02-21 15:15:06 UTC (rev 3462) +++ remoting3/trunk/util/src/main/java/org/jboss/cx/remoting/core/util/MessageInput.java 2008-02-21 15:17:59 UTC (rev 3463) @@ -1,7 +1,7 @@ package org.jboss.cx.remoting.core.util; +import java.io.IOException; import java.io.ObjectInput; -import java.io.IOException; /** * Modified: remoting3/trunk/util/src/main/java/org/jboss/cx/remoting/core/util/ServiceURI.java =================================================================== --- remoting3/trunk/util/src/main/java/org/jboss/cx/remoting/core/util/ServiceURI.java 2008-02-21 15:15:06 UTC (rev 3462) +++ remoting3/trunk/util/src/main/java/org/jboss/cx/remoting/core/util/ServiceURI.java 2008-02-21 15:17:59 UTC (rev 3463) @@ -2,8 +2,8 @@ import java.net.URI; import java.net.URISyntaxException; +import java.util.regex.Matcher; import java.util.regex.Pattern; -import java.util.regex.Matcher; /** *

16 years, 9 months

1
0
0 / 0

JBoss Remoting SVN: r3462 - in remoting3/trunk: srp/src/main/java/org/jboss/cx/remoting/core/security/sasl and 1 other directory.

by jboss-remoting-commits＠lists.jboss.org

Author: david.lloyd(a)jboss.com Date: 2008-02-21 10:15:06 -0500 (Thu, 21 Feb 2008) New Revision: 3462 Modified: remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppConnection.java remoting3/trunk/srp/src/main/java/org/jboss/cx/remoting/core/security/sasl/SrpSaslServerFactoryImpl.java Log: Default the client to SRP if no mechanism is selected. Modified: remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppConnection.java =================================================================== --- remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppConnection.java 2008-02-21 05:25:03 UTC (rev 3461) +++ remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppConnection.java 2008-02-21 15:15:06 UTC (rev 3462) @@ -11,6 +11,7 @@ import java.util.Enumeration; import java.util.LinkedHashSet; import java.util.HashSet; +import java.util.Collections; import java.util.concurrent.Executor; import org.apache.mina.common.AttributeKey; import org.apache.mina.common.IdleStatus; @@ -181,15 +182,7 @@ if (list != null) { return list.toArray(new String[list.size()]); } - final Set<String> mechanisms = new LinkedHashSet<String>(); - final Enumeration<javax.security.sasl.SaslClientFactory> e = Sasl.getSaslClientFactories(); - while (e.hasMoreElements()) { - final javax.security.sasl.SaslClientFactory clientFactory = e.nextElement(); - for (String name : clientFactory.getMechanismNames(saslProps)) { - mechanisms.add(name); - } - } - return mechanisms.toArray(new String[mechanisms.size()]); + return new String[] { "SRP" }; } private Map<String, ?> getSaslProperties(final AttributeMap attributeMap) { @@ -746,7 +739,7 @@ try { saslClientFilter.handleSaslChallenge(ioSession, bytes); } catch (SaslException ex) { - log.debug("Failed to handle challenge from server; reset and try again"); + log.debug("Failed to handle challenge from server (%s). Sending new auth request.", ex.getMessage()); // todo - retry counter - JBREM-907 sendAuthRequest(); } Modified: remoting3/trunk/srp/src/main/java/org/jboss/cx/remoting/core/security/sasl/SrpSaslServerFactoryImpl.java =================================================================== --- remoting3/trunk/srp/src/main/java/org/jboss/cx/remoting/core/security/sasl/SrpSaslServerFactoryImpl.java 2008-02-21 05:25:03 UTC (rev 3461) +++ remoting3/trunk/srp/src/main/java/org/jboss/cx/remoting/core/security/sasl/SrpSaslServerFactoryImpl.java 2008-02-21 15:15:06 UTC (rev 3462) @@ -16,6 +16,6 @@ } public String[] getMechanismNames(Map<String, ?> props) { - return new String[0]; + return new String[] { "SRP" }; } }

16 years, 9 months

1
0
0 / 0

JBoss Remoting SVN: r3461 - remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp.

by jboss-remoting-commits＠lists.jboss.org

Author: david.lloyd(a)jboss.com Date: 2008-02-21 00:25:03 -0500 (Thu, 21 Feb 2008) New Revision: 3461 Modified: remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppConnection.java Log: Properly handle failures caused by the inability to process the server challenge; in this case, restart the auth process Modified: remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppConnection.java =================================================================== --- remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppConnection.java 2008-02-21 03:01:31 UTC (rev 3460) +++ remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppConnection.java 2008-02-21 05:25:03 UTC (rev 3461) @@ -241,6 +241,8 @@ ((NameCallback)callback).setName("anonymous"); } else if (callback instanceof PasswordCallback) { ((PasswordCallback)callback).setPassword(new char[0]); + } else if (callback instanceof RealmCallback) { + ((RealmCallback)callback).setText("default"); } else { throw new UnsupportedCallbackException(callback, "Default anonymous client callback handler cannot support this callback type"); } @@ -350,7 +352,7 @@ private void close() { state.transition(State.CLOSED); - ioSession.close().awaitUninterruptibly(); + ioSession.close(); protocolContext.closeSession(); } @@ -644,6 +646,43 @@ default: break OUT; } } + case AWAITING_CLIENT_RESPONSE: { + switch (type) { + case SASL_RESPONSE: { + if (trace) { + log.trace("Recevied SASL response from client"); + } + byte[] bytes = new byte[input.remaining()]; + input.readFully(bytes); + SaslServerFilter saslServerFilter = getSaslServerFilter(); + try { + if (saslServerFilter.handleSaslResponse(ioSession, bytes)) { + final IoBuffer buffer = newBuffer(60, false); + final MessageOutput output = protocolContext.getMessageOutput(new IoBufferByteOutput(buffer, ioSession)); + write(output, MessageType.AUTH_SUCCESS); + output.commit(); + saslServerFilter.startEncryption(ioSession); + state.requireTransition(State.AWAITING_CLIENT_RESPONSE, State.UP); + } + } catch (SaslException ex) { + final IoBuffer buffer = newBuffer(100, true); + final MessageOutput output = protocolContext.getMessageOutput(new IoBufferByteOutput(buffer, ioSession)); + write(output, MessageType.AUTH_FAILED); + output.writeUTF("Authentication failed: " + ex.getMessage()); + output.commit(); + log.debug("Client authentication failed (" + ex.getMessage() + ")"); + // todo - retry counter - JBREM-907 + state.requireTransition(State.AWAITING_CLIENT_RESPONSE, State.AWAITING_CLIENT_AUTH_REQUEST); + } + return; + } + case AUTH_REQUEST: { + state.transition(State.AWAITING_CLIENT_AUTH_REQUEST); + break; // fall thru to AWAITING_CLIENT_AUTH_REQUEST/AUTH_REQUEST + } + default: break OUT; + } + } case AWAITING_CLIENT_AUTH_REQUEST: { switch (type) { case AUTH_REQUEST: { @@ -666,9 +705,9 @@ final MessageOutput output = protocolContext.getMessageOutput(new IoBufferByteOutput(buffer, ioSession)); write(output, MessageType.AUTH_SUCCESS); output.commit(); - state.requireTransition(State.AWAITING_CLIENT_VERSION, State.UP); + state.requireTransition(State.UP); } else { - state.requireTransition(State.AWAITING_CLIENT_VERSION, State.AWAITING_CLIENT_RESPONSE); + state.requireTransition(State.AWAITING_CLIENT_RESPONSE); } } catch (SaslException ex) { final IoBuffer buffer = newBuffer(100, true); @@ -692,54 +731,27 @@ final String name = input.readUTF(); remoteName = name.length() > 0 ? name : null; sendAuthRequest(); - state.requireTransition(State.AWAITING_SERVER_VERSION, State.AWAITING_SERVER_CHALLENGE); + state.requireTransition(State.AWAITING_SERVER_CHALLENGE); return; } default: break OUT; } } - case AWAITING_CLIENT_RESPONSE: { + case AWAITING_SERVER_CHALLENGE: { switch (type) { - case SASL_RESPONSE: { - if (trace) { - log.trace("Recevied SASL response from client"); - } + case SASL_CHALLENGE: { byte[] bytes = new byte[input.remaining()]; input.readFully(bytes); - SaslServerFilter saslServerFilter = getSaslServerFilter(); + SaslClientFilter saslClientFilter = getSaslClientFilter(); try { - if (saslServerFilter.handleSaslResponse(ioSession, bytes)) { - final IoBuffer buffer = newBuffer(60, false); - final MessageOutput output = protocolContext.getMessageOutput(new IoBufferByteOutput(buffer, ioSession)); - write(output, MessageType.AUTH_SUCCESS); - output.commit(); - saslServerFilter.startEncryption(ioSession); - state.requireTransition(State.AWAITING_CLIENT_RESPONSE, State.UP); - } + saslClientFilter.handleSaslChallenge(ioSession, bytes); } catch (SaslException ex) { - final IoBuffer buffer = newBuffer(100, true); - final MessageOutput output = protocolContext.getMessageOutput(new IoBufferByteOutput(buffer, ioSession)); - write(output, MessageType.AUTH_FAILED); - output.writeUTF("Authentication failed: " + ex.getMessage()); - output.commit(); - log.info("Client authentication failed (" + ex.getMessage() + ")"); + log.debug("Failed to handle challenge from server; reset and try again"); // todo - retry counter - JBREM-907 - state.requireTransition(State.AWAITING_CLIENT_RESPONSE, State.AWAITING_CLIENT_AUTH_REQUEST); + sendAuthRequest(); } return; } - default: break OUT; - } - } - case AWAITING_SERVER_CHALLENGE: { - switch (type) { - case SASL_CHALLENGE: { - byte[] bytes = new byte[input.remaining()]; - input.readFully(bytes); - SaslClientFilter saslClientFilter = getSaslClientFilter(); - saslClientFilter.handleSaslChallenge(ioSession, bytes); - return; - } case AUTH_SUCCESS: { SaslClientFilter saslClientFilter = getSaslClientFilter(); saslClientFilter.startEncryption(ioSession); @@ -748,7 +760,7 @@ } case AUTH_FAILED: { String reason = input.readUTF(); - log.info("JRPP client failed to authenticate: %s", reason); + log.debug("JRPP client failed to authenticate: %s", reason); final SaslClientFilter oldClientFilter = getSaslClientFilter(); oldClientFilter.destroy(); final CallbackHandler callbackHandler = getClientCallbackHandler(attributeMap);

16 years, 9 months

1
0
0 / 0

JBoss Remoting SVN: r3460 - remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp.

by jboss-remoting-commits＠lists.jboss.org

Author: david.lloyd(a)jboss.com Date: 2008-02-20 22:01:31 -0500 (Wed, 20 Feb 2008) New Revision: 3460 Modified: remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppConnection.java Log: Fix JRPP session initialization problems Modified: remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppConnection.java =================================================================== --- remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppConnection.java 2008-02-21 00:35:30 UTC (rev 3459) +++ remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppConnection.java 2008-02-21 03:01:31 UTC (rev 3460) @@ -125,6 +125,7 @@ try { ioSession.setAttribute(JRPP_CONNECTION, this); this.ioSession = ioSession; + this.protocolContext = protocolContext; } finally { state.releaseExclusive(); } @@ -312,7 +313,7 @@ output.commit(); } - public void sendVersionMessage() throws IOException { + private void sendVersionMessage() throws IOException { // send version info final IoBuffer buffer = newBuffer(60, false); final MessageOutput output = protocolContext.getMessageOutput(new IoBufferByteOutput(buffer, ioSession)); @@ -322,6 +323,24 @@ output.commit(); } + private void sendAuthRequest() throws IOException { + final CallbackHandler callbackHandler = getClientCallbackHandler(attributeMap); + final Map<String, ?> saslProps = getSaslProperties(attributeMap); + final String[] clientMechs = getClientMechanisms(attributeMap, saslProps); + final String authorizationId = getAuthorizationId(attributeMap, protocolContext); + final SaslClient saslClient = Sasl.createSaslClient(clientMechs, authorizationId, "jrpp", remoteName, saslProps, callbackHandler); + final SaslClientFilter saslClientFilter = getSaslClientFilter(); + saslClientFilter.setSaslClient(ioSession, saslClient); + final IoBuffer buffer = newBuffer(600, true); + MessageOutput output = protocolContext.getMessageOutput(new IoBufferByteOutput(buffer, ioSession)); + write(output, MessageType.AUTH_REQUEST); + output.writeInt(clientMechs.length); + for (String mech : clientMechs) { + output.writeUTF(mech); + } + output.commit(); + } + public boolean waitForUp() throws IOException { while (! state.in(State.UP, State.CLOSED)) { state.waitForAny(); @@ -633,22 +652,30 @@ for (int i = 0; i < mechCount; i ++) { clientMechs[i] = input.readUTF(); } - final CallbackHandler callbackHandler = getServerCallbackHandler(attributeMap); - final Map<String, ?> saslProps = getSaslProperties(attributeMap); - final Set<String> serverMechs = getServerMechanisms(attributeMap, saslProps); - final String negotiatedMechanism = getNegotiatedMechanism(clientMechs, serverMechs); - final SaslServer saslServer = Sasl.createSaslServer(negotiatedMechanism, "jrpp", protocolContext.getLocalEndpointName(), saslProps, callbackHandler); - final SaslServerFilter saslServerFilter = getSaslServerFilter(); - saslServerFilter.setSaslServer(ioSession, saslServer); - if (saslServerFilter.sendInitialChallenge(ioSession)) { - // complete (that was quick!) - final IoBuffer buffer = newBuffer(60, false); + try { + final CallbackHandler callbackHandler = getServerCallbackHandler(attributeMap); + final Map<String, ?> saslProps = getSaslProperties(attributeMap); + final Set<String> serverMechs = getServerMechanisms(attributeMap, saslProps); + final String negotiatedMechanism = getNegotiatedMechanism(clientMechs, serverMechs); + final SaslServer saslServer = Sasl.createSaslServer(negotiatedMechanism, "jrpp", protocolContext.getLocalEndpointName(), saslProps, callbackHandler); + final SaslServerFilter saslServerFilter = getSaslServerFilter(); + saslServerFilter.setSaslServer(ioSession, saslServer); + if (saslServerFilter.sendInitialChallenge(ioSession)) { + // complete (that was quick!) + final IoBuffer buffer = newBuffer(60, false); + final MessageOutput output = protocolContext.getMessageOutput(new IoBufferByteOutput(buffer, ioSession)); + write(output, MessageType.AUTH_SUCCESS); + output.commit(); + state.requireTransition(State.AWAITING_CLIENT_VERSION, State.UP); + } else { + state.requireTransition(State.AWAITING_CLIENT_VERSION, State.AWAITING_CLIENT_RESPONSE); + } + } catch (SaslException ex) { + final IoBuffer buffer = newBuffer(100, true); final MessageOutput output = protocolContext.getMessageOutput(new IoBufferByteOutput(buffer, ioSession)); - write(output, MessageType.AUTH_SUCCESS); + write(output, MessageType.AUTH_FAILED); + output.writeUTF("Unable to initiate SASL authentication: " + ex.getMessage()); output.commit(); - state.requireTransition(State.AWAITING_CLIENT_VERSION, State.UP); - } else { - state.requireTransition(State.AWAITING_CLIENT_VERSION, State.AWAITING_CLIENT_RESPONSE); } return; } @@ -664,13 +691,7 @@ } final String name = input.readUTF(); remoteName = name.length() > 0 ? name : null; - final CallbackHandler callbackHandler = getClientCallbackHandler(attributeMap); - final Map<String, ?> saslProps = getSaslProperties(attributeMap); - final String[] clientMechs = getClientMechanisms(attributeMap, saslProps); - final String authorizationId = getAuthorizationId(attributeMap, protocolContext); - final SaslClient saslClient = Sasl.createSaslClient(clientMechs, authorizationId, "jrpp", remoteName, saslProps, callbackHandler); - final SaslClientFilter saslClientFilter = getSaslClientFilter(); - saslClientFilter.setSaslClient(ioSession, saslClient); + sendAuthRequest(); state.requireTransition(State.AWAITING_SERVER_VERSION, State.AWAITING_SERVER_CHALLENGE); return; } @@ -696,9 +717,10 @@ state.requireTransition(State.AWAITING_CLIENT_RESPONSE, State.UP); } } catch (SaslException ex) { - final IoBuffer buffer = newBuffer(60, false); + final IoBuffer buffer = newBuffer(100, true); final MessageOutput output = protocolContext.getMessageOutput(new IoBufferByteOutput(buffer, ioSession)); write(output, MessageType.AUTH_FAILED); + output.writeUTF("Authentication failed: " + ex.getMessage()); output.commit(); log.info("Client authentication failed (" + ex.getMessage() + ")"); // todo - retry counter - JBREM-907 @@ -725,7 +747,8 @@ return; } case AUTH_FAILED: { - log.info("JRPP client rejected authentication"); + String reason = input.readUTF(); + log.info("JRPP client failed to authenticate: %s", reason); final SaslClientFilter oldClientFilter = getSaslClientFilter(); oldClientFilter.destroy(); final CallbackHandler callbackHandler = getClientCallbackHandler(attributeMap); @@ -735,6 +758,8 @@ final SaslClient saslClient = Sasl.createSaslClient(clientMechs, authorizationId, "jrpp", remoteName, saslProps, callbackHandler); final SaslClientFilter saslClientFilter = getSaslClientFilter(); saslClientFilter.setSaslClient(ioSession, saslClient); + // todo - retry counter - JBREM-907 + sendAuthRequest(); return; } default: break OUT;

16 years, 9 months

1
0
0 / 0

JBoss Remoting SVN: r3459 - in remoting3/trunk: api/src/main/java/org/jboss/cx/remoting/spi and 9 other directories.

by jboss-remoting-commits＠lists.jboss.org

Author: david.lloyd(a)jboss.com Date: 2008-02-20 19:35:30 -0500 (Wed, 20 Feb 2008) New Revision: 3459 Added: remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/CommonKeys.java remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppServer.java Removed: remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/EndpointLocator.java remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/spi/SessionLocalTransaction.java remoting3/trunk/mina-sasl/src/main/java/org/apache/mina/filter/sasl/SaslClientFactory.java remoting3/trunk/mina-sasl/src/main/java/org/apache/mina/filter/sasl/SaslServerFactory.java Modified: remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/Endpoint.java remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/spi/protocol/ProtocolContext.java remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/spi/protocol/ProtocolHandlerFactory.java remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/spi/wrapper/EndpointWrapper.java remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/CoreEndpoint.java remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/CoreSession.java remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/LocalProtocol.java remoting3/trunk/http/src/main/java/org/jboss/cx/remoting/http/HttpProtocolSupport.java remoting3/trunk/http/src/main/java/org/jboss/cx/remoting/http/RemotingHttpSessionImpl.java remoting3/trunk/http/src/main/java/org/jboss/cx/remoting/http/spi/RemotingHttpSessionContext.java remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppConnection.java remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppProtocolSupport.java remoting3/trunk/mina-sasl/src/main/java/org/apache/mina/filter/sasl/SaslClientFilter.java remoting3/trunk/mina-sasl/src/main/java/org/apache/mina/filter/sasl/SaslServerFilter.java remoting3/trunk/standalone/src/main/java/org/jboss/cx/remoting/Remoting.java remoting3/trunk/util/src/main/java/org/jboss/cx/remoting/core/util/AttributeKey.java Log: This represents about 95% of the work needed to bring around JBREM-884. Just need to work out some kinks with the JRPP connections... Added: remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/CommonKeys.java =================================================================== --- remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/CommonKeys.java (rev 0) +++ remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/CommonKeys.java 2008-02-21 00:35:30 UTC (rev 3459) @@ -0,0 +1,49 @@ +package org.jboss.cx.remoting; + +import org.jboss.cx.remoting.core.util.AttributeKey; + +import java.util.Map; +import java.util.Set; +import java.util.List; + +import javax.security.auth.callback.CallbackHandler; + +import static org.jboss.cx.remoting.core.util.AttributeKey.key; + +/** + * A set of attribute keys that are common across various protocols. + */ +public final class CommonKeys { + private CommonKeys() { /* no construction */ } + + // SASL + + /** + * A key that represents the SASL properties to be used for this connection or server. + */ + public static final AttributeKey<Map<String, ?>> SASL_PROPERTIES = key("SASL_PROPERTIES"); + /** + * The SASL client mechanisms to try, in order. If none are given, then the list is generated based on the registered + * providers. + */ + public static final AttributeKey<List<String>> SASL_CLIENT_MECHANISMS = key("SASL_CLIENT_MECHANISMS"); + /** + * The SASL server mechanisms to make available to clients. If none are given, then the set is generated based on + * the registered providers. + */ + public static final AttributeKey<Set<String>> SASL_SERVER_MECHANISMS = key("SASL_SERVER_MECHANISMS"); + + // Generic auth + + /** + * The authentication callback handler to make available to the authentication layer. + */ + public static final AttributeKey<CallbackHandler> AUTH_CALLBACK_HANDLER = key("AUTH_CALLBACK_HANDLER"); + /** + * The client authorization ID to send to the server. If not specified, defaults to the local endpoint name. If + * the local endpoint is anonymous, defaults to {@code null}. + */ + public static final AttributeKey<String> AUTHORIZATION_ID = key("AUTHORIZATION_ID"); + + // TODO: add keys for SSL/TLS +} Modified: remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/Endpoint.java =================================================================== --- remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/Endpoint.java 2008-02-19 08:12:17 UTC (rev 3458) +++ remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/Endpoint.java 2008-02-21 00:35:30 UTC (rev 3459) @@ -8,8 +8,6 @@ import org.jboss.cx.remoting.spi.protocol.ProtocolRegistrationSpec; import org.jboss.cx.remoting.core.util.AttributeMap; -import javax.security.auth.callback.CallbackHandler; - /** * A potential participant in a JBoss Remoting communications relationship. */ @@ -47,14 +45,14 @@ * authority is used to locate the server (the exact interpretation is dependent upon the protocol). The URI path is * the service to connect to. The path may be relative to a protocol-specific deployment path. * - * @param endpointLocator the endpoint locator + * @param remoteUri the URI of the server to connect to * @param attributeMap the attribute map to use to configure this session * @return a new session * * @throws RemotingException if there is a problem creating the session, or if the request or reply type does not * match the remote service */ - Session openSession(EndpointLocator endpointLocator, AttributeMap attributeMap) throws RemotingException; + Session openSession(URI remoteUri, AttributeMap attributeMap) throws RemotingException; /** * Get the name of this endpoint. @@ -116,32 +114,4 @@ * @throws RemotingException if there is a problem with the discovery parameters */ Discovery discover(String endpointName, URI nextHop, int cost) throws RemotingException; - - /** - * Get the callback handler used to authenticate a remote endpoint by default. - * - * @return the callback handler - */ - CallbackHandler getRemoteCallbackHandler(); - - /** - * Change the callback handler used to authenticate a remote endpoint by default. - * - * @param callbackHandler the callback handler - */ - void setRemoteCallbackHandler(CallbackHandler callbackHandler); - - /** - * Get the callback handler used to authenticate this endpoint to a remote endpoint by default. - * - * @return the callback handler - */ - CallbackHandler getLocalCallbackHandler(); - - /** - * Change the callback handler used to authenticate this endpoint to a remote endpoint by default. - * - * @param callbackHandler the callback handler - */ - void setLocalCallbackHandler(CallbackHandler callbackHandler); } Deleted: remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/EndpointLocator.java =================================================================== --- remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/EndpointLocator.java 2008-02-19 08:12:17 UTC (rev 3458) +++ remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/EndpointLocator.java 2008-02-21 00:35:30 UTC (rev 3459) @@ -1,85 +0,0 @@ -package org.jboss.cx.remoting; - -import java.io.IOException; -import java.net.URI; - -import javax.security.auth.callback.Callback; -import javax.security.auth.callback.CallbackHandler; -import javax.security.auth.callback.NameCallback; -import javax.security.auth.callback.PasswordCallback; -import javax.security.auth.callback.UnsupportedCallbackException; - -/** - * - */ -public final class EndpointLocator { - private final URI endpointUri; - private final String authorizationId; - private final CallbackHandler clientCallbackHandler; - - private EndpointLocator(final URI endpointUri, final String authorizationId, final CallbackHandler clientCallbackHandler) { - this.endpointUri = endpointUri; - this.authorizationId = authorizationId; - this.clientCallbackHandler = clientCallbackHandler; - } - - public static final CallbackHandler DEFAULT_CALLBACK_HANDLER = new CallbackHandler() { - public void handle(Callback[] callbacks) throws IOException, UnsupportedCallbackException { - if (callbacks.length > 0) { - throw new UnsupportedCallbackException(callbacks[0], "No callback types are supported"); - } - } - }; - - public static final EndpointLocator DEFAULT = new EndpointLocator(null, null, DEFAULT_CALLBACK_HANDLER); - - public URI getEndpointUri() { - return endpointUri; - } - - public String getAuthorizationId() { - return authorizationId; - } - - public CallbackHandler getClientCallbackHandler() { - return clientCallbackHandler; - } - - public EndpointLocator setEndpointUri(URI endpointUri) { - return new EndpointLocator(endpointUri, authorizationId, clientCallbackHandler); - } - - public EndpointLocator setAuthorizationId(String authorizationId) { - return new EndpointLocator(endpointUri, authorizationId, clientCallbackHandler); - } - - public EndpointLocator setClientCallbackHandler(CallbackHandler clientCallbackHandler) { - return new EndpointLocator(endpointUri, authorizationId, clientCallbackHandler); - } - - public EndpointLocator setClientAuthentication(String userName, char[] password) { - return new EndpointLocator(endpointUri, userName, new SimpleClientCallbackHandler(userName, password)); - } - - public static final class SimpleClientCallbackHandler implements CallbackHandler { - private final String userName; - private final char[] password; - - private SimpleClientCallbackHandler(final String userName, final char[] password) { - this.userName = userName; - this.password = password; - } - - public void handle(Callback[] callbacks) throws IOException, UnsupportedCallbackException { - for (Callback callback : callbacks) { - if (callback instanceof NameCallback) { - ((NameCallback) callback).setName(userName); - } else if (callback instanceof PasswordCallback) { - ((PasswordCallback) callback).setPassword(password); - } else { - throw new UnsupportedCallbackException(callback, "This handler only supports username/password callbacks"); - } - } - } - } -} Deleted: remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/spi/SessionLocalTransaction.java =================================================================== --- remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/spi/SessionLocalTransaction.java 2008-02-19 08:12:17 UTC (rev 3458) +++ remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/spi/SessionLocalTransaction.java 2008-02-21 00:35:30 UTC (rev 3459) @@ -1,9 +0,0 @@ -package org.jboss.cx.remoting.spi; - -/** - * Represents a locally-managed transaction. Instances of this interface are created when a local transaction is - * suspended via the {@code SessionHandler}, and are passed back in to the {@code SessionHandler} when resuming a - * transaction. - */ -public interface SessionLocalTransaction { -} Modified: remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/spi/protocol/ProtocolContext.java =================================================================== --- remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/spi/protocol/ProtocolContext.java 2008-02-19 08:12:17 UTC (rev 3458) +++ remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/spi/protocol/ProtocolContext.java 2008-02-21 00:35:30 UTC (rev 3459) @@ -46,6 +46,8 @@ void receiveStreamData(StreamIdentifier streamIdentifier, MessageInput data); + void openSession(String remoteEndpointName); + void closeSession(); /* CLIENT OR SERVER methods */ Modified: remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/spi/protocol/ProtocolHandlerFactory.java =================================================================== --- remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/spi/protocol/ProtocolHandlerFactory.java 2008-02-19 08:12:17 UTC (rev 3458) +++ remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/spi/protocol/ProtocolHandlerFactory.java 2008-02-21 00:35:30 UTC (rev 3459) @@ -2,9 +2,8 @@ import java.io.IOException; import java.net.URI; +import org.jboss.cx.remoting.core.util.AttributeMap; -import javax.security.auth.callback.CallbackHandler; - /** * */ @@ -26,12 +25,12 @@ * * @param context the protocol context to use for inbound data * @param remoteUri the URI of the remote side - * @param clientCallbackHandler the callback handler to use to authenticate this client + * @param attributeMap * @return the protocol handler for outbound data * * @throws IOException if the handler could not be created */ - ProtocolHandler createHandler(ProtocolContext context, URI remoteUri, CallbackHandler clientCallbackHandler) throws IOException; + ProtocolHandler createHandler(ProtocolContext context, URI remoteUri, AttributeMap attributeMap) throws IOException; /** * Signifies that this protocol has been unregistered from the endpoint. Modified: remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/spi/wrapper/EndpointWrapper.java =================================================================== --- remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/spi/wrapper/EndpointWrapper.java 2008-02-19 08:12:17 UTC (rev 3458) +++ remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/spi/wrapper/EndpointWrapper.java 2008-02-21 00:35:30 UTC (rev 3459) @@ -3,7 +3,6 @@ import java.net.URI; import java.util.concurrent.ConcurrentMap; import org.jboss.cx.remoting.Endpoint; -import org.jboss.cx.remoting.EndpointLocator; import org.jboss.cx.remoting.EndpointShutdownListener; import org.jboss.cx.remoting.InterceptorDeploymentSpec; import org.jboss.cx.remoting.RemotingException; @@ -15,8 +14,6 @@ import org.jboss.cx.remoting.spi.protocol.ProtocolRegistration; import org.jboss.cx.remoting.spi.protocol.ProtocolRegistrationSpec; -import javax.security.auth.callback.CallbackHandler; - /** * */ @@ -35,8 +32,8 @@ delegate.shutdown(); } - public Session openSession(EndpointLocator endpointLocator, AttributeMap attributeMap) throws RemotingException { - return delegate.openSession(endpointLocator, attributeMap); + public Session openSession(final URI remoteUri, AttributeMap attributeMap) throws RemotingException { + return delegate.openSession(remoteUri, attributeMap); } public Discovery discover(final String endpointName, final URI nextHop, final int cost) throws RemotingException { @@ -59,22 +56,6 @@ return delegate.registerProtocol(spec); } - public CallbackHandler getLocalCallbackHandler() { - return delegate.getLocalCallbackHandler(); - } - - public CallbackHandler getRemoteCallbackHandler() { - return delegate.getRemoteCallbackHandler(); - } - - public void setRemoteCallbackHandler(final CallbackHandler callbackHandler) { - delegate.setRemoteCallbackHandler(callbackHandler); - } - - public void setLocalCallbackHandler(final CallbackHandler callbackHandler) { - delegate.setLocalCallbackHandler(callbackHandler); - } - public void addShutdownListener(final EndpointShutdownListener listener) { delegate.addShutdownListener(listener); } Modified: remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/CoreEndpoint.java =================================================================== --- remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/CoreEndpoint.java 2008-02-19 08:12:17 UTC (rev 3458) +++ remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/CoreEndpoint.java 2008-02-21 00:35:30 UTC (rev 3459) @@ -13,7 +13,6 @@ import java.util.regex.Matcher; import java.util.regex.Pattern; import org.jboss.cx.remoting.Endpoint; -import org.jboss.cx.remoting.EndpointLocator; import org.jboss.cx.remoting.EndpointShutdownListener; import org.jboss.cx.remoting.InterceptorDeploymentSpec; import org.jboss.cx.remoting.RemotingException; @@ -45,8 +44,6 @@ private final String name; private final Endpoint userEndpoint = new UserEndpoint(); - private CallbackHandler remoteCallbackHandler; - private CallbackHandler localCallbackHandler; private final OrderedExecutorFactory orderedExecutorFactory; private final AtomicStateMachine<State> state = AtomicStateMachine.start(State.UP); private final ExecutorService executor; @@ -179,7 +176,10 @@ } public ProtocolContext establishSession(ProtocolHandler handler) { - final CoreSession session = new CoreSession(CoreEndpoint.this, handler); + final CoreSession session = new CoreSession(CoreEndpoint.this); + session.initializeServer(handler); + + //, handler); return session.getProtocolContext(); } } @@ -288,8 +288,8 @@ } } - public Session openSession(final EndpointLocator endpointLocator, final AttributeMap attributeMap) throws RemotingException { - final String scheme = endpointLocator.getEndpointUri().getScheme(); + public Session openSession(final URI uri, final AttributeMap attributeMap) throws RemotingException { + final String scheme = uri.getScheme(); if (scheme == null) { throw new RemotingException("No scheme on remote endpoint URI"); } @@ -301,7 +301,8 @@ } final ProtocolHandlerFactory factory = registration.getProtocolHandlerFactory(); try { - final CoreSession session = new CoreSession(CoreEndpoint.this, factory, endpointLocator); + final CoreSession session = new CoreSession(CoreEndpoint.this); + session.initializeClient(factory, uri, attributeMap); sessions.add(session); return session.getUserSession(); } catch (IOException e) { @@ -367,29 +368,5 @@ // todo - implement return null; } - - public CallbackHandler getRemoteCallbackHandler() { - synchronized(this) { - return remoteCallbackHandler; - } - } - - public CallbackHandler getLocalCallbackHandler() { - synchronized(this) { - return localCallbackHandler; - } - } - - public void setRemoteCallbackHandler(final CallbackHandler remoteCallbackHandler) { - synchronized(this) { - CoreEndpoint.this.remoteCallbackHandler = remoteCallbackHandler; - } - } - - public void setLocalCallbackHandler(final CallbackHandler localCallbackHandler) { - synchronized(this) { - CoreEndpoint.this.localCallbackHandler = localCallbackHandler; - } - } } } Modified: remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/CoreSession.java =================================================================== --- remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/CoreSession.java 2008-02-19 08:12:17 UTC (rev 3458) +++ remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/CoreSession.java 2008-02-21 00:35:30 UTC (rev 3459) @@ -13,9 +13,8 @@ import java.util.HashMap; import java.util.concurrent.ConcurrentMap; import java.util.concurrent.Executor; +import java.net.URI; import org.jboss.cx.remoting.ContextSource; -import org.jboss.cx.remoting.Endpoint; -import org.jboss.cx.remoting.EndpointLocator; import org.jboss.cx.remoting.RemoteExecutionException; import org.jboss.cx.remoting.RemotingException; import org.jboss.cx.remoting.RequestListener; @@ -30,6 +29,7 @@ import org.jboss.cx.remoting.spi.protocol.ContextIdentifier; import org.jboss.cx.remoting.core.util.MessageInput; import org.jboss.cx.remoting.core.util.MessageOutput; +import org.jboss.cx.remoting.core.util.AttributeMap; import org.jboss.cx.remoting.spi.protocol.ProtocolContext; import org.jboss.cx.remoting.spi.protocol.ProtocolHandler; import org.jboss.cx.remoting.spi.protocol.ProtocolHandlerFactory; @@ -40,9 +40,7 @@ import org.jboss.cx.remoting.spi.stream.StreamSerializer; import org.jboss.cx.remoting.spi.stream.StreamSerializerFactory; -import javax.security.auth.callback.CallbackHandler; - /** * Three execution contexts: * @@ -56,7 +54,7 @@ private final ProtocolContextImpl protocolContext = new ProtocolContextImpl(); private final UserSession userSession = new UserSession(); - // stream serialization detectors - immutable + // stream serialization detectors - immutable (for now?) private final List<StreamDetector> streamDetectors; // clients - weak reference, to clean up if the user leaks @@ -72,42 +70,46 @@ // don't GC the endpoint while a session lives private final CoreEndpoint endpoint; - private final ProtocolHandler protocolHandler; - private final String remoteEndpointName; - private final AtomicStateMachine<State> state = AtomicStateMachine.start(State.UP); + /** The protocol handler. Set on NEW -> CONNECTING */ + private ProtocolHandler protocolHandler; + /** The remote endpoint name. Set on CONNECTING -> UP */ + private String remoteEndpointName; + private final AtomicStateMachine<State> state = AtomicStateMachine.start(State.NEW); + // Constructors - CoreSession(final CoreEndpoint endpoint, final ProtocolHandler protocolHandler) { + CoreSession(final CoreEndpoint endpoint) { if (endpoint == null) { throw new NullPointerException("endpoint is null"); } + this.endpoint = endpoint; + // todo - make stream detectors pluggable + streamDetectors = java.util.Collections.<StreamDetector>singletonList(new DefaultStreamDetector()); + } + + // Initializers + + void initializeServer(final ProtocolHandler protocolHandler) { if (protocolHandler == null) { throw new NullPointerException("protocolHandler is null"); } - this.endpoint = endpoint; + state.requireTransitionExclusive(State.NEW, State.CONNECTING); this.protocolHandler = protocolHandler; - streamDetectors = java.util.Collections.<StreamDetector>singletonList(new DefaultStreamDetector()); - remoteEndpointName = protocolHandler.getRemoteEndpointName(); + state.releaseExclusive(); } - CoreSession(final CoreEndpoint endpoint, final ProtocolHandlerFactory factory, final EndpointLocator endpointLocator) throws IOException { - if (endpoint == null) { - throw new NullPointerException("endpoint is null"); + void initializeClient(final ProtocolHandlerFactory protocolHandlerFactory, final URI remoteUri, final AttributeMap attributeMap) throws IOException { + if (protocolHandlerFactory == null) { + throw new NullPointerException("protocolHandlerFactory is null"); } - if (factory == null) { - throw new NullPointerException("factory is null"); + state.requireTransitionExclusive(State.NEW, State.CONNECTING); + try { + protocolHandlerFactory.createHandler(protocolContext, remoteUri, attributeMap); + } finally { + state.releaseExclusive(); } - if (endpointLocator == null) { - throw new NullPointerException("endpointLocator is null"); - } - streamDetectors = java.util.Collections.<StreamDetector>singletonList(new DefaultStreamDetector()); - this.endpoint = endpoint; - final CallbackHandler locatorCallbackHandler = endpointLocator.getClientCallbackHandler(); - final Endpoint userEndpoint = endpoint.getUserEndpoint(); - protocolHandler = factory.createHandler(protocolContext, endpointLocator.getEndpointUri(), locatorCallbackHandler == null ? userEndpoint.getLocalCallbackHandler() : locatorCallbackHandler); - remoteEndpointName = protocolHandler.getRemoteEndpointName(); } // Outbound protocol messages @@ -227,9 +229,11 @@ // State mgmt private enum State { - DOWN, + NEW, + CONNECTING, UP, STOPPING, + DOWN, } void shutdown() { @@ -448,8 +452,9 @@ if (locator.getServiceType() == null) { throw new NullPointerException("locator.getServiceType() is null"); } - state.requireHold(State.UP); + state.waitForNotHold(State.CONNECTING); try { + state.require(State.UP); final CoreOutboundService<I, O> service = createService(locator); service.sendServiceRequest(); service.await(); @@ -567,6 +572,16 @@ coreStream.receiveStreamData(data); } + public void openSession(String remoteEndpointName) { + state.waitForNotExclusive(State.NEW); + try { + state.requireTransition(State.CONNECTING, State.UP); + CoreSession.this.remoteEndpointName = remoteEndpointName; + } finally { + state.releaseExclusive(); + } + } + public void receiveRequest(final ContextIdentifier remoteContextIdentifier, final RequestIdentifier requestIdentifier, final Object request) { final CoreInboundContext context = getServerContext(remoteContextIdentifier); if (context != null) { Modified: remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/LocalProtocol.java =================================================================== --- remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/LocalProtocol.java 2008-02-19 08:12:17 UTC (rev 3458) +++ remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/LocalProtocol.java 2008-02-21 00:35:30 UTC (rev 3459) @@ -15,6 +15,7 @@ import org.jboss.cx.remoting.core.util.MessageOutput; import org.jboss.cx.remoting.spi.protocol.ContextIdentifier; import org.jboss.cx.remoting.core.util.MessageInput; +import org.jboss.cx.remoting.core.util.AttributeMap; import org.jboss.cx.remoting.spi.protocol.ProtocolContext; import org.jboss.cx.remoting.spi.protocol.ProtocolHandler; import org.jboss.cx.remoting.spi.protocol.ProtocolHandlerFactory; @@ -29,8 +30,6 @@ import org.jboss.cx.remoting.spi.protocol.SimpleStreamIdentifier; import org.jboss.cx.remoting.spi.protocol.StreamIdentifier; -import javax.security.auth.callback.CallbackHandler; - /** * */ @@ -59,7 +58,7 @@ return true; } - public ProtocolHandler createHandler(ProtocolContext context, URI remoteUri, final CallbackHandler clientCallbackHandler) throws IOException { + public ProtocolHandler createHandler(ProtocolContext context, URI remoteUri, final AttributeMap attributeMap) throws IOException { final String remoteName = remoteUri.getSchemeSpecificPart(); final ProtocolServerContext serverContext = endpoints.get(remoteName); if (serverContext == null) { Modified: remoting3/trunk/http/src/main/java/org/jboss/cx/remoting/http/HttpProtocolSupport.java =================================================================== --- remoting3/trunk/http/src/main/java/org/jboss/cx/remoting/http/HttpProtocolSupport.java 2008-02-19 08:12:17 UTC (rev 3458) +++ remoting3/trunk/http/src/main/java/org/jboss/cx/remoting/http/HttpProtocolSupport.java 2008-02-21 00:35:30 UTC (rev 3459) @@ -7,6 +7,7 @@ import org.jboss.cx.remoting.Endpoint; import org.jboss.cx.remoting.RemotingException; import org.jboss.cx.remoting.core.util.CollectionUtil; +import org.jboss.cx.remoting.core.util.AttributeMap; import org.jboss.cx.remoting.http.spi.RemotingHttpServerContext; import org.jboss.cx.remoting.http.spi.RemotingHttpSessionContext; import org.jboss.cx.remoting.http.spi.HttpTransporter; @@ -18,8 +19,6 @@ import org.jboss.cx.remoting.spi.protocol.ProtocolRegistrationSpec; import org.jboss.cx.remoting.spi.protocol.ProtocolServerContext; -import javax.security.auth.callback.CallbackHandler; - /** * */ @@ -68,11 +67,11 @@ return false; } - public ProtocolHandler createHandler(ProtocolContext context, URI remoteUri, CallbackHandler clientCallbackHandler) throws IOException { + public ProtocolHandler createHandler(ProtocolContext context, URI remoteUri, final AttributeMap attributeMap) throws IOException { if (httpTransporter == null) { throw new IOException("No ability to initiate an HTTP connection (no transporter available)"); } - return new RemotingHttpSessionImpl(HttpProtocolSupport.this, context, clientCallbackHandler).getProtocolHandler(); + return new RemotingHttpSessionImpl(HttpProtocolSupport.this, context).getProtocolHandler(); } public void close() { Modified: remoting3/trunk/http/src/main/java/org/jboss/cx/remoting/http/RemotingHttpSessionImpl.java =================================================================== --- remoting3/trunk/http/src/main/java/org/jboss/cx/remoting/http/RemotingHttpSessionImpl.java 2008-02-19 08:12:17 UTC (rev 3458) +++ remoting3/trunk/http/src/main/java/org/jboss/cx/remoting/http/RemotingHttpSessionImpl.java 2008-02-21 00:35:30 UTC (rev 3459) @@ -17,8 +17,6 @@ import org.jboss.cx.remoting.RemoteExecutionException; import org.jboss.cx.remoting.ServiceLocator; -import javax.security.auth.callback.CallbackHandler; - import java.util.LinkedList; import java.util.Set; import java.util.HashSet; @@ -43,15 +41,13 @@ private final BlockingQueue<IncomingHttpMessage> incomingQueue = CollectionUtil.synchronizedQueue(new LinkedList<IncomingHttpMessage>()); private final BlockingQueue<OutputAction> outgoingQueue = CollectionUtil.synchronizedQueue(new LinkedList<OutputAction>()); private final String sessionId; - private final CallbackHandler callbackHandler; private final AtomicLong outputSequence = new AtomicLong(0L); private final AtomicLong inputSequence = new AtomicLong(0L); private static final int PROTOCOL_VERSION = 0; - public RemotingHttpSessionImpl(final HttpProtocolSupport protocolSupport, final ProtocolContext protocolContext, final CallbackHandler callbackHandler) { + public RemotingHttpSessionImpl(final HttpProtocolSupport protocolSupport, final ProtocolContext protocolContext) { this.protocolContext = protocolContext; - this.callbackHandler = callbackHandler; String sessionId; do { sessionId = protocolSupport.generateSessionId(); @@ -109,10 +105,6 @@ } } } - - public CallbackHandler getCallbackHandler() { - return callbackHandler; - } } private void write(ObjectOutput output, MsgType type) throws IOException { Modified: remoting3/trunk/http/src/main/java/org/jboss/cx/remoting/http/spi/RemotingHttpSessionContext.java =================================================================== --- remoting3/trunk/http/src/main/java/org/jboss/cx/remoting/http/spi/RemotingHttpSessionContext.java 2008-02-19 08:12:17 UTC (rev 3458) +++ remoting3/trunk/http/src/main/java/org/jboss/cx/remoting/http/spi/RemotingHttpSessionContext.java 2008-02-21 00:35:30 UTC (rev 3459) @@ -20,10 +20,4 @@ OutgoingHttpMessage getNextMessage(long timeoutMillis) throws InterruptedException; - /** - * Get the callback handler to use to authenticate incoming HTTP messages. - * - * @return the callback handler - */ - CallbackHandler getCallbackHandler(); } Modified: remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppConnection.java =================================================================== --- remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppConnection.java 2008-02-19 08:12:17 UTC (rev 3458) +++ remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppConnection.java 2008-02-21 00:35:30 UTC (rev 3459) @@ -4,32 +4,30 @@ import java.io.IOException; import java.io.ObjectInput; import java.io.ObjectOutput; -import java.net.InetSocketAddress; -import java.net.URI; -import java.util.Collections; import java.util.Set; +import java.util.Map; +import java.util.HashMap; +import java.util.List; +import java.util.Enumeration; +import java.util.LinkedHashSet; +import java.util.HashSet; import java.util.concurrent.Executor; import org.apache.mina.common.AttributeKey; -import org.apache.mina.common.ConnectFuture; import org.apache.mina.common.IdleStatus; import org.apache.mina.common.IoBuffer; -import org.apache.mina.common.IoConnector; import org.apache.mina.common.IoSession; -import org.apache.mina.common.IoSessionInitializer; -import org.apache.mina.filter.sasl.CallbackHandlerFactory; -import org.apache.mina.filter.sasl.SaslClientFactory; import org.apache.mina.filter.sasl.SaslClientFilter; -import org.apache.mina.filter.sasl.SaslMessageSender; -import org.apache.mina.filter.sasl.SaslServerFactory; import org.apache.mina.filter.sasl.SaslServerFilter; import org.apache.mina.handler.multiton.SingleSessionIoHandler; import org.jboss.cx.remoting.RemoteExecutionException; import org.jboss.cx.remoting.ServiceLocator; +import org.jboss.cx.remoting.CommonKeys; import org.jboss.cx.remoting.log.Logger; import org.jboss.cx.remoting.core.util.AtomicStateMachine; import org.jboss.cx.remoting.core.util.CollectionUtil; import org.jboss.cx.remoting.core.util.MessageInput; import org.jboss.cx.remoting.core.util.MessageOutput; +import org.jboss.cx.remoting.core.util.AttributeMap; import org.jboss.cx.remoting.jrpp.id.IdentifierManager; import org.jboss.cx.remoting.jrpp.id.JrppContextIdentifier; import org.jboss.cx.remoting.jrpp.id.JrppRequestIdentifier; @@ -46,10 +44,17 @@ import org.jboss.cx.remoting.spi.protocol.StreamIdentifier; import javax.security.auth.callback.CallbackHandler; +import javax.security.auth.callback.Callback; +import javax.security.auth.callback.UnsupportedCallbackException; +import javax.security.auth.callback.NameCallback; +import javax.security.auth.callback.PasswordCallback; import javax.security.sasl.Sasl; +import javax.security.sasl.SaslException; import javax.security.sasl.SaslClient; -import javax.security.sasl.SaslException; import javax.security.sasl.SaslServer; +import javax.security.sasl.RealmCallback; +import javax.security.sasl.SaslServerFactory; +import javax.security.sasl.AuthorizeCallback; /** * @@ -62,16 +67,17 @@ private static final AttributeKey JRPP_CONNECTION = new AttributeKey(JrppConnection.class, "jrppConnection"); - private static final String SASL_CLIENT_FILTER_NAME = "SASL client filter"; - private static final String SASL_SERVER_FILTER_NAME = "SASL server filter"; + public static final String SASL_CLIENT_FILTER_NAME = "SASL client filter"; + public static final String SASL_SERVER_FILTER_NAME = "SASL server filter"; - private IoSession ioSession; private final ProtocolHandler protocolHandler; - private final ProtocolContext protocolContext; private final SingleSessionIoHandler ioHandler; private final IdentifierManager identifierManager; + private final AttributeMap attributeMap; + private IoSession ioSession; private String remoteName; + private ProtocolContext protocolContext; /** * The negotiated protocol version. Value is set to {@code min(PROTOCOL_VERSION, remote PROTOCOL_VERSION)}. @@ -85,10 +91,14 @@ } private enum State { + /** Initial state - unconnected */ + NEW, /** Client side, waiting to receive protocol version info */ AWAITING_SERVER_VERSION, /** Server side, waiting to receive protocol version info */ AWAITING_CLIENT_VERSION, + /** Server side, waiting to receive authentication request */ + AWAITING_CLIENT_AUTH_REQUEST, /** Client side, auth phase */ AWAITING_SERVER_CHALLENGE, /** Server side, auth phase */ @@ -99,93 +109,157 @@ CLOSED, } - private AtomicStateMachine<State> currentState; + private final AtomicStateMachine<State> state = AtomicStateMachine.start(State.NEW); private static final Logger log = Logger.getLogger(JrppConnection.class); - /** - * Client side. - * - * @param connector - * @param uri - * @param protocolContext - * @param clientCallbackHandler - */ - public JrppConnection(final IoConnector connector, final URI uri, final ProtocolContext protocolContext, final CallbackHandler clientCallbackHandler) { - // todo - this seems very iffy to me, since we're basically leaking "this" before constructor is done - this.protocolContext = protocolContext; + public JrppConnection(final AttributeMap attributeMap) { + this.attributeMap = attributeMap; ioHandler = new IoHandlerImpl(); - final ConnectFuture future = connector.connect(new InetSocketAddress(uri.getHost(), uri.getPort()), new IoSessionInitializer<ConnectFuture>() { - public void initializeSession(final IoSession session, final ConnectFuture future) { - session.setAttribute(JRPP_CONNECTION, JrppConnection.this); - JrppConnection.this.ioSession = session; + identifierManager = new IdentifierManager(); + protocolHandler = new RemotingProtocolHandler(); + } + + public void initializeClient(final IoSession ioSession, final ProtocolContext protocolContext) { + state.transitionExclusive(State.NEW, State.AWAITING_SERVER_VERSION); + try { + ioSession.setAttribute(JRPP_CONNECTION, this); + this.ioSession = ioSession; + } finally { + state.releaseExclusive(); + } + } + + public void initializeServer(final IoSession ioSession, final ProtocolServerContext protocolServerContext) { + state.transitionExclusive(State.NEW, State.AWAITING_CLIENT_VERSION); + try { + ioSession.setAttribute(JRPP_CONNECTION, this); + this.ioSession = ioSession; + final ProtocolContext protocolContext = protocolServerContext.establishSession(protocolHandler); + this.protocolContext = protocolContext; + } finally { + state.releaseExclusive(); + } + } + + private String getNegotiatedMechanism(final String[] clientMechs, final Set<String> serverMechs) throws SaslException { + for (String name : clientMechs) { + if (serverMechs.contains(name)) { + return name; } - }); - // make sure it's initialized for *this* thread as well - ioSession = future.awaitUninterruptibly().getSession(); + } + throw new SaslException("No acceptable mechanisms found"); + } - protocolHandler = new RemotingProtocolHandler(); - identifierManager = new IdentifierManager(); - currentState = AtomicStateMachine.start(State.AWAITING_SERVER_VERSION); - ioSession.getFilterChain().addLast(SASL_CLIENT_FILTER_NAME, new SaslClientFilter(new SaslClientFactory(){ - public SaslClient createSaslClient(IoSession ioSession, CallbackHandler callbackHandler) throws SaslException { - return Sasl.createSaslClient(new String[] { "SRP" }, protocolContext.getLocalEndpointName(), "JRPP", uri.getHost(), Collections.<String,Object>emptyMap(), callbackHandler); + private String getAuthorizationId(final AttributeMap attributeMap, final ProtocolContext protocolContext) { + final String authorizationId = attributeMap.get(CommonKeys.AUTHORIZATION_ID); + if (authorizationId != null) { + return authorizationId; + } + return protocolContext.getLocalEndpointName(); + } + + private Set<String> getServerMechanisms(final AttributeMap attributeMap, final Map<String, ?> saslProps) { + final Set<String> set = attributeMap.get(CommonKeys.SASL_SERVER_MECHANISMS); + if (set != null) { + return set; + } + final Set<String> mechanisms = new HashSet<String>(); + final Enumeration<SaslServerFactory> e = Sasl.getSaslServerFactories(); + while (e.hasMoreElements()) { + final SaslServerFactory serverFactory = e.nextElement(); + for (String name : serverFactory.getMechanismNames(saslProps)) { + mechanisms.add(name); } - }, new SaslMessageSender() { - public void sendSaslMessage(IoSession ioSession, byte[] rawMsgData) throws IOException { - final IoBuffer buffer = newBuffer(rawMsgData.length + 30, false); - final MessageOutput output = protocolContext.getMessageOutput(new IoBufferByteOutput(buffer, ioSession)); - write(output, MessageType.SASL_RESPONSE); - output.write(rawMsgData); - output.commit(); + } + return mechanisms; + } + + private String[] getClientMechanisms(final AttributeMap attributeMap, final Map<String, ?> saslProps) { + final List<String> list = attributeMap.get(CommonKeys.SASL_CLIENT_MECHANISMS); + if (list != null) { + return list.toArray(new String[list.size()]); + } + final Set<String> mechanisms = new LinkedHashSet<String>(); + final Enumeration<javax.security.sasl.SaslClientFactory> e = Sasl.getSaslClientFactories(); + while (e.hasMoreElements()) { + final javax.security.sasl.SaslClientFactory clientFactory = e.nextElement(); + for (String name : clientFactory.getMechanismNames(saslProps)) { + mechanisms.add(name); } - }, new CallbackHandlerFactory() { - public CallbackHandler getCallbackHandler() { - return clientCallbackHandler; - } - })); + } + return mechanisms.toArray(new String[mechanisms.size()]); } - /** - * Server side. - * - * @param ioSession - * @param serverContext - * @throws java.io.IOException - */ - public JrppConnection(final IoSession ioSession, final ProtocolServerContext serverContext, final CallbackHandler serverCallbackHandler) throws IOException { - ioSession.setAttribute(JRPP_CONNECTION, this); - this.ioSession = ioSession; + private Map<String, ?> getSaslProperties(final AttributeMap attributeMap) { + final Map<String, ?> props = attributeMap.get(CommonKeys.SASL_PROPERTIES); + if (props != null) { + return props; + } + final Map<String, Object> defaultProps = new HashMap<String, Object>(); + defaultProps.put(Sasl.POLICY_NOPLAINTEXT, "true"); + defaultProps.put(Sasl.POLICY_NOANONYMOUS, "true"); + defaultProps.put(Sasl.POLICY_NODICTIONARY, "true"); + defaultProps.put(Sasl.POLICY_NOACTIVE, "true"); + defaultProps.put(Sasl.QOP, "auth-conf"); + return defaultProps; + } - protocolHandler = new RemotingProtocolHandler(); - ioHandler = new IoHandlerImpl(); + private CallbackHandler getServerCallbackHandler(final AttributeMap attributeMap) { + final CallbackHandler callbackHandler = attributeMap.get(CommonKeys.AUTH_CALLBACK_HANDLER); + if (callbackHandler != null) { + return callbackHandler; + } + return new CallbackHandler() { + public void handle(Callback[] callbacks) throws IOException, UnsupportedCallbackException { + for (Callback callback : callbacks) { + if (callback instanceof NameCallback) { + ((NameCallback)callback).setName("anonymous"); + } else if (callback instanceof PasswordCallback) { + ((PasswordCallback)callback).setPassword(new char[0]); + } else if (callback instanceof RealmCallback) { + continue; + } else if (callback instanceof AuthorizeCallback) { + ((AuthorizeCallback)callback).setAuthorized(true); + } + throw new UnsupportedCallbackException(callback, "Default anonymous server callback handler cannot support this callback type"); + } + } + }; + } - protocolContext = serverContext.establishSession(protocolHandler); - identifierManager = new IdentifierManager(); - currentState = AtomicStateMachine.start(State.AWAITING_CLIENT_VERSION); - ioSession.getFilterChain().addLast(SASL_SERVER_FILTER_NAME, new SaslServerFilter(new SaslServerFactory(){ - public SaslServer createSaslServer(IoSession ioSession, CallbackHandler callbackHandler) throws SaslException { - return Sasl.createSaslServer("SRP", "JRPP", protocolContext.getLocalEndpointName(), Collections.<String,Object>emptyMap(), callbackHandler); + private CallbackHandler getClientCallbackHandler(final AttributeMap attributeMap) { + final CallbackHandler callbackHandler = attributeMap.get(CommonKeys.AUTH_CALLBACK_HANDLER); + if (callbackHandler != null) { + return callbackHandler; + } + return new CallbackHandler() { + public void handle(Callback[] callbacks) throws IOException, UnsupportedCallbackException { + for (Callback callback : callbacks) { + if (callback instanceof NameCallback) { + ((NameCallback)callback).setName("anonymous"); + } else if (callback instanceof PasswordCallback) { + ((PasswordCallback)callback).setPassword(new char[0]); + } else { + throw new UnsupportedCallbackException(callback, "Default anonymous client callback handler cannot support this callback type"); + } + } } - }, new SaslMessageSender(){ - public void sendSaslMessage(IoSession ioSession, byte[] rawMsgData) throws IOException { - final IoBuffer buffer = newBuffer(rawMsgData.length + 30, false); - final MessageOutput output = protocolContext.getMessageOutput(new IoBufferByteOutput(buffer, ioSession)); - write(output, MessageType.SASL_CHALLENGE); - output.write(rawMsgData); - output.commit(); - } - }, new CallbackHandlerFactory(){ - public CallbackHandler getCallbackHandler() { - return serverCallbackHandler; - } - })); + }; } public static JrppConnection getConnection(IoSession ioSession) { return (JrppConnection) ioSession.getAttribute(JRPP_CONNECTION); } + private SaslClientFilter getSaslClientFilter() { + return (SaslClientFilter) ioSession.getFilterChain().get(SASL_CLIENT_FILTER_NAME); + } + + private SaslServerFilter getSaslServerFilter() { + return (SaslServerFilter) ioSession.getFilterChain().get(SASL_SERVER_FILTER_NAME); + } + public IoSession getIoSession() { return ioSession; } @@ -238,15 +312,25 @@ output.commit(); } + public void sendVersionMessage() throws IOException { + // send version info + final IoBuffer buffer = newBuffer(60, false); + final MessageOutput output = protocolContext.getMessageOutput(new IoBufferByteOutput(buffer, ioSession)); + write(output, MessageType.VERSION); + output.writeShort(PROTOCOL_VERSION); + output.writeUTF(protocolContext.getLocalEndpointName()); + output.commit(); + } + public boolean waitForUp() throws IOException { - while (! currentState.in(State.UP, State.CLOSED)) { - currentState.waitForAny(); + while (! state.in(State.UP, State.CLOSED)) { + state.waitForAny(); } - return currentState.in(State.UP); + return state.in(State.UP); } private void close() { - currentState.transition(State.CLOSED); + state.transition(State.CLOSED); ioSession.close().awaitUninterruptibly(); protocolContext.closeSession(); } @@ -281,7 +365,7 @@ } public void closeSession() throws IOException { - if (currentState.transition(State.CLOSED)) { + if (state.transition(State.CLOSED)) { // todo - maybe we don't need to wait? ioSession.close().awaitUninterruptibly(); } @@ -292,7 +376,7 @@ } public void closeService(ServiceIdentifier serviceIdentifier) throws IOException { - if (! currentState.in(State.UP)) { + if (! state.in(State.UP)) { return; } final IoBuffer buffer = newBuffer(60, false); @@ -303,7 +387,7 @@ } public void closeContext(ContextIdentifier contextIdentifier) throws IOException { - if (! currentState.in(State.UP)) { + if (! state.in(State.UP)) { return; } final IoBuffer buffer = newBuffer(60, false); @@ -314,7 +398,7 @@ } public void closeStream(StreamIdentifier streamIdentifier) throws IOException { - if (! currentState.in(State.UP)) { + if (! state.in(State.UP)) { return; } if (true /* todo if close not already sent */) { @@ -342,7 +426,7 @@ if (locator == null) { throw new NullPointerException("locator is null"); } - if (! currentState.in(State.UP)) { + if (! state.in(State.UP)) { throw new IllegalStateException("JrppConnection is not in the UP state!"); } final IoBuffer buffer = newBuffer(500, true); @@ -486,13 +570,8 @@ } public void sessionOpened() throws IOException { - // send version info - final IoBuffer buffer = newBuffer(60, false); - final MessageOutput output = protocolContext.getMessageOutput(new IoBufferByteOutput(buffer, ioSession)); - write(output, MessageType.VERSION); - output.writeShort(PROTOCOL_VERSION); - output.writeUTF(protocolContext.getLocalEndpointName()); - output.commit(); + // TODO - there may be a mina bug where this method is not guaranteed to be called before any messages can be received! DIRMINA-535 + sendVersionMessage(); } public void sessionClosed() { @@ -528,9 +607,9 @@ final MessageInput input = protocolContext.getMessageInput(new IoBufferByteInput((IoBuffer) message)); final MessageType type = MessageType.values()[input.readByte() & 0xff]; if (trace) { - log.trace("Received message of type %s in state %s", type, currentState.getState()); + log.trace("Received message of type %s in state %s", type, state.getState()); } - OUT: switch (currentState.getState()) { + OUT: switch (state.getState()) { case AWAITING_CLIENT_VERSION: { switch (type) { case VERSION: { @@ -540,16 +619,36 @@ } final String name = input.readUTF(); remoteName = name.length() > 0 ? name : null; - SaslServerFilter saslServerFilter = getSaslServerFilter(); + state.requireTransition(State.AWAITING_CLIENT_AUTH_REQUEST); + return; + } + default: break OUT; + } + } + case AWAITING_CLIENT_AUTH_REQUEST: { + switch (type) { + case AUTH_REQUEST: { + final int mechCount = input.readInt(); + final String[] clientMechs = new String[mechCount]; + for (int i = 0; i < mechCount; i ++) { + clientMechs[i] = input.readUTF(); + } + final CallbackHandler callbackHandler = getServerCallbackHandler(attributeMap); + final Map<String, ?> saslProps = getSaslProperties(attributeMap); + final Set<String> serverMechs = getServerMechanisms(attributeMap, saslProps); + final String negotiatedMechanism = getNegotiatedMechanism(clientMechs, serverMechs); + final SaslServer saslServer = Sasl.createSaslServer(negotiatedMechanism, "jrpp", protocolContext.getLocalEndpointName(), saslProps, callbackHandler); + final SaslServerFilter saslServerFilter = getSaslServerFilter(); + saslServerFilter.setSaslServer(ioSession, saslServer); if (saslServerFilter.sendInitialChallenge(ioSession)) { // complete (that was quick!) final IoBuffer buffer = newBuffer(60, false); final MessageOutput output = protocolContext.getMessageOutput(new IoBufferByteOutput(buffer, ioSession)); write(output, MessageType.AUTH_SUCCESS); output.commit(); - currentState.requireTransition(State.AWAITING_CLIENT_VERSION, State.UP); + state.requireTransition(State.AWAITING_CLIENT_VERSION, State.UP); } else { - currentState.requireTransition(State.AWAITING_CLIENT_VERSION, State.AWAITING_CLIENT_RESPONSE); + state.requireTransition(State.AWAITING_CLIENT_VERSION, State.AWAITING_CLIENT_RESPONSE); } return; } @@ -565,7 +664,14 @@ } final String name = input.readUTF(); remoteName = name.length() > 0 ? name : null; - currentState.requireTransition(State.AWAITING_SERVER_VERSION, State.AWAITING_SERVER_CHALLENGE); + final CallbackHandler callbackHandler = getClientCallbackHandler(attributeMap); + final Map<String, ?> saslProps = getSaslProperties(attributeMap); + final String[] clientMechs = getClientMechanisms(attributeMap, saslProps); + final String authorizationId = getAuthorizationId(attributeMap, protocolContext); + final SaslClient saslClient = Sasl.createSaslClient(clientMechs, authorizationId, "jrpp", remoteName, saslProps, callbackHandler); + final SaslClientFilter saslClientFilter = getSaslClientFilter(); + saslClientFilter.setSaslClient(ioSession, saslClient); + state.requireTransition(State.AWAITING_SERVER_VERSION, State.AWAITING_SERVER_CHALLENGE); return; } default: break OUT; @@ -587,7 +693,7 @@ write(output, MessageType.AUTH_SUCCESS); output.commit(); saslServerFilter.startEncryption(ioSession); - currentState.requireTransition(State.AWAITING_CLIENT_RESPONSE, State.UP); + state.requireTransition(State.AWAITING_CLIENT_RESPONSE, State.UP); } } catch (SaslException ex) { final IoBuffer buffer = newBuffer(60, false); @@ -595,6 +701,8 @@ write(output, MessageType.AUTH_FAILED); output.commit(); log.info("Client authentication failed (" + ex.getMessage() + ")"); + // todo - retry counter - JBREM-907 + state.requireTransition(State.AWAITING_CLIENT_RESPONSE, State.AWAITING_CLIENT_AUTH_REQUEST); } return; } @@ -613,12 +721,20 @@ case AUTH_SUCCESS: { SaslClientFilter saslClientFilter = getSaslClientFilter(); saslClientFilter.startEncryption(ioSession); - currentState.requireTransition(State.AWAITING_SERVER_CHALLENGE, State.UP); + state.requireTransition(State.AWAITING_SERVER_CHALLENGE, State.UP); return; } case AUTH_FAILED: { log.info("JRPP client rejected authentication"); - close(); + final SaslClientFilter oldClientFilter = getSaslClientFilter(); + oldClientFilter.destroy(); + final CallbackHandler callbackHandler = getClientCallbackHandler(attributeMap); + final Map<String, ?> saslProps = getSaslProperties(attributeMap); + final String[] clientMechs = getClientMechanisms(attributeMap, saslProps); + final String authorizationId = getAuthorizationId(attributeMap, protocolContext); + final SaslClient saslClient = Sasl.createSaslClient(clientMechs, authorizationId, "jrpp", remoteName, saslProps, callbackHandler); + final SaslClientFilter saslClientFilter = getSaslClientFilter(); + saslClientFilter.setSaslClient(ioSession, saslClient); return; } default: break OUT; @@ -723,17 +839,9 @@ } } } - throw new IllegalStateException("Got message " + type + " during " + currentState); + throw new IllegalStateException("Got message " + type + " during " + state); } - private SaslClientFilter getSaslClientFilter() { - return (SaslClientFilter) ioSession.getFilterChain().get(SASL_CLIENT_FILTER_NAME); - } - - private SaslServerFilter getSaslServerFilter() { - return (SaslServerFilter) ioSession.getFilterChain().get(SASL_SERVER_FILTER_NAME); - } - public void messageSent(Object object) { } } @@ -743,6 +851,7 @@ */ private enum MessageType { VERSION, + AUTH_REQUEST, SASL_CHALLENGE, SASL_RESPONSE, AUTH_SUCCESS, Modified: remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppProtocolSupport.java =================================================================== --- remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppProtocolSupport.java 2008-02-19 08:12:17 UTC (rev 3458) +++ remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppProtocolSupport.java 2008-02-21 00:35:30 UTC (rev 3459) @@ -3,24 +3,24 @@ import java.io.IOException; import java.net.SocketAddress; import java.net.URI; -import java.util.Set; -import java.util.concurrent.ExecutorService; -import java.util.concurrent.Executors; -import org.apache.mina.common.IoAcceptor; +import java.net.InetSocketAddress; +import java.util.concurrent.Executor; import org.apache.mina.common.IoConnector; -import org.apache.mina.common.IoHandler; import org.apache.mina.common.IoSession; +import org.apache.mina.common.ConnectFuture; +import org.apache.mina.common.IoSessionInitializer; +import org.apache.mina.common.IoProcessor; import org.apache.mina.filter.logging.LoggingFilter; +import org.apache.mina.filter.sasl.SaslClientFilter; +import org.apache.mina.filter.sasl.SaslMessageSender; import org.apache.mina.handler.multiton.SingleSessionIoHandler; import org.apache.mina.handler.multiton.SingleSessionIoHandlerDelegate; import org.apache.mina.handler.multiton.SingleSessionIoHandlerFactory; import org.apache.mina.transport.socket.nio.NioProcessor; -import org.apache.mina.transport.socket.nio.NioSocketAcceptor; import org.apache.mina.transport.socket.nio.NioSocketConnector; import org.jboss.cx.remoting.Endpoint; -import org.jboss.cx.remoting.EndpointShutdownListener; import org.jboss.cx.remoting.RemotingException; -import org.jboss.cx.remoting.core.util.CollectionUtil; +import org.jboss.cx.remoting.core.util.AttributeMap; import org.jboss.cx.remoting.jrpp.mina.FramingIoFilter; import org.jboss.cx.remoting.spi.protocol.ProtocolContext; import org.jboss.cx.remoting.spi.protocol.ProtocolHandler; @@ -29,63 +29,91 @@ import org.jboss.cx.remoting.spi.protocol.ProtocolRegistrationSpec; import org.jboss.cx.remoting.spi.protocol.ProtocolServerContext; -import javax.security.auth.callback.CallbackHandler; - /** * */ public final class JrppProtocolSupport { - @SuppressWarnings ({"UnusedDeclaration"}) - private final Endpoint endpoint; - private final ProtocolServerContext serverContext; - private final IoHandler serverIoHandler = new SingleSessionIoHandlerDelegate(new ServerSessionHandlerFactory()); - private final Set<IoAcceptor> ioAcceptors = CollectionUtil.synchronizedSet(CollectionUtil.<IoAcceptor>hashSet()); - // todo - make the thread pools configurable - private final ExecutorService threadPool = Executors.newCachedThreadPool(); - private final NioProcessor nioProcessor = new NioProcessor(threadPool); - private final ProtocolHandlerFactoryImpl protocolHandlerFactory = new ProtocolHandlerFactoryImpl(); + private ProtocolHandlerFactoryImpl protocolHandlerFactory; - public JrppProtocolSupport(final Endpoint endpoint) throws RemotingException { + /** Thread pool to use. Set before {@code create}. */ + private Executor executor; + /** Endpoint. Set before {@code create}. */ + private Endpoint endpoint; + + /** The NIO processor. Set upon {@code create}. */ + private IoProcessor ioProcessor; + /** Protocol server context. Set upon {@code create}. */ + private ProtocolServerContext serverContext; + /** Protocol registration. Set upon {@code create}. */ + private ProtocolRegistration registration; + + public JrppProtocolSupport() { + } + + // Accessors + + public Executor getExecutor() { + return executor; + } + + public void setExecutor(final Executor executor) { + this.executor = executor; + } + + public Endpoint getEndpoint() { + return endpoint; + } + + public void setEndpoint(final Endpoint endpoint) { + this.endpoint = endpoint; + } + + // Package getters + + IoProcessor getIoProcessor() { + return ioProcessor; + } + + ProtocolServerContext getServerContext() { + return serverContext; + } + + // Lifecycle + + public void create() throws RemotingException { + ioProcessor = new NioProcessor(executor); + protocolHandlerFactory = new ProtocolHandlerFactoryImpl(); final ProtocolRegistrationSpec spec = ProtocolRegistrationSpec.DEFAULT.setScheme("jrpp").setProtocolHandlerFactory(protocolHandlerFactory); final ProtocolRegistration registration = endpoint.registerProtocol(spec); serverContext = registration.getProtocolServerContext(); - this.endpoint = endpoint; - endpoint.addShutdownListener(new EndpointShutdownListener() { - public void handleShutdown(Endpoint endpoint) { - shutdown(); - } - }); + this.registration = registration; } - public void addServer(final SocketAddress address) throws IOException { - // todo - make the acceptor managable so it can be started and stopped - final IoAcceptor ioAcceptor = new NioSocketAcceptor(threadPool, nioProcessor); - ioAcceptor.setDefaultLocalAddress(address); - ioAcceptor.setHandler(serverIoHandler); - ioAcceptor.getFilterChain().addLast("framing filter", new FramingIoFilter()); - ioAcceptor.getFilterChain().addLast("debug 0", new LoggingFilter()); - ioAcceptor.bind(); - ioAcceptors.add(ioAcceptor); + public void start() { + registration.start(); } - public void shutdown() { - for (IoAcceptor acceptor : ioAcceptors) { - acceptor.unbind(); + public void stop() { + registration.stop(); + } + + public void destroy() { + if (ioProcessor != null) { + ioProcessor.dispose(); } - for (IoAcceptor acceptor : ioAcceptors) { - acceptor.dispose(); + if (registration != null) { + registration.unregister(); + registration = null; } - ioAcceptors.clear(); - protocolHandlerFactory.connector.dispose(); - threadPool.shutdown(); + protocolHandlerFactory = null; + serverContext = null; } - private final class ServerSessionHandlerFactory implements SingleSessionIoHandlerFactory { - public SingleSessionIoHandler getHandler(IoSession ioSession) throws IOException { - final JrppConnection connection; - connection = new JrppConnection(ioSession, serverContext, endpoint.getRemoteCallbackHandler()); - return connection.getIoHandler(); - } + // Utilities + + private SocketAddress getSocketAddressFromUri(final URI uri) { + // todo - validate host and/or port! + return new InetSocketAddress(uri.getHost(), uri.getPort()); } /** @@ -94,9 +122,15 @@ private final class ProtocolHandlerFactoryImpl implements ProtocolHandlerFactory, SingleSessionIoHandlerFactory { private final IoConnector connector; + @SuppressWarnings ({"unchecked"}) public ProtocolHandlerFactoryImpl() { - connector = new NioSocketConnector(threadPool, nioProcessor); + connector = new NioSocketConnector(executor, ioProcessor); connector.getFilterChain().addLast("framing filter", new FramingIoFilter()); + connector.getFilterChain().addLast(JrppConnection.SASL_CLIENT_FILTER_NAME, new SaslClientFilter(new SaslMessageSender() { + public void sendSaslMessage(IoSession ioSession, byte[] rawMsgData) throws IOException { + JrppConnection.getConnection(ioSession).sendResponse(rawMsgData); + } + })); connector.getFilterChain().addLast("debug 0", new LoggingFilter()); connector.setHandler(new SingleSessionIoHandlerDelegate(this)); } @@ -105,19 +139,21 @@ return false; } - public ProtocolHandler createHandler(ProtocolContext context, URI remoteUri, CallbackHandler clientCallbackHandler) throws IOException { + public ProtocolHandler createHandler(final ProtocolContext context, final URI remoteUri, final AttributeMap attributeMap) throws IOException { // todo - add a connect timeout // todo - local connect addr - final JrppConnection jrppConnection = new JrppConnection(connector, remoteUri, context, clientCallbackHandler); - if (jrppConnection.waitForUp()) { - return jrppConnection.getProtocolHandler(); - } else { - throw new IOException("Failed to initiate a JRPP connection"); - } + final JrppConnection jrppConnection = new JrppConnection(attributeMap); + final SocketAddress serverAddress = getSocketAddressFromUri(remoteUri); + final ConnectFuture future = connector.connect(serverAddress, new IoSessionInitializer<ConnectFuture>() { + public void initializeSession(final IoSession ioSession, final ConnectFuture connectFuture) { + jrppConnection.initializeClient(ioSession, context); + } + }); + future.awaitUninterruptibly(); + return jrppConnection.getProtocolHandler(); } public void close() { - shutdown(); } public SingleSessionIoHandler getHandler(IoSession session) throws Exception { Added: remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppServer.java =================================================================== --- remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppServer.java (rev 0) +++ remoting3/trunk/jrpp/src/main/java/org/jboss/cx/remoting/jrpp/JrppServer.java 2008-02-21 00:35:30 UTC (rev 3459) @@ -0,0 +1,118 @@ +package org.jboss.cx.remoting.jrpp; + +import java.net.SocketAddress; +import java.util.concurrent.Executor; +import java.io.IOException; +import org.apache.mina.transport.socket.nio.NioSocketAcceptor; +import org.apache.mina.common.IoAcceptor; +import org.apache.mina.common.IoHandler; +import org.apache.mina.common.IoSession; +import org.apache.mina.common.IoProcessor; +import org.apache.mina.filter.logging.LoggingFilter; +import org.apache.mina.filter.sasl.SaslServerFilter; +import org.apache.mina.filter.sasl.SaslMessageSender; +import org.apache.mina.handler.multiton.SingleSessionIoHandlerFactory; +import org.apache.mina.handler.multiton.SingleSessionIoHandler; +import org.apache.mina.handler.multiton.SingleSessionIoHandlerDelegate; +import org.jboss.cx.remoting.jrpp.mina.FramingIoFilter; +import org.jboss.cx.remoting.spi.protocol.ProtocolServerContext; +import org.jboss.cx.remoting.core.util.AttributeMap; + +/** + * + */ +public final class JrppServer { + private final IoHandler ioHandler = new SingleSessionIoHandlerDelegate(new ServerSessionHandlerFactory()); + + // injected properties + + /** The server socket address. Set before {@code create}. */ + private SocketAddress socketAddress; + /** Protocol support object. Set before {@code create}. */ + private JrppProtocolSupport protocolSupport; + + // calculated properties + + /** Executor. Set upon {@code create}. */ + private Executor executor; + /** NIO Processor. Set upon {@code create}. */ + private IoProcessor ioProcessor; + /** IO Acceptor. Set upon {@code create}. */ + private IoAcceptor ioAcceptor; + /** Protocol server context. Set upon {@code create}. */ + private ProtocolServerContext serverContext; + /** Attribute map. Set before {@code create}. */ + private AttributeMap attributeMap; + + // Accessors + + public SocketAddress getSocketAddress() { + return socketAddress; + } + + public void setSocketAddress(final SocketAddress socketAddress) { + this.socketAddress = socketAddress; + } + + public JrppProtocolSupport getProtocolSupport() { + return protocolSupport; + } + + public void setProtocolSupport(final JrppProtocolSupport protocolSupport) { + this.protocolSupport = protocolSupport; + } + + public AttributeMap getAttributeMap() { + return attributeMap; + } + + public void setAttributeMap(final AttributeMap attributeMap) { + this.attributeMap = attributeMap; + } + + // Lifecycle + + @SuppressWarnings ({"unchecked"}) + public void create() { + serverContext = protocolSupport.getServerContext(); + executor = protocolSupport.getExecutor(); + ioProcessor = protocolSupport.getIoProcessor(); + ioAcceptor = new NioSocketAcceptor(executor, ioProcessor); + ioAcceptor.setDefaultLocalAddress(socketAddress); + ioAcceptor.setHandler(ioHandler); + ioAcceptor.getFilterChain().addLast("framing filter", new FramingIoFilter()); + ioAcceptor.getFilterChain().addLast(JrppConnection.SASL_SERVER_FILTER_NAME, new SaslServerFilter(new SaslMessageSender() { + public void sendSaslMessage(IoSession ioSession, byte[] rawMsgData) throws IOException { + JrppConnection.getConnection(ioSession).sendChallenge(rawMsgData); + } + })); + ioAcceptor.getFilterChain().addLast("debug 0", new LoggingFilter()); + } + + public void start() throws IOException { + ioAcceptor.bind(); + } + + public void stop() { + ioAcceptor.unbind(); + } + + public void destroy() { + ioAcceptor.dispose(); + ioAcceptor = null; + ioProcessor = null; + executor = null; + serverContext = null; + } + + // MINA support + + private final class ServerSessionHandlerFactory implements SingleSessionIoHandlerFactory { + public SingleSessionIoHandler getHandler(IoSession ioSession) throws IOException { + final JrppConnection connection = new JrppConnection(attributeMap); + connection.initializeServer(ioSession, serverContext); + return connection.getIoHandler(); + } + } + +} Deleted: remoting3/trunk/mina-sasl/src/main/java/org/apache/mina/filter/sasl/SaslClientFactory.java =================================================================== --- remoting3/trunk/mina-sasl/src/main/java/org/apache/mina/filter/sasl/SaslClientFactory.java 2008-02-19 08:12:17 UTC (rev 3458) +++ remoting3/trunk/mina-sasl/src/main/java/org/apache/mina/filter/sasl/SaslClientFactory.java 2008-02-21 00:35:30 UTC (rev 3459) @@ -1,14 +0,0 @@ -package org.apache.mina.filter.sasl; - -import org.apache.mina.common.IoSession; - -import javax.security.auth.callback.CallbackHandler; -import javax.security.sasl.SaslClient; -import javax.security.sasl.SaslException; - -/** - * - */ -public interface SaslClientFactory { - SaslClient createSaslClient(IoSession ioSession, CallbackHandler callbackHandler) throws SaslException; -} Modified: remoting3/trunk/mina-sasl/src/main/java/org/apache/mina/filter/sasl/SaslClientFilter.java =================================================================== --- remoting3/trunk/mina-sasl/src/main/java/org/apache/mina/filter/sasl/SaslClientFilter.java 2008-02-19 08:12:17 UTC (rev 3458) +++ remoting3/trunk/mina-sasl/src/main/java/org/apache/mina/filter/sasl/SaslClientFilter.java 2008-02-21 00:35:30 UTC (rev 3459) @@ -2,7 +2,6 @@ import java.io.IOException; import org.apache.mina.common.AttributeKey; -import org.apache.mina.common.IoFilterChain; import org.apache.mina.common.IoSession; import javax.security.sasl.Sasl; @@ -28,19 +27,13 @@ public final class SaslClientFilter extends AbstractSaslFilter { private static final AttributeKey SASL_CLIENT_KEY = new AttributeKey(SaslClientFilter.class, "saslClient"); - private final SaslClientFactory saslClientFactory; - private final CallbackHandlerFactory callbackHandlerFactory; - /** * Construct a new SASL client filter. * - * @param saslClientFactory a factory which may be used to create a new SASL client instance for an {@code IoSession}. * @param messageSender the message sender, used to send response messages */ - public SaslClientFilter(final SaslClientFactory saslClientFactory, final SaslMessageSender messageSender, final CallbackHandlerFactory callbackHandlerFactory) { + public SaslClientFilter(final SaslMessageSender messageSender) { super(messageSender); - this.saslClientFactory = saslClientFactory; - this.callbackHandlerFactory = callbackHandlerFactory; } /** @@ -49,11 +42,21 @@ * @param ioSession the session * @return the SASL client instance */ - protected SaslClient getSaslClient(IoSession ioSession) { + public SaslClient getSaslClient(IoSession ioSession) { return (SaslClient) ioSession.getAttribute(SASL_CLIENT_KEY); } /** + * Set the {@code SaslClient} instance for the given session. + * + * @param ioSession the session + * @param saslClient the SASL client instance + */ + public void setSaslClient(IoSession ioSession, SaslClient saslClient) { + ioSession.setAttribute(SASL_CLIENT_KEY, saslClient); + } + + /** * Handle a received (and decoded) SASL challenge message. This method is called when the upper-level * protocol receives a complete SASL challenge message. If a response is produced, it will be sent via the * provided {@link org.apache.mina.filter.sasl.SaslMessageSender}. @@ -117,19 +120,6 @@ return (String) getSaslClient(ioSession).getNegotiatedProperty(Sasl.QOP); } - public void onPreAdd(IoFilterChain ioFilterChain, String string, NextFilter nextFilter) throws Exception { - final IoSession ioSession = ioFilterChain.getSession(); - ioSession.setAttribute(SASL_CLIENT_KEY, saslClientFactory.createSaslClient(ioSession, callbackHandlerFactory.getCallbackHandler())); - } - - public void onPostRemove(IoFilterChain ioFilterChain, String string, NextFilter nextFilter) throws Exception { - final IoSession ioSession = ioFilterChain.getSession(); - final SaslClient client = getSaslClient(ioSession); - if (client != null) { - client.dispose(); - } - } - protected byte[] wrap(IoSession ioSession, byte[] data, int offs, int len) throws SaslException { return getSaslClient(ioSession).wrap(data, offs, len); } Deleted: remoting3/trunk/mina-sasl/src/main/java/org/apache/mina/filter/sasl/SaslServerFactory.java =================================================================== --- remoting3/trunk/mina-sasl/src/main/java/org/apache/mina/filter/sasl/SaslServerFactory.java 2008-02-19 08:12:17 UTC (rev 3458) +++ remoting3/trunk/mina-sasl/src/main/java/org/apache/mina/filter/sasl/SaslServerFactory.java 2008-02-21 00:35:30 UTC (rev 3459) @@ -1,14 +0,0 @@ -package org.apache.mina.filter.sasl; - -import org.apache.mina.common.IoSession; - -import javax.security.auth.callback.CallbackHandler; -import javax.security.sasl.SaslException; -import javax.security.sasl.SaslServer; - -/** - * - */ -public interface SaslServerFactory { - SaslServer createSaslServer(IoSession ioSession, CallbackHandler callbackHandler) throws SaslException; -} Modified: remoting3/trunk/mina-sasl/src/main/java/org/apache/mina/filter/sasl/SaslServerFilter.java =================================================================== --- remoting3/trunk/mina-sasl/src/main/java/org/apache/mina/filter/sasl/SaslServerFilter.java 2008-02-19 08:12:17 UTC (rev 3458) +++ remoting3/trunk/mina-sasl/src/main/java/org/apache/mina/filter/sasl/SaslServerFilter.java 2008-02-21 00:35:30 UTC (rev 3459) @@ -2,7 +2,6 @@ import java.io.IOException; import org.apache.mina.common.AttributeKey; -import org.apache.mina.common.IoFilterChain; import org.apache.mina.common.IoSession; import javax.security.sasl.Sasl; @@ -28,19 +27,13 @@ public final class SaslServerFilter extends AbstractSaslFilter { private static final AttributeKey SASL_SERVER_KEY = new AttributeKey(SaslServerFilter.class, "saslServer"); - private final SaslServerFactory saslServerFactory; - private final CallbackHandlerFactory callbackHandlerFactory; - /** * Construct a new SASL server filter. * - * @param saslServerFactory a factory which may be used to create a new SASL server instance for an {@code IoSession}. * @param messageSender the message sender, used to send challenge messages */ - public SaslServerFilter(final SaslServerFactory saslServerFactory, final SaslMessageSender messageSender, final CallbackHandlerFactory callbackHandlerFactory) { + public SaslServerFilter(final SaslMessageSender messageSender) { super(messageSender); - this.saslServerFactory = saslServerFactory; - this.callbackHandlerFactory = callbackHandlerFactory; } /** @@ -49,11 +42,21 @@ * @param ioSession the session * @return the SASL server instance */ - protected SaslServer getSaslServer(IoSession ioSession) { + public SaslServer getSaslServer(IoSession ioSession) { return (SaslServer) ioSession.getAttribute(SASL_SERVER_KEY); } /** + * Set the {@code SaslServer} instance for the given session. + * + * @param ioSession the session + * @param saslServer the SASL server instance + */ + public void setSaslServer(IoSession ioSession, SaslServer saslServer) { + ioSession.setAttribute(SASL_SERVER_KEY, saslServer); + } + + /** * Handle a received (and decoded) SASL response message. This method is called when the upper-level * protocol receives a complete SASL response message. If another challenge is produced, it will be sent via the * provided {@link org.apache.mina.filter.sasl.SaslMessageSender}. @@ -114,23 +117,6 @@ return (String) getSaslServer(ioSession).getNegotiatedProperty(Sasl.QOP); } - public void onPreAdd(IoFilterChain ioFilterChain, String string, NextFilter nextFilter) throws Exception { - final IoSession ioSession = ioFilterChain.getSession(); - final SaslServer saslServer = saslServerFactory.createSaslServer(ioSession, callbackHandlerFactory.getCallbackHandler()); - if (saslServer == null) { - throw new NullPointerException("saslServer is null"); - } - ioSession.setAttribute(SASL_SERVER_KEY, saslServer); - } - - public void onPostRemove(IoFilterChain ioFilterChain, String string, NextFilter nextFilter) throws Exception { - final IoSession ioSession = ioFilterChain.getSession(); - final SaslServer server = getSaslServer(ioSession); - if (server != null) { - server.dispose(); - } - } - protected byte[] wrap(IoSession ioSession, byte[] data, int offs, int len) throws SaslException { return getSaslServer(ioSession).wrap(data, offs, len); } Modified: remoting3/trunk/standalone/src/main/java/org/jboss/cx/remoting/Remoting.java =================================================================== --- remoting3/trunk/standalone/src/main/java/org/jboss/cx/remoting/Remoting.java 2008-02-19 08:12:17 UTC (rev 3458) +++ remoting3/trunk/standalone/src/main/java/org/jboss/cx/remoting/Remoting.java 2008-02-21 00:35:30 UTC (rev 3459) @@ -1,12 +1,21 @@ package org.jboss.cx.remoting; import java.net.URI; +import java.io.IOException; import org.jboss.cx.remoting.log.Logger; import org.jboss.cx.remoting.core.CoreEndpointProvider; +import org.jboss.cx.remoting.core.util.AttributeMap; +import org.jboss.cx.remoting.core.util.AttributeHashMap; import org.jboss.cx.remoting.spi.EndpointProvider; import org.jboss.cx.remoting.spi.wrapper.ContextSourceWrapper; import org.jboss.cx.remoting.spi.wrapper.SessionWrapper; +import javax.security.auth.callback.CallbackHandler; +import javax.security.auth.callback.Callback; +import javax.security.auth.callback.UnsupportedCallbackException; +import javax.security.auth.callback.NameCallback; +import javax.security.auth.callback.PasswordCallback; + /** * */ @@ -21,11 +30,26 @@ return EndpointProviderHolder.provider.createEndpoint(name); } - public static Session createEndpointAndSession(String endpointName, URI remoteUri, String userName, char[] password) throws RemotingException { + public static Session createEndpointAndSession(String endpointName, URI remoteUri, final String userName, final char[] password) throws RemotingException { final Endpoint endpoint = createEndpoint(endpointName); boolean ok = false; + final CallbackHandler callbackHandler = new CallbackHandler() { + public void handle(Callback[] callbacks) throws IOException, UnsupportedCallbackException { + for (Callback callback : callbacks) { + if (callback instanceof NameCallback) { + ((NameCallback)callback).setName(userName); + } else if (callback instanceof PasswordCallback) { + ((PasswordCallback)callback).setPassword(password); + } else { + throw new UnsupportedCallbackException(callback); + } + } + } + }; + final AttributeMap attributeMap = new AttributeHashMap(); + attributeMap.put(CommonKeys.AUTH_CALLBACK_HANDLER, callbackHandler); try { - final Session session = new SessionWrapper(endpoint.openSession(EndpointLocator.DEFAULT.setEndpointUri(remoteUri).setClientAuthentication(userName, password), null)) { + final Session session = new SessionWrapper(endpoint.openSession(remoteUri, attributeMap)) { public void close() throws RemotingException { try { super.close(); Modified: remoting3/trunk/util/src/main/java/org/jboss/cx/remoting/core/util/AttributeKey.java =================================================================== --- remoting3/trunk/util/src/main/java/org/jboss/cx/remoting/core/util/AttributeKey.java 2008-02-19 08:12:17 UTC (rev 3458) +++ remoting3/trunk/util/src/main/java/org/jboss/cx/remoting/core/util/AttributeKey.java 2008-02-21 00:35:30 UTC (rev 3459) @@ -6,6 +6,10 @@ public final class AttributeKey<T> { private final String name; + public static <T> AttributeKey<T> key(String name) { + return new AttributeKey<T>(name); + } + public AttributeKey(final String name) { this.name = name; }

16 years, 9 months

1
0
0 / 0

JBoss Remoting SVN: r3458 - remoting2/branches/2.x.

by jboss-remoting-commits＠lists.jboss.org

Author: ron.sigal(a)jboss.com Date: 2008-02-19 03:12:17 -0500 (Tue, 19 Feb 2008) New Revision: 3458 Modified: remoting2/branches/2.x/build.xml Log: JBREM-876: Increased max heap size to 1024m in functional tests. Modified: remoting2/branches/2.x/build.xml =================================================================== --- remoting2/branches/2.x/build.xml 2008-02-19 03:16:58 UTC (rev 3457) +++ remoting2/branches/2.x/build.xml 2008-02-19 08:12:17 UTC (rev 3458) @@ -915,7 +915,9 @@ <target name="tests.functional.main" depends="tests.jars"> <mkdir dir="${output.tests.results}"/> <mkdir dir="${output.tests.tmp}"/> - <junit printsummary="true" fork="yes" includeantruntime="true" tmpdir="${output.tests.tmp}"> + <junit + printsummary="true" fork="yes" includeantruntime="true" + tempdir="${output.tests.tmp}" maxmemory="1024m"> <jvmarg value="-Dloader.path=${output.lib.dir}/jboss-remoting-loading-tests.jar"/> <jvmarg value="-D${remoting.metadata.key}=${metadata}"/> <classpath> @@ -959,7 +961,9 @@ <target name="tests.functional.main.core" depends="tests.jars"> <mkdir dir="${output.tests.results}"/> <mkdir dir="${output.tests.tmp}"/> - <junit printsummary="true" fork="yes" includeantruntime="true" tempdir="${output.tests.tmp}"> + <junit + printsummary="true" fork="yes" includeantruntime="true" + tempdir="${output.tests.tmp}" maxmemory="1024m"> <jvmarg value="-Dloader.path=${output.lib.dir}/jboss-remoting-loading-tests.jar"/> <jvmarg value="-D${remoting.metadata.key}=${metadata}"/> <classpath> @@ -1069,7 +1073,9 @@ <mkdir dir="${output.tests.results}"/> <mkdir dir="${output.tests.tmp}"/> <echo>http with ${version}</echo> - <junit printsummary="true" fork="yes" includeantruntime="true" tempdir="${output.tests.tmp}"> + <junit + printsummary="true" fork="yes" includeantruntime="true" + tempdir="${output.tests.tmp}" maxmemory="1024m"> <jvmarg value="-Dloader.path=${output.lib.dir}/jboss-remoting-loading-tests.jar"/> <jvmarg value="-D${remoting.metadata.key}=${metadata}"/> <classpath> @@ -1107,7 +1113,9 @@ <mkdir dir="${output.tests.results}"/> <mkdir dir="${output.tests.tmp}"/> <echo>http with ${version}</echo> - <junit printsummary="true" fork="yes" includeantruntime="true" tempdir="${output.tests.tmp}"> + <junit + printsummary="true" fork="yes" includeantruntime="true" + tempdir="${output.tests.tmp}" maxmemory="1024m"> <jvmarg value="-Dloader.path=${output.lib.dir}/jboss-remoting-loading-tests.jar"/> <jvmarg value="-D${remoting.metadata.key}=${metadata}"/> <classpath>

16 years, 9 months

1
0
0 / 0

JBoss Remoting SVN: r3457 - in remoting3/trunk: api/src/main/java/org/jboss/cx/remoting/spi/wrapper and 1 other directories.

by jboss-remoting-commits＠lists.jboss.org

Author: david.lloyd(a)jboss.com Date: 2008-02-18 22:16:58 -0500 (Mon, 18 Feb 2008) New Revision: 3457 Modified: remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/RequestContext.java remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/spi/wrapper/RequestContextWrapper.java remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/CoreInboundRequest.java Log: setCancelHandler -> addCancelHandler Modified: remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/RequestContext.java =================================================================== --- remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/RequestContext.java 2008-02-19 02:42:17 UTC (rev 3456) +++ remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/RequestContext.java 2008-02-19 03:16:58 UTC (rev 3457) @@ -40,18 +40,10 @@ void sendCancelled() throws RemotingException, IllegalStateException; /** - * Set a notifier to be called if a cancel request is received. The notifier may be called from the current thread - * or a different thread. If the request has already been cancelled, the notifier will be called immediately. If there - * was a previous notifier set, it will be overwritten. Calling this method guarantees that the supplied handler - * will be called, unless it is cleared or a new handler is set before the original handler is called. The handler - * may be called at any time after the cancel request is recevied, though implementations should make a reasonable effort - * to ensure that the handler is called in a timely manner. The handler is cleared before it is called. - * <p/> - * Setting a {@code null} value clears any notifier. - * <p/> - * This method returns {@code this} in order to facilitate method call chaining. + * Add a notifier to be called if a cancel request is received. The notifier may be called from the current thread + * or a different thread. If the request has already been cancelled, the notifier will be called immediately. * * @param handler */ - void setCancelHandler(RequestCancelHandler<O> handler); + void addCancelHandler(RequestCancelHandler<O> handler); } Modified: remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/spi/wrapper/RequestContextWrapper.java =================================================================== --- remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/spi/wrapper/RequestContextWrapper.java 2008-02-19 02:42:17 UTC (rev 3456) +++ remoting3/trunk/api/src/main/java/org/jboss/cx/remoting/spi/wrapper/RequestContextWrapper.java 2008-02-19 03:16:58 UTC (rev 3457) @@ -30,8 +30,8 @@ delegate.sendCancelled(); } - public void setCancelHandler(final RequestCancelHandler<O> requestCancelHandler) { - delegate.setCancelHandler(requestCancelHandler); + public void addCancelHandler(final RequestCancelHandler<O> requestCancelHandler) { + delegate.addCancelHandler(requestCancelHandler); } } Modified: remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/CoreInboundRequest.java =================================================================== --- remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/CoreInboundRequest.java 2008-02-19 02:42:17 UTC (rev 3456) +++ remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/CoreInboundRequest.java 2008-02-19 03:16:58 UTC (rev 3457) @@ -87,7 +87,7 @@ context.sendCancelAcknowledge(requestIdentifier); } - public void setCancelHandler(final RequestCancelHandler<O> requestCancelHandler) { + public void addCancelHandler(final RequestCancelHandler<O> requestCancelHandler) { // todo - should be a list } }

16 years, 9 months

1
0
0 / 0

2024

2023

2022

2021

2020

2019

2018

2017

2016

2015

2014

2013

2012

2011

2010

2009

2008

jboss-remoting-commits February 2008