geode-core/src/main/java/org/apache/geode/internal/cache/xmlcache/RegionCreation.java

/*
 * Licensed to the Apache Software Foundation (ASF) under one or more contributor license
 * agreements. See the NOTICE file distributed with this work for additional information regarding
 * copyright ownership. The ASF licenses this file to You under the Apache License, Version 2.0 (the
 * "License"); you may not use this file except in compliance with the License. You may obtain a
 * copy of the License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software distributed under the License
 * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
 * or implied. See the License for the specific language governing permissions and limitations under
 * the License.
 */
package org.apache.geode.internal.cache.xmlcache;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.util.ArrayList;
import java.util.Collection;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Iterator;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.locks.Lock;

import org.apache.geode.cache.AttributesFactory;
import org.apache.geode.cache.AttributesMutator;
import org.apache.geode.cache.Cache;
import org.apache.geode.cache.CacheLoaderException;
import org.apache.geode.cache.CacheStatistics;
import org.apache.geode.cache.CacheWriterException;
import org.apache.geode.cache.EntryExistsException;
import org.apache.geode.cache.EntryNotFoundException;
import org.apache.geode.cache.InterestResultPolicy;
import org.apache.geode.cache.Region;
import org.apache.geode.cache.RegionAttributes;
import org.apache.geode.cache.RegionDestroyedException;
import org.apache.geode.cache.RegionExistsException;
import org.apache.geode.cache.RegionService;
import org.apache.geode.cache.TimeoutException;
import org.apache.geode.cache.query.SelectResults;
import org.apache.geode.cache.query.internal.index.IndexCreationData;
import org.apache.geode.cache.snapshot.RegionSnapshotService;
import org.apache.geode.internal.cache.InternalCache;
import org.apache.geode.internal.cache.LocalRegion;
import org.apache.geode.internal.cache.extension.Extensible;
import org.apache.geode.internal.cache.extension.ExtensionPoint;
import org.apache.geode.internal.cache.extension.SimpleExtensionPoint;

/**
 * Represents a {@link Region} that is created declaratively. Notice that it implements the
 * {@link Region} interface so that this class must be updated when {@link Region} is modified. This
 * class is public for testing purposes.
 *
 * @since GemFire 3.0
 */
public class RegionCreation implements Region, Extensible<Region<?, ?>> {

  /** The name of this region */
  private final String name;

  /**
   * The id of the region-attributes this regions uses by default.
   *
   * @since GemFire 6.5
   */
  private String refid;

  /**
   * If true then someone explicitly added region attributes to this region
   *
   * @since GemFire 6.5
   */
  private boolean hasAttributes;

  /** The full path to this region */
  private final String fullPath;

  /** The attributes of this region */
  private RegionAttributesCreation attrs;

  /** This region's subregions keyed on name */
  private Map subregions = new LinkedHashMap();

  /** The key/value pairs in this region */
  private Map values = new HashMap();

  /**
   * List of IndexCreationData objects. A region can contain multiple indexes defined
   */
  private List indexes = new ArrayList();

  /** The cache in which this region will reside */
  private final CacheCreation cache;

  /**
   * {@link ExtensionPoint} to {@link Region}.
   *
   * @since GemFire 8.1
   */
  private final SimpleExtensionPoint<Region<?, ?>> extensionPoint =
      new SimpleExtensionPoint<Region<?, ?>>(this, this);

  /**
   * Creates a new <code>RegionCreation</code> with the given name and with the default
   * <code>RegionAttributes</code>.
   */
  public RegionCreation(CacheCreation cache, RegionCreation parent, String name, String refid) {
    this.cache = cache;
    if (parent != null) {
      this.fullPath = parent.getFullPath() + SEPARATOR + name;

    } else {
      this.fullPath = SEPARATOR + name;
    }
    this.name = name;
    this.refid = refid;
    this.attrs = new RegionAttributesCreation(this.cache);
    if (refid != null) {
      this.attrs.setRefid(refid);
      this.attrs.inheritAttributes(cache);
    }
  }

  public RegionCreation(CacheCreation cache, String name, String refid) {
    this(cache, null, name, refid);
  }

