Attachment #119456 for bug #250486

Some Eclipse Foundation services are deprecated, or will be soon. Please ensure you've read this important communication.

Lines 11-16 Link Here

(-)src/org/eclipse/emf/cdo/tests/TransactionHandlerTest.java (-1 / +6 lines)
11	**************************************************************************/	11	**************************************************************************/
12	package org.eclipse.emf.cdo.tests;	12	package org.eclipse.emf.cdo.tests;
13		13
		14	import org.eclipse.emf.cdo.CDOCommitContext;
14	import org.eclipse.emf.cdo.CDOObject;	15	import org.eclipse.emf.cdo.CDOObject;
15	import org.eclipse.emf.cdo.CDOSession;	16	import org.eclipse.emf.cdo.CDOSession;
16	import org.eclipse.emf.cdo.CDOTransaction;	17	import org.eclipse.emf.cdo.CDOTransaction;
Lines 377-383 Link Here
377	listOfAddingObject.add(object);	378	listOfAddingObject.add(object);
378	}	379	}
379		380
380	public void committingTransaction(CDOTransaction transaction)	381	public void committingTransaction(CDOTransaction transaction, CDOCommitContext commitContext)
381	{	382	{
382	numberOfCommit++;	383	numberOfCommit++;
383	}	384	}
Lines 396-400 Link Here
396	{	397	{
397	numberOfRollback++;	398	numberOfRollback++;
398	}	399	}
		400
		401	public void committedTransaction(CDOTransaction transaction, CDOCommitContext commitContext)
		402	{
		403	}
399	}	404	}
400	}	405	}

Lines 79-84 Link Here

(-)src/org/eclipse/emf/cdo/tests/AllTestsAllConfigs.java (+1 lines)
79	testClasses.add(RepositoryTest.class);	79	testClasses.add(RepositoryTest.class);
80	testClasses.add(LockingManagerTest.class);	80	testClasses.add(LockingManagerTest.class);
81	testClasses.add(MultiValuedOfAttributeTest.class);	81	testClasses.add(MultiValuedOfAttributeTest.class);
		82	testClasses.add(AdapterManagerTest.class);
82		83
83	// Specific for MEMStore	84	// Specific for MEMStore
84	testClasses.add(MEMStoreQueryTest.class);	85	testClasses.add(MEMStoreQueryTest.class);




 **************************************************************************/
package org.eclipse.emf.cdo.tests;

import org.eclipse.emf.cdo.CDOAdapterPolicy;
import org.eclipse.emf.cdo.CDODeltaNotification;
import org.eclipse.emf.cdo.CDOSession;
import org.eclipse.emf.cdo.CDOTransaction;

