Added the initial implementation of codec embedder

src/main/java/org/jboss/netty/handler/codec/embedder/AbstractCodecEmbedder.java

@@ -0,0 +1,70 @@
+/*
+ * JBoss, Home of Professional Open Source
+ *
+ * Copyright 2008, Red Hat Middleware LLC, and individual contributors
+ * by the @author tags. See the COPYRIGHT.txt in the distribution for a
+ * full listing of individual contributors.
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as
+ * published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This software is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+package org.jboss.netty.handler.codec.embedder;
+
+import static org.jboss.netty.channel.Channels.*;
+
+import org.jboss.netty.channel.Channel;
+import org.jboss.netty.channel.ChannelHandler;
+
+/**
+ * @author The Netty Project (netty-dev@lists.jboss.org)
+ * @author Trustin Lee (tlee@redhat.com)
+ * @version $Rev$, $Date$
+ */
+abstract class AbstractCodecEmbedder<T> implements CodecEmbedder<T> {
+
+    final EmbeddedChannelHandlerContext context;
+
+    AbstractCodecEmbedder(ChannelHandler handler) {
+        if (handler == null) {
+            throw new NullPointerException("handler");
+        }
+
+        this.context = new EmbeddedChannelHandlerContext(handler);
+
+        // Fire the typical initial events.
+        Channel channel = context.getChannel();
+        fireChannelOpen(context, channel);
+        fireChannelBound(context, channel, channel.getLocalAddress());
+        fireChannelConnected(context, channel, channel.getRemoteAddress());
+    }
+
+    public boolean finish() {
+        Channel channel = context.getChannel();
+        fireChannelDisconnected(context, channel);
+        fireChannelUnbound(context, channel);
+        fireChannelClosed(context, channel);
+        return context.productQueue.isEmpty();
+    }
+
+    @SuppressWarnings("unchecked")
+    public T poll() {
+        return (T) context.productQueue.poll();
+    }
+
+    @SuppressWarnings("unchecked")
+    public T peek() {
+        return (T) context.productQueue.peek();
+    }
+}

src/main/java/org/jboss/netty/handler/codec/embedder/CodecEmbedder.java

@@ -0,0 +1,36 @@
+/*
+ * JBoss, Home of Professional Open Source
+ *
+ * Copyright 2008, Red Hat Middleware LLC, and individual contributors
+ * by the @author tags. See the COPYRIGHT.txt in the distribution for a
+ * full listing of individual contributors.
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as
+ * published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This software is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+package org.jboss.netty.handler.codec.embedder;
+
+
+/**
+ * @author The Netty Project (netty-dev@lists.jboss.org)
+ * @author Trustin Lee (tlee@redhat.com)
+ * @version $Rev$, $Date$
+ */
+public interface CodecEmbedder<T> {
+    boolean offer(Object input);
+    boolean finish();
+    T poll();
+    T peek();
+}

src/main/java/org/jboss/netty/handler/codec/embedder/CodecEmbedderException.java

@@ -0,0 +1,49 @@
+/*
+ * JBoss, Home of Professional Open Source
+ *
+ * Copyright 2008, Red Hat Middleware LLC, and individual contributors
+ * by the @author tags. See the COPYRIGHT.txt in the distribution for a
+ * full listing of individual contributors.
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as
+ * published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This software is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+package org.jboss.netty.handler.codec.embedder;
+
+/**
+ * @author The Netty Project (netty-dev@lists.jboss.org)
+ * @author Trustin Lee (tlee@redhat.com)
+ * @version $Rev$, $Date$
+ */
+public class CodecEmbedderException extends RuntimeException {
+
+    private static final long serialVersionUID = -6283302594160331474L;
+
+    public CodecEmbedderException() {
+        super();
+    }
+
+    public CodecEmbedderException(String message, Throwable cause) {
+        super(message, cause);
+    }
+
+    public CodecEmbedderException(String message) {
+        super(message);
+    }
+
+    public CodecEmbedderException(Throwable cause) {
+        super(cause);
+    }
+}

src/main/java/org/jboss/netty/handler/codec/embedder/DecoderEmbedder.java

