contrueCT commented on PR #3140:
URL: https://github.com/apache/hugegraph/pull/3140#issuecomment-5424173879

   Follow-up in 
[`3941b1c91`](https://github.com/apache/hugegraph/pull/3140/commits/3941b1c910cbf264724be0c289bed5f7498a88a1)
 makes two small initialization improvements on top of the bounded-concurrency 
change:
   
   - **Multiple Stores:** after waiting for one completion, drain every 
completion already queued before refilling the 8-source window. This makes an 
already-completed failure visible before another Store stream (for example, 
`S9`) is started.
   - **Exactly one Store:** initialize its first entry inline and bypass 
executor/future dispatch, since the caller must wait for that entry anyway. The 
previous interruption contract is preserved: restore the interrupt flag, report 
the same initialization error, and close the source.
   
   The ordered merge, concurrency bound, cancellation, and cleanup behavior 
remain unchanged.
   
   ![Ordered scan initialization 
follow-up](https://gist.githubusercontent.com/contrueCT/6cb586216d8f96aa8ebfea7ffba87ea4/raw/447a406ed68f0866da0065342a8c8a0732bc4c03/pr-3140-ordered-scan-initialization.svg)
   
   Validation: `ClientSuiteTest` — **34 tests passed, 0 failures, 0 errors**.
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to