albertogpz commented on a change in pull request #6739:
URL: https://github.com/apache/geode/pull/6739#discussion_r694035111
##########
File path:
geode-core/src/distributedTest/java/org/apache/geode/internal/cache/tier/sockets/UpdatePropagationDUnitTest.java
##########
@@ -305,6 +364,43 @@ private void verifyUpdates() {
});
}
+ private void doPuts(int entries) {
+ Region r1 = getCache().getRegion(SEPARATOR + REGION_NAME);
+ assertNotNull(r1);
+ for (int i = 0; i < entries; i++) {
+ try {
+ System.out.println("toberal Putting " + i);
Review comment:
This line must be removed.
##########
File path:
geode-core/src/distributedTest/java/org/apache/geode/internal/cache/tier/sockets/UpdatePropagationDUnitTest.java
##########
@@ -305,6 +364,43 @@ private void verifyUpdates() {
});
}
+ private void doPuts(int entries) {
+ Region r1 = getCache().getRegion(SEPARATOR + REGION_NAME);
+ assertNotNull(r1);
+ for (int i = 0; i < entries; i++) {
+ try {
+ System.out.println("toberal Putting " + i);
+ r1.put("" + i, "" + i);
+ System.out.println("toberal Put " + i);
+ } catch (Exception e) {
+ System.out.println("toberal Exception putting " + i);
+ }
+ try {
+ Thread.sleep(1000);
+ } catch (InterruptedException e) {
+ e.printStackTrace();
+ }
+ }
+ }
+
+ private int getNotNullEntriesNumber(int entries) {
+ int notNullEntries = 0;
+ Region r1 = getCache().getRegion(SEPARATOR + REGION_NAME);
+ assertNotNull(r1);
+ for (int i = 0; i < entries; i++) {
+ try {
+ Object value = r1.get("" + i, "" + i);
+ System.out.println("toberal Read " + i + " -> " + value);
Review comment:
This line must be removed.
##########
File path:
geode-core/src/distributedTest/java/org/apache/geode/internal/cache/tier/sockets/UpdatePropagationDUnitTest.java
##########
@@ -305,6 +364,43 @@ private void verifyUpdates() {
});
}
+ private void doPuts(int entries) {
+ Region r1 = getCache().getRegion(SEPARATOR + REGION_NAME);
+ assertNotNull(r1);
+ for (int i = 0; i < entries; i++) {
+ try {
+ System.out.println("toberal Putting " + i);
+ r1.put("" + i, "" + i);
+ System.out.println("toberal Put " + i);
Review comment:
This line must be removed.
##########
File path:
geode-core/src/distributedTest/java/org/apache/geode/internal/cache/tier/sockets/UpdatePropagationDUnitTest.java
##########
@@ -305,6 +364,43 @@ private void verifyUpdates() {
});
}
+ private void doPuts(int entries) {
+ Region r1 = getCache().getRegion(SEPARATOR + REGION_NAME);
+ assertNotNull(r1);
+ for (int i = 0; i < entries; i++) {
+ try {
+ System.out.println("toberal Putting " + i);
+ r1.put("" + i, "" + i);
+ System.out.println("toberal Put " + i);
+ } catch (Exception e) {
+ System.out.println("toberal Exception putting " + i);
Review comment:
This line must be removed.
--
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]
