public static class NioEndpoint.KeyAttachment extends SocketWrapper<NioChannel>
| 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) |
boolean |
getCometNotify()
Deprecated.
|
NioEndpoint.Poller |
getPoller() |
java.util.concurrent.CountDownLatch |
getReadLatch() |
NioEndpoint.SendfileData |
getSendfileData() |
java.util.concurrent.CountDownLatch |
getWriteLatch() |
long |
getWriteTimeout() |
int |
interestOps() |
int |
interestOps(int ops) |
protected java.util.concurrent.CountDownLatch |
resetLatch(java.util.concurrent.CountDownLatch latch) |
void |
resetReadLatch() |
void |
resetWriteLatch() |
void |
setCometNotify(boolean notify)
Deprecated.
|
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, addDispatch, clearDispatches, decrementKeepAlive, getBlockingStatus, getBlockingStatusReadLock, getBlockingStatusWriteLock, getError, getIteratorAndClearDispatches, getLastAccess, getLocalAddr, getLocalName, getLocalPort, getRemoteAddr, getRemoteHost, getRemotePort, getSocket, getTimeout, getWriteThreadLock, isAsync, isComet, isKeptAlive, isSecure, isUpgraded, registerforEvent, setAsync, setBlockingStatus, setComet, setError, setKeepAliveLeft, setKeptAlive, setLocalAddr, setLocalName, setLocalPort, setRemoteAddr, setRemoteHost, setRemotePort, setSecure, setTimeout, setUpgraded, toStringpublic NioEndpoint.KeyAttachment(NioChannel channel)
public NioEndpoint.Poller getPoller()
public void setPoller(NioEndpoint.Poller poller)
@Deprecated public void setCometNotify(boolean notify)
@Deprecated public boolean getCometNotify()
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.InterruptedExceptionpublic void awaitReadLatch(long timeout,
java.util.concurrent.TimeUnit unit)
throws java.lang.InterruptedException
java.lang.InterruptedExceptionpublic void awaitWriteLatch(long timeout,
java.util.concurrent.TimeUnit unit)
throws java.lang.InterruptedException
java.lang.InterruptedExceptionpublic void setSendfileData(NioEndpoint.SendfileData sf)
public NioEndpoint.SendfileData getSendfileData()
public void setWriteTimeout(long writeTimeout)
public long getWriteTimeout()
Copyright © 2000-2018 Apache Software Foundation. All Rights Reserved.