{
  public void testSameSession() throws Exception
  {
    testSameSession(CDOAdapterPolicy.ALL);
  }

  public void testSameSession_disable() throws Exception
  {
    testSameSession(CDOAdapterPolicy.NONE);
  }

  public void testSameSession(final CDOAdapterPolicy enabled) throws Exception
  {
    msg("Opening session");
    final CDOSession session = openModel1Session();

    msg("Opening transaction");
    final CDOTransaction transaction = session.openTransaction();

    transaction.setAdapterDeltaNotificationPolicy(enabled);

    msg("Creating resource");
    final CDOResource resourceA = transaction.createResource("/test1");

      @Override
      protected boolean successful()
      {
        return enabled == CDOAdapterPolicy.ALL && adapter.getNotifications().size() == 1
            || enabled == CDOAdapterPolicy.NONE && adapter.getNotifications().size() == 0;
      }
    }.timedOut();

    assertEquals(false, timedOut);

    // Switching policy to the other
    final CDOAdapterPolicy enabled2 = enabled == CDOAdapterPolicy.ALL ? CDOAdapterPolicy.NONE : CDOAdapterPolicy.ALL;
        : CDOChangeSubscriptionPolicy.ALL;

    transaction.setAdapterDeltaNotificationPolicy(enabled2);

    adapter.getNotifications().clear();


      @Override
      protected boolean successful()
      {
        return enabled2 == CDOAdapterPolicy.ALL && adapter.getNotifications().size() == 1
            || enabled2 == CDOAdapterPolicy.NONE && adapter.getNotifications().size() == 0;
      }
    }.timedOut();



  public void testSeparateSession() throws Exception
  {
    testSeparateSession(CDOAdapterPolicy.ALL);

  }

  public void testSeparateSession_disable() throws Exception
  {
    testSeparateSession(CDOAdapterPolicy.NONE);
  }

  public void testSeparateSession(final CDOAdapterPolicy enabled) throws Exception
  {
    msg("Opening session");
    final CDOSession session = openModel1Session();


    msg("Opening transaction");
    final CDOTransaction transaction = session.openTransaction();
    transaction.setAdapterDeltaNotificationPolicy(enabled);

    msg("Creating resource");
    final CDOResource resourceA = transaction.createResource("/test1");

      @Override
      protected boolean successful()
      {
        return enabled == CDOAdapterPolicy.ALL && adapter.getNotifications().size() == 1
            || enabled == CDOAdapterPolicy.NONE && adapter.getNotifications().size() == 0;
      }
    }.timedOut();

    assertEquals(false, timedOut);

    // Switching policy to the other
    final CDOAdapterPolicy enabled2 = enabled == CDOAdapterPolicy.ALL ? CDOAdapterPolicy.NONE : CDOAdapterPolicy.ALL;
        : CDOChangeSubscriptionPolicy.ALL;

    transaction.setAdapterDeltaNotificationPolicy(enabled2);

    adapter.getNotifications().clear();


      @Override
      protected boolean successful()
      {
        return enabled2 == CDOAdapterPolicy.ALL && adapter.getNotifications().size() == 1
            || enabled2 == CDOAdapterPolicy.NONE && adapter.getNotifications().size() == 0;
      }
    }.timedOut();



    msg("Opening transaction");
    final CDOTransaction transaction = session.openTransaction();
    transaction.setAdapterDeltaNotificationPolicy(CDOAdapterPolicy.ALL);
    msg("Creating resource");
    final CDOResource resourceA = transaction.createResource("/test1");


    session2.setPassiveUpdateEnabled(false);

    final CDOTransaction transaction2 = session2.openTransaction();
    transaction.setAdapterDeltaNotificationPolicy(CDOAdapterPolicy.ALL);

    final Category category1B = (Category)transaction2.getObject(CDOUtil.getCDOObject(category1A).cdoID(), true);


    msg("Opening transaction");
    final CDOTransaction transaction = session.openTransaction();

    transaction.setAdapterDeltaNotificationPolicy(customPolicy);

    msg("Creating resource");
    final CDOResource resourceA = transaction.createResource("/test1");

    assertEquals(false, timedOut);

    // Switching policy to the other
    transaction.setAdapterDeltaNotificationPolicy(CDOAdapterPolicy.ALL);

    adapter.getNotifications().clear();


    msg("Opening transaction");
    final CDOTransaction transaction = session.openTransaction();

    transaction.setAdapterDeltaNotificationPolicy(CDOAdapterPolicy.ALL);

    msg("Creating resource");
    final CDOResource resourceA = transaction.createResource("/test1");

  /**
   * @author Simon McDuff
   */
  private class CDOIDFilterChangeSubscriptionPolicy implements CDOAdapterPolicy
  {
    private Set<CDOID> cdoIDs = new HashSet<CDOID>();


    {
    }

    public boolean valid(EObject eObject, Adapter object)
    {
      return cdoIDs.contains(((InternalCDOObject)eObject).cdoID());
    }





package org.eclipse.emf.cdo.tests.bugzilla;

import org.eclipse.emf.cdo.CDOAdapterPolicy;
import org.eclipse.emf.cdo.CDOSession;
import org.eclipse.emf.cdo.CDOTransaction;
import org.eclipse.emf.cdo.common.id.CDOID;

    CDOTransaction transaction1 = session.openTransaction();

    transaction1.setInvalidationNotificationEnabled(true);
    transaction1.setAdapterDeltaNotificationPolicy(CDOAdapterPolicy.ALL);

    String resourcePath = "/test1";
    CDOResource res = transaction1.createResource(resourcePath);

    CDOTransaction transaction1 = sessionA.openTransaction();

    transaction1.setInvalidationNotificationEnabled(true);
    transaction1.setAdapterDeltaNotificationPolicy(CDOAdapterPolicy.ALL);

    String resourcePath = "/test1";
    CDOResource res = transaction1.createResource(resourcePath);

    CDOID companyID = CDOUtil.getCDOObject(obj2).cdoID();
    Company companyB = (Company)transB1.getObject(companyID);
    sessionB.setPassiveUpdateEnabled(false);
    transB1.setAdapterDeltaNotificationPolicy(CDOAdapterPolicy.ALL);
    final TestAdapter testAdapter = new TestAdapter();
    companyB.eAdapters().add(testAdapter);
    assertEquals(true, ((InternalCDOTransaction)transB1).hasSubscription(companyID));

Lines 11-17 Link Here

(-)src/org/eclipse/emf/cdo/tests/bugzilla/Bugzilla_254489_Test.java (-2 / +2 lines)
11		11
12	package org.eclipse.emf.cdo.tests.bugzilla;	12	package org.eclipse.emf.cdo.tests.bugzilla;
13		13
14	import org.eclipse.emf.cdo.CDOChangeSubscriptionPolicy;	14	import org.eclipse.emf.cdo.CDOAdapterPolicy;
15	import org.eclipse.emf.cdo.CDOSession;	15	import org.eclipse.emf.cdo.CDOSession;
16	import org.eclipse.emf.cdo.CDOTransaction;	16	import org.eclipse.emf.cdo.CDOTransaction;
17	import org.eclipse.emf.cdo.eresource.CDOResource;	17	import org.eclipse.emf.cdo.eresource.CDOResource;
Lines 55-61 Link Here
55		55
56	transaction1.commit();	56	transaction1.commit();
57		57
58	transaction2.setChangeSubscriptionPolicy(CDOChangeSubscriptionPolicy.ALL);	58	transaction2.setAdapterDeltaNotificationPolicy(CDOAdapterPolicy.ALL);
59	CDOResource res2 = transaction2.getResource("/res1");	59	CDOResource res2 = transaction2.getResource("/res1");
60	Company companyA2 = (Company)res2.getContents().get(0);	60	Company companyA2 = (Company)res2.getContents().get(0);
61	final TestAdapter companyA2Adapter = new TestAdapter();	61	final TestAdapter companyA2Adapter = new TestAdapter();




/***************************************************************************
 * 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:
 *    Simon McDuff - initial API and implementation
 **************************************************************************/
package org.eclipse.emf.cdo.tests;

import org.eclipse.emf.cdo.CDOAdapterPolicy;
import org.eclipse.emf.cdo.CDOSession;
import org.eclipse.emf.cdo.CDOTransaction;
import org.eclipse.emf.cdo.common.id.CDOID;
import org.eclipse.emf.cdo.tests.model1.Company;
import org.eclipse.emf.cdo.util.CDOUtil;

import org.eclipse.emf.common.notify.Adapter;
import org.eclipse.emf.common.notify.Notification;
import org.eclipse.emf.common.notify.Notifier;

import java.lang.ref.WeakReference;
import java.util.ArrayList;
import java.util.List;

/**
 * @author Simon McDuff
 */
public class AdapterManagerTest extends AbstractCDOTest
{
  public void testAdapterPolicy_NONE() throws Exception
  {
    msg("Opening session");
    final CDOSession session = openModel1Session();

    session.setPassiveUpdateEnabled(false);

    // ************************************************************* //

    msg("Creating company");
    Company companyA = getModel1Factory().createCompany();
    TestAdapter testAdapter = new TestAdapter();
    msg("Opening transaction");
    CDOTransaction transaction = session.openTransaction();

    transaction.createResource("/resA").getContents().add(companyA);

    msg("Committing");
    transaction.commit();

    CDOID id = CDOUtil.getCDOObject(companyA).cdoID();
    companyA.eAdapters().add(testAdapter);
    companyA = null;

    System.gc();

    assertEquals(false, transaction.isObjectRegistered(id));
    companyA = (Company)transaction.getObject(id);
    assertEquals(0, testAdapter.getNotifications().size());
    companyA.setCity("Ottawa");
    assertEquals(0, testAdapter.getNotifications().size());
  }

  public void testAdapterPolicy_ALL() throws Exception
  {
    msg("Opening session");
    final CDOSession session = openModel1Session();

    session.setPassiveUpdateEnabled(false);

    // ************************************************************* //

    msg("Creating company");
    Company companyA = getModel1Factory().createCompany();
    TestAdapter testAdapter = new TestAdapter();
    msg("Opening transaction");
    CDOTransaction transaction = session.openTransaction();

    transaction.setAdapterReferencePolicy(CDOAdapterPolicy.ALL);

    transaction.createResource("/resA").getContents().add(companyA);

    msg("Committing");
    transaction.commit();
    CDOID id = CDOUtil.getCDOObject(companyA).cdoID();
    companyA.eAdapters().add(testAdapter);
    companyA = null;

    testAdapter.getNotifications().clear();
    System.gc();

    assertEquals(true, transaction.isObjectRegistered(id));
    companyA = (Company)transaction.getObject(id);

    assertEquals(0, testAdapter.getNotifications().size());
    companyA.setCity("Ottawa");
    assertEquals(1, testAdapter.getNotifications().size());
  }

  public void testAdapterPolicy_AttachObject() throws Exception
  {
    msg("Opening session");
    final CDOSession session = openModel1Session();

    session.setPassiveUpdateEnabled(false);

    // ************************************************************* //

    msg("Creating company");
    Company companyA = getModel1Factory().createCompany();
    TestAdapter testAdapter = new TestAdapter();

    companyA.eAdapters().add(testAdapter);

    msg("Opening transaction");
    CDOTransaction transaction = session.openTransaction();

    transaction.setAdapterReferencePolicy(CDOAdapterPolicy.ALL);

    transaction.createResource("/resA").getContents().add(companyA);

    msg("Committing");
    transaction.commit();
    CDOID id = CDOUtil.getCDOObject(companyA).cdoID();

    companyA = null;

    testAdapter.getNotifications().clear();
    System.gc();

    assertEquals(true, transaction.isObjectRegistered(id));
    companyA = (Company)transaction.getObject(id);

    assertEquals(0, testAdapter.getNotifications().size());
    companyA.setCity("Ottawa");
    assertEquals(1, testAdapter.getNotifications().size());
  }

  public void testAdapterPolicy_DetachObject() throws Exception
  {
    msg("Opening session");
    final CDOSession session = openModel1Session();

    session.setPassiveUpdateEnabled(false);

    // ************************************************************* //

    msg("Creating company");
    Company companyA = getModel1Factory().createCompany();
    WeakReference<Company> weakCompanyA = new WeakReference<Company>(companyA);

    TestAdapter testAdapter = new TestAdapter();

    companyA.eAdapters().add(testAdapter);

    msg("Opening transaction");
    CDOTransaction transaction = session.openTransaction();

    transaction.setAdapterReferencePolicy(CDOAdapterPolicy.ALL);

    transaction.createResource("/resA").getContents().add(companyA);

    msg("Committing");
    transaction.commit();
    CDOID id = CDOUtil.getCDOObject(companyA).cdoID();
    companyA = null;

    testAdapter.getNotifications().clear();
    System.gc();

    assertEquals(true, transaction.isObjectRegistered(id));
    Company companyB = (Company)transaction.getObject(id);
    assertEquals(companyB, weakCompanyA.get());
    companyB.setCity("Ottawa");
    transaction.getResource("/resA").getContents().remove(0);
    transaction.commit();
    companyB = null;

    testAdapter.getNotifications().clear();
    System.gc();

    assertTrue(weakCompanyA.get() == null);
  }

  public void testAdapterPolicy_ChangePolicy() throws Exception
  {
    msg("Opening session");
    final CDOSession session = openModel1Session();

    session.setPassiveUpdateEnabled(false);

    // ************************************************************* //

    msg("Creating company");
    Company companyA = getModel1Factory().createCompany();

    TestAdapter testAdapter = new TestAdapter();
    companyA.eAdapters().add(testAdapter);

    msg("Opening transaction");
    CDOTransaction transaction = session.openTransaction();

    transaction.createResource("/resA").getContents().add(companyA);

    msg("Committing");
    transaction.commit();
    CDOID id = CDOUtil.getCDOObject(companyA).cdoID();
    transaction.setAdapterReferencePolicy(CDOAdapterPolicy.ALL);
    companyA = null;

    testAdapter.getNotifications().clear();
    System.gc();

    assertEquals(true, transaction.isObjectRegistered(id));
    transaction.setAdapterReferencePolicy(CDOAdapterPolicy.NONE);

    System.gc();

    assertEquals(false, transaction.isObjectRegistered(id));
  }

  /**
   * @author Simon McDuff
   */
  private static class TestAdapter implements Adapter
  {
    private List<Notification> notifications = new ArrayList<Notification>();

    public TestAdapter()
    {
    }

    public Notifier getTarget()
    {
      return null;
    }

    public List<Notification> getNotifications()
    {
      return notifications;
    }

    public boolean isAdapterForType(Object type)
    {
      return false;
    }

    public void notifyChanged(Notification notification)
    {
      notifications.add(notification);
    }

    public void setTarget(Notifier newTarget)
    {

    }
  }

}




  public void setInvalidationNotificationEnabled(boolean enabled);

  /**
   * Returns the current {@link CDOAdapterPolicy change subscription policy}.
   * 
   * @return The current change subscription policy, never <code>null</code>.
   * @see #setAdapterDeltaNotificationPolicy(CDOAdapterPolicy)
   * @since 2.0
   */
  public CDOAdapterPolicy getAdapterDeltaNotificationPolicy();

  /**
   * Specifies the change subscription policy. By default, the value is set to {@link CDOAdapterPolicy#NONE}.
   * <p>
   * To activate the policy, you must do the following: <br>
   * <code>transaction.setChangeSubscriptionPolicy(CDOChangeSubscriptionPolicy.ALL);</code>

   * By activating this feature, each object having at least one adapter that matches the current policy will be
   * registered with the server and will be notified for each change occurring in the scope of any other transaction.
   * <p>
   * {@link CDOAdapterPolicy#NONE} - Disabled. <br>
   * {@link CDOAdapterPolicy#ALL} - Enabled for all adapters used.<br>
   * {@link CDOAdapterPolicy#ONLY_CDO_ADAPTER} - Enabled only for adapters that implement {@link CDOAdapter}. <br>
   * Any other class that implement {@link CDOAdapterPolicy} will enable for whatever rules defined in that class. <br>
   * Any other class that implement {@link CDOChangeSubscriptionPolicy} will enable for whatever rules defined in that
   * class. <br>
   * <p>
   * If <code>myAdapter</code> in the above example matches the current policy, <code>eObject</code> will be registered
   * with the server and you will receive all changes from other transaction.

   * 
   * @since 2.0
   */
  public void setAdapterDeltaNotificationPolicy(CDOAdapterPolicy policy);

  /**
   * @since 2.0
   */
  public void setAdapterReferencePolicy(CDOAdapterPolicy policy);

  /**
   * @since 2.0
   */
  public CDOAdapterPolicy getAdapterReferencePolicy();

  /**
   * @since 2.0




   * Called by a <code>CDOTransaction</code> <b>before</b> it is being committed. The implementor of this method is
   * allowed to throw an unchecked exception that will propagate up to the operation that is about to commit the
   * transaction.
   * 
   * @since 2.0
   */
  public void committingTransaction(CDOTransaction transaction, CDOCommitContext commitContext);

  /**
   * Called by a <code>CDOTransaction</code> <b>after</b> it is being committed. The implementor of this method is not
   * allowed to throw an unchecked exception that will propagate up to the operation that is about to commit the
   * transaction.
   * 
   * @since 2.0
   */
  public void committedTransaction(CDOTransaction transaction, CDOCommitContext commitContext);

  /**
   * Called by a <code>CDOTransaction</code> <b>after</b> it is rolled back. If the implementor of this method throws an

Lines 25-31 Link Here

(-)src/org/eclipse/emf/cdo/CDOInvalidationNotification.java (-1 / +1 lines)
25	*	25	*
26	* @author Simon McDuff	26	* @author Simon McDuff
27	* @see CDOSessionInvalidationEvent	27	* @see CDOSessionInvalidationEvent
28	* @see CDOChangeSubscriptionPolicy	28	* @see CDOAdapterPolicy
29	* @noimplement This interface is not intended to be implemented by clients.	29	* @noimplement This interface is not intended to be implemented by clients.
30	*/	30	*/
31	public interface CDOInvalidationNotification extends CDONotification	31	public interface CDOInvalidationNotification extends CDONotification

Lines 26-32 Link Here

(-)src/org/eclipse/emf/cdo/CDOSessionInvalidationEvent.java (-1 / +1 lines)
26	*	26	*
27	* @author Eike Stepper	27	* @author Eike Stepper
28	* @see CDOInvalidationNotification	28	* @see CDOInvalidationNotification
29	* @see CDOChangeSubscriptionPolicy	29	* @see CDOAdapterPolicy
30	* @noimplement This interface is not intended to be implemented by clients.	30	* @noimplement This interface is not intended to be implemented by clients.
31	*/	31	*/
32	public interface CDOSessionInvalidationEvent extends CDOSessionEvent	32	public interface CDOSessionInvalidationEvent extends CDOSessionEvent

Lines 20-26 Link Here

(-)src/org/eclipse/emf/cdo/CDOViewInvalidationEvent.java (-1 / +1 lines)
20	*	20	*
21	* @author Simon McDuff	21	* @author Simon McDuff
22	* @see CDOInvalidationNotification	22	* @see CDOInvalidationNotification
23	* @see CDOChangeSubscriptionPolicy	23	* @see CDOAdapterPolicy
24	* @noimplement This interface is not intended to be implemented by clients.	24	* @noimplement This interface is not intended to be implemented by clients.
25	* @since 2.0	25	* @since 2.0
26	*/	26	*/




/***************************************************************************
 * 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:
 *    Simon McDuff - initial API and implementation
 *    Eike Stepper - maintenance
 **************************************************************************/
package org.eclipse.emf.cdo;

import org.eclipse.emf.common.notify.Adapter;
import org.eclipse.emf.ecore.EObject;

/**
 * Specifies a change subscription policy.
 * <p>
 * To activate a policy, you must do the following: <br>
 * <code>view.setChangeSubscriptionPolicy(CDOChangeSubscriptionPolicy.ALL);</code>
 * <p>
 * To register an object, you must add an adapter to the object in which you are interested:<br>
 * <code>eObject.eAdapters().add(myAdapter);</code>
 * <p>
 * By activating this feature, each object having at least one adapter that matches the current policy will be
 * registered with the server and will be notified for each change occurring in the scope of any other transaction.
 * <p>
 * {@link CDOChangeSubscriptionPolicy#NONE} - Disabled. <br>
 * {@link CDOChangeSubscriptionPolicy#ALL} - Enabled for all adapters used.<br>
 * {@link CDOChangeSubscriptionPolicy#ONLY_CDO_ADAPTER} - Enabled only for adapters that implement {@link CDOAdapter}. <br>
 * Any other class that implement {@link CDOChangeSubscriptionPolicy} will enable for whatever rules defined in that
 * class. <br>
 * <p>
 * If <code>myAdapter</code> in the above example matches the current policy, <code>eObject</code> will be registered
 * with the server and you will receive all changes from other transaction.
 * <p>
 * When the policy is changed all objects in the cache will automatically be recalculated.
 * <p>
 * You can subscribe to temporary objects. Even if you cannot receive notifications from other {@link CDOTransaction}
 * for these because they are only local to you, at commit time these objects will be registered automatically.
 * <p>
 * <b>Note:</b> It can be used with <code>CDOSession.setPassiveUpdate(false)</code>. In this case, it will receive
 * changes without having the objects changed.
 * 
 * @author Simon McDuff
 * @see CDOSessionInvalidationEvent
 * @see CDOInvalidationNotification
 * @since 2.0
 */
public interface CDOChangeSubscriptionPolicy
{
  public static final CDOChangeSubscriptionPolicy NONE = new CDOChangeSubscriptionPolicy()
  {
    public boolean shouldSubscribe(EObject eObject, Adapter adapter)
    {
      return false;
    }
  };

  public static final CDOChangeSubscriptionPolicy ONLY_CDO_ADAPTER = new CDOChangeSubscriptionPolicy()
  {
    public boolean shouldSubscribe(EObject eObject, Adapter adapter)
    {
      return adapter instanceof CDOAdapter;
    }
  };

  public static final CDOChangeSubscriptionPolicy ALL = new CDOChangeSubscriptionPolicy()
  {
    public boolean shouldSubscribe(EObject eObject, Adapter adapter)
    {
      return true;
    }
  };

  public boolean shouldSubscribe(EObject eObject, Adapter adapter);
}

Lines 12-18 Link Here

(-)src/org/eclipse/emf/internal/cdo/CDOViewImpl.java (-11 / +152 lines)
12	**************************************************************************/	12	**************************************************************************/
13	package org.eclipse.emf.internal.cdo;	13	package org.eclipse.emf.internal.cdo;
14		14
15	import org.eclipse.emf.cdo.CDOChangeSubscriptionPolicy;	15	import org.eclipse.emf.cdo.CDOAdapterPolicy;
16	import org.eclipse.emf.cdo.CDOFeatureAnalyzer;	16	import org.eclipse.emf.cdo.CDOFeatureAnalyzer;
17	import org.eclipse.emf.cdo.CDONotification;	17	import org.eclipse.emf.cdo.CDONotification;
18	import org.eclipse.emf.cdo.CDOObject;	18	import org.eclipse.emf.cdo.CDOObject;
Lines 64-69 Link Here
64	import org.eclipse.net4j.util.WrappedException;	64	import org.eclipse.net4j.util.WrappedException;
65	import org.eclipse.net4j.util.ReflectUtil.ExcludeFromDump;	65	import org.eclipse.net4j.util.ReflectUtil.ExcludeFromDump;
66	import org.eclipse.net4j.util.collection.CloseableIterator;	66	import org.eclipse.net4j.util.collection.CloseableIterator;
		67	import org.eclipse.net4j.util.collection.HashBag;
67	import org.eclipse.net4j.util.concurrent.RWLockManager;	68	import org.eclipse.net4j.util.concurrent.RWLockManager;
68	import org.eclipse.net4j.util.om.trace.ContextTracer;	69	import org.eclipse.net4j.util.om.trace.ContextTracer;
69	import org.eclipse.net4j.util.ref.ReferenceValueMap;	70	import org.eclipse.net4j.util.ref.ReferenceValueMap;
Lines 133-142 Link Here
133	*/	134	*/
134	private ChangeSubscriptionManager changeSubscriptionManager = new ChangeSubscriptionManager();	135	private ChangeSubscriptionManager changeSubscriptionManager = new ChangeSubscriptionManager();
135		136
		137	private ViewAdapterManager adapterPolicyManager = null;
		138
136	/**	139	/**
137	* @since 2.0	140	* @since 2.0
138	*/	141	*/
139	private CDOChangeSubscriptionPolicy changeSubscriptionPolicy = CDOChangeSubscriptionPolicy.NONE;	142	private CDOAdapterPolicy changeSubscriptionPolicy = CDOAdapterPolicy.NONE;
		143
		144	private CDOAdapterPolicy adapterReferencePolicy = CDOAdapterPolicy.NONE;
140		145
141	/**	146	/**
142	* @since 2.0	147	* @since 2.0
Lines 148-153 Link Here
148	invalidationNotificationEnabled = OM.PREF_ENABLE_INVALIDATION_NOTIFICATION.getValue();	153	invalidationNotificationEnabled = OM.PREF_ENABLE_INVALIDATION_NOTIFICATION.getValue();
149	revisionPrefetchingPolicy = CDOUtil.createRevisionPrefetchingPolicy(OM.PREF_REVISION_LOADING_CHUNK_SIZE.getValue());	154	revisionPrefetchingPolicy = CDOUtil.createRevisionPrefetchingPolicy(OM.PREF_REVISION_LOADING_CHUNK_SIZE.getValue());
150	objects = createObjectsMap();	155	objects = createObjectsMap();
		156	adapterPolicyManager = createAdapterManager();
151	}	157	}
152		158
153	public int getViewID()	159	public int getViewID()
Lines 337-343 Link Here
337	/**	343	/**
338	* @since 2.0	344	* @since 2.0
339	*/	345	*/
340	public CDOChangeSubscriptionPolicy getChangeSubscriptionPolicy()	346	public CDOAdapterPolicy getAdapterDeltaNotificationPolicy()
341	{	347	{
342	return changeSubscriptionPolicy;	348	return changeSubscriptionPolicy;
343	}	349	}
Lines 345-355 Link Here
345	/**	351	/**
346	* @since 2.0	352	* @since 2.0
347	*/	353	*/
348	public void setChangeSubscriptionPolicy(CDOChangeSubscriptionPolicy subscriptionPolicy)	354	public void setAdapterDeltaNotificationPolicy(CDOAdapterPolicy subscriptionPolicy)
349	{	355	{
350	if (subscriptionPolicy == null)	356	if (subscriptionPolicy == null)
351	{	357	{
352	subscriptionPolicy = CDOChangeSubscriptionPolicy.NONE;	358	subscriptionPolicy = CDOAdapterPolicy.NONE;
353	}	359	}
354		360
355	if (changeSubscriptionPolicy != subscriptionPolicy)	361	if (changeSubscriptionPolicy != subscriptionPolicy)
Lines 362-367 Link Here
362	/**	368	/**
363	* @since 2.0	369	* @since 2.0
364	*/	370	*/
		371	public CDOAdapterPolicy getAdapterReferencePolicy()
		372	{
		373	return adapterReferencePolicy;
		374	}
		375
		376	/**
		377	* @since 2.0
		378	*/
		379	public void setAdapterReferencePolicy(CDOAdapterPolicy adapterPolicy)
		380	{
		381	if (adapterPolicy == null)
		382	{
		383	adapterPolicy = CDOAdapterPolicy.NONE;
		384	}
		385
		386	if (this.adapterReferencePolicy != adapterPolicy)
		387	{
		388	this.adapterReferencePolicy = adapterPolicy;
		389	adapterPolicyManager.reset();
		390	}
		391	}
		392
		393	/**
		394	* @since 2.0
		395	*/
365	public CDORevisionPrefetchingPolicy getRevisionPrefetchingPolicy()	396	public CDORevisionPrefetchingPolicy getRevisionPrefetchingPolicy()
366	{	397	{
367	return revisionPrefetchingPolicy;	398	return revisionPrefetchingPolicy;
Lines 1211-1217 Link Here
1211	*/	1242	*/
1212	public void handleChangeSubscription(Collection<CDORevisionDelta> deltas, Collection<CDOID> detachedObjects)	1243	public void handleChangeSubscription(Collection<CDORevisionDelta> deltas, Collection<CDOID> detachedObjects)
1213	{	1244	{
1214	if (getChangeSubscriptionPolicy() != CDOChangeSubscriptionPolicy.NONE)	1245	if (getAdapterDeltaNotificationPolicy() != CDOAdapterPolicy.NONE)
1215	{	1246	{
1216	if (deltas != null)	1247	if (deltas != null)
1217	{	1248	{
Lines 1251-1256 Link Here
1251	/**	1282	/**
1252	* @since 2.0	1283	* @since 2.0
1253	*/	1284	*/
		1285	public void handleAddAdapter(InternalCDOObject eObject, Adapter adapter)
		1286	{
		1287	if (!FSMUtil.isNew(eObject))
		1288	{
		1289	subscribe(eObject, adapter);
		1290	}
		1291
		1292	adapterPolicyManager.attachAdapter(eObject, adapter);
		1293	}
		1294
		1295	/**
		1296	* @since 2.0
		1297	*/
		1298	public void handleRemoveAdapter(InternalCDOObject eObject, Adapter adapter)
		1299	{
		1300	if (!FSMUtil.isNew(eObject))
		1301	{
		1302	unsubscribe(eObject, adapter);
		1303	}
		1304
		1305	adapterPolicyManager.detachAdapter(eObject, adapter);
		1306	}
		1307
		1308	/**
		1309	* @since 2.0
		1310	*/
1254	public void subscribe(EObject eObject, Adapter adapter)	1311	public void subscribe(EObject eObject, Adapter adapter)
1255	{	1312	{
1256	changeSubscriptionManager.subscribe(eObject, adapter);	1313	changeSubscriptionManager.subscribe(eObject, adapter);
Lines 1280-1291 Link Here
1280	return changeSubscriptionManager;	1337	return changeSubscriptionManager;
1281	}	1338	}
1282		1339
		1340	/**
		1341	* @since 2.0
		1342	*/
		1343	protected ViewAdapterManager getAdapterManager()
		1344	{
		1345	return adapterPolicyManager;
		1346	}
		1347
1283	protected ConcurrentMap<CDOID, InternalCDOObject> createObjectsMap()	1348	protected ConcurrentMap<CDOID, InternalCDOObject> createObjectsMap()
1284	{	1349	{
1285	return new ReferenceValueMap.Weak<CDOID, InternalCDOObject>();	1350	return new ReferenceValueMap.Weak<CDOID, InternalCDOObject>();
1286	}	1351	}
1287		1352
1288	/**	1353	/**
		1354	* @since 2.0
		1355	*/
		1356	protected ViewAdapterManager createAdapterManager()
		1357	{
		1358	return new ViewAdapterManager();
		1359	}
		1360
		1361	/**
1289	* Needed for {@link CDOAuditImpl#setTimeStamp(long)}.	1362	* Needed for {@link CDOAuditImpl#setTimeStamp(long)}.
1290	*	1363	*
1291	* @since 2.0	1364	* @since 2.0
Lines 1426-1431 Link Here
1426	* @author Simon McDuff	1499	* @author Simon McDuff
1427	* @since 2.0	1500	* @since 2.0
1428	*/	1501	*/
		1502	protected class ViewAdapterManager
		1503	{
		1504	protected Set<CDOObject> objects = new HashBag<CDOObject>();
		1505
		1506	synchronized protected void attachObject(CDOObject object)
		1507	{
		1508	int count = 0;
		1509	for (Adapter adapter : object.eAdapters())
		1510	{
		1511	if (adapterReferencePolicy.valid(object, adapter))
		1512	{
		1513	count++;
		1514	}
		1515	}
		1516
		1517	for (int i = 0; i < count; i++)
		1518	{
		1519	objects.add(object);
		1520	}
		1521
		1522	}
		1523
		1524	synchronized protected void detachObject(CDOObject object)
		1525	{
		1526	while (objects.remove(object))
		1527	{
		1528	;
		1529	}
		1530	}
		1531
		1532	synchronized protected void attachAdapter(CDOObject object, Adapter adapter)
		1533	{
		1534	if (getAdapterReferencePolicy().valid(object, adapter))
		1535	{
		1536	objects.add(object);
		1537	}
		1538	}
		1539
		1540	synchronized protected void detachAdapter(CDOObject object, Adapter adapter)
		1541	{
		1542	if (getAdapterReferencePolicy().valid(object, adapter))
		1543	{
		1544	objects.add(object);
		1545	}
		1546	}
		1547
		1548	synchronized public void reset()
		1549	{
		1550	// Keep the object in memory
		1551	Set<CDOObject> oldObject = objects;
		1552	objects = new HashBag<CDOObject>();
		1553	if (getAdapterReferencePolicy() != CDOAdapterPolicy.NONE)
		1554	{
		1555	InternalCDOObject objects[] = getObjectsArray();
		1556	for (int i = 0; i < objects.length; i++)
		1557	{
		1558	InternalCDOObject object = objects[i];
		1559	attachObject(object);
		1560	}
		1561	}
		1562	oldObject.clear();
		1563	}
		1564	};
		1565
1566	/**
1567	* @author Simon McDuff
1568	* @since 2.0
1569	*/
1429	protected class ChangeSubscriptionManager	1570	protected class ChangeSubscriptionManager
1430	{	1571	{
1431	private Map<CDOID, SubscribeEntry> subscriptions = new HashMap<CDOID, SubscribeEntry>()	1572	private Map<CDOID, SubscribeEntry> subscriptions = new HashMap<CDOID, SubscribeEntry>()
Lines 1452-1458 Link Here
1452	{	1593	{
1453	subscriptions.clear();	1594	subscriptions.clear();
1454	List<CDOID> cdoIDs = new ArrayList<CDOID>();	1595	List<CDOID> cdoIDs = new ArrayList<CDOID>();
1455	if (changeSubscriptionPolicy != CDOChangeSubscriptionPolicy.NONE)	1596	if (changeSubscriptionPolicy != CDOAdapterPolicy.NONE)
1456	{	1597	{
1457	for (InternalCDOObject cdoObject : getObjectsArray())	1598	for (InternalCDOObject cdoObject : getObjectsArray())
1458	{	1599	{
Lines 1539-1545 Link Here
1539	{	1680	{
1540	for (Adapter adapter : object.eAdapters())	1681	for (Adapter adapter : object.eAdapters())
1541	{	1682	{
1542	if (changeSubscriptionPolicy.shouldSubscribe(object, adapter))	1683	if (changeSubscriptionPolicy.valid(object, adapter))
1543	{	1684	{
1544	count++;	1685	count++;
1545	}	1686	}
Lines 1554-1560 Link Here
1554	{	1695	{
1555	synchronized (subscriptions)	1696	synchronized (subscriptions)
1556	{	1697	{
1557	if (getChangeSubscriptionPolicy().shouldSubscribe(eObject, adapter))	1698	if (getAdapterDeltaNotificationPolicy().valid(eObject, adapter))
1558	{	1699	{
1559	InternalCDOObject internalCDOObject = FSMUtil.adapt(eObject, CDOViewImpl.this);	1700	InternalCDOObject internalCDOObject = FSMUtil.adapt(eObject, CDOViewImpl.this);
1560	if (internalCDOObject.cdoView() != CDOViewImpl.this)	1701	if (internalCDOObject.cdoView() != CDOViewImpl.this)
Lines 1582-1588 Link Here
1582	}	1723	}
1583		1724
1584	// Notification need to be enable to send correct value to the server	1725	// Notification need to be enable to send correct value to the server
1585	if (getChangeSubscriptionPolicy() != CDOChangeSubscriptionPolicy.NONE)	1726	if (getAdapterDeltaNotificationPolicy() != CDOAdapterPolicy.NONE)
1586	{	1727	{
1587	request(Collections.singletonList(id), false, true);	1728	request(Collections.singletonList(id), false, true);
1588	}	1729	}
Lines 1600-1606 Link Here
1600	subscriptions.remove(id);	1741	subscriptions.remove(id);
1601		1742
1602	// Notification need to be enable to send correct value to the server	1743	// Notification need to be enable to send correct value to the server
1603	if (getChangeSubscriptionPolicy() != CDOChangeSubscriptionPolicy.NONE)	1744	if (getAdapterDeltaNotificationPolicy() != CDOAdapterPolicy.NONE)
1604	{	1745	{
1605	request(Collections.singletonList(id), false, false);	1746	request(Collections.singletonList(id), false, false);
1606	}	1747	}




 * @author Simon McDuff
 * @since 2.0
 */
public class CDOXATransactionCommitContext implements Callable<Object>, CDOIDProvider, InternalCDOCommitContext
{
  private CDOXATransactionImpl transactionManager;



  private CommitTransactionResult result;

  private InternalCDOCommitContext delegateCommitContext;

  private Map<CDOIDExternalTempImpl, InternalCDOTransaction> requestedIDs = new HashMap<CDOIDExternalTempImpl, InternalCDOTransaction>();

  private Map<InternalCDOObject, CDOIDExternalTempImpl> objectToID = new HashMap<InternalCDOObject, CDOIDExternalTempImpl>();

  public CDOXATransactionCommitContext(CDOXATransactionImpl manager, InternalCDOCommitContext commitContext)
  {
    transactionManager = manager;
    delegateCommitContext = commitContext;




/***************************************************************************
 * 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:
 *    Simon McDuff - initial API and implementation
 *    Eike Stepper - maintenance
 **************************************************************************/
package org.eclipse.emf.internal.cdo;

import org.eclipse.emf.cdo.CDOObject;
import org.eclipse.emf.cdo.common.id.CDOID;
import org.eclipse.emf.cdo.common.model.CDOPackage;
import org.eclipse.emf.cdo.common.revision.delta.CDORevisionDelta;
import org.eclipse.emf.cdo.eresource.CDOResource;

import org.eclipse.emf.internal.cdo.protocol.CommitTransactionResult;

import java.util.List;
import java.util.Map;

/**
 * Provides a context for a commit operation.
 * 
 * @author Simon McDuff
 * @since 2.0
 */
public interface CDOCommitContext
{
  public InternalCDOTransaction getTransaction();

  public void preCommit();

  public void postCommit(CommitTransactionResult result);

  public List<CDOPackage> getNewPackages();

  public Map<CDOID, CDOResource> getNewResources();

  public Map<CDOID, CDOObject> getNewObjects();

  public Map<CDOID, CDOObject> getDirtyObjects();

  public Map<CDOID, CDORevisionDelta> getRevisionDeltas();

  public Map<CDOID, CDOObject> getDetachedObjects();
}

Lines 25-31 Link Here

(-)src/org/eclipse/emf/internal/cdo/InternalCDOTransaction.java (-1 / +1 lines)
25	*/	25	*/
26	public interface InternalCDOTransaction extends CDOTransaction, InternalCDOView	26	public interface InternalCDOTransaction extends CDOTransaction, InternalCDOView
27	{	27	{
28	public CDOCommitContext createCommitContext();	28	public InternalCDOCommitContext createCommitContext();
29		29
30	public void handleRollback(CDOSavepoint savepoint);	30	public void handleRollback(CDOSavepoint savepoint);
31		31

Lines 257-263 Link Here

(-)src/org/eclipse/emf/internal/cdo/CDOXATransactionImpl.java (-1 / +1 lines)
257		257
258	for (InternalCDOTransaction transaction : transactions)	258	for (InternalCDOTransaction transaction : transactions)
259	{	259	{
260	CDOCommitContext context = transaction.createCommitContext();	260	InternalCDOCommitContext context = transaction.createCommitContext();
261	CDOXATransactionCommitContext xaContext = new CDOXATransactionCommitContext(this, context);	261	CDOXATransactionCommitContext xaContext = new CDOXATransactionCommitContext(this, context);
262	xaContext.setState(CDOXAPhase1State.INSTANCE);	262	xaContext.setState(CDOXAPhase1State.INSTANCE);
263	activeContext.put(transaction, xaContext);	263	activeContext.put(transaction, xaContext);

Lines 78-83 Link Here

(-)src/org/eclipse/emf/internal/cdo/InternalCDOView.java (+4 lines)
78		78
79	public boolean isLocked(CDOObject object, RWLockManager.LockType lockType);	79	public boolean isLocked(CDOObject object, RWLockManager.LockType lockType);
80		80
		81	public void handleAddAdapter(InternalCDOObject eObject, Adapter adapter);
		82
		83	public void handleRemoveAdapter(InternalCDOObject eObject, Adapter adapter);
		84
81	public void subscribe(EObject eObject, Adapter adapter);	85	public void subscribe(EObject eObject, Adapter adapter);
82		86
83	public void unsubscribe(EObject eObject, Adapter adapter);	87	public void unsubscribe(EObject eObject, Adapter adapter);

Lines 39-45 Link Here

(-)src/org/eclipse/emf/internal/cdo/CDOSingleTransactionStrategy.java (-1 / +1 lines)
39		39
40	public void commit(InternalCDOTransaction transaction, IProgressMonitor progressMonitor) throws Exception	40	public void commit(InternalCDOTransaction transaction, IProgressMonitor progressMonitor) throws Exception
41	{	41	{
42	CDOCommitContext commitContext = transaction.createCommitContext();	42	InternalCDOCommitContext commitContext = transaction.createCommitContext();
43	if (TRACER.isEnabled())	43	if (TRACER.isEnabled())
44	{	44	{
45	TRACER.format("CDOCommitContext.preCommit");	45	TRACER.format("CDOCommitContext.preCommit");

Lines 11-19 Link Here

(-)src/org/eclipse/emf/internal/cdo/CDOTransactionImpl.java (-3 / +70 lines)
11	**************************************************************************/	11	**************************************************************************/
12	package org.eclipse.emf.internal.cdo;	12	package org.eclipse.emf.internal.cdo;
13		13
		14	import org.eclipse.emf.cdo.CDOAdapterPolicy;
		15	import org.eclipse.emf.cdo.CDOCommitContext;
14	import org.eclipse.emf.cdo.CDOObject;	16	import org.eclipse.emf.cdo.CDOObject;
15	import org.eclipse.emf.cdo.CDOSavepoint;	17	import org.eclipse.emf.cdo.CDOSavepoint;
16	import org.eclipse.emf.cdo.CDOState;	18	import org.eclipse.emf.cdo.CDOState;
		19	import org.eclipse.emf.cdo.CDOTransaction;
17	import org.eclipse.emf.cdo.CDOTransactionConflictEvent;	20	import org.eclipse.emf.cdo.CDOTransactionConflictEvent;
18	import org.eclipse.emf.cdo.CDOTransactionFinishedEvent;	21	import org.eclipse.emf.cdo.CDOTransactionFinishedEvent;
19	import org.eclipse.emf.cdo.CDOTransactionHandler;	22	import org.eclipse.emf.cdo.CDOTransactionHandler;
Lines 457-463 Link Here
457	/**	460	/**
458	* @since 2.0	461	* @since 2.0
459	*/	462	*/
460	public CDOCommitContext createCommitContext()	463	public InternalCDOCommitContext createCommitContext()
461	{	464	{
462	return new CDOCommitContextImpl();	465	return new CDOCommitContextImpl();
463	}	466	}
Lines 1047-1055 Link Here
1047	}	1050	}
1048		1051
1049	/**	1052	/**
		1053	* @since 2.0
		1054	*/
		1055	@Override
		1056	protected ViewAdapterManager createAdapterManager()
		1057	{
		1058	return new TransactionAdapterManager();
		1059	}
		1060
		1061	/**
1050	* @author Simon McDuff	1062	* @author Simon McDuff
1051	*/	1063	*/
1052	private class CDOCommitContextImpl implements CDOCommitContext	1064	private class CDOCommitContextImpl implements InternalCDOCommitContext
1053	{	1065	{
1054	private Map<CDOID, CDOResource> newResources;	1066	private Map<CDOID, CDOResource> newResources;
1055		1067
Lines 1120-1126 Link Here
1120		1132
1121	for (CDOTransactionHandler handler : getHandlers())	1133	for (CDOTransactionHandler handler : getHandlers())
1122	{	1134	{
1123	handler.committingTransaction(getTransaction());	1135	handler.committingTransaction(getTransaction(), this);
1124	}	1136	}
1125		1137
1126	try	1138	try
Lines 1192-1197 Link Here
1192	session.handleCommitNotification(timeStamp, dirtyIDs, detachedIDs, deltasCopy, getTransaction());	1204	session.handleCommitNotification(timeStamp, dirtyIDs, detachedIDs, deltasCopy, getTransaction());
1193	}	1205	}
1194		1206
		1207	for (CDOTransactionHandler handler : getHandlers())
		1208	{
		1209	handler.committedTransaction(getTransaction(), this);
		1210	}
		1211	((TransactionAdapterManager)getAdapterManager()).committedTransaction(getTransaction(), this);
		1212
1195	cleanUp();	1213	cleanUp();
1196	lastCommitTime = timeStamp;	1214	lastCommitTime = timeStamp;
1197	Map<CDOIDTemp, CDOID> idMappings = result.getIDMappings();	1215	Map<CDOIDTemp, CDOID> idMappings = result.getIDMappings();
Lines 1329-1334 Link Here
1329	}	1347	}
1330	}	1348	}
1331		1349
		1350	private final class TransactionAdapterManager extends ViewAdapterManager implements CDOTransactionHandler
		1351	{
		1352	public TransactionAdapterManager()
		1353	{
		1354	// Should we register to the handler ?? Since we always need to call it.
		1355	// addHandler(this);
		1356	}
		1357
		1358	public void attachingObject(CDOTransaction transaction, CDOObject object)
		1359	{
		1360
		1361	}
		1362
		1363	public void committedTransaction(CDOTransaction transaction, CDOCommitContext commitContext)
		1364	{
		1365	if (getAdapterReferencePolicy() != CDOAdapterPolicy.NONE)
		1366	{
		1367	for (CDOObject object : commitContext.getNewObjects().values())
		1368	{
		1369	attachObject(object);
		1370	}
		1371	for (CDOObject object : commitContext.getNewResources().values())
		1372	{
		1373	attachObject(object);
		1374	}
		1375	for (CDOObject object : commitContext.getDetachedObjects().values())
		1376	{
		1377	detachObject(object);
		1378	}
		1379	}
		1380	}
		1381
		1382	public void committingTransaction(CDOTransaction transaction, CDOCommitContext commitContext)
		1383	{
		1384	}
		1385
		1386	public void detachingObject(CDOTransaction transaction, CDOObject object)
		1387	{
		1388	}
		1389
		1390	public void modifyingObject(CDOTransaction transaction, CDOObject object, CDOFeatureDelta featureDelta)
		1391	{
		1392	}
		1393
		1394	public void rolledBackTransaction(CDOTransaction transaction)
		1395	{
		1396	}
		1397	}
		1398
1332	/**	1399	/**
1333	* @author Eike Stepper	1400	* @author Eike Stepper
1334	*/	1401	*/




        protected void didAdd(int index, Adapter newObject)
        {
          super.didAdd(index, newObject);
          if (!FSMUtil.isTransient(CDOObjectImpl.this))
          {
            cdoView().handleAddAdapter(CDOObjectImpl.this, newObject);
          }
        }


        protected void didRemove(int index, Adapter oldObject)
        {
          super.didRemove(index, oldObject);
          if (!FSMUtil.isTransient(CDOObjectImpl.this))
          {
            cdoView().handleRemoveAdapter(CDOObjectImpl.this, oldObject);

          }
        }
      };




            </message_arguments>
        </filter>
    </resource>
    <resource path="src/org/eclipse/emf/internal/cdo/InternalCDOCommitContext.java" type="org.eclipse.emf.internal.cdo.InternalCDOCommitContext">
        <filter id="643846161">
            <message_arguments>
                <message_argument value="CommitTransactionResult"/>
                <message_argument value="InternalCDOCommitContext"/>
                <message_argument value="postCommit(CommitTransactionResult)"/>
            </message_arguments>
        </filter>
    </resource>
    <resource path="src/org/eclipse/emf/internal/cdo/CDOXATransactionCommitContext.java" type="org.eclipse.emf.internal.cdo.CDOXATransactionCommitContext">
        <filter id="643846161">
            <message_arguments>
                <message_argument value="CommitTransactionResult"/>
                <message_argument value="CDOXATransactionCommitContext"/>
                <message_argument value="setResult(CommitTransactionResult)"/>
            </message_arguments>
        </filter>
        <filter id="643842064">
            <message_arguments>
                <message_argument value="CommitTransactionResult"/>
                <message_argument value="CDOXATransactionCommitContext"/>
                <message_argument value="getResult()"/>
            </message_arguments>
        </filter>
    </resource>
    <resource path="src/org/eclipse/emf/internal/cdo/CDOXATransactionCommitContext.java" type="org.eclipse.emf.internal.cdo.CDOXATransactionCommitContext">
        <filter id="643846161">
            <message_arguments>
                <message_argument value="CommitTransactionResult"/>
                <message_argument value="CDOXATransactionCommitContext"/>
                <message_argument value="postCommit(CommitTransactionResult)"/>
            </message_arguments>
        </filter>
    </resource>
    <resource path="src/org/eclipse/emf/internal/cdo/CDOXATransactionImpl.java" type="org.eclipse.emf.internal.cdo.CDOXATransactionImpl$CDOXAState">
        <filter id="643846161">
            <message_arguments>
                <message_argument value="CommitTransactionResult"/>
                <message_argument value="CDOXAState"/>
                <message_argument value="check_result(CommitTransactionResult)"/>
            </message_arguments>
        </filter>
    </resource>
    <resource path="src/org/eclipse/emf/internal/cdo/InternalCDOObject.java" type="org.eclipse.emf.internal.cdo.InternalCDOObject">
        <filter id="1211105284">
            <message_arguments>
                <message_argument value="cdoInternalCleanup()"/>
            </message_arguments>
        </filter>
        <filter id="1211105284">
            <message_arguments>
                <message_argument value="cdoInternalPostLoad(boolean)"/>
            </message_arguments>
        </filter>
    </resource>




import org.eclipse.emf.cdo.common.revision.CDOReferenceAdjuster;
import org.eclipse.emf.cdo.internal.common.revision.CDOIDMapper;

import org.eclipse.emf.internal.cdo.InternalCDOCommitContext;
import org.eclipse.emf.internal.cdo.revision.CDOPostCommitReferenceAdjuster;

import java.util.HashMap;


  private CDOReferenceAdjuster referenceAdjuster;

  private InternalCDOCommitContext commitContext;

  public CommitTransactionResult(InternalCDOCommitContext commitContext, String rollbackMessage)
  {
    this.rollbackMessage = rollbackMessage;
    this.commitContext = commitContext;
  }

  public CommitTransactionResult(InternalCDOCommitContext commitContext, long timeStamp)
  {
    this.timeStamp = timeStamp;
    this.commitContext = commitContext;

    this.referenceAdjuster = referenceAdjuster;
  }

  public InternalCDOCommitContext getCommitContext()
  {
    return commitContext;
  }




import org.eclipse.emf.cdo.internal.common.CDODataOutputImpl;
import org.eclipse.emf.cdo.spi.common.InternalCDOPackage;

import org.eclipse.emf.internal.cdo.InternalCDOCommitContext;
import org.eclipse.emf.internal.cdo.InternalCDOSession;
import org.eclipse.emf.internal.cdo.bundle.OM;
import org.eclipse.emf.internal.cdo.revision.CDOListWithElementProxiesImpl;

  private static final ContextTracer PROTOCOL_TRACER = new ContextTracer(OM.DEBUG_PROTOCOL,
      CommitTransactionRequest.class);

  protected InternalCDOCommitContext commitContext;

  public CommitTransactionRequest(CDOClientProtocol protocol, InternalCDOCommitContext commitContext)
  {
    this(protocol, CDOProtocolConstants.SIGNAL_COMMIT_TRANSACTION, commitContext);
  }

  public CommitTransactionRequest(CDOClientProtocol protocol, short signalID, InternalCDOCommitContext commitContext)
  {
    super(protocol, signalID);
    this.commitContext = commitContext;
  }

  protected InternalCDOCommitContext getCommitContext()
  {
    return commitContext;
  }




 **************************************************************************/
package org.eclipse.emf.cdo.util;

import org.eclipse.emf.cdo.CDOCommitContext;
import org.eclipse.emf.cdo.CDOObject;
import org.eclipse.emf.cdo.CDOTransaction;
import org.eclipse.emf.cdo.CDOTransactionHandler;

 */
public abstract class CDODefaultTransactionHandler implements CDOTransactionHandler
{

  protected CDODefaultTransactionHandler()
  {
  }

  /**
   * This implementation does nothing. Clients may override to provide specialized behaviour.
   */
  public void committingTransaction(CDOTransaction transaction, CDOCommitContext commitContext)
  {
    // Do nothing
  }

  {
    // Do nothing
  }

  /**
   * This implementation does nothing. Clients may override to provide specialized behaviour.
   */
  public void committedTransaction(CDOTransaction transaction, CDOCommitContext commitContext)
  {
    // Do nothing
  }
}

Lines 11-16 Link Here

(-)src/org/eclipse/emf/internal/cdo/util/CDOPackageRegistryImpl.java (-1 / +6 lines)
11	**************************************************************************/	11	**************************************************************************/
12	package org.eclipse.emf.internal.cdo.util;	12	package org.eclipse.emf.internal.cdo.util;
13		13
		14	import org.eclipse.emf.cdo.CDOCommitContext;
14	import org.eclipse.emf.cdo.CDOObject;	15	import org.eclipse.emf.cdo.CDOObject;
15	import org.eclipse.emf.cdo.CDOSession;	16	import org.eclipse.emf.cdo.CDOSession;
16	import org.eclipse.emf.cdo.CDOTransaction;	17	import org.eclipse.emf.cdo.CDOTransaction;
Lines 368-374 Link Here
368	{	369	{
369	}	370	}
370		371
371	public void committingTransaction(CDOTransaction transaction)	372	public void committingTransaction(CDOTransaction transaction, CDOCommitContext commitContext)
372	{	373	{
373	}	374	}
374		375
Lines 379-384 Link Here
379	public void detachingObject(CDOTransaction transaction, CDOObject object)	380	public void detachingObject(CDOTransaction transaction, CDOObject object)
380	{	381	{
381	}	382	}
		383
		384	public void committedTransaction(CDOTransaction transaction, CDOCommitContext commitContext)
		385	{
		386	}
382	}	387	}
383		388
384	/**	389	/**




/***************************************************************************
 * 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:
 *    Simon McDuff - initial API and implementation
 *    Eike Stepper - maintenance
 **************************************************************************/
package org.eclipse.emf.internal.cdo;

import org.eclipse.emf.cdo.CDOCommitContext;

import org.eclipse.emf.internal.cdo.protocol.CommitTransactionResult;

/**
 * Provides a context for a commit operation.
 * 
 * @author Simon McDuff
 * @since 2.0
 */
public interface InternalCDOCommitContext extends CDOCommitContext
{
  public InternalCDOTransaction getTransaction();

  public void preCommit();

  public void postCommit(CommitTransactionResult result);

}




/***************************************************************************
 * 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:
 *    Simon McDuff - initial API and implementation
 *    Eike Stepper - maintenance
 **************************************************************************/
package org.eclipse.emf.cdo;

import org.eclipse.emf.common.notify.Adapter;
import org.eclipse.emf.ecore.EObject;

/**
 * Specifies an adapter policy.
 * <p>
 * To activate a policy, you must do the following: <br>
 * <code>view.setChangeSubscriptionPolicy(CDOAdapterPolicy.ALL);</code>
 * <p>
 * To register an object, you must add an adapter to the object in which you are interested:<br>
 * <code>eObject.eAdapters().add(myAdapter);</code>
 * <p>
 * By activating this feature, each object having at least one adapter that matches the current policy will be
 * registered with the server and will be notified for each change occurring in the scope of any other transaction.
 * <p>
 * {@link CDOAdapterPolicy#NONE} - Disabled. <br>
 * {@link CDOAdapterPolicy#ALL} - Enabled for all adapters used.<br>
 * {@link CDOAdapterPolicy#ONLY_CDO_ADAPTER} - Enabled only for adapters that implement {@link CDOAdapter}. <br>
 * Any other class that implement {@link CDOAdapterPolicy} will enable for whatever rules defined in that class. <br>
 * <p>
 * If <code>myAdapter</code> in the above example matches the current policy, <code>eObject</code> will be registered
 * with the server and you will receive all changes from other transaction.
 * <p>
 * When the policy is changed all objects in the cache will automatically be recalculated.
 * <p>
 * You can subscribe to temporary objects. Even if you cannot receive notifications from other {@link CDOTransaction}
 * for these because they are only local to you, at commit time these objects will be registered automatically.
 * <p>
 * <b>Note:</b> It can be used with <code>CDOSession.setPassiveUpdate(false)</code>. In this case, it will receive
 * changes without having the objects changed.
 * 
 * @author Simon McDuff
 * @see CDOSessionInvalidationEvent
 * @see CDOInvalidationNotification
 * @since 2.0
 */
public interface CDOAdapterPolicy
{
  public static final CDOAdapterPolicy NONE = new CDOAdapterPolicy()
  {
    public boolean valid(EObject eObject, Adapter adapter)
    {
      return false;
    }
  };

  public static final CDOAdapterPolicy ONLY_CDO_ADAPTER = new CDOAdapterPolicy()
  {
    public boolean valid(EObject eObject, Adapter adapter)
    {
      return adapter instanceof CDOAdapter;
    }
  };

  public static final CDOAdapterPolicy ALL = new CDOAdapterPolicy()
  {
    public boolean valid(EObject eObject, Adapter adapter)
    {
      return true;
    }
  };

  public boolean valid(EObject eObject, Adapter adapter);
}




/***************************************************************************
 * 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:
 *    Simon McDuff - initial API and implementation
 *    Eike Stepper - maintenance
 **************************************************************************/
package org.eclipse.emf.cdo;

import org.eclipse.emf.cdo.common.id.CDOID;
import org.eclipse.emf.cdo.common.model.CDOPackage;
import org.eclipse.emf.cdo.common.revision.delta.CDORevisionDelta;
import org.eclipse.emf.cdo.eresource.CDOResource;

import java.util.List;
import java.util.Map;

/**
 * Provides a context for a commit operation.
 * 
 * @author Simon McDuff
 * @since 2.0
 */
public interface CDOCommitContext
{
  public CDOTransaction getTransaction();

  public List<CDOPackage> getNewPackages();

  public Map<CDOID, CDOResource> getNewResources();

  public Map<CDOID, CDOObject> getNewObjects();

  public Map<CDOID, CDOObject> getDirtyObjects();

  public Map<CDOID, CDORevisionDelta> getRevisionDeltas();

  public Map<CDOID, CDOObject> getDetachedObjects();
}

Return to bug 250486

Lines 10-16 Link Here

(-)src/org/eclipse/emf/cdo/tests/ChangeSubscriptionTest.java (-30 / +28 lines)
10	**************************************************************************/	10	**************************************************************************/
11	package org.eclipse.emf.cdo.tests;	11	package org.eclipse.emf.cdo.tests;
12		12
13	import org.eclipse.emf.cdo.CDOChangeSubscriptionPolicy;	13	import org.eclipse.emf.cdo.CDOAdapterPolicy;
14	import org.eclipse.emf.cdo.CDODeltaNotification;	14	import org.eclipse.emf.cdo.CDODeltaNotification;
15	import org.eclipse.emf.cdo.CDOSession;	15	import org.eclipse.emf.cdo.CDOSession;
16	import org.eclipse.emf.cdo.CDOTransaction;	16	import org.eclipse.emf.cdo.CDOTransaction;
Lines 39-53 Link Here
39	{	39	{
40	public void testSameSession() throws Exception	40	public void testSameSession() throws Exception
41	{	41	{
42	testSameSession(CDOChangeSubscriptionPolicy.ALL);	42	testSameSession(CDOAdapterPolicy.ALL);
43	}	43	}
44		44
45	public void testSameSession_disable() throws Exception	45	public void testSameSession_disable() throws Exception
46	{	46	{
47	testSameSession(CDOChangeSubscriptionPolicy.NONE);	47	testSameSession(CDOAdapterPolicy.NONE);
48	}	48	}
49		49
50	public void testSameSession(final CDOChangeSubscriptionPolicy enabled) throws Exception	50	public void testSameSession(final CDOAdapterPolicy enabled) throws Exception
51	{	51	{
52	msg("Opening session");	52	msg("Opening session");
53	final CDOSession session = openModel1Session();	53	final CDOSession session = openModel1Session();
Lines 69-75 Link Here
69	msg("Opening transaction");	69	msg("Opening transaction");
70	final CDOTransaction transaction = session.openTransaction();	70	final CDOTransaction transaction = session.openTransaction();
71		71
72	transaction.setChangeSubscriptionPolicy(enabled);	72	transaction.setAdapterDeltaNotificationPolicy(enabled);
73		73
74	msg("Creating resource");	74	msg("Creating resource");
75	final CDOResource resourceA = transaction.createResource("/test1");	75	final CDOResource resourceA = transaction.createResource("/test1");
Lines 103-120 Link Here
103	@Override	103	@Override
104	protected boolean successful()	104	protected boolean successful()
105	{	105	{
106	return enabled == CDOChangeSubscriptionPolicy.ALL && adapter.getNotifications().size() == 1	106	return enabled == CDOAdapterPolicy.ALL && adapter.getNotifications().size() == 1
107	\|\| enabled == CDOChangeSubscriptionPolicy.NONE && adapter.getNotifications().size() == 0;	107	\|\| enabled == CDOAdapterPolicy.NONE && adapter.getNotifications().size() == 0;
108	}	108	}
109	}.timedOut();	109	}.timedOut();
110		110
111	assertEquals(false, timedOut);	111	assertEquals(false, timedOut);
112		112
113	// Switching policy to the other	113	// Switching policy to the other
114	final CDOChangeSubscriptionPolicy enabled2 = enabled == CDOChangeSubscriptionPolicy.ALL ? CDOChangeSubscriptionPolicy.NONE	114	final CDOAdapterPolicy enabled2 = enabled == CDOAdapterPolicy.ALL ? CDOAdapterPolicy.NONE : CDOAdapterPolicy.ALL;
115	: CDOChangeSubscriptionPolicy.ALL;
116		115
117	transaction.setChangeSubscriptionPolicy(enabled2);	116	transaction.setAdapterDeltaNotificationPolicy(enabled2);
118		117
119	adapter.getNotifications().clear();	118	adapter.getNotifications().clear();
120		119
Lines 132-139 Link Here
132	@Override	131	@Override
133	protected boolean successful()	132	protected boolean successful()
134	{	133	{
135	return enabled2 == CDOChangeSubscriptionPolicy.ALL && adapter.getNotifications().size() == 1	134	return enabled2 == CDOAdapterPolicy.ALL && adapter.getNotifications().size() == 1
136	\|\| enabled2 == CDOChangeSubscriptionPolicy.NONE && adapter.getNotifications().size() == 0;	135	\|\| enabled2 == CDOAdapterPolicy.NONE && adapter.getNotifications().size() == 0;
137	}	136	}
138	}.timedOut();	137	}.timedOut();
139		138
Lines 142-157 Link Here
142		141
143	public void testSeparateSession() throws Exception	142	public void testSeparateSession() throws Exception
144	{	143	{
145	testSeparateSession(CDOChangeSubscriptionPolicy.ALL);	144	testSeparateSession(CDOAdapterPolicy.ALL);
146		145
147	}	146	}
148		147
149	public void testSeparateSession_disable() throws Exception	148	public void testSeparateSession_disable() throws Exception
150	{	149	{
151	testSeparateSession(CDOChangeSubscriptionPolicy.NONE);	150	testSeparateSession(CDOAdapterPolicy.NONE);
152	}	151	}
153		152
154	public void testSeparateSession(final CDOChangeSubscriptionPolicy enabled) throws Exception	153	public void testSeparateSession(final CDOAdapterPolicy enabled) throws Exception
155	{	154	{
156	msg("Opening session");	155	msg("Opening session");
157	final CDOSession session = openModel1Session();	156	final CDOSession session = openModel1Session();
Lines 172-178 Link Here
172		171
173	msg("Opening transaction");	172	msg("Opening transaction");
174	final CDOTransaction transaction = session.openTransaction();	173	final CDOTransaction transaction = session.openTransaction();
175	transaction.setChangeSubscriptionPolicy(enabled);	174	transaction.setAdapterDeltaNotificationPolicy(enabled);
176		175
177	msg("Creating resource");	176	msg("Creating resource");
178	final CDOResource resourceA = transaction.createResource("/test1");	177	final CDOResource resourceA = transaction.createResource("/test1");
Lines 209-226 Link Here
209	@Override	208	@Override
210	protected boolean successful()	209	protected boolean successful()
211	{	210	{
212	return enabled == CDOChangeSubscriptionPolicy.ALL && adapter.getNotifications().size() == 1	211	return enabled == CDOAdapterPolicy.ALL && adapter.getNotifications().size() == 1
213	\|\| enabled == CDOChangeSubscriptionPolicy.NONE && adapter.getNotifications().size() == 0;	212	\|\| enabled == CDOAdapterPolicy.NONE && adapter.getNotifications().size() == 0;
214	}	213	}
215	}.timedOut();	214	}.timedOut();
216		215
217	assertEquals(false, timedOut);	216	assertEquals(false, timedOut);
218		217
219	// Switching policy to the other	218	// Switching policy to the other
220	final CDOChangeSubscriptionPolicy enabled2 = enabled == CDOChangeSubscriptionPolicy.ALL ? CDOChangeSubscriptionPolicy.NONE	219	final CDOAdapterPolicy enabled2 = enabled == CDOAdapterPolicy.ALL ? CDOAdapterPolicy.NONE : CDOAdapterPolicy.ALL;
221	: CDOChangeSubscriptionPolicy.ALL;
222		220
223	transaction.setChangeSubscriptionPolicy(enabled2);	221	transaction.setAdapterDeltaNotificationPolicy(enabled2);
224		222
225	adapter.getNotifications().clear();	223	adapter.getNotifications().clear();
226		224
Lines 238-245 Link Here
238	@Override	236	@Override
239	protected boolean successful()	237	protected boolean successful()
240	{	238	{
241	return enabled2 == CDOChangeSubscriptionPolicy.ALL && adapter.getNotifications().size() == 1	239	return enabled2 == CDOAdapterPolicy.ALL && adapter.getNotifications().size() == 1
242	\|\| enabled2 == CDOChangeSubscriptionPolicy.NONE && adapter.getNotifications().size() == 0;	240	\|\| enabled2 == CDOAdapterPolicy.NONE && adapter.getNotifications().size() == 0;
243	}	241	}
244	}.timedOut();	242	}.timedOut();
245		243
Lines 268-274 Link Here
268		266
269	msg("Opening transaction");	267	msg("Opening transaction");
270	final CDOTransaction transaction = session.openTransaction();	268	final CDOTransaction transaction = session.openTransaction();
271	transaction.setChangeSubscriptionPolicy(CDOChangeSubscriptionPolicy.ALL);	269	transaction.setAdapterDeltaNotificationPolicy(CDOAdapterPolicy.ALL);
272	msg("Creating resource");	270	msg("Creating resource");
273	final CDOResource resourceA = transaction.createResource("/test1");	271	final CDOResource resourceA = transaction.createResource("/test1");
274		272
Lines 289-295 Link Here
289	session2.setPassiveUpdateEnabled(false);	287	session2.setPassiveUpdateEnabled(false);
290		288
291	final CDOTransaction transaction2 = session2.openTransaction();	289	final CDOTransaction transaction2 = session2.openTransaction();
292	transaction.setChangeSubscriptionPolicy(CDOChangeSubscriptionPolicy.ALL);	290	transaction.setAdapterDeltaNotificationPolicy(CDOAdapterPolicy.ALL);
293		291
294	final Category category1B = (Category)transaction2.getObject(CDOUtil.getCDOObject(category1A).cdoID(), true);	292	final Category category1B = (Category)transaction2.getObject(CDOUtil.getCDOObject(category1A).cdoID(), true);
295		293
Lines 339-345 Link Here
339	msg("Opening transaction");	337	msg("Opening transaction");
340	final CDOTransaction transaction = session.openTransaction();	338	final CDOTransaction transaction = session.openTransaction();
341		339
342	transaction.setChangeSubscriptionPolicy(customPolicy);	340	transaction.setAdapterDeltaNotificationPolicy(customPolicy);
343		341
344	msg("Creating resource");	342	msg("Creating resource");
345	final CDOResource resourceA = transaction.createResource("/test1");	343	final CDOResource resourceA = transaction.createResource("/test1");
Lines 390-396 Link Here
390	assertEquals(false, timedOut);	388	assertEquals(false, timedOut);
391		389
392	// Switching policy to the other	390	// Switching policy to the other
393	transaction.setChangeSubscriptionPolicy(CDOChangeSubscriptionPolicy.ALL);	391	transaction.setAdapterDeltaNotificationPolicy(CDOAdapterPolicy.ALL);
394		392
395	adapter.getNotifications().clear();	393	adapter.getNotifications().clear();
396		394
Lines 439-445 Link Here
439	msg("Opening transaction");	437	msg("Opening transaction");
440	final CDOTransaction transaction = session.openTransaction();	438	final CDOTransaction transaction = session.openTransaction();
441		439
442	transaction.setChangeSubscriptionPolicy(CDOChangeSubscriptionPolicy.ALL);	440	transaction.setAdapterDeltaNotificationPolicy(CDOAdapterPolicy.ALL);
443		441
444	msg("Creating resource");	442	msg("Creating resource");
445	final CDOResource resourceA = transaction.createResource("/test1");	443	final CDOResource resourceA = transaction.createResource("/test1");
Lines 570-576 Link Here
570	/**	568	/**
571	* @author Simon McDuff	569	* @author Simon McDuff
572	*/	570	*/
573	private class CDOIDFilterChangeSubscriptionPolicy implements CDOChangeSubscriptionPolicy	571	private class CDOIDFilterChangeSubscriptionPolicy implements CDOAdapterPolicy
574	{	572	{
575	private Set<CDOID> cdoIDs = new HashSet<CDOID>();	573	private Set<CDOID> cdoIDs = new HashSet<CDOID>();
576		574
Lines 578-584 Link Here
578	{	576	{
579	}	577	}
580		578
581	public boolean shouldSubscribe(EObject eObject, Adapter object)	579	public boolean valid(EObject eObject, Adapter object)
582	{	580	{
583	return cdoIDs.contains(((InternalCDOObject)eObject).cdoID());	581	return cdoIDs.contains(((InternalCDOObject)eObject).cdoID());
584	}	582	}

Added Link Here

(-)src/org/eclipse/emf/cdo/tests/AdapterManagerTest.java (+261 lines)
1	/***************************************************************************
2	* Copyright (c) 2004 - 2008 Eike Stepper, Germany.
3	* All rights reserved. This program and the accompanying materials
4	* are made available under the terms of the Eclipse Public License v1.0
5	* which accompanies this distribution, and is available at
6	* http://www.eclipse.org/legal/epl-v10.html
7	*
8	* Contributors:
9	* Simon McDuff - initial API and implementation
10	**************************************************************************/
11	package org.eclipse.emf.cdo.tests;
12
13	import org.eclipse.emf.cdo.CDOAdapterPolicy;
14	import org.eclipse.emf.cdo.CDOSession;
15	import org.eclipse.emf.cdo.CDOTransaction;
16	import org.eclipse.emf.cdo.common.id.CDOID;
17	import org.eclipse.emf.cdo.tests.model1.Company;
18	import org.eclipse.emf.cdo.util.CDOUtil;
19
20	import org.eclipse.emf.common.notify.Adapter;
21	import org.eclipse.emf.common.notify.Notification;
22	import org.eclipse.emf.common.notify.Notifier;
23
24	import java.lang.ref.WeakReference;
25	import java.util.ArrayList;
26	import java.util.List;
27
28	/**
29	* @author Simon McDuff
30	*/
31	public class AdapterManagerTest extends AbstractCDOTest
32	{
33	public void testAdapterPolicy_NONE() throws Exception
34	{
35	msg("Opening session");
36	final CDOSession session = openModel1Session();
37
38	session.setPassiveUpdateEnabled(false);
39
40	// ************************************************************* //
41
42	msg("Creating company");
43	Company companyA = getModel1Factory().createCompany();
44	TestAdapter testAdapter = new TestAdapter();
45	msg("Opening transaction");
46	CDOTransaction transaction = session.openTransaction();
47
48	transaction.createResource("/resA").getContents().add(companyA);
49
50	msg("Committing");
51	transaction.commit();
52
53	CDOID id = CDOUtil.getCDOObject(companyA).cdoID();
54	companyA.eAdapters().add(testAdapter);
55	companyA = null;
56
57	System.gc();
58
59	assertEquals(false, transaction.isObjectRegistered(id));
60	companyA = (Company)transaction.getObject(id);
61	assertEquals(0, testAdapter.getNotifications().size());
62	companyA.setCity("Ottawa");
63	assertEquals(0, testAdapter.getNotifications().size());
64	}
65
66	public void testAdapterPolicy_ALL() throws Exception
67	{
68	msg("Opening session");
69	final CDOSession session = openModel1Session();
70
71	session.setPassiveUpdateEnabled(false);
72
73	// ************************************************************* //
74
75	msg("Creating company");
76	Company companyA = getModel1Factory().createCompany();
77	TestAdapter testAdapter = new TestAdapter();
78	msg("Opening transaction");
79	CDOTransaction transaction = session.openTransaction();
80
81	transaction.setAdapterReferencePolicy(CDOAdapterPolicy.ALL);
82
83	transaction.createResource("/resA").getContents().add(companyA);
84
85	msg("Committing");
86	transaction.commit();
87	CDOID id = CDOUtil.getCDOObject(companyA).cdoID();
88	companyA.eAdapters().add(testAdapter);
89	companyA = null;
90
91	testAdapter.getNotifications().clear();
92	System.gc();
93
94	assertEquals(true, transaction.isObjectRegistered(id));
95	companyA = (Company)transaction.getObject(id);
96
97	assertEquals(0, testAdapter.getNotifications().size());
98	companyA.setCity("Ottawa");
99	assertEquals(1, testAdapter.getNotifications().size());
100	}
101
102	public void testAdapterPolicy_AttachObject() throws Exception
103	{
104	msg("Opening session");
105	final CDOSession session = openModel1Session();
106
107	session.setPassiveUpdateEnabled(false);
108
109	// ************************************************************* //
110
111	msg("Creating company");
112	Company companyA = getModel1Factory().createCompany();
113	TestAdapter testAdapter = new TestAdapter();
114
115	companyA.eAdapters().add(testAdapter);
116
117	msg("Opening transaction");
118	CDOTransaction transaction = session.openTransaction();
119
120	transaction.setAdapterReferencePolicy(CDOAdapterPolicy.ALL);
121
122	transaction.createResource("/resA").getContents().add(companyA);
123
124	msg("Committing");
125	transaction.commit();
126	CDOID id = CDOUtil.getCDOObject(companyA).cdoID();
127
128	companyA = null;
129
130	testAdapter.getNotifications().clear();
131	System.gc();
132
133	assertEquals(true, transaction.isObjectRegistered(id));
134	companyA = (Company)transaction.getObject(id);
135
136	assertEquals(0, testAdapter.getNotifications().size());
137	companyA.setCity("Ottawa");
138	assertEquals(1, testAdapter.getNotifications().size());
139	}
140
141	public void testAdapterPolicy_DetachObject() throws Exception
142	{
143	msg("Opening session");
144	final CDOSession session = openModel1Session();
145
146	session.setPassiveUpdateEnabled(false);
147
148	// ************************************************************* //
149
150	msg("Creating company");
151	Company companyA = getModel1Factory().createCompany();
152	WeakReference<Company> weakCompanyA = new WeakReference<Company>(companyA);
153
154	TestAdapter testAdapter = new TestAdapter();
155
156	companyA.eAdapters().add(testAdapter);
157
158	msg("Opening transaction");
159	CDOTransaction transaction = session.openTransaction();
160
161	transaction.setAdapterReferencePolicy(CDOAdapterPolicy.ALL);
162
163	transaction.createResource("/resA").getContents().add(companyA);
164
165	msg("Committing");
166	transaction.commit();
167	CDOID id = CDOUtil.getCDOObject(companyA).cdoID();
168	companyA = null;
169
170	testAdapter.getNotifications().clear();
171	System.gc();
172
173	assertEquals(true, transaction.isObjectRegistered(id));
174	Company companyB = (Company)transaction.getObject(id);
175	assertEquals(companyB, weakCompanyA.get());
176	companyB.setCity("Ottawa");
177	transaction.getResource("/resA").getContents().remove(0);
178	transaction.commit();
179	companyB = null;
180
181	testAdapter.getNotifications().clear();
182	System.gc();
183
184	assertTrue(weakCompanyA.get() == null);
185	}
186
187	public void testAdapterPolicy_ChangePolicy() throws Exception
188	{
189	msg("Opening session");
190	final CDOSession session = openModel1Session();
191
192	session.setPassiveUpdateEnabled(false);
193
194	// ************************************************************* //
195
196	msg("Creating company");
197	Company companyA = getModel1Factory().createCompany();
198
199	TestAdapter testAdapter = new TestAdapter();
200	companyA.eAdapters().add(testAdapter);
201
202	msg("Opening transaction");
203	CDOTransaction transaction = session.openTransaction();
204
205	transaction.createResource("/resA").getContents().add(companyA);
206
207	msg("Committing");
208	transaction.commit();
209	CDOID id = CDOUtil.getCDOObject(companyA).cdoID();
210	transaction.setAdapterReferencePolicy(CDOAdapterPolicy.ALL);
211	companyA = null;
212
213	testAdapter.getNotifications().clear();
214	System.gc();
215
216	assertEquals(true, transaction.isObjectRegistered(id));
217	transaction.setAdapterReferencePolicy(CDOAdapterPolicy.NONE);
218
219	System.gc();
220
221	assertEquals(false, transaction.isObjectRegistered(id));
222	}
223
224	/**
225	* @author Simon McDuff
226	*/
227	private static class TestAdapter implements Adapter
228	{
229	private List<Notification> notifications = new ArrayList<Notification>();
230
231	public TestAdapter()
232	{
233	}
234
235	public Notifier getTarget()
236	{
237	return null;
238	}
239
240	public List<Notification> getNotifications()
241	{
242	return notifications;
243	}
244
245	public boolean isAdapterForType(Object type)
246	{
247	return false;
248	}
249
250	public void notifyChanged(Notification notification)
251	{
252	notifications.add(notification);
253	}
254
255	public void setTarget(Notifier newTarget)
256	{
257
258	}
259	}
260
261	}

Lines 187-202 Link Here

(-)src/org/eclipse/emf/cdo/CDOView.java (-11 / +19 lines)
187	public void setInvalidationNotificationEnabled(boolean enabled);	187	public void setInvalidationNotificationEnabled(boolean enabled);
188		188
189	/**	189	/**
190	* Returns the current {@link CDOChangeSubscriptionPolicy change subscription policy}.	190	* Returns the current {@link CDOAdapterPolicy change subscription policy}.
191	*	191	*
192	* @return The current change subscription policy, never <code>null</code>.	192	* @return The current change subscription policy, never <code>null</code>.
193	* @see #setChangeSubscriptionPolicy(CDOChangeSubscriptionPolicy)	193	* @see #setAdapterDeltaNotificationPolicy(CDOAdapterPolicy)
194	* @since 2.0	194	* @since 2.0
195	*/	195	*/
196	public CDOChangeSubscriptionPolicy getChangeSubscriptionPolicy();	196	public CDOAdapterPolicy getAdapterDeltaNotificationPolicy();
197		197
198	/**	198	/**
199	* Specifies the change subscription policy. By default, the value is set to {@link CDOChangeSubscriptionPolicy#NONE}.	199	* Specifies the change subscription policy. By default, the value is set to {@link CDOAdapterPolicy#NONE}.
200	* <p>	200	* <p>
201	* To activate the policy, you must do the following: <br>	201	* To activate the policy, you must do the following: <br>
202	* <code>transaction.setChangeSubscriptionPolicy(CDOChangeSubscriptionPolicy.ALL);</code>	202	* <code>transaction.setChangeSubscriptionPolicy(CDOChangeSubscriptionPolicy.ALL);</code>
Lines 207-218 Link Here
207	* By activating this feature, each object having at least one adapter that matches the current policy will be	207	* By activating this feature, each object having at least one adapter that matches the current policy will be
208	* registered with the server and will be notified for each change occurring in the scope of any other transaction.	208	* registered with the server and will be notified for each change occurring in the scope of any other transaction.
209	* <p>	209	* <p>
210	* {@link CDOChangeSubscriptionPolicy#NONE} - Disabled. <br>	210	* {@link CDOAdapterPolicy#NONE} - Disabled. <br>
211	* {@link CDOChangeSubscriptionPolicy#ALL} - Enabled for all adapters used.<br>	211	* {@link CDOAdapterPolicy#ALL} - Enabled for all adapters used.<br>
212	* {@link CDOChangeSubscriptionPolicy#ONLY_CDO_ADAPTER} - Enabled only for adapters that implement {@link CDOAdapter}.	212	* {@link CDOAdapterPolicy#ONLY_CDO_ADAPTER} - Enabled only for adapters that implement {@link CDOAdapter}. <br>
213	* <br>	213	* Any other class that implement {@link CDOAdapterPolicy} will enable for whatever rules defined in that class. <br>
214	* Any other class that implement {@link CDOChangeSubscriptionPolicy} will enable for whatever rules defined in that
215	* class. <br>
216	* <p>	214	* <p>
217	* If <code>myAdapter</code> in the above example matches the current policy, <code>eObject</code> will be registered	215	* If <code>myAdapter</code> in the above example matches the current policy, <code>eObject</code> will be registered
218	* with the server and you will receive all changes from other transaction.	216	* with the server and you will receive all changes from other transaction.
Lines 227-233 Link Here
227	*	225	*
228	* @since 2.0	226	* @since 2.0
229	*/	227	*/
230	public void setChangeSubscriptionPolicy(CDOChangeSubscriptionPolicy policy);	228	public void setAdapterDeltaNotificationPolicy(CDOAdapterPolicy policy);
		229
		230	/**
		231	* @since 2.0
		232	*/
		233	public void setAdapterReferencePolicy(CDOAdapterPolicy policy);
		234
		235	/**
		236	* @since 2.0
		237	*/
		238	public CDOAdapterPolicy getAdapterReferencePolicy();
231		239
232	/**	240	/**
233	* @since 2.0	241	* @since 2.0

Lines 48-55 Link Here

(-)src/org/eclipse/emf/cdo/CDOTransactionHandler.java (-1 / +12 lines)
48	* Called by a <code>CDOTransaction</code> <b>before</b> it is being committed. The implementor of this method is	48	* Called by a <code>CDOTransaction</code> <b>before</b> it is being committed. The implementor of this method is
49	* allowed to throw an unchecked exception that will propagate up to the operation that is about to commit the	49	* allowed to throw an unchecked exception that will propagate up to the operation that is about to commit the
50	* transaction.	50	* transaction.
		51	*
		52	* @since 2.0
		53	*/
		54	public void committingTransaction(CDOTransaction transaction, CDOCommitContext commitContext);
		55
		56	/**
		57	* Called by a <code>CDOTransaction</code> <b>after</b> it is being committed. The implementor of this method is not
		58	* allowed to throw an unchecked exception that will propagate up to the operation that is about to commit the
		59	* transaction.
		60	*
		61	* @since 2.0
51	*/	62	*/
52	public void committingTransaction(CDOTransaction transaction);	63	public void committedTransaction(CDOTransaction transaction, CDOCommitContext commitContext);
53		64
54	/**	65	/**
55	* Called by a <code>CDOTransaction</code> <b>after</b> it is rolled back. If the implementor of this method throws an	66	* Called by a <code>CDOTransaction</code> <b>after</b> it is rolled back. If the implementor of this method throws an

Removed Link Here

(-)src/org/eclipse/emf/cdo/CDOChangeSubscriptionPolicy.java (-78 lines)
1	/***************************************************************************
2	* Copyright (c) 2004 - 2008 Eike Stepper, Germany.
3	* All rights reserved. This program and the accompanying materials
4	* are made available under the terms of the Eclipse Public License v1.0
5	* which accompanies this distribution, and is available at
6	* http://www.eclipse.org/legal/epl-v10.html
7	*
8	* Contributors:
9	* Simon McDuff - initial API and implementation
10	* Eike Stepper - maintenance
11	**************************************************************************/
12	package org.eclipse.emf.cdo;
13
14	import org.eclipse.emf.common.notify.Adapter;
15	import org.eclipse.emf.ecore.EObject;
16
17	/**
18	* Specifies a change subscription policy.
19	* <p>
20	* To activate a policy, you must do the following: <br>
21	* <code>view.setChangeSubscriptionPolicy(CDOChangeSubscriptionPolicy.ALL);</code>
22	* <p>
23	* To register an object, you must add an adapter to the object in which you are interested:<br>
24	* <code>eObject.eAdapters().add(myAdapter);</code>
25	* <p>
26	* By activating this feature, each object having at least one adapter that matches the current policy will be
27	* registered with the server and will be notified for each change occurring in the scope of any other transaction.
28	* <p>
29	* {@link CDOChangeSubscriptionPolicy#NONE} - Disabled. <br>
30	* {@link CDOChangeSubscriptionPolicy#ALL} - Enabled for all adapters used.<br>
31	* {@link CDOChangeSubscriptionPolicy#ONLY_CDO_ADAPTER} - Enabled only for adapters that implement {@link CDOAdapter}. <br>
32	* Any other class that implement {@link CDOChangeSubscriptionPolicy} will enable for whatever rules defined in that
33	* class. <br>
34	* <p>
35	* If <code>myAdapter</code> in the above example matches the current policy, <code>eObject</code> will be registered
36	* with the server and you will receive all changes from other transaction.
37	* <p>
38	* When the policy is changed all objects in the cache will automatically be recalculated.
39	* <p>
40	* You can subscribe to temporary objects. Even if you cannot receive notifications from other {@link CDOTransaction}
41	* for these because they are only local to you, at commit time these objects will be registered automatically.
42	* <p>
43	* <b>Note:</b> It can be used with <code>CDOSession.setPassiveUpdate(false)</code>. In this case, it will receive
44	* changes without having the objects changed.
45	*
46	* @author Simon McDuff
47	* @see CDOSessionInvalidationEvent
48	* @see CDOInvalidationNotification
49	* @since 2.0
50	*/
51	public interface CDOChangeSubscriptionPolicy
52	{
53	public static final CDOChangeSubscriptionPolicy NONE = new CDOChangeSubscriptionPolicy()
54	{
55	public boolean shouldSubscribe(EObject eObject, Adapter adapter)
56	{
57	return false;
58	}
59	};
60
61	public static final CDOChangeSubscriptionPolicy ONLY_CDO_ADAPTER = new CDOChangeSubscriptionPolicy()
62	{
63	public boolean shouldSubscribe(EObject eObject, Adapter adapter)
64	{
65	return adapter instanceof CDOAdapter;
66	}
67	};
68
69	public static final CDOChangeSubscriptionPolicy ALL = new CDOChangeSubscriptionPolicy()
70	{
71	public boolean shouldSubscribe(EObject eObject, Adapter adapter)
72	{
73	return true;
74	}
75	};
76
77	public boolean shouldSubscribe(EObject eObject, Adapter adapter);
78	}

Removed Link Here

(-)src/org/eclipse/emf/internal/cdo/CDOCommitContext.java (-50 lines)
1	/***************************************************************************
2	* Copyright (c) 2004 - 2008 Eike Stepper, Germany.
3	* All rights reserved. This program and the accompanying materials
4	* are made available under the terms of the Eclipse Public License v1.0
5	* which accompanies this distribution, and is available at
6	* http://www.eclipse.org/legal/epl-v10.html
7	*
8	* Contributors:
9	* Simon McDuff - initial API and implementation
10	* Eike Stepper - maintenance
11	**************************************************************************/
12	package org.eclipse.emf.internal.cdo;
13
14	import org.eclipse.emf.cdo.CDOObject;
15	import org.eclipse.emf.cdo.common.id.CDOID;
16	import org.eclipse.emf.cdo.common.model.CDOPackage;
17	import org.eclipse.emf.cdo.common.revision.delta.CDORevisionDelta;
18	import org.eclipse.emf.cdo.eresource.CDOResource;
19
20	import org.eclipse.emf.internal.cdo.protocol.CommitTransactionResult;
21
22	import java.util.List;
23	import java.util.Map;
24
25	/**
26	* Provides a context for a commit operation.
27	*
28	* @author Simon McDuff
29	* @since 2.0
30	*/
31	public interface CDOCommitContext
32	{
33	public InternalCDOTransaction getTransaction();
34
35	public void preCommit();
36
37	public void postCommit(CommitTransactionResult result);
38
39	public List<CDOPackage> getNewPackages();
40
41	public Map<CDOID, CDOResource> getNewResources();
42
43	public Map<CDOID, CDOObject> getNewObjects();
44
45	public Map<CDOID, CDOObject> getDirtyObjects();
46
47	public Map<CDOID, CDORevisionDelta> getRevisionDeltas();
48
49	public Map<CDOID, CDOObject> getDetachedObjects();
50	}

Lines 535-543 Link Here

(-)src/org/eclipse/emf/internal/cdo/CDOObjectImpl.java (-4 / +5 lines)
535	protected void didAdd(int index, Adapter newObject)	535	protected void didAdd(int index, Adapter newObject)
536	{	536	{
537	super.didAdd(index, newObject);	537	super.didAdd(index, newObject);
538	if (!FSMUtil.isTransient(CDOObjectImpl.this) && !FSMUtil.isNew(CDOObjectImpl.this))	538	if (!FSMUtil.isTransient(CDOObjectImpl.this))
539	{	539	{
540	cdoView().subscribe(CDOObjectImpl.this, newObject);	540	cdoView().handleAddAdapter(CDOObjectImpl.this, newObject);
541	}	541	}
542	}	542	}
543		543
Lines 545-553 Link Here
545	protected void didRemove(int index, Adapter oldObject)	545	protected void didRemove(int index, Adapter oldObject)
546	{	546	{
547	super.didRemove(index, oldObject);	547	super.didRemove(index, oldObject);
548	if (!FSMUtil.isTransient(CDOObjectImpl.this) && !FSMUtil.isNew(CDOObjectImpl.this))	548	if (!FSMUtil.isTransient(CDOObjectImpl.this))
549	{	549	{
550	cdoView().unsubscribe(CDOObjectImpl.this, oldObject);	550	cdoView().handleRemoveAdapter(CDOObjectImpl.this, oldObject);
		551
551	}	552	}
552	}	553	}
553	};	554	};

Lines 18-64 Link Here

(-).settings/.api_filters (-17 / +26 lines)
18	</message_arguments>	18	</message_arguments>
19	</filter>	19	</filter>
20	</resource>	20	</resource>
21	<resource path="src/org/eclipse/emf/internal/cdo/CDOXATransactionImpl.java" type="org.eclipse.emf.internal.cdo.CDOXATransactionImpl$CDOXAState">	21	<resource path="src/org/eclipse/emf/internal/cdo/InternalCDOCommitContext.java" type="org.eclipse.emf.internal.cdo.InternalCDOCommitContext">
22	<filter id="643846161">	22	<filter id="643846161">
23	<message_arguments>	23	<message_arguments>
24	<message_argument value="CommitTransactionResult"/>	24	<message_argument value="CommitTransactionResult"/>
25	<message_argument value="CDOXAState"/>	25	<message_argument value="InternalCDOCommitContext"/>
26	<message_argument value="check_result(CommitTransactionResult)"/>	26	<message_argument value="postCommit(CommitTransactionResult)"/>
27	</message_arguments>	27	</message_arguments>
28	</filter>	28	</filter>
29	</resource>	29	</resource>
30	<resource path="src/org/eclipse/emf/internal/cdo/InternalCDOObject.java" type="org.eclipse.emf.internal.cdo.InternalCDOObject">	30	<resource path="src/org/eclipse/emf/internal/cdo/CDOXATransactionCommitContext.java" type="org.eclipse.emf.internal.cdo.CDOXATransactionCommitContext">
31	<filter id="1211105284">	31	<filter id="643846161">
32	<message_arguments>	32	<message_arguments>
33	<message_argument value="cdoInternalCleanup()"/>	33	<message_argument value="CommitTransactionResult"/>
		34	<message_argument value="CDOXATransactionCommitContext"/>
		35	<message_argument value="setResult(CommitTransactionResult)"/>
34	</message_arguments>	36	</message_arguments>
35	</filter>	37	</filter>
36	<filter id="1211105284">	38	<filter id="643842064">
37	<message_arguments>	39	<message_arguments>
38	<message_argument value="cdoInternalPostLoad(boolean)"/>	40	<message_argument value="CommitTransactionResult"/>
		41	<message_argument value="CDOXATransactionCommitContext"/>
		42	<message_argument value="getResult()"/>
39	</message_arguments>	43	</message_arguments>
40	</filter>	44	</filter>
41	</resource>
42	<resource path="src/org/eclipse/emf/internal/cdo/CDOXATransactionCommitContext.java" type="org.eclipse.emf.internal.cdo.CDOXATransactionCommitContext">
43	<filter id="643846161">	45	<filter id="643846161">
44	<message_arguments>	46	<message_arguments>
45	<message_argument value="CommitTransactionResult"/>	47	<message_argument value="CommitTransactionResult"/>
46	<message_argument value="CDOXATransactionCommitContext"/>	48	<message_argument value="CDOXATransactionCommitContext"/>
47	<message_argument value="setResult(CommitTransactionResult)"/>	49	<message_argument value="postCommit(CommitTransactionResult)"/>
48	</message_arguments>	50	</message_arguments>
49	</filter>	51	</filter>
		52	</resource>
		53	<resource path="src/org/eclipse/emf/internal/cdo/CDOXATransactionImpl.java" type="org.eclipse.emf.internal.cdo.CDOXATransactionImpl$CDOXAState">
50	<filter id="643846161">	54	<filter id="643846161">
51	<message_arguments>	55	<message_arguments>
52	<message_argument value="CommitTransactionResult"/>	56	<message_argument value="CommitTransactionResult"/>
53	<message_argument value="CDOXATransactionCommitContext"/>	57	<message_argument value="CDOXAState"/>
54	<message_argument value="postCommit(CommitTransactionResult)"/>	58	<message_argument value="check_result(CommitTransactionResult)"/>
55	</message_arguments>	59	</message_arguments>
56	</filter>	60	</filter>
57	<filter id="643842064">	61	</resource>
		62	<resource path="src/org/eclipse/emf/internal/cdo/InternalCDOObject.java" type="org.eclipse.emf.internal.cdo.InternalCDOObject">
		63	<filter id="1211105284">
58	<message_arguments>	64	<message_arguments>
59	<message_argument value="CommitTransactionResult"/>	65	<message_argument value="cdoInternalCleanup()"/>
60	<message_argument value="CDOXATransactionCommitContext"/>	66	</message_arguments>
61	<message_argument value="getResult()"/>	67	</filter>
		68	<filter id="1211105284">
		69	<message_arguments>
		70	<message_argument value="cdoInternalPostLoad(boolean)"/>
62	</message_arguments>	71	</message_arguments>
63	</filter>	72	</filter>
64	</resource>	73	</resource>

Lines 15-21 Link Here

(-)src/org/eclipse/emf/internal/cdo/protocol/CommitTransactionResult.java (-5 / +5 lines)
15	import org.eclipse.emf.cdo.common.revision.CDOReferenceAdjuster;	15	import org.eclipse.emf.cdo.common.revision.CDOReferenceAdjuster;
16	import org.eclipse.emf.cdo.internal.common.revision.CDOIDMapper;	16	import org.eclipse.emf.cdo.internal.common.revision.CDOIDMapper;
17		17
18	import org.eclipse.emf.internal.cdo.CDOCommitContext;	18	import org.eclipse.emf.internal.cdo.InternalCDOCommitContext;
19	import org.eclipse.emf.internal.cdo.revision.CDOPostCommitReferenceAdjuster;	19	import org.eclipse.emf.internal.cdo.revision.CDOPostCommitReferenceAdjuster;
20		20
21	import java.util.HashMap;	21	import java.util.HashMap;
Lines 35-49 Link Here
35		35
36	private CDOReferenceAdjuster referenceAdjuster;	36	private CDOReferenceAdjuster referenceAdjuster;
37		37
38	private CDOCommitContext commitContext;	38	private InternalCDOCommitContext commitContext;
39		39
40	public CommitTransactionResult(CDOCommitContext commitContext, String rollbackMessage)	40	public CommitTransactionResult(InternalCDOCommitContext commitContext, String rollbackMessage)
41	{	41	{
42	this.rollbackMessage = rollbackMessage;	42	this.rollbackMessage = rollbackMessage;
43	this.commitContext = commitContext;	43	this.commitContext = commitContext;
44	}	44	}
45		45
46	public CommitTransactionResult(CDOCommitContext commitContext, long timeStamp)	46	public CommitTransactionResult(InternalCDOCommitContext commitContext, long timeStamp)
47	{	47	{
48	this.timeStamp = timeStamp;	48	this.timeStamp = timeStamp;
49	this.commitContext = commitContext;	49	this.commitContext = commitContext;
Lines 65-71 Link Here
65	this.referenceAdjuster = referenceAdjuster;	65	this.referenceAdjuster = referenceAdjuster;
66	}	66	}
67		67
68	public CDOCommitContext getCommitContext()	68	public InternalCDOCommitContext getCommitContext()
69	{	69	{
70	return commitContext;	70	return commitContext;
71	}	71	}

Lines 10-15 Link Here

(-)src/org/eclipse/emf/cdo/util/CDODefaultTransactionHandler.java (-1 / +11 lines)
10	**************************************************************************/	10	**************************************************************************/
11	package org.eclipse.emf.cdo.util;	11	package org.eclipse.emf.cdo.util;
12		12
		13	import org.eclipse.emf.cdo.CDOCommitContext;
13	import org.eclipse.emf.cdo.CDOObject;	14	import org.eclipse.emf.cdo.CDOObject;
14	import org.eclipse.emf.cdo.CDOTransaction;	15	import org.eclipse.emf.cdo.CDOTransaction;
15	import org.eclipse.emf.cdo.CDOTransactionHandler;	16	import org.eclipse.emf.cdo.CDOTransactionHandler;
Lines 21-26 Link Here
21	*/	22	*/
22	public abstract class CDODefaultTransactionHandler implements CDOTransactionHandler	23	public abstract class CDODefaultTransactionHandler implements CDOTransactionHandler
23	{	24	{
		25
24	protected CDODefaultTransactionHandler()	26	protected CDODefaultTransactionHandler()
25	{	27	{
26	}	28	}
Lines 52-58 Link Here
52	/**	54	/**
53	* This implementation does nothing. Clients may override to provide specialized behaviour.	55	* This implementation does nothing. Clients may override to provide specialized behaviour.
54	*/	56	*/
55	public void committingTransaction(CDOTransaction transaction)	57	public void committingTransaction(CDOTransaction transaction, CDOCommitContext commitContext)
56	{	58	{
57	// Do nothing	59	// Do nothing
58	}	60	}
Lines 64-67 Link Here
64	{	66	{
65	// Do nothing	67	// Do nothing
66	}	68	}
		69
		70	/**
		71	* This implementation does nothing. Clients may override to provide specialized behaviour.
		72	*/
		73	public void committedTransaction(CDOTransaction transaction, CDOCommitContext commitContext)
		74	{
		75	// Do nothing
		76	}
67	}	77	}

Added Link Here

(-)src/org/eclipse/emf/cdo/CDOAdapterPolicy.java (+77 lines)
1	/***************************************************************************
2	* Copyright (c) 2004 - 2008 Eike Stepper, Germany.
3	* All rights reserved. This program and the accompanying materials
4	* are made available under the terms of the Eclipse Public License v1.0
5	* which accompanies this distribution, and is available at
6	* http://www.eclipse.org/legal/epl-v10.html
7	*
8	* Contributors:
9	* Simon McDuff - initial API and implementation
10	* Eike Stepper - maintenance
11	**************************************************************************/
12	package org.eclipse.emf.cdo;
13
14	import org.eclipse.emf.common.notify.Adapter;
15	import org.eclipse.emf.ecore.EObject;
16
17	/**
18	* Specifies an adapter policy.
19	* <p>
20	* To activate a policy, you must do the following: <br>
21	* <code>view.setChangeSubscriptionPolicy(CDOAdapterPolicy.ALL);</code>
22	* <p>
23	* To register an object, you must add an adapter to the object in which you are interested:<br>
24	* <code>eObject.eAdapters().add(myAdapter);</code>
25	* <p>
26	* By activating this feature, each object having at least one adapter that matches the current policy will be
27	* registered with the server and will be notified for each change occurring in the scope of any other transaction.
28	* <p>
29	* {@link CDOAdapterPolicy#NONE} - Disabled. <br>
30	* {@link CDOAdapterPolicy#ALL} - Enabled for all adapters used.<br>
31	* {@link CDOAdapterPolicy#ONLY_CDO_ADAPTER} - Enabled only for adapters that implement {@link CDOAdapter}. <br>
32	* Any other class that implement {@link CDOAdapterPolicy} will enable for whatever rules defined in that class. <br>
33	* <p>
34	* If <code>myAdapter</code> in the above example matches the current policy, <code>eObject</code> will be registered
35	* with the server and you will receive all changes from other transaction.
36	* <p>
37	* When the policy is changed all objects in the cache will automatically be recalculated.
38	* <p>
39	* You can subscribe to temporary objects. Even if you cannot receive notifications from other {@link CDOTransaction}
40	* for these because they are only local to you, at commit time these objects will be registered automatically.
41	* <p>
42	* <b>Note:</b> It can be used with <code>CDOSession.setPassiveUpdate(false)</code>. In this case, it will receive
43	* changes without having the objects changed.
44	*
45	* @author Simon McDuff
46	* @see CDOSessionInvalidationEvent
47	* @see CDOInvalidationNotification
48	* @since 2.0
49	*/
50	public interface CDOAdapterPolicy
51	{
52	public static final CDOAdapterPolicy NONE = new CDOAdapterPolicy()
53	{
54	public boolean valid(EObject eObject, Adapter adapter)
55	{
56	return false;
57	}
58	};
59
60	public static final CDOAdapterPolicy ONLY_CDO_ADAPTER = new CDOAdapterPolicy()
61	{
62	public boolean valid(EObject eObject, Adapter adapter)
63	{
64	return adapter instanceof CDOAdapter;
65	}
66	};
67
68	public static final CDOAdapterPolicy ALL = new CDOAdapterPolicy()
69	{
70	public boolean valid(EObject eObject, Adapter adapter)
71	{
72	return true;
73	}
74	};
75
76	public boolean valid(EObject eObject, Adapter adapter);
77	}

Added Link Here

(-)src/org/eclipse/emf/cdo/CDOCommitContext.java (+43 lines)
1	/***************************************************************************
2	* Copyright (c) 2004 - 2008 Eike Stepper, Germany.
3	* All rights reserved. This program and the accompanying materials
4	* are made available under the terms of the Eclipse Public License v1.0
5	* which accompanies this distribution, and is available at
6	* http://www.eclipse.org/legal/epl-v10.html
7	*
8	* Contributors:
9	* Simon McDuff - initial API and implementation
10	* Eike Stepper - maintenance
11	**************************************************************************/
12	package org.eclipse.emf.cdo;
13
14	import org.eclipse.emf.cdo.common.id.CDOID;
15	import org.eclipse.emf.cdo.common.model.CDOPackage;
16	import org.eclipse.emf.cdo.common.revision.delta.CDORevisionDelta;
17	import org.eclipse.emf.cdo.eresource.CDOResource;
18
19	import java.util.List;
20	import java.util.Map;
21
22	/**
23	* Provides a context for a commit operation.
24	*
25	* @author Simon McDuff
26	* @since 2.0
27	*/
28	public interface CDOCommitContext
29	{
30	public CDOTransaction getTransaction();
31
32	public List<CDOPackage> getNewPackages();
33
34	public Map<CDOID, CDOResource> getNewResources();
35
36	public Map<CDOID, CDOObject> getNewObjects();
37
38	public Map<CDOID, CDOObject> getDirtyObjects();
39
40	public Map<CDOID, CDORevisionDelta> getRevisionDeltas();
41
42	public Map<CDOID, CDOObject> getDetachedObjects();
43	}