[jira] [Updated] (HDDS-6137) Optimized the putBlock method of BlockDataStreamOutput

["ASF GitHub Bot (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/HDDS-6137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

ASF GitHub Bot updated HDDS-6137:
---------------------------------
    Labels: pull-request-available  (was: )

> Optimized the putBlock method of BlockDataStreamOutput
> ------------------------------------------------------
>
>                 Key: HDDS-6137
>                 URL: https://issues.apache.org/jira/browse/HDDS-6137
>             Project: Apache Ozone
>          Issue Type: Sub-task
>            Reporter: GuoHao
>            Assignee: GuoHao
>            Priority: Major
>              Labels: pull-request-available
>
> Optimized the putBlock method of BlockDataStreamOutput
>  
> *1. PutBlock does not use RaftRpc, but through the stream close() method*
> {code:java}
> // putBlock metadata
> ByteBuffer buf =
>     ContainerCommandRequestMessage.toMessage(putBlockRequestProto, null)
>         .getContent().asReadOnlyByteBuffer();
> out.writeAsync(buf, StandardWriteOption.CLOSE); {code}
> *2.Mark the stream data boundary by sending an empty stream packet*
> {code:java}
> // Mark the stream data boundary
> out.writeAsync(ByteBuffer.allocateDirect(0).asReadOnlyBuffer()); {code}
>  
> *3. Flush is also in the form of async RPC, because putBlock needs to fetch bcsId (Raft log index)*
>  



--
This message was sent by Atlassian Jira
(v8.20.1#820001)

---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@ozone.apache.org
For additional commands, e-mail: issues-help@ozone.apache.org