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 [1/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...
Author: trustin
Date: Sun Sep 16 16:55:27 2007
New Revision: 576217
URL: http://svn.apache.org/viewvc?rev=576217&view=rev
Log:
Cleaned up source code using Eclipse source code cleaner
Modified:
mina/trunk/core/src/main/java/org/apache/mina/common/AbstractByteBuffer.java
mina/trunk/core/src/main/java/org/apache/mina/common/AbstractIoAcceptor.java
mina/trunk/core/src/main/java/org/apache/mina/common/AbstractIoConnector.java
mina/trunk/core/src/main/java/org/apache/mina/common/AbstractIoProcessor.java
mina/trunk/core/src/main/java/org/apache/mina/common/AbstractIoService.java
mina/trunk/core/src/main/java/org/apache/mina/common/AbstractIoSession.java
mina/trunk/core/src/main/java/org/apache/mina/common/AbstractIoSessionConfig.java
mina/trunk/core/src/main/java/org/apache/mina/common/BroadcastIoSession.java
mina/trunk/core/src/main/java/org/apache/mina/common/BufferDataException.java
mina/trunk/core/src/main/java/org/apache/mina/common/ByteBuffer.java
mina/trunk/core/src/main/java/org/apache/mina/common/ByteBufferAllocator.java
mina/trunk/core/src/main/java/org/apache/mina/common/ByteBufferHexDumper.java
mina/trunk/core/src/main/java/org/apache/mina/common/ByteBufferWrapper.java
mina/trunk/core/src/main/java/org/apache/mina/common/CloseFuture.java
mina/trunk/core/src/main/java/org/apache/mina/common/ConnectFuture.java
mina/trunk/core/src/main/java/org/apache/mina/common/DefaultCloseFuture.java
mina/trunk/core/src/main/java/org/apache/mina/common/DefaultConnectFuture.java
mina/trunk/core/src/main/java/org/apache/mina/common/DefaultExceptionMonitor.java
mina/trunk/core/src/main/java/org/apache/mina/common/DefaultFileRegion.java
mina/trunk/core/src/main/java/org/apache/mina/common/DefaultIoFilterChain.java
mina/trunk/core/src/main/java/org/apache/mina/common/DefaultIoFilterChainBuilder.java
mina/trunk/core/src/main/java/org/apache/mina/common/DefaultIoFuture.java
mina/trunk/core/src/main/java/org/apache/mina/common/DefaultTransportMetadata.java
mina/trunk/core/src/main/java/org/apache/mina/common/DefaultWriteFuture.java
mina/trunk/core/src/main/java/org/apache/mina/common/DefaultWriteRequest.java
mina/trunk/core/src/main/java/org/apache/mina/common/DummySession.java
mina/trunk/core/src/main/java/org/apache/mina/common/ExceptionMonitor.java
mina/trunk/core/src/main/java/org/apache/mina/common/ExpiringIoSessionRecycler.java
mina/trunk/core/src/main/java/org/apache/mina/common/FileRegion.java
mina/trunk/core/src/main/java/org/apache/mina/common/IdleStatus.java
mina/trunk/core/src/main/java/org/apache/mina/common/IdleStatusChecker.java
mina/trunk/core/src/main/java/org/apache/mina/common/IoAcceptor.java
mina/trunk/core/src/main/java/org/apache/mina/common/IoAcceptorWrapper.java
mina/trunk/core/src/main/java/org/apache/mina/common/IoConnector.java
mina/trunk/core/src/main/java/org/apache/mina/common/IoConnectorWrapper.java
mina/trunk/core/src/main/java/org/apache/mina/common/IoEvent.java
mina/trunk/core/src/main/java/org/apache/mina/common/IoEventType.java
mina/trunk/core/src/main/java/org/apache/mina/common/IoFilter.java
mina/trunk/core/src/main/java/org/apache/mina/common/IoFilterAdapter.java
mina/trunk/core/src/main/java/org/apache/mina/common/IoFilterChain.java
mina/trunk/core/src/main/java/org/apache/mina/common/IoFilterChainBuilder.java
mina/trunk/core/src/main/java/org/apache/mina/common/IoFilterEvent.java
mina/trunk/core/src/main/java/org/apache/mina/common/IoFilterLifeCycleException.java
mina/trunk/core/src/main/java/org/apache/mina/common/IoFuture.java
mina/trunk/core/src/main/java/org/apache/mina/common/IoFutureListener.java
mina/trunk/core/src/main/java/org/apache/mina/common/IoHandler.java
mina/trunk/core/src/main/java/org/apache/mina/common/IoHandlerAdapter.java
mina/trunk/core/src/main/java/org/apache/mina/common/IoProcessor.java
mina/trunk/core/src/main/java/org/apache/mina/common/IoService.java
mina/trunk/core/src/main/java/org/apache/mina/common/IoServiceListener.java
mina/trunk/core/src/main/java/org/apache/mina/common/IoServiceListenerSupport.java
mina/trunk/core/src/main/java/org/apache/mina/common/IoSessionConfig.java
mina/trunk/core/src/main/java/org/apache/mina/common/IoSessionLogger.java
mina/trunk/core/src/main/java/org/apache/mina/common/IoSessionRecycler.java
mina/trunk/core/src/main/java/org/apache/mina/common/RuntimeIOException.java
mina/trunk/core/src/main/java/org/apache/mina/common/SimpleByteBufferAllocator.java
mina/trunk/core/src/main/java/org/apache/mina/common/TrafficMask.java
mina/trunk/core/src/main/java/org/apache/mina/common/TransportMetadata.java
mina/trunk/core/src/main/java/org/apache/mina/common/WriteFuture.java
mina/trunk/core/src/main/java/org/apache/mina/common/WriteRequest.java
mina/trunk/core/src/main/java/org/apache/mina/common/WriteRequestWrapper.java
mina/trunk/core/src/main/java/org/apache/mina/common/WriteTimeoutException.java
mina/trunk/core/src/main/java/org/apache/mina/filter/codec/CumulativeProtocolDecoder.java
mina/trunk/core/src/main/java/org/apache/mina/filter/codec/ProtocolCodecException.java
mina/trunk/core/src/main/java/org/apache/mina/filter/codec/ProtocolCodecFactory.java
mina/trunk/core/src/main/java/org/apache/mina/filter/codec/ProtocolCodecFilter.java
mina/trunk/core/src/main/java/org/apache/mina/filter/codec/ProtocolCodecSession.java
mina/trunk/core/src/main/java/org/apache/mina/filter/codec/ProtocolDecoder.java
mina/trunk/core/src/main/java/org/apache/mina/filter/codec/ProtocolDecoderAdapter.java
mina/trunk/core/src/main/java/org/apache/mina/filter/codec/ProtocolDecoderException.java
mina/trunk/core/src/main/java/org/apache/mina/filter/codec/ProtocolDecoderOutput.java
mina/trunk/core/src/main/java/org/apache/mina/filter/codec/ProtocolEncoder.java
mina/trunk/core/src/main/java/org/apache/mina/filter/codec/ProtocolEncoderAdapter.java
mina/trunk/core/src/main/java/org/apache/mina/filter/codec/ProtocolEncoderException.java
mina/trunk/core/src/main/java/org/apache/mina/filter/codec/ProtocolEncoderOutput.java
mina/trunk/core/src/main/java/org/apache/mina/filter/codec/SynchronizedProtocolDecoder.java
mina/trunk/core/src/main/java/org/apache/mina/filter/codec/SynchronizedProtocolEncoder.java
mina/trunk/core/src/main/java/org/apache/mina/filter/codec/demux/DemuxingProtocolCodecFactory.java
mina/trunk/core/src/main/java/org/apache/mina/filter/codec/demux/MessageDecoder.java
mina/trunk/core/src/main/java/org/apache/mina/filter/codec/demux/MessageDecoderAdapter.java
mina/trunk/core/src/main/java/org/apache/mina/filter/codec/demux/MessageDecoderFactory.java
mina/trunk/core/src/main/java/org/apache/mina/filter/codec/demux/MessageDecoderResult.java
mina/trunk/core/src/main/java/org/apache/mina/filter/codec/demux/MessageEncoder.java
mina/trunk/core/src/main/java/org/apache/mina/filter/codec/demux/MessageEncoderFactory.java
mina/trunk/core/src/main/java/org/apache/mina/filter/codec/serialization/ObjectSerializationCodecFactory.java
mina/trunk/core/src/main/java/org/apache/mina/filter/codec/serialization/ObjectSerializationDecoder.java
mina/trunk/core/src/main/java/org/apache/mina/filter/codec/serialization/ObjectSerializationEncoder.java
mina/trunk/core/src/main/java/org/apache/mina/filter/codec/serialization/ObjectSerializationInputStream.java
mina/trunk/core/src/main/java/org/apache/mina/filter/codec/serialization/ObjectSerializationOutputStream.java
mina/trunk/core/src/main/java/org/apache/mina/filter/codec/textline/LineDelimiter.java
mina/trunk/core/src/main/java/org/apache/mina/filter/codec/textline/TextLineCodecFactory.java
mina/trunk/core/src/main/java/org/apache/mina/filter/codec/textline/TextLineDecoder.java
mina/trunk/core/src/main/java/org/apache/mina/filter/codec/textline/TextLineEncoder.java
mina/trunk/core/src/main/java/org/apache/mina/filter/executor/AbstractExecutorFilter.java
mina/trunk/core/src/main/java/org/apache/mina/filter/executor/UnorderedExecutorFilter.java
mina/trunk/core/src/main/java/org/apache/mina/filter/firewall/BlacklistFilter.java
mina/trunk/core/src/main/java/org/apache/mina/filter/firewall/ConnectionThrottleFilter.java
mina/trunk/core/src/main/java/org/apache/mina/filter/logging/LoggingFilter.java
mina/trunk/core/src/main/java/org/apache/mina/filter/logging/MDCInjectionFilter.java
mina/trunk/core/src/main/java/org/apache/mina/filter/reqres/Request.java
mina/trunk/core/src/main/java/org/apache/mina/filter/reqres/RequestResponseFilter.java
mina/trunk/core/src/main/java/org/apache/mina/filter/reqres/RequestTimeoutException.java
mina/trunk/core/src/main/java/org/apache/mina/filter/reqres/Response.java
mina/trunk/core/src/main/java/org/apache/mina/filter/reqres/ResponseInspector.java
mina/trunk/core/src/main/java/org/apache/mina/filter/reqres/ResponseInspectorFactory.java
mina/trunk/core/src/main/java/org/apache/mina/filter/reqres/ResponseType.java
mina/trunk/core/src/main/java/org/apache/mina/filter/ssl/SSLByteBufferUtil.java
mina/trunk/core/src/main/java/org/apache/mina/filter/ssl/SSLFilter.java
mina/trunk/core/src/main/java/org/apache/mina/filter/ssl/SSLHandler.java
mina/trunk/core/src/main/java/org/apache/mina/filter/statistic/ProfilerTimerFilter.java
mina/trunk/core/src/main/java/org/apache/mina/filter/stream/StreamWriteFilter.java
mina/trunk/core/src/main/java/org/apache/mina/filter/traffic/ReadThrottleFilterBuilder.java
mina/trunk/core/src/main/java/org/apache/mina/filter/util/ReferenceCountingIoFilter.java
mina/trunk/core/src/main/java/org/apache/mina/filter/util/SessionAttributeInitializingFilter.java
mina/trunk/core/src/main/java/org/apache/mina/filter/util/WrappingFilter.java
mina/trunk/core/src/main/java/org/apache/mina/handler/chain/ChainedIoHandler.java
mina/trunk/core/src/main/java/org/apache/mina/handler/chain/IoHandlerChain.java
mina/trunk/core/src/main/java/org/apache/mina/handler/chain/IoHandlerCommand.java
mina/trunk/core/src/main/java/org/apache/mina/handler/demux/DemuxingIoHandler.java
mina/trunk/core/src/main/java/org/apache/mina/handler/demux/MessageHandler.java
mina/trunk/core/src/main/java/org/apache/mina/handler/demux/UnknownMessageTypeException.java
mina/trunk/core/src/main/java/org/apache/mina/handler/multiton/SingleSessionIoHandler.java
mina/trunk/core/src/main/java/org/apache/mina/handler/multiton/SingleSessionIoHandlerAdapter.java
mina/trunk/core/src/main/java/org/apache/mina/handler/multiton/SingleSessionIoHandlerDelegate.java
mina/trunk/core/src/main/java/org/apache/mina/handler/multiton/SingleSessionIoHandlerFactory.java
mina/trunk/core/src/main/java/org/apache/mina/handler/stream/IoSessionInputStream.java
mina/trunk/core/src/main/java/org/apache/mina/handler/stream/IoSessionOutputStream.java
mina/trunk/core/src/main/java/org/apache/mina/handler/stream/StreamIoHandler.java
mina/trunk/core/src/main/java/org/apache/mina/management/IoSessionStat.java
mina/trunk/core/src/main/java/org/apache/mina/management/StatCollector.java
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/AbstractDatagramSessionConfig.java
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/AbstractSocketSessionConfig.java
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/DatagramAcceptor.java
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/DatagramConnector.java
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/DatagramSessionConfig.java
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/DatagramSessionImpl.java
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/DefaultDatagramSessionConfig.java
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/DefaultSocketSessionConfig.java
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/NIOProcessor.java
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/NIOSession.java
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/SocketSessionConfig.java
mina/trunk/core/src/main/java/org/apache/mina/transport/socket/nio/SocketSessionImpl.java
mina/trunk/core/src/main/java/org/apache/mina/transport/vmpipe/DefaultVmPipeSessionConfig.java
mina/trunk/core/src/main/java/org/apache/mina/transport/vmpipe/VmPipe.java
mina/trunk/core/src/main/java/org/apache/mina/transport/vmpipe/VmPipeAcceptor.java
mina/trunk/core/src/main/java/org/apache/mina/transport/vmpipe/VmPipeAddress.java
mina/trunk/core/src/main/java/org/apache/mina/transport/vmpipe/VmPipeFilterChain.java
mina/trunk/core/src/main/java/org/apache/mina/transport/vmpipe/VmPipeSession.java
mina/trunk/core/src/main/java/org/apache/mina/transport/vmpipe/VmPipeSessionConfig.java
mina/trunk/core/src/main/java/org/apache/mina/transport/vmpipe/VmPipeSessionImpl.java
mina/trunk/core/src/main/java/org/apache/mina/util/AvailablePortFinder.java
mina/trunk/core/src/main/java/org/apache/mina/util/ConcurrentHashSet.java
mina/trunk/core/src/main/java/org/apache/mina/util/CopyOnWriteMap.java
mina/trunk/core/src/main/java/org/apache/mina/util/ExpirationListener.java
mina/trunk/core/src/main/java/org/apache/mina/util/ExpiringMap.java
mina/trunk/core/src/main/java/org/apache/mina/util/IdentityHashSet.java
mina/trunk/core/src/main/java/org/apache/mina/util/MapBackedSet.java
mina/trunk/core/src/main/java/org/apache/mina/util/NamePreservingRunnable.java
mina/trunk/core/src/main/java/org/apache/mina/util/NewThreadExecutor.java
mina/trunk/core/src/test/java/org/apache/mina/common/ByteBufferTest.java
mina/trunk/core/src/test/java/org/apache/mina/common/DefaultIoFilterChainBuilderTest.java
mina/trunk/core/src/test/java/org/apache/mina/common/FutureTest.java
mina/trunk/core/src/test/java/org/apache/mina/common/IoFilterChainTest.java
mina/trunk/core/src/test/java/org/apache/mina/common/IoServiceListenerSupportTest.java
mina/trunk/core/src/test/java/org/apache/mina/filter/codec/CumulativeProtocolDecoderTest.java
mina/trunk/core/src/test/java/org/apache/mina/filter/codec/serialization/ObjectSerializationTest.java
mina/trunk/core/src/test/java/org/apache/mina/filter/codec/textline/TextLineDecoderTest.java
mina/trunk/core/src/test/java/org/apache/mina/filter/codec/textline/TextLineEncoderTest.java
mina/trunk/core/src/test/java/org/apache/mina/filter/executor/ExecutorFilterRegressionTest.java
mina/trunk/core/src/test/java/org/apache/mina/filter/logging/MDCInjectionFilterTest.java
mina/trunk/core/src/test/java/org/apache/mina/filter/reqres/RequestResponseFilterTest.java
mina/trunk/core/src/test/java/org/apache/mina/filter/util/WrappingFilterTest.java
mina/trunk/core/src/test/java/org/apache/mina/handler/chain/ChainedIoHandlerTest.java
mina/trunk/core/src/test/java/org/apache/mina/handler/demux/DemuxingIoHandlerTest.java
mina/trunk/core/src/test/java/org/apache/mina/transport/AbstractBindTest.java
mina/trunk/core/src/test/java/org/apache/mina/transport/AbstractConnectorTest.java
mina/trunk/core/src/test/java/org/apache/mina/transport/AbstractTrafficControlTest.java
mina/trunk/core/src/test/java/org/apache/mina/transport/socket/nio/DatagramBindTest.java
mina/trunk/core/src/test/java/org/apache/mina/transport/socket/nio/DatagramConfigTest.java
mina/trunk/core/src/test/java/org/apache/mina/transport/socket/nio/DatagramConnectorTest.java
mina/trunk/core/src/test/java/org/apache/mina/transport/socket/nio/DatagramRecyclerTest.java
mina/trunk/core/src/test/java/org/apache/mina/transport/socket/nio/DatagramTrafficControlTest.java
mina/trunk/core/src/test/java/org/apache/mina/transport/socket/nio/SocketBindTest.java
mina/trunk/core/src/test/java/org/apache/mina/transport/socket/nio/SocketConnectorTest.java
mina/trunk/core/src/test/java/org/apache/mina/transport/socket/nio/SocketTrafficControlTest.java
mina/trunk/core/src/test/java/org/apache/mina/transport/vmpipe/VmPipeBindTest.java
mina/trunk/core/src/test/java/org/apache/mina/transport/vmpipe/VmPipeEventOrderTest.java
mina/trunk/core/src/test/java/org/apache/mina/transport/vmpipe/VmPipeTrafficControlTest.java
mina/trunk/core/src/test/java/org/apache/mina/util/IoFilterImpl.java
mina/trunk/example/src/main/java/org/apache/mina/example/chat/ChatCommand.java
mina/trunk/example/src/main/java/org/apache/mina/example/chat/ChatProtocolHandler.java
mina/trunk/example/src/main/java/org/apache/mina/example/chat/Main.java
mina/trunk/example/src/main/java/org/apache/mina/example/chat/SpringMain.java
mina/trunk/example/src/main/java/org/apache/mina/example/chat/client/ChatClientSupport.java
mina/trunk/example/src/main/java/org/apache/mina/example/chat/client/SwingChatClient.java
mina/trunk/example/src/main/java/org/apache/mina/example/chat/client/SwingChatClientHandler.java
mina/trunk/example/src/main/java/org/apache/mina/example/echoserver/EchoProtocolHandler.java
mina/trunk/example/src/main/java/org/apache/mina/example/echoserver/Main.java
mina/trunk/example/src/main/java/org/apache/mina/example/echoserver/ssl/BogusSSLContextFactory.java
mina/trunk/example/src/main/java/org/apache/mina/example/echoserver/ssl/BogusTrustManagerFactory.java
mina/trunk/example/src/main/java/org/apache/mina/example/echoserver/ssl/SSLServerSocketFactory.java
mina/trunk/example/src/main/java/org/apache/mina/example/echoserver/ssl/SSLSocketFactory.java
mina/trunk/example/src/main/java/org/apache/mina/example/httpclient/Wget.java
mina/trunk/example/src/main/java/org/apache/mina/example/httpserver/codec/HttpRequestDecoder.java
mina/trunk/example/src/main/java/org/apache/mina/example/httpserver/codec/HttpRequestMessage.java
mina/trunk/example/src/main/java/org/apache/mina/example/httpserver/codec/HttpResponseEncoder.java
mina/trunk/example/src/main/java/org/apache/mina/example/httpserver/codec/HttpResponseMessage.java
mina/trunk/example/src/main/java/org/apache/mina/example/httpserver/codec/HttpServerProtocolCodecFactory.java
mina/trunk/example/src/main/java/org/apache/mina/example/httpserver/codec/Server.java
mina/trunk/example/src/main/java/org/apache/mina/example/httpserver/codec/ServerHandler.java
mina/trunk/example/src/main/java/org/apache/mina/example/httpserver/stream/HttpProtocolHandler.java
mina/trunk/example/src/main/java/org/apache/mina/example/httpserver/stream/Main.java
mina/trunk/example/src/main/java/org/apache/mina/example/netcat/Main.java
mina/trunk/example/src/main/java/org/apache/mina/example/netcat/NetCatProtocolHandler.java
mina/trunk/example/src/main/java/org/apache/mina/example/proxy/AbstractProxyIoHandler.java
mina/trunk/example/src/main/java/org/apache/mina/example/proxy/ClientToProxyIoHandler.java
mina/trunk/example/src/main/java/org/apache/mina/example/proxy/Main.java
mina/trunk/example/src/main/java/org/apache/mina/example/proxy/ServerToProxyIoHandler.java
mina/trunk/example/src/main/java/org/apache/mina/example/reverser/Main.java
mina/trunk/example/src/main/java/org/apache/mina/example/reverser/ReverseProtocolHandler.java
mina/trunk/example/src/main/java/org/apache/mina/example/sumup/Client.java
mina/trunk/example/src/main/java/org/apache/mina/example/sumup/ClientSessionHandler.java
mina/trunk/example/src/main/java/org/apache/mina/example/sumup/Server.java
mina/trunk/example/src/main/java/org/apache/mina/example/sumup/ServerSessionHandler.java
mina/trunk/example/src/main/java/org/apache/mina/example/sumup/codec/AbstractMessageDecoder.java
mina/trunk/example/src/main/java/org/apache/mina/example/sumup/codec/AbstractMessageEncoder.java
mina/trunk/example/src/main/java/org/apache/mina/example/sumup/codec/AddMessageDecoder.java
mina/trunk/example/src/main/java/org/apache/mina/example/sumup/codec/AddMessageEncoder.java
mina/trunk/example/src/main/java/org/apache/mina/example/sumup/codec/Constants.java
mina/trunk/example/src/main/java/org/apache/mina/example/sumup/codec/ResultMessageDecoder.java
mina/trunk/example/src/main/java/org/apache/mina/example/sumup/codec/ResultMessageEncoder.java
mina/trunk/example/src/main/java/org/apache/mina/example/sumup/codec/SumUpProtocolCodecFactory.java
mina/trunk/example/src/main/java/org/apache/mina/example/sumup/message/AbstractMessage.java
mina/trunk/example/src/main/java/org/apache/mina/example/sumup/message/AddMessage.java
mina/trunk/example/src/main/java/org/apache/mina/example/sumup/message/ResultMessage.java
mina/trunk/example/src/main/java/org/apache/mina/example/tennis/Main.java
mina/trunk/example/src/main/java/org/apache/mina/example/tennis/TennisBall.java
mina/trunk/example/src/main/java/org/apache/mina/example/tennis/TennisPlayer.java
mina/trunk/example/src/main/java/org/apache/mina/example/udp/ClientPanel.java
mina/trunk/example/src/main/java/org/apache/mina/example/udp/MemoryMonitor.java
mina/trunk/example/src/main/java/org/apache/mina/example/udp/MemoryMonitorHandler.java
mina/trunk/example/src/main/java/org/apache/mina/example/udp/client/MemMonClient.java
mina/trunk/example/src/test/java/org/apache/mina/example/echoserver/AbstractTest.java
mina/trunk/example/src/test/java/org/apache/mina/example/echoserver/AcceptorTest.java
mina/trunk/example/src/test/java/org/apache/mina/example/echoserver/ConnectorTest.java
mina/trunk/example/src/test/java/org/apache/mina/example/echoserver/ssl/SSLFilterTest.java
mina/trunk/filter-codec-netty/src/main/java/org/apache/mina/filter/codec/netty/NettyCodecFactory.java
mina/trunk/filter-codec-netty/src/main/java/org/apache/mina/filter/codec/netty/NettyDecoder.java
mina/trunk/filter-codec-netty/src/main/java/org/apache/mina/filter/codec/netty/NettyEncoder.java
mina/trunk/filter-compression/src/main/java/org/apache/mina/filter/compression/CompressionFilter.java
mina/trunk/filter-compression/src/main/java/org/apache/mina/filter/compression/Zlib.java
mina/trunk/filter-compression/src/test/java/org/apache/mina/filter/compression/CompressionFilterTest.java
mina/trunk/filter-compression/src/test/java/org/apache/mina/filter/compression/ZlibTest.java
mina/trunk/integration-jmx/src/main/java/org/apache/mina/integration/jmx/IoServiceManager.java
mina/trunk/integration-jmx/src/main/java/org/apache/mina/integration/jmx/IoServiceManagerMBean.java
mina/trunk/integration-jmx/src/main/java/org/apache/mina/integration/jmx/IoSessionManager.java
mina/trunk/integration-jmx/src/main/java/org/apache/mina/integration/jmx/IoSessionManagerMBean.java
mina/trunk/integration-spring/src/main/java/org/apache/mina/integration/spring/DefaultIoFilterChainBuilderFactoryBean.java
mina/trunk/integration-spring/src/main/java/org/apache/mina/integration/spring/InetAddressEditor.java
mina/trunk/integration-spring/src/main/java/org/apache/mina/integration/spring/InetSocketAddressEditor.java
mina/trunk/integration-spring/src/main/java/org/apache/mina/integration/spring/IoFilterMapping.java
mina/trunk/integration-spring/src/main/java/org/apache/mina/integration/spring/ThreadPoolExecutorFactoryBean.java
mina/trunk/integration-spring/src/main/java/org/apache/mina/integration/spring/VmPipeAddressEditor.java
mina/trunk/integration-spring/src/main/java/org/apache/mina/integration/spring/ssl/BogusTrustManagerFactory.java
mina/trunk/integration-spring/src/main/java/org/apache/mina/integration/spring/ssl/KeyStoreFactoryBean.java
mina/trunk/integration-spring/src/main/java/org/apache/mina/integration/spring/ssl/SSLContextFactoryBean.java
mina/trunk/integration-spring/src/test/java/org/apache/mina/integration/spring/DefaultIoFilterChainBuilderFactoryBeanTest.java
mina/trunk/integration-spring/src/test/java/org/apache/mina/integration/spring/InetAddressEditorTest.java
mina/trunk/integration-spring/src/test/java/org/apache/mina/integration/spring/InetSocketAddressEditorTest.java
mina/trunk/integration-spring/src/test/java/org/apache/mina/integration/spring/IoFilterMappingTest.java
mina/trunk/integration-spring/src/test/java/org/apache/mina/integration/spring/VmPipeAddressEditorTest.java
mina/trunk/integration-spring/src/test/java/org/apache/mina/integration/spring/ssl/KeyStoreFactoryBeanTest.java
mina/trunk/protocol-http-client/src/main/java/org/apache/mina/protocol/http/client/AsyncHttpClient.java
mina/trunk/protocol-http-client/src/main/java/org/apache/mina/protocol/http/client/SimpleTrustManagerFactory.java
mina/trunk/protocol-http-client/src/test/java/org/apache/mina/protocol/http/client/AbstractTest.java
mina/trunk/protocol-http-client/src/test/java/org/apache/mina/protocol/http/client/AsyncHttpClientTest.java
mina/trunk/transport-serial/src/main/java/org/apache/mina/transport/serial/DefaultSerialSessionConfig.java
mina/trunk/transport-serial/src/main/java/org/apache/mina/transport/serial/SerialAddress.java
mina/trunk/transport-serial/src/main/java/org/apache/mina/transport/serial/SerialConnector.java
mina/trunk/transport-serial/src/main/java/org/apache/mina/transport/serial/SerialPortUnavailableException.java
mina/trunk/transport-serial/src/main/java/org/apache/mina/transport/serial/SerialSessionConfig.java
mina/trunk/transport-serial/src/main/java/org/apache/mina/transport/serial/SerialSessionImpl.java
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/AbstractByteBuffer.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/AbstractByteBuffer.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/AbstractByteBuffer.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/AbstractByteBuffer.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/AbstractIoAcceptor.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/AbstractIoAcceptor.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/AbstractIoAcceptor.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/AbstractIoAcceptor.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 base implementation of {@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/AbstractIoConnector.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/AbstractIoConnector.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/AbstractIoConnector.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/AbstractIoConnector.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 base implementation of {@link IoConnector}.
- *
+ *
* @author The Apache MINA Project (dev@mina.apache.org)
* @version $Rev$, $Date$
*/
@@ -86,7 +86,7 @@
/**
* Implement this method to perform the actual connect operation.
- *
+ *
* @param localAddress <tt>null</tt> if no local address is specified
*/
protected abstract ConnectFuture doConnect(SocketAddress remoteAddress,
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/AbstractIoProcessor.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/AbstractIoProcessor.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/AbstractIoProcessor.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/AbstractIoProcessor.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;
@@ -31,10 +31,10 @@
/**
* An abstract implementation of {@link IoProcessor} which helps
* transport developers to write an {@link IoProcessor} easily.
- *
+ *
* @author The Apache MINA Project (dev@mina.apache.org)
* @version $Rev$, $Date$
- *
+ *
* TODO Provide abstraction for bind, unbind and connect (+ cancellation)
*/
public abstract class AbstractIoProcessor implements IoProcessor {
@@ -45,11 +45,11 @@
private final Queue<AbstractIoSession> newSessions =
new ConcurrentLinkedQueue<AbstractIoSession>();
- private final Queue<AbstractIoSession> removingSessions =
+ private final Queue<AbstractIoSession> removingSessions =
new ConcurrentLinkedQueue<AbstractIoSession>();
- private final Queue<AbstractIoSession> flushingSessions =
+ private final Queue<AbstractIoSession> flushingSessions =
new ConcurrentLinkedQueue<AbstractIoSession>();
- private final Queue<AbstractIoSession> trafficControllingSessions =
+ private final Queue<AbstractIoSession> trafficControllingSessions =
new ConcurrentLinkedQueue<AbstractIoSession>();
private Worker worker;
@@ -59,11 +59,11 @@
this.threadName = threadName;
this.executor = executor;
}
-
+
protected abstract int select(int timeout) throws Exception;
protected abstract void wakeup();
-
+
protected abstract Iterator<AbstractIoSession> allSessions() throws Exception;
protected abstract Iterator<AbstractIoSession> selectedSessions() throws Exception;
@@ -146,7 +146,7 @@
try {
doAdd(session);
addedSessions ++;
-
+
// DefaultIoFilterChain.CONNECT_FUTURE is cleared inside here
// in AbstractIoFilterChain.fireSessionOpened().
((AbstractIoService) session.getService()).getListeners().fireSessionCreated(session);
@@ -156,10 +156,10 @@
session.getFilterChain().fireExceptionCaught(session, e);
}
}
-
+
return addedSessions;
}
-
+
private int remove() {
int removedSessions = 0;
for (; ;) {
@@ -168,7 +168,7 @@
if (session == null) {
break;
}
-
+
SessionState state = state(session);
switch (state) {
case OPEN:
@@ -194,28 +194,28 @@
throw new IllegalStateException(String.valueOf(state));
}
}
-
+
return removedSessions;
}
-
+
private void process() throws Exception {
for (Iterator<AbstractIoSession> i = selectedSessions(); i.hasNext();) {
process(i.next());
i.remove();
}
}
-
+
private void process(AbstractIoSession session) throws Exception {
int readyOps = readyOps(session);
- if (((readyOps & SelectionKey.OP_READ) != 0) && session.getTrafficMask().isReadable()) {
+ if ((readyOps & SelectionKey.OP_READ) != 0 && session.getTrafficMask().isReadable()) {
read(session);
}
- if (((readyOps & SelectionKey.OP_WRITE) != 0) && session.getTrafficMask().isWritable()) {
+ if ((readyOps & SelectionKey.OP_WRITE) != 0 && session.getTrafficMask().isWritable()) {
scheduleFlush(session);
}
}
-
+
private void read(AbstractIoSession session) {
IoSessionConfig config = session.getConfig();
ByteBuffer buf = ByteBuffer.allocate(config.getReadBufferSize());
@@ -244,7 +244,7 @@
if (readBytes > 0) {
session.getFilterChain().fireMessageReceived(session, buf);
buf = null;
-
+
if (session.getTransportMetadata().hasFragmentation()) {
if (readBytes * 2 < config.getReadBufferSize()) {
if (config.getReadBufferSize() > config.getMinReadBufferSize()) {
@@ -252,7 +252,7 @@
}
} else if (readBytes == config.getReadBufferSize()) {
int newReadBufferSize = config.getReadBufferSize() << 1;
- if (newReadBufferSize <= (config.getMaxReadBufferSize())) {
+ if (newReadBufferSize <= config.getMaxReadBufferSize()) {
config.setReadBufferSize(newReadBufferSize);
} else {
config.setReadBufferSize(config.getMaxReadBufferSize());
@@ -270,11 +270,11 @@
session.getFilterChain().fireExceptionCaught(session, e);
}
}
-
+
private void notifyIdleness() throws Exception {
// process idle sessions
long currentTime = System.currentTimeMillis();
- if ((currentTime - lastIdleCheckTime) >= 1000) {
+ if (currentTime - lastIdleCheckTime >= 1000) {
lastIdleCheckTime = currentTime;
for (Iterator<AbstractIoSession> i = allSessions(); i.hasNext();) {
AbstractIoSession session = i.next();
@@ -308,7 +308,7 @@
private void notifyIdleness0(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);
}
@@ -316,7 +316,7 @@
private void notifyWriteTimeout(AbstractIoSession session,
long currentTime, long writeTimeout, long lastIoTime) throws Exception {
- if (writeTimeout > 0 && (currentTime - lastIoTime) >= writeTimeout
+ if (writeTimeout > 0 && currentTime - lastIoTime >= writeTimeout
&& (interestOps(session) & SelectionKey.OP_WRITE) != 0) {
session.getFilterChain().fireExceptionCaught(session,
new WriteTimeoutException());
@@ -341,7 +341,7 @@
clearWriteRequestQueue(session);
continue;
}
-
+
SessionState state = state(session);
switch (state) {
case OPEN:
@@ -368,7 +368,7 @@
}
}
}
-
+
private void clearWriteRequestQueue(AbstractIoSession session) {
Queue<WriteRequest> writeRequestQueue = session.getWriteRequestQueue();
WriteRequest req;
@@ -395,10 +395,10 @@
}
}
}
-
+
private boolean flush(AbstractIoSession session) throws Exception {
// Clear OP_WRITE
- interestOps(session, interestOps(session) & (~SelectionKey.OP_WRITE));
+ interestOps(session, interestOps(session) & ~SelectionKey.OP_WRITE);
Queue<WriteRequest> writeRequestQueue = session.getWriteRequestQueue();
@@ -406,7 +406,7 @@
// fairness.
int maxWrittenBytes = session.getConfig().getMaxReadBufferSize();
int writtenBytes = 0;
-
+
try {
do {
// Check for pending writes.
@@ -433,7 +433,7 @@
region.setPosition(region.getPosition() + localWrittenBytes);
writtenBytes += localWrittenBytes;
}
-
+
if (region.getCount() > 0 || writtenBytes >= maxWrittenBytes) {
// Kernel buffer is full or wrote too much.
interestOps(session, interestOps(session) | SelectionKey.OP_WRITE);
@@ -470,7 +470,7 @@
return true;
}
-
+
private void updateTrafficMask() {
for (; ;) {
AbstractIoSession session = trafficControllingSessions.poll();
@@ -478,7 +478,7 @@
if (session == null) {
break;
}
-
+
SessionState state = state(session);
switch (state) {
case OPEN:
@@ -510,18 +510,18 @@
}
}
}
-
+
private class Worker implements Runnable {
public void run() {
int nSessions = 0;
-
+
Thread.currentThread().setName(AbstractIoProcessor.this.threadName);
lastIdleCheckTime = System.currentTimeMillis();
for (;;) {
try {
int nKeys = select(1000);
-
+
nSessions += add();
updateTrafficMask();
@@ -553,7 +553,7 @@
}
}
}
-
+
protected static enum SessionState {
OPEN,
CLOSED,
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/AbstractIoService.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/AbstractIoService.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/AbstractIoService.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/AbstractIoService.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 implementation of {@link IoService}s.
- *
+ *
* @author The Apache MINA Project (dev@mina.apache.org)
* @version $Rev$, $Date$
*/
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/AbstractIoSession.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/AbstractIoSession.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/AbstractIoSession.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/AbstractIoSession.java Sun Sep 16 16:55:27 2007
@@ -52,12 +52,12 @@
s.scheduledWriteMessages.set(0);
}
};
-
+
private final Object lock = new Object();
-
+
private final Map<String, Object> attributes = Collections
.synchronizedMap(new HashMap<String, Object>(4));
-
+
private final Queue<WriteRequest> writeRequestQueue =
new ConcurrentLinkedQueue<WriteRequest>();
@@ -74,7 +74,7 @@
// Status variables
private final AtomicBoolean scheduledForFlush = new AtomicBoolean();
-
+
private final AtomicLong scheduledWriteBytes = new AtomicLong();
private final AtomicInteger scheduledWriteMessages = new AtomicInteger();
@@ -109,9 +109,9 @@
lastIdleTimeForWrite = System.currentTimeMillis();
closeFuture.addListener(SCHEDULED_COUNTER_RESETTER);
}
-
+
protected abstract IoProcessor getProcessor();
-
+
public boolean isConnected() {
return !closeFuture.isClosed();
}
@@ -127,7 +127,7 @@
public boolean isScheduledForFlush() {
return scheduledForFlush.get();
}
-
+
public boolean setScheduledForFlush(boolean flag) {
if (flag) {
return scheduledForFlush.compareAndSet(false, true);
@@ -374,11 +374,11 @@
public long getWrittenMessages() {
return writtenMessages;
}
-
+
public long getScheduledWriteBytes() {
return scheduledWriteBytes.get();
}
-
+
public int getScheduledWriteMessages() {
return scheduledWriteMessages.get();
}
@@ -398,7 +398,7 @@
lastWriteTime = System.currentTimeMillis();
idleCountForBoth = 0;
idleCountForWrite = 0;
-
+
scheduledWriteBytes.addAndGet(-increment);
}
}
@@ -419,7 +419,7 @@
public void increaseScheduledWriteMessages() {
scheduledWriteMessages.incrementAndGet();
}
-
+
public Queue<WriteRequest> getWriteRequestQueue() {
return writeRequestQueue;
}
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/AbstractIoSessionConfig.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/AbstractIoSessionConfig.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/AbstractIoSessionConfig.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/AbstractIoSessionConfig.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 base implementation of {@link IoSessionConfig}.
- *
+ *
* @author The Apache MINA Project (dev@mina.apache.org)
* @version $Rev$, $Date$
*/
@@ -38,12 +38,12 @@
protected AbstractIoSessionConfig() {
}
-
+
public final void setAll(IoSessionConfig config) {
if (config == null) {
throw new NullPointerException("config");
}
-
+
setReadBufferSize(config.getReadBufferSize());
setMinReadBufferSize(config.getMinReadBufferSize());
setMaxReadBufferSize(config.getMaxReadBufferSize());
@@ -51,10 +51,10 @@
setIdleTime(IdleStatus.READER_IDLE, config.getIdleTime(IdleStatus.READER_IDLE));
setIdleTime(IdleStatus.WRITER_IDLE, config.getIdleTime(IdleStatus.WRITER_IDLE));
setWriteTimeout(config.getWriteTimeout());
-
+
doSetAll(config);
}
-
+
/**
* Implement this method to set all transport-specific configuration
* properties retrieved from the specified <tt>config</tt>.
@@ -64,7 +64,7 @@
public int getReadBufferSize() {
return readBufferSize;
}
-
+
public void setReadBufferSize(int readBufferSize) {
if (readBufferSize <= 0) {
throw new IllegalArgumentException("readBufferSize: " + readBufferSize + " (expected: 1+)");
@@ -75,14 +75,14 @@
public int getMinReadBufferSize() {
return minReadBufferSize;
}
-
+
public void setMinReadBufferSize(int minReadBufferSize) {
if (minReadBufferSize <= 0) {
throw new IllegalArgumentException("minReadBufferSize: " + minReadBufferSize + " (expected: 1+)");
}
if (minReadBufferSize > maxReadBufferSize ) {
throw new IllegalArgumentException("minReadBufferSize: " + minReadBufferSize + " (expected: smaller than " + maxReadBufferSize + ')');
-
+
}
this.minReadBufferSize = minReadBufferSize;
}
@@ -90,15 +90,15 @@
public int getMaxReadBufferSize() {
return maxReadBufferSize;
}
-
+
public void setMaxReadBufferSize(int maxReadBufferSize) {
if (maxReadBufferSize <= 0) {
throw new IllegalArgumentException("maxReadBufferSize: " + maxReadBufferSize + " (expected: 1+)");
}
-
+
if (maxReadBufferSize < minReadBufferSize) {
throw new IllegalArgumentException("maxReadBufferSize: " + maxReadBufferSize + " (expected: greater than " + minReadBufferSize + ')');
-
+
}
this.maxReadBufferSize = maxReadBufferSize;
}
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/BroadcastIoSession.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/BroadcastIoSession.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/BroadcastIoSession.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/BroadcastIoSession.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 IoSession} for broadcast transports. (e.g. UDP broadcast or multicast)
- *
+ *
* <h2>Writing Back to the Broadcasting Server</h2>
* <p>
* When you implement a client that receives a broadcast message from a server
@@ -34,7 +34,7 @@
* This interface provides {@link #write(Object, SocketAddress)} method so you
* can specify the destination.
* </p>
- *
+ *
* @author The Apache MINA Project (dev@mina.apache.org)
* @version $Rev$, $Date$
*/
@@ -45,7 +45,7 @@
* will be invoked when the message is actually sent to remote peer. You can
* also wait for the returned {@link WriteFuture} if you want to wait for
* the message actually written.
- *
+ *
* @param destination <tt>null</tt> if you want the message sent to the
* default remote address
*/
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/BufferDataException.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/BufferDataException.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/BufferDataException.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/BufferDataException.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/ByteBuffer.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/ByteBuffer.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/ByteBuffer.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/ByteBuffer.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;
@@ -73,7 +73,7 @@
* <pre>
* // Prefer heap buffers to direct buffers.
* ByteBuffer.setPreferDirectBuffer(false);
- *
+ *
* // Try to allocate a heap buffer first, and then a direct buffer.
* ByteBuffer buf = ByteBuffer.allocate(1024);
* </pre>
@@ -137,7 +137,7 @@
private static ByteBufferAllocator allocator = new SimpleByteBufferAllocator();
private static boolean preferDirectBuffers = false;
-
+
/**
* An immutable empty buffer.
*/
@@ -193,7 +193,7 @@
* {@link #allocate(int, boolean)} to allocate buffers of specific type.
*
* @param capacity the capacity of the buffer
- *
+ *
* @see #setPreferDirectBuffers(boolean)
*/
public static ByteBuffer allocate(int capacity) {
@@ -647,11 +647,11 @@
/**
* Relative <i>get</i> method for reading a medium int value.
- *
+ *
* <p> Reads the next three bytes at this buffer's current position,
* composing them into an int value according to the current byte order,
* and then increments the position by three.</p>
- *
+ *
* @return The medium int value at the buffer's current position
*/
public int getMediumInt() {
@@ -667,11 +667,11 @@
/**
* Relative <i>get</i> method for reading an unsigned medium int value.
- *
+ *
* <p> Reads the next three bytes at this buffer's current position,
* composing them into an int value according to the current byte order,
* and then increments the position by three.</p>
- *
+ *
* @return The unsigned medium int value at the buffer's current position
*/
public int getUnsignedMediumInt() {
@@ -687,13 +687,13 @@
/**
* Absolute <i>get</i> method for reading a medium int value.
- *
+ *
* <p> Reads the next three bytes at this buffer's current position,
* composing them into an int value according to the current byte order.</p>
- *
+ *
* @param index The index from which the medium int will be read
* @return The medium int value at the given index
- *
+ *
* @throws IndexOutOfBoundsException
* If <tt>index</tt> is negative
* or not smaller than the buffer's limit
@@ -711,13 +711,13 @@
/**
* Absolute <i>get</i> method for reading an unsigned medium int value.
- *
+ *
* <p> Reads the next three bytes at this buffer's current position,
* composing them into an int value according to the current byte order.</p>
- *
+ *
* @param index The index from which the unsigned medium int will be read
* @return The unsigned medium int value at the given index
- *
+ *
* @throws IndexOutOfBoundsException
* If <tt>index</tt> is negative
* or not smaller than the buffer's limit
@@ -734,7 +734,7 @@
}
private int getMediumInt(byte b1, byte b2, byte b3) {
- int ret = (b1 << 16 & 0xff0000) | (b2 << 8 & 0xff00) | (b3 & 0xff);
+ int ret = b1 << 16 & 0xff0000 | b2 << 8 & 0xff00 | b3 & 0xff;
// Check to see if the medium int is negative (high bit in b1 set)
if ((b1 & 0x80) == 0x80) {
// Make the the whole int negative
@@ -1001,9 +1001,9 @@
}
/**
- * Returns hexdump of this buffer. The data and pointer are
+ * Returns hexdump of this buffer. The data and pointer are
* not changed as a result of this method call.
- *
+ *
* @return
* hexidecimal representation of this ByteBuffer
*/
@@ -1013,10 +1013,10 @@
/**
* Return hexdump of this buffer with limited length.
- *
- * @param lengthLimit The maximum number of bytes to dump from
+ *
+ * @param lengthLimit The maximum number of bytes to dump from
* the current buffer position.
- * @return
+ * @return
* hexidecimal representation of this ByteBuffer
*/
public String getHexDump(int lengthLimit) {
@@ -1078,7 +1078,7 @@
}
if (end < 0) {
- newPos = end = oldPos + ((oldLimit - oldPos) & 0xFFFFFFFE);
+ newPos = end = oldPos + (oldLimit - oldPos & 0xFFFFFFFE);
} else {
if (end + 2 <= oldLimit) {
newPos = end + 2;
@@ -1152,7 +1152,7 @@
boolean utf16 = decoder.charset().name().startsWith("UTF-16");
- if (utf16 && ((fieldSize & 1) != 0)) {
+ if (utf16 && (fieldSize & 1) != 0) {
throw new IllegalArgumentException("fieldSize is not even.");
}
@@ -1180,7 +1180,7 @@
}
} else {
for (i = oldPos; i < end; i += 2) {
- if ((get(i) == 0) && (get(i + 1) == 0)) {
+ if (get(i) == 0 && get(i + 1) == 0) {
break;
}
}
@@ -1319,7 +1319,7 @@
boolean utf16 = encoder.charset().name().startsWith("UTF-16");
- if (utf16 && ((fieldSize & 1) != 0)) {
+ if (utf16 && (fieldSize & 1) != 0) {
throw new IllegalArgumentException("fieldSize is not even.");
}
@@ -1416,7 +1416,7 @@
boolean utf16 = decoder.charset().name().startsWith("UTF-16");
- if (utf16 && ((fieldSize & 1) != 0)) {
+ if (utf16 && (fieldSize & 1) != 0) {
throw new BufferDataException(
"fieldSize is not even for a UTF-16 string.");
}
@@ -1603,7 +1603,7 @@
}
// Write the length field
- fill(padValue, padding - ((position() - oldPos) & padMask));
+ fill(padValue, padding - (position() - oldPos & padMask));
int length = position() - oldPos;
switch (prefixLength) {
case 1:
@@ -1755,7 +1755,7 @@
/**
* Returns the first occurence position of the specified byte from the current position to
* the current limit.
- *
+ *
* @return <tt>-1</tt> if the specified byte is not found
*/
public int indexOf(byte b) {
@@ -1807,7 +1807,7 @@
int r = size & 7;
if (q > 0) {
- int intValue = value | (value << 8) | (value << 16) | (value << 24);
+ int intValue = value | value << 8 | value << 16 | value << 24;
long longValue = intValue;
longValue <<= 32;
longValue |= intValue;
@@ -1821,7 +1821,7 @@
r = r & 3;
if (q > 0) {
- int intValue = value | (value << 8) | (value << 16) | (value << 24);
+ int intValue = value | value << 8 | value << 16 | value << 24;
putInt(intValue);
}
@@ -1829,7 +1829,7 @@
r = r & 1;
if (q > 0) {
- short shortValue = (short) (value | (value << 8));
+ short shortValue = (short) (value | value << 8);
putShort(shortValue);
}
@@ -1912,10 +1912,10 @@
/**
* Reads a byte from the buffer and returns the correlating enum constant defined
* by the specified enum type.
- *
+ *
* @param <E> The enum type to return
* @param enumClass The enum's class object
- * @return
+ * @return
*/
public <E extends Enum<E>> E getEnum(Class<E> enumClass) {
return toEnum(enumClass, get());
@@ -1924,11 +1924,11 @@
/**
* Reads a byte from the buffer and returns the correlating enum constant defined
* by the specified enum type.
- *
+ *
* @param <E> The enum type to return
* @param index the index from which the byte will be read
* @param enumClass The enum's class object
- * @return
+ * @return
*/
public <E extends Enum<E>> E getEnum(int index, Class<E> enumClass) {
return toEnum(enumClass, get(index));
@@ -1937,10 +1937,10 @@
/**
* Reads a short from the buffer and returns the correlating enum constant defined
* by the specified enum type.
- *
+ *
* @param <E> The enum type to return
* @param enumClass The enum's class object
- * @return
+ * @return
*/
public <E extends Enum<E>> E getEnumShort(Class<E> enumClass) {
return toEnum(enumClass, getShort());
@@ -1949,11 +1949,11 @@
/**
* Reads a short from the buffer and returns the correlating enum constant defined
* by the specified enum type.
- *
+ *
* @param <E> The enum type to return
* @param index the index from which the bytes will be read
* @param enumClass The enum's class object
- * @return
+ * @return
*/
public <E extends Enum<E>> E getEnumShort(int index, Class<E> enumClass) {
return toEnum(enumClass, getShort(index));
@@ -1962,10 +1962,10 @@
/**
* Reads an int from the buffer and returns the correlating enum constant defined
* by the specified enum type.
- *
+ *
* @param <E> The enum type to return
* @param enumClass The enum's class object
- * @return
+ * @return
*/
public <E extends Enum<E>> E getEnumInt(Class<E> enumClass) {
return toEnum(enumClass, getInt());
@@ -1974,11 +1974,11 @@
/**
* Reads an int from the buffer and returns the correlating enum constant defined
* by the specified enum type.
- *
+ *
* @param <E> The enum type to return
* @param index the index from which the bytes will be read
* @param enumClass The enum's class object
- * @return
+ * @return
*/
public <E extends Enum<E>> E getEnumInt(int index, Class<E> enumClass) {
return toEnum(enumClass, getInt(index));
@@ -1986,7 +1986,7 @@
/**
* Writes an enum's ordinal value to the buffer as a byte.
- *
+ *
* @param e The enum to write to the buffer
*/
public ByteBuffer putEnum(Enum<?> e) {
@@ -2013,7 +2013,7 @@
/**
* Writes an enum's ordinal value to the buffer as a short.
- *
+ *
* @param e The enum to write to the buffer
*/
public ByteBuffer putEnumShort(Enum<?> e) {
@@ -2026,7 +2026,7 @@
/**
* Writes an enum's ordinal value to the buffer as a short.
- *
+ *
* @param index The index at which the bytes will be written
* @param e The enum to write to the buffer
*/
@@ -2040,7 +2040,7 @@
/**
* Writes an enum's ordinal value to the buffer as an integer.
- *
+ *
* @param e The enum to write to the buffer
*/
public ByteBuffer putEnumInt(Enum<?> e) {
@@ -2049,7 +2049,7 @@
/**
* Writes an enum's ordinal value to the buffer as an integer.
- *
+ *
* @param index The index at which the bytes will be written
* @param e The enum to write to the buffer
*/
@@ -2084,11 +2084,11 @@
/**
* Reads a byte sized bit vector and converts it to an {@link EnumSet}.
- *
+ *
* <p>Each bit is mapped to a value in the specified enum. The least significant
* bit maps to the first entry in the specified enum and each subsequent bit maps
* to each subsequent bit as mapped to the subsequent enum value.</p>
- *
+ *
* @param <E> the enum type
* @param enumClass the enum class used to create the EnumSet
* @return the EnumSet representation of the bit vector
@@ -2099,7 +2099,7 @@
/**
* Reads a byte sized bit vector and converts it to an {@link EnumSet}.
- *
+ *
* @see #getEnumSet(Class)
* @param <E> the enum type
* @param index the index from which the byte will be read
@@ -2113,7 +2113,7 @@
/**
* Reads a short sized bit vector and converts it to an {@link EnumSet}.
- *
+ *
* @see #getEnumSet(Class)
* @param <E> the enum type
* @param enumClass the enum class used to create the EnumSet
@@ -2125,7 +2125,7 @@
/**
* Reads a short sized bit vector and converts it to an {@link EnumSet}.
- *
+ *
* @see #getEnumSet(Class)
* @param <E> the enum type
* @param index the index from which the bytes will be read
@@ -2139,7 +2139,7 @@
/**
* Reads an int sized bit vector and converts it to an {@link EnumSet}.
- *
+ *
* @see #getEnumSet(Class)
* @param <E> the enum type
* @param enumClass the enum class used to create the EnumSet
@@ -2151,7 +2151,7 @@
/**
* Reads an int sized bit vector and converts it to an {@link EnumSet}.
- *
+ *
* @see #getEnumSet(Class)
* @param <E> the enum type
* @param index the index from which the bytes will be read
@@ -2165,7 +2165,7 @@
/**
* Reads a long sized bit vector and converts it to an {@link EnumSet}.
- *
+ *
* @see #getEnumSet(Class)
* @param <E> the enum type
* @param enumClass the enum class used to create the EnumSet
@@ -2177,7 +2177,7 @@
/**
* Reads a long sized bit vector and converts it to an {@link EnumSet}.
- *
+ *
* @see #getEnumSet(Class)
* @param <E> the enum type
* @param index the index from which the bytes will be read
@@ -2190,7 +2190,7 @@
}
/**
- * Utility method for converting a bit vector to an EnumSet.
+ * Utility method for converting a bit vector to an EnumSet.
*/
private <E extends Enum<E>> EnumSet<E> toEnumSet(Class<E> clazz, long vector) {
EnumSet<E> set = EnumSet.noneOf(clazz);
@@ -2205,8 +2205,8 @@
}
/**
- * Writes the specified {@link Set} to the buffer as a byte sized bit vector.
- *
+ * Writes the specified {@link Set} to the buffer as a byte sized bit vector.
+ *
* @param <E> the enum type of the Set
* @param set the enum set to write to the buffer
*/
@@ -2220,8 +2220,8 @@
}
/**
- * Writes the specified {@link Set} to the buffer as a byte sized bit vector.
- *
+ * Writes the specified {@link Set} to the buffer as a byte sized bit vector.
+ *
* @param <E> the enum type of the Set
* @param index the index at which the byte will be written
* @param set the enum set to write to the buffer
@@ -2236,8 +2236,8 @@
}
/**
- * Writes the specified {@link Set} to the buffer as a short sized bit vector.
- *
+ * Writes the specified {@link Set} to the buffer as a short sized bit vector.
+ *
* @param <E> the enum type of the Set
* @param set the enum set to write to the buffer
*/
@@ -2251,8 +2251,8 @@
}
/**
- * Writes the specified {@link Set} to the buffer as a short sized bit vector.
- *
+ * Writes the specified {@link Set} to the buffer as a short sized bit vector.
+ *
* @param <E> the enum type of the Set
* @param index the index at which the bytes will be written
* @param set the enum set to write to the buffer
@@ -2267,8 +2267,8 @@
}
/**
- * Writes the specified {@link Set} to the buffer as an int sized bit vector.
- *
+ * Writes the specified {@link Set} to the buffer as an int sized bit vector.
+ *
* @param <E> the enum type of the Set
* @param set the enum set to write to the buffer
*/
@@ -2282,8 +2282,8 @@
}
/**
- * Writes the specified {@link Set} to the buffer as an int sized bit vector.
- *
+ * Writes the specified {@link Set} to the buffer as an int sized bit vector.
+ *
* @param <E> the enum type of the Set
* @param index the index at which the bytes will be written
* @param set the enum set to write to the buffer
@@ -2298,8 +2298,8 @@
}
/**
- * Writes the specified {@link Set} to the buffer as a long sized bit vector.
- *
+ * Writes the specified {@link Set} to the buffer as a long sized bit vector.
+ *
* @param <E> the enum type of the Set
* @param set the enum set to write to the buffer
*/
@@ -2308,8 +2308,8 @@
}
/**
- * Writes the specified {@link Set} to the buffer as a long sized bit vector.
- *
+ * Writes the specified {@link Set} to the buffer as a long sized bit vector.
+ *
* @param <E> the enum type of the Set
* @param index the index at which the bytes will be written
* @param set the enum set to write to the buffer
@@ -2319,7 +2319,7 @@
}
/**
- * Utility method for converting an Set to a bit vector.
+ * Utility method for converting an Set to a bit vector.
*/
private <E extends Enum<E>> long toLong(Set<E> set) {
long vector = 0;
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/ByteBufferAllocator.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/ByteBufferAllocator.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/ByteBufferAllocator.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/ByteBufferAllocator.java Sun Sep 16 16:55:27 2007
@@ -6,30 +6,30 @@
* 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;
/**
* Allocates {@link ByteBuffer}s and manages them. Please implement this
* interface if you need more advanced memory management scheme.
- *
+ *
* @author The Apache MINA Project (dev@mina.apache.org)
* @version $Rev$, $Date$
*/
public interface ByteBufferAllocator {
/**
* Returns the buffer which is capable of the specified size.
- *
+ *
* @param capacity the capacity of the buffer
* @param direct <tt>true</tt> to get a direct buffer,
* <tt>false</tt> to get a heap buffer.
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/ByteBufferHexDumper.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/ByteBufferHexDumper.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/ByteBufferHexDumper.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/ByteBufferHexDumper.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;
/**
* Provides utility methods for ByteBuffers.
- *
+ *
* @author The Apache MINA Project (dev@mina.apache.org)
* @version $Rev$, $Date$
*/
@@ -67,7 +67,7 @@
return "empty";
}
- StringBuffer out = new StringBuffer((in.remaining() * 3) - 1);
+ StringBuffer out = new StringBuffer(in.remaining() * 3 - 1);
int mark = in.position();
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/ByteBufferWrapper.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/ByteBufferWrapper.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/ByteBufferWrapper.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/ByteBufferWrapper.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;
@@ -39,7 +39,7 @@
* You can think this class like a {@link FilterOutputStream}. All operations
* are proxied by default so that you can extend this class and override existing
* operations selectively. You can introduce new operations, too.
- *
+ *
* @author The Apache MINA Project (dev@mina.apache.org)
* @version $Rev$, $Date$
*/
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/CloseFuture.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/CloseFuture.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/CloseFuture.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/CloseFuture.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;
@@ -31,7 +31,7 @@
* // Now connection should be closed.
* assert future.isClosed();
* </pre>
- *
+ *
* @author The Apache MINA Project (dev@mina.apache.org)
* @version $Rev$, $Date$
*/
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/ConnectFuture.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/ConnectFuture.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/ConnectFuture.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/ConnectFuture.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;
@@ -37,7 +37,7 @@
public interface ConnectFuture extends IoFuture {
/**
* Returns {@link IoSession} which is the result of connect operation.
- *
+ *
* @return <tt>null</tt> if the connect operation is not finished yet
* @throws RuntimeIOException if connection attempt failed by an exception
*/
@@ -45,9 +45,9 @@
/**
* Returns the cause of the connection failure.
- *
+ *
* @return <tt>null</tt> if the connect operation is not finished yet,
- * or if the connection attempt is successful.
+ * or if the connection attempt is successful.
*/
Throwable getException();
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/DefaultCloseFuture.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/DefaultCloseFuture.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/DefaultCloseFuture.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/DefaultCloseFuture.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 CloseFuture}.
- *
+ *
* @author The Apache MINA Project (dev@mina.apache.org)
* @version $Rev$, $Date$
*/
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/DefaultConnectFuture.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/DefaultConnectFuture.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/DefaultConnectFuture.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/DefaultConnectFuture.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/DefaultExceptionMonitor.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/DefaultExceptionMonitor.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/DefaultExceptionMonitor.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/DefaultExceptionMonitor.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>
* All {@link IoService}s have this implementation as a default exception
* monitor.
- *
+ *
* @author The Apache MINA Project (dev@mina.apache.org)
* @version $Rev$, $Date$
*/
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/DefaultFileRegion.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/DefaultFileRegion.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/DefaultFileRegion.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/DefaultFileRegion.java Sun Sep 16 16:55:27 2007
@@ -6,11 +6,11 @@
public class DefaultFileRegion implements FileRegion {
private final FileChannel channel;
-
+
private long originalPosition;
private long position;
private long count;
-
+
public DefaultFileRegion(FileChannel channel, long position, long count) {
if (channel == null) {
throw new IllegalArgumentException("channel can not be null");
@@ -26,7 +26,7 @@
this.position = position;
this.count = count;
}
-
+
public long getWrittenBytes() {
return position - originalPosition;
}
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/DefaultIoFilterChain.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/DefaultIoFilterChain.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/DefaultIoFilterChain.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/DefaultIoFilterChain.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;
@@ -557,9 +557,9 @@
@Override
public void filterWrite(NextFilter nextFilter, IoSession session,
WriteRequest writeRequest) throws Exception {
-
+
AbstractIoSession s = (AbstractIoSession) session;
-
+
// Maintain counters.
if (writeRequest.getMessage() instanceof ByteBuffer) {
ByteBuffer buffer = (ByteBuffer) writeRequest.getMessage();
@@ -571,7 +571,7 @@
if (remaining == 0) {
// Zero-sized buffer means the internal message
// delimiter.
- s.increaseScheduledWriteMessages();
+ s.increaseScheduledWriteMessages();
} else {
s.increaseScheduledWriteBytes(buffer.remaining());
}
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/DefaultIoFilterChainBuilder.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/DefaultIoFilterChainBuilder.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/DefaultIoFilterChainBuilder.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/DefaultIoFilterChainBuilder.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;
@@ -41,7 +41,7 @@
* doesn't manage the life cycle of the {@link IoFilter}s at all, and the
* existing {@link IoSession}s won't get affected by the changes in this builder.
* {@link IoFilterChainBuilder}s affect only newly created {@link IoSession}s.
- *
+ *
* <pre>
* IoAcceptor acceptor = ...;
* DefaultIoFilterChainBuilder builder = acceptor.getFilterChain();
@@ -61,7 +61,7 @@
public DefaultIoFilterChainBuilder() {
entries = new CopyOnWriteArrayList<Entry>();
}
-
+
/**
* Creates a new copy of the specified {@link DefaultFilterChainBuilder}.
*/
@@ -81,7 +81,7 @@
return e;
}
}
-
+
return null;
}
@@ -327,7 +327,7 @@
if (baseName == null) {
throw new NullPointerException("baseName");
}
-
+
if (!contains(baseName)) {
throw new IllegalArgumentException("Unknown filter name: "
+ baseName);
Modified: mina/trunk/core/src/main/java/org/apache/mina/common/DefaultIoFuture.java
URL: http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/DefaultIoFuture.java?rev=576217&r1=576216&r2=576217&view=diff
==============================================================================
--- mina/trunk/core/src/main/java/org/apache/mina/common/DefaultIoFuture.java (original)
+++ mina/trunk/core/src/main/java/org/apache/mina/common/DefaultIoFuture.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 @@
/**
* A default implementation of {@link IoFuture}.
- *
+ *
* @author The Apache MINA Project (dev@mina.apache.org)
* @version $Rev$, $Date$
*/
@@ -47,7 +47,7 @@
/**
* Creates a new instance.
- *
+ *
* @param session an {@link IoSession} which is associated with this future
*/
public DefaultIoFuture(IoSession session) {
@@ -121,7 +121,7 @@
}
public boolean awaitUninterruptibly(long timeoutMillis) {
- long startTime = (timeoutMillis <= 0) ? 0 : System.currentTimeMillis();
+ long startTime = timeoutMillis <= 0 ? 0 : System.currentTimeMillis();
long waitTime = timeoutMillis;
synchronized (lock) {
@@ -255,7 +255,7 @@
}
}
}
-
+
private void notifyListener(IoFutureListener l) {
try {
l.operationComplete(this);