You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mina.apache.org by tr...@apache.org on 2007/09/17 01:55:40 UTC
svn commit: r576217 [2/7] - in /mina/trunk:
core/src/main/java/org/apache/mina/common/
core/src/main/java/org/apache/mina/filter/codec/
core/src/main/java/org/apache/mina/filter/codec/demux/
core/src/main/java/org/apache/mina/filter/codec/serialization...
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/DefaultTransportMetadata.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/DefaultTransportMetadata.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/DefaultTransportMetadata.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/DefaultTransportMetadata.java Sun Sep 16 16:55:27 2007
@@ -6,16 +6,16 @@
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
- * under the License.
- *
+ * under the License.
+ *
*/
package org.apache.mina.common;
@@ -28,7 +28,7 @@
/**
* A default immutable implementation of {@link TransportMetadata}.
- *
+ *
* @author The Apache MINA Project (dev@mina.apache.org)
* @version $Rev$, $Date$
*/
@@ -66,11 +66,11 @@
if (envelopeTypes == null) {
throw new NullPointerException("envelopeTypes");
}
-
+
if (envelopeTypes.length == 0) {
throw new NullPointerException("envelopeTypes is empty.");
}
-
+
if (sessionConfigType == null) {
throw new NullPointerException("sessionConfigType");
}
@@ -80,8 +80,8 @@
this.fragmentation = fragmentation;
this.addressType = addressType;
this.sessionConfigType = sessionConfigType;
-
- Set<Class<? extends Object>> newEnvelopeTypes =
+
+ Set<Class<? extends Object>> newEnvelopeTypes =
new IdentityHashSet<Class<? extends Object>>();
for (Class<? extends Object> c: envelopeTypes) {
newEnvelopeTypes.add(c);
@@ -108,7 +108,7 @@
public boolean isConnectionless() {
return connectionless;
}
-
+
public boolean hasFragmentation() {
return fragmentation;
}
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/DefaultWriteFuture.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/DefaultWriteFuture.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/DefaultWriteFuture.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/DefaultWriteFuture.java Sun Sep 16 16:55:27 2007
@@ -6,23 +6,23 @@
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
- * under the License.
- *
+ * under the License.
+ *
*/
package org.apache.mina.common;
/**
* A default implementation of {@link WriteFuture}.
- *
+ *
* @author The Apache MINA Project (dev@mina.apache.org)
* @version $Rev$, $Date$
*/
@@ -51,7 +51,7 @@
public DefaultWriteFuture(IoSession session) {
super(session);
}
-
+
public boolean isWritten() {
if (isReady()) {
return ((Boolean) getValue()).booleanValue();
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/DefaultWriteRequest.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/DefaultWriteRequest.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/DefaultWriteRequest.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/DefaultWriteRequest.java Sun Sep 16 16:55:27 2007
@@ -6,16 +6,16 @@
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
- * under the License.
- *
+ * under the License.
+ *
*/
package org.apache.mina.common;
@@ -112,7 +112,7 @@
/**
* Creates a new instance.
- *
+ *
* @param message a message to write
* @param future a future that needs to be notified when an operation is finished
* @param destination the destination of the message. This property will be
@@ -149,7 +149,7 @@
/**
* Returne the destination of this write request.
- *
+ *
* @return <tt>null</tt> for the default destination
*/
public SocketAddress getDestination() {
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/DummySession.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/DummySession.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/DummySession.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/DummySession.java Sun Sep 16 16:55:27 2007
@@ -46,7 +46,7 @@
};
private volatile IoService service;
-
+
private volatile IoProcessor processor;
private volatile IoSessionConfig config = new AbstractIoSessionConfig() {
@@ -98,7 +98,7 @@
acceptor.setLocalAddress(ANONYMOUS_ADDRESS);
this.service = acceptor;
-
+
this.processor = new IoProcessor() {
public void add(IoSession session) {
}
@@ -191,10 +191,12 @@
this.remoteAddress = remoteAddress;
}
+ @Override
public long getScheduledWriteBytes() {
return 0;
}
+ @Override
public int getScheduledWriteMessages() {
return 0;
}
@@ -213,16 +215,17 @@
this.service = service;
}
-
+
+ @Override
public IoProcessor getProcessor() {
return processor;
}
-
+
public void setProcessor(IoProcessor processor) {
if (processor == null) {
throw new NullPointerException("processor");
}
-
+
this.processor = processor;
}
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/ExceptionMonitor.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/ExceptionMonitor.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/ExceptionMonitor.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/ExceptionMonitor.java Sun Sep 16 16:55:27 2007
@@ -6,16 +6,16 @@
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
- * under the License.
- *
+ * under the License.
+ *
*/
package org.apache.mina.common;
@@ -28,10 +28,10 @@
* by calling {@link #setInstance(ExceptionMonitor)}. The default
* monitor logs all caught exceptions in <tt>WARN</tt> level using
* SLF4J.
- *
+ *
* @author The Apache MINA Project (dev@mina.apache.org)
* @version $Rev$, $Date$
- *
+ *
* @see DefaultExceptionMonitor
*/
public abstract class ExceptionMonitor {
@@ -47,7 +47,7 @@
/**
* Sets the uncaught exception monitor. If <code>null</code> is specified,
* the default monitor will be set.
- *
+ *
* @param monitor A new instance of {@link DefaultExceptionMonitor} is set
* if <tt>null</tt> is specified.
*/
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/ExpiringIoSessionRecycler.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/ExpiringIoSessionRecycler.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/ExpiringIoSessionRecycler.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/ExpiringIoSessionRecycler.java Sun Sep 16 16:55:27 2007
@@ -6,16 +6,16 @@
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
- * under the License.
- *
+ * under the License.
+ *
*/
package org.apache.mina.common;
@@ -28,15 +28,15 @@
/**
* An {@link IoSessionRecycler} with sessions that time out on inactivity.
- *
+ *
* TODO Document me.
- *
+ *
* @author The Apache MINA Project (dev@mina.apache.org)
* @version $Rev$, $Date$
*/
public class ExpiringIoSessionRecycler implements IoSessionRecycler {
private ExpiringMap<Object, IoSession> sessionMap;
-
+
private ExpiringMap<Object, IoSession>.Expirer mapExpirer;
public ExpiringIoSessionRecycler() {
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/FileRegion.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/FileRegion.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/FileRegion.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/FileRegion.java Sun Sep 16 16:55:27 2007
@@ -4,45 +4,45 @@
/**
* Indicates the region of a file to be sent to the remote host.
- *
+ *
* @author The Apache MINA Project (dev@mina.apache.org)
* @version $Rev: 560320 $, $Date: 2007-07-27 11:12:26 -0600 (Fri, 27 Jul 2007) $,
*/
public interface FileRegion {
/**
- * The open <tt>FileChannel<tt> from which data will be read to send to remote host.
- *
+ * The open <tt>FileChannel<tt> from which data will be read to send to remote host.
+ *
* @return An open <tt>FileChannel<tt>.
*/
FileChannel getFileChannel();
-
+
/**
- * The current file position from which data will be read.
- *
+ * The current file position from which data will be read.
+ *
* @return The current file position.
*/
long getPosition();
-
+
/**
* Updates the current file position. May not be negative.
- *
+ *
* @param value The new value for the file position.
*/
void setPosition(long value);
-
+
/**
* The number of bytes to be written from the file to the remote host.
- *
+ *
* @return The number of bytes to be written.
*/
long getCount();
-
+
/**
* The total number of bytes already written.
- *
+ *
* @return The total number of bytes already written.
*/
long getWrittenBytes();
-
+
}
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/IdleStatus.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/IdleStatus.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/IdleStatus.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/IdleStatus.java Sun Sep 16 16:55:27 2007
@@ -6,16 +6,16 @@
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
- * under the License.
- *
+ * under the License.
+ *
*/
package org.apache.mina.common;
@@ -30,7 +30,7 @@
* <p>
* Idle time settings are all disabled by default. You can enable them
* using {@link IoSession#setIdleTime(IdleStatus,int)}.
- *
+ *
* @author The Apache MINA Project (dev@mina.apache.org)
* @version $Rev$, $Date$
*/
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/IdleStatusChecker.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/IdleStatusChecker.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/IdleStatusChecker.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/IdleStatusChecker.java Sun Sep 16 16:55:27 2007
@@ -6,16 +6,16 @@
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
- * under the License.
- *
+ * under the License.
+ *
*/
package org.apache.mina.common;
@@ -25,8 +25,8 @@
import org.apache.mina.util.IdentityHashSet;
/**
- * Dectects idle sessions and fires <tt>sessionIdle</tt> events to them.
- *
+ * Dectects idle sessions and fires <tt>sessionIdle</tt> events to them.
+ *
* @author The Apache MINA Project (dev@mina.apache.org)
* @version $Rev: 525369 $, $Date: 2007-04-04 05:05:11 +0200 (mer., 04 avr. 2007) $
*/
@@ -100,7 +100,7 @@
private void notifyIdleSession0(AbstractIoSession session, long currentTime,
long idleTime, IdleStatus status, long lastIoTime) {
if (idleTime > 0 && lastIoTime != 0
- && (currentTime - lastIoTime) >= idleTime) {
+ && currentTime - lastIoTime >= idleTime) {
session.increaseIdleCount(status);
session.getFilterChain().fireSessionIdle(session, status);
}
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/IoAcceptor.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/IoAcceptor.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/IoAcceptor.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/IoAcceptor.java Sun Sep 16 16:55:27 2007
@@ -6,16 +6,16 @@
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
- * under the License.
- *
+ * under the License.
+ *
*/
package org.apache.mina.common;
@@ -28,7 +28,7 @@
* <p>
* Please refer to
* <a href="../../../../../xref-examples/org/apache/mina/examples/echoserver/Main.html">EchoServer</a>
- * example.
+ * example.
* <p>
* You should bind to the desired socket address to accept incoming
* connections, and then events for incoming connections will be sent to
@@ -36,7 +36,7 @@
* <p>
* Threads accept incoming connections start automatically when
* {@link #bind()} is invoked, and stop when {@link #unbind()} is invoked.
- *
+ *
* @author The Apache MINA Project (dev@mina.apache.org)
* @version $Rev$, $Date$
*/
@@ -48,7 +48,7 @@
/**
* Sets the local address to bind.
- *
+ *
* @throws IllegalStateException if this service is already running.
*/
void setLocalAddress(SocketAddress localAddress);
@@ -67,7 +67,7 @@
/**
* Bind to the configured local address and start to accept incoming connections.
- *
+ *
* @throws IOException if failed to bind
*/
void bind() throws IOException;
@@ -92,7 +92,7 @@
* This operation is optional. Please throw {@link UnsupportedOperationException}
* if the transport type doesn't support this operation. This operation is
* usually implemented for connectionless transport types.
- *
+ *
* @throws UnsupportedOperationException if this operation is not supported
* @throws IllegalStateException if this service is not running.
*/
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/IoAcceptorWrapper.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/IoAcceptorWrapper.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/IoAcceptorWrapper.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/IoAcceptorWrapper.java Sun Sep 16 16:55:27 2007
@@ -6,16 +6,16 @@
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
- * under the License.
- *
+ * under the License.
+ *
*/
package org.apache.mina.common;
@@ -26,7 +26,7 @@
/**
* An {@link IoAcceptor} that wraps the other {@link IoAcceptor}.
- *
+ *
* @author The Apache MINA Project (dev@mina.apache.org)
* @version $Rev$, $Date$
*/
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/IoConnector.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/IoConnector.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/IoConnector.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/IoConnector.java Sun Sep 16 16:55:27 2007
@@ -6,16 +6,16 @@
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
- * under the License.
- *
+ * under the License.
+ *
*/
package org.apache.mina.common;
@@ -27,7 +27,7 @@
* <p>
* Please refer to
* <a href="../../../../../xref-examples/org/apache/mina/examples/netcat/Main.html">NetCat</a>
- * example.
+ * example.
* <p>
* You should connect to the desired socket address to start communication,
* and then events for incoming connections will be sent to the specified
@@ -36,7 +36,7 @@
* Threads connect to endpoint start automatically when
* {@link #connect(SocketAddress)} is invoked, and stop when all
* connection attempts are finished.
- *
+ *
* @author The Apache MINA Project (dev@mina.apache.org)
* @version $Rev$, $Date$
*/
@@ -58,16 +58,16 @@
/**
* Connects to the specified remote address.
- *
- * @return the {@link ConnectFuture} instance which is completed when the
+ *
+ * @return the {@link ConnectFuture} instance which is completed when the
* connection attempt initiated by this call succeeds or fails.
*/
ConnectFuture connect(SocketAddress remoteAddress);
/**
* Connects to the specified remote address binding to the specified local address.
- *
- * @return the {@link ConnectFuture} instance which is completed when the
+ *
+ * @return the {@link ConnectFuture} instance which is completed when the
* connection attempt initiated by this call succeeds or fails.
*/
ConnectFuture connect(SocketAddress remoteAddress,
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/IoConnectorWrapper.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/IoConnectorWrapper.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/IoConnectorWrapper.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/IoConnectorWrapper.java Sun Sep 16 16:55:27 2007
@@ -6,16 +6,16 @@
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
- * under the License.
- *
+ * under the License.
+ *
*/
package org.apache.mina.common;
@@ -25,7 +25,7 @@
/**
* An {@link IoConnector} that wraps the other {@link IoConnector}.
- *
+ *
* @author The Apache MINA Project (dev@mina.apache.org)
* @version $Rev$, $Date$
*/
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/IoEvent.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/IoEvent.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/IoEvent.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/IoEvent.java Sun Sep 16 16:55:27 2007
@@ -6,16 +6,16 @@
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
- * under the License.
- *
+ * under the License.
+ *
*/
package org.apache.mina.common;
@@ -23,7 +23,7 @@
* An I/O event or an I/O request that MINA provides.
* Most users won't need to use this class. It is usually used by internal
* components to store I/O events.
- *
+ *
* @author The Apache MINA Project (dev@mina.apache.org)
* @version $Rev$, $Date$
*/
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/IoEventType.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/IoEventType.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/IoEventType.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/IoEventType.java Sun Sep 16 16:55:27 2007
@@ -6,16 +6,16 @@
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
- * under the License.
- *
+ * under the License.
+ *
*/
package org.apache.mina.common;
@@ -23,7 +23,7 @@
* An {@link Enum} that represents the type of I/O events and requests.
* Most users won't need to use this class. It is usually used by internal
* components to store I/O events.
- *
+ *
* @author The Apache MINA Project (dev@mina.apache.org)
* @version $Rev$, $Date$
*/
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/IoFilter.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/IoFilter.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/IoFilter.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/IoFilter.java Sun Sep 16 16:55:27 2007
@@ -6,16 +6,16 @@
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
- * under the License.
- *
+ * under the License.
+ *
*/
package org.apache.mina.common;
@@ -36,7 +36,7 @@
* <strong>Please NEVER implement your filters to wrap
* {@link IoSession}s.</strong> Users can cache the reference to the
* session, which might malfunction if any filters are added or removed later.
- *
+ *
* <h3>The Life Cycle</h3>
* {@link IoFilter}s are activated only when they are inside {@link IoFilterChain}.
* <p>
@@ -66,11 +66,11 @@
* notify that the filter is removed from the chain.</li>
* <li>{@link #destroy()} is invoked by {@link ReferenceCountingIoFilter} if
* the removed filter was the last one.</li>
- * </ol>
- *
+ * </ol>
+ *
* @author The Apache MINA Project (dev@mina.apache.org)
* @version $Rev$, $Date$
- *
+ *
* @see IoFilterAdapter
*/
public interface IoFilter {
@@ -94,7 +94,7 @@
* Invoked before this filter is added to the specified <tt>parent</tt>.
* Please note that this method can be invoked more than once if
* this filter is added to more than one parents. This method is not
- * invoked before {@link #init()} is invoked.
+ * invoked before {@link #init()} is invoked.
*
* @param parent the parent who called this method
* @param name the name assigned to this filter
@@ -108,7 +108,7 @@
* Invoked after this filter is added to the specified <tt>parent</tt>.
* Please note that this method can be invoked more than once if
* this filter is added to more than one parents. This method is not
- * invoked before {@link #init()} is invoked.
+ * invoked before {@link #init()} is invoked.
*
* @param parent the parent who called this method
* @param name the name assigned to this filter
@@ -123,7 +123,7 @@
* Please note that this method can be invoked more than once if
* this filter is removed from more than one parents.
* This method is always invoked before {@link #destroy()} is invoked.
- *
+ *
* @param parent the parent who called this method
* @param name the name assigned to this filter
* @param nextFilter the {@link NextFilter} for this filter. You can reuse
@@ -137,7 +137,7 @@
* Please note that this method can be invoked more than once if
* this filter is removed from more than one parents.
* This method is always invoked before {@link #destroy()} is invoked.
- *
+ *
* @param parent the parent who called this method
* @param name the name assigned to this filter
* @param nextFilter the {@link NextFilter} for this filter. You can reuse
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/IoFilterAdapter.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/IoFilterAdapter.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/IoFilterAdapter.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/IoFilterAdapter.java Sun Sep 16 16:55:27 2007
@@ -6,16 +6,16 @@
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
- * under the License.
- *
+ * under the License.
+ *
*/
package org.apache.mina.common;
@@ -23,7 +23,7 @@
* An abstract adapter class for {@link IoFilter}. You can extend
* this class and selectively override required event filter methods only. All
* methods forwards events to the next filter by default.
- *
+ *
* @author The Apache MINA Project (dev@mina.apache.org)
* @version $Rev$, $Date$
*/
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/IoFilterChain.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/IoFilterChain.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/IoFilterChain.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/IoFilterChain.java Sun Sep 16 16:55:27 2007
@@ -6,16 +6,16 @@
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
- * under the License.
- *
+ * under the License.
+ *
*/
package org.apache.mina.common;
@@ -26,8 +26,8 @@
/**
* A container of {@link IoFilter}s that forwards {@link IoHandler} events
* to the consisting filters and terminal {@link IoHandler} sequentially.
- * Every {@link IoSession} has its own {@link IoFilterChain} (1-to-1 relationship).
- *
+ * Every {@link IoSession} has its own {@link IoFilterChain} (1-to-1 relationship).
+ *
* @author The Apache MINA Project (dev@mina.apache.org)
* @version $Rev$, $Date$
*/
@@ -80,7 +80,7 @@
/**
* Returns <tt>true</tt> if this chain contains an {@link IoFilter} of the
- * specified <tt>filterType</tt>.
+ * specified <tt>filterType</tt>.
*/
boolean contains(Class<? extends IoFilter> filterType);
@@ -121,7 +121,7 @@
/**
* Replace the filter with the specified name with the specified new
* filter.
- *
+ *
* @return the old filter
* @throws IllegalArgumentException if there's no such filter
*/
@@ -130,7 +130,7 @@
/**
* Replace the filter with the specified name with the specified new
* filter.
- *
+ *
* @throws IllegalArgumentException if there's no such filter
*/
void replace(IoFilter oldFilter, IoFilter newFilter);
@@ -139,7 +139,7 @@
* Replace the filter of the specified type with the specified new
* filter. If there's more than one filter with the specified type,
* the first match will be replaced.
- *
+ *
* @throws IllegalArgumentException if there's no such filter
*/
IoFilter replace(Class<? extends IoFilter> oldFilterType, IoFilter newFilter);
@@ -155,7 +155,7 @@
/**
* Replace the filter with the specified name with the specified new
* filter.
- *
+ *
* @throws IllegalArgumentException if there's no such filter
*/
void remove(IoFilter filter);
@@ -164,7 +164,7 @@
* Replace the filter of the specified type with the specified new
* filter. If there's more than one filter with the specified type,
* the first match will be replaced.
- *
+ *
* @throws IllegalArgumentException if there's no such filter
*/
IoFilter remove(Class<? extends IoFilter> filterType);
@@ -257,7 +257,7 @@
/**
* Returns the {@link NextFilter} of the filter.
- *
+ *
* @throws IllegalStateException if the {@link NextFilter} is not available
*/
NextFilter getNextFilter();
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/IoFilterChainBuilder.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/IoFilterChainBuilder.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/IoFilterChainBuilder.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/IoFilterChainBuilder.java Sun Sep 16 16:55:27 2007
@@ -6,16 +6,16 @@
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
- * under the License.
- *
+ * under the License.
+ *
*/
package org.apache.mina.common;
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/IoFilterEvent.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/IoFilterEvent.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/IoFilterEvent.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/IoFilterEvent.java Sun Sep 16 16:55:27 2007
@@ -6,16 +6,16 @@
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
- * under the License.
- *
+ * under the License.
+ *
*/
package org.apache.mina.common;
@@ -25,7 +25,7 @@
* An I/O event or an I/O request that MINA provides for {@link IoFilter}s.
* Most users won't need to use this class. It is usually used by internal
* components to store I/O events.
- *
+ *
* @author The Apache MINA Project (dev@mina.apache.org)
* @version $Rev$, $Date$
*/
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/IoFilterLifeCycleException.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/IoFilterLifeCycleException.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/IoFilterLifeCycleException.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/IoFilterLifeCycleException.java Sun Sep 16 16:55:27 2007
@@ -6,16 +6,16 @@
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
- * under the License.
- *
+ * under the License.
+ *
*/
package org.apache.mina.common;
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/IoFuture.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/IoFuture.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/IoFuture.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/IoFuture.java Sun Sep 16 16:55:27 2007
@@ -6,16 +6,16 @@
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
- * under the License.
- *
+ * under the License.
+ *
*/
package org.apache.mina.common;
@@ -23,7 +23,7 @@
/**
* Represents the result of an ashynchronous I/O operation.
- *
+ *
* @author The Apache MINA Project (dev@mina.apache.org)
* @version $Rev$, $Date$
*/
@@ -40,14 +40,14 @@
/**
* Wait for the asynchronous operation to end with the specified timeout.
- *
+ *
* @return <tt>true</tt> if the operation is finished.
*/
boolean await(long timeout, TimeUnit unit) throws InterruptedException;
/**
* Wait for the asynchronous operation to end with the specified timeout.
- *
+ *
* @return <tt>true</tt> if the operation is finished.
*/
boolean await(long timeoutMillis) throws InterruptedException;
@@ -60,7 +60,7 @@
/**
* Wait for the asynchronous operation to end with the specified timeout
* uninterruptibly.
- *
+ *
* @return <tt>true</tt> if the operation is finished.
*/
boolean awaitUninterruptibly(long timeout, TimeUnit unit);
@@ -68,7 +68,7 @@
/**
* Wait for the asynchronous operation to end with the specified timeout
* uninterruptibly.
- *
+ *
* @return <tt>true</tt> if the operation is finished.
*/
boolean awaitUninterruptibly(long timeoutMillis);
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/IoFutureListener.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/IoFutureListener.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/IoFutureListener.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/IoFutureListener.java Sun Sep 16 16:55:27 2007
@@ -6,16 +6,16 @@
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
- * under the License.
- *
+ * under the License.
+ *
*/
package org.apache.mina.common;
@@ -24,7 +24,7 @@
/**
* Something interested in being notified when the result
* of an {@link IoFuture} becomes available.
- *
+ *
* @author The Apache MINA Project (dev@mina.apache.org)
* @version $Rev$, $Date$
*/
@@ -42,7 +42,7 @@
/**
* Invoked when the operation associated with the {@link IoFuture}
* has been completed.
- *
+ *
* @param future The source {@link IoFuture} which called this
* callback.
*/
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/IoHandler.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/IoHandler.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/IoHandler.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/IoHandler.java Sun Sep 16 16:55:27 2007
@@ -6,16 +6,16 @@
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
- * under the License.
- *
+ * under the License.
+ *
*/
package org.apache.mina.common;
@@ -23,10 +23,10 @@
/**
* Handles all I/O events fired by MINA.
- *
+ *
* @author The Apache MINA Project (dev@mina.apache.org)
* @version $Rev$, $Date$
- *
+ *
* @see IoHandlerAdapter
*/
public interface IoHandler {
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/IoHandlerAdapter.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/IoHandlerAdapter.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/IoHandlerAdapter.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/IoHandlerAdapter.java Sun Sep 16 16:55:27 2007
@@ -6,16 +6,16 @@
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
- * under the License.
- *
+ * under the License.
+ *
*/
package org.apache.mina.common;
@@ -23,8 +23,8 @@
/**
* An abstract adapter class for {@link IoHandler}. You can extend this
* class and selectively override required event handler methods only. All
- * methods do nothing by default.
- *
+ * methods do nothing by default.
+ *
* @author The Apache MINA Project (dev@mina.apache.org)
* @version $Rev$, $Date$
*/
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/IoProcessor.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/IoProcessor.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/IoProcessor.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/IoProcessor.java Sun Sep 16 16:55:27 2007
@@ -6,16 +6,16 @@
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
- * under the License.
- *
+ * under the License.
+ *
*/
package org.apache.mina.common;
@@ -24,7 +24,7 @@
* actual I/O operations for {@link IoSession}s. It abstracts existing
* reactor frameworks such as Java NIO once again to simplify transport
* implementations.
- *
+ *
* @author Apache MINA Project (dev@mina.apache.org)
* @version $Rev$, $Date$
*/
@@ -39,7 +39,7 @@
/**
* Flushes the internal write request queue of the specified
* {@code session}.
- *
+ *
* @param writeRequest the write request added right now
*/
void flush(IoSession session, WriteRequest writeRequest);
@@ -49,7 +49,7 @@
* in {@link IoSession#getTrafficMask()}.
*/
void updateTrafficMask(IoSession session);
-
+
/**
* Removes and closes the specified {@code session} from the I/O
* processor so that the I/O processor closes the connection
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/IoService.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/IoService.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/IoService.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/IoService.java Sun Sep 16 16:55:27 2007
@@ -6,16 +6,16 @@
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
- * under the License.
- *
+ * under the License.
+ *
*/
package org.apache.mina.common;
@@ -24,7 +24,7 @@
/**
* Base interface for all {@link IoAcceptor}s and {@link IoConnector}s
* that provide I/O service and manage {@link IoSession}s.
- *
+ *
* @author The Apache MINA Project (dev@mina.apache.org)
* @version $Rev$, $Date$
*/
@@ -60,7 +60,7 @@
* Returns all sessions which are currently managed by this service.
* {@link IoAcceptor} will assume the specified <tt>address</tt> is a local
* address, and {@link IoConnector} will assume it's a remote address.
- *
+ *
* @return the sessions. An empty collection if there's no session.
* @throws UnsupportedOperationException if this operation isn't supported
* for the particular transport type implemented by this {@link IoService}.
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/IoServiceListener.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/IoServiceListener.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/IoServiceListener.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/IoServiceListener.java Sun Sep 16 16:55:27 2007
@@ -6,16 +6,16 @@
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
- * under the License.
- *
+ * under the License.
+ *
*/
package org.apache.mina.common;
@@ -24,35 +24,35 @@
/**
* Something interested in being notified when the result
* of an {@link IoFuture} becomes available.
- *
+ *
* @author The Apache MINA Project (dev@mina.apache.org)
* @version $Rev$, $Date$
*/
public interface IoServiceListener extends EventListener {
/**
* Invoked when a new service is activated by an {@link IoService}.
- *
+ *
* @param service the {@link IoService}
*/
void serviceActivated(IoService service);
/**
* Invoked when a service is deactivated by an {@link IoService}.
- *
+ *
* @param service the {@link IoService}
*/
void serviceDeactivated(IoService service);
/**
* Invoked when a new session is created by an {@link IoService}.
- *
+ *
* @param session the new session
*/
void sessionCreated(IoSession session);
/**
* Invoked when a session is being destroyed by an {@link IoService}.
- *
+ *
* @param session the session to be destroyed
*/
void sessionDestroyed(IoSession session);
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/IoServiceListenerSupport.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/IoServiceListenerSupport.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/IoServiceListenerSupport.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/IoServiceListenerSupport.java Sun Sep 16 16:55:27 2007
@@ -6,16 +6,16 @@
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
- * under the License.
- *
+ * under the License.
+ *
*/
package org.apache.mina.common;
@@ -29,7 +29,7 @@
/**
* A helper which provides addition and removal of {@link IoServiceListener}s and firing
* events.
- *
+ *
* @author The Apache MINA Project (dev@mina.apache.org)
* @version $Rev$, $Date$
*/
@@ -211,7 +211,7 @@
Object lock = new Object();
IoFutureListener listener = new LockNotifyingListener(lock);
-
+
for (IoSession s : managedSessions) {
s.close().addListener(listener);
}
@@ -226,14 +226,14 @@
// Ignored
}
}
-
+
private static class LockNotifyingListener implements IoFutureListener {
private final Object lock;
-
+
public LockNotifyingListener(Object lock) {
this.lock = lock;
}
-
+
public void operationComplete(IoFuture future) {
synchronized (lock) {
lock.notifyAll();
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/IoSessionConfig.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/IoSessionConfig.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/IoSessionConfig.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/IoSessionConfig.java Sun Sep 16 16:55:27 2007
@@ -6,27 +6,27 @@
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
- * under the License.
- *
+ * under the License.
+ *
*/
package org.apache.mina.common;
/**
* The configuration of {@link IoSession}.
- *
+ *
* @author The Apache MINA Project (dev@mina.apache.org)
* @version $Rev$, $Date$
*/
public interface IoSessionConfig {
-
+
/**
* Returns the size of the read buffer that I/O processor allocates
* per each read. It's unusual to adjust this property because
@@ -40,7 +40,7 @@
* it's often adjusted automatically by the I/O processor.
*/
void setReadBufferSize(int readBufferSize);
-
+
/**
* Returns the minimum size of the read buffer that I/O processor
* allocates per each read. I/O processor will not decrease the
@@ -54,7 +54,7 @@
* read buffer size to the smaller value than this property value.
*/
void setMinReadBufferSize(int minReadBufferSize);
-
+
/**
* Returns the maximum size of the read buffer that I/O processor
* allocates per each read. I/O processor will not increase the
@@ -68,7 +68,7 @@
* read buffer size to the greater value than this property value.
*/
void setMaxReadBufferSize(int maxReadBufferSize);
-
+
/**
* Returns idle time for the specified type of idleness in seconds.
*/
@@ -98,7 +98,7 @@
* Sets write timeout in seconds.
*/
void setWriteTimeout(int writeTimeout);
-
+
/**
* Sets all configuration properties retrieved from the specified
* <tt>config</tt>.
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/IoSessionLogger.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/IoSessionLogger.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/IoSessionLogger.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/IoSessionLogger.java Sun Sep 16 16:55:27 2007
@@ -6,16 +6,16 @@
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
- * under the License.
- *
+ * under the License.
+ *
*/
package org.apache.mina.common;
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/IoSessionRecycler.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/IoSessionRecycler.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/IoSessionRecycler.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/IoSessionRecycler.java Sun Sep 16 16:55:27 2007
@@ -6,16 +6,16 @@
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
- * under the License.
- *
+ * under the License.
+ *
*/
package org.apache.mina.common;
@@ -24,7 +24,7 @@
/**
* A connectionless transport can recycle existing sessions by assigning an
* {@link IoSessionRecycler} to an {@link IoService}.
- *
+ *
* @author The Apache MINA Project (dev@mina.apache.org)
* TODO More documentation
*/
@@ -49,7 +49,7 @@
/**
* Called when the underlying transport creates or writes a new {@link IoSession}.
- *
+ *
* @param session
* the new {@link IoSession}.
*/
@@ -57,7 +57,7 @@
/**
* Attempts to retrieve a recycled {@link IoSession}.
- *
+ *
* @param localAddress
* the local socket address of the {@link IoSession} the
* transport wants to recycle.
@@ -70,7 +70,7 @@
/**
* Called when an {@link IoSession} is explicitly closed.
- *
+ *
* @param session
* the new {@link IoSession}.
*/
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/RuntimeIOException.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/RuntimeIOException.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/RuntimeIOException.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/RuntimeIOException.java Sun Sep 16 16:55:27 2007
@@ -6,16 +6,16 @@
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
- * under the License.
- *
+ * under the License.
+ *
*/
package org.apache.mina.common;
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/SimpleByteBufferAllocator.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/SimpleByteBufferAllocator.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/SimpleByteBufferAllocator.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/SimpleByteBufferAllocator.java Sun Sep 16 16:55:27 2007
@@ -6,16 +6,16 @@
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
- * under the License.
- *
+ * under the License.
+ *
*/
package org.apache.mina.common;
@@ -25,7 +25,7 @@
/**
* A simplistic {@link ByteBufferAllocator} which simply allocates a new
* buffer every time.
- *
+ *
* @author The Apache MINA Project (dev@mina.apache.org)
* @version $Rev$, $Date$
*/
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/TrafficMask.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/TrafficMask.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/TrafficMask.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/TrafficMask.java Sun Sep 16 16:55:27 2007
@@ -6,16 +6,16 @@
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
- * under the License.
- *
+ * under the License.
+ *
*/
package org.apache.mina.common;
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/TransportMetadata.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/TransportMetadata.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/TransportMetadata.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/TransportMetadata.java Sun Sep 16 16:55:27 2007
@@ -6,16 +6,16 @@
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
- * under the License.
- *
+ * under the License.
+ *
*/
package org.apache.mina.common;
@@ -24,7 +24,7 @@
/**
* Provides meta-information that describes an {@link IoService}.
- *
+ *
* @author The Apache MINA Project (dev@mina.apache.org)
* @version $Rev$, $Date$
*/
@@ -40,11 +40,11 @@
* <a href="http://en.wikipedia.org/wiki/Connectionless">connectionless</a>.
*/
boolean isConnectionless();
-
+
/**
* Returns {@code true} if the messages exchanged by the service can be
* <a href="http://en.wikipedia.org/wiki/IPv4#Fragmentation_and_reassembly">fragmented
- * or reassembled</a> by its underlying transport.
+ * or reassembled</a> by its underlying transport.
*/
boolean hasFragmentation();
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/WriteFuture.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/WriteFuture.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/WriteFuture.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/WriteFuture.java Sun Sep 16 16:55:27 2007
@@ -6,16 +6,16 @@
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
- * under the License.
- *
+ * under the License.
+ *
*/
package org.apache.mina.common;
@@ -38,7 +38,7 @@
* // (e.g. Connection is closed)
* }
* </pre>
- *
+ *
* @author The Apache MINA Project (dev@mina.apache.org)
* @version $Rev$, $Date$
*/
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/WriteRequest.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/WriteRequest.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/WriteRequest.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/WriteRequest.java Sun Sep 16 16:55:27 2007
@@ -6,16 +6,16 @@
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
- * under the License.
- *
+ * under the License.
+ *
*/
package org.apache.mina.common;
@@ -40,7 +40,7 @@
/**
* Returns the destination of this write request.
- *
+ *
* @return <tt>null</tt> for the default destination
*/
SocketAddress getDestination();
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/WriteRequestWrapper.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/WriteRequestWrapper.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/WriteRequestWrapper.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/WriteRequestWrapper.java Sun Sep 16 16:55:27 2007
@@ -6,16 +6,16 @@
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
- * under the License.
- *
+ * under the License.
+ *
*/
package org.apache.mina.common;
@@ -23,7 +23,7 @@
/**
* A wrapper for an existing {@link WriteRequest}.
- *
+ *
* @author The Apache MINA Project (dev@mina.apache.org)
* @version $Rev$, $Date$
*/
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/WriteTimeoutException.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/WriteTimeoutException.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/WriteTimeoutException.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/WriteTimeoutException.java Sun Sep 16 16:55:27 2007
@@ -6,16 +6,16 @@
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
- * under the License.
- *
+ * under the License.
+ *
*/
package org.apache.mina.common;
@@ -24,9 +24,9 @@
/**
* An {@link IOException} which is thrown when write buffer is not flushed for
* {@link IoSession#getWriteTimeout()} seconds.
- *
+ *
* @author The Apache MINA Project (dev@mina.apache.org)
- * @version $Rev$, $Date$,
+ * @version $Rev$, $Date$,
*/
public class WriteTimeoutException extends IOException {
private static final long serialVersionUID = 3906931157944579121L;
Modified: mina/trunk/core/src/main/java/org/apache/mina/filter/codec/CumulativeProtocolDecoder.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/filter/codec/CumulativeProtocolDecoder.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/filter/codec/CumulativeProtocolDecoder.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/filter/codec/CumulativeProtocolDecoder.java Sun Sep 16 16:55:27 2007
@@ -6,16 +6,16 @@
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
- * under the License.
- *
+ * under the License.
+ *
*/
package org.apache.mina.filter.codec;
@@ -30,30 +30,30 @@
* decoders should cumulate received buffers to make a message complete or
* to postpone decoding until more buffers arrive.
* <p>
- * Here is an example decoder that decodes CRLF terminated lines into
+ * Here is an example decoder that decodes CRLF terminated lines into
* <code>Command</code> objects:
* <pre>
- * public class CRLFTerminatedCommandLineDecoder
+ * public class CRLFTerminatedCommandLineDecoder
* extends CumulativeProtocolDecoder {
- *
+ *
* private Command parseCommand(ByteBuffer in) {
- * // Convert the bytes in the specified buffer to a
+ * // Convert the bytes in the specified buffer to a
* // Command object.
* ...
* }
- *
+ *
* protected boolean doDecode(IoSession session, ByteBuffer in,
- * ProtocolDecoderOutput out)
+ * ProtocolDecoderOutput out)
* throws Exception {
- *
+ *
* // Remember the initial position.
* int start = in.position();
- *
+ *
* // Now find the first CRLF in the buffer.
* byte previous = 0;
* while (in.hasRemaining()) {
* byte current = in.get();
- *
+ *
* if (previous == '\r' && current == '\n') {
* // Remember the current position and limit.
* int position = in.position();
@@ -71,25 +71,25 @@
* in.position(position);
* in.limit(limit);
* }
- * // Decoded one line; CumulativeProtocolDecoder will
- * // call me again until I return false. So just
- * // return true until there are no more lines in the
+ * // Decoded one line; CumulativeProtocolDecoder will
+ * // call me again until I return false. So just
+ * // return true until there are no more lines in the
* // buffer.
* return true;
* }
- *
+ *
* previous = current;
* }
- *
- * // Could not find CRLF in the buffer. Reset the initial
+ *
+ * // Could not find CRLF in the buffer. Reset the initial
* // position to the one we recorded above.
* in.position(start);
- *
+ *
* return false;
* }
* }
* </pre>
- *
+ *
* @author The Apache MINA Project (dev@mina.apache.org)
* @version $Rev$, $Date$
*/
@@ -110,7 +110,7 @@
* decoding request to {@link #doDecode(IoSession, ByteBuffer, ProtocolDecoderOutput)}.
* <tt>doDecode()</tt> is invoked repeatedly until it returns <tt>false</tt>
* and the cumulative buffer is compacted after decoding ends.
- *
+ *
* @throws IllegalStateException if your <tt>doDecode()</tt> returned
* <tt>true</tt> not consuming the cumulative buffer.
*/
@@ -163,8 +163,8 @@
/**
* Implement this method to consume the specified cumulative buffer and
- * decode its content into message(s).
- *
+ * decode its content into message(s).
+ *
* @param in the cumulative buffer
* @return <tt>true</tt> if and only if there's more to decode in the buffer
* and you want to have <tt>doDecode</tt> method invoked again.
Modified: mina/trunk/core/src/main/java/org/apache/mina/filter/codec/ProtocolCodecException.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/filter/codec/ProtocolCodecException.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/filter/codec/ProtocolCodecException.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/filter/codec/ProtocolCodecException.java Sun Sep 16 16:55:27 2007
@@ -6,16 +6,16 @@
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
- * under the License.
- *
+ * under the License.
+ *
*/
package org.apache.mina.filter.codec;
@@ -23,7 +23,7 @@
* An exception that is thrown when {@link ProtocolEncoder} or
* {@link ProtocolDecoder} cannot understand or failed to validate
* data to process.
- *
+ *
* @author The Apache MINA Project (dev@mina.apache.org)
* @version $Rev$, $Date$
*/
Modified: mina/trunk/core/src/main/java/org/apache/mina/filter/codec/ProtocolCodecFactory.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/filter/codec/ProtocolCodecFactory.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/filter/codec/ProtocolCodecFactory.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/filter/codec/ProtocolCodecFactory.java Sun Sep 16 16:55:27 2007
@@ -6,16 +6,16 @@
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
- * under the License.
- *
+ * under the License.
+ *
*/
package org.apache.mina.filter.codec;
@@ -26,7 +26,7 @@
* Please refer to
* <a href="../../../../../xref-examples/org/apache/mina/examples/reverser/ReverseProtocolProvider.html"><code>ReverserProtocolProvider</code></a>
* example.
- *
+ *
* @author The Apache MINA Project (dev@mina.apache.org)
* @version $Rev$, $Date$
*/
Modified: mina/trunk/core/src/main/java/org/apache/mina/filter/codec/ProtocolCodecFilter.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/filter/codec/ProtocolCodecFilter.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/filter/codec/ProtocolCodecFilter.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/filter/codec/ProtocolCodecFilter.java Sun Sep 16 16:55:27 2007
@@ -6,16 +6,16 @@
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
- * under the License.
- *
+ * under the License.
+ *
*/
package org.apache.mina.filter.codec;
@@ -39,7 +39,7 @@
* An {@link IoFilter} which translates binary or protocol specific data into
* message object and vice versa using {@link ProtocolCodecFactory},
* {@link ProtocolEncoder}, or {@link ProtocolDecoder}.
- *
+ *
* @author The Apache MINA Project (dev@mina.apache.org)
* @version $Rev$, $Date$
*/
@@ -314,7 +314,7 @@
private void disposeDecoderOut(IoSession session) {
session.removeAttribute(DECODER_OUT);
}
-
+
private static class EncodedWriteRequest extends DefaultWriteRequest {
private EncodedWriteRequest(ByteBuffer encodedMessage,
WriteFuture future, SocketAddress destination) {
@@ -332,7 +332,7 @@
return EMPTY_BUFFER;
}
}
-
+
private static class ProtocolDecoderOutputImpl extends
AbstractProtocolDecoderOutput {
private final IoSession session;
Modified: mina/trunk/core/src/main/java/org/apache/mina/filter/codec/ProtocolCodecSession.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/filter/codec/ProtocolCodecSession.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/filter/codec/ProtocolCodecSession.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/filter/codec/ProtocolCodecSession.java Sun Sep 16 16:55:27 2007
@@ -6,16 +6,16 @@
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
- * under the License.
- *
+ * under the License.
+ *
*/
package org.apache.mina.filter.codec;
@@ -31,56 +31,56 @@
* A virtual {@link IoSession} that provides {@link ProtocolEncoderOutput}
* and {@link ProtocolDecoderOutput}. It is useful for unit-testing
* codec and reusing codec for non-network-use (e.g. serialization).
- *
+ *
* <h2>Encoding</h2>
* <pre>
* ProtocolCodecSession session = new ProtocolCodecSession();
* ProtocolEncoder encoder = ...;
* MessageX in = ...;
- *
+ *
* encoder.encode(session, in, session.getProtocolEncoderOutput());
- *
+ *
* ByteBuffer buffer = session.getProtocolDecoderOutputQueue().poll();
* </pre>
- *
+ *
* <h2>Decoding</h2>
* <pre>
* ProtocolCodecSession session = new ProtocolCodecSession();
* ProtocolDecoder decoder = ...;
* ByteBuffer in = ...;
- *
+ *
* decoder.decode(session, in, session.getProtocolDecoderOutput());
- *
+ *
* Object message = session.getProtocolDecoderOutputQueue().poll();
* </pre>
- *
+ *
* @author The Apache MINA Project (dev@mina.apache.org)
* @version $Rev$, $Date$
*/
public class ProtocolCodecSession extends DummySession {
-
+
private final WriteFuture notWrittenFuture =
DefaultWriteFuture.newNotWrittenFuture(this);
-
+
private final AbstractProtocolEncoderOutput encoderOutput =
new AbstractProtocolEncoderOutput() {
public WriteFuture flush() {
return notWrittenFuture;
}
};
-
+
private final AbstractProtocolDecoderOutput decoderOutput =
new AbstractProtocolDecoderOutput() {
public void flush() {
}
};
-
+
/**
* Creates a new instance.
*/
public ProtocolCodecSession() {
}
-
+
/**
* Returns the {@link ProtocolEncoderOutput} that buffers
* {@link ByteBuffer}s generated by {@link ProtocolEncoder}.
@@ -88,14 +88,14 @@
public ProtocolEncoderOutput getEncoderOutput() {
return encoderOutput;
}
-
+
/**
* Returns the {@link Queue} of the buffered encoder output.
*/
public Queue<ByteBuffer> getEncoderOutputQueue() {
return encoderOutput.getBufferQueue();
}
-
+
/**
* Returns the {@link ProtocolEncoderOutput} that buffers
* messages generated by {@link ProtocolDecoder}.
@@ -103,7 +103,7 @@
public ProtocolDecoderOutput getDecoderOutput() {
return decoderOutput;
}
-
+
/**
* Returns the {@link Queue} of the buffered decoder output.
*/
Modified: mina/trunk/core/src/main/java/org/apache/mina/filter/codec/ProtocolDecoder.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/filter/codec/ProtocolDecoder.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/filter/codec/ProtocolDecoder.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/filter/codec/ProtocolDecoder.java Sun Sep 16 16:55:27 2007
@@ -6,16 +6,16 @@
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
- * under the License.
- *
+ * under the License.
+ *
*/
package org.apache.mina.filter.codec;
@@ -31,8 +31,8 @@
* <p>
* Please refer to
* <a href="../../../../../xref-examples/org/apache/mina/examples/reverser/TextLineDecoder.html"><code>TextLineDecoder</code></a>
- * example.
- *
+ * example.
+ *
* @author The Apache MINA Project (dev@mina.apache.org)
* @version $Rev$, $Date$
*/
@@ -42,7 +42,7 @@
* MINA invokes {@link #decode(IoSession, ByteBuffer, ProtocolDecoderOutput)}
* method with read data, and then the decoder implementation puts decoded
* messages into {@link ProtocolDecoderOutput}.
- *
+ *
* @throws Exception if the read data violated protocol specification
*/
void decode(IoSession session, ByteBuffer in, ProtocolDecoderOutput out)
@@ -54,7 +54,7 @@
* such as HTTP response without <tt>content-length</tt> header. Implement this
* method to process the remaining data that {@link #decode(IoSession, ByteBuffer, ProtocolDecoderOutput)}
* method didn't process completely.
- *
+ *
* @throws Exception if the read data violated protocol specification
*/
void finishDecode(IoSession session, ProtocolDecoderOutput out)
@@ -62,7 +62,7 @@
/**
* Releases all resources related with this decoder.
- *
+ *
* @throws Exception if failed to dispose all resources
*/
void dispose(IoSession session) throws Exception;