Details
-
Sub-task
-
Status: Resolved
-
Minor
-
Resolution: Fixed
-
None
-
None
-
Reviewed
Description
Currently, in DFSStripedOutputStream#flushAllInternals( ), we trigger and
wait for flushInternal( ) in sequence. So the runtime flow is like:
Streamer0#flushInternal( ) Streamer0#waitForAckedSeqno( ) Streamer1#flushInternal( ) Streamer1#waitForAckedSeqno( ) … Streamer8#flushInternal( ) Streamer8#waitForAckedSeqno( )
It could be better to trigger all the streamers to flushInternal( ) and
wait for all of them to return from waitForAckedSeqno( ), and then flushAllInternals( ) returns.