org.jboss.netty -> io.netty
This commit is contained in:
Trustin Lee
parent
84902a6e7a
commit
6fdb7d9116
2
.gitignore
vendored
2
.gitignore
vendored
@ -3,7 +3,7 @@
|
||||
/.settings
|
||||
/target
|
||||
/reports
|
||||
/src/main/java/org/jboss/netty/util/Version.java
|
||||
/src/main/java/io/netty/util/Version.java
|
||||
/*.iml
|
||||
/*.ipr
|
||||
/*.iws
|
||||
|
||||
2
pom.xml
2
pom.xml
@ -394,7 +394,7 @@
|
||||
<echo>Build number: ${buildNumber}</echo>
|
||||
<mkdir dir="${project.build.directory}" />
|
||||
<echo message="${project.version}" file="${project.build.directory}/version.txt" />
|
||||
<echo message="// DO NOT MODIFY - WILL BE OVERWRITTEN DURING THE BUILD PROCESS${line.separator}package org.jboss.netty.util;${line.separator}/**${line.separator} * Provides the version information of Netty.${line.separator} * @apiviz.landmark${line.separator} */${line.separator}public final class Version {${line.separator} /** The version identifier. */${line.separator} public static final String ID = "${project.version}-${buildNumber}";${line.separator} /** Prints out the version identifier to stdout. */${line.separator} public static void main(String[] args) { System.out.println(ID); }${line.separator} private Version() { super(); }${line.separator}}${line.separator}" file="${basedir}/src/main/java/org/jboss/netty/util/Version.java" />
|
||||
<echo message="// DO NOT MODIFY - WILL BE OVERWRITTEN DURING THE BUILD PROCESS${line.separator}package io.netty.util;${line.separator}/**${line.separator} * Provides the version information of Netty.${line.separator} * @apiviz.landmark${line.separator} */${line.separator}public final class Version {${line.separator} /** The version identifier. */${line.separator} public static final String ID = "${project.version}-${buildNumber}";${line.separator} /** Prints out the version identifier to stdout. */${line.separator} public static void main(String[] args) { System.out.println(ID); }${line.separator} private Version() { super(); }${line.separator}}${line.separator}" file="${basedir}/src/main/java/io/netty/util/Version.java" />
|
||||
</tasks>
|
||||
</configuration>
|
||||
</execution>
|
||||
|
||||
@ -13,9 +13,9 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.bootstrap;
|
||||
package io.netty.bootstrap;
|
||||
|
||||
import static org.jboss.netty.channel.Channels.*;
|
||||
import static io.netty.channel.Channels.*;
|
||||
|
||||
import java.util.ArrayList;
|
||||
import java.util.HashMap;
|
||||
@ -25,12 +25,12 @@ import java.util.List;
|
||||
import java.util.Map;
|
||||
import java.util.TreeMap;
|
||||
|
||||
import org.jboss.netty.channel.Channel;
|
||||
import org.jboss.netty.channel.ChannelFactory;
|
||||
import org.jboss.netty.channel.ChannelHandler;
|
||||
import org.jboss.netty.channel.ChannelPipeline;
|
||||
import org.jboss.netty.channel.ChannelPipelineFactory;
|
||||
import org.jboss.netty.util.ExternalResourceReleasable;
|
||||
import io.netty.channel.Channel;
|
||||
import io.netty.channel.ChannelFactory;
|
||||
import io.netty.channel.ChannelHandler;
|
||||
import io.netty.channel.ChannelPipeline;
|
||||
import io.netty.channel.ChannelPipelineFactory;
|
||||
import io.netty.util.ExternalResourceReleasable;
|
||||
|
||||
/**
|
||||
* A helper class which initializes a {@link Channel}. This class provides
|
||||
@ -43,7 +43,7 @@ import org.jboss.netty.util.ExternalResourceReleasable;
|
||||
* @author <a href="http://www.jboss.org/netty/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @apiviz.uses org.jboss.netty.channel.ChannelFactory
|
||||
* @apiviz.uses io.netty.channel.ChannelFactory
|
||||
*/
|
||||
public class Bootstrap implements ExternalResourceReleasable {
|
||||
|
||||
|
||||
@ -13,20 +13,20 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.bootstrap;
|
||||
package io.netty.bootstrap;
|
||||
|
||||
import java.net.InetSocketAddress;
|
||||
import java.net.SocketAddress;
|
||||
|
||||
import org.jboss.netty.channel.Channel;
|
||||
import org.jboss.netty.channel.ChannelConfig;
|
||||
import org.jboss.netty.channel.ChannelFactory;
|
||||
import org.jboss.netty.channel.ChannelFuture;
|
||||
import org.jboss.netty.channel.ChannelHandler;
|
||||
import org.jboss.netty.channel.ChannelPipeline;
|
||||
import org.jboss.netty.channel.ChannelPipelineException;
|
||||
import org.jboss.netty.channel.ChannelPipelineFactory;
|
||||
import org.jboss.netty.channel.Channels;
|
||||
import io.netty.channel.Channel;
|
||||
import io.netty.channel.ChannelConfig;
|
||||
import io.netty.channel.ChannelFactory;
|
||||
import io.netty.channel.ChannelFuture;
|
||||
import io.netty.channel.ChannelHandler;
|
||||
import io.netty.channel.ChannelPipeline;
|
||||
import io.netty.channel.ChannelPipelineException;
|
||||
import io.netty.channel.ChannelPipelineFactory;
|
||||
import io.netty.channel.Channels;
|
||||
|
||||
/**
|
||||
* A helper class which creates a new client-side {@link Channel} and makes a
|
||||
|
||||
@ -13,21 +13,21 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.bootstrap;
|
||||
package io.netty.bootstrap;
|
||||
|
||||
import java.net.InetSocketAddress;
|
||||
import java.net.SocketAddress;
|
||||
|
||||
import org.jboss.netty.channel.Channel;
|
||||
import org.jboss.netty.channel.ChannelConfig;
|
||||
import org.jboss.netty.channel.ChannelException;
|
||||
import org.jboss.netty.channel.ChannelFactory;
|
||||
import org.jboss.netty.channel.ChannelFuture;
|
||||
import org.jboss.netty.channel.ChannelHandler;
|
||||
import org.jboss.netty.channel.ChannelPipeline;
|
||||
import org.jboss.netty.channel.ChannelPipelineException;
|
||||
import org.jboss.netty.channel.ChannelPipelineFactory;
|
||||
import org.jboss.netty.channel.Channels;
|
||||
import io.netty.channel.Channel;
|
||||
import io.netty.channel.ChannelConfig;
|
||||
import io.netty.channel.ChannelException;
|
||||
import io.netty.channel.ChannelFactory;
|
||||
import io.netty.channel.ChannelFuture;
|
||||
import io.netty.channel.ChannelHandler;
|
||||
import io.netty.channel.ChannelPipeline;
|
||||
import io.netty.channel.ChannelPipelineException;
|
||||
import io.netty.channel.ChannelPipelineFactory;
|
||||
import io.netty.channel.Channels;
|
||||
|
||||
/**
|
||||
* A helper class which creates a new server-side {@link Channel} for a
|
||||
|
||||
@ -13,9 +13,9 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.bootstrap;
|
||||
package io.netty.bootstrap;
|
||||
|
||||
import static org.jboss.netty.channel.Channels.*;
|
||||
import static io.netty.channel.Channels.*;
|
||||
|
||||
import java.net.InetSocketAddress;
|
||||
import java.net.SocketAddress;
|
||||
@ -26,21 +26,21 @@ import java.util.concurrent.BlockingQueue;
|
||||
import java.util.concurrent.LinkedBlockingQueue;
|
||||
import java.util.concurrent.TimeUnit;
|
||||
|
||||
import org.jboss.netty.channel.Channel;
|
||||
import org.jboss.netty.channel.ChannelConfig;
|
||||
import org.jboss.netty.channel.ChannelException;
|
||||
import org.jboss.netty.channel.ChannelFactory;
|
||||
import org.jboss.netty.channel.ChannelFuture;
|
||||
import org.jboss.netty.channel.ChannelHandler;
|
||||
import org.jboss.netty.channel.ChannelHandlerContext;
|
||||
import org.jboss.netty.channel.ChannelPipeline;
|
||||
import org.jboss.netty.channel.ChannelPipelineFactory;
|
||||
import org.jboss.netty.channel.ChannelStateEvent;
|
||||
import org.jboss.netty.channel.Channels;
|
||||
import org.jboss.netty.channel.ChildChannelStateEvent;
|
||||
import org.jboss.netty.channel.ExceptionEvent;
|
||||
import org.jboss.netty.channel.ServerChannelFactory;
|
||||
import org.jboss.netty.channel.SimpleChannelUpstreamHandler;
|
||||
import io.netty.channel.Channel;
|
||||
import io.netty.channel.ChannelConfig;
|
||||
import io.netty.channel.ChannelException;
|
||||
import io.netty.channel.ChannelFactory;
|
||||
import io.netty.channel.ChannelFuture;
|
||||
import io.netty.channel.ChannelHandler;
|
||||
import io.netty.channel.ChannelHandlerContext;
|
||||
import io.netty.channel.ChannelPipeline;
|
||||
import io.netty.channel.ChannelPipelineFactory;
|
||||
import io.netty.channel.ChannelStateEvent;
|
||||
import io.netty.channel.Channels;
|
||||
import io.netty.channel.ChildChannelStateEvent;
|
||||
import io.netty.channel.ExceptionEvent;
|
||||
import io.netty.channel.ServerChannelFactory;
|
||||
import io.netty.channel.SimpleChannelUpstreamHandler;
|
||||
|
||||
/**
|
||||
* A helper class which creates a new server-side {@link Channel} and accepts
|
||||
|
||||
@ -21,4 +21,4 @@
|
||||
* @apiviz.landmark
|
||||
* @apiviz.exclude ^org\.jboss\.netty\.util\.
|
||||
*/
|
||||
package org.jboss.netty.bootstrap;
|
||||
package io.netty.bootstrap;
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.buffer;
|
||||
package io.netty.buffer;
|
||||
|
||||
import java.io.IOException;
|
||||
import java.io.InputStream;
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.buffer;
|
||||
package io.netty.buffer;
|
||||
|
||||
import java.nio.ByteOrder;
|
||||
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.buffer;
|
||||
package io.netty.buffer;
|
||||
|
||||
import java.nio.ByteOrder;
|
||||
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.buffer;
|
||||
package io.netty.buffer;
|
||||
|
||||
import java.io.IOException;
|
||||
import java.io.InputStream;
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.buffer;
|
||||
package io.netty.buffer;
|
||||
|
||||
import java.io.IOException;
|
||||
import java.io.InputStream;
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.buffer;
|
||||
package io.netty.buffer;
|
||||
|
||||
import java.nio.ByteBuffer;
|
||||
import java.nio.ByteOrder;
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.buffer;
|
||||
package io.netty.buffer;
|
||||
|
||||
|
||||
/**
|
||||
@ -28,7 +28,7 @@ package org.jboss.netty.buffer;
|
||||
* @author <a href="http://www.jboss.org/netty/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @apiviz.uses org.jboss.netty.buffer.ChannelBuffer
|
||||
* @apiviz.uses io.netty.buffer.ChannelBuffer
|
||||
*/
|
||||
public interface ChannelBufferIndexFinder {
|
||||
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.buffer;
|
||||
package io.netty.buffer;
|
||||
|
||||
import java.io.DataInput;
|
||||
import java.io.DataInputStream;
|
||||
@ -36,7 +36,7 @@ import java.io.InputStream;
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @see ChannelBufferOutputStream
|
||||
* @apiviz.uses org.jboss.netty.buffer.ChannelBuffer
|
||||
* @apiviz.uses io.netty.buffer.ChannelBuffer
|
||||
*/
|
||||
public class ChannelBufferInputStream extends InputStream implements DataInput {
|
||||
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.buffer;
|
||||
package io.netty.buffer;
|
||||
|
||||
import java.io.DataOutput;
|
||||
import java.io.DataOutputStream;
|
||||
@ -35,7 +35,7 @@ import java.io.OutputStream;
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @see ChannelBufferInputStream
|
||||
* @apiviz.uses org.jboss.netty.buffer.ChannelBuffer
|
||||
* @apiviz.uses io.netty.buffer.ChannelBuffer
|
||||
*/
|
||||
public class ChannelBufferOutputStream extends OutputStream implements DataOutput {
|
||||
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.buffer;
|
||||
package io.netty.buffer;
|
||||
|
||||
import java.nio.ByteBuffer;
|
||||
import java.nio.ByteOrder;
|
||||
@ -26,7 +26,7 @@ import java.nio.charset.CoderResult;
|
||||
import java.util.ArrayList;
|
||||
import java.util.List;
|
||||
|
||||
import org.jboss.netty.util.CharsetUtil;
|
||||
import io.netty.util.CharsetUtil;
|
||||
|
||||
|
||||
/**
|
||||
@ -37,7 +37,7 @@ import org.jboss.netty.util.CharsetUtil;
|
||||
* This classes is intended to be used with Java 5 static import statement:
|
||||
*
|
||||
* <pre>
|
||||
* import static org.jboss.netty.buffer.{@link ChannelBuffers}.*;
|
||||
* import static io.netty.buffer.{@link ChannelBuffers}.*;
|
||||
*
|
||||
* {@link ChannelBuffer} heapBuffer = buffer(128);
|
||||
* {@link ChannelBuffer} directBuffer = directBuffer(256);
|
||||
@ -86,7 +86,7 @@ import org.jboss.netty.util.CharsetUtil;
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @apiviz.landmark
|
||||
* @apiviz.has org.jboss.netty.buffer.ChannelBuffer oneway - - creates
|
||||
* @apiviz.has io.netty.buffer.ChannelBuffer oneway - - creates
|
||||
*/
|
||||
public class ChannelBuffers {
|
||||
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.buffer;
|
||||
package io.netty.buffer;
|
||||
|
||||
import java.io.IOException;
|
||||
import java.io.InputStream;
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.buffer;
|
||||
package io.netty.buffer;
|
||||
|
||||
import java.lang.ref.ReferenceQueue;
|
||||
import java.nio.ByteBuffer;
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.buffer;
|
||||
package io.netty.buffer;
|
||||
|
||||
import java.io.IOException;
|
||||
import java.io.InputStream;
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.buffer;
|
||||
package io.netty.buffer;
|
||||
|
||||
import java.io.IOException;
|
||||
import java.io.InputStream;
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.buffer;
|
||||
package io.netty.buffer;
|
||||
|
||||
import java.io.IOException;
|
||||
import java.io.InputStream;
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.buffer;
|
||||
package io.netty.buffer;
|
||||
|
||||
import java.nio.ByteBuffer;
|
||||
import java.nio.ByteOrder;
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.buffer;
|
||||
package io.netty.buffer;
|
||||
|
||||
import java.nio.ByteOrder;
|
||||
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.buffer;
|
||||
package io.netty.buffer;
|
||||
|
||||
import java.io.IOException;
|
||||
import java.io.InputStream;
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.buffer;
|
||||
package io.netty.buffer;
|
||||
|
||||
import java.io.IOException;
|
||||
import java.io.InputStream;
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.buffer;
|
||||
package io.netty.buffer;
|
||||
|
||||
import java.io.IOException;
|
||||
import java.io.InputStream;
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.buffer;
|
||||
package io.netty.buffer;
|
||||
|
||||
/**
|
||||
* The common interface for buffer wrappers and derived buffers. Most users won't
|
||||
|
||||
@ -21,7 +21,7 @@
|
||||
* Netty uses its own buffer API instead of NIO {@link java.nio.ByteBuffer} to
|
||||
* represent a sequence of bytes. This approach has significant advantage over
|
||||
* using {@link java.nio.ByteBuffer}. Netty's new buffer type,
|
||||
* {@link org.jboss.netty.buffer.ChannelBuffer}, has been designed from ground
|
||||
* {@link io.netty.buffer.ChannelBuffer}, has been designed from ground
|
||||
* up to address the problems of {@link java.nio.ByteBuffer} and to meet the
|
||||
* daily needs of network application developers. To list a few cool features:
|
||||
* <ul>
|
||||
@ -35,13 +35,13 @@
|
||||
*
|
||||
* <h3>Extensibility</h3>
|
||||
*
|
||||
* {@link org.jboss.netty.buffer.ChannelBuffer} has rich set of operations
|
||||
* {@link io.netty.buffer.ChannelBuffer} has rich set of operations
|
||||
* optimized for rapid protocol implementation. For example,
|
||||
* {@link org.jboss.netty.buffer.ChannelBuffer} provides various operations
|
||||
* {@link io.netty.buffer.ChannelBuffer} provides various operations
|
||||
* for accessing unsigned values and strings and searching for certain byte
|
||||
* sequence in a buffer. You can also extend or wrap existing buffer type
|
||||
* to add convenient accessors. The custom buffer type still implements
|
||||
* {@link org.jboss.netty.buffer.ChannelBuffer} interface rather than
|
||||
* {@link io.netty.buffer.ChannelBuffer} interface rather than
|
||||
* introducing an incompatible type.
|
||||
*
|
||||
* <h3>Transparent Zero Copy</h3>
|
||||
@ -70,7 +70,7 @@
|
||||
* // The composite type is incompatible with the component type.
|
||||
* ByteBuffer[] message = new ByteBuffer[] { header, body };
|
||||
* </pre>
|
||||
* By contrast, {@link org.jboss.netty.buffer.ChannelBuffer} does not have such
|
||||
* By contrast, {@link io.netty.buffer.ChannelBuffer} does not have such
|
||||
* caveats because it is fully extensible and has a built-in composite buffer
|
||||
* type.
|
||||
* <pre>
|
||||
@ -98,7 +98,7 @@
|
||||
* of the resulting string and let {@link java.lang.StringBuffer} expand itself
|
||||
* on demand. Netty allows you to do the same via a <em>dynamic</em> buffer
|
||||
* which is created by the
|
||||
* {@link org.jboss.netty.buffer.ChannelBuffers#dynamicBuffer()} method.
|
||||
* {@link io.netty.buffer.ChannelBuffers#dynamicBuffer()} method.
|
||||
* <pre>
|
||||
* // A new dynamic buffer is created. Internally, the actual buffer is created
|
||||
* // lazily to avoid potentially wasted memory space.
|
||||
@ -120,7 +120,7 @@
|
||||
* <h3>Better Performance</h3>
|
||||
*
|
||||
* Most frequently used buffer implementation of
|
||||
* {@link org.jboss.netty.buffer.ChannelBuffer} is a very thin wrapper of a
|
||||
* {@link io.netty.buffer.ChannelBuffer} is a very thin wrapper of a
|
||||
* byte array (i.e. {@code byte[]}). Unlike {@link java.nio.ByteBuffer}, it has
|
||||
* no complicated boundary check and index compensation, and therefore it is
|
||||
* easier for a JVM to optimize the buffer access. More complicated buffer
|
||||
@ -131,4 +131,4 @@
|
||||
* @apiviz.exclude ^java\.lang\.
|
||||
* @apiviz.exclude ^java\.io\.[^\.]+Stream$
|
||||
*/
|
||||
package org.jboss.netty.buffer;
|
||||
package io.netty.buffer;
|
||||
|
||||
@ -13,12 +13,12 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
import java.net.SocketAddress;
|
||||
import java.util.concurrent.ConcurrentMap;
|
||||
|
||||
import org.jboss.netty.util.internal.ConcurrentHashMap;
|
||||
import io.netty.util.internal.ConcurrentHashMap;
|
||||
|
||||
/**
|
||||
* A skeletal {@link Channel} implementation.
|
||||
|
||||
@ -13,9 +13,9 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
import static org.jboss.netty.channel.Channels.*;
|
||||
import static io.netty.channel.Channels.*;
|
||||
|
||||
/**
|
||||
* A skeletal {@link ChannelSink} implementation.
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
import java.net.SocketAddress;
|
||||
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
import java.util.ArrayList;
|
||||
import java.util.List;
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
|
||||
/**
|
||||
|
||||
@ -13,17 +13,17 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
import java.net.InetSocketAddress;
|
||||
import java.net.SocketAddress;
|
||||
import java.nio.channels.NotYetConnectedException;
|
||||
import java.nio.channels.SelectionKey;
|
||||
|
||||
import org.jboss.netty.channel.socket.DatagramChannel;
|
||||
import org.jboss.netty.channel.socket.ServerSocketChannel;
|
||||
import org.jboss.netty.channel.socket.SocketChannel;
|
||||
import org.jboss.netty.channel.socket.nio.NioSocketChannelConfig;
|
||||
import io.netty.channel.socket.DatagramChannel;
|
||||
import io.netty.channel.socket.ServerSocketChannel;
|
||||
import io.netty.channel.socket.SocketChannel;
|
||||
import io.netty.channel.socket.nio.NioSocketChannelConfig;
|
||||
|
||||
|
||||
/**
|
||||
@ -104,8 +104,8 @@ import org.jboss.netty.channel.socket.nio.NioSocketChannelConfig;
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @apiviz.landmark
|
||||
* @apiviz.composedOf org.jboss.netty.channel.ChannelConfig
|
||||
* @apiviz.composedOf org.jboss.netty.channel.ChannelPipeline
|
||||
* @apiviz.composedOf io.netty.channel.ChannelConfig
|
||||
* @apiviz.composedOf io.netty.channel.ChannelPipeline
|
||||
*
|
||||
* @apiviz.exclude ^org\.jboss\.netty\.channel\.([a-z]+\.)+[^\.]+Channel$
|
||||
*/
|
||||
|
||||
@ -13,16 +13,16 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
import java.nio.ByteOrder;
|
||||
import java.util.Map;
|
||||
|
||||
import org.jboss.netty.buffer.ChannelBuffer;
|
||||
import org.jboss.netty.buffer.ChannelBufferFactory;
|
||||
import org.jboss.netty.buffer.HeapChannelBufferFactory;
|
||||
import org.jboss.netty.channel.socket.SocketChannelConfig;
|
||||
import org.jboss.netty.channel.socket.nio.NioSocketChannelConfig;
|
||||
import io.netty.buffer.ChannelBuffer;
|
||||
import io.netty.buffer.ChannelBufferFactory;
|
||||
import io.netty.buffer.HeapChannelBufferFactory;
|
||||
import io.netty.channel.socket.SocketChannelConfig;
|
||||
import io.netty.channel.socket.nio.NioSocketChannelConfig;
|
||||
|
||||
/**
|
||||
* A set of configuration properties of a {@link Channel}.
|
||||
@ -63,8 +63,8 @@ import org.jboss.netty.channel.socket.nio.NioSocketChannelConfig;
|
||||
* @author <a href="http://www.jboss.org/netty/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @apiviz.has org.jboss.netty.channel.ChannelPipelineFactory
|
||||
* @apiviz.composedOf org.jboss.netty.channel.ReceiveBufferSizePredictor
|
||||
* @apiviz.has io.netty.channel.ChannelPipelineFactory
|
||||
* @apiviz.composedOf io.netty.channel.ReceiveBufferSizePredictor
|
||||
*
|
||||
* @apiviz.excludeSubtypes
|
||||
*/
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
/**
|
||||
* Handles or intercepts a downstream {@link ChannelEvent}, and sends a
|
||||
|
||||
@ -13,15 +13,15 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
import java.io.InputStream;
|
||||
import java.io.OutputStream;
|
||||
import java.net.Socket;
|
||||
import java.net.SocketAddress;
|
||||
|
||||
import org.jboss.netty.buffer.ChannelBuffer;
|
||||
import org.jboss.netty.channel.socket.ServerSocketChannel;
|
||||
import io.netty.buffer.ChannelBuffer;
|
||||
import io.netty.channel.socket.ServerSocketChannel;
|
||||
|
||||
/**
|
||||
* An I/O event or I/O request associated with a {@link Channel}.
|
||||
@ -182,7 +182,7 @@ import org.jboss.netty.channel.socket.ServerSocketChannel;
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @apiviz.landmark
|
||||
* @apiviz.composedOf org.jboss.netty.channel.ChannelFuture
|
||||
* @apiviz.composedOf io.netty.channel.ChannelFuture
|
||||
*/
|
||||
public interface ChannelEvent {
|
||||
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
/**
|
||||
* A {@link RuntimeException} which is thrown when an I/O operation fails.
|
||||
|
||||
@ -13,13 +13,13 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
import java.util.concurrent.Executor;
|
||||
|
||||
import org.jboss.netty.channel.group.ChannelGroup;
|
||||
import org.jboss.netty.channel.socket.nio.NioServerSocketChannelFactory;
|
||||
import org.jboss.netty.util.ExternalResourceReleasable;
|
||||
import io.netty.channel.group.ChannelGroup;
|
||||
import io.netty.channel.socket.nio.NioServerSocketChannelFactory;
|
||||
import io.netty.util.ExternalResourceReleasable;
|
||||
|
||||
|
||||
/**
|
||||
@ -51,7 +51,7 @@ import org.jboss.netty.util.ExternalResourceReleasable;
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @apiviz.landmark
|
||||
* @apiviz.has org.jboss.netty.channel.Channel oneway - - creates
|
||||
* @apiviz.has io.netty.channel.Channel oneway - - creates
|
||||
*
|
||||
* @apiviz.exclude ^org\.jboss\.netty\.channel\.([a-z]+\.)+.*ChannelFactory$
|
||||
*/
|
||||
|
||||
@ -13,12 +13,12 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
import java.util.concurrent.TimeUnit;
|
||||
|
||||
import org.jboss.netty.bootstrap.ClientBootstrap;
|
||||
import org.jboss.netty.handler.execution.ExecutionHandler;
|
||||
import io.netty.bootstrap.ClientBootstrap;
|
||||
import io.netty.handler.execution.ExecutionHandler;
|
||||
|
||||
/**
|
||||
* The result of an asynchronous {@link Channel} I/O operation.
|
||||
@ -168,7 +168,7 @@ import org.jboss.netty.handler.execution.ExecutionHandler;
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @apiviz.landmark
|
||||
* @apiviz.owns org.jboss.netty.channel.ChannelFutureListener - - notifies
|
||||
* @apiviz.owns io.netty.channel.ChannelFutureListener - - notifies
|
||||
*/
|
||||
public interface ChannelFuture {
|
||||
|
||||
|
||||
@ -14,7 +14,7 @@
|
||||
* under the License.
|
||||
*/
|
||||
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
import java.util.HashSet;
|
||||
import java.util.Set;
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
import java.util.EventListener;
|
||||
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
|
||||
/**
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
import java.lang.annotation.Documented;
|
||||
import java.lang.annotation.ElementType;
|
||||
@ -22,8 +22,8 @@ import java.lang.annotation.Retention;
|
||||
import java.lang.annotation.RetentionPolicy;
|
||||
import java.lang.annotation.Target;
|
||||
|
||||
import org.jboss.netty.bootstrap.Bootstrap;
|
||||
import org.jboss.netty.channel.group.ChannelGroup;
|
||||
import io.netty.bootstrap.Bootstrap;
|
||||
import io.netty.channel.group.ChannelGroup;
|
||||
|
||||
/**
|
||||
* Handles or intercepts a {@link ChannelEvent}, and sends a
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
|
||||
/**
|
||||
@ -120,7 +120,7 @@ package org.jboss.netty.channel;
|
||||
* @author <a href="http://www.jboss.org/netty/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @apiviz.owns org.jboss.netty.channel.ChannelHandler
|
||||
* @apiviz.owns io.netty.channel.ChannelHandler
|
||||
*/
|
||||
public interface ChannelHandlerContext {
|
||||
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
/**
|
||||
* A {@link RuntimeException} which is thrown when a
|
||||
|
||||
@ -13,11 +13,11 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
import java.util.concurrent.ConcurrentMap;
|
||||
|
||||
import org.jboss.netty.util.internal.ConcurrentIdentityWeakKeyHashMap;
|
||||
import io.netty.util.internal.ConcurrentIdentityWeakKeyHashMap;
|
||||
|
||||
/**
|
||||
* A global variable that is local to a {@link Channel}. Think of this as a
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
import java.io.InputStream;
|
||||
import java.io.OutputStream;
|
||||
@ -21,10 +21,10 @@ import java.util.List;
|
||||
import java.util.Map;
|
||||
import java.util.NoSuchElementException;
|
||||
|
||||
import org.jboss.netty.buffer.ChannelBuffer;
|
||||
import org.jboss.netty.handler.execution.ExecutionHandler;
|
||||
import org.jboss.netty.handler.execution.OrderedMemoryAwareThreadPoolExecutor;
|
||||
import org.jboss.netty.handler.ssl.SslHandler;
|
||||
import io.netty.buffer.ChannelBuffer;
|
||||
import io.netty.handler.execution.ExecutionHandler;
|
||||
import io.netty.handler.execution.OrderedMemoryAwareThreadPoolExecutor;
|
||||
import io.netty.handler.ssl.SslHandler;
|
||||
|
||||
|
||||
/**
|
||||
@ -46,7 +46,7 @@ import org.jboss.netty.handler.ssl.SslHandler;
|
||||
* {@link Channels} rather than calling an individual implementation's
|
||||
* constructor:
|
||||
* <pre>
|
||||
* import static org.jboss.netty.channel.{@link Channels}.*;
|
||||
* import static io.netty.channel.{@link Channels}.*;
|
||||
* {@link ChannelPipeline} pipeline = pipeline(); // same with Channels.pipeline()
|
||||
* </pre>
|
||||
*
|
||||
@ -205,9 +205,9 @@ import org.jboss.netty.handler.ssl.SslHandler;
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @apiviz.landmark
|
||||
* @apiviz.composedOf org.jboss.netty.channel.ChannelHandlerContext
|
||||
* @apiviz.owns org.jboss.netty.channel.ChannelHandler
|
||||
* @apiviz.uses org.jboss.netty.channel.ChannelSink - - sends events downstream
|
||||
* @apiviz.composedOf io.netty.channel.ChannelHandlerContext
|
||||
* @apiviz.owns io.netty.channel.ChannelHandler
|
||||
* @apiviz.uses io.netty.channel.ChannelSink - - sends events downstream
|
||||
*/
|
||||
public interface ChannelPipeline {
|
||||
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
/**
|
||||
* A {@link ChannelException} which is thrown when a {@link ChannelPipeline}
|
||||
|
||||
@ -13,11 +13,11 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
import org.jboss.netty.bootstrap.Bootstrap;
|
||||
import org.jboss.netty.bootstrap.ClientBootstrap;
|
||||
import org.jboss.netty.bootstrap.ConnectionlessBootstrap;
|
||||
import io.netty.bootstrap.Bootstrap;
|
||||
import io.netty.bootstrap.ClientBootstrap;
|
||||
import io.netty.bootstrap.ConnectionlessBootstrap;
|
||||
|
||||
/**
|
||||
* Creates a new {@link ChannelPipeline} for a new {@link Channel}.
|
||||
@ -35,7 +35,7 @@ import org.jboss.netty.bootstrap.ConnectionlessBootstrap;
|
||||
* @author <a href="http://www.jboss.org/netty/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @apiviz.has org.jboss.netty.channel.ChannelPipeline oneway - - creates
|
||||
* @apiviz.has io.netty.channel.ChannelPipeline oneway - - creates
|
||||
*/
|
||||
public interface ChannelPipelineFactory {
|
||||
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
|
||||
/**
|
||||
@ -26,7 +26,7 @@ package org.jboss.netty.channel;
|
||||
* @author <a href="http://www.jboss.org/netty/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @apiviz.uses org.jboss.netty.channel.ChannelPipeline - - sends events upstream
|
||||
* @apiviz.uses io.netty.channel.ChannelPipeline - - sends events upstream
|
||||
*/
|
||||
public interface ChannelSink {
|
||||
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
import java.net.SocketAddress;
|
||||
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
|
||||
/**
|
||||
@ -27,7 +27,7 @@ package org.jboss.netty.channel;
|
||||
* @author <a href="http://www.jboss.org/netty/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @apiviz.has org.jboss.netty.channel.ChannelState
|
||||
* @apiviz.has io.netty.channel.ChannelState
|
||||
*/
|
||||
public interface ChannelStateEvent extends ChannelEvent {
|
||||
|
||||
|
||||
@ -13,11 +13,11 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
import java.util.concurrent.Executor;
|
||||
|
||||
import org.jboss.netty.handler.execution.ExecutionHandler;
|
||||
import io.netty.handler.execution.ExecutionHandler;
|
||||
|
||||
|
||||
/**
|
||||
|
||||
@ -13,12 +13,12 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
import java.net.SocketAddress;
|
||||
import java.util.Map;
|
||||
|
||||
import org.jboss.netty.util.internal.ConversionUtil;
|
||||
import io.netty.util.internal.ConversionUtil;
|
||||
|
||||
|
||||
/**
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
/**
|
||||
* A {@link ChannelEvent} which represents the notification of the state of
|
||||
|
||||
@ -13,12 +13,12 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
import java.util.concurrent.TimeUnit;
|
||||
|
||||
import org.jboss.netty.logging.InternalLogger;
|
||||
import org.jboss.netty.logging.InternalLoggerFactory;
|
||||
import io.netty.logging.InternalLogger;
|
||||
import io.netty.logging.InternalLoggerFactory;
|
||||
|
||||
/**
|
||||
* A skeletal {@link ChannelFuture} implementation which represents a
|
||||
|
||||
@ -13,15 +13,15 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
import java.util.Map;
|
||||
import java.util.Map.Entry;
|
||||
|
||||
import org.jboss.netty.buffer.ChannelBufferFactory;
|
||||
import org.jboss.netty.buffer.HeapChannelBufferFactory;
|
||||
import org.jboss.netty.channel.socket.SocketChannelConfig;
|
||||
import org.jboss.netty.util.internal.ConversionUtil;
|
||||
import io.netty.buffer.ChannelBufferFactory;
|
||||
import io.netty.buffer.HeapChannelBufferFactory;
|
||||
import io.netty.channel.socket.SocketChannelConfig;
|
||||
import io.netty.util.internal.ConversionUtil;
|
||||
|
||||
/**
|
||||
* The default {@link SocketChannelConfig} implementation.
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
import static java.util.concurrent.TimeUnit.*;
|
||||
|
||||
@ -22,9 +22,9 @@ import java.util.Collection;
|
||||
import java.util.List;
|
||||
import java.util.concurrent.TimeUnit;
|
||||
|
||||
import org.jboss.netty.logging.InternalLogger;
|
||||
import org.jboss.netty.logging.InternalLoggerFactory;
|
||||
import org.jboss.netty.util.internal.DeadLockProofWorker;
|
||||
import io.netty.logging.InternalLogger;
|
||||
import io.netty.logging.InternalLoggerFactory;
|
||||
import io.netty.util.internal.DeadLockProofWorker;
|
||||
|
||||
/**
|
||||
* The default {@link ChannelFuture} implementation. It is recommended to
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
import java.util.ArrayList;
|
||||
import java.util.HashMap;
|
||||
@ -22,8 +22,8 @@ import java.util.List;
|
||||
import java.util.Map;
|
||||
import java.util.NoSuchElementException;
|
||||
|
||||
import org.jboss.netty.logging.InternalLogger;
|
||||
import org.jboss.netty.logging.InternalLoggerFactory;
|
||||
import io.netty.logging.InternalLogger;
|
||||
import io.netty.logging.InternalLoggerFactory;
|
||||
|
||||
/**
|
||||
* The default {@link ChannelPipeline} implementation. It is recommended
|
||||
|
||||
@ -13,9 +13,9 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
import static org.jboss.netty.channel.Channels.*;
|
||||
import static io.netty.channel.Channels.*;
|
||||
|
||||
/**
|
||||
* The default {@link ChildChannelStateEvent} implementation.
|
||||
|
||||
@ -13,11 +13,11 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
import static org.jboss.netty.channel.Channels.*;
|
||||
import static io.netty.channel.Channels.*;
|
||||
|
||||
import org.jboss.netty.util.internal.StackTraceSimplifier;
|
||||
import io.netty.util.internal.StackTraceSimplifier;
|
||||
|
||||
/**
|
||||
* The default {@link ExceptionEvent} implementation.
|
||||
|
||||
@ -1,11 +1,11 @@
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
import java.io.IOException;
|
||||
import java.nio.channels.FileChannel;
|
||||
import java.nio.channels.WritableByteChannel;
|
||||
|
||||
import org.jboss.netty.logging.InternalLogger;
|
||||
import org.jboss.netty.logging.InternalLoggerFactory;
|
||||
import io.netty.logging.InternalLogger;
|
||||
import io.netty.logging.InternalLoggerFactory;
|
||||
|
||||
public class DefaultFileRegion implements FileRegion {
|
||||
|
||||
|
||||
@ -13,14 +13,14 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
import java.util.Map;
|
||||
import java.util.Map.Entry;
|
||||
|
||||
import org.jboss.netty.buffer.ChannelBufferFactory;
|
||||
import org.jboss.netty.buffer.HeapChannelBufferFactory;
|
||||
import org.jboss.netty.channel.socket.ServerSocketChannelConfig;
|
||||
import io.netty.buffer.ChannelBufferFactory;
|
||||
import io.netty.buffer.HeapChannelBufferFactory;
|
||||
import io.netty.channel.socket.ServerSocketChannelConfig;
|
||||
|
||||
/**
|
||||
* The default {@link ServerSocketChannelConfig} implementation.
|
||||
|
||||
@ -13,9 +13,9 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
import static org.jboss.netty.channel.Channels.*;
|
||||
import static io.netty.channel.Channels.*;
|
||||
|
||||
/**
|
||||
* The default {@link WriteCompletionEvent} implementation.
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
/**
|
||||
* The default downstream {@link ChannelStateEvent} implementation.
|
||||
|
||||
@ -13,11 +13,11 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
import java.net.SocketAddress;
|
||||
|
||||
import org.jboss.netty.util.internal.StringUtil;
|
||||
import io.netty.util.internal.StringUtil;
|
||||
|
||||
/**
|
||||
* The default downstream {@link MessageEvent} implementation.
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
/**
|
||||
* A {@link ChannelEvent} which represents the notification of an exception
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
/**
|
||||
* The {@link CompleteChannelFuture} which is failed already. It is
|
||||
|
||||
@ -13,13 +13,13 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
import java.io.IOException;
|
||||
import java.nio.channels.FileChannel;
|
||||
import java.nio.channels.WritableByteChannel;
|
||||
|
||||
import org.jboss.netty.util.ExternalResourceReleasable;
|
||||
import io.netty.util.ExternalResourceReleasable;
|
||||
|
||||
/**
|
||||
* A region of a file that is sent via a {@link Channel} which supports
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
|
||||
/**
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
|
||||
/**
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
/**
|
||||
* A {@link ChannelHandler} that is notified when it is added to or removed
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
import java.net.SocketAddress;
|
||||
|
||||
|
||||
@ -13,9 +13,9 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
import org.jboss.netty.buffer.ChannelBuffer;
|
||||
import io.netty.buffer.ChannelBuffer;
|
||||
|
||||
/**
|
||||
* Predicts the number of readable bytes in the receive buffer of a
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
/**
|
||||
* Creates a new {@link ReceiveBufferSizePredictor}.
|
||||
@ -21,7 +21,7 @@ package org.jboss.netty.channel;
|
||||
* @author <a href="http://www.jboss.org/netty/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @apiviz.has org.jboss.netty.channel.ReceiveBufferSizePredictor oneway - - creates
|
||||
* @apiviz.has io.netty.channel.ReceiveBufferSizePredictor oneway - - creates
|
||||
*/
|
||||
public interface ReceiveBufferSizePredictorFactory {
|
||||
|
||||
|
||||
@ -13,9 +13,9 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
import org.jboss.netty.channel.socket.ServerSocketChannel;
|
||||
import io.netty.channel.socket.ServerSocketChannel;
|
||||
|
||||
/**
|
||||
* A {@link Channel} that accepts an incoming connection attempt and creates
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
/**
|
||||
* A {@link ChannelFactory} that creates a {@link ServerChannel}.
|
||||
@ -21,7 +21,7 @@ package org.jboss.netty.channel;
|
||||
* @author <a href="http://www.jboss.org/netty/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @apiviz.has org.jboss.netty.channel.ServerChannel oneway - - creates
|
||||
* @apiviz.has io.netty.channel.ServerChannel oneway - - creates
|
||||
*/
|
||||
public interface ServerChannelFactory extends ChannelFactory {
|
||||
@Override
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
import java.net.SocketAddress;
|
||||
|
||||
|
||||
@ -13,13 +13,13 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
import java.net.SocketAddress;
|
||||
|
||||
import org.jboss.netty.buffer.ChannelBuffer;
|
||||
import org.jboss.netty.logging.InternalLogger;
|
||||
import org.jboss.netty.logging.InternalLoggerFactory;
|
||||
import io.netty.buffer.ChannelBuffer;
|
||||
import io.netty.logging.InternalLogger;
|
||||
import io.netty.logging.InternalLoggerFactory;
|
||||
|
||||
|
||||
/**
|
||||
|
||||
@ -13,11 +13,11 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
import org.jboss.netty.buffer.ChannelBuffer;
|
||||
import org.jboss.netty.logging.InternalLogger;
|
||||
import org.jboss.netty.logging.InternalLoggerFactory;
|
||||
import io.netty.buffer.ChannelBuffer;
|
||||
import io.netty.logging.InternalLogger;
|
||||
import io.netty.logging.InternalLoggerFactory;
|
||||
|
||||
|
||||
/**
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
import java.util.ArrayList;
|
||||
import java.util.HashMap;
|
||||
@ -21,9 +21,9 @@ import java.util.LinkedHashMap;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
|
||||
import org.jboss.netty.logging.InternalLogger;
|
||||
import org.jboss.netty.logging.InternalLoggerFactory;
|
||||
import org.jboss.netty.util.internal.ConversionUtil;
|
||||
import io.netty.logging.InternalLogger;
|
||||
import io.netty.logging.InternalLoggerFactory;
|
||||
import io.netty.util.internal.ConversionUtil;
|
||||
|
||||
/**
|
||||
* A {@link ChannelPipeline} that might perform better at the cost of
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
/**
|
||||
* The {@link CompleteChannelFuture} which is succeeded already. It is
|
||||
|
||||
@ -13,9 +13,9 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
import static org.jboss.netty.channel.Channels.*;
|
||||
import static io.netty.channel.Channels.*;
|
||||
|
||||
/**
|
||||
* The default upstream {@link ChannelStateEvent} implementation.
|
||||
|
||||
@ -13,13 +13,13 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
import static org.jboss.netty.channel.Channels.*;
|
||||
import static io.netty.channel.Channels.*;
|
||||
|
||||
import java.net.SocketAddress;
|
||||
|
||||
import org.jboss.netty.util.internal.StringUtil;
|
||||
import io.netty.util.internal.StringUtil;
|
||||
|
||||
/**
|
||||
* The default upstream {@link MessageEvent} implementation.
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel;
|
||||
package io.netty.channel;
|
||||
|
||||
/**
|
||||
* A {@link ChannelEvent} which represents the notification of the completion
|
||||
|
||||
@ -13,20 +13,20 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel.group;
|
||||
package io.netty.channel.group;
|
||||
|
||||
import java.net.SocketAddress;
|
||||
import java.util.Set;
|
||||
|
||||
import org.jboss.netty.bootstrap.ServerBootstrap;
|
||||
import org.jboss.netty.buffer.ChannelBuffer;
|
||||
import org.jboss.netty.buffer.ChannelBuffers;
|
||||
import org.jboss.netty.channel.Channel;
|
||||
import org.jboss.netty.channel.ChannelHandlerContext;
|
||||
import org.jboss.netty.channel.ChannelStateEvent;
|
||||
import org.jboss.netty.channel.ServerChannel;
|
||||
import org.jboss.netty.channel.SimpleChannelUpstreamHandler;
|
||||
import org.jboss.netty.util.CharsetUtil;
|
||||
import io.netty.bootstrap.ServerBootstrap;
|
||||
import io.netty.buffer.ChannelBuffer;
|
||||
import io.netty.buffer.ChannelBuffers;
|
||||
import io.netty.channel.Channel;
|
||||
import io.netty.channel.ChannelHandlerContext;
|
||||
import io.netty.channel.ChannelStateEvent;
|
||||
import io.netty.channel.ServerChannel;
|
||||
import io.netty.channel.SimpleChannelUpstreamHandler;
|
||||
import io.netty.util.CharsetUtil;
|
||||
|
||||
/**
|
||||
* A thread-safe {@link Set} that contains open {@link Channel}s and provides
|
||||
@ -92,7 +92,7 @@ import org.jboss.netty.util.CharsetUtil;
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @apiviz.landmark
|
||||
* @apiviz.has org.jboss.netty.channel.group.ChannelGroupFuture oneway - - returns
|
||||
* @apiviz.has io.netty.channel.group.ChannelGroupFuture oneway - - returns
|
||||
*/
|
||||
public interface ChannelGroup extends Set<Channel>, Comparable<ChannelGroup> {
|
||||
|
||||
|
||||
@ -13,18 +13,18 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel.group;
|
||||
package io.netty.channel.group;
|
||||
|
||||
import java.util.Iterator;
|
||||
import java.util.concurrent.TimeUnit;
|
||||
|
||||
import org.jboss.netty.channel.Channel;
|
||||
import org.jboss.netty.channel.ChannelFuture;
|
||||
import org.jboss.netty.channel.ChannelHandler;
|
||||
import org.jboss.netty.channel.ChannelHandlerContext;
|
||||
import org.jboss.netty.channel.ChannelPipeline;
|
||||
import org.jboss.netty.channel.MessageEvent;
|
||||
import org.jboss.netty.handler.execution.ExecutionHandler;
|
||||
import io.netty.channel.Channel;
|
||||
import io.netty.channel.ChannelFuture;
|
||||
import io.netty.channel.ChannelHandler;
|
||||
import io.netty.channel.ChannelHandlerContext;
|
||||
import io.netty.channel.ChannelPipeline;
|
||||
import io.netty.channel.MessageEvent;
|
||||
import io.netty.handler.execution.ExecutionHandler;
|
||||
|
||||
/**
|
||||
* The result of an asynchronous {@link ChannelGroup} operation.
|
||||
@ -111,7 +111,7 @@ import org.jboss.netty.handler.execution.ExecutionHandler;
|
||||
* @author <a href="http://www.jboss.org/netty/">The Netty Project</a>
|
||||
* @author <a href="http://gleamynode.net/">Trustin Lee</a>
|
||||
*
|
||||
* @apiviz.owns org.jboss.netty.channel.group.ChannelGroupFutureListener - - notifies
|
||||
* @apiviz.owns io.netty.channel.group.ChannelGroupFutureListener - - notifies
|
||||
*/
|
||||
public interface ChannelGroupFuture extends Iterable<ChannelFuture> {
|
||||
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel.group;
|
||||
package io.netty.channel.group;
|
||||
|
||||
import java.util.EventListener;
|
||||
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel.group;
|
||||
package io.netty.channel.group;
|
||||
|
||||
import java.util.Iterator;
|
||||
import java.util.NoSuchElementException;
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel.group;
|
||||
package io.netty.channel.group;
|
||||
|
||||
import java.net.SocketAddress;
|
||||
import java.util.AbstractSet;
|
||||
@ -25,12 +25,12 @@ import java.util.Map;
|
||||
import java.util.concurrent.ConcurrentMap;
|
||||
import java.util.concurrent.atomic.AtomicInteger;
|
||||
|
||||
import org.jboss.netty.buffer.ChannelBuffer;
|
||||
import org.jboss.netty.channel.Channel;
|
||||
import org.jboss.netty.channel.ChannelFuture;
|
||||
import org.jboss.netty.channel.ChannelFutureListener;
|
||||
import org.jboss.netty.channel.ServerChannel;
|
||||
import org.jboss.netty.util.internal.ConcurrentHashMap;
|
||||
import io.netty.buffer.ChannelBuffer;
|
||||
import io.netty.channel.Channel;
|
||||
import io.netty.channel.ChannelFuture;
|
||||
import io.netty.channel.ChannelFutureListener;
|
||||
import io.netty.channel.ServerChannel;
|
||||
import io.netty.util.internal.ConcurrentHashMap;
|
||||
|
||||
/**
|
||||
* The default {@link ChannelGroup} implementation.
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel.group;
|
||||
package io.netty.channel.group;
|
||||
|
||||
import static java.util.concurrent.TimeUnit.*;
|
||||
|
||||
@ -26,12 +26,12 @@ import java.util.List;
|
||||
import java.util.Map;
|
||||
import java.util.concurrent.TimeUnit;
|
||||
|
||||
import org.jboss.netty.channel.Channel;
|
||||
import org.jboss.netty.channel.ChannelFuture;
|
||||
import org.jboss.netty.channel.ChannelFutureListener;
|
||||
import org.jboss.netty.logging.InternalLogger;
|
||||
import org.jboss.netty.logging.InternalLoggerFactory;
|
||||
import org.jboss.netty.util.internal.DeadLockProofWorker;
|
||||
import io.netty.channel.Channel;
|
||||
import io.netty.channel.ChannelFuture;
|
||||
import io.netty.channel.ChannelFutureListener;
|
||||
import io.netty.logging.InternalLogger;
|
||||
import io.netty.logging.InternalLoggerFactory;
|
||||
import io.netty.util.internal.DeadLockProofWorker;
|
||||
|
||||
/**
|
||||
* The default {@link ChannelGroupFuture} implementation.
|
||||
|
||||
@ -16,9 +16,9 @@
|
||||
|
||||
/**
|
||||
* A channel registry which helps a user maintain the list of open
|
||||
* {@link org.jboss.netty.channel.Channel}s and perform bulk operations on them.
|
||||
* {@link io.netty.channel.Channel}s and perform bulk operations on them.
|
||||
*
|
||||
* @apiviz.exclude ^java
|
||||
* @apiviz.exclude \.DefaultChannelGroupFuture$
|
||||
*/
|
||||
package org.jboss.netty.channel.group;
|
||||
package io.netty.channel.group;
|
||||
|
||||
@ -13,7 +13,7 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel.iostream;
|
||||
package io.netty.channel.iostream;
|
||||
|
||||
import java.io.InputStream;
|
||||
import java.io.OutputStream;
|
||||
|
||||
@ -13,9 +13,9 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel.iostream;
|
||||
package io.netty.channel.iostream;
|
||||
|
||||
import org.jboss.netty.channel.*;
|
||||
import io.netty.channel.*;
|
||||
|
||||
import java.net.SocketAddress;
|
||||
|
||||
|
||||
@ -13,21 +13,21 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel.iostream;
|
||||
package io.netty.channel.iostream;
|
||||
|
||||
|
||||
import org.jboss.netty.channel.Channel;
|
||||
import org.jboss.netty.channel.ChannelFactory;
|
||||
import org.jboss.netty.channel.ChannelPipeline;
|
||||
import org.jboss.netty.channel.group.ChannelGroup;
|
||||
import org.jboss.netty.channel.group.ChannelGroupFuture;
|
||||
import org.jboss.netty.channel.group.DefaultChannelGroup;
|
||||
import org.jboss.netty.util.internal.ExecutorUtil;
|
||||
import io.netty.channel.Channel;
|
||||
import io.netty.channel.ChannelFactory;
|
||||
import io.netty.channel.ChannelPipeline;
|
||||
import io.netty.channel.group.ChannelGroup;
|
||||
import io.netty.channel.group.ChannelGroupFuture;
|
||||
import io.netty.channel.group.DefaultChannelGroup;
|
||||
import io.netty.util.internal.ExecutorUtil;
|
||||
|
||||
import java.util.concurrent.ExecutorService;
|
||||
|
||||
/**
|
||||
* A {@link org.jboss.netty.channel.ChannelFactory} for creating {@link IOStreamChannel} instances.
|
||||
* A {@link io.netty.channel.ChannelFactory} for creating {@link IOStreamChannel} instances.
|
||||
*
|
||||
* @author Daniel Bimschas
|
||||
* @author Dennis Pfisterer
|
||||
|
||||
@ -13,20 +13,20 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel.iostream;
|
||||
package io.netty.channel.iostream;
|
||||
|
||||
import org.jboss.netty.buffer.ChannelBuffer;
|
||||
import org.jboss.netty.buffer.ChannelBuffers;
|
||||
import org.jboss.netty.channel.*;
|
||||
import io.netty.buffer.ChannelBuffer;
|
||||
import io.netty.buffer.ChannelBuffers;
|
||||
import io.netty.channel.*;
|
||||
|
||||
import java.io.OutputStream;
|
||||
import java.io.PushbackInputStream;
|
||||
import java.util.concurrent.ExecutorService;
|
||||
|
||||
import static org.jboss.netty.channel.Channels.*;
|
||||
import static io.netty.channel.Channels.*;
|
||||
|
||||
/**
|
||||
* A {@link org.jboss.netty.channel.ChannelSink} implementation which reads from
|
||||
* 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
|
||||
|
||||
@ -13,27 +13,27 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel.local;
|
||||
package io.netty.channel.local;
|
||||
|
||||
import static org.jboss.netty.channel.Channels.*;
|
||||
import static io.netty.channel.Channels.*;
|
||||
|
||||
import java.nio.channels.ClosedChannelException;
|
||||
import java.nio.channels.NotYetConnectedException;
|
||||
import java.util.Queue;
|
||||
import java.util.concurrent.atomic.AtomicInteger;
|
||||
|
||||
import org.jboss.netty.channel.AbstractChannel;
|
||||
import org.jboss.netty.channel.ChannelConfig;
|
||||
import org.jboss.netty.channel.ChannelException;
|
||||
import org.jboss.netty.channel.ChannelFactory;
|
||||
import org.jboss.netty.channel.ChannelFuture;
|
||||
import org.jboss.netty.channel.ChannelFutureListener;
|
||||
import org.jboss.netty.channel.ChannelPipeline;
|
||||
import org.jboss.netty.channel.ChannelSink;
|
||||
import org.jboss.netty.channel.DefaultChannelConfig;
|
||||
import org.jboss.netty.channel.MessageEvent;
|
||||
import org.jboss.netty.util.internal.QueueFactory;
|
||||
import org.jboss.netty.util.internal.ThreadLocalBoolean;
|
||||
import io.netty.channel.AbstractChannel;
|
||||
import io.netty.channel.ChannelConfig;
|
||||
import io.netty.channel.ChannelException;
|
||||
import io.netty.channel.ChannelFactory;
|
||||
import io.netty.channel.ChannelFuture;
|
||||
import io.netty.channel.ChannelFutureListener;
|
||||
import io.netty.channel.ChannelPipeline;
|
||||
import io.netty.channel.ChannelSink;
|
||||
import io.netty.channel.DefaultChannelConfig;
|
||||
import io.netty.channel.MessageEvent;
|
||||
import io.netty.util.internal.QueueFactory;
|
||||
import io.netty.util.internal.ThreadLocalBoolean;
|
||||
|
||||
/**
|
||||
* @author <a href="http://www.jboss.org/netty/">The Netty Project</a>
|
||||
|
||||
@ -13,10 +13,10 @@
|
||||
* License for the specific language governing permissions and limitations
|
||||
* under the License.
|
||||
*/
|
||||
package org.jboss.netty.channel.local;
|
||||
package io.netty.channel.local;
|
||||
|
||||
import org.jboss.netty.channel.ChannelPipeline;
|
||||
import org.jboss.netty.channel.ChannelSink;
|
||||
import io.netty.channel.ChannelPipeline;
|
||||
import io.netty.channel.ChannelSink;
|
||||
|
||||
/**
|
||||
* The default {@link LocalClientChannelFactory} implementation.
|
||||
|
||||
Some files were not shown because too many files have changed in this diff Show More
Loading…
Reference in New Issue
Block a user