* Added missing svn properties

* Updated @author tags
This commit is contained in:
Trustin Lee 2009-02-09 08:32:13 +00:00
parent ddf8cad09c
commit 78cdc91acd
12 changed files with 44 additions and 19 deletions

View File

@ -31,7 +31,7 @@ import org.jboss.netty.channel.ChannelSink;
* @author Trustin Lee (tlee@redhat.com) * @author Trustin Lee (tlee@redhat.com)
* @version $Rev$, $Date$ * @version $Rev$, $Date$
*/ */
class LocalAcceptedChannel extends LocalChannel { final class LocalAcceptedChannel extends LocalChannel {
LocalAcceptedChannel(LocalServerChannel parent, ChannelFactory factory, LocalAcceptedChannel(LocalServerChannel parent, ChannelFactory factory,
ChannelPipeline pipeline, ChannelSink sink, ChannelPipeline pipeline, ChannelSink sink,
LocalChannel pairedChannel) { LocalChannel pairedChannel) {

View File

@ -29,8 +29,10 @@ import org.jboss.netty.channel.ChannelException;
import org.jboss.netty.util.ConcurrentWeakHashMap; import org.jboss.netty.util.ConcurrentWeakHashMap;
/** /**
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> * @author The Netty Project (netty-dev@lists.jboss.org)
* @author Andy Taylor (andy.taylor@jboss.org)
* @author Trustin Lee (tlee@redhat.com) * @author Trustin Lee (tlee@redhat.com)
* @version $Rev$, $Date$
*/ */
public final class LocalAddress extends SocketAddress implements Comparable<LocalAddress> { public final class LocalAddress extends SocketAddress implements Comparable<LocalAddress> {
private static final long serialVersionUID = -3601961747680808645L; private static final long serialVersionUID = -3601961747680808645L;

View File

@ -38,8 +38,10 @@ import org.jboss.netty.channel.MessageEvent;
import org.jboss.netty.util.LinkedTransferQueue; import org.jboss.netty.util.LinkedTransferQueue;
/** /**
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> * @author The Netty Project (netty-dev@lists.jboss.org)
* @author Andy Taylor (andy.taylor@jboss.org)
* @author Trustin Lee (tlee@redhat.com) * @author Trustin Lee (tlee@redhat.com)
* @version $Rev$, $Date$
*/ */
class LocalChannel extends AbstractChannel { class LocalChannel extends AbstractChannel {
private final ThreadLocal<Boolean> delivering = new ThreadLocal<Boolean>() { private final ThreadLocal<Boolean> delivering = new ThreadLocal<Boolean>() {

View File

@ -30,8 +30,10 @@ import org.jboss.netty.channel.ChannelConfig;
import org.jboss.netty.channel.ChannelPipelineFactory; import org.jboss.netty.channel.ChannelPipelineFactory;
/** /**
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> * @author The Netty Project (netty-dev@lists.jboss.org)
* @author Andy Taylor (andy.taylor@jboss.org)
* @author Trustin Lee (tlee@redhat.com) * @author Trustin Lee (tlee@redhat.com)
* @version $Rev$, $Date$
*/ */
class LocalChannelConfig implements ChannelConfig { class LocalChannelConfig implements ChannelConfig {

View File

@ -31,7 +31,7 @@ import org.jboss.netty.channel.ChannelSink;
* @author Trustin Lee (tlee@redhat.com) * @author Trustin Lee (tlee@redhat.com)
* @version $Rev$, $Date$ * @version $Rev$, $Date$
*/ */
class LocalClientChannel extends LocalChannel { final class LocalClientChannel extends LocalChannel {
LocalClientChannel(ChannelFactory factory, LocalClientChannel(ChannelFactory factory,
ChannelPipeline pipeline, ChannelSink sink, ChannelPipeline pipeline, ChannelSink sink,
LocalChannel pairedChannel) { LocalChannel pairedChannel) {

View File

@ -27,8 +27,10 @@ import org.jboss.netty.channel.ChannelPipeline;
import org.jboss.netty.channel.ChannelSink; import org.jboss.netty.channel.ChannelSink;
/** /**
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> * @author The Netty Project (netty-dev@lists.jboss.org)
* @author Andy Taylor (andy.taylor@jboss.org)
* @author Trustin Lee (tlee@redhat.com) * @author Trustin Lee (tlee@redhat.com)
* @version $Rev$, $Date$
*/ */
public class LocalClientChannelFactory implements ChannelFactory { public class LocalClientChannelFactory implements ChannelFactory {

View File

@ -38,7 +38,10 @@ import org.jboss.netty.logging.InternalLogger;
import org.jboss.netty.logging.InternalLoggerFactory; import org.jboss.netty.logging.InternalLoggerFactory;
/** /**
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> * @author The Netty Project (netty-dev@lists.jboss.org)
* @author Andy Taylor (andy.taylor@jboss.org)
* @author Trustin Lee (tlee@redhat.com)
* @version $Rev$, $Date$
*/ */
final class LocalClientChannelSink extends AbstractChannelSink { final class LocalClientChannelSink extends AbstractChannelSink {

View File

@ -32,8 +32,10 @@ import org.jboss.netty.channel.ChannelPipeline;
import org.jboss.netty.channel.ChannelSink; import org.jboss.netty.channel.ChannelSink;
/** /**
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> * @author The Netty Project (netty-dev@lists.jboss.org)
* @author Andy Taylor (andy.taylor@jboss.org)
* @author Trustin Lee (tlee@redhat.com) * @author Trustin Lee (tlee@redhat.com)
* @version $Rev$, $Date$
*/ */
final class LocalServerChannel extends AbstractServerChannel { final class LocalServerChannel extends AbstractServerChannel {
final ChannelConfig channelConfig; final ChannelConfig channelConfig;

View File

@ -27,7 +27,10 @@ import org.jboss.netty.channel.ChannelPipeline;
import org.jboss.netty.channel.ChannelSink; import org.jboss.netty.channel.ChannelSink;
/** /**
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> * @author The Netty Project (netty-dev@lists.jboss.org)
* @author Andy Taylor (andy.taylor@jboss.org)
* @author Trustin Lee (tlee@redhat.com)
* @version $Rev$, $Date$
*/ */
public class LocalServerChannelFactory implements ChannelFactory { public class LocalServerChannelFactory implements ChannelFactory {

View File

@ -34,7 +34,10 @@ import org.jboss.netty.channel.ChannelStateEvent;
import org.jboss.netty.channel.MessageEvent; import org.jboss.netty.channel.MessageEvent;
/** /**
* @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> * @author The Netty Project (netty-dev@lists.jboss.org)
* @author Andy Taylor (andy.taylor@jboss.org)
* @author Trustin Lee (tlee@redhat.com)
* @version $Rev$, $Date$
*/ */
final class LocalServerChannelSink extends AbstractChannelSink { final class LocalServerChannelSink extends AbstractChannelSink {

View File

@ -26,16 +26,17 @@ import java.io.InputStreamReader;
import org.jboss.netty.bootstrap.ClientBootstrap; import org.jboss.netty.bootstrap.ClientBootstrap;
import org.jboss.netty.bootstrap.ServerBootstrap; import org.jboss.netty.bootstrap.ServerBootstrap;
import org.jboss.netty.channel.Channel; import org.jboss.netty.channel.ChannelDownstreamHandler;
import org.jboss.netty.channel.ChannelEvent;
import org.jboss.netty.channel.ChannelFactory; import org.jboss.netty.channel.ChannelFactory;
import org.jboss.netty.channel.ChannelFuture; import org.jboss.netty.channel.ChannelFuture;
import org.jboss.netty.channel.ChannelHandlerContext; import org.jboss.netty.channel.ChannelHandlerContext;
import org.jboss.netty.channel.ChannelPipelineCoverage; import org.jboss.netty.channel.ChannelPipelineCoverage;
import org.jboss.netty.channel.ChannelUpstreamHandler;
import org.jboss.netty.channel.local.LocalAddress; import org.jboss.netty.channel.local.LocalAddress;
import org.jboss.netty.channel.local.LocalClientChannelFactory; import org.jboss.netty.channel.local.LocalClientChannelFactory;
import org.jboss.netty.channel.local.LocalServerChannelFactory; import org.jboss.netty.channel.local.LocalServerChannelFactory;
import org.jboss.netty.example.echo.EchoHandler; import org.jboss.netty.example.echo.EchoHandler;
import org.jboss.netty.handler.codec.oneone.OneToOneDecoder;
import org.jboss.netty.handler.codec.string.StringDecoder; import org.jboss.netty.handler.codec.string.StringDecoder;
import org.jboss.netty.handler.codec.string.StringEncoder; import org.jboss.netty.handler.codec.string.StringEncoder;
@ -84,12 +85,17 @@ public class LocalExample {
} }
@ChannelPipelineCoverage("all") @ChannelPipelineCoverage("all")
static class PrintHandler extends OneToOneDecoder { static class PrintHandler implements ChannelUpstreamHandler, ChannelDownstreamHandler {
@Override public void handleUpstream(ChannelHandlerContext ctx, ChannelEvent e)
protected Object decode(ChannelHandlerContext ctx, Channel channel, Object msg) throws Exception { throws Exception {
String message = (String) msg; System.err.println(e);
System.out.println("received message back '" + message + "'"); ctx.sendUpstream(e);
return message; }
public void handleDownstream(ChannelHandlerContext ctx, ChannelEvent e)
throws Exception {
System.err.println(e);
ctx.sendDownstream(e);
} }
} }
} }

View File

@ -53,7 +53,7 @@ import java.util.concurrent.locks.ReentrantLock;
* @author Doug Lea * @author Doug Lea
* @author Jason T. Greene * @author Jason T. Greene
* @author Trustin Lee (tlee@redhat.com) * @author Trustin Lee (tlee@redhat.com)
* @version $Rev: 557 $, $Date: 2008-12-03 09:39:33 +0900 (Wed, 03 Dec 2008) $ * @version $Rev$, $Date$
* *
* @param <K> the type of keys maintained by this map * @param <K> the type of keys maintained by this map
* @param <V> the type of mapped values * @param <V> the type of mapped values