public static class NioEndpoint.KeyAttachment extends SocketWrapper<NioChannel>
Modifier and Type | Field and Description |
---|---|
protected boolean |
comet |
protected boolean |
cometNotify |
protected int |
cometOps |
protected int |
interestOps |
protected NioEndpoint.Poller |
poller |
protected CountDownLatch |
readLatch |
protected NioEndpoint.SendfileData |
sendfileData |
protected CountDownLatch |
writeLatch |
async, error, keepAliveLeft, keptAlive, lastAccess, lastRegistered, socket, timeout
Constructor and Description |
---|
NioEndpoint.KeyAttachment(NioChannel channel) |
access, access, decrementKeepAlive, getError, getLastAccess, getSocket, getTimeout, isAsync, isKeptAlive, setAsync, setError, setKeepAliveLeft, setKeptAlive, setTimeout
protected NioEndpoint.Poller poller
protected int interestOps
protected boolean comet
protected int cometOps
protected boolean cometNotify
protected CountDownLatch readLatch
protected CountDownLatch writeLatch
protected NioEndpoint.SendfileData sendfileData
public NioEndpoint.KeyAttachment(NioChannel channel)
public void reset(NioEndpoint.Poller poller, NioChannel channel, long soTimeout)
public void reset()
public NioEndpoint.Poller getPoller()
public void setPoller(NioEndpoint.Poller poller)
public void setComet(boolean comet)
public boolean getComet()
public void setCometNotify(boolean notify)
public boolean getCometNotify()
public void setCometOps(int ops)
public int getCometOps()
public NioChannel getChannel()
public void setChannel(NioChannel channel)
public int interestOps()
public int interestOps(int ops)
public CountDownLatch getReadLatch()
public CountDownLatch getWriteLatch()
protected CountDownLatch resetLatch(CountDownLatch latch)
public void resetReadLatch()
public void resetWriteLatch()
protected CountDownLatch startLatch(CountDownLatch latch, int cnt)
public void startReadLatch(int cnt)
public void startWriteLatch(int cnt)
protected void awaitLatch(CountDownLatch latch, long timeout, TimeUnit unit) throws InterruptedException
InterruptedException
public void awaitReadLatch(long timeout, TimeUnit unit) throws InterruptedException
InterruptedException
public void awaitWriteLatch(long timeout, TimeUnit unit) throws InterruptedException
InterruptedException
public long getLastRegistered()
public void setLastRegistered(long reg)
public void setSendfileData(NioEndpoint.SendfileData sf)
public NioEndpoint.SendfileData getSendfileData()
Copyright © 2000-2013 Apache Software Foundation. All Rights Reserved.