You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mina.apache.org by jv...@apache.org on 2012/11/06 16:28:26 UTC
svn commit: r1406175 - in /mina/mina/trunk:
http/src/main/java/org/apache/mina/http/HttpServerCodec.java
ldap/src/main/java/org/apache/mina/ldap/LdapCodec.java
Author: jvermillard
Date: Tue Nov 6 15:28:26 2012
New Revision: 1406175
URL: http://svn.apache.org/viewvc?rev=1406175&view=rev
Log:
removed sessionCreated
Modified:
mina/mina/trunk/http/src/main/java/org/apache/mina/http/HttpServerCodec.java
mina/mina/trunk/ldap/src/main/java/org/apache/mina/ldap/LdapCodec.java
Modified: mina/mina/trunk/http/src/main/java/org/apache/mina/http/HttpServerCodec.java
URL: http://svn.apache.org/viewvc/mina/mina/trunk/http/src/main/java/org/apache/mina/http/HttpServerCodec.java?rev=1406175&r1=1406174&r2=1406175&view=diff
==============================================================================
--- mina/mina/trunk/http/src/main/java/org/apache/mina/http/HttpServerCodec.java (original)
+++ mina/mina/trunk/http/src/main/java/org/apache/mina/http/HttpServerCodec.java Tue Nov 6 15:28:26 2012
@@ -49,13 +49,13 @@ public class HttpServerCodec extends Pro
}
@Override
- public void sessionCreated(IoSession session) {
- super.sessionCreated(session);
+ public void sessionOpened(final IoSession session) {
+ super.sessionOpened(session);
session.setAttribute(DECODER_STATE_ATT, DecoderState.NEW);
}
@Override
- public void sessionClosed(IoSession session) {
+ public void sessionClosed(final IoSession session) {
super.sessionClosed(session);
session.removeAttribute(DECODER_STATE_ATT);
session.removeAttribute(PARTIAL_HEAD_ATT);
Modified: mina/mina/trunk/ldap/src/main/java/org/apache/mina/ldap/LdapCodec.java
URL: http://svn.apache.org/viewvc/mina/mina/trunk/ldap/src/main/java/org/apache/mina/ldap/LdapCodec.java?rev=1406175&r1=1406174&r2=1406175&view=diff
==============================================================================
--- mina/mina/trunk/ldap/src/main/java/org/apache/mina/ldap/LdapCodec.java (original)
+++ mina/mina/trunk/ldap/src/main/java/org/apache/mina/ldap/LdapCodec.java Tue Nov 6 15:28:26 2012
@@ -75,50 +75,47 @@ public class LdapCodec extends ProtocolC
}
@Override
- public void sessionCreated(IoSession session) {
- LdapMessageContainer<MessageDecorator<? extends Message>> container = new LdapMessageContainer<MessageDecorator<? extends Message>>(
+ public void sessionOpened(final IoSession session) {
+ final LdapMessageContainer<MessageDecorator<? extends Message>> container = new LdapMessageContainer<MessageDecorator<? extends Message>>(
codec);
session.setAttribute(MESSAGE_CONTAINER_AT, container);
}
@Override
- public void sessionOpened(IoSession session) {
- }
-
- @Override
- public void sessionClosed(IoSession session) {
+ public void sessionClosed(final IoSession session) {
session.removeAttribute(MESSAGE_CONTAINER_AT);
}
@Override
- public void sessionIdle(IoSession session, IdleStatus status) {
+ public void sessionIdle(final IoSession session, final IdleStatus status) {
// TODO Auto-generated method stub
}
@Override
- public void messageWriting(IoSession session, Object message, WriteFilterChainController controller) {
+ public void messageWriting(final IoSession session, final Object message,
+ final WriteFilterChainController controller) {
if (message instanceof AddResponse) {
- ldapEncoder.encode(session, (AddResponse) message, controller);
+ ldapEncoder.encode(session, message, controller);
} else if (message instanceof BindResponse) {
- ldapEncoder.encode(session, (BindResponse) message, controller);
+ ldapEncoder.encode(session, message, controller);
} else if (message instanceof DeleteResponse) {
- ldapEncoder.encode(session, (DeleteResponse) message, controller);
+ ldapEncoder.encode(session, message, controller);
} else if (message instanceof CompareResponse) {
- ldapEncoder.encode(session, (CompareResponse) message, controller);
+ ldapEncoder.encode(session, message, controller);
} else if (message instanceof ExtendedResponse) {
- ldapEncoder.encode(session, (ExtendedResponse) message, controller);
+ ldapEncoder.encode(session, message, controller);
} else if (message instanceof IntermediateResponse) {
- ldapEncoder.encode(session, (IntermediateResponse) message, controller);
+ ldapEncoder.encode(session, message, controller);
} else if (message instanceof ModifyResponse) {
- ldapEncoder.encode(session, (ModifyResponse) message, controller);
+ ldapEncoder.encode(session, message, controller);
} else if (message instanceof ModifyDnResponse) {
- ldapEncoder.encode(session, (ModifyDnResponse) message, controller);
+ ldapEncoder.encode(session, message, controller);
} else if (message instanceof SearchResultDone) {
- ldapEncoder.encode(session, (SearchResultDone) message, controller);
+ ldapEncoder.encode(session, message, controller);
} else if (message instanceof SearchResultEntry) {
- ldapEncoder.encode(session, (SearchResultEntry) message, controller);
+ ldapEncoder.encode(session, message, controller);
} else if (message instanceof SearchResultReference) {
- ldapEncoder.encode(session, (SearchResultReference) message, controller);
+ ldapEncoder.encode(session, message, controller);
} else if (message instanceof ByteBuffer) {
controller.callWriteNextFilter(message);
}