1 files changed, 117 insertions, 0 deletions
diff --git a/plugins/org.eclipse.emf.cdo/src/org/eclipse/emf/internal/cdo/view/CDOAuditImpl.java b/plugins/org.eclipse.emf.cdo/src/org/eclipse/emf/internal/cdo/view/CDOAuditImpl.java
new file mode 100644
index 0000000000..38f7fbbb4a
--- /dev/null
+++ b/plugins/org.eclipse.emf.cdo/src/org/eclipse/emf/internal/cdo/view/CDOAuditImpl.java
@@ -0,0 +1,117 @@
+/***************************************************************************
+ * Copyright (c) 2004 - 2008 Eike Stepper, Germany.
+ * 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.internal.cdo.view;
+
+import org.eclipse.emf.cdo.common.id.CDOID;
+import org.eclipse.emf.cdo.common.revision.CDORevision;
+import org.eclipse.emf.cdo.common.revision.CDORevisionResolver;
+import org.eclipse.emf.cdo.spi.common.revision.InternalCDORevision;
+import org.eclipse.emf.cdo.view.CDOAudit;
+
+import org.eclipse.emf.internal.cdo.CDOStateMachine;
+import org.eclipse.emf.internal.cdo.protocol.CDOClientProtocol;
+import org.eclipse.emf.internal.cdo.protocol.SetAuditRequest;
+
+import org.eclipse.net4j.util.WrappedException;
+
+import org.eclipse.emf.spi.cdo.InternalCDOObject;
+import org.eclipse.emf.spi.cdo.InternalCDOSession;
+
+import java.text.MessageFormat;
+import java.util.List;
+
+/**
+ * @author Eike Stepper
+ */
+public class CDOAuditImpl extends CDOViewImpl implements CDOAudit
+{
+  private long timeStamp;
+
+  /**
+   * @since 2.0
+   */
+  public CDOAuditImpl(long timeStamp)
+  {
+    this.timeStamp = timeStamp;
+  }
+
+  @Override
+  public Type getViewType()
+  {
+    return Type.AUDIT;
+  }
+
+  @Override
+  public long getTimeStamp()
+  {
+    return timeStamp;
+  }
+
+  /**
+   * @since 2.0
+   */
+  public void setTimeStamp(long timeStamp)
+  {
+    checkActive();
+    if (this.timeStamp != timeStamp)
+    {
+      List<InternalCDOObject> invalidObjects = getInvalidObjects(timeStamp);
+      boolean[] existanceFlags = sendSetAuditRequest(timeStamp, invalidObjects);
+      this.timeStamp = timeStamp;
+
+      int i = 0;
+      for (InternalCDOObject invalidObject : invalidObjects)
+      {
+        boolean existanceFlag = existanceFlags[i++];
+        if (existanceFlag)
+        {
+          // --> PROXY
+          CDOStateMachine.INSTANCE.invalidate(invalidObject, CDORevision.UNSPECIFIED_VERSION);
+        }
+        else
+        {
+          // --> DETACHED
+          CDOStateMachine.INSTANCE.detachRemote(invalidObject);
+        }
+      }
+    }
+  }
+
+  private boolean[] sendSetAuditRequest(long timeStamp, List<InternalCDOObject> invalidObjects)
+  {
+    try
+    {
+      CDOClientProtocol protocol = (CDOClientProtocol)getSession().getProtocol();
+      return new SetAuditRequest(protocol, getViewID(), timeStamp, invalidObjects).send();
+    }
+    catch (Exception ex)
+    {
+      throw WrappedException.wrap(ex);
+    }
+  }
+
+  @Override
+  public InternalCDORevision getRevision(CDOID id, boolean loadOnDemand)
+  {
+    checkActive();
+    InternalCDOSession session = getSession();
+    int initialChunkSize = session.options().getCollectionLoadingPolicy().getInitialChunkSize();
+
+    CDORevisionResolver revisionManager = session.getRevisionManager();
+    return (InternalCDORevision)revisionManager.getRevisionByTime(id, initialChunkSize, timeStamp, loadOnDemand);
+  }
+
+  @Override
+  public String toString()
+  {
+    return MessageFormat.format("CDOAudit({0})", getViewID());
+  }
+}