HDDS-13974. Use the same gRPC steam for reading the same block.#9369

Merged

szetszwo merged 30 commits intoapache:masterfrom

szetszwo:HDDS-13974

Nov 26, 2025

Commits on Nov 25, 2025

fix synchronized

chungen0126
authored and
szetszwo
committed
fix checkstyle

chungen0126
authored and
szetszwo
committed
A ChunkOffsetInBlock to the ChunkInfo proto message to allow checksum offsets to be calculated correctly on the client

S O'Donnell
authored and
szetszwo
committed
Refactor to stream entire block to client in a single call. Commented on many tests to allow it to compile

S O'Donnell
authored and
szetszwo
committed
Implement seek

S O'Donnell
authored and
szetszwo
committed
Test for and implement no checksum case

S O'Donnell
authored and
szetszwo
committed
Revert "Add ChunkOffsetInBlock to the ChunkInfo proto message to allow checksum offsets to be calculated correctly on the client"

S O'Donnell
authored and
szetszwo
committed
Adapted unit tests to the new approach

S O'Donnell
authored and
szetszwo
committed
Fix style and remove commented tests

S O'Donnell
authored and
szetszwo
committed
Remove synchronization from streaming reader

S O'Donnell
authored and
szetszwo
committed
Remove or comment out unused code

S O'Donnell
authored and
szetszwo
committed
Throw IOException for ops attempts after closed

S O'Donnell
authored and
szetszwo
committed
Move setPipeline into shared superclass

S O'Donnell
authored and
szetszwo
committed
Fix findbugs warning

S O'Donnell
authored and
szetszwo
committed
Fix PMD

S O'Donnell
authored and
szetszwo
committed
Fix more findbugs

S O'Donnell
authored and
szetszwo
committed
Remove test broken by refactor. It is covered by the integration test anyway

S O'Donnell
authored and
szetszwo
committed
Fix bug caused by refactor

S O'Donnell
authored and
szetszwo
committed
Tidy up formatting

S O'Donnell
authored and
szetszwo
committed
Reuse datanode selection and deadline code in XCeiverGRPC

S O'Donnell
authored and
szetszwo
committed
Fix findbugs

S O'Donnell
authored and
szetszwo
committed
Retry initializing the reader if all DNs fail via pipeline refresh

S O'Donnell
authored and
szetszwo
committed
Fix broken test caused by refactor

S O'Donnell
authored and
szetszwo
committed
Refresh pipeline only for specific exception catagories

S O'Donnell
authored and
szetszwo
committed
Take and release semaphore when starting / completing streaming reads

S O'Donnell
authored and
szetszwo
committed
Fix findbugs sync warning

S O'Donnell
authored and
szetszwo
committed
Address review comment for handling local errors with onError

S O'Donnell
authored and
szetszwo
committed
Refactor somewhat to address problems when local checksum validation fails

S O'Donnell
authored and
szetszwo
committed
Adding new file missed in last commit

S O'Donnell
authored and
szetszwo
committed
Add missing import
szetszwo
committed

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

HDDS-13974. Use the same gRPC steam for reading the same block.#9369

HDDS-13974. Use the same gRPC steam for reading the same block.#9369
szetszwo merged 30 commits intoapache:masterfrom
szetszwo:HDDS-13974

Commits on Nov 25, 2025

fix synchronized

fix checkstyle

A ChunkOffsetInBlock to the ChunkInfo proto message to allow checksum offsets to be calculated correctly on the client

Refactor to stream entire block to client in a single call. Commented on many tests to allow it to compile

Implement seek

Test for and implement no checksum case

Revert "Add ChunkOffsetInBlock to the ChunkInfo proto message to allow checksum offsets to be calculated correctly on the client"

Adapted unit tests to the new approach

Fix style and remove commented tests

Remove synchronization from streaming reader

Remove or comment out unused code

Throw IOException for ops attempts after closed

Move setPipeline into shared superclass

Fix findbugs warning

Fix PMD

Fix more findbugs

Remove test broken by refactor. It is covered by the integration test anyway

Fix bug caused by refactor

Tidy up formatting

Reuse datanode selection and deadline code in XCeiverGRPC

Fix findbugs

Retry initializing the reader if all DNs fail via pipeline refresh

Fix broken test caused by refactor

Refresh pipeline only for specific exception catagories

Take and release semaphore when starting / completing streaming reads

Fix findbugs sync warning

Address review comment for handling local errors with onError

Refactor somewhat to address problems when local checksum validation fails

Adding new file missed in last commit

Add missing import

HDDS-13974. Use the same gRPC steam for reading the same block.#9369szetszwo merged 30 commits intoapache:masterapache/ozone:masterfrom szetszwo:HDDS-13974szetszwo/ozone:HDDS-13974Copy head branch name to clipboard

Commits

Commits on Nov 25, 2025

HDDS-13974. Use the same gRPC steam for reading the same block.#9369
szetszwo merged 30 commits intoapache:masterfrom
szetszwo:HDDS-13974