  public RegionCreation(CacheCreation cache, String name) {
    this(cache, null, name, null);
  }

  @Override
  public Object put(Object key, Object value) throws TimeoutException, CacheWriterException {
    return this.values.put(key, value);
  }

  /**
   * Fills in the state (that is, adds entries and creates subregions) of a given
   * <code>Region</code> based on the description provided by this <code>RegionCreation</code>.
   *
   */
  private void fillIn(Region region)
      throws TimeoutException, CacheWriterException, RegionExistsException {

    for (Iterator iter = this.values.entrySet().iterator(); iter.hasNext();) {
      Map.Entry entry = (Map.Entry) iter.next();
      region.put(entry.getKey(), entry.getValue());
    }

    if (region instanceof Extensible) {
      // UnitTest CacheXml81Test.testRegionExtension
      @SuppressWarnings("unchecked")
      final Extensible<Region<?, ?>> extensible = (Extensible<Region<?, ?>>) region;
      extensionPoint.fireCreate(extensible);
    }

    for (Iterator iter = this.subregions.values().iterator(); iter.hasNext();) {
      RegionCreation sub = (RegionCreation) iter.next();
      sub.create(region);
    }
  }

  /**
   * Sets the mutable attributes of the given region based on the attributes of this
   * <code>RegionCreation</code>. This allows us to modify the attributes of an existing region
   * using a cache.xml file.
   *
   * @see AttributesMutator
   */
  private void setMutableAttributes(Region region) {
    AttributesMutator mutator = region.getAttributesMutator();

    RegionAttributesCreation attrs = this.attrs;

    if (attrs.hasCacheListeners()) {
      mutator.initCacheListeners(attrs.getCacheListeners());
    }

    if (attrs.hasCacheLoader()) {
      mutator.setCacheLoader(attrs.getCacheLoader());
    }

    if (attrs.hasCacheWriter()) {
      mutator.setCacheWriter(attrs.getCacheWriter());
    }

    if (attrs.hasEntryIdleTimeout()) {
      mutator.setEntryIdleTimeout(attrs.getEntryIdleTimeout());
    }
    if (attrs.hasCustomEntryIdleTimeout()) {
      mutator.setCustomEntryIdleTimeout(attrs.getCustomEntryIdleTimeout());
    }

    if (attrs.hasEntryTimeToLive()) {
      mutator.setEntryTimeToLive(attrs.getEntryTimeToLive());
    }
    if (attrs.hasCustomEntryTimeToLive()) {
      mutator.setCustomEntryTimeToLive(attrs.getCustomEntryTimeToLive());
    }

    if (attrs.hasRegionIdleTimeout()) {
      mutator.setRegionIdleTimeout(attrs.getEntryIdleTimeout());
    }

    if (attrs.hasRegionTimeToLive()) {
      mutator.setRegionTimeToLive(attrs.getRegionTimeToLive());
    }

    if (attrs.hasCloningEnabled()) {
      mutator.setCloningEnabled(attrs.getCloningEnabled());
    }
  }

  /**
   * Creates a root {@link Region} in a given <code>Cache</code> based on the description provided
   * by this <code>RegionCreation</code>.
   *
   */
  void createRoot(Cache cache)
      throws TimeoutException, CacheWriterException, RegionExistsException {
    Region root = null;

    // Validate the attributes before creating the root region
    this.attrs.inheritAttributes(cache);
    this.attrs.setIndexes(this.indexes);
    this.attrs.prepareForValidation();

    extensionPoint.beforeCreate(cache);

    try {
      root = ((InternalCache) cache).basicCreateRegion(this.name,
          new AttributesFactory(this.attrs).create());
    } catch (RegionExistsException ex) {
      root = ex.getRegion();
      setMutableAttributes(root);
    } catch (RegionDestroyedException ex) {
      // Region was concurrently destroyed.
      cache.getLogger().warning(
          String.format("Region was globally destroyed during cache initialization: %s",
              this.name));
      // do nothing
    }
    if (root != null) {
      fillIn(root);
    }
  }

