Remove @author and @version / Remove COPYRIGHT.txt
* The new copyright header replaces @author * COPYRIGHT.txt is irrelevant to us now.
This commit is contained in:
Trustin Lee
parent
015daec3fa
commit
59f39cae75
|
|
@ -1,16 +0,0 @@
|
|||
The Netty Project - Copyright 2009 Red Hat, Inc, and is licensed under the
|
||||
Apache License version 2.0 as published by the Apache Software Foundation.
|
||||
|
||||
A summary of the individual contributors is given below. Any omission should be
|
||||
sent to Trustin Lee <trustin@gmail.com>.
|
||||
|
||||
SVN Login(s) Name
|
||||
-------------------------------------------------------------------------------
|
||||
amit.bhayani@jboss.com Amit Bhayani
|
||||
ataylor Andy Taylor
|
||||
beve Daniel Bevenius
|
||||
fredbregier Frederic Bregier
|
||||
trustin Trustin Heuiseung Lee
|
||||
-------------------------------------------------------------------------------
|
||||
|
||||
* JBoss is a registered trademark of Red Hat, Inc.
|
||||
|
|
@ -39,10 +39,6 @@ import io.netty.util.ExternalResourceReleasable;
|
|||
* structure. Please refer to {@link ClientBootstrap}, {@link ServerBootstrap},
|
||||
* and {@link ConnectionlessBootstrap} for client side, server-side, and
|
||||
* connectionless (e.g. UDP) channel initialization respectively.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @apiviz.uses io.netty.channel.ChannelFactory
|
||||
*/
|
||||
public class Bootstrap implements ExternalResourceReleasable {
|
||||
|
|
|
|||
|
|
@ -102,10 +102,6 @@ import io.netty.channel.Channels;
|
|||
* {@link ClientBootstrap} instances as you want with the same
|
||||
* {@link ChannelFactory} to apply different settings for different
|
||||
* {@link Channel}s.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @apiviz.landmark
|
||||
*/
|
||||
public class ClientBootstrap extends Bootstrap {
|
||||
|
|
|
|||
|
|
@ -111,10 +111,6 @@ import io.netty.channel.Channels;
|
|||
* many {@link ConnectionlessBootstrap} instances as you want with the same
|
||||
* {@link ChannelFactory} to apply different settings for different
|
||||
* {@link Channel}s.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @apiviz.landmark
|
||||
*/
|
||||
public class ConnectionlessBootstrap extends Bootstrap {
|
||||
|
|
|
|||
|
|
@ -152,10 +152,6 @@ import io.netty.channel.SimpleChannelUpstreamHandler;
|
|||
* {@link ServerBootstrap} instances as you want with the same
|
||||
* {@link ChannelFactory} to apply different settings for different
|
||||
* {@link Channel}s.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @apiviz.landmark
|
||||
*/
|
||||
public class ServerBootstrap extends Bootstrap {
|
||||
|
|
|
|||
|
|
@ -26,9 +26,6 @@ import java.nio.charset.Charset;
|
|||
|
||||
/**
|
||||
* A skeletal implementation of a buffer.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public abstract class AbstractChannelBuffer implements ChannelBuffer {
|
||||
|
||||
|
|
|
|||
|
|
@ -19,9 +19,6 @@ import java.nio.ByteOrder;
|
|||
|
||||
/**
|
||||
* A skeletal implementation of {@link ChannelBufferFactory}.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public abstract class AbstractChannelBufferFactory implements ChannelBufferFactory {
|
||||
|
||||
|
|
|
|||
|
|
@ -22,9 +22,6 @@ import java.nio.ByteOrder;
|
|||
* A big-endian Java heap buffer. It is recommended to use {@link ChannelBuffers#buffer(int)}
|
||||
* and {@link ChannelBuffers#wrappedBuffer(byte[])} instead of calling the
|
||||
* constructor explicitly.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public class BigEndianHeapChannelBuffer extends HeapChannelBuffer {
|
||||
|
||||
|
|
|
|||
|
|
@ -28,9 +28,6 @@ import java.nio.channels.ScatteringByteChannel;
|
|||
* A NIO {@link ByteBuffer} based buffer. It is recommended to use {@link ChannelBuffers#directBuffer(int)}
|
||||
* and {@link ChannelBuffers#wrappedBuffer(ByteBuffer)} instead of calling the
|
||||
* constructor explicitly.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public class ByteBufferBackedChannelBuffer extends AbstractChannelBuffer {
|
||||
|
||||
|
|
|
|||
|
|
@ -130,8 +130,6 @@ import java.nio.charset.UnsupportedCharsetException;
|
|||
* +-------------------+------------------+------------------+
|
||||
* | | | |
|
||||
* 0 <= readerIndex <= writerIndex <= capacity
|
||||
*
|
||||
*
|
||||
* AFTER discardReadBytes()
|
||||
*
|
||||
* +------------------+--------------------------------------+
|
||||
|
|
@ -162,8 +160,6 @@ import java.nio.charset.UnsupportedCharsetException;
|
|||
* +-------------------+------------------+------------------+
|
||||
* | | | |
|
||||
* 0 <= readerIndex <= writerIndex <= capacity
|
||||
*
|
||||
*
|
||||
* AFTER clear()
|
||||
*
|
||||
* +---------------------------------------------------------+
|
||||
|
|
@ -228,10 +224,6 @@ import java.nio.charset.UnsupportedCharsetException;
|
|||
*
|
||||
* Please refer to {@link ChannelBufferInputStream} and
|
||||
* {@link ChannelBufferOutputStream}.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @apiviz.landmark
|
||||
*/
|
||||
public interface ChannelBuffer extends Comparable<ChannelBuffer> {
|
||||
|
|
@ -1360,8 +1352,7 @@ public interface ChannelBuffer extends Comparable<ChannelBuffer> {
|
|||
* @throws IndexOutOfBoundsException
|
||||
* if {@code src.readableBytes} is greater than
|
||||
* {@code this.writableBytes}
|
||||
*
|
||||
*/
|
||||
*/
|
||||
void writeBytes(ChannelBuffer src);
|
||||
|
||||
/**
|
||||
|
|
@ -1615,8 +1606,7 @@ public interface ChannelBuffer extends Comparable<ChannelBuffer> {
|
|||
* This method is identical to {@code buf.copy(buf.readerIndex(), buf.readableBytes())}.
|
||||
* This method does not modify {@code readerIndex} or {@code writerIndex} of
|
||||
* this buffer.
|
||||
*
|
||||
*/
|
||||
*/
|
||||
ChannelBuffer copy();
|
||||
|
||||
/**
|
||||
|
|
|
|||
|
|
@ -20,9 +20,6 @@ import java.nio.ByteOrder;
|
|||
|
||||
/**
|
||||
* A factory that creates or pools {@link ChannelBuffer}s.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public interface ChannelBufferFactory {
|
||||
|
||||
|
|
|
|||
|
|
@ -24,10 +24,6 @@ package io.netty.buffer;
|
|||
* refer to {@link ChannelBuffer#indexOf(int, int, ChannelBufferIndexFinder)} and
|
||||
* {@link ChannelBuffer#bytesBefore(int, int, ChannelBufferIndexFinder)}
|
||||
* for more explanation.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @apiviz.uses io.netty.buffer.ChannelBuffer
|
||||
*/
|
||||
public interface ChannelBufferIndexFinder {
|
||||
|
|
|
|||
|
|
@ -31,10 +31,6 @@ import java.io.InputStream;
|
|||
* This stream implements {@link DataInput} for your convenience.
|
||||
* The endianness of the stream is not always big endian but depends on
|
||||
* the endianness of the underlying buffer.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @see ChannelBufferOutputStream
|
||||
* @apiviz.uses io.netty.buffer.ChannelBuffer
|
||||
*/
|
||||
|
|
|
|||
|
|
@ -30,10 +30,6 @@ import java.io.OutputStream;
|
|||
* This stream implements {@link DataOutput} for your convenience.
|
||||
* The endianness of the stream is not always big endian but depends on
|
||||
* the endianness of the underlying buffer.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @see ChannelBufferInputStream
|
||||
* @apiviz.uses io.netty.buffer.ChannelBuffer
|
||||
*/
|
||||
|
|
|
|||
|
|
@ -81,10 +81,6 @@ import io.netty.util.CharsetUtil;
|
|||
* This class also provides various utility methods to help implementation
|
||||
* of a new buffer type, generation of hex dump and swapping an integer's
|
||||
* byte order.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @apiviz.landmark
|
||||
* @apiviz.has io.netty.buffer.ChannelBuffer oneway - - creates
|
||||
*/
|
||||
|
|
|
|||
|
|
@ -31,10 +31,6 @@ import java.util.List;
|
|||
* A virtual buffer which shows multiple buffers as a single merged buffer. It
|
||||
* is recommended to use {@link ChannelBuffers#wrappedBuffer(ChannelBuffer...)}
|
||||
* instead of calling the constructor explicitly.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
* @author Frederic Bregier (fredbregier@free.fr)
|
||||
*/
|
||||
public class CompositeChannelBuffer extends AbstractChannelBuffer {
|
||||
|
||||
|
|
|
|||
|
|
@ -29,9 +29,6 @@ import java.nio.ByteOrder;
|
|||
* is much lower than the GC throughput of heap buffers. This factory avoids
|
||||
* this problem by allocating a large chunk of pre-allocated direct buffer and
|
||||
* reducing the number of the garbage collected internal direct buffer objects.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public class DirectChannelBufferFactory extends AbstractChannelBufferFactory {
|
||||
|
||||
|
|
|
|||
|
|
@ -28,9 +28,6 @@ import java.nio.channels.ScatteringByteChannel;
|
|||
* A derived buffer which simply forwards all data access requests to its
|
||||
* parent. It is recommended to use {@link ChannelBuffer#duplicate()} instead
|
||||
* of calling the constructor explicitly.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public class DuplicatedChannelBuffer extends AbstractChannelBuffer implements WrappedChannelBuffer {
|
||||
|
||||
|
|
|
|||
|
|
@ -28,9 +28,6 @@ import java.nio.channels.ScatteringByteChannel;
|
|||
* A dynamic capacity buffer which increases its capacity as needed. It is
|
||||
* recommended to use {@link ChannelBuffers#dynamicBuffer(int)} instead of
|
||||
* calling the constructor explicitly.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public class DynamicChannelBuffer extends AbstractChannelBuffer {
|
||||
|
||||
|
|
|
|||
|
|
@ -25,9 +25,6 @@ import java.nio.channels.ScatteringByteChannel;
|
|||
|
||||
/**
|
||||
* A skeletal implementation for Java heap buffers.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public abstract class HeapChannelBuffer extends AbstractChannelBuffer {
|
||||
|
||||
|
|
|
|||
|
|
@ -23,9 +23,6 @@ import java.nio.ByteOrder;
|
|||
* the specified capacity. {@link HeapChannelBufferFactory} should perform
|
||||
* very well in most situations because it relies on the JVM garbage collector,
|
||||
* which is highly optimized for heap allocation.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public class HeapChannelBufferFactory extends AbstractChannelBufferFactory {
|
||||
|
||||
|
|
|
|||
|
|
@ -22,9 +22,6 @@ import java.nio.ByteOrder;
|
|||
* A little-endian Java heap buffer. It is recommended to use {@link ChannelBuffers#buffer(ByteOrder, int)}
|
||||
* and {@link ChannelBuffers#wrappedBuffer(ByteOrder, byte[])} instead of
|
||||
* calling the constructor explicitly.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public class LittleEndianHeapChannelBuffer extends HeapChannelBuffer {
|
||||
|
||||
|
|
|
|||
|
|
@ -28,9 +28,6 @@ import java.nio.channels.ScatteringByteChannel;
|
|||
* A derived buffer which forbids any write requests to its parent. It is
|
||||
* recommended to use {@link ChannelBuffers#unmodifiableBuffer(ChannelBuffer)}
|
||||
* instead of calling the constructor explicitly.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public class ReadOnlyChannelBuffer extends AbstractChannelBuffer implements WrappedChannelBuffer {
|
||||
|
||||
|
|
|
|||
|
|
@ -29,9 +29,6 @@ import java.nio.channels.ScatteringByteChannel;
|
|||
* recommended to use {@link ChannelBuffer#slice()} and
|
||||
* {@link ChannelBuffer#slice(int, int)} instead of calling the constructor
|
||||
* explicitly.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public class SlicedChannelBuffer extends AbstractChannelBuffer implements WrappedChannelBuffer {
|
||||
|
||||
|
|
|
|||
|
|
@ -29,9 +29,6 @@ import java.nio.channels.ScatteringByteChannel;
|
|||
* It is recommended to use {@link ChannelBuffer#slice()} and
|
||||
* {@link ChannelBuffer#slice(int, int)} instead of calling the constructor
|
||||
* explicitly.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public class TruncatedChannelBuffer extends AbstractChannelBuffer implements WrappedChannelBuffer {
|
||||
|
||||
|
|
|
|||
|
|
@ -18,9 +18,6 @@ package io.netty.buffer;
|
|||
/**
|
||||
* The common interface for buffer wrappers and derived buffers. Most users won't
|
||||
* need to use this interface. It is used internally in most cases.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public interface WrappedChannelBuffer extends ChannelBuffer {
|
||||
/**
|
||||
|
|
|
|||
|
|
@ -22,10 +22,6 @@ import io.netty.util.internal.ConcurrentHashMap;
|
|||
|
||||
/**
|
||||
* A skeletal {@link Channel} implementation.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
*/
|
||||
public abstract class AbstractChannel implements Channel {
|
||||
|
||||
|
|
|
|||
|
|
@ -19,9 +19,6 @@ import static io.netty.channel.Channels.*;
|
|||
|
||||
/**
|
||||
* A skeletal {@link ChannelSink} implementation.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public abstract class AbstractChannelSink implements ChannelSink {
|
||||
|
||||
|
|
|
|||
|
|
@ -29,9 +29,6 @@ import java.net.SocketAddress;
|
|||
* <li>{@link #write(Object, SocketAddress)}</li>
|
||||
* <li>and the shortcut methods which calls the methods mentioned above
|
||||
* </ul>
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public abstract class AbstractServerChannel extends AbstractChannel implements ServerChannel {
|
||||
|
||||
|
|
|
|||
|
|
@ -27,9 +27,6 @@ import java.util.List;
|
|||
* number of readable bytes if the read operation was not able to fill a certain
|
||||
* amount of the allocated buffer two times consecutively. Otherwise, it keeps
|
||||
* returning the same prediction.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public class AdaptiveReceiveBufferSizePredictor implements
|
||||
ReceiveBufferSizePredictor {
|
||||
|
|
|
|||
|
|
@ -19,9 +19,6 @@ package io.netty.channel;
|
|||
/**
|
||||
* The {@link ReceiveBufferSizePredictorFactory} that creates a new
|
||||
* {@link AdaptiveReceiveBufferSizePredictor}.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public class AdaptiveReceiveBufferSizePredictorFactory implements
|
||||
ReceiveBufferSizePredictorFactory {
|
||||
|
|
|
|||
|
|
@ -99,10 +99,6 @@ import io.netty.channel.socket.nio.NioSocketChannelConfig;
|
|||
* {@code writeBufferHighWaterMark} properties in {@link NioSocketChannelConfig}
|
||||
* to determine when to set or clear the {@link #OP_WRITE} flag.
|
||||
* </p>
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @apiviz.landmark
|
||||
* @apiviz.composedOf io.netty.channel.ChannelConfig
|
||||
* @apiviz.composedOf io.netty.channel.ChannelPipeline
|
||||
|
|
@ -374,7 +370,6 @@ public interface Channel extends Comparable<Channel> {
|
|||
|
||||
/**
|
||||
* Attaches an object to this {@link Channel} to store a stateful information
|
||||
*
|
||||
*/
|
||||
*/
|
||||
void setAttachment(Object attachment);
|
||||
}
|
||||
|
|
|
|||
|
|
@ -59,10 +59,6 @@ import io.netty.channel.socket.nio.NioSocketChannelConfig;
|
|||
* More options are available in the sub-types of {@link ChannelConfig}. For
|
||||
* example, you can configure the parameters which are specific to a TCP/IP
|
||||
* socket as explained in {@link SocketChannelConfig} or {@link NioSocketChannelConfig}.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @apiviz.has io.netty.channel.ChannelPipelineFactory
|
||||
* @apiviz.composedOf io.netty.channel.ReceiveBufferSizePredictor
|
||||
*
|
||||
|
|
|
|||
|
|
@ -67,10 +67,6 @@ package io.netty.channel;
|
|||
* may be invoked by more than one thread simultaneously. If the handler
|
||||
* accesses a shared resource or stores stateful information, you might need
|
||||
* proper synchronization in the handler implementation.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @apiviz.exclude ^org\.jboss\.netty\.handler\..*$
|
||||
*/
|
||||
public interface ChannelDownstreamHandler extends ChannelHandler {
|
||||
|
|
|
|||
|
|
@ -177,10 +177,6 @@ import io.netty.channel.socket.ServerSocketChannel;
|
|||
* Please refer to the {@link ChannelHandler} and {@link ChannelPipeline}
|
||||
* documentation to find out how an event flows in a pipeline and how to handle
|
||||
* the event in your application.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @apiviz.landmark
|
||||
* @apiviz.composedOf io.netty.channel.ChannelFuture
|
||||
*/
|
||||
|
|
|
|||
|
|
@ -17,10 +17,6 @@ package io.netty.channel;
|
|||
|
||||
/**
|
||||
* A {@link RuntimeException} which is thrown when an I/O operation fails.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @apiviz.hidden
|
||||
*/
|
||||
public class ChannelException extends RuntimeException {
|
||||
|
|
|
|||
|
|
@ -46,10 +46,6 @@ import io.netty.util.ExternalResourceReleasable;
|
|||
* For detailed transport-specific information on shutting down a factory,
|
||||
* please refer to the Javadoc of {@link ChannelFactory}'s subtypes, such as
|
||||
* {@link NioServerSocketChannelFactory}.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @apiviz.landmark
|
||||
* @apiviz.has io.netty.channel.Channel oneway - - creates
|
||||
*
|
||||
|
|
|
|||
|
|
@ -163,10 +163,6 @@ import io.netty.handler.execution.ExecutionHandler;
|
|||
* // Connection established successfully
|
||||
* }
|
||||
* </pre>
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @apiviz.landmark
|
||||
* @apiviz.owns io.netty.channel.ChannelFutureListener - - notifies
|
||||
*/
|
||||
|
|
|
|||
|
|
@ -24,10 +24,6 @@ import java.util.Set;
|
|||
* Class which is used to consolidate multiple channel futures into one, by
|
||||
* listening to the individual futures and producing an aggregated result
|
||||
* (success/failure) when all futures have completed.
|
||||
*
|
||||
* @author The Netty Project (netty-dev@lists.jboss.org)
|
||||
* @author Iain McGinniss (iain.mcginniss@onedrum.com)
|
||||
* @author OneDrum Ltd.
|
||||
*/
|
||||
public class ChannelFutureAggregator implements ChannelFutureListener {
|
||||
|
||||
|
|
|
|||
|
|
@ -29,9 +29,6 @@ import java.util.EventListener;
|
|||
* in the handler method can cause an unexpected pause during I/O. If you need
|
||||
* to perform a blocking operation on I/O completion, try to execute the
|
||||
* operation in a different thread using a thread pool.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public interface ChannelFutureListener extends EventListener {
|
||||
|
||||
|
|
|
|||
|
|
@ -35,9 +35,6 @@ package io.netty.channel;
|
|||
* in the handler method can cause an unexpected pause during I/O. If you need
|
||||
* to perform a blocking operation on I/O completion, try to execute the
|
||||
* operation in a different thread using a thread pool.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public interface ChannelFutureProgressListener extends ChannelFutureListener {
|
||||
|
||||
|
|
|
|||
|
|
@ -202,10 +202,6 @@ import io.netty.channel.group.ChannelGroup;
|
|||
* Please refer to the {@link ChannelEvent} and {@link ChannelPipeline} to find
|
||||
* out what a upstream event and a downstream event are, what fundamental
|
||||
* differences they have, and how they flow in a pipeline.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @apiviz.landmark
|
||||
* @apiviz.exclude ^org\.jboss\.netty\.handler\..*$
|
||||
*/
|
||||
|
|
@ -222,10 +218,7 @@ public interface ChannelHandler {
|
|||
* <p>
|
||||
* This annotation is provided for documentation purpose, just like
|
||||
* <a href="http://www.javaconcurrencyinpractice.com/annotations/doc/">the JCIP annotations</a>.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
*/
|
||||
@Inherited
|
||||
@Documented
|
||||
@Target(ElementType.TYPE)
|
||||
|
|
|
|||
|
|
@ -116,10 +116,6 @@ package io.netty.channel;
|
|||
* {@link ChannelPipeline} to find out what a upstream event and a downstream
|
||||
* event are, what fundamental differences they have, how they flow in a
|
||||
* pipeline, and how to handle the event in your application.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @apiviz.owns io.netty.channel.ChannelHandler
|
||||
*/
|
||||
public interface ChannelHandlerContext {
|
||||
|
|
|
|||
|
|
@ -19,10 +19,6 @@ package io.netty.channel;
|
|||
* A {@link RuntimeException} which is thrown when a
|
||||
* {@link LifeCycleAwareChannelHandler} throws an {@link Exception}
|
||||
* in its handler methods.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @apiviz.hidden
|
||||
*/
|
||||
public class ChannelHandlerLifeCycleException extends RuntimeException {
|
||||
|
|
|
|||
|
|
@ -28,14 +28,9 @@ import io.netty.util.internal.ConcurrentIdentityWeakKeyHashMap;
|
|||
* Alternatively, you might want to use the
|
||||
* {@link ChannelHandlerContext#setAttachment(Object) ChannelHandlerContext.attachment}
|
||||
* property, which performs better.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @deprecated Use {@link Channel#setAttachment(Object)} and {@link Channel#getAttachment()}
|
||||
*
|
||||
* @apiviz.stereotype utility
|
||||
*
|
||||
*/
|
||||
@Deprecated
|
||||
public class ChannelLocal<T> {
|
||||
|
|
|
|||
|
|
@ -200,10 +200,6 @@ import io.netty.handler.ssl.SslHandler;
|
|||
* To implement the expected behavior, you have to add <tt>SecondHandler</tt>
|
||||
* before the removal or make sure there is at least one more handler between
|
||||
* <tt>FirstHandler</tt> and <tt>SecondHandler</tt>.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @apiviz.landmark
|
||||
* @apiviz.composedOf io.netty.channel.ChannelHandlerContext
|
||||
* @apiviz.owns io.netty.channel.ChannelHandler
|
||||
|
|
|
|||
|
|
@ -19,10 +19,6 @@ package io.netty.channel;
|
|||
* A {@link ChannelException} which is thrown when a {@link ChannelPipeline}
|
||||
* failed to process a {@link ChannelEvent} or when a {@link ChannelPipelineFactory}
|
||||
* failed to initialize a {@link ChannelPipeline}.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @apiviz.hidden
|
||||
*/
|
||||
public class ChannelPipelineException extends ChannelException {
|
||||
|
|
|
|||
|
|
@ -31,10 +31,6 @@ import io.netty.bootstrap.ConnectionlessBootstrap;
|
|||
* Also, when a {@link ClientBootstrap} or {@link ConnectionlessBootstrap}
|
||||
* creates a new channel, it uses the {@link Bootstrap#getPipelineFactory() "pipelineFactory"}
|
||||
* property to create a new {@link ChannelPipeline} for each new channel.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @apiviz.has io.netty.channel.ChannelPipeline oneway - - creates
|
||||
*/
|
||||
public interface ChannelPipelineFactory {
|
||||
|
|
|
|||
|
|
@ -22,10 +22,6 @@ package io.netty.channel;
|
|||
* A {@link ChannelSink} is an internal component which is supposed to be
|
||||
* implemented by a transport provider. Most users will not see this type
|
||||
* in their code.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @apiviz.uses io.netty.channel.ChannelPipeline - - sends events upstream
|
||||
*/
|
||||
public interface ChannelSink {
|
||||
|
|
|
|||
|
|
@ -73,9 +73,6 @@ import java.net.SocketAddress;
|
|||
* </table>
|
||||
* <p>
|
||||
* To see how an event is interpreted further, please refer to {@link ChannelEvent}.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public enum ChannelState {
|
||||
/**
|
||||
|
|
|
|||
|
|
@ -23,10 +23,6 @@ package io.netty.channel;
|
|||
* respectively. Please refer to the {@link ChannelEvent} documentation to
|
||||
* find out what an upstream event and a downstream event are and what
|
||||
* fundamental differences they have.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @apiviz.has io.netty.channel.ChannelState
|
||||
*/
|
||||
public interface ChannelStateEvent extends ChannelEvent {
|
||||
|
|
|
|||
|
|
@ -83,10 +83,6 @@ import io.netty.handler.execution.ExecutionHandler;
|
|||
* this behavior changes depending on what {@link Executor} was employed to
|
||||
* dispatch the events. Please refer to {@link ExecutionHandler} for more
|
||||
* information.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @apiviz.exclude ^org\.jboss\.netty\.handler\..*$
|
||||
*/
|
||||
public interface ChannelUpstreamHandler extends ChannelHandler {
|
||||
|
|
|
|||
|
|
@ -45,10 +45,6 @@ import io.netty.util.internal.ConversionUtil;
|
|||
* event generation methods provided by {@link Channels} rather than calling
|
||||
* {@link ChannelHandlerContext#sendUpstream(ChannelEvent)} or
|
||||
* {@link ChannelHandlerContext#sendDownstream(ChannelEvent)} by yourself.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @apiviz.landmark
|
||||
*/
|
||||
public class Channels {
|
||||
|
|
|
|||
|
|
@ -20,9 +20,6 @@ package io.netty.channel;
|
|||
* a child {@link Channel}. This event is for going upstream only. Please
|
||||
* refer to the {@link ChannelEvent} documentation to find out what an upstream
|
||||
* event and a downstream event are and what fundamental differences they have.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public interface ChildChannelStateEvent extends ChannelEvent {
|
||||
|
||||
|
|
|
|||
|
|
@ -23,9 +23,6 @@ import io.netty.logging.InternalLoggerFactory;
|
|||
/**
|
||||
* A skeletal {@link ChannelFuture} implementation which represents a
|
||||
* {@link ChannelFuture} which has been completed already.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public abstract class CompleteChannelFuture implements ChannelFuture {
|
||||
|
||||
|
|
|
|||
|
|
@ -25,9 +25,6 @@ import io.netty.util.internal.ConversionUtil;
|
|||
|
||||
/**
|
||||
* The default {@link SocketChannelConfig} implementation.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public class DefaultChannelConfig implements ChannelConfig {
|
||||
|
||||
|
|
|
|||
|
|
@ -31,9 +31,6 @@ import io.netty.util.internal.DeadLockProofWorker;
|
|||
* use {@link Channels#future(Channel)} and {@link Channels#future(Channel, boolean)}
|
||||
* to create a new {@link ChannelFuture} rather than calling the constructor
|
||||
* explicitly.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public class DefaultChannelFuture implements ChannelFuture {
|
||||
|
||||
|
|
|
|||
|
|
@ -29,9 +29,6 @@ import io.netty.logging.InternalLoggerFactory;
|
|||
* The default {@link ChannelPipeline} implementation. It is recommended
|
||||
* to use {@link Channels#pipeline()} to create a new {@link ChannelPipeline}
|
||||
* instance rather than calling the constructor directly.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public class DefaultChannelPipeline implements ChannelPipeline {
|
||||
|
||||
|
|
|
|||
|
|
@ -19,9 +19,6 @@ import static io.netty.channel.Channels.*;
|
|||
|
||||
/**
|
||||
* The default {@link ChildChannelStateEvent} implementation.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public class DefaultChildChannelStateEvent implements ChildChannelStateEvent {
|
||||
|
||||
|
|
|
|||
|
|
@ -21,9 +21,6 @@ import io.netty.util.internal.StackTraceSimplifier;
|
|||
|
||||
/**
|
||||
* The default {@link ExceptionEvent} implementation.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public class DefaultExceptionEvent implements ExceptionEvent {
|
||||
|
||||
|
|
|
|||
|
|
@ -24,9 +24,6 @@ import io.netty.channel.socket.ServerSocketChannelConfig;
|
|||
|
||||
/**
|
||||
* The default {@link ServerSocketChannelConfig} implementation.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public class DefaultServerChannelConfig implements ChannelConfig {
|
||||
|
||||
|
|
|
|||
|
|
@ -19,9 +19,6 @@ import static io.netty.channel.Channels.*;
|
|||
|
||||
/**
|
||||
* The default {@link WriteCompletionEvent} implementation.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public class DefaultWriteCompletionEvent implements WriteCompletionEvent {
|
||||
|
||||
|
|
|
|||
|
|
@ -17,9 +17,6 @@ package io.netty.channel;
|
|||
|
||||
/**
|
||||
* The default downstream {@link ChannelStateEvent} implementation.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public class DownstreamChannelStateEvent implements ChannelStateEvent {
|
||||
|
||||
|
|
|
|||
|
|
@ -21,9 +21,6 @@ import io.netty.util.internal.StringUtil;
|
|||
|
||||
/**
|
||||
* The default downstream {@link MessageEvent} implementation.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public class DownstreamMessageEvent implements MessageEvent {
|
||||
|
||||
|
|
|
|||
|
|
@ -21,9 +21,6 @@ package io.netty.channel;
|
|||
* going upstream only. Please refer to the {@link ChannelEvent} documentation
|
||||
* to find out what an upstream event and a downstream event are and what
|
||||
* fundamental differences they have.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public interface ExceptionEvent extends ChannelEvent {
|
||||
|
||||
|
|
|
|||
|
|
@ -19,9 +19,6 @@ package io.netty.channel;
|
|||
* The {@link CompleteChannelFuture} which is failed already. It is
|
||||
* recommended to use {@link Channels#failedFuture(Channel, Throwable)}
|
||||
* instead of calling the constructor of this future.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public class FailedChannelFuture extends CompleteChannelFuture {
|
||||
|
||||
|
|
|
|||
|
|
@ -53,9 +53,6 @@ import io.netty.util.ExternalResourceReleasable;
|
|||
* Currently, the NIO transport is the only transport that supports {@link FileRegion}.
|
||||
* Attempting to write a {@link FileRegion} to non-NIO {@link Channel} will trigger
|
||||
* a {@link ClassCastException} or a similar exception.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public interface FileRegion extends ExternalResourceReleasable {
|
||||
|
||||
|
|
|
|||
|
|
@ -19,9 +19,6 @@ package io.netty.channel;
|
|||
/**
|
||||
* The {@link ReceiveBufferSizePredictor} that always yields the same buffer
|
||||
* size prediction. This predictor ignores the feed back from the I/O thread.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public class FixedReceiveBufferSizePredictor implements
|
||||
ReceiveBufferSizePredictor {
|
||||
|
|
|
|||
|
|
@ -19,9 +19,6 @@ package io.netty.channel;
|
|||
/**
|
||||
* The {@link ReceiveBufferSizePredictorFactory} that returns a
|
||||
* {@link FixedReceiveBufferSizePredictor} with the pre-defined configuration.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public class FixedReceiveBufferSizePredictorFactory implements
|
||||
ReceiveBufferSizePredictorFactory {
|
||||
|
|
|
|||
|
|
@ -27,9 +27,6 @@ package io.netty.channel;
|
|||
* might lead to an unexpected behavior. It is because the context object
|
||||
* might not have been fully added to the pipeline or the context object is not
|
||||
* a part of the pipeline anymore respectively.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public interface LifeCycleAwareChannelHandler extends ChannelHandler {
|
||||
void beforeAdd(ChannelHandlerContext ctx) throws Exception;
|
||||
|
|
|
|||
|
|
@ -24,9 +24,6 @@ import java.net.SocketAddress;
|
|||
* downstream event respectively. Please refer to the {@link ChannelEvent}
|
||||
* documentation to find out what an upstream event and a downstream event are
|
||||
* and what fundamental differences they have.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public interface MessageEvent extends ChannelEvent {
|
||||
|
||||
|
|
|
|||
|
|
@ -29,9 +29,6 @@ import io.netty.buffer.ChannelBuffer;
|
|||
* Once a read operation is performed and the actual number of read bytes is
|
||||
* known, an I/O thread will call {@link #previousReceiveBufferSize(int)} to
|
||||
* update the predictor so it can predict more accurately next time.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public interface ReceiveBufferSizePredictor {
|
||||
|
||||
|
|
|
|||
|
|
@ -17,10 +17,6 @@ package io.netty.channel;
|
|||
|
||||
/**
|
||||
* Creates a new {@link ReceiveBufferSizePredictor}.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @apiviz.has io.netty.channel.ReceiveBufferSizePredictor oneway - - creates
|
||||
*/
|
||||
public interface ReceiveBufferSizePredictorFactory {
|
||||
|
|
|
|||
|
|
@ -21,9 +21,6 @@ import io.netty.channel.socket.ServerSocketChannel;
|
|||
* A {@link Channel} that accepts an incoming connection attempt and creates
|
||||
* its child {@link Channel}s by accepting them. {@link ServerSocketChannel} is
|
||||
* a good example.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public interface ServerChannel extends Channel {
|
||||
// This is a tag interface.
|
||||
|
|
|
|||
|
|
@ -17,10 +17,6 @@ package io.netty.channel;
|
|||
|
||||
/**
|
||||
* A {@link ChannelFactory} that creates a {@link ServerChannel}.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @apiviz.has io.netty.channel.ServerChannel oneway - - creates
|
||||
*/
|
||||
public interface ServerChannelFactory extends ChannelFactory {
|
||||
|
|
|
|||
|
|
@ -49,9 +49,6 @@ import java.net.SocketAddress;
|
|||
* <strong>super.handleDownstream(ctx, e);</strong>
|
||||
* }
|
||||
* }</pre>
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public class SimpleChannelDownstreamHandler implements ChannelDownstreamHandler {
|
||||
|
||||
|
|
|
|||
|
|
@ -70,9 +70,6 @@ import io.netty.logging.InternalLoggerFactory;
|
|||
* <strong>super.handleDownstream(ctx, e);</strong>
|
||||
* }
|
||||
* }</pre>
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public class SimpleChannelHandler implements ChannelUpstreamHandler, ChannelDownstreamHandler {
|
||||
|
||||
|
|
|
|||
|
|
@ -50,9 +50,6 @@ import io.netty.logging.InternalLoggerFactory;
|
|||
* <strong>super.handleUpstream(ctx, e);</strong>
|
||||
* }
|
||||
* }</pre>
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public class SimpleChannelUpstreamHandler implements ChannelUpstreamHandler {
|
||||
|
||||
|
|
|
|||
|
|
@ -30,9 +30,6 @@ import io.netty.util.internal.ConversionUtil;
|
|||
* disabled dynamic insertion and removal of {@link ChannelHandler}s.
|
||||
* An attempt to insert, remove, or replace a handler in this pipeline will
|
||||
* trigger an {@link UnsupportedOperationException}.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public class StaticChannelPipeline implements ChannelPipeline {
|
||||
|
||||
|
|
|
|||
|
|
@ -19,9 +19,6 @@ package io.netty.channel;
|
|||
* The {@link CompleteChannelFuture} which is succeeded already. It is
|
||||
* recommended to use {@link Channels#succeededFuture(Channel)} instead of
|
||||
* calling the constructor of this future.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public class SucceededChannelFuture extends CompleteChannelFuture {
|
||||
|
||||
|
|
|
|||
|
|
@ -19,9 +19,6 @@ import static io.netty.channel.Channels.*;
|
|||
|
||||
/**
|
||||
* The default upstream {@link ChannelStateEvent} implementation.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public class UpstreamChannelStateEvent implements ChannelStateEvent {
|
||||
|
||||
|
|
|
|||
|
|
@ -23,9 +23,6 @@ import io.netty.util.internal.StringUtil;
|
|||
|
||||
/**
|
||||
* The default upstream {@link MessageEvent} implementation.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public class UpstreamMessageEvent implements MessageEvent {
|
||||
|
||||
|
|
|
|||
|
|
@ -21,9 +21,6 @@ package io.netty.channel;
|
|||
* only. Please refer to the {@link ChannelEvent} documentation to find out
|
||||
* what an upstream event and a downstream event are and what fundamental
|
||||
* differences they have.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public interface WriteCompletionEvent extends ChannelEvent {
|
||||
/**
|
||||
|
|
|
|||
|
|
@ -87,10 +87,6 @@ import io.netty.util.CharsetUtil;
|
|||
* }
|
||||
* }
|
||||
* </pre>
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @apiviz.landmark
|
||||
* @apiviz.has io.netty.channel.group.ChannelGroupFuture oneway - - returns
|
||||
*/
|
||||
|
|
|
|||
|
|
@ -107,10 +107,6 @@ import io.netty.handler.execution.ExecutionHandler;
|
|||
* where it is more convenient to call {@link #await()}. In such a case, please
|
||||
* make sure you do not call {@link #await()} in an I/O thread. Otherwise,
|
||||
* {@link IllegalStateException} will be raised to prevent a dead lock.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @apiviz.owns io.netty.channel.group.ChannelGroupFutureListener - - notifies
|
||||
*/
|
||||
public interface ChannelGroupFuture extends Iterable<ChannelFuture> {
|
||||
|
|
|
|||
|
|
@ -22,9 +22,6 @@ import java.util.EventListener;
|
|||
* asynchronous {@link ChannelGroup} I/O operations is notified once this
|
||||
* listener is added by calling {@link ChannelGroupFuture#addListener(ChannelGroupFutureListener)}
|
||||
* and all I/O operations are complete.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public interface ChannelGroupFutureListener extends EventListener {
|
||||
|
||||
|
|
|
|||
|
|
@ -19,8 +19,6 @@ import java.util.Iterator;
|
|||
import java.util.NoSuchElementException;
|
||||
|
||||
/**
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
final class CombinedIterator<E> implements Iterator<E> {
|
||||
|
||||
|
|
|
|||
|
|
@ -34,10 +34,6 @@ import io.netty.util.internal.ConcurrentHashMap;
|
|||
|
||||
/**
|
||||
* The default {@link ChannelGroup} implementation.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @apiviz.landmark
|
||||
*/
|
||||
public class DefaultChannelGroup extends AbstractSet<Channel> implements ChannelGroup {
|
||||
|
|
|
|||
|
|
@ -35,9 +35,6 @@ import io.netty.util.internal.DeadLockProofWorker;
|
|||
|
||||
/**
|
||||
* The default {@link ChannelGroupFuture} implementation.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public class DefaultChannelGroupFuture implements ChannelGroupFuture {
|
||||
|
||||
|
|
|
|||
|
|
@ -23,15 +23,11 @@ import java.net.SocketAddress;
|
|||
* A {@link java.net.SocketAddress} implementation holding an
|
||||
* {@link java.io.InputStream} and an {@link java.io.OutputStream} instance used
|
||||
* as "remote" address to connect to with a {@link IOStreamChannel}.
|
||||
*
|
||||
* @author Daniel Bimschas
|
||||
* @author Dennis Pfisterer
|
||||
*/
|
||||
public class IOStreamAddress extends SocketAddress {
|
||||
|
||||
/**
|
||||
*
|
||||
*/
|
||||
*/
|
||||
private static final long serialVersionUID = -4382415449059935960L;
|
||||
|
||||
private final InputStream inputStream;
|
||||
|
|
|
|||
|
|
@ -22,9 +22,6 @@ import java.net.SocketAddress;
|
|||
/**
|
||||
* A channel to an {@link java.io.InputStream} and an
|
||||
* {@link java.io.OutputStream}.
|
||||
*
|
||||
* @author Daniel Bimschas
|
||||
* @author Dennis Pfisterer
|
||||
*/
|
||||
public class IOStreamChannel extends AbstractChannel {
|
||||
|
||||
|
|
|
|||
|
|
@ -28,9 +28,6 @@ import java.util.concurrent.ExecutorService;
|
|||
|
||||
/**
|
||||
* A {@link io.netty.channel.ChannelFactory} for creating {@link IOStreamChannel} instances.
|
||||
*
|
||||
* @author Daniel Bimschas
|
||||
* @author Dennis Pfisterer
|
||||
*/
|
||||
public class IOStreamChannelFactory implements ChannelFactory {
|
||||
|
||||
|
|
|
|||
|
|
@ -28,9 +28,6 @@ import static io.netty.channel.Channels.*;
|
|||
/**
|
||||
* A {@link io.netty.channel.ChannelSink} implementation which reads from
|
||||
* an {@link java.io.InputStream} and writes to an {@link java.io.OutputStream}.
|
||||
*
|
||||
* @author Daniel Bimschas
|
||||
* @author Dennis Pfisterer
|
||||
*/
|
||||
public class IOStreamChannelSink extends AbstractChannelSink {
|
||||
|
||||
|
|
|
|||
|
|
@ -36,9 +36,6 @@ import io.netty.util.internal.QueueFactory;
|
|||
import io.netty.util.internal.ThreadLocalBoolean;
|
||||
|
||||
/**
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author Andy Taylor (andy.taylor@jboss.org)
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
final class DefaultLocalChannel extends AbstractChannel implements LocalChannel {
|
||||
|
||||
|
|
|
|||
|
|
@ -20,11 +20,6 @@ import io.netty.channel.ChannelSink;
|
|||
|
||||
/**
|
||||
* The default {@link LocalClientChannelFactory} implementation.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author Andy Taylor (andy.taylor@jboss.org)
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @apiviz.landmark
|
||||
*/
|
||||
public class DefaultLocalClientChannelFactory implements LocalClientChannelFactory {
|
||||
|
|
|
|||
|
|
@ -27,9 +27,6 @@ import io.netty.channel.ChannelSink;
|
|||
import io.netty.channel.DefaultServerChannelConfig;
|
||||
|
||||
/**
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author Andy Taylor (andy.taylor@jboss.org)
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
final class DefaultLocalServerChannel extends AbstractServerChannel implements
|
||||
LocalServerChannel {
|
||||
|
|
|
|||
|
|
@ -20,11 +20,6 @@ import io.netty.channel.ChannelSink;
|
|||
|
||||
/**
|
||||
* The default {@link LocalServerChannelFactory} implementation.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author Andy Taylor (andy.taylor@jboss.org)
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @apiviz.landmark
|
||||
*/
|
||||
public class DefaultLocalServerChannelFactory implements LocalServerChannelFactory {
|
||||
|
|
|
|||
|
|
@ -27,11 +27,6 @@ import java.net.SocketAddress;
|
|||
* An ephemeral address is an anonymous address which is assigned temporarily
|
||||
* and is released as soon as the connection is closed. All ephemeral addresses
|
||||
* have the same ID, {@code "ephemeral"}, but they are not equal to each other.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author Andy Taylor (andy.taylor@jboss.org)
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @apiviz.landmark
|
||||
*/
|
||||
public final class LocalAddress extends SocketAddress implements Comparable<LocalAddress> {
|
||||
|
|
|
|||
|
|
@ -19,10 +19,6 @@ import io.netty.channel.Channel;
|
|||
|
||||
/**
|
||||
* A {@link Channel} for the local transport.
|
||||
*
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author Andy Taylor (andy.taylor@jboss.org)
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
public interface LocalChannel extends Channel {
|
||||
@Override
|
||||
|
|
|
|||
|
|
@ -21,8 +21,6 @@ import io.netty.channel.Channel;
|
|||
import io.netty.util.internal.ConcurrentHashMap;
|
||||
|
||||
/**
|
||||
* @author <a href="http://netty.io/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*/
|
||||
final class LocalChannelRegistry {
|
||||
|
||||
|
|
|
|||
Some files were not shown because too many files have changed in this diff Show More
Loading…
Reference in New Issue
Block a user