path: root/plugins/org.eclipse.emf.cdo.tests/src/org/eclipse/emf/cdo/tests/RevisionHolderTest.java

/**
 * Copyright (c) 2004 - 2009 Eike Stepper (Berlin, Germany) and others.
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License v1.0
 * which accompanies this distribution, and is available at
 * http://www.eclipse.org/legal/epl-v10.html
 *
 * Contributors:
 *    Eike Stepper - initial API and implementation
 */
package org.eclipse.emf.cdo.tests;

import org.eclipse.emf.cdo.common.id.CDOID;
import org.eclipse.emf.cdo.common.id.CDOIDUtil;
import org.eclipse.emf.cdo.common.io.CDODataOutput;
import org.eclipse.emf.cdo.common.revision.CDOList;
import org.eclipse.emf.cdo.common.revision.CDOReferenceAdjuster;
import org.eclipse.emf.cdo.common.revision.CDORevision;
import org.eclipse.emf.cdo.common.revision.CDORevisionData;
import org.eclipse.emf.cdo.common.revision.delta.CDORevisionDelta;
import org.eclipse.emf.cdo.internal.common.revision.cache.lru.DLRevisionHolder;
import org.eclipse.emf.cdo.internal.common.revision.cache.lru.LRURevisionCache;
import org.eclipse.emf.cdo.internal.common.revision.cache.lru.LRURevisionHolder;
import org.eclipse.emf.cdo.internal.common.revision.cache.lru.LRURevisionList;
import org.eclipse.emf.cdo.internal.common.revision.cache.lru.RevisionHolder;
import org.eclipse.emf.cdo.spi.common.revision.InternalCDOList;
import org.eclipse.emf.cdo.spi.common.revision.InternalCDORevision;

import org.eclipse.emf.ecore.EClass;
import org.eclipse.emf.ecore.EStructuralFeature;

import java.io.IOException;
import java.util.LinkedList;
import java.util.List;

/**
 * @author Eike Stepper
 */
public class RevisionHolderTest extends AbstractCDOTest
{
  public void testChronology() throws Exception
  {
    LRURevisionCache cache = new LRURevisionCache();
    cache.activate();

    TestRevision r1v1 = new TestRevision(1, 1, 1);
    cache.addRevision(r1v1);
    assertEquals(CDORevision.UNSPECIFIED_DATE, r1v1.getRevised());

    TestRevision r1v2 = new TestRevision(1, 2, 6);
    cache.addRevision(r1v2);
    assertEquals(CDORevision.UNSPECIFIED_DATE, r1v2.getRevised());
    assertEquals(r1v2.getCreated() - 1, r1v1.getRevised());

    TestRevision r1v3 = new TestRevision(1, 3, 11);
    cache.addRevision(r1v3);
    assertEquals(CDORevision.UNSPECIFIED_DATE, r1v3.getRevised());
    assertEquals(r1v3.getCreated() - 1, r1v2.getRevised());
    assertEquals(r1v2.getCreated() - 1, r1v1.getRevised());

    CDOID id = r1v1.getID();

    RevisionHolder h1v3 = cache.getHolder(id);
    assertEquals(r1v3, h1v3.getRevision());

    RevisionHolder h1v2 = h1v3.getNext();
    assertEquals(r1v2, h1v2.getRevision());

    RevisionHolder h1v1 = h1v2.getNext();
    assertEquals(r1v1, h1v1.getRevision());
    assertEquals(null, h1v1.getNext());

    h1v2 = h1v1.getPrev();
    assertEquals(r1v2, h1v2.getRevision());

    h1v3 = h1v2.getPrev();
    assertEquals(r1v3, h1v3.getRevision());
    assertEquals(null, h1v3.getPrev());
  }

  public void testAddHead() throws Exception
  {
    LinkedList<LRURevisionHolder> linkedList = new LinkedList<LRURevisionHolder>();
    LRURevisionList list = new LRURevisionList(100);
    validateList(list, 0);
    for (int i = 0; i < 10; i++)
    {
      LRURevisionHolder holder = new LRURevisionHolder(new TestRevision(i));
      linkedList.addFirst(holder);
      list.addHead(holder);
      validateList(list, i + 1);
      validateList(list, linkedList);
    }
  }

  public void testAddTail() throws Exception
  {
    LinkedList<LRURevisionHolder> linkedList = new LinkedList<LRURevisionHolder>();
    LRURevisionList list = new LRURevisionList(100);
    validateList(list, 0);
    for (int i = 0; i < 10; i++)
    {
      LRURevisionHolder holder = new LRURevisionHolder(new TestRevision(i));
      linkedList.addLast(holder);
      list.addTail(holder);
      validateList(list, i + 1);
      validateList(list, linkedList);
    }
  }