  /**
   * Called by CacheXmlParser to add the IndexCreationData object to the list. It is called when
   * functional element is encounetered
   *
   */
  void addIndexData(IndexCreationData icd) {
    this.indexes.add(icd);
  }

  /**
   * Creates a {@link Region} with the given parent using the description provided by this
   * <code>RegionCreation</code>.
   *
   */
  void create(Region parent) throws TimeoutException, CacheWriterException, RegionExistsException {

    // Validate the attributes before creating the sub-region
    this.attrs.inheritAttributes(parent.getCache());
    this.attrs.prepareForValidation();
    this.attrs.setIndexes(this.indexes);

    Region me = null;
    try {
      me = parent.createSubregion(this.name, new AttributesFactory(this.attrs).create());
    } catch (RegionExistsException ex) {
      me = ex.getRegion();
      setMutableAttributes(me);
    } catch (RegionDestroyedException ex) {
      // Region was concurrently destroyed.
      cache.getLogger().warning(
          String.format("Region was globally destroyed during cache initialization: %s",
              this.name));
      // do nothing
    }

    if (me != null) {
      // Register named region attributes
      String id = this.attrs.getId();
      if (id != null) {
        RegionAttributes realAttrs = me.getAttributes();
        me.getCache().setRegionAttributes(id, realAttrs);
      }

      fillIn(me);
    }
  }

  /**
   * Returns whether or not this <code>RegionCreation</code> is equivalent to another
   * <code>Region</code>.
   */
  public boolean sameAs(Region other) {
    if (other == null) {
      return false;
    }

    if (!this.getName().equals(other.getName())) {
      throw new RuntimeException(String.format("region names differ: this: %s other: %s",
          new Object[] {this.getName(), other.getName()}));
    }

    if (!this.attrs.sameAs(other.getAttributes())) {
      throw new RuntimeException(
          String.format("region attributes differ this: %s other: %s",
              new Object[] {this.attrs, other.getAttributes()}));
    }

    Collection myEntries = this.basicEntries(false);
    Collection otherEntries = ((LocalRegion) other).basicEntries(false);
    if (myEntries.size() != otherEntries.size()) {
      return false;
    }

    for (Iterator iter = myEntries.iterator(); iter.hasNext();) {
      Region.Entry myEntry = (Region.Entry) iter.next();
      Region.Entry otherEntry = other.getEntry(myEntry.getKey());
      if (otherEntry == null) {
        return false;

      } else if (!myEntry.getValue().equals(otherEntry.getValue())) {
        return false;
      }
    }

    return true;
  }

  @Override
  public String getName() {
    return this.name;
  }

  /**
   * Sets the attributes of this region
   */
  public void setAttributes(RegionAttributes attrs) {
    setAttributes(attrs, true);
  }

  /**
   * Note: hydra invokes this with setRefid=false.
   */
  public void setAttributes(RegionAttributes attrs, boolean setRefid) {
    this.hasAttributes = true;
    if (attrs instanceof RegionAttributesCreation) {
      this.attrs = (RegionAttributesCreation) attrs;
    } else {
      this.attrs = new RegionAttributesCreation(this.cache, attrs, false);
    }
    if ((setRefid && (this.attrs.getRefid() == null))) {
      this.attrs.setRefid(getRefid());
    }
    if (attrs.getPartitionAttributes() != null && attrs.getEvictionAttributes() != null
        && attrs.getEvictionAttributes().getAlgorithm().isLRUMemory()
        && attrs.getPartitionAttributes().getLocalMaxMemory() != 0 && attrs.getEvictionAttributes()
            .getMaximum() != attrs.getPartitionAttributes().getLocalMaxMemory()) {
      getCache().getLogger().warning(String.format(
          "For region %s with data policy PARTITION, memory LRU eviction attribute maximum has been reset from %sMB to local-max-memory %sMB",
          new Object[] {this.getName(), attrs.getEvictionAttributes().getMaximum(),
              attrs.getPartitionAttributes().getLocalMaxMemory()}));
      this.attrs.setEvictionAttributes(attrs.getEvictionAttributes().createLRUMemoryAttributes(
          attrs.getPartitionAttributes().getLocalMaxMemory(),
          attrs.getEvictionAttributes().getObjectSizer(),
          attrs.getEvictionAttributes().getAction()));
    }
  }

