Class ReadAheadEndpoint
java.lang.Object
org.apache.zookeeper.server.admin.ReadAheadEndpoint
- All Implemented Interfaces:
Closeable,AutoCloseable,org.eclipse.jetty.io.EndPoint
-
Constructor Summary
ConstructorsConstructorDescriptionReadAheadEndpoint(org.eclipse.jetty.io.EndPoint channel, int readAheadLength) -
Method Summary
Modifier and TypeMethodDescriptionvoidclose()intfill(ByteBuffer dst) voidfillInterested(org.eclipse.jetty.util.Callback v) booleanflush(ByteBuffer... v) byte[]getBytes()org.eclipse.jetty.io.ConnectionlonglongbooleanbooleanbooleanisOpen()booleanbooleanvoidonClose()voidonOpen()voidsetConnection(org.eclipse.jetty.io.Connection v) voidsetIdleTimeout(long v) voidbooleantryFillInterested(org.eclipse.jetty.util.Callback v) voidupgrade(org.eclipse.jetty.io.Connection v) voidwrite(org.eclipse.jetty.util.Callback v, ByteBuffer... b)
-
Constructor Details
-
ReadAheadEndpoint
public ReadAheadEndpoint(org.eclipse.jetty.io.EndPoint channel, int readAheadLength)
-
-
Method Details
-
getLocalAddress
- Specified by:
getLocalAddressin interfaceorg.eclipse.jetty.io.EndPoint
-
getRemoteAddress
- Specified by:
getRemoteAddressin interfaceorg.eclipse.jetty.io.EndPoint
-
isOpen
public boolean isOpen()- Specified by:
isOpenin interfaceorg.eclipse.jetty.io.EndPoint
-
getCreatedTimeStamp
public long getCreatedTimeStamp()- Specified by:
getCreatedTimeStampin interfaceorg.eclipse.jetty.io.EndPoint
-
isOutputShutdown
public boolean isOutputShutdown()- Specified by:
isOutputShutdownin interfaceorg.eclipse.jetty.io.EndPoint
-
isInputShutdown
public boolean isInputShutdown()- Specified by:
isInputShutdownin interfaceorg.eclipse.jetty.io.EndPoint
-
shutdownOutput
public void shutdownOutput()- Specified by:
shutdownOutputin interfaceorg.eclipse.jetty.io.EndPoint
-
close
public void close()- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceCloseable- Specified by:
closein interfaceorg.eclipse.jetty.io.EndPoint
-
getTransport
- Specified by:
getTransportin interfaceorg.eclipse.jetty.io.EndPoint
-
getIdleTimeout
public long getIdleTimeout()- Specified by:
getIdleTimeoutin interfaceorg.eclipse.jetty.io.EndPoint
-
getConnection
public org.eclipse.jetty.io.Connection getConnection()- Specified by:
getConnectionin interfaceorg.eclipse.jetty.io.EndPoint
-
onOpen
public void onOpen()- Specified by:
onOpenin interfaceorg.eclipse.jetty.io.EndPoint
-
onClose
public void onClose()- Specified by:
onClosein interfaceorg.eclipse.jetty.io.EndPoint
-
isOptimizedForDirectBuffers
public boolean isOptimizedForDirectBuffers()- Specified by:
isOptimizedForDirectBuffersin interfaceorg.eclipse.jetty.io.EndPoint
-
isFillInterested
public boolean isFillInterested()- Specified by:
isFillInterestedin interfaceorg.eclipse.jetty.io.EndPoint
-
tryFillInterested
public boolean tryFillInterested(org.eclipse.jetty.util.Callback v) - Specified by:
tryFillInterestedin interfaceorg.eclipse.jetty.io.EndPoint
-
flush
- Specified by:
flushin interfaceorg.eclipse.jetty.io.EndPoint- Throws:
IOException
-
setIdleTimeout
public void setIdleTimeout(long v) - Specified by:
setIdleTimeoutin interfaceorg.eclipse.jetty.io.EndPoint
-
write
- Specified by:
writein interfaceorg.eclipse.jetty.io.EndPoint- Throws:
WritePendingException
-
setConnection
public void setConnection(org.eclipse.jetty.io.Connection v) - Specified by:
setConnectionin interfaceorg.eclipse.jetty.io.EndPoint
-
upgrade
public void upgrade(org.eclipse.jetty.io.Connection v) - Specified by:
upgradein interfaceorg.eclipse.jetty.io.EndPoint
-
fillInterested
- Specified by:
fillInterestedin interfaceorg.eclipse.jetty.io.EndPoint- Throws:
ReadPendingException
-
fill
- Specified by:
fillin interfaceorg.eclipse.jetty.io.EndPoint- Throws:
IOException
-
getBytes
public byte[] getBytes()
-