* Changed all package names to org.jboss.netty.*
* Added .classpath, .project and target to svn:ignore
This commit is contained in:
parent
1bc79ea2a4
commit
0202a01cf1
@ -20,9 +20,9 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.bootstrap;
|
package org.jboss.netty.bootstrap;
|
||||||
|
|
||||||
import static net.gleamynode.netty.channel.Channels.*;
|
import static org.jboss.netty.channel.Channels.*;
|
||||||
|
|
||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
import java.util.HashMap;
|
import java.util.HashMap;
|
||||||
@ -33,12 +33,12 @@ import java.util.Map;
|
|||||||
import java.util.Random;
|
import java.util.Random;
|
||||||
import java.util.TreeMap;
|
import java.util.TreeMap;
|
||||||
|
|
||||||
import net.gleamynode.netty.channel.ChannelFactory;
|
import org.jboss.netty.channel.ChannelFactory;
|
||||||
import net.gleamynode.netty.channel.ChannelHandler;
|
import org.jboss.netty.channel.ChannelHandler;
|
||||||
import net.gleamynode.netty.channel.ChannelPipeline;
|
import org.jboss.netty.channel.ChannelPipeline;
|
||||||
import net.gleamynode.netty.channel.ChannelPipelineFactory;
|
import org.jboss.netty.channel.ChannelPipelineFactory;
|
||||||
import net.gleamynode.netty.channel.SimpleChannelHandler;
|
import org.jboss.netty.channel.SimpleChannelHandler;
|
||||||
import net.gleamynode.netty.logging.Logger;
|
import org.jboss.netty.logging.Logger;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @author The Netty Project (netty-dev@lists.jboss.org)
|
* @author The Netty Project (netty-dev@lists.jboss.org)
|
||||||
@ -46,7 +46,7 @@ import net.gleamynode.netty.logging.Logger;
|
|||||||
*
|
*
|
||||||
* @version $Rev$, $Date$
|
* @version $Rev$, $Date$
|
||||||
*
|
*
|
||||||
* @apiviz.uses net.gleamynode.netty.channel.ChannelFactory
|
* @apiviz.uses org.jboss.netty.channel.ChannelFactory
|
||||||
*/
|
*/
|
||||||
public class Bootstrap {
|
public class Bootstrap {
|
||||||
|
|
@ -20,24 +20,24 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.bootstrap;
|
package org.jboss.netty.bootstrap;
|
||||||
|
|
||||||
import static net.gleamynode.netty.channel.Channels.*;
|
import static org.jboss.netty.channel.Channels.*;
|
||||||
|
|
||||||
import java.net.SocketAddress;
|
import java.net.SocketAddress;
|
||||||
import java.util.concurrent.BlockingQueue;
|
import java.util.concurrent.BlockingQueue;
|
||||||
import java.util.concurrent.LinkedBlockingQueue;
|
import java.util.concurrent.LinkedBlockingQueue;
|
||||||
import java.util.concurrent.TimeUnit;
|
import java.util.concurrent.TimeUnit;
|
||||||
|
|
||||||
import net.gleamynode.netty.channel.ChannelFactory;
|
import org.jboss.netty.channel.ChannelFactory;
|
||||||
import net.gleamynode.netty.channel.ChannelFuture;
|
import org.jboss.netty.channel.ChannelFuture;
|
||||||
import net.gleamynode.netty.channel.ChannelHandlerContext;
|
import org.jboss.netty.channel.ChannelHandlerContext;
|
||||||
import net.gleamynode.netty.channel.ChannelPipeline;
|
import org.jboss.netty.channel.ChannelPipeline;
|
||||||
import net.gleamynode.netty.channel.ChannelPipelineCoverage;
|
import org.jboss.netty.channel.ChannelPipelineCoverage;
|
||||||
import net.gleamynode.netty.channel.ChannelPipelineException;
|
import org.jboss.netty.channel.ChannelPipelineException;
|
||||||
import net.gleamynode.netty.channel.ChannelStateEvent;
|
import org.jboss.netty.channel.ChannelStateEvent;
|
||||||
import net.gleamynode.netty.channel.ExceptionEvent;
|
import org.jboss.netty.channel.ExceptionEvent;
|
||||||
import net.gleamynode.netty.channel.SimpleChannelHandler;
|
import org.jboss.netty.channel.SimpleChannelHandler;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @author The Netty Project (netty-dev@lists.jboss.org)
|
* @author The Netty Project (netty-dev@lists.jboss.org)
|
@ -20,9 +20,9 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.bootstrap;
|
package org.jboss.netty.bootstrap;
|
||||||
|
|
||||||
import static net.gleamynode.netty.channel.Channels.*;
|
import static org.jboss.netty.channel.Channels.*;
|
||||||
|
|
||||||
import java.net.SocketAddress;
|
import java.net.SocketAddress;
|
||||||
import java.util.HashMap;
|
import java.util.HashMap;
|
||||||
@ -32,18 +32,18 @@ import java.util.concurrent.BlockingQueue;
|
|||||||
import java.util.concurrent.LinkedBlockingQueue;
|
import java.util.concurrent.LinkedBlockingQueue;
|
||||||
import java.util.concurrent.TimeUnit;
|
import java.util.concurrent.TimeUnit;
|
||||||
|
|
||||||
import net.gleamynode.netty.channel.Channel;
|
import org.jboss.netty.channel.Channel;
|
||||||
import net.gleamynode.netty.channel.ChannelException;
|
import org.jboss.netty.channel.ChannelException;
|
||||||
import net.gleamynode.netty.channel.ChannelFactory;
|
import org.jboss.netty.channel.ChannelFactory;
|
||||||
import net.gleamynode.netty.channel.ChannelFuture;
|
import org.jboss.netty.channel.ChannelFuture;
|
||||||
import net.gleamynode.netty.channel.ChannelHandler;
|
import org.jboss.netty.channel.ChannelHandler;
|
||||||
import net.gleamynode.netty.channel.ChannelHandlerContext;
|
import org.jboss.netty.channel.ChannelHandlerContext;
|
||||||
import net.gleamynode.netty.channel.ChannelPipeline;
|
import org.jboss.netty.channel.ChannelPipeline;
|
||||||
import net.gleamynode.netty.channel.ChannelPipelineCoverage;
|
import org.jboss.netty.channel.ChannelPipelineCoverage;
|
||||||
import net.gleamynode.netty.channel.ChannelStateEvent;
|
import org.jboss.netty.channel.ChannelStateEvent;
|
||||||
import net.gleamynode.netty.channel.ChildChannelStateEvent;
|
import org.jboss.netty.channel.ChildChannelStateEvent;
|
||||||
import net.gleamynode.netty.channel.ExceptionEvent;
|
import org.jboss.netty.channel.ExceptionEvent;
|
||||||
import net.gleamynode.netty.channel.SimpleChannelHandler;
|
import org.jboss.netty.channel.SimpleChannelHandler;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @author The Netty Project (netty-dev@lists.jboss.org)
|
* @author The Netty Project (netty-dev@lists.jboss.org)
|
@ -27,4 +27,4 @@
|
|||||||
*
|
*
|
||||||
* @apiviz.landmark
|
* @apiviz.landmark
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.bootstrap;
|
package org.jboss.netty.bootstrap;
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.buffer;
|
package org.jboss.netty.buffer;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.io.InputStream;
|
import java.io.InputStream;
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.buffer;
|
package org.jboss.netty.buffer;
|
||||||
|
|
||||||
import java.nio.ByteOrder;
|
import java.nio.ByteOrder;
|
||||||
|
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.buffer;
|
package org.jboss.netty.buffer;
|
||||||
|
|
||||||
import java.io.EOFException;
|
import java.io.EOFException;
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.buffer;
|
package org.jboss.netty.buffer;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.io.InputStream;
|
import java.io.InputStream;
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.buffer;
|
package org.jboss.netty.buffer;
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@ -29,7 +29,7 @@ package net.gleamynode.netty.buffer;
|
|||||||
*
|
*
|
||||||
* @version $Rev$, $Date$
|
* @version $Rev$, $Date$
|
||||||
*
|
*
|
||||||
* @apiviz.uses net.gleamynode.netty.buffer.ChannelBuffer
|
* @apiviz.uses org.jboss.netty.buffer.ChannelBuffer
|
||||||
*/
|
*/
|
||||||
public interface ChannelBufferIndexFinder {
|
public interface ChannelBufferIndexFinder {
|
||||||
|
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.buffer;
|
package org.jboss.netty.buffer;
|
||||||
|
|
||||||
import java.io.DataInput;
|
import java.io.DataInput;
|
||||||
import java.io.DataInputStream;
|
import java.io.DataInputStream;
|
||||||
@ -36,7 +36,7 @@ import java.io.InputStream;
|
|||||||
* @version $Rev$, $Date$
|
* @version $Rev$, $Date$
|
||||||
*
|
*
|
||||||
* @see ChannelBufferOutputStream
|
* @see ChannelBufferOutputStream
|
||||||
* @apiviz.uses net.gleamynode.netty.buffer.ChannelBuffer
|
* @apiviz.uses org.jboss.netty.buffer.ChannelBuffer
|
||||||
*/
|
*/
|
||||||
public class ChannelBufferInputStream extends InputStream implements DataInput {
|
public class ChannelBufferInputStream extends InputStream implements DataInput {
|
||||||
|
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.buffer;
|
package org.jboss.netty.buffer;
|
||||||
|
|
||||||
import java.io.DataOutput;
|
import java.io.DataOutput;
|
||||||
import java.io.DataOutputStream;
|
import java.io.DataOutputStream;
|
||||||
@ -35,7 +35,7 @@ import java.io.OutputStream;
|
|||||||
* @version $Rev$, $Date$
|
* @version $Rev$, $Date$
|
||||||
*
|
*
|
||||||
* @see ChannelBufferInputStream
|
* @see ChannelBufferInputStream
|
||||||
* @apiviz.uses net.gleamynode.netty.buffer.ChannelBuffer
|
* @apiviz.uses org.jboss.netty.buffer.ChannelBuffer
|
||||||
*/
|
*/
|
||||||
public class ChannelBufferOutputStream extends OutputStream implements DataOutput {
|
public class ChannelBufferOutputStream extends OutputStream implements DataOutput {
|
||||||
|
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.buffer;
|
package org.jboss.netty.buffer;
|
||||||
|
|
||||||
import java.nio.ByteBuffer;
|
import java.nio.ByteBuffer;
|
||||||
import java.nio.ByteOrder;
|
import java.nio.ByteOrder;
|
||||||
@ -34,7 +34,7 @@ import java.nio.ByteOrder;
|
|||||||
* This classes is intended to be used with Java 5 static import statement:
|
* This classes is intended to be used with Java 5 static import statement:
|
||||||
*
|
*
|
||||||
* <pre>
|
* <pre>
|
||||||
* import static net.gleamynode.netty.buffer.ChannelBuffers.*;
|
* import static org.jboss.netty.buffer.ChannelBuffers.*;
|
||||||
*
|
*
|
||||||
* ChannelBuffer heapBuffer = buffer(128);
|
* ChannelBuffer heapBuffer = buffer(128);
|
||||||
* ChannelBuffer directBuffer = directBuffer(256);
|
* ChannelBuffer directBuffer = directBuffer(256);
|
||||||
@ -85,7 +85,7 @@ import java.nio.ByteOrder;
|
|||||||
* @version $Rev$, $Date$
|
* @version $Rev$, $Date$
|
||||||
*
|
*
|
||||||
* @apiviz.landmark
|
* @apiviz.landmark
|
||||||
* @apiviz.has net.gleamynode.netty.buffer.ChannelBuffer oneway - - creates
|
* @apiviz.has org.jboss.netty.buffer.ChannelBuffer oneway - - creates
|
||||||
*/
|
*/
|
||||||
public class ChannelBuffers {
|
public class ChannelBuffers {
|
||||||
|
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.buffer;
|
package org.jboss.netty.buffer;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.io.InputStream;
|
import java.io.InputStream;
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.buffer;
|
package org.jboss.netty.buffer;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.io.InputStream;
|
import java.io.InputStream;
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.buffer;
|
package org.jboss.netty.buffer;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.io.InputStream;
|
import java.io.InputStream;
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.buffer;
|
package org.jboss.netty.buffer;
|
||||||
|
|
||||||
import java.io.EOFException;
|
import java.io.EOFException;
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.buffer;
|
package org.jboss.netty.buffer;
|
||||||
|
|
||||||
import java.nio.ByteOrder;
|
import java.nio.ByteOrder;
|
||||||
|
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.buffer;
|
package org.jboss.netty.buffer;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.io.InputStream;
|
import java.io.InputStream;
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.buffer;
|
package org.jboss.netty.buffer;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.io.InputStream;
|
import java.io.InputStream;
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.buffer;
|
package org.jboss.netty.buffer;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.io.InputStream;
|
import java.io.InputStream;
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.buffer;
|
package org.jboss.netty.buffer;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @author The Netty Project (netty-dev@lists.jboss.org)
|
* @author The Netty Project (netty-dev@lists.jboss.org)
|
@ -28,4 +28,4 @@
|
|||||||
* @apiviz.landmark
|
* @apiviz.landmark
|
||||||
* @apiviz.exclude ^java\.io\.[^\.]+Stream$
|
* @apiviz.exclude ^java\.io\.[^\.]+Stream$
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.buffer;
|
package org.jboss.netty.buffer;
|
@ -20,13 +20,13 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel;
|
package org.jboss.netty.channel;
|
||||||
|
|
||||||
import java.net.SocketAddress;
|
import java.net.SocketAddress;
|
||||||
import java.util.UUID;
|
import java.util.UUID;
|
||||||
import java.util.concurrent.atomic.AtomicBoolean;
|
import java.util.concurrent.atomic.AtomicBoolean;
|
||||||
|
|
||||||
import net.gleamynode.netty.util.TimeBasedUuidGenerator;
|
import org.jboss.netty.util.TimeBasedUuidGenerator;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
*
|
@ -20,9 +20,9 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel;
|
package org.jboss.netty.channel;
|
||||||
|
|
||||||
import static net.gleamynode.netty.channel.Channels.*;
|
import static org.jboss.netty.channel.Channels.*;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
*
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel;
|
package org.jboss.netty.channel;
|
||||||
|
|
||||||
import java.net.SocketAddress;
|
import java.net.SocketAddress;
|
||||||
|
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel;
|
package org.jboss.netty.channel;
|
||||||
|
|
||||||
import java.net.SocketAddress;
|
import java.net.SocketAddress;
|
||||||
import java.util.UUID;
|
import java.util.UUID;
|
||||||
@ -34,8 +34,8 @@ import java.util.UUID;
|
|||||||
* @version $Rev$, $Date$
|
* @version $Rev$, $Date$
|
||||||
*
|
*
|
||||||
* @apiviz.landmark
|
* @apiviz.landmark
|
||||||
* @apiviz.composedOf net.gleamynode.netty.channel.ChannelConfig
|
* @apiviz.composedOf org.jboss.netty.channel.ChannelConfig
|
||||||
* @apiviz.composedOf net.gleamynode.netty.channel.ChannelPipeline
|
* @apiviz.composedOf org.jboss.netty.channel.ChannelPipeline
|
||||||
*/
|
*/
|
||||||
public interface Channel {
|
public interface Channel {
|
||||||
static int OP_NONE = 0;
|
static int OP_NONE = 0;
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel;
|
package org.jboss.netty.channel;
|
||||||
|
|
||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
|
|
||||||
@ -32,7 +32,7 @@ import java.util.Map;
|
|||||||
*
|
*
|
||||||
* @version $Rev$, $Date$
|
* @version $Rev$, $Date$
|
||||||
*
|
*
|
||||||
* @apiviz.has net.gleamynode.netty.channel.ChannelPipelineFactory
|
* @apiviz.has org.jboss.netty.channel.ChannelPipelineFactory
|
||||||
*/
|
*/
|
||||||
public interface ChannelConfig {
|
public interface ChannelConfig {
|
||||||
void setOptions(Map<String, Object> options);
|
void setOptions(Map<String, Object> options);
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel;
|
package org.jboss.netty.channel;
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel;
|
package org.jboss.netty.channel;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
*
|
||||||
@ -30,7 +30,7 @@ package net.gleamynode.netty.channel;
|
|||||||
* @version $Rev$, $Date$
|
* @version $Rev$, $Date$
|
||||||
*
|
*
|
||||||
* @apiviz.landmark
|
* @apiviz.landmark
|
||||||
* @apiviz.composedOf net.gleamynode.netty.channel.ChannelFuture
|
* @apiviz.composedOf org.jboss.netty.channel.ChannelFuture
|
||||||
*/
|
*/
|
||||||
public interface ChannelEvent {
|
public interface ChannelEvent {
|
||||||
Channel getChannel();
|
Channel getChannel();
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel;
|
package org.jboss.netty.channel;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
*
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel;
|
package org.jboss.netty.channel;
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@ -31,7 +31,7 @@ package net.gleamynode.netty.channel;
|
|||||||
* @version $Rev$, $Date$
|
* @version $Rev$, $Date$
|
||||||
*
|
*
|
||||||
* @apiviz.landmark
|
* @apiviz.landmark
|
||||||
* @apiviz.has net.gleamynode.netty.channel.Channel oneway - - creates
|
* @apiviz.has org.jboss.netty.channel.Channel oneway - - creates
|
||||||
*/
|
*/
|
||||||
public interface ChannelFactory {
|
public interface ChannelFactory {
|
||||||
Channel newChannel(ChannelPipeline pipeline);
|
Channel newChannel(ChannelPipeline pipeline);
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel;
|
package org.jboss.netty.channel;
|
||||||
|
|
||||||
import java.util.concurrent.TimeUnit;
|
import java.util.concurrent.TimeUnit;
|
||||||
|
|
||||||
@ -32,7 +32,7 @@ import java.util.concurrent.TimeUnit;
|
|||||||
* @version $Rev$, $Date$
|
* @version $Rev$, $Date$
|
||||||
*
|
*
|
||||||
* @apiviz.landmark
|
* @apiviz.landmark
|
||||||
* @apiviz.owns net.gleamynode.netty.channel.ChannelFutureListener - - notifies
|
* @apiviz.owns org.jboss.netty.channel.ChannelFutureListener - - notifies
|
||||||
*/
|
*/
|
||||||
public interface ChannelFuture {
|
public interface ChannelFuture {
|
||||||
Channel getChannel();
|
Channel getChannel();
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel;
|
package org.jboss.netty.channel;
|
||||||
|
|
||||||
import java.util.EventListener;
|
import java.util.EventListener;
|
||||||
|
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel;
|
package org.jboss.netty.channel;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
*
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel;
|
package org.jboss.netty.channel;
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@ -30,7 +30,7 @@ package net.gleamynode.netty.channel;
|
|||||||
*
|
*
|
||||||
* @version $Rev$, $Date$
|
* @version $Rev$, $Date$
|
||||||
*
|
*
|
||||||
* @apiviz.owns net.gleamynode.netty.channel.ChannelHandler
|
* @apiviz.owns org.jboss.netty.channel.ChannelHandler
|
||||||
*/
|
*/
|
||||||
public interface ChannelHandlerContext {
|
public interface ChannelHandlerContext {
|
||||||
ChannelPipeline getPipeline();
|
ChannelPipeline getPipeline();
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel;
|
package org.jboss.netty.channel;
|
||||||
|
|
||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
|
|
||||||
@ -33,9 +33,9 @@ import java.util.Map;
|
|||||||
* @version $Rev$, $Date$
|
* @version $Rev$, $Date$
|
||||||
*
|
*
|
||||||
* @apiviz.landmark
|
* @apiviz.landmark
|
||||||
* @apiviz.composedOf net.gleamynode.netty.channel.ChannelHandlerContext
|
* @apiviz.composedOf org.jboss.netty.channel.ChannelHandlerContext
|
||||||
* @apiviz.owns net.gleamynode.netty.channel.ChannelHandler
|
* @apiviz.owns org.jboss.netty.channel.ChannelHandler
|
||||||
* @apiviz.uses net.gleamynode.netty.channel.ChannelSink - - sends events downstream
|
* @apiviz.uses org.jboss.netty.channel.ChannelSink - - sends events downstream
|
||||||
*/
|
*/
|
||||||
public interface ChannelPipeline {
|
public interface ChannelPipeline {
|
||||||
void addFirst (String name, ChannelHandler handler);
|
void addFirst (String name, ChannelHandler handler);
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel;
|
package org.jboss.netty.channel;
|
||||||
|
|
||||||
import java.lang.annotation.Documented;
|
import java.lang.annotation.Documented;
|
||||||
import java.lang.annotation.ElementType;
|
import java.lang.annotation.ElementType;
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel;
|
package org.jboss.netty.channel;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
*
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel;
|
package org.jboss.netty.channel;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
*
|
||||||
@ -29,7 +29,7 @@ package net.gleamynode.netty.channel;
|
|||||||
*
|
*
|
||||||
* @version $Rev$, $Date$
|
* @version $Rev$, $Date$
|
||||||
*
|
*
|
||||||
* @apiviz.has net.gleamynode.netty.channel.ChannelPipeline oneway - - creates
|
* @apiviz.has org.jboss.netty.channel.ChannelPipeline oneway - - creates
|
||||||
*/
|
*/
|
||||||
public interface ChannelPipelineFactory {
|
public interface ChannelPipelineFactory {
|
||||||
ChannelPipeline getPipeline() throws Exception;
|
ChannelPipeline getPipeline() throws Exception;
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel;
|
package org.jboss.netty.channel;
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@ -30,7 +30,7 @@ package net.gleamynode.netty.channel;
|
|||||||
*
|
*
|
||||||
* @version $Rev$, $Date$
|
* @version $Rev$, $Date$
|
||||||
*
|
*
|
||||||
* @apiviz.uses net.gleamynode.netty.channel.ChannelPipeline - - sends events upstream
|
* @apiviz.uses org.jboss.netty.channel.ChannelPipeline - - sends events upstream
|
||||||
*/
|
*/
|
||||||
public interface ChannelSink {
|
public interface ChannelSink {
|
||||||
void eventSunk(ChannelPipeline pipeline, ChannelEvent e) throws Exception;
|
void eventSunk(ChannelPipeline pipeline, ChannelEvent e) throws Exception;
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel;
|
package org.jboss.netty.channel;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
*
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel;
|
package org.jboss.netty.channel;
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@ -30,7 +30,7 @@ package net.gleamynode.netty.channel;
|
|||||||
*
|
*
|
||||||
* @version $Rev$, $Date$
|
* @version $Rev$, $Date$
|
||||||
*
|
*
|
||||||
* @apiviz.has net.gleamynode.netty.channel.ChannelState
|
* @apiviz.has org.jboss.netty.channel.ChannelState
|
||||||
*/
|
*/
|
||||||
public interface ChannelStateEvent extends ChannelEvent {
|
public interface ChannelStateEvent extends ChannelEvent {
|
||||||
ChannelState getState();
|
ChannelState getState();
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel;
|
package org.jboss.netty.channel;
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel;
|
package org.jboss.netty.channel;
|
||||||
|
|
||||||
import java.net.SocketAddress;
|
import java.net.SocketAddress;
|
||||||
import java.util.Map;
|
import java.util.Map;
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel;
|
package org.jboss.netty.channel;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
*
|
@ -20,11 +20,11 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel;
|
package org.jboss.netty.channel;
|
||||||
|
|
||||||
import java.util.concurrent.TimeUnit;
|
import java.util.concurrent.TimeUnit;
|
||||||
|
|
||||||
import net.gleamynode.netty.logging.Logger;
|
import org.jboss.netty.logging.Logger;
|
||||||
|
|
||||||
public abstract class CompleteChannelFuture implements ChannelFuture {
|
public abstract class CompleteChannelFuture implements ChannelFuture {
|
||||||
|
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel;
|
package org.jboss.netty.channel;
|
||||||
|
|
||||||
public class DefaultChannelEvent implements ChannelEvent {
|
public class DefaultChannelEvent implements ChannelEvent {
|
||||||
|
|
@ -20,13 +20,13 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel;
|
package org.jboss.netty.channel;
|
||||||
|
|
||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
import java.util.concurrent.TimeUnit;
|
import java.util.concurrent.TimeUnit;
|
||||||
|
|
||||||
import net.gleamynode.netty.logging.Logger;
|
import org.jboss.netty.logging.Logger;
|
||||||
|
|
||||||
|
|
||||||
public class DefaultChannelFuture implements ChannelFuture {
|
public class DefaultChannelFuture implements ChannelFuture {
|
@ -20,9 +20,9 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel;
|
package org.jboss.netty.channel;
|
||||||
|
|
||||||
import static net.gleamynode.netty.channel.ChannelPipelineCoverage.*;
|
import static org.jboss.netty.channel.ChannelPipelineCoverage.*;
|
||||||
|
|
||||||
import java.lang.annotation.AnnotationFormatError;
|
import java.lang.annotation.AnnotationFormatError;
|
||||||
import java.util.HashMap;
|
import java.util.HashMap;
|
||||||
@ -30,7 +30,7 @@ import java.util.LinkedHashMap;
|
|||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
import java.util.NoSuchElementException;
|
import java.util.NoSuchElementException;
|
||||||
|
|
||||||
import net.gleamynode.netty.logging.Logger;
|
import org.jboss.netty.logging.Logger;
|
||||||
|
|
||||||
|
|
||||||
public class DefaultChannelPipeline implements ChannelPipeline {
|
public class DefaultChannelPipeline implements ChannelPipeline {
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel;
|
package org.jboss.netty.channel;
|
||||||
|
|
||||||
public class DefaultChannelStateEvent extends DefaultChannelEvent implements
|
public class DefaultChannelStateEvent extends DefaultChannelEvent implements
|
||||||
ChannelStateEvent {
|
ChannelStateEvent {
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel;
|
package org.jboss.netty.channel;
|
||||||
|
|
||||||
public class DefaultChildChannelStateEvent extends DefaultChannelEvent implements
|
public class DefaultChildChannelStateEvent extends DefaultChannelEvent implements
|
||||||
ChildChannelStateEvent {
|
ChildChannelStateEvent {
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel;
|
package org.jboss.netty.channel;
|
||||||
|
|
||||||
|
|
||||||
public class DefaultExceptionEvent extends DefaultChannelEvent implements
|
public class DefaultExceptionEvent extends DefaultChannelEvent implements
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel;
|
package org.jboss.netty.channel;
|
||||||
|
|
||||||
import java.net.SocketAddress;
|
import java.net.SocketAddress;
|
||||||
|
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel;
|
package org.jboss.netty.channel;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
*
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel;
|
package org.jboss.netty.channel;
|
||||||
|
|
||||||
|
|
||||||
public class FailedChannelFuture extends CompleteChannelFuture {
|
public class FailedChannelFuture extends CompleteChannelFuture {
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel;
|
package org.jboss.netty.channel;
|
||||||
|
|
||||||
import java.net.SocketAddress;
|
import java.net.SocketAddress;
|
||||||
|
|
@ -20,9 +20,9 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel;
|
package org.jboss.netty.channel;
|
||||||
|
|
||||||
import net.gleamynode.netty.logging.Logger;
|
import org.jboss.netty.logging.Logger;
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel;
|
package org.jboss.netty.channel;
|
||||||
|
|
||||||
|
|
||||||
public class SucceededChannelFuture extends CompleteChannelFuture {
|
public class SucceededChannelFuture extends CompleteChannelFuture {
|
@ -34,4 +34,4 @@
|
|||||||
* @apiviz.exclude \.[A-Za-z]+ChannelFuture$
|
* @apiviz.exclude \.[A-Za-z]+ChannelFuture$
|
||||||
* @apiviz.exclude \.ChannelState$
|
* @apiviz.exclude \.ChannelState$
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel;
|
package org.jboss.netty.channel;
|
@ -20,10 +20,10 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel.socket;
|
package org.jboss.netty.channel.socket;
|
||||||
|
|
||||||
import net.gleamynode.netty.channel.ChannelFactory;
|
import org.jboss.netty.channel.ChannelFactory;
|
||||||
import net.gleamynode.netty.channel.ChannelPipeline;
|
import org.jboss.netty.channel.ChannelPipeline;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @author The Netty Project (netty-dev@lists.jboss.org)
|
* @author The Netty Project (netty-dev@lists.jboss.org)
|
||||||
@ -31,7 +31,7 @@ import net.gleamynode.netty.channel.ChannelPipeline;
|
|||||||
*
|
*
|
||||||
* @version $Rev$, $Date$
|
* @version $Rev$, $Date$
|
||||||
*
|
*
|
||||||
* @apiviz.has net.gleamynode.netty.channel.socket.SocketChannel oneway - - creates
|
* @apiviz.has org.jboss.netty.channel.socket.SocketChannel oneway - - creates
|
||||||
*/
|
*/
|
||||||
public interface ClientSocketChannelFactory extends ChannelFactory {
|
public interface ClientSocketChannelFactory extends ChannelFactory {
|
||||||
SocketChannel newChannel(ChannelPipeline pipeline);
|
SocketChannel newChannel(ChannelPipeline pipeline);
|
@ -20,16 +20,16 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel.socket;
|
package org.jboss.netty.channel.socket;
|
||||||
|
|
||||||
import java.net.ServerSocket;
|
import java.net.ServerSocket;
|
||||||
import java.net.SocketException;
|
import java.net.SocketException;
|
||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
import java.util.Map.Entry;
|
import java.util.Map.Entry;
|
||||||
|
|
||||||
import net.gleamynode.netty.channel.ChannelException;
|
import org.jboss.netty.channel.ChannelException;
|
||||||
import net.gleamynode.netty.channel.ChannelPipelineFactory;
|
import org.jboss.netty.channel.ChannelPipelineFactory;
|
||||||
import net.gleamynode.netty.util.ConvertUtil;
|
import org.jboss.netty.util.ConvertUtil;
|
||||||
|
|
||||||
public class DefaultServerSocketChannelConfig implements ServerSocketChannelConfig {
|
public class DefaultServerSocketChannelConfig implements ServerSocketChannelConfig {
|
||||||
|
|
@ -20,16 +20,16 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel.socket;
|
package org.jboss.netty.channel.socket;
|
||||||
|
|
||||||
import java.net.Socket;
|
import java.net.Socket;
|
||||||
import java.net.SocketException;
|
import java.net.SocketException;
|
||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
import java.util.Map.Entry;
|
import java.util.Map.Entry;
|
||||||
|
|
||||||
import net.gleamynode.netty.channel.ChannelException;
|
import org.jboss.netty.channel.ChannelException;
|
||||||
import net.gleamynode.netty.channel.ChannelPipelineFactory;
|
import org.jboss.netty.channel.ChannelPipelineFactory;
|
||||||
import net.gleamynode.netty.util.ConvertUtil;
|
import org.jboss.netty.util.ConvertUtil;
|
||||||
|
|
||||||
public class DefaultSocketChannelConfig implements SocketChannelConfig {
|
public class DefaultSocketChannelConfig implements SocketChannelConfig {
|
||||||
|
|
@ -20,11 +20,11 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel.socket;
|
package org.jboss.netty.channel.socket;
|
||||||
|
|
||||||
import java.net.InetSocketAddress;
|
import java.net.InetSocketAddress;
|
||||||
|
|
||||||
import net.gleamynode.netty.channel.Channel;
|
import org.jboss.netty.channel.Channel;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @author The Netty Project (netty-dev@lists.jboss.org)
|
* @author The Netty Project (netty-dev@lists.jboss.org)
|
||||||
@ -32,7 +32,7 @@ import net.gleamynode.netty.channel.Channel;
|
|||||||
*
|
*
|
||||||
* @version $Rev$, $Date$
|
* @version $Rev$, $Date$
|
||||||
*
|
*
|
||||||
* @apiviz.composedOf net.gleamynode.netty.channel.socket.ServerSocketChannelConfig
|
* @apiviz.composedOf org.jboss.netty.channel.socket.ServerSocketChannelConfig
|
||||||
*/
|
*/
|
||||||
public interface ServerSocketChannel extends Channel {
|
public interface ServerSocketChannel extends Channel {
|
||||||
ServerSocketChannelConfig getConfig();
|
ServerSocketChannelConfig getConfig();
|
@ -20,9 +20,9 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel.socket;
|
package org.jboss.netty.channel.socket;
|
||||||
|
|
||||||
import net.gleamynode.netty.channel.ChannelConfig;
|
import org.jboss.netty.channel.ChannelConfig;
|
||||||
|
|
||||||
public interface ServerSocketChannelConfig extends ChannelConfig {
|
public interface ServerSocketChannelConfig extends ChannelConfig {
|
||||||
int getBacklog();
|
int getBacklog();
|
@ -20,10 +20,10 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel.socket;
|
package org.jboss.netty.channel.socket;
|
||||||
|
|
||||||
import net.gleamynode.netty.channel.ChannelFactory;
|
import org.jboss.netty.channel.ChannelFactory;
|
||||||
import net.gleamynode.netty.channel.ChannelPipeline;
|
import org.jboss.netty.channel.ChannelPipeline;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @author The Netty Project (netty-dev@lists.jboss.org)
|
* @author The Netty Project (netty-dev@lists.jboss.org)
|
||||||
@ -31,7 +31,7 @@ import net.gleamynode.netty.channel.ChannelPipeline;
|
|||||||
*
|
*
|
||||||
* @version $Rev$, $Date$
|
* @version $Rev$, $Date$
|
||||||
*
|
*
|
||||||
* @apiviz.has net.gleamynode.netty.channel.socket.ServerSocketChannel oneway - - creates
|
* @apiviz.has org.jboss.netty.channel.socket.ServerSocketChannel oneway - - creates
|
||||||
*/
|
*/
|
||||||
public interface ServerSocketChannelFactory extends ChannelFactory {
|
public interface ServerSocketChannelFactory extends ChannelFactory {
|
||||||
ServerSocketChannel newChannel(ChannelPipeline pipeline);
|
ServerSocketChannel newChannel(ChannelPipeline pipeline);
|
@ -20,11 +20,11 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel.socket;
|
package org.jboss.netty.channel.socket;
|
||||||
|
|
||||||
import java.net.InetSocketAddress;
|
import java.net.InetSocketAddress;
|
||||||
|
|
||||||
import net.gleamynode.netty.channel.Channel;
|
import org.jboss.netty.channel.Channel;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @author The Netty Project (netty-dev@lists.jboss.org)
|
* @author The Netty Project (netty-dev@lists.jboss.org)
|
||||||
@ -32,7 +32,7 @@ import net.gleamynode.netty.channel.Channel;
|
|||||||
*
|
*
|
||||||
* @version $Rev$, $Date$
|
* @version $Rev$, $Date$
|
||||||
*
|
*
|
||||||
* @apiviz.composedOf net.gleamynode.netty.channel.socket.SocketChannelConfig
|
* @apiviz.composedOf org.jboss.netty.channel.socket.SocketChannelConfig
|
||||||
*/
|
*/
|
||||||
public interface SocketChannel extends Channel {
|
public interface SocketChannel extends Channel {
|
||||||
SocketChannelConfig getConfig();
|
SocketChannelConfig getConfig();
|
@ -20,9 +20,9 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel.socket;
|
package org.jboss.netty.channel.socket;
|
||||||
|
|
||||||
import net.gleamynode.netty.channel.ChannelConfig;
|
import org.jboss.netty.channel.ChannelConfig;
|
||||||
|
|
||||||
public interface SocketChannelConfig extends ChannelConfig {
|
public interface SocketChannelConfig extends ChannelConfig {
|
||||||
boolean isTcpNoDelay();
|
boolean isTcpNoDelay();
|
@ -20,12 +20,12 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel.socket.nio;
|
package org.jboss.netty.channel.socket.nio;
|
||||||
|
|
||||||
import java.net.Socket;
|
import java.net.Socket;
|
||||||
|
|
||||||
import net.gleamynode.netty.channel.socket.DefaultSocketChannelConfig;
|
import org.jboss.netty.channel.socket.DefaultSocketChannelConfig;
|
||||||
import net.gleamynode.netty.util.ConvertUtil;
|
import org.jboss.netty.util.ConvertUtil;
|
||||||
|
|
||||||
class DefaultNioSocketChannelConfig extends DefaultSocketChannelConfig
|
class DefaultNioSocketChannelConfig extends DefaultSocketChannelConfig
|
||||||
implements NioSocketChannelConfig {
|
implements NioSocketChannelConfig {
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel.socket.nio;
|
package org.jboss.netty.channel.socket.nio;
|
||||||
|
|
||||||
public class DefaultReceiveBufferSizePredictor implements
|
public class DefaultReceiveBufferSizePredictor implements
|
||||||
ReceiveBufferSizePredictor {
|
ReceiveBufferSizePredictor {
|
@ -20,16 +20,16 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel.socket.nio;
|
package org.jboss.netty.channel.socket.nio;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.nio.channels.SocketChannel;
|
import java.nio.channels.SocketChannel;
|
||||||
|
|
||||||
import net.gleamynode.netty.channel.Channel;
|
import org.jboss.netty.channel.Channel;
|
||||||
import net.gleamynode.netty.channel.ChannelException;
|
import org.jboss.netty.channel.ChannelException;
|
||||||
import net.gleamynode.netty.channel.ChannelFactory;
|
import org.jboss.netty.channel.ChannelFactory;
|
||||||
import net.gleamynode.netty.channel.ChannelPipeline;
|
import org.jboss.netty.channel.ChannelPipeline;
|
||||||
import net.gleamynode.netty.channel.ChannelSink;
|
import org.jboss.netty.channel.ChannelSink;
|
||||||
|
|
||||||
class NioAcceptedSocketChannel extends NioSocketChannel {
|
class NioAcceptedSocketChannel extends NioSocketChannel {
|
||||||
|
|
@ -20,19 +20,19 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel.socket.nio;
|
package org.jboss.netty.channel.socket.nio;
|
||||||
|
|
||||||
import static net.gleamynode.netty.channel.Channels.*;
|
import static org.jboss.netty.channel.Channels.*;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.nio.channels.SocketChannel;
|
import java.nio.channels.SocketChannel;
|
||||||
|
|
||||||
import net.gleamynode.netty.channel.ChannelException;
|
import org.jboss.netty.channel.ChannelException;
|
||||||
import net.gleamynode.netty.channel.ChannelFactory;
|
import org.jboss.netty.channel.ChannelFactory;
|
||||||
import net.gleamynode.netty.channel.ChannelFuture;
|
import org.jboss.netty.channel.ChannelFuture;
|
||||||
import net.gleamynode.netty.channel.ChannelPipeline;
|
import org.jboss.netty.channel.ChannelPipeline;
|
||||||
import net.gleamynode.netty.channel.ChannelSink;
|
import org.jboss.netty.channel.ChannelSink;
|
||||||
import net.gleamynode.netty.logging.Logger;
|
import org.jboss.netty.logging.Logger;
|
||||||
|
|
||||||
class NioClientSocketChannel extends NioSocketChannel {
|
class NioClientSocketChannel extends NioSocketChannel {
|
||||||
|
|
@ -20,14 +20,14 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel.socket.nio;
|
package org.jboss.netty.channel.socket.nio;
|
||||||
|
|
||||||
import java.util.concurrent.Executor;
|
import java.util.concurrent.Executor;
|
||||||
|
|
||||||
import net.gleamynode.netty.channel.ChannelPipeline;
|
import org.jboss.netty.channel.ChannelPipeline;
|
||||||
import net.gleamynode.netty.channel.ChannelSink;
|
import org.jboss.netty.channel.ChannelSink;
|
||||||
import net.gleamynode.netty.channel.socket.ClientSocketChannelFactory;
|
import org.jboss.netty.channel.socket.ClientSocketChannelFactory;
|
||||||
import net.gleamynode.netty.channel.socket.SocketChannel;
|
import org.jboss.netty.channel.socket.SocketChannel;
|
||||||
|
|
||||||
public class NioClientSocketChannelFactory implements ClientSocketChannelFactory {
|
public class NioClientSocketChannelFactory implements ClientSocketChannelFactory {
|
||||||
|
|
@ -20,9 +20,9 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel.socket.nio;
|
package org.jboss.netty.channel.socket.nio;
|
||||||
|
|
||||||
import static net.gleamynode.netty.channel.Channels.*;
|
import static org.jboss.netty.channel.Channels.*;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.net.SocketAddress;
|
import java.net.SocketAddress;
|
||||||
@ -35,17 +35,17 @@ import java.util.concurrent.Executor;
|
|||||||
import java.util.concurrent.atomic.AtomicBoolean;
|
import java.util.concurrent.atomic.AtomicBoolean;
|
||||||
import java.util.concurrent.atomic.AtomicInteger;
|
import java.util.concurrent.atomic.AtomicInteger;
|
||||||
|
|
||||||
import net.gleamynode.netty.channel.AbstractChannelSink;
|
import org.jboss.netty.channel.AbstractChannelSink;
|
||||||
import net.gleamynode.netty.channel.ChannelEvent;
|
import org.jboss.netty.channel.ChannelEvent;
|
||||||
import net.gleamynode.netty.channel.ChannelException;
|
import org.jboss.netty.channel.ChannelException;
|
||||||
import net.gleamynode.netty.channel.ChannelFuture;
|
import org.jboss.netty.channel.ChannelFuture;
|
||||||
import net.gleamynode.netty.channel.ChannelFutureListener;
|
import org.jboss.netty.channel.ChannelFutureListener;
|
||||||
import net.gleamynode.netty.channel.ChannelPipeline;
|
import org.jboss.netty.channel.ChannelPipeline;
|
||||||
import net.gleamynode.netty.channel.ChannelState;
|
import org.jboss.netty.channel.ChannelState;
|
||||||
import net.gleamynode.netty.channel.ChannelStateEvent;
|
import org.jboss.netty.channel.ChannelStateEvent;
|
||||||
import net.gleamynode.netty.channel.MessageEvent;
|
import org.jboss.netty.channel.MessageEvent;
|
||||||
import net.gleamynode.netty.logging.Logger;
|
import org.jboss.netty.logging.Logger;
|
||||||
import net.gleamynode.netty.util.NamePreservingRunnable;
|
import org.jboss.netty.util.NamePreservingRunnable;
|
||||||
|
|
||||||
class NioClientSocketPipelineSink extends AbstractChannelSink {
|
class NioClientSocketPipelineSink extends AbstractChannelSink {
|
||||||
|
|
@ -20,26 +20,26 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel.socket.nio;
|
package org.jboss.netty.channel.socket.nio;
|
||||||
|
|
||||||
import static net.gleamynode.netty.channel.Channels.*;
|
import static org.jboss.netty.channel.Channels.*;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.net.InetSocketAddress;
|
import java.net.InetSocketAddress;
|
||||||
import java.nio.channels.ServerSocketChannel;
|
import java.nio.channels.ServerSocketChannel;
|
||||||
|
|
||||||
import net.gleamynode.netty.channel.AbstractServerChannel;
|
import org.jboss.netty.channel.AbstractServerChannel;
|
||||||
import net.gleamynode.netty.channel.ChannelException;
|
import org.jboss.netty.channel.ChannelException;
|
||||||
import net.gleamynode.netty.channel.ChannelFactory;
|
import org.jboss.netty.channel.ChannelFactory;
|
||||||
import net.gleamynode.netty.channel.ChannelFuture;
|
import org.jboss.netty.channel.ChannelFuture;
|
||||||
import net.gleamynode.netty.channel.ChannelPipeline;
|
import org.jboss.netty.channel.ChannelPipeline;
|
||||||
import net.gleamynode.netty.channel.ChannelSink;
|
import org.jboss.netty.channel.ChannelSink;
|
||||||
import net.gleamynode.netty.channel.socket.DefaultServerSocketChannelConfig;
|
import org.jboss.netty.channel.socket.DefaultServerSocketChannelConfig;
|
||||||
import net.gleamynode.netty.channel.socket.ServerSocketChannelConfig;
|
import org.jboss.netty.channel.socket.ServerSocketChannelConfig;
|
||||||
import net.gleamynode.netty.logging.Logger;
|
import org.jboss.netty.logging.Logger;
|
||||||
|
|
||||||
class NioServerSocketChannel extends AbstractServerChannel
|
class NioServerSocketChannel extends AbstractServerChannel
|
||||||
implements net.gleamynode.netty.channel.socket.ServerSocketChannel {
|
implements org.jboss.netty.channel.socket.ServerSocketChannel {
|
||||||
|
|
||||||
private static final Logger logger =
|
private static final Logger logger =
|
||||||
Logger.getLogger(NioServerSocketChannel.class);
|
Logger.getLogger(NioServerSocketChannel.class);
|
@ -20,14 +20,14 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel.socket.nio;
|
package org.jboss.netty.channel.socket.nio;
|
||||||
|
|
||||||
import java.util.concurrent.Executor;
|
import java.util.concurrent.Executor;
|
||||||
|
|
||||||
import net.gleamynode.netty.channel.ChannelPipeline;
|
import org.jboss.netty.channel.ChannelPipeline;
|
||||||
import net.gleamynode.netty.channel.ChannelSink;
|
import org.jboss.netty.channel.ChannelSink;
|
||||||
import net.gleamynode.netty.channel.socket.ServerSocketChannel;
|
import org.jboss.netty.channel.socket.ServerSocketChannel;
|
||||||
import net.gleamynode.netty.channel.socket.ServerSocketChannelFactory;
|
import org.jboss.netty.channel.socket.ServerSocketChannelFactory;
|
||||||
|
|
||||||
public class NioServerSocketChannelFactory implements ServerSocketChannelFactory {
|
public class NioServerSocketChannelFactory implements ServerSocketChannelFactory {
|
||||||
|
|
@ -20,9 +20,9 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel.socket.nio;
|
package org.jboss.netty.channel.socket.nio;
|
||||||
|
|
||||||
import static net.gleamynode.netty.channel.Channels.*;
|
import static org.jboss.netty.channel.Channels.*;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.net.SocketAddress;
|
import java.net.SocketAddress;
|
||||||
@ -32,16 +32,16 @@ import java.nio.channels.SocketChannel;
|
|||||||
import java.util.concurrent.Executor;
|
import java.util.concurrent.Executor;
|
||||||
import java.util.concurrent.atomic.AtomicInteger;
|
import java.util.concurrent.atomic.AtomicInteger;
|
||||||
|
|
||||||
import net.gleamynode.netty.channel.AbstractChannelSink;
|
import org.jboss.netty.channel.AbstractChannelSink;
|
||||||
import net.gleamynode.netty.channel.Channel;
|
import org.jboss.netty.channel.Channel;
|
||||||
import net.gleamynode.netty.channel.ChannelEvent;
|
import org.jboss.netty.channel.ChannelEvent;
|
||||||
import net.gleamynode.netty.channel.ChannelFuture;
|
import org.jboss.netty.channel.ChannelFuture;
|
||||||
import net.gleamynode.netty.channel.ChannelPipeline;
|
import org.jboss.netty.channel.ChannelPipeline;
|
||||||
import net.gleamynode.netty.channel.ChannelState;
|
import org.jboss.netty.channel.ChannelState;
|
||||||
import net.gleamynode.netty.channel.ChannelStateEvent;
|
import org.jboss.netty.channel.ChannelStateEvent;
|
||||||
import net.gleamynode.netty.channel.MessageEvent;
|
import org.jboss.netty.channel.MessageEvent;
|
||||||
import net.gleamynode.netty.logging.Logger;
|
import org.jboss.netty.logging.Logger;
|
||||||
import net.gleamynode.netty.util.NamePreservingRunnable;
|
import org.jboss.netty.util.NamePreservingRunnable;
|
||||||
|
|
||||||
class NioServerSocketPipelineSink extends AbstractChannelSink {
|
class NioServerSocketPipelineSink extends AbstractChannelSink {
|
||||||
|
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel.socket.nio;
|
package org.jboss.netty.channel.socket.nio;
|
||||||
|
|
||||||
import java.net.InetSocketAddress;
|
import java.net.InetSocketAddress;
|
||||||
import java.net.SocketAddress;
|
import java.net.SocketAddress;
|
||||||
@ -28,13 +28,13 @@ import java.nio.channels.SocketChannel;
|
|||||||
import java.util.Queue;
|
import java.util.Queue;
|
||||||
import java.util.concurrent.ConcurrentLinkedQueue;
|
import java.util.concurrent.ConcurrentLinkedQueue;
|
||||||
|
|
||||||
import net.gleamynode.netty.channel.AbstractChannel;
|
import org.jboss.netty.channel.AbstractChannel;
|
||||||
import net.gleamynode.netty.channel.Channel;
|
import org.jboss.netty.channel.Channel;
|
||||||
import net.gleamynode.netty.channel.ChannelFactory;
|
import org.jboss.netty.channel.ChannelFactory;
|
||||||
import net.gleamynode.netty.channel.ChannelFuture;
|
import org.jboss.netty.channel.ChannelFuture;
|
||||||
import net.gleamynode.netty.channel.ChannelPipeline;
|
import org.jboss.netty.channel.ChannelPipeline;
|
||||||
import net.gleamynode.netty.channel.ChannelSink;
|
import org.jboss.netty.channel.ChannelSink;
|
||||||
import net.gleamynode.netty.channel.MessageEvent;
|
import org.jboss.netty.channel.MessageEvent;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @author The Netty Project (netty-dev@lists.jboss.org)
|
* @author The Netty Project (netty-dev@lists.jboss.org)
|
||||||
@ -44,7 +44,7 @@ import net.gleamynode.netty.channel.MessageEvent;
|
|||||||
*
|
*
|
||||||
*/
|
*/
|
||||||
abstract class NioSocketChannel extends AbstractChannel
|
abstract class NioSocketChannel extends AbstractChannel
|
||||||
implements net.gleamynode.netty.channel.socket.SocketChannel {
|
implements org.jboss.netty.channel.socket.SocketChannel {
|
||||||
|
|
||||||
final SocketChannel socket;
|
final SocketChannel socket;
|
||||||
private final NioSocketChannelConfig config;
|
private final NioSocketChannelConfig config;
|
@ -20,12 +20,12 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel.socket.nio;
|
package org.jboss.netty.channel.socket.nio;
|
||||||
|
|
||||||
import java.nio.ByteBuffer;
|
import java.nio.ByteBuffer;
|
||||||
import java.nio.channels.WritableByteChannel;
|
import java.nio.channels.WritableByteChannel;
|
||||||
|
|
||||||
import net.gleamynode.netty.channel.socket.SocketChannelConfig;
|
import org.jboss.netty.channel.socket.SocketChannelConfig;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
*
|
||||||
@ -34,7 +34,7 @@ import net.gleamynode.netty.channel.socket.SocketChannelConfig;
|
|||||||
*
|
*
|
||||||
* @version $Rev$, $Date$
|
* @version $Rev$, $Date$
|
||||||
*
|
*
|
||||||
* @apiviz.has net.gleamynode.netty.channel.socket.nio.ReceiveBufferSizePredictor
|
* @apiviz.has org.jboss.netty.channel.socket.nio.ReceiveBufferSizePredictor
|
||||||
*/
|
*/
|
||||||
public interface NioSocketChannelConfig extends SocketChannelConfig {
|
public interface NioSocketChannelConfig extends SocketChannelConfig {
|
||||||
|
|
@ -20,9 +20,9 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel.socket.nio;
|
package org.jboss.netty.channel.socket.nio;
|
||||||
|
|
||||||
import static net.gleamynode.netty.channel.Channels.*;
|
import static org.jboss.netty.channel.Channels.*;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.nio.ByteBuffer;
|
import java.nio.ByteBuffer;
|
||||||
@ -35,13 +35,13 @@ import java.util.Set;
|
|||||||
import java.util.concurrent.Executor;
|
import java.util.concurrent.Executor;
|
||||||
import java.util.concurrent.atomic.AtomicBoolean;
|
import java.util.concurrent.atomic.AtomicBoolean;
|
||||||
|
|
||||||
import net.gleamynode.netty.buffer.ChannelBuffer;
|
import org.jboss.netty.buffer.ChannelBuffer;
|
||||||
import net.gleamynode.netty.buffer.ChannelBuffers;
|
import org.jboss.netty.buffer.ChannelBuffers;
|
||||||
import net.gleamynode.netty.channel.Channel;
|
import org.jboss.netty.channel.Channel;
|
||||||
import net.gleamynode.netty.channel.ChannelException;
|
import org.jboss.netty.channel.ChannelException;
|
||||||
import net.gleamynode.netty.channel.ChannelFuture;
|
import org.jboss.netty.channel.ChannelFuture;
|
||||||
import net.gleamynode.netty.logging.Logger;
|
import org.jboss.netty.logging.Logger;
|
||||||
import net.gleamynode.netty.util.NamePreservingRunnable;
|
import org.jboss.netty.util.NamePreservingRunnable;
|
||||||
|
|
||||||
class NioWorker implements Runnable {
|
class NioWorker implements Runnable {
|
||||||
|
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel.socket.nio;
|
package org.jboss.netty.channel.socket.nio;
|
||||||
|
|
||||||
public interface ReceiveBufferSizePredictor {
|
public interface ReceiveBufferSizePredictor {
|
||||||
int nextReceiveBufferSize();
|
int nextReceiveBufferSize();
|
@ -25,4 +25,4 @@
|
|||||||
* <a href="http://en.wikipedia.org/wiki/New_I/O">NIO</a>-based socket channel
|
* <a href="http://en.wikipedia.org/wiki/New_I/O">NIO</a>-based socket channel
|
||||||
* API implementation - recommended for large number of connections (> 1000).
|
* API implementation - recommended for large number of connections (> 1000).
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel.socket.nio;
|
package org.jboss.netty.channel.socket.nio;
|
@ -20,20 +20,20 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel.socket.oio;
|
package org.jboss.netty.channel.socket.oio;
|
||||||
|
|
||||||
import static net.gleamynode.netty.channel.Channels.*;
|
import static org.jboss.netty.channel.Channels.*;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.io.OutputStream;
|
import java.io.OutputStream;
|
||||||
import java.io.PushbackInputStream;
|
import java.io.PushbackInputStream;
|
||||||
import java.net.Socket;
|
import java.net.Socket;
|
||||||
|
|
||||||
import net.gleamynode.netty.channel.Channel;
|
import org.jboss.netty.channel.Channel;
|
||||||
import net.gleamynode.netty.channel.ChannelException;
|
import org.jboss.netty.channel.ChannelException;
|
||||||
import net.gleamynode.netty.channel.ChannelFactory;
|
import org.jboss.netty.channel.ChannelFactory;
|
||||||
import net.gleamynode.netty.channel.ChannelPipeline;
|
import org.jboss.netty.channel.ChannelPipeline;
|
||||||
import net.gleamynode.netty.channel.ChannelSink;
|
import org.jboss.netty.channel.ChannelSink;
|
||||||
|
|
||||||
class OioAcceptedSocketChannel extends OioSocketChannel {
|
class OioAcceptedSocketChannel extends OioSocketChannel {
|
||||||
|
|
@ -20,17 +20,17 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel.socket.oio;
|
package org.jboss.netty.channel.socket.oio;
|
||||||
|
|
||||||
import static net.gleamynode.netty.channel.Channels.*;
|
import static org.jboss.netty.channel.Channels.*;
|
||||||
|
|
||||||
import java.io.OutputStream;
|
import java.io.OutputStream;
|
||||||
import java.io.PushbackInputStream;
|
import java.io.PushbackInputStream;
|
||||||
import java.net.Socket;
|
import java.net.Socket;
|
||||||
|
|
||||||
import net.gleamynode.netty.channel.ChannelFactory;
|
import org.jboss.netty.channel.ChannelFactory;
|
||||||
import net.gleamynode.netty.channel.ChannelPipeline;
|
import org.jboss.netty.channel.ChannelPipeline;
|
||||||
import net.gleamynode.netty.channel.ChannelSink;
|
import org.jboss.netty.channel.ChannelSink;
|
||||||
|
|
||||||
class OioClientSocketChannel extends OioSocketChannel {
|
class OioClientSocketChannel extends OioSocketChannel {
|
||||||
|
|
@ -20,13 +20,13 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel.socket.oio;
|
package org.jboss.netty.channel.socket.oio;
|
||||||
|
|
||||||
import java.util.concurrent.Executor;
|
import java.util.concurrent.Executor;
|
||||||
|
|
||||||
import net.gleamynode.netty.channel.ChannelPipeline;
|
import org.jboss.netty.channel.ChannelPipeline;
|
||||||
import net.gleamynode.netty.channel.socket.ClientSocketChannelFactory;
|
import org.jboss.netty.channel.socket.ClientSocketChannelFactory;
|
||||||
import net.gleamynode.netty.channel.socket.SocketChannel;
|
import org.jboss.netty.channel.socket.SocketChannel;
|
||||||
|
|
||||||
public class OioClientSocketChannelFactory implements ClientSocketChannelFactory {
|
public class OioClientSocketChannelFactory implements ClientSocketChannelFactory {
|
||||||
|
|
@ -20,23 +20,23 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel.socket.oio;
|
package org.jboss.netty.channel.socket.oio;
|
||||||
|
|
||||||
import static net.gleamynode.netty.channel.Channels.*;
|
import static org.jboss.netty.channel.Channels.*;
|
||||||
|
|
||||||
import java.io.PushbackInputStream;
|
import java.io.PushbackInputStream;
|
||||||
import java.net.SocketAddress;
|
import java.net.SocketAddress;
|
||||||
import java.util.concurrent.Executor;
|
import java.util.concurrent.Executor;
|
||||||
|
|
||||||
import net.gleamynode.netty.channel.AbstractChannelSink;
|
import org.jboss.netty.channel.AbstractChannelSink;
|
||||||
import net.gleamynode.netty.channel.ChannelEvent;
|
import org.jboss.netty.channel.ChannelEvent;
|
||||||
import net.gleamynode.netty.channel.ChannelFuture;
|
import org.jboss.netty.channel.ChannelFuture;
|
||||||
import net.gleamynode.netty.channel.ChannelFutureListener;
|
import org.jboss.netty.channel.ChannelFutureListener;
|
||||||
import net.gleamynode.netty.channel.ChannelPipeline;
|
import org.jboss.netty.channel.ChannelPipeline;
|
||||||
import net.gleamynode.netty.channel.ChannelState;
|
import org.jboss.netty.channel.ChannelState;
|
||||||
import net.gleamynode.netty.channel.ChannelStateEvent;
|
import org.jboss.netty.channel.ChannelStateEvent;
|
||||||
import net.gleamynode.netty.channel.MessageEvent;
|
import org.jboss.netty.channel.MessageEvent;
|
||||||
import net.gleamynode.netty.util.NamePreservingRunnable;
|
import org.jboss.netty.util.NamePreservingRunnable;
|
||||||
|
|
||||||
class OioClientSocketPipelineSink extends AbstractChannelSink {
|
class OioClientSocketPipelineSink extends AbstractChannelSink {
|
||||||
|
|
@ -20,24 +20,24 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel.socket.oio;
|
package org.jboss.netty.channel.socket.oio;
|
||||||
|
|
||||||
import static net.gleamynode.netty.channel.Channels.*;
|
import static org.jboss.netty.channel.Channels.*;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.net.InetSocketAddress;
|
import java.net.InetSocketAddress;
|
||||||
import java.net.ServerSocket;
|
import java.net.ServerSocket;
|
||||||
|
|
||||||
import net.gleamynode.netty.channel.AbstractServerChannel;
|
import org.jboss.netty.channel.AbstractServerChannel;
|
||||||
import net.gleamynode.netty.channel.ChannelException;
|
import org.jboss.netty.channel.ChannelException;
|
||||||
import net.gleamynode.netty.channel.ChannelFactory;
|
import org.jboss.netty.channel.ChannelFactory;
|
||||||
import net.gleamynode.netty.channel.ChannelFuture;
|
import org.jboss.netty.channel.ChannelFuture;
|
||||||
import net.gleamynode.netty.channel.ChannelPipeline;
|
import org.jboss.netty.channel.ChannelPipeline;
|
||||||
import net.gleamynode.netty.channel.ChannelSink;
|
import org.jboss.netty.channel.ChannelSink;
|
||||||
import net.gleamynode.netty.channel.socket.DefaultServerSocketChannelConfig;
|
import org.jboss.netty.channel.socket.DefaultServerSocketChannelConfig;
|
||||||
import net.gleamynode.netty.channel.socket.ServerSocketChannel;
|
import org.jboss.netty.channel.socket.ServerSocketChannel;
|
||||||
import net.gleamynode.netty.channel.socket.ServerSocketChannelConfig;
|
import org.jboss.netty.channel.socket.ServerSocketChannelConfig;
|
||||||
import net.gleamynode.netty.logging.Logger;
|
import org.jboss.netty.logging.Logger;
|
||||||
|
|
||||||
class OioServerSocketChannel extends AbstractServerChannel
|
class OioServerSocketChannel extends AbstractServerChannel
|
||||||
implements ServerSocketChannel {
|
implements ServerSocketChannel {
|
@ -20,14 +20,14 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel.socket.oio;
|
package org.jboss.netty.channel.socket.oio;
|
||||||
|
|
||||||
import java.util.concurrent.Executor;
|
import java.util.concurrent.Executor;
|
||||||
|
|
||||||
import net.gleamynode.netty.channel.ChannelPipeline;
|
import org.jboss.netty.channel.ChannelPipeline;
|
||||||
import net.gleamynode.netty.channel.ChannelSink;
|
import org.jboss.netty.channel.ChannelSink;
|
||||||
import net.gleamynode.netty.channel.socket.ServerSocketChannel;
|
import org.jboss.netty.channel.socket.ServerSocketChannel;
|
||||||
import net.gleamynode.netty.channel.socket.ServerSocketChannelFactory;
|
import org.jboss.netty.channel.socket.ServerSocketChannelFactory;
|
||||||
|
|
||||||
public class OioServerSocketChannelFactory implements ServerSocketChannelFactory {
|
public class OioServerSocketChannelFactory implements ServerSocketChannelFactory {
|
||||||
|
|
@ -20,9 +20,9 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel.socket.oio;
|
package org.jboss.netty.channel.socket.oio;
|
||||||
|
|
||||||
import static net.gleamynode.netty.channel.Channels.*;
|
import static org.jboss.netty.channel.Channels.*;
|
||||||
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.net.Socket;
|
import java.net.Socket;
|
||||||
@ -30,16 +30,16 @@ import java.net.SocketAddress;
|
|||||||
import java.net.SocketTimeoutException;
|
import java.net.SocketTimeoutException;
|
||||||
import java.util.concurrent.Executor;
|
import java.util.concurrent.Executor;
|
||||||
|
|
||||||
import net.gleamynode.netty.channel.AbstractChannelSink;
|
import org.jboss.netty.channel.AbstractChannelSink;
|
||||||
import net.gleamynode.netty.channel.Channel;
|
import org.jboss.netty.channel.Channel;
|
||||||
import net.gleamynode.netty.channel.ChannelEvent;
|
import org.jboss.netty.channel.ChannelEvent;
|
||||||
import net.gleamynode.netty.channel.ChannelFuture;
|
import org.jboss.netty.channel.ChannelFuture;
|
||||||
import net.gleamynode.netty.channel.ChannelPipeline;
|
import org.jboss.netty.channel.ChannelPipeline;
|
||||||
import net.gleamynode.netty.channel.ChannelState;
|
import org.jboss.netty.channel.ChannelState;
|
||||||
import net.gleamynode.netty.channel.ChannelStateEvent;
|
import org.jboss.netty.channel.ChannelStateEvent;
|
||||||
import net.gleamynode.netty.channel.MessageEvent;
|
import org.jboss.netty.channel.MessageEvent;
|
||||||
import net.gleamynode.netty.logging.Logger;
|
import org.jboss.netty.logging.Logger;
|
||||||
import net.gleamynode.netty.util.NamePreservingRunnable;
|
import org.jboss.netty.util.NamePreservingRunnable;
|
||||||
|
|
||||||
class OioServerSocketPipelineSink extends AbstractChannelSink {
|
class OioServerSocketPipelineSink extends AbstractChannelSink {
|
||||||
|
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel.socket.oio;
|
package org.jboss.netty.channel.socket.oio;
|
||||||
|
|
||||||
import java.io.OutputStream;
|
import java.io.OutputStream;
|
||||||
import java.io.PushbackInputStream;
|
import java.io.PushbackInputStream;
|
||||||
@ -28,15 +28,15 @@ import java.net.InetSocketAddress;
|
|||||||
import java.net.Socket;
|
import java.net.Socket;
|
||||||
import java.net.SocketAddress;
|
import java.net.SocketAddress;
|
||||||
|
|
||||||
import net.gleamynode.netty.channel.AbstractChannel;
|
import org.jboss.netty.channel.AbstractChannel;
|
||||||
import net.gleamynode.netty.channel.Channel;
|
import org.jboss.netty.channel.Channel;
|
||||||
import net.gleamynode.netty.channel.ChannelFactory;
|
import org.jboss.netty.channel.ChannelFactory;
|
||||||
import net.gleamynode.netty.channel.ChannelFuture;
|
import org.jboss.netty.channel.ChannelFuture;
|
||||||
import net.gleamynode.netty.channel.ChannelPipeline;
|
import org.jboss.netty.channel.ChannelPipeline;
|
||||||
import net.gleamynode.netty.channel.ChannelSink;
|
import org.jboss.netty.channel.ChannelSink;
|
||||||
import net.gleamynode.netty.channel.socket.DefaultSocketChannelConfig;
|
import org.jboss.netty.channel.socket.DefaultSocketChannelConfig;
|
||||||
import net.gleamynode.netty.channel.socket.SocketChannel;
|
import org.jboss.netty.channel.socket.SocketChannel;
|
||||||
import net.gleamynode.netty.channel.socket.SocketChannelConfig;
|
import org.jboss.netty.channel.socket.SocketChannelConfig;
|
||||||
|
|
||||||
abstract class OioSocketChannel extends AbstractChannel
|
abstract class OioSocketChannel extends AbstractChannel
|
||||||
implements SocketChannel {
|
implements SocketChannel {
|
@ -20,17 +20,17 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel.socket.oio;
|
package org.jboss.netty.channel.socket.oio;
|
||||||
|
|
||||||
import static net.gleamynode.netty.channel.Channels.*;
|
import static org.jboss.netty.channel.Channels.*;
|
||||||
|
|
||||||
import java.io.OutputStream;
|
import java.io.OutputStream;
|
||||||
import java.io.PushbackInputStream;
|
import java.io.PushbackInputStream;
|
||||||
|
|
||||||
import net.gleamynode.netty.buffer.ChannelBuffer;
|
import org.jboss.netty.buffer.ChannelBuffer;
|
||||||
import net.gleamynode.netty.buffer.ChannelBuffers;
|
import org.jboss.netty.buffer.ChannelBuffers;
|
||||||
import net.gleamynode.netty.channel.Channel;
|
import org.jboss.netty.channel.Channel;
|
||||||
import net.gleamynode.netty.channel.ChannelFuture;
|
import org.jboss.netty.channel.ChannelFuture;
|
||||||
|
|
||||||
class OioWorker implements Runnable {
|
class OioWorker implements Runnable {
|
||||||
|
|
@ -25,4 +25,4 @@
|
|||||||
* Old blocking I/O based socket channel API implementation - recommended for
|
* Old blocking I/O based socket channel API implementation - recommended for
|
||||||
* small number of connections (< 1000).
|
* small number of connections (< 1000).
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel.socket.oio;
|
package org.jboss.netty.channel.socket.oio;
|
@ -24,4 +24,4 @@
|
|||||||
/**
|
/**
|
||||||
* Abstract TCP and UDP socket interfaces which extend the core channel API.
|
* Abstract TCP and UDP socket interfaces which extend the core channel API.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.channel.socket;
|
package org.jboss.netty.channel.socket;
|
@ -20,14 +20,14 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.example.discard;
|
package org.jboss.netty.example.discard;
|
||||||
|
|
||||||
import java.net.InetSocketAddress;
|
import java.net.InetSocketAddress;
|
||||||
import java.util.concurrent.Executors;
|
import java.util.concurrent.Executors;
|
||||||
|
|
||||||
import net.gleamynode.netty.bootstrap.ClientBootstrap;
|
import org.jboss.netty.bootstrap.ClientBootstrap;
|
||||||
import net.gleamynode.netty.channel.ChannelFactory;
|
import org.jboss.netty.channel.ChannelFactory;
|
||||||
import net.gleamynode.netty.channel.socket.nio.NioClientSocketChannelFactory;
|
import org.jboss.netty.channel.socket.nio.NioClientSocketChannelFactory;
|
||||||
|
|
||||||
public class DiscardClient {
|
public class DiscardClient {
|
||||||
|
|
@ -20,23 +20,23 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.example.discard;
|
package org.jboss.netty.example.discard;
|
||||||
|
|
||||||
import java.util.Random;
|
import java.util.Random;
|
||||||
import java.util.concurrent.atomic.AtomicLong;
|
import java.util.concurrent.atomic.AtomicLong;
|
||||||
import java.util.logging.Level;
|
import java.util.logging.Level;
|
||||||
import java.util.logging.Logger;
|
import java.util.logging.Logger;
|
||||||
|
|
||||||
import net.gleamynode.netty.buffer.ChannelBuffer;
|
import org.jboss.netty.buffer.ChannelBuffer;
|
||||||
import net.gleamynode.netty.buffer.ChannelBuffers;
|
import org.jboss.netty.buffer.ChannelBuffers;
|
||||||
import net.gleamynode.netty.channel.Channel;
|
import org.jboss.netty.channel.Channel;
|
||||||
import net.gleamynode.netty.channel.ChannelEvent;
|
import org.jboss.netty.channel.ChannelEvent;
|
||||||
import net.gleamynode.netty.channel.ChannelHandlerContext;
|
import org.jboss.netty.channel.ChannelHandlerContext;
|
||||||
import net.gleamynode.netty.channel.ChannelPipelineCoverage;
|
import org.jboss.netty.channel.ChannelPipelineCoverage;
|
||||||
import net.gleamynode.netty.channel.ChannelStateEvent;
|
import org.jboss.netty.channel.ChannelStateEvent;
|
||||||
import net.gleamynode.netty.channel.ExceptionEvent;
|
import org.jboss.netty.channel.ExceptionEvent;
|
||||||
import net.gleamynode.netty.channel.MessageEvent;
|
import org.jboss.netty.channel.MessageEvent;
|
||||||
import net.gleamynode.netty.channel.SimpleChannelHandler;
|
import org.jboss.netty.channel.SimpleChannelHandler;
|
||||||
|
|
||||||
@ChannelPipelineCoverage("all")
|
@ChannelPipelineCoverage("all")
|
||||||
public class DiscardHandler extends SimpleChannelHandler {
|
public class DiscardHandler extends SimpleChannelHandler {
|
@ -20,14 +20,14 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.example.discard;
|
package org.jboss.netty.example.discard;
|
||||||
|
|
||||||
import java.net.InetSocketAddress;
|
import java.net.InetSocketAddress;
|
||||||
import java.util.concurrent.Executors;
|
import java.util.concurrent.Executors;
|
||||||
|
|
||||||
import net.gleamynode.netty.bootstrap.ServerBootstrap;
|
import org.jboss.netty.bootstrap.ServerBootstrap;
|
||||||
import net.gleamynode.netty.channel.ChannelFactory;
|
import org.jboss.netty.channel.ChannelFactory;
|
||||||
import net.gleamynode.netty.channel.socket.nio.NioServerSocketChannelFactory;
|
import org.jboss.netty.channel.socket.nio.NioServerSocketChannelFactory;
|
||||||
|
|
||||||
public class DiscardServer {
|
public class DiscardServer {
|
||||||
|
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.example.discard;
|
package org.jboss.netty.example.discard;
|
||||||
|
|
||||||
public class ThroughputMonitor extends Thread {
|
public class ThroughputMonitor extends Thread {
|
||||||
|
|
@ -20,14 +20,14 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.example.echo;
|
package org.jboss.netty.example.echo;
|
||||||
|
|
||||||
import java.net.InetSocketAddress;
|
import java.net.InetSocketAddress;
|
||||||
import java.util.concurrent.Executors;
|
import java.util.concurrent.Executors;
|
||||||
|
|
||||||
import net.gleamynode.netty.bootstrap.ClientBootstrap;
|
import org.jboss.netty.bootstrap.ClientBootstrap;
|
||||||
import net.gleamynode.netty.channel.ChannelFactory;
|
import org.jboss.netty.channel.ChannelFactory;
|
||||||
import net.gleamynode.netty.channel.socket.nio.NioClientSocketChannelFactory;
|
import org.jboss.netty.channel.socket.nio.NioClientSocketChannelFactory;
|
||||||
|
|
||||||
public class EchoClient {
|
public class EchoClient {
|
||||||
|
|
@ -20,21 +20,21 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.example.echo;
|
package org.jboss.netty.example.echo;
|
||||||
|
|
||||||
import java.util.concurrent.atomic.AtomicLong;
|
import java.util.concurrent.atomic.AtomicLong;
|
||||||
import java.util.logging.Level;
|
import java.util.logging.Level;
|
||||||
import java.util.logging.Logger;
|
import java.util.logging.Logger;
|
||||||
|
|
||||||
import net.gleamynode.netty.buffer.ChannelBuffer;
|
import org.jboss.netty.buffer.ChannelBuffer;
|
||||||
import net.gleamynode.netty.buffer.ChannelBuffers;
|
import org.jboss.netty.buffer.ChannelBuffers;
|
||||||
import net.gleamynode.netty.channel.ChannelEvent;
|
import org.jboss.netty.channel.ChannelEvent;
|
||||||
import net.gleamynode.netty.channel.ChannelHandlerContext;
|
import org.jboss.netty.channel.ChannelHandlerContext;
|
||||||
import net.gleamynode.netty.channel.ChannelPipelineCoverage;
|
import org.jboss.netty.channel.ChannelPipelineCoverage;
|
||||||
import net.gleamynode.netty.channel.ChannelStateEvent;
|
import org.jboss.netty.channel.ChannelStateEvent;
|
||||||
import net.gleamynode.netty.channel.ExceptionEvent;
|
import org.jboss.netty.channel.ExceptionEvent;
|
||||||
import net.gleamynode.netty.channel.MessageEvent;
|
import org.jboss.netty.channel.MessageEvent;
|
||||||
import net.gleamynode.netty.channel.SimpleChannelHandler;
|
import org.jboss.netty.channel.SimpleChannelHandler;
|
||||||
|
|
||||||
@ChannelPipelineCoverage("all")
|
@ChannelPipelineCoverage("all")
|
||||||
public class EchoHandler extends SimpleChannelHandler {
|
public class EchoHandler extends SimpleChannelHandler {
|
@ -20,14 +20,14 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.example.echo;
|
package org.jboss.netty.example.echo;
|
||||||
|
|
||||||
import java.net.InetSocketAddress;
|
import java.net.InetSocketAddress;
|
||||||
import java.util.concurrent.Executors;
|
import java.util.concurrent.Executors;
|
||||||
|
|
||||||
import net.gleamynode.netty.bootstrap.ServerBootstrap;
|
import org.jboss.netty.bootstrap.ServerBootstrap;
|
||||||
import net.gleamynode.netty.channel.ChannelFactory;
|
import org.jboss.netty.channel.ChannelFactory;
|
||||||
import net.gleamynode.netty.channel.socket.nio.NioServerSocketChannelFactory;
|
import org.jboss.netty.channel.socket.nio.NioServerSocketChannelFactory;
|
||||||
|
|
||||||
public class EchoServer {
|
public class EchoServer {
|
||||||
|
|
@ -20,7 +20,7 @@
|
|||||||
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
* Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
|
||||||
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
* 02110-1301 USA, or see the FSF site: http://www.fsf.org.
|
||||||
*/
|
*/
|
||||||
package net.gleamynode.netty.example.echo;
|
package org.jboss.netty.example.echo;
|
||||||
|
|
||||||
public class ThroughputMonitor extends Thread {
|
public class ThroughputMonitor extends Thread {
|
||||||
|
|
Some files were not shown because too many files have changed in this diff Show More
Loading…
Reference in New Issue
Block a user