  @Override
  public RegionAttributes getAttributes() {
    return this.attrs;
  }



  @Override
  public Region getSubregion(String regionName) {
    return (Region) this.subregions.get(regionName);
  }

  /**
   * Adds a subregion with the given name to this region
   *
   *
   * @throws RegionExistsException If a subregion with <code>name</code> already exists
   */
  void addSubregion(String name, RegionCreation region) throws RegionExistsException {

    if (this.subregions.containsKey(name)) {
      RegionCreation existing = (RegionCreation) this.subregions.get(name);
      throw new RegionExistsException(existing);

    } else {
      this.subregions.put(name, region);
    }
  }

  @Override
  public Set subregions(boolean recursive) {
    if (recursive) {
      throw new UnsupportedOperationException(
          "Getting subregions recursively is not supported.");
    }

    return new HashSet(this.subregions.values());
  }

  @Override
  public void writeToDisk() {
    throw new UnsupportedOperationException(
        "Writing a RegionCreation to disk is not supported.");
  }

  @Override
  public void registerInterest(Object key) throws CacheWriterException {
    throw new UnsupportedOperationException(
        "Unsupported at this time");
  }

  @Override
  public void registerInterest(Object key, boolean isDurable) throws CacheWriterException {
    throw new UnsupportedOperationException(
        "Unsupported at this time");
  }

  @Override
  public void registerInterest(Object key, boolean isDurable, boolean receiveValues)
      throws CacheWriterException {
    throw new UnsupportedOperationException(
        "Unsupported at this time");
  }

  @Override
  public void registerInterestRegex(String regex) throws CacheWriterException {
    throw new UnsupportedOperationException(
        "Unsupported at this time");
  }

  @Override
  public void registerInterestRegex(String regex, boolean isDurable) throws CacheWriterException {
    throw new UnsupportedOperationException(
        "Unsupported at this time");
  }

  @Override
  public void registerInterestRegex(String regex, boolean isDurable, boolean receiveValues)
      throws CacheWriterException {
    throw new UnsupportedOperationException(
        "Unsupported at this time");
  }

  @Override
  public void registerInterest(Object key, InterestResultPolicy policy)
      throws CacheWriterException {
    throw new UnsupportedOperationException(
        "Unsupported at this time");
  }

  @Override
  public void registerInterest(Object key, InterestResultPolicy policy, boolean isDurable)
      throws CacheWriterException {
    throw new UnsupportedOperationException(
        "Unsupported at this time");
  }

  @Override
  public void registerInterest(Object key, InterestResultPolicy policy, boolean isDurable,
      boolean receiveValues) throws CacheWriterException {
    throw new UnsupportedOperationException(
        "Unsupported at this time");
  }


  @Override
  public void registerInterestRegex(String regex, InterestResultPolicy policy)
      throws CacheWriterException {
    throw new UnsupportedOperationException(
        "Unsupported at this time");
  }

  @Override
  public void registerInterestRegex(String regex, InterestResultPolicy policy, boolean isDurable)
      throws CacheWriterException {
    throw new UnsupportedOperationException(
        "Unsupported at this time");
  }

  @Override
  public void registerInterestRegex(String regex, InterestResultPolicy policy, boolean isDurable,
      boolean receiveValues) throws CacheWriterException {
    throw new UnsupportedOperationException(
        "Unsupported at this time");
  }

  @Override
  public void unregisterInterest(Object key) throws CacheWriterException {
    throw new UnsupportedOperationException(
        "Unsupported at this time");
  }

  public void unregisterInterest(Object key, boolean isDurable) throws CacheWriterException {
    throw new UnsupportedOperationException(
        "Unsupported at this time");
  }

  @Override
  public void unregisterInterestRegex(String regex) throws CacheWriterException {
    throw new UnsupportedOperationException(
        "Unsupported at this time");
  }

  public void unregisterInterestRegex(String regex, boolean isDurable) throws CacheWriterException {
    throw new UnsupportedOperationException(
        "Unsupported at this time");
  }


