Commit 455a525
Bigtable - improvement: Rewrite ReframingResponseObserver (#2925)
The new version uses atomics to ensure mutual exclusion instead of synchronization.
This allows the delivery loop to be simpler since there is no need to need to defer actions until after exiting the synchronization.
Also, move all interactions with the Reframer to the delivery loop, which ensures proper error handling if the Reframer detects an error.1 parent 3d09764 commit 455a525
3 files changed
Lines changed: 178 additions & 193 deletions
File tree
- google-cloud-bigtable/src
- main/java/com/google/cloud/bigtable/gaxx/reframing
- test/java/com/google/cloud/bigtable/gaxx
- reframing
- testing
0 commit comments