1 files changed, 77 insertions, 0 deletions
diff --git a/plugins/org.eclipse.emf.cdo.tests/src/org/eclipse/emf/cdo/tests/FailoverTest.java b/plugins/org.eclipse.emf.cdo.tests/src/org/eclipse/emf/cdo/tests/FailoverTest.java
new file mode 100644
index 0000000000..617a915613
--- /dev/null
+++ b/plugins/org.eclipse.emf.cdo.tests/src/org/eclipse/emf/cdo/tests/FailoverTest.java
@@ -0,0 +1,77 @@
+/**
+ * Copyright (c) 2004 - 2010 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.eresource.CDOResource;
+import org.eclipse.emf.cdo.session.CDOSession;
+import org.eclipse.emf.cdo.tests.model1.Company;
+import org.eclipse.emf.cdo.transaction.CDOTransaction;
+
+/**
+ * @author Eike Stepper
+ */
+public class FailoverTest extends AbstractSyncingTest
+{
+  @Override
+  protected boolean isSqueezedCommitInfos()
+  {
+    return false;
+  }
+
+  @Override
+  protected boolean isFailover()
+  {
+    return true;
+  }
+
+  public void testMasterCommits_ArrivalInClone() throws Exception
+  {
+    CDOSession session = openSession(getRepository().getName() + "_master");
+    CDOTransaction transaction = session.openTransaction();
+    CDOResource resource = transaction.createResource("/my/resource");
+
+    Company company = getModel1Factory().createCompany();
+    company.setName("Test");
+
+    // 2 * Root resource + folder + resource + company
+    int expectedRevisions = 2 + 1 + 1 + 1;
+
+    resource.getContents().add(company);
+    long timeStamp = transaction.commit().getTimeStamp();
+    checkRevisions(getRepository(), timeStamp, expectedRevisions);
+
+    for (int i = 0; i < 10; i++)
+    {
+      company.setName("Test" + i);
+      timeStamp = transaction.commit().getTimeStamp();
+      expectedRevisions += 1; // Changed company
+      checkRevisions(getRepository(), timeStamp, expectedRevisions);
+    }
+
+    for (int i = 0; i < 10; i++)
+    {
+      company.getCategories().add(getModel1Factory().createCategory());
+      timeStamp = transaction.commit().getTimeStamp();
+      expectedRevisions += 2; // Changed company + new category
+      checkRevisions(getRepository(), timeStamp, expectedRevisions);
+    }
+
+    for (int i = 0; i < 10; i++)
+    {
+      company.getCategories().remove(0);
+      timeStamp = transaction.commit().getTimeStamp();
+      expectedRevisions += 2; // Changed company + detached category
+      checkRevisions(getRepository(), timeStamp, expectedRevisions);
+    }
+
+    session.close();
+  }
+}