@@ -0,0 +1,44 @@
+/*
+ * JBoss, Home of Professional Open Source
+ *
+ * Copyright 2008, Red Hat Middleware LLC, and individual contributors
+ * by the @author tags. See the COPYRIGHT.txt in the distribution for a
+ * full listing of individual contributors.
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as
+ * published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This software is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+package org.jboss.netty.handler.codec.embedder;
+
+import static org.jboss.netty.channel.Channels.*;
+
+import org.jboss.netty.channel.ChannelUpstreamHandler;
+
+/**
+ * @author The Netty Project (netty-dev@lists.jboss.org)
+ * @author Trustin Lee (tlee@redhat.com)
+ * @version $Rev$, $Date$
+ */
+public class DecoderEmbedder<T> extends AbstractCodecEmbedder<T> {
+
+    public DecoderEmbedder(ChannelUpstreamHandler handler) {
+        super(handler);
+    }
+
+    public boolean offer(Object input) {
+        fireMessageReceived(context.getChannel(), input);
+        return context.productQueue.isEmpty();
+    }
+}

src/main/java/org/jboss/netty/handler/codec/embedder/EmbeddedChannel.java

@@ -0,0 +1,65 @@
+/*
+ * JBoss, Home of Professional Open Source
+ *
+ * Copyright 2008, Red Hat Middleware LLC, and individual contributors
+ * by the @author tags. See the COPYRIGHT.txt in the distribution for a
+ * full listing of individual contributors.
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as
+ * published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This software is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+package org.jboss.netty.handler.codec.embedder;
+
+import java.net.SocketAddress;
+
+import org.jboss.netty.channel.AbstractChannel;
+import org.jboss.netty.channel.ChannelConfig;
+import org.jboss.netty.channel.ChannelPipeline;
+
+/**
+ * @author The Netty Project (netty-dev@lists.jboss.org)
+ * @author Trustin Lee (tlee@redhat.com)
+ * @version $Rev$, $Date$
+ */
+class EmbeddedChannel extends AbstractChannel {
+
+    private final SocketAddress localAddress = new EmbeddedSocketAddress();
+    private final SocketAddress remoteAddress = new EmbeddedSocketAddress();
+
+    EmbeddedChannel(
+            EmbeddedChannelHandlerContext context, ChannelPipeline pipeline) {
+        super(null, EmbeddedChannelFactory.INSTANCE, pipeline, context);
+    }
+
+    public ChannelConfig getConfig() {
+        return EmbeddedChannelConfig.INSTANCE;
+    }
+
+    public SocketAddress getLocalAddress() {
+        return localAddress;
+    }
+
+    public SocketAddress getRemoteAddress() {
+        return remoteAddress;
+    }
+
+    public boolean isBound() {
+        return true;
+    }
+
+    public boolean isConnected() {
+        return true;
+    }
+}

src/main/java/org/jboss/netty/handler/codec/embedder/EmbeddedChannelConfig.java

@@ -0,0 +1,70 @@
+/*
+ * JBoss, Home of Professional Open Source
+ *
+ * Copyright 2008, Red Hat Middleware LLC, and individual contributors
+ * by the @author tags. See the COPYRIGHT.txt in the distribution for a
+ * full listing of individual contributors.
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as
+ * published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This software is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+package org.jboss.netty.handler.codec.embedder;
+
+import java.util.Map;
+
+import org.jboss.netty.channel.ChannelConfig;
+import org.jboss.netty.channel.ChannelPipelineFactory;
+
+/**
+ * @author The Netty Project (netty-dev@lists.jboss.org)
+ * @author Trustin Lee (tlee@redhat.com)
+ * @version $Rev$, $Date$
+ */
+class EmbeddedChannelConfig implements ChannelConfig {
+
+    static final ChannelConfig INSTANCE = new EmbeddedChannelConfig();
+
+    private EmbeddedChannelConfig() {
+        super();
+    }
+
+    public int getConnectTimeoutMillis() {
+        return 0;
+    }
+
+    public ChannelPipelineFactory getPipelineFactory() {
+        return null;
+    }
+
+    public int getWriteTimeoutMillis() {
+        return 0;
+    }
+
+    public void setConnectTimeoutMillis(int connectTimeoutMillis) {
+        // Unused
+    }
+
+    public void setOptions(Map<String, Object> options) {
+        // Unused
+    }
+
+    public void setPipelineFactory(ChannelPipelineFactory pipelineFactory) {
+        // Unused
+    }
+
+    public void setWriteTimeoutMillis(int writeTimeoutMillis) {
+        // Unused
+    }
+}

