protected VersionTag findVersionTagsForRetriedBulkOp(LocalRegion r,EventID eventID){
  VersionTag tag=r.findVersionTagForClientBulkOp(eventID);
  if (tag != null) {
    if (logger.isDebugEnabled()) {
      logger.debug("recovered version tag {} for replayed bulk operation {}",tag,eventID);
    }
    return tag;
  }
  if (r instanceof DistributedRegion || r instanceof PartitionedRegion) {
    tag=FindVersionTagOperation.findVersionTag(r,eventID,true);
  }
  if (tag != null) {
    if (logger.isDebugEnabled()) {
      logger.debug("recovered version tag {} for replayed bulk operation {}",tag,eventID);
    }
  }
  return tag;
}

protected VersionTag findVersionTagsForRetriedBulkOp ( LocalRegion r , EventID eventID ) { VersionTag tag = r . findVersionTagForClientBulkOp ( eventID ) ; if ( tag != null ) { if ( logger . isDebugEnabled ( ) ) { logger . debug ( "recovered version tag {} for replayed bulk operation {}" , tag , eventID ) ; } return tag ; } if ( r instanceof DistributedRegion || r instanceof PartitionedRegion ) { tag = FindVersionTagOperation . findVersionTag ( r , eventID , true ) ; } if ( tag != null ) { if ( logger . isDebugEnabled ( ) ) { logger . debug ( "recovered version tag {} for replayed bulk operation {}" , tag , eventID ) ; } } return tag ; }
if an operation is retried then some server may have seen it already . we cannot apply this operation to the cache without knowing whether a version tag has already been created for it . otherwise caches that have seen the event already will reject it but others will not , but will have no version tag with which to perform concurrency checks . < p > the client event should have the event identifier from the client and the region affected by the operation .
