@Override
  public void run2() {
    if (!waitForColocationCompleted(redundancyProvider.getPartitionedRegion())) {
      // if after all the time, colocation is still not completed, do nothing
      return;
    }

    if (redundancyProvider.getPartitionedRegion().isLocallyDestroyed
        || redundancyProvider.getPartitionedRegion().isClosed)
      return;

    PartitionedRegion leaderRegion =
        ColocationHelper.getLeaderRegion(redundancyProvider.getPartitionedRegion());
    RecoveryLock lock = leaderRegion.getRecoveryLock();
    lock.lock();
    try {
      createMissingBuckets(redundancyProvider.getPartitionedRegion());
    } finally {
      lock.unlock();
    }
  }
A task for creating buckets in a child colocated region that are present in the leader region.
geode-core/src/main/java/org/apache/geode/internal/cache/partitioned/CreateMissingBucketsTask.java