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 TypeMethodDescriptionvoid
close()
int
fill
(ByteBuffer dst) void
fillInterested
(org.eclipse.jetty.util.Callback v) boolean
flush
(ByteBuffer... v) byte[]
getBytes()
org.eclipse.jetty.io.Connection
long
long
boolean
boolean
boolean
isOpen()
boolean
boolean
void
onClose()
void
onOpen()
void
setConnection
(org.eclipse.jetty.io.Connection v) void
setIdleTimeout
(long v) void
boolean
tryFillInterested
(org.eclipse.jetty.util.Callback v) void
upgrade
(org.eclipse.jetty.io.Connection v) void
write
(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:
getLocalAddress
in interfaceorg.eclipse.jetty.io.EndPoint
-
getRemoteAddress
- Specified by:
getRemoteAddress
in interfaceorg.eclipse.jetty.io.EndPoint
-
isOpen
public boolean isOpen()- Specified by:
isOpen
in interfaceorg.eclipse.jetty.io.EndPoint
-
getCreatedTimeStamp
public long getCreatedTimeStamp()- Specified by:
getCreatedTimeStamp
in interfaceorg.eclipse.jetty.io.EndPoint
-
isOutputShutdown
public boolean isOutputShutdown()- Specified by:
isOutputShutdown
in interfaceorg.eclipse.jetty.io.EndPoint
-
isInputShutdown
public boolean isInputShutdown()- Specified by:
isInputShutdown
in interfaceorg.eclipse.jetty.io.EndPoint
-
shutdownOutput
public void shutdownOutput()- Specified by:
shutdownOutput
in interfaceorg.eclipse.jetty.io.EndPoint
-
close
public void close()- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
- Specified by:
close
in interfaceorg.eclipse.jetty.io.EndPoint
-
getTransport
- Specified by:
getTransport
in interfaceorg.eclipse.jetty.io.EndPoint
-
getIdleTimeout
public long getIdleTimeout()- Specified by:
getIdleTimeout
in interfaceorg.eclipse.jetty.io.EndPoint
-
getConnection
public org.eclipse.jetty.io.Connection getConnection()- Specified by:
getConnection
in interfaceorg.eclipse.jetty.io.EndPoint
-
onOpen
public void onOpen()- Specified by:
onOpen
in interfaceorg.eclipse.jetty.io.EndPoint
-
onClose
public void onClose()- Specified by:
onClose
in interfaceorg.eclipse.jetty.io.EndPoint
-
isOptimizedForDirectBuffers
public boolean isOptimizedForDirectBuffers()- Specified by:
isOptimizedForDirectBuffers
in interfaceorg.eclipse.jetty.io.EndPoint
-
isFillInterested
public boolean isFillInterested()- Specified by:
isFillInterested
in interfaceorg.eclipse.jetty.io.EndPoint
-
tryFillInterested
public boolean tryFillInterested(org.eclipse.jetty.util.Callback v) - Specified by:
tryFillInterested
in interfaceorg.eclipse.jetty.io.EndPoint
-
flush
- Specified by:
flush
in interfaceorg.eclipse.jetty.io.EndPoint
- Throws:
IOException
-
setIdleTimeout
public void setIdleTimeout(long v) - Specified by:
setIdleTimeout
in interfaceorg.eclipse.jetty.io.EndPoint
-
write
- Specified by:
write
in interfaceorg.eclipse.jetty.io.EndPoint
- Throws:
WritePendingException
-
setConnection
public void setConnection(org.eclipse.jetty.io.Connection v) - Specified by:
setConnection
in interfaceorg.eclipse.jetty.io.EndPoint
-
upgrade
public void upgrade(org.eclipse.jetty.io.Connection v) - Specified by:
upgrade
in interfaceorg.eclipse.jetty.io.EndPoint
-
fillInterested
- Specified by:
fillInterested
in interfaceorg.eclipse.jetty.io.EndPoint
- Throws:
ReadPendingException
-
fill
- Specified by:
fill
in interfaceorg.eclipse.jetty.io.EndPoint
- Throws:
IOException
-
getBytes
public byte[] getBytes()
-