2008-08-08 02:37:18 +02:00
|
|
|
/*
|
2008-08-08 03:27:24 +02:00
|
|
|
* JBoss, Home of Professional Open Source
|
2008-08-08 02:37:18 +02:00
|
|
|
*
|
2008-08-08 03:27:24 +02:00
|
|
|
* 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.
|
2008-08-08 02:37:18 +02:00
|
|
|
*
|
2008-08-08 03:27:24 +02:00
|
|
|
* 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,
|
2008-08-08 02:37:18 +02:00
|
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
2008-08-08 03:27:24 +02:00
|
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
2008-08-08 02:37:18 +02:00
|
|
|
* Lesser General Public License for more details.
|
|
|
|
*
|
|
|
|
* You should have received a copy of the GNU Lesser General Public
|
2008-08-08 03:27:24 +02:00
|
|
|
* 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.
|
2008-08-08 02:37:18 +02:00
|
|
|
*/
|
2008-08-08 03:40:10 +02:00
|
|
|
package org.jboss.netty.channel;
|
2008-08-08 02:37:18 +02:00
|
|
|
|
|
|
|
import java.net.SocketAddress;
|
|
|
|
import java.util.UUID;
|
|
|
|
import java.util.concurrent.atomic.AtomicBoolean;
|
|
|
|
|
2008-08-08 03:40:10 +02:00
|
|
|
import org.jboss.netty.util.TimeBasedUuidGenerator;
|
2008-08-08 02:37:18 +02:00
|
|
|
|
|
|
|
/**
|
|
|
|
*
|
2008-08-08 03:27:24 +02:00
|
|
|
* @author The Netty Project (netty-dev@lists.jboss.org)
|
|
|
|
* @author Trustin Lee (tlee@redhat.com)
|
2008-08-08 02:37:18 +02:00
|
|
|
*
|
|
|
|
* @version $Rev$, $Date$
|
|
|
|
*
|
|
|
|
*/
|
|
|
|
public abstract class AbstractChannel implements Channel, Comparable<Channel> {
|
|
|
|
|
|
|
|
private final UUID id = TimeBasedUuidGenerator.generate();
|
|
|
|
private final Channel parent;
|
|
|
|
private final ChannelFactory factory;
|
|
|
|
private final ChannelPipeline pipeline;
|
|
|
|
private final ChannelFuture succeededFuture = new SucceededChannelFuture(this);
|
|
|
|
|
|
|
|
private final AtomicBoolean closed = new AtomicBoolean();
|
|
|
|
private volatile int interestOps = OP_READ;
|
|
|
|
|
|
|
|
/** Cache for the string representation of this channel */
|
|
|
|
private String strVal;
|
|
|
|
|
|
|
|
protected AbstractChannel(
|
|
|
|
Channel parent, ChannelFactory factory,
|
|
|
|
ChannelPipeline pipeline, ChannelSink sink) {
|
|
|
|
|
|
|
|
this.parent = parent;
|
|
|
|
this.factory = factory;
|
|
|
|
this.pipeline = pipeline;
|
|
|
|
pipeline.attach(this, sink);
|
|
|
|
}
|
|
|
|
|
|
|
|
public final UUID getId() {
|
|
|
|
return id;
|
|
|
|
}
|
|
|
|
|
|
|
|
public Channel getParent() {
|
|
|
|
return parent;
|
|
|
|
}
|
|
|
|
|
|
|
|
public ChannelFactory getFactory() {
|
|
|
|
return factory;
|
|
|
|
}
|
|
|
|
|
|
|
|
public ChannelPipeline getPipeline() {
|
|
|
|
return pipeline;
|
|
|
|
}
|
|
|
|
|
|
|
|
protected ChannelFuture getSucceededFuture() {
|
|
|
|
return succeededFuture;
|
|
|
|
}
|
|
|
|
|
|
|
|
protected ChannelFuture getUnsupportedOperationFuture() {
|
|
|
|
return new FailedChannelFuture(this, new UnsupportedOperationException());
|
|
|
|
}
|
|
|
|
|
|
|
|
@Override
|
|
|
|
public final int hashCode() {
|
|
|
|
return System.identityHashCode(this);
|
|
|
|
}
|
|
|
|
|
|
|
|
@Override
|
|
|
|
public final boolean equals(Object o) {
|
|
|
|
return this == o;
|
|
|
|
}
|
|
|
|
|
2008-08-25 10:57:03 +02:00
|
|
|
public final int compareTo(Channel o) {
|
|
|
|
return getId().compareTo(o.getId());
|
2008-08-08 02:37:18 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
public boolean isOpen() {
|
|
|
|
return !closed.get();
|
|
|
|
}
|
|
|
|
|
|
|
|
protected boolean setClosed() {
|
|
|
|
return closed.compareAndSet(false, true);
|
|
|
|
}
|
|
|
|
|
|
|
|
public ChannelFuture bind(SocketAddress localAddress) {
|
|
|
|
return Channels.bind(this, localAddress);
|
|
|
|
}
|
|
|
|
|
|
|
|
public ChannelFuture close() {
|
|
|
|
return Channels.close(this);
|
|
|
|
}
|
|
|
|
|
|
|
|
public ChannelFuture connect(SocketAddress remoteAddress) {
|
|
|
|
return Channels.connect(this, remoteAddress);
|
|
|
|
}
|
|
|
|
|
|
|
|
public ChannelFuture disconnect() {
|
|
|
|
return Channels.disconnect(this);
|
|
|
|
}
|
|
|
|
|
|
|
|
public int getInterestOps() {
|
|
|
|
return interestOps;
|
|
|
|
}
|
|
|
|
|
|
|
|
public ChannelFuture setInterestOps(int interestOps) {
|
|
|
|
return Channels.setInterestOps(this, interestOps);
|
|
|
|
}
|
|
|
|
|
|
|
|
protected void setInterestOpsNow(int interestOps) {
|
|
|
|
this.interestOps = interestOps;
|
|
|
|
}
|
|
|
|
|
|
|
|
public boolean isReadable() {
|
|
|
|
return (getInterestOps() & OP_READ) != 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
public boolean isWritable() {
|
|
|
|
return (getInterestOps() & OP_WRITE) == 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
public ChannelFuture setReadable(boolean readable) {
|
|
|
|
if (readable) {
|
|
|
|
return setInterestOps(getInterestOps() | OP_READ);
|
|
|
|
} else {
|
|
|
|
return setInterestOps(getInterestOps() & ~OP_READ);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
public ChannelFuture write(Object message) {
|
|
|
|
return Channels.write(this, message);
|
|
|
|
}
|
|
|
|
|
|
|
|
public ChannelFuture write(Object message, SocketAddress remoteAddress) {
|
|
|
|
return Channels.write(this, message, remoteAddress);
|
|
|
|
}
|
|
|
|
|
|
|
|
@Override
|
|
|
|
public String toString() {
|
|
|
|
if (strVal != null) {
|
|
|
|
return strVal;
|
|
|
|
}
|
|
|
|
|
|
|
|
StringBuilder buf = new StringBuilder(128);
|
|
|
|
buf.append(getClass().getSimpleName());
|
|
|
|
buf.append("(id: ");
|
|
|
|
buf.append(id.toString());
|
|
|
|
|
|
|
|
if (isConnected()) {
|
|
|
|
buf.append(", ");
|
|
|
|
if (getParent() == null) {
|
|
|
|
buf.append(getLocalAddress());
|
|
|
|
buf.append(" => ");
|
|
|
|
buf.append(getRemoteAddress());
|
|
|
|
} else {
|
|
|
|
buf.append(getRemoteAddress());
|
|
|
|
buf.append(" => ");
|
|
|
|
buf.append(getLocalAddress());
|
|
|
|
}
|
|
|
|
} else if (isBound()) {
|
|
|
|
buf.append(", ");
|
|
|
|
buf.append(getLocalAddress());
|
|
|
|
}
|
|
|
|
|
|
|
|
buf.append(')');
|
|
|
|
|
|
|
|
return strVal = buf.toString();
|
|
|
|
}
|
|
|
|
}
|