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 java.util.concurrent.CountDownLatch |
readLatch |
protected NioEndpoint.SendfileData |
sendfileData |
protected java.util.concurrent.CountDownLatch |
writeLatch |
async, error, keepAliveLeft, keptAlive, lastAccess, lastRegistered, socket, timeout
Constructor and Description |
---|
NioEndpoint.KeyAttachment(NioChannel channel) |
Modifier and Type | Method and Description |
---|---|
protected void |
awaitLatch(java.util.concurrent.CountDownLatch latch,
long timeout,
java.util.concurrent.TimeUnit unit) |
void |
awaitReadLatch(long timeout,
java.util.concurrent.TimeUnit unit) |
void |
awaitWriteLatch(long timeout,
java.util.concurrent.TimeUnit unit) |
NioChannel |
getChannel() |
boolean |
getCometNotify() |
int |
getCometOps()
Deprecated.
Unused - will be removed in Tomcat 8
|
long |
getLastRegistered()
Deprecated.
Unused - will be removed in Tomcat 8
|
NioEndpoint.Poller |
getPoller() |
java.util.concurrent.CountDownLatch |
getReadLatch() |
NioEndpoint.SendfileData |
getSendfileData() |
java.util.concurrent.CountDownLatch |
getWriteLatch() |
long |
getWriteTimeout() |
int |
interestOps() |
int |
interestOps(int ops) |
void |
reset() |
void |
reset(NioEndpoint.Poller poller,
NioChannel channel,
long soTimeout) |
protected java.util.concurrent.CountDownLatch |
resetLatch(java.util.concurrent.CountDownLatch latch) |
void |
resetReadLatch() |
void |
resetWriteLatch() |
void |
setChannel(NioChannel channel) |
void |
setCometNotify(boolean notify) |
void |
setCometOps(int ops)
Deprecated.
Unused (value is set but never read) - will be removed in
Tomcat 8
|
void |
setLastRegistered(long reg)
Deprecated.
Unused - will be removed in Tomcat 8
|
void |
setPoller(NioEndpoint.Poller poller) |
void |
setSendfileData(NioEndpoint.SendfileData sf) |
void |
setWriteTimeout(long writeTimeout) |
protected java.util.concurrent.CountDownLatch |
startLatch(java.util.concurrent.CountDownLatch latch,
int cnt) |
void |
startReadLatch(int cnt) |
void |
startWriteLatch(int cnt) |
access, access, decrementKeepAlive, getBlockingStatus, getBlockingStatusReadLock, getBlockingStatusWriteLock, getError, getLastAccess, getSocket, getTimeout, getWriteThreadLock, isAsync, isComet, isKeptAlive, isSecure, isUpgraded, reset, setAsync, setBlockingStatus, setComet, setError, setKeepAliveLeft, setKeptAlive, setSecure, setTimeout, setUpgraded, toString
protected NioEndpoint.Poller poller
protected int interestOps
protected boolean comet
protected int cometOps
protected boolean cometNotify
protected java.util.concurrent.CountDownLatch readLatch
protected java.util.concurrent.CountDownLatch writeLatch
protected volatile 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 setCometNotify(boolean notify)
public boolean getCometNotify()
@Deprecated public void setCometOps(int ops)
@Deprecated public int getCometOps()
public NioChannel getChannel()
public void setChannel(NioChannel channel)
public int interestOps()
public int interestOps(int ops)
public java.util.concurrent.CountDownLatch getReadLatch()
public java.util.concurrent.CountDownLatch getWriteLatch()
protected java.util.concurrent.CountDownLatch resetLatch(java.util.concurrent.CountDownLatch latch)
public void resetReadLatch()
public void resetWriteLatch()
protected java.util.concurrent.CountDownLatch startLatch(java.util.concurrent.CountDownLatch latch, int cnt)
public void startReadLatch(int cnt)
public void startWriteLatch(int cnt)
protected void awaitLatch(java.util.concurrent.CountDownLatch latch, long timeout, java.util.concurrent.TimeUnit unit) throws java.lang.InterruptedException
java.lang.InterruptedException
public void awaitReadLatch(long timeout, java.util.concurrent.TimeUnit unit) throws java.lang.InterruptedException
java.lang.InterruptedException
public void awaitWriteLatch(long timeout, java.util.concurrent.TimeUnit unit) throws java.lang.InterruptedException
java.lang.InterruptedException
@Deprecated public long getLastRegistered()
@Deprecated public void setLastRegistered(long reg)
public void setSendfileData(NioEndpoint.SendfileData sf)
public NioEndpoint.SendfileData getSendfileData()
public void setWriteTimeout(long writeTimeout)
public long getWriteTimeout()
Copyright © 2000-2015 Apache Software Foundation. All Rights Reserved.