src/main/java/org/jboss/netty/handler/codec/embedder/EmbeddedChannelFactory.java

@@ -0,0 +1,49 @@
+/*
+ * JBoss, Home of Professional Open Source
+ *
+ * Copyright 2008, Red Hat Middleware LLC, and individual contributors
+ * by the @author tags. See the COPYRIGHT.txt in the distribution for a
+ * full listing of individual contributors.
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as
+ * published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This software is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+package org.jboss.netty.handler.codec.embedder;
+
+import org.jboss.netty.channel.Channel;
+import org.jboss.netty.channel.ChannelFactory;
+import org.jboss.netty.channel.ChannelPipeline;
+
+/**
+ * @author The Netty Project (netty-dev@lists.jboss.org)
+ * @author Trustin Lee (tlee@redhat.com)
+ * @version $Rev$, $Date$
+ */
+class EmbeddedChannelFactory implements ChannelFactory {
+
+    static final ChannelFactory INSTANCE = new EmbeddedChannelFactory();
+
+    private EmbeddedChannelFactory() {
+        super();
+    }
+
+    public Channel newChannel(ChannelPipeline pipeline) {
+        throw new UnsupportedOperationException();
+    }
+
+    public void releaseExternalResources() {
+        throw new UnsupportedOperationException();
+    }
+}

src/main/java/org/jboss/netty/handler/codec/embedder/EmbeddedChannelHandlerContext.java

@@ -0,0 +1,118 @@
+/*
+ * JBoss, Home of Professional Open Source
+ *
+ * Copyright 2008, Red Hat Middleware LLC, and individual contributors
+ * by the @author tags. See the COPYRIGHT.txt in the distribution for a
+ * full listing of individual contributors.
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as
+ * published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This software is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+package org.jboss.netty.handler.codec.embedder;
+
+import java.util.LinkedList;
+import java.util.Queue;
+
+import org.jboss.netty.channel.Channel;
+import org.jboss.netty.channel.ChannelDownstreamHandler;
+import org.jboss.netty.channel.ChannelEvent;
+import org.jboss.netty.channel.ChannelHandler;
+import org.jboss.netty.channel.ChannelHandlerContext;
+import org.jboss.netty.channel.ChannelPipeline;
+import org.jboss.netty.channel.ChannelPipelineException;
+import org.jboss.netty.channel.ChannelSink;
+import org.jboss.netty.channel.ChannelUpstreamHandler;
+import org.jboss.netty.channel.Channels;
+import org.jboss.netty.channel.ExceptionEvent;
+import org.jboss.netty.channel.MessageEvent;
+
+/**
+ * @author The Netty Project (netty-dev@lists.jboss.org)
+ * @author Trustin Lee (tlee@redhat.com)
+ * @version $Rev$, $Date$
+ */
+class EmbeddedChannelHandlerContext implements ChannelHandlerContext, ChannelSink {
+
+    private static final String NAME = "__embedded__";
+
+    private final Channel channel;
+    private final ChannelHandler handler;
+    private final ChannelPipeline pipeline;
+    final Queue<Object> productQueue = new LinkedList<Object>();
+
+    EmbeddedChannelHandlerContext(ChannelHandler handler) {
+        this.handler = handler;
+        pipeline = Channels.pipeline();
+        pipeline.addLast(NAME, handler);
+        channel = new EmbeddedChannel(this, pipeline);
+    }
+
+    public boolean canHandleDownstream() {
+        return handler instanceof ChannelDownstreamHandler;
+    }
+
+    public boolean canHandleUpstream() {
+        return handler instanceof ChannelUpstreamHandler;
+    }
+
+    public ChannelHandler getHandler() {
+        return handler;
+    }
+
+    public String getName() {
+        return NAME;
+    }
+
+    public Channel getChannel() {
+        return channel;
+    }
+
+    public ChannelPipeline getPipeline() {
+        return pipeline;
+    }
+
+    public void sendDownstream(ChannelEvent e) {
+        handleEvent(e);
+    }
+
+    public void sendUpstream(ChannelEvent e) {
+        handleEvent(e);
+    }
+
+    public void eventSunk(ChannelPipeline pipeline, ChannelEvent e) {
+        handleEvent(e);
+    }
+
+    private void handleEvent(ChannelEvent e) {
+        if (e instanceof MessageEvent) {
+            productQueue.offer(((MessageEvent) e).getMessage());
+        } else if (e instanceof ExceptionEvent) {
+            throw new CodecEmbedderException(((ExceptionEvent) e).getCause());
+        }
+
+        // Swallow otherwise.
+    }
+
+    public void exceptionCaught(
+            ChannelPipeline pipeline, ChannelEvent e,
+            ChannelPipelineException cause) throws Exception {
+        Throwable actualCause = cause.getCause();
+        if (actualCause == null) {
+            actualCause = cause;
+        }
+
+        throw new CodecEmbedderException(actualCause);
+    }
+}

