public VersionedObjectList basicBridgeRemoveAll(List<Object> keys,
      ArrayList<VersionTag> retryVersions, ClientProxyMembershipID memberId, EventID eventId,
      Object callbackArg, boolean isRetry) throws TimeoutException, CacheWriterException {

    long startOp = getStatisticsClock().getTime();

    @Released
    final EntryEventImpl event =
        entryEventFactory.create(this, Operation.REMOVEALL_DESTROY, null,
            null, callbackArg, false,
            memberId.getDistributedMember(), true, eventId);

    try {
      event.setContext(memberId);
      event.setPossibleDuplicate(isRetry);
      DistributedRemoveAllOperation removeAllOp =
          new DistributedRemoveAllOperation(event, keys.size(), true);
      try {
        VersionedObjectList result = basicRemoveAll(keys, removeAllOp, retryVersions);
        getCachePerfStats().endRemoveAll(startOp);
        return result;
      } finally {
        removeAllOp.freeOffHeapResources();
      }
    } finally {
      event.release();
    }
  }
Called on a cache server when it has a received a removeAll command from a client.

@param keys a collection of the keys we are putting
@param retryVersions a collection of version tags. If the client is retrying a key then that
       keys slot will be non-null in this collection. Note that keys and retryVersions are
       parallel lists.
@param callbackArg callback argument from client
@param isRetry whether this is a client retry
geode-core/src/main/java/org/apache/geode/internal/cache/LocalRegion.java