mhansonp commented on a change in pull request #6858:
URL: https://github.com/apache/geode/pull/6858#discussion_r707525078
##########
File path:
geode-core/src/main/java/org/apache/geode/internal/cache/ha/HARegionQueue.java
##########
@@ -2211,22 +2194,16 @@ public Object
updateHAEventWrapper(InternalDistributedMember sender,
* a single peek thread.
*/
private static class BlockingHARegionQueue extends HARegionQueue {
- /**
- * Guards the Put permits
- */
- private final Object putGuard = new Object();
-
- private final int capacity;
-
/**
* Current put permits available
*/
- private int putPermits;
+ private final AtomicInteger putPermits = new AtomicInteger(0);
Review comment:
Variable changes that were required.
--
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]
