protected int getBucketCount(VM vm0) {
    return (Integer) vm0.invoke(new SerializableCallable("checkLowRedundancy") {

      @Override
      public Object call() {
        Cache cache = getCache();
        PartitionedRegion region = (PartitionedRegion) cache.getRegion("region1");
        return region.getLocalBucketsListTestOnly().size();
      }
    });
  }
Test that we don't try to put buckets in the same zone when we don't have enough zones.
geode-core/src/distributedTest/java/org/apache/geode/internal/cache/PartitionedRegionRedundancyZoneDUnitTest.java