public VersionedObjectList basicBridgePutAll(Map map, Map<Object, VersionTag> retryVersions,
      ClientProxyMembershipID memberId, EventID eventId, boolean skipCallbacks, Object callbackArg,
      boolean isRetry)
      throws TimeoutException, CacheWriterException {

    long startPut = getStatisticsClock().getTime();

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

    try {
      event.setContext(memberId);
      event.setPossibleDuplicate(isRetry);
      DistributedPutAllOperation putAllOp = new DistributedPutAllOperation(event, map.size(), true);
      try {
        VersionedObjectList result = basicPutAll(map, putAllOp, retryVersions);
        getCachePerfStats().endPutAll(startPut);
        return result;
      } finally {
        putAllOp.freeOffHeapResources();
      }
    } finally {
      event.release();
    }
  }
Called on a cache server when it has a received a putAll command from a client.

@param map a map of key->value for the entries we are putting
@param retryVersions a map of key->version tag. If any of the entries are the result of a
       retried client event, we need to make sure we send the original version tag along with
       the event.
@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