  public void testRemoveHead() throws Exception
  {
    LinkedList<LRURevisionHolder> linkedList = new LinkedList<LRURevisionHolder>();
    LRURevisionList list = new LRURevisionList(100);
    for (int i = 0; i < 10; i++)
    {
      LRURevisionHolder holder = new LRURevisionHolder(new TestRevision(i));
      linkedList.addLast(holder);
      list.addTail(holder);
    }

    validateList(list, 10);
    validateList(list, linkedList);

    LRURevisionHolder holder = linkedList.removeFirst();
    list.remove(holder);
    validateList(list, 9);
    validateList(list, linkedList);
  }

  public void testRemoveTail() throws Exception
  {
    LinkedList<LRURevisionHolder> linkedList = new LinkedList<LRURevisionHolder>();
    LRURevisionList list = new LRURevisionList(100);
    for (int i = 0; i < 10; i++)
    {
      LRURevisionHolder holder = new LRURevisionHolder(new TestRevision(i));
      linkedList.addLast(holder);
      list.addTail(holder);
    }

    validateList(list, 10);
    validateList(list, linkedList);

    LRURevisionHolder holder = linkedList.removeLast();
    list.remove(holder);
    validateList(list, 9);
    validateList(list, linkedList);
  }

  public void testRemoveMiddle() throws Exception
  {
    LinkedList<LRURevisionHolder> linkedList = new LinkedList<LRURevisionHolder>();
    LRURevisionList list = new LRURevisionList(100);
    for (int i = 0; i < 10; i++)
    {
      LRURevisionHolder holder = new LRURevisionHolder(new TestRevision(i));
      linkedList.addLast(holder);
      list.addTail(holder);
    }

    validateList(list, 10);
    validateList(list, linkedList);

    LRURevisionHolder holder = linkedList.remove(5);
    list.remove(holder);
    validateList(list, 9);
    validateList(list, linkedList);
  }

  public void testRemoveAll() throws Exception
  {
    LinkedList<LRURevisionHolder> linkedList = new LinkedList<LRURevisionHolder>();
    LRURevisionList list = new LRURevisionList(100);
    for (int i = 0; i < 10; i++)
    {
      LRURevisionHolder holder = new LRURevisionHolder(new TestRevision(i));
      linkedList.addLast(holder);
      list.addTail(holder);
    }

    validateList(list, 10);
    validateList(list, linkedList);

    for (int i = 10; i > 0; i--)
    {
      LRURevisionHolder holder = linkedList.remove(0);
      list.remove(holder);
      validateList(list, i - 1);
      validateList(list, linkedList);
    }

    validateList(list, 0);
    validateList(list, linkedList);
  }

  public void testRevised() throws Exception
  {
    LRURevisionCache cache = new LRURevisionCache();
    cache.activate();

    TestRevision r1v1 = new TestRevision(1, 1, 1);
    cache.addRevision(r1v1);
    assertEquals(CDORevision.UNSPECIFIED_DATE, r1v1.getRevised());

    TestRevision r1v3 = new TestRevision(1, 3, 11);
    cache.addRevision(r1v3);
    assertEquals(CDORevision.UNSPECIFIED_DATE, r1v3.getRevised());
    assertNotSame(r1v3.getCreated() - 1, r1v1.getRevised());

    CDOID id = r1v1.getID();

    RevisionHolder h1v3 = cache.getHolder(id);
    assertEquals(r1v3, h1v3.getRevision());
  }

  private void validateList(LRURevisionList list, int size)
  {
    assertEquals(size, list.size());
    if (size == 0)
    {
      assertEquals(list.getDLHead(), list.getDLTail());
    }
    else
    {
      assertNotNull(list.getDLHead());
      assertNotNull(list.getDLTail());
    }

    assertEquals(list.getDLHead(), list.getDLHead().getDLNext().getDLPrev());
    assertEquals(list.getDLTail(), list.getDLTail().getDLPrev().getDLNext());

    DLRevisionHolder holder = list.getDLHead();
    for (int i = 0; i < size; i++)
    {
      assertEquals(holder, holder.getDLNext().getDLPrev());
      assertEquals(holder, holder.getDLPrev().getDLNext());
    }
  }

  private void validateList(LRURevisionList list, List<LRURevisionHolder> expected)
  {
    assertEquals(expected.size(), list.size());
    for (int i = 0; i < expected.size(); i++)
    {
      assertEquals(expected.get(i), list.get(i));
    }
  }

  /**
   * @author Eike Stepper
   */
  private static final class TestRevision implements InternalCDORevision
  {
    private CDOID id;

    private int version;

    private long created;

    private long revised;

    public TestRevision(long id, int version, long created, long revised)
    {
      this.id = CDOIDUtil.createLong(id);
      this.version = version;
      this.created = created;
      this.revised = revised;
    }

    public TestRevision(long id, int version, long created)
    {
      this(id, version, created, CDORevision.UNSPECIFIED_DATE);
    }

    public TestRevision(long id)
    {
      this(id, 0, CDORevision.UNSPECIFIED_DATE);
    }

    public CDOID getID()
    {
      return id;
    }

    public void setID(CDOID id)
    {
      this.id = id;
    }

    public int getVersion()
    {
      return version;
    }

    public void setVersion(int version)
    {
      this.version = version;
    }