  @Override
  public List getInterestList() throws CacheWriterException {
    throw new UnsupportedOperationException(
        "Unsupported at this time");
  }

  public List getDurableInterestList() throws CacheWriterException {
    throw new UnsupportedOperationException(
        "Unsupported at this time");
  }

  @Override
  public List getInterestListRegex() throws CacheWriterException {
    throw new UnsupportedOperationException(
        "Unsupported at this time");
  }

  @Override
  public Set keySetOnServer() throws CacheWriterException {
    throw new UnsupportedOperationException(
        "Unsupported at this time");
  }

  @Override
  public boolean containsKeyOnServer(Object key) throws CacheWriterException {
    throw new UnsupportedOperationException(
        "Unsupported at this time");
  }

  @Override
  public int sizeOnServer() throws CacheWriterException {
    throw new UnsupportedOperationException(
        "Unsupported at this time");
  }

  @Override
  public boolean isEmptyOnServer() throws CacheWriterException {
    throw new UnsupportedOperationException(
        "Unsupported at this time");
  }

  static class Entry implements Region.Entry {
    private Object key;
    private Object value;

    Entry(Object key, Object value) {
      this.key = key;
      this.value = value;
    }

    @Override
    public boolean isLocal() {
      return false;
    }

    @Override
    public Object getKey() {
      return key;
    }

    @Override
    public Object getValue() {
      return value;
    }

    @Override
    public Region getRegion() {
      throw new UnsupportedOperationException("Should not be invoked");
    }

    @Override
    public CacheStatistics getStatistics() {
      throw new UnsupportedOperationException("Should not be invoked");
    }

    @Override
    public Object getUserAttribute() {
      throw new UnsupportedOperationException("Should not be invoked");
    }

    @Override
    public Object setUserAttribute(Object userAttribute) {
      throw new UnsupportedOperationException("Should not be invoked");
    }

    @Override
    public boolean isDestroyed() {
      throw new UnsupportedOperationException("Should not be invoked");
    }

    @Override
    public Object setValue(Object arg0) {
      throw new UnsupportedOperationException("Should not be invoked");
    }
  }

  @Override
  public Region.Entry getEntry(Object key) {
    Object value = this.values.get(key);
    if (value == null) {
      return null;

    } else {
      return new Entry(key, value);
    }
  }

  public Set entries(boolean recursive) {
    return basicEntries(recursive);
  }

  public Set basicEntries(boolean recursive) {
    if (recursive) {
      throw new UnsupportedOperationException(
          "Getting entries recursively is not supported.");
    }

    Set set = new HashSet();
    for (Iterator iter = this.values.entrySet().iterator(); iter.hasNext();) {
      final Map.Entry entry = (Map.Entry) iter.next();
      set.add(new Entry(entry.getKey(), entry.getValue()));
    }

    return set;
  }

  @Override
  public String getFullPath() {
    return this.fullPath;
  }

