@After
  public void tearDown() {
    for (VM vm : asList(getController(), client1, client2, server1, server2)) {
      vm.invoke(() -> {
        countDown(LATCH);
        countDown(BEFORE);
        countDown(AFTER);
        closeClientCache();
        closeCache();
        PoolManager.close();
        DISK_DIR.set(null);
      });
    }
  }
Tests putAll for c/s. Also tests removeAll

@since GemFire 5.0.23
geode-cq/src/distributedTest/java/org/apache/geode/internal/cache/PutAllClientServerDistributedTest.java