Modifier and Type | Method and Description |
---|---|
DataBuffer |
BlockWorkerDataReader.readChunk() |
DataBuffer |
SharedGrpcDataReader.readChunk() |
protected DataBuffer |
BufferCachingGrpcDataReader.readChunk()
Reads a chunk of data.
|
DataBuffer |
NettyDataReader.readChunk() |
DataBuffer |
DataReader.readChunk()
Reads a chunk.
|
DataBuffer |
GrpcDataReader.readChunk() |
DataBuffer |
BufferCachingGrpcDataReader.readChunk(int index)
Reads a specific chunk from the block.
|
Modifier and Type | Method and Description |
---|---|
DataMessage<ResT,DataBuffer> |
GrpcDataMessageBlockingStream.receiveDataMessage(long timeoutMs)
Receives a response with data buffer from the server.
|
Modifier and Type | Method and Description |
---|---|
void |
GrpcDataMessageBlockingStream.sendDataMessage(DataMessage<ReqT,DataBuffer> message,
long timeoutMs)
Sends a request.
|
Modifier and Type | Method and Description |
---|---|
DataResponseEvent |
ResponseEventFactory.createDataResponseEvent(DataBuffer dataBuffer)
Create a DataResponseEvent.
|
Modifier and Type | Class and Description |
---|---|
class |
ReadableDataBuffer
Class for making wrapping
ReadableBuffer as DataBuffer . |
Modifier and Type | Method and Description |
---|---|
DataBuffer |
DataMessageMarshaller.pollBuffer(T message) |
Modifier and Type | Method and Description |
---|---|
void |
DataMessageMarshaller.offerBuffer(DataBuffer buffer,
T message) |
Modifier and Type | Method and Description |
---|---|
ReadResponse |
ReadResponseMarshaller.combineData(DataMessage<ReadResponse,DataBuffer> message) |
abstract T |
DataMessageMarshaller.combineData(DataMessage<T,DataBuffer> message)
Combines the data buffer into the message.
|
WriteRequest |
WriteRequestMarshaller.combineData(DataMessage<WriteRequest,DataBuffer> message) |
Modifier and Type | Method and Description |
---|---|
DataBuffer |
RPCMessage.getPayloadDataBuffer()
Returns the data buffer of the payload.
|
DataBuffer |
RPCProtoMessage.getPayloadDataBuffer() |
Modifier and Type | Method and Description |
---|---|
static RPCProtoMessage |
RPCProtoMessage.createOkResponse(DataBuffer data)
Creates an OK response with data.
|
static RPCProtoMessage |
RPCProtoMessage.createResponse(io.grpc.Status status,
String message,
DataBuffer data)
Creates a response for a given status, message, and data buffer.
|
Constructor and Description |
---|
RPCProtoMessage(byte[] serialized,
ProtoMessage prototype,
DataBuffer data)
Creates an instance of
RPCProtoMessage from a serialized proto message. |
RPCProtoMessage(ProtoMessage message,
DataBuffer data)
Creates an instance of
RPCProtoMessage . |
Modifier and Type | Class and Description |
---|---|
class |
CompositeDataBuffer
A CompositeDataBuffer which includes a
List of DataBuffer . |
class |
DataFileChannel
A DataBuffer with the underlying data being a
FileChannel . |
class |
NettyDataBuffer
A DataBuffer with the underlying data being a
ByteBuf . |
class |
NioDataBuffer
A DataBuffer with the underlying data being a
ByteBuffer . |
Constructor and Description |
---|
CompositeDataBuffer(List<DataBuffer> dataBufferList)
CompositeDataBuffer wraps multiple
DataBuffer . |
Modifier and Type | Method and Description |
---|---|
abstract long |
BlockWriter.append(DataBuffer buffer)
Appends buffer.readableBytes() bytes to the end of this block writer from the given buffer.
|
Modifier and Type | Method and Description |
---|---|
long |
PagedFileWriter.append(DataBuffer buffer) |
Modifier and Type | Method and Description |
---|---|
protected void |
UfsFileWriteHandler.writeBuf(UfsFileWriteRequestContext context,
io.grpc.stub.StreamObserver<WriteResponse> observer,
DataBuffer buf,
long pos) |
Modifier and Type | Method and Description |
---|---|
void |
DataMessageServerStreamObserver.onNext(DataMessage<T,DataBuffer> value)
Receives a message with data buffer from the stream.
|
Constructor and Description |
---|
DataMessageServerStreamObserver(io.grpc.stub.CallStreamObserver<T> observer,
BufferRepository<T,DataBuffer> bufferRepository) |
Modifier and Type | Method and Description |
---|---|
DataBuffer |
FileReadHandler.FilePacketReader.getDataBuffer(io.netty.channel.Channel channel,
long offset,
int len) |
DataBuffer |
AbstractReadHandler.PacketReader.getDataBuffer(io.netty.channel.Channel channel,
long offset,
int len)
Returns the appropriate
DataBuffer representing the data to send, depending on the
configurable transfer type. |
Modifier and Type | Method and Description |
---|---|
void |
S3NettyHandler.processTransferResponse(DataBuffer packet)
Writes a
DataBuffer into netty channel. |
Copyright © 2023. All Rights Reserved.