mivanac commented on a change in pull request #5630:
URL: https://github.com/apache/geode/pull/5630#discussion_r604405466
##########
File path:
geode-wan/src/distributedTest/java/org/apache/geode/internal/cache/wan/parallel/ParallelGatewaySenderOperationsDUnitTest.java
##########
@@ -1023,6 +1238,268 @@ private void createPartitionedRegions(boolean
createAccessors) {
vm3.invoke(() -> createPartitionedRegion(regionName, "ln", 1, 100,
isOffHeap()));
}
+ private void updateBatchSize(int batchsize) {
+ vm4.invoke(() -> {
+ AbstractGatewaySender sender = (AbstractGatewaySender)
cache.getGatewaySender("ln");
+ boolean paused = false;
+ if (sender.isRunning() && !sender.isPaused()) {
Review comment:
We pause gw sender to prevent any interference with running processes.
This was one of comments on RFC. And I am not sure that internal handling in
command execution is documented for users. But if everyone agrees that this is
needed, I can add.
--
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.
For queries about this service, please contact Infrastructure at:
[email protected]