src/main/java/org/jboss/netty/handler/codec/embedder/EmbeddedSocketAddress.java

@@ -0,0 +1,38 @@
+/*
+ * JBoss, Home of Professional Open Source
+ *
+ * Copyright 2008, Red Hat Middleware LLC, and individual contributors
+ * by the @author tags. See the COPYRIGHT.txt in the distribution for a
+ * full listing of individual contributors.
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as
+ * published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This software is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+package org.jboss.netty.handler.codec.embedder;
+
+import java.net.SocketAddress;
+
+/**
+ * @author The Netty Project (netty-dev@lists.jboss.org)
+ * @author Trustin Lee (tlee@redhat.com)
+ * @version $Rev$, $Date$
+ */
+class EmbeddedSocketAddress extends SocketAddress {
+    private static final long serialVersionUID = 1400788804624980619L;
+
+    EmbeddedSocketAddress() {
+        super();
+    }
+}

src/main/java/org/jboss/netty/handler/codec/embedder/EncoderEmbedder.java

@@ -0,0 +1,46 @@
+/*
+ * JBoss, Home of Professional Open Source
+ *
+ * Copyright 2008, Red Hat Middleware LLC, and individual contributors
+ * by the @author tags. See the COPYRIGHT.txt in the distribution for a
+ * full listing of individual contributors.
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as
+ * published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This software is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+package org.jboss.netty.handler.codec.embedder;
+
+import static org.jboss.netty.channel.Channels.*;
+
+import org.jboss.netty.channel.Channel;
+import org.jboss.netty.channel.ChannelDownstreamHandler;
+
+/**
+ * @author The Netty Project (netty-dev@lists.jboss.org)
+ * @author Trustin Lee (tlee@redhat.com)
+ * @version $Rev$, $Date$
+ */
+public class EncoderEmbedder<T> extends AbstractCodecEmbedder<T> {
+
+    public EncoderEmbedder(ChannelDownstreamHandler handler) {
+        super(handler);
+    }
+
+    public boolean offer(Object input) {
+        Channel channel = context.getChannel();
+        write(context, channel, succeededFuture(channel), input);
+        return context.productQueue.isEmpty();
+    }
+}

src/main/java/org/jboss/netty/handler/codec/embedder/package-info.java

@@ -0,0 +1,30 @@
+/*
+ * JBoss, Home of Professional Open Source
+ *
+ * Copyright 2008, Red Hat Middleware LLC, and individual contributors
+ * by the @author tags. See the COPYRIGHT.txt in the distribution for a
+ * full listing of individual contributors.
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as
+ * published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This software is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+
+/**
+ * A helper that wraps an encoder or a decoder so that it can be used outside
+ * a {@link org.jboss.netty.channel.ChannelPipeline} or inside a
+ * {@link org.jboss.netty.channel.ChannelHandler} conveniently.
+ */
+package org.jboss.netty.handler.codec.embedder;
+