  @Override
  public Region getParentRegion() {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public AttributesMutator getAttributesMutator() {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public CacheStatistics getStatistics() {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public void invalidateRegion() throws TimeoutException {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public void invalidateRegion(Object aCallbackArgument) throws TimeoutException {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public void localInvalidateRegion() {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public void localInvalidateRegion(Object aCallbackArgument) {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public void destroyRegion() throws CacheWriterException, TimeoutException {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public void destroyRegion(Object aCacheWriterParam)
      throws CacheWriterException, TimeoutException {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public void localDestroyRegion() {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public void localDestroyRegion(Object aCallbackArgument) {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public void close() {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public Region createSubregion(String subregionName, RegionAttributes attrs)
      throws RegionExistsException, TimeoutException {
    RegionCreation subregion = new RegionCreation(this.cache, this, subregionName, null);
    subregion.setAttributes(attrs);
    this.addSubregion(subregionName, subregion);
    return subregion;
  }

  @Override
  public Object get(Object key) throws CacheLoaderException, TimeoutException {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public Object get(Object key, Object aCallbackArgument)
      throws TimeoutException, CacheLoaderException {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public Object put(Object key, Object value, Object aCacheWriterParam)
      throws TimeoutException, CacheWriterException {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public void create(Object key, Object value)
      throws TimeoutException, EntryExistsException, CacheWriterException {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public void create(Object key, Object value, Object aCacheWriterParam)
      throws TimeoutException, EntryExistsException, CacheWriterException {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public void invalidate(Object key) throws TimeoutException, EntryNotFoundException {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public void invalidate(Object key, Object callbackArgument)
      throws TimeoutException, EntryNotFoundException {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public void localInvalidate(Object key) throws EntryNotFoundException {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public void localInvalidate(Object key, Object callbackArgument) throws EntryNotFoundException {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public Object destroy(Object key)
      throws TimeoutException, EntryNotFoundException, CacheWriterException {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public Object destroy(Object key, Object aCacheWriterParam)
      throws TimeoutException, EntryNotFoundException, CacheWriterException {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public void localDestroy(Object key) throws EntryNotFoundException {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public void localDestroy(Object key, Object callbackArgument) throws EntryNotFoundException {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  public Set keys() {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public Collection values() {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public Cache getCache() {
    return this.cache;
  }

  @Override
  public RegionService getRegionService() {
    return this.cache;
  }

  @Override
  public Object getUserAttribute() {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public void setUserAttribute(Object value) {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public boolean isDestroyed() {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public boolean containsValueForKey(Object key) {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public boolean containsKey(Object key) {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public Lock getRegionDistributedLock() {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public Lock getDistributedLock(Object key) {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public boolean existsValue(String predicate) {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public SelectResults query(String predicate) {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public Object selectValue(String predicate) {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public void loadSnapshot(InputStream inputStream)
      throws IOException, ClassNotFoundException, CacheWriterException, TimeoutException {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public void saveSnapshot(OutputStream outputStream) throws IOException {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public void becomeLockGrantor() {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public int size() {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public void clear() {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public boolean isEmpty() {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public boolean containsValue(Object arg0) {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public void putAll(Map arg0) {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public void putAll(Map arg0, Object callbackArg) {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public Map getAll(Collection keys) {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public Map getAll(Collection keys, Object callback) {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public Set entrySet() {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public Set keySet() {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public Object remove(Object arg0) {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public Set entrySet(boolean recursive) {
    if (recursive) {
      throw new UnsupportedOperationException(
          "Getting entries recursively is not supported.");
    }

    Set set = new HashSet();
    for (Iterator iter = this.values.entrySet().iterator(); iter.hasNext();) {
      final Map.Entry entry = (Map.Entry) iter.next();
      set.add(new Entry(entry.getKey(), entry.getValue()));
    }

    return set;
  }

  @Override
  public void localClear() {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public void forceRolling() {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  public boolean forceCompaction() {
    throw new UnsupportedOperationException("Shouldn't be invoked");
  }

  @Override
  public Object putIfAbsent(Object key, Object value) {
    throw new UnsupportedOperationException();
  }

  @Override
  public boolean remove(Object key, Object value) {
    throw new UnsupportedOperationException();
  }

  @Override
  public Object replace(Object key, Object value) {
    throw new UnsupportedOperationException();
  }

  @Override
  public boolean replace(Object key, Object oldValue, Object newValue) {
    throw new UnsupportedOperationException();
  }

  /**
   * Sets the refid of the region attributes being created
   *
   * @since GemFire 6.5
   */
  public void setRefid(String refid) {
    this.refid = refid;
  }

  /**
   * Returns the refid of the region attributes being created
   *
   * @since GemFire 6.5
   */
  public String getRefid() {
    return this.refid;
  }

  /**
   * Returns true if someone explicitly added region attributes to this region.
   */
  public boolean hasAttributes() {
    return this.hasAttributes;
  }

  @Override
  public RegionSnapshotService<?, ?> getSnapshotService() {
    throw new UnsupportedOperationException();
  }

  @Override
  public void removeAll(Collection keys) {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  @Override
  public void removeAll(Collection keys, Object aCallbackArgument) {
    throw new UnsupportedOperationException("Should not be invoked");
  }

  /**
   * @since GemFire 8.1
   */
  @Override
  public ExtensionPoint<Region<?, ?>> getExtensionPoint() {
    return extensionPoint;
  }
}