Package org.apache.bookkeeper.proto
Class BookieProtocol.BatchedReadResponse
- java.lang.Object
-
- org.apache.bookkeeper.proto.BookieProtocol.Response
-
- org.apache.bookkeeper.proto.BookieProtocol.BatchedReadResponse
-
- All Implemented Interfaces:
io.netty.util.ReferenceCounted
- Enclosing interface:
- BookieProtocol
public static class BookieProtocol.BatchedReadResponse extends BookieProtocol.Response implements io.netty.util.ReferenceCounted
The response for batched read. The ledger_id and entry_id will be used as start_ledger_id and start_entry_id. And all the returned data is from one ledger.
-
-
Field Summary
Fields Modifier and Type Field Description (package private) ByteBufList
data
(package private) long
requestId
-
Fields inherited from class org.apache.bookkeeper.proto.BookieProtocol.Response
entryId, errorCode, ledgerId, opCode, protocolVersion
-
-
Constructor Summary
Constructors Constructor Description BatchedReadResponse(byte protocolVersion, int errorCode, long ledgerId, long entryId, long requestId)
BatchedReadResponse(byte protocolVersion, int errorCode, long ledgerId, long entryId, long requestId, ByteBufList data)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description (package private) ByteBufList
getData()
(package private) long
getRequestId()
int
refCnt()
boolean
release()
boolean
release(int decrement)
io.netty.util.ReferenceCounted
retain()
io.netty.util.ReferenceCounted
retain(int increment)
io.netty.util.ReferenceCounted
touch()
io.netty.util.ReferenceCounted
touch(java.lang.Object hint)
-
Methods inherited from class org.apache.bookkeeper.proto.BookieProtocol.Response
getEntryId, getErrorCode, getLedgerId, getOpCode, getProtocolVersion, init, recycle, toString
-
-
-
-
Field Detail
-
requestId
final long requestId
-
data
final ByteBufList data
-
-
Constructor Detail
-
BatchedReadResponse
BatchedReadResponse(byte protocolVersion, int errorCode, long ledgerId, long entryId, long requestId)
-
BatchedReadResponse
BatchedReadResponse(byte protocolVersion, int errorCode, long ledgerId, long entryId, long requestId, ByteBufList data)
-
-
Method Detail
-
getData
ByteBufList getData()
-
getRequestId
long getRequestId()
-
refCnt
public int refCnt()
- Specified by:
refCnt
in interfaceio.netty.util.ReferenceCounted
-
retain
public io.netty.util.ReferenceCounted retain()
- Specified by:
retain
in interfaceio.netty.util.ReferenceCounted
-
retain
public io.netty.util.ReferenceCounted retain(int increment)
- Specified by:
retain
in interfaceio.netty.util.ReferenceCounted
-
touch
public io.netty.util.ReferenceCounted touch()
- Specified by:
touch
in interfaceio.netty.util.ReferenceCounted
-
touch
public io.netty.util.ReferenceCounted touch(java.lang.Object hint)
- Specified by:
touch
in interfaceio.netty.util.ReferenceCounted
-
release
public boolean release()
- Specified by:
release
in interfaceio.netty.util.ReferenceCounted
- Overrides:
release
in classBookieProtocol.Response
-
release
public boolean release(int decrement)
- Specified by:
release
in interfaceio.netty.util.ReferenceCounted
-
-