    public long getCreated()
    {
      return created;
    }

    public void setCreated(long created)
    {
      this.created = created;
    }

    public long getRevised()
    {
      return revised;
    }

    public void setRevised(long revised)
    {
      this.revised = revised;
    }

    public boolean isCurrent()
    {
      return revised == UNSPECIFIED_DATE;
    }

    public boolean isTransactional()
    {
      return version < 0;
    }

    public boolean isValid(long timeStamp)
    {
      return (revised == UNSPECIFIED_DATE || revised >= timeStamp) && timeStamp >= created;
    }

    public EClass getEClass()
    {
      throw new UnsupportedOperationException();
    }

    public CDORevisionData data()
    {
      throw new UnsupportedOperationException();
    }

    public boolean isResourceNode()
    {
      throw new UnsupportedOperationException();
    }

    public boolean isResourceFolder()
    {
      throw new UnsupportedOperationException();
    }

    public boolean isResource()
    {
      throw new UnsupportedOperationException();
    }

    public CDORevisionDelta compare(CDORevision origin)
    {
      throw new UnsupportedOperationException();
    }

    public void merge(CDORevisionDelta delta)
    {
      throw new UnsupportedOperationException();
    }

    public CDORevision copy()
    {
      return new TestRevision(CDOIDUtil.getLong(id), version, created, revised);
    }

    public void write(CDODataOutput out, int referenceChunk) throws IOException
    {
      throw new UnsupportedOperationException();
    }

    public void add(EStructuralFeature feature, int index, Object value)
    {
      throw new UnsupportedOperationException();
    }

    public void adjustReferences(CDOReferenceAdjuster revisionAdjuster)
    {
      throw new UnsupportedOperationException();
    }

    public void clear(EStructuralFeature feature)
    {
      throw new UnsupportedOperationException();
    }

    public boolean contains(EStructuralFeature feature, Object value)
    {
      throw new UnsupportedOperationException();
    }

    public Object get(EStructuralFeature feature, int index)
    {
      throw new UnsupportedOperationException();
    }

    public Object getContainerID()
    {
      throw new UnsupportedOperationException();
    }

    public int getContainingFeatureID()
    {
      throw new UnsupportedOperationException();
    }

    public CDOList getList(EStructuralFeature feature, int size)
    {
      throw new UnsupportedOperationException();
    }

    public CDOList getList(EStructuralFeature feature)
    {
      throw new UnsupportedOperationException();
    }

    public CDOID getResourceID()
    {
      throw new UnsupportedOperationException();
    }

    public CDORevision revision()
    {
      throw new UnsupportedOperationException();
    }

    public Object getValue(EStructuralFeature feature)
    {
      throw new UnsupportedOperationException();
    }

    public int hashCode(EStructuralFeature feature)
    {
      throw new UnsupportedOperationException();
    }

    public int indexOf(EStructuralFeature feature, Object value)
    {
      throw new UnsupportedOperationException();
    }

    public boolean isEmpty(EStructuralFeature feature)
    {
      throw new UnsupportedOperationException();
    }

    public int lastIndexOf(EStructuralFeature feature, Object value)
    {
      throw new UnsupportedOperationException();
    }

    public Object move(EStructuralFeature feature, int targetIndex, int sourceIndex)
    {
      throw new UnsupportedOperationException();
    }

    public Object remove(EStructuralFeature feature, int index)
    {
      throw new UnsupportedOperationException();
    }

    public Object set(EStructuralFeature feature, int index, Object value)
    {
      throw new UnsupportedOperationException();
    }

    public void setContainerID(Object containerID)
    {
      throw new UnsupportedOperationException();
    }

    public void setContainingFeatureID(int containingFeatureID)
    {
      throw new UnsupportedOperationException();
    }

    public void setListSize(EStructuralFeature feature, int size)
    {
      throw new UnsupportedOperationException();
    }

    public void setResourceID(CDOID resourceID)
    {
      throw new UnsupportedOperationException();
    }

    public int setTransactional()
    {
      throw new UnsupportedOperationException();
    }

    public void setUntransactional()
    {
      throw new UnsupportedOperationException();
    }

    public Object setValue(EStructuralFeature feature, Object value)
    {
      throw new UnsupportedOperationException();
    }

    public int size(EStructuralFeature feature)
    {
      throw new UnsupportedOperationException();
    }

    public <T> T[] toArray(EStructuralFeature feature, T[] array)
    {
      throw new UnsupportedOperationException();
    }

    public Object[] toArray(EStructuralFeature feature)
    {
      throw new UnsupportedOperationException();
    }

    public void unset(EStructuralFeature feature)
    {
      throw new UnsupportedOperationException();
    }

    public void setList(EStructuralFeature feature, InternalCDOList list)
    {
      throw new UnsupportedOperationException();
    }

    public Object basicGet(EStructuralFeature feature, int index)
    {
      throw new UnsupportedOperationException();
    }

    public Object basicSet(EStructuralFeature feature, int index, Object value)
    {
      throw new UnsupportedOperationException();
    }
  }
}