1 files changed, 0 insertions, 469 deletions
diff --git a/plugins/org.eclipse.emf.cdo/src/org/eclipse/emf/internal/cdo/CDOAdapterImpl.java b/plugins/org.eclipse.emf.cdo/src/org/eclipse/emf/internal/cdo/CDOAdapterImpl.java
deleted file mode 100644
index 79567994a8..0000000000
--- a/plugins/org.eclipse.emf.cdo/src/org/eclipse/emf/internal/cdo/CDOAdapterImpl.java
+++ /dev/null
@@ -1,469 +0,0 @@
-/***************************************************************************
- * Copyright (c) 2004-2007 Eike Stepper, Germany.
- * All rights reserved. This program and the accompanying materials
- * are made available under the terms of the Eclipse Public License v1.0
- * which accompanies this distribution, and is available at
- * http://www.eclipse.org/legal/epl-v10.html
- * 
- * Contributors:
- *    Eike Stepper - initial API and implementation
- **************************************************************************/
-package org.eclipse.emf.internal.cdo;
-
-import org.eclipse.emf.cdo.CDOAdapter;
-import org.eclipse.emf.cdo.CDOObject;
-import org.eclipse.emf.cdo.CDOState;
-import org.eclipse.emf.cdo.CDOView;
-import org.eclipse.emf.cdo.eresource.CDOResource;
-import org.eclipse.emf.cdo.eresource.EresourceFactory;
-import org.eclipse.emf.cdo.eresource.impl.CDOResourceImpl;
-import org.eclipse.emf.cdo.internal.protocol.event.CDOEventImpl;
-import org.eclipse.emf.cdo.internal.protocol.event.CDOEventSourceImpl;
-import org.eclipse.emf.cdo.internal.protocol.revision.CDORevisionImpl;
-import org.eclipse.emf.cdo.protocol.CDOID;
-import org.eclipse.emf.cdo.protocol.event.CDOInvalidationEvent;
-import org.eclipse.emf.cdo.protocol.model.CDOClass;
-import org.eclipse.emf.cdo.protocol.util.ImplementationError;
-import org.eclipse.emf.cdo.protocol.util.TransportException;
-import org.eclipse.emf.cdo.util.CDOUtil;
-
-import org.eclipse.net4j.util.om.trace.ContextTracer;
-
-import org.eclipse.emf.common.notify.Adapter;
-import org.eclipse.emf.common.notify.Notification;
-import org.eclipse.emf.common.notify.Notifier;
-import org.eclipse.emf.common.util.EList;
-import org.eclipse.emf.ecore.resource.Resource;
-import org.eclipse.emf.ecore.resource.ResourceSet;
-import org.eclipse.emf.internal.cdo.bundle.CDO;
-import org.eclipse.emf.internal.cdo.protocol.ResourcePathRequest;
-
-import java.text.MessageFormat;
-import java.util.HashMap;
-import java.util.Map;
-import java.util.Set;
-
-/**
- * @author Eike Stepper
- */
-public class CDOAdapterImpl extends CDOEventSourceImpl implements CDOAdapter, Adapter.Internal
-{
-  private static final ContextTracer TRACER = new ContextTracer(CDO.DEBUG_ADAPTER, CDOAdapterImpl.class);
-
-  private CDOSessionImpl session;
-
-  private ResourceSet resourceSet;
-
-  private CDOViewImpl view;
-
-  private CDOTransactionImpl transaction;
-
-  private Map<CDOID, CDOObjectImpl> objects = new HashMap();
-
-  public CDOAdapterImpl(CDOSessionImpl session, boolean readOnly)
-  {
-    this.session = session;
-    view = new CDOViewImpl(this, CDOView.UNSPECIFIED_DATE);
-    if (!readOnly)
-    {
-      transaction = new CDOTransactionImpl(this);
-    }
-  }
-
-  public CDOAdapterImpl(CDOSessionImpl session, long timeStamp)
-  {
-    this.session = session;
-    view = new CDOViewImpl(this, timeStamp);
-  }
-
-  public ResourceSet getResourceSet()
-  {
-    return resourceSet;
-  }
-
-  public CDOSessionImpl getSession()
-  {
-    return session;
-  }
-
-  public CDOViewImpl getView()
-  {
-    return view;
-  }
-
-  public CDOTransactionImpl getTransaction()
-  {
-    return transaction;
-  }
-
-  public boolean isActual()
-  {
-    return getView().isActual();
-  }
-
-  public boolean isHistorical()
-  {
-    return getView().isHistorical();
-  }
-
-  public boolean isReadOnly()
-  {
-    return transaction == null;
-  }
-
-  public CDOResource createResource(String path)
-  {
-    return (CDOResource)getResourceSet().createResource(CDOUtil.createURI(path));
-  }
-
-  public CDOResource getResource(String path)
-  {
-    return (CDOResource)getResourceSet().getResource(CDOUtil.createURI(path), true);
-  }
-
-  public CDOResourceImpl getResource(CDOID resourceID)
-  {
-    if (resourceID == null || resourceID == CDOID.NULL)
-    {
-      throw new ImplementationError("resourceID == null || resourceID == CDOID.NULL");
-    }
-
-    ResourceSet resourceSet = getResourceSet();
-    EList<Resource> resources = resourceSet.getResources();
-    for (Resource resource : resources)
-    {
-      if (resource instanceof CDOResourceImpl)
-      {
-        CDOResourceImpl cdoResource = (CDOResourceImpl)resource;
-        if (resourceID.equals(cdoResource.cdoID()))
-        {
-          return cdoResource;
-        }
-      }
-    }
-
-    try
-    {
-      ResourcePathRequest signal = new ResourcePathRequest(getSession().getChannel(), resourceID);
-      String path = signal.send();
-
-      CDOResourceImpl resource = (CDOResourceImpl)EresourceFactory.eINSTANCE.createCDOResource();
-      resource.setResourceSet(resourceSet);
-      resource.setPath(path);
-
-      CDOObjectImpl resourceObject = resource;
-      resourceObject.setID(resourceID);
-      resourceObject.setAdapter(this);
-      resourceObject.setResource(resource);
-      resourceObject.setState(CDOState.PROXY);
-
-      return resource;
-    }
-    catch (Exception ex)
-    {
-      throw new TransportException(ex);
-    }
-  }
-
-  public CDOObject lookupObject(CDOID id)
-  {
-    if (TRACER.isEnabled())
-    {
-      TRACER.format("Looking up object {0}", id);
-    }
-
-    CDOObjectImpl object = objects.get(id);
-    if (object == null)
-    {
-      object = createObjectFromView(id);
-      registerObject(object);
-    }
-
-    return object;
-  }
-
-  public void registerObject(CDOObjectImpl object)
-  {
-    if (TRACER.isEnabled())
-    {
-      TRACER.format("Registering object {0}", object);
-    }
-
-    CDOObjectImpl old = objects.put(object.cdoID(), object);
-    if (old != null)
-    {
-      throw new IllegalStateException("Duplicate ID: " + object);
-    }
-  }
-
-  public void deregisterObject(CDOObjectImpl object)
-  {
-    if (TRACER.isEnabled())
-    {
-      TRACER.format("Deregistering object {0}", object);
-    }
-
-    CDOObjectImpl old = objects.remove(object.cdoID());
-    if (old == null)
-    {
-      throw new IllegalStateException("Unknown ID: " + object);
-    }
-  }
-
-  public void remapObject(CDOID oldID)
-  {
-    CDOObjectImpl object = objects.remove(oldID);
-    CDOID newID = object.cdoID();
-    objects.put(newID, object);
-    if (TRACER.isEnabled())
-    {
-      TRACER.format("Remapping object: {0} --> {1}", oldID, newID);
-    }
-  }
-
-  /**
-   * Turns registered objects into proxies and synchronously delivers
-   * invalidation events to registered event listeners.
-   * <p>
-   * <b>Implementation note:</b> This implementation guarantees that exceptions
-   * from listener code don't propagate up to the caller of this method. Runtime
-   * exceptions from the implementation of the {@link CDOStateMachine} are
-   * propagated to the caller of this method but this should not happen in the
-   * absence of implementation errors.
-   * 
-   * @param timeStamp
-   *          The point in time when the newly committed revision have been
-   *          created.
-   * @param dirtyOIDs
-   *          A set of the object IDs to be invalidated. <b>Implementation note:</b>
-   *          This implementation expects the dirtyOIDs set to be unmodifiable.
-   *          It does not wrap the set (again).
-   */
-  public void notifyInvalidation(long timeStamp, Set<CDOID> dirtyOIDs)
-  {
-    for (CDOID dirtyOID : dirtyOIDs)
-    {
-      CDOObjectImpl object = objects.get(dirtyOID);
-      if (object != null)
-      {
-        CDOStateMachine.INSTANCE.invalidate(object, timeStamp);
-      }
-    }
-
-    fireObjectEvent(new CDOInvalidationEventImpl(timeStamp, dirtyOIDs));
-  }
-
-  public void commit()
-  {
-    checkWritable();
-    transaction.commit();
-  }
-
-  public void rollback()
-  {
-    checkWritable();
-    transaction.rollback();
-  }
-
-  public void detach()
-  {
-    session.adapterDetached(this);
-  }
-
-  @Override
-  public String toString()
-  {
-    return MessageFormat.format("CDOAdapter({0}, {1})", view.toString(), isReadOnly() ? "readOnly" : "readWrite");
-  }
-
-  public boolean isAdapterForType(Object type)
-  {
-    return type instanceof ResourceSet;
-  }
-
-  public Notifier getTarget()
-  {
-    return resourceSet;
-  }
-
-  public void setTarget(Notifier newTarget)
-  {
-    ResourceSet resourceSet = (ResourceSet)newTarget;
-    if (TRACER.isEnabled())
-    {
-      TRACER.trace("Attaching CDO adapter to " + resourceSet);
-    }
-
-    this.resourceSet = resourceSet;
-    for (Resource resource : resourceSet.getResources())
-    {
-      if (resource instanceof CDOResourceImpl)
-      {
-        CDOResourceImpl cdoResource = (CDOResourceImpl)resource;
-        CDOStateMachine.INSTANCE.attach(cdoResource, cdoResource, this);
-      }
-    }
-  }
-
-  public void unsetTarget(Notifier oldTarget)
-  {
-    ResourceSet resourceSet = (ResourceSet)oldTarget;
-    for (Resource resource : resourceSet.getResources())
-    {
-      if (resource instanceof CDOResourceImpl)
-      {
-        CDOResourceImpl cdoResource = (CDOResourceImpl)resource;
-        CDOStateMachine.INSTANCE.detach(cdoResource, cdoResource, this);
-      }
-    }
-
-    if (TRACER.isEnabled())
-    {
-      TRACER.trace("Detaching CDO adapter from " + resourceSet);
-    }
-
-    if (resourceSet == oldTarget)
-    {
-      setTarget(null);
-    }
-  }
-
-  public void notifyChanged(Notification msg)
-  {
-    switch (msg.getEventType())
-    {
-    case Notification.ADD:
-      notifyAdd(msg);
-      break;
-
-    case Notification.ADD_MANY:
-      notifyAddMany(msg);
-      break;
-
-    case Notification.REMOVE:
-      notifyRemove(msg);
-      break;
-
-    case Notification.REMOVE_MANY:
-      notifyRemoveMany(msg);
-      break;
-    }
-  }
-
-  private void notifyAdd(Notification msg)
-  {
-    if (msg.getNewValue() instanceof CDOResourceImpl)
-    {
-      CDOResourceImpl cdoResource = (CDOResourceImpl)msg.getNewValue();
-      CDOStateMachine.INSTANCE.attach(cdoResource, cdoResource, this);
-    }
-  }
-
-  private void notifyAddMany(Notification msg)
-  {
-    EList<Resource> newResources = (EList<Resource>)msg.getNewValue();
-    EList<Resource> oldResources = (EList<Resource>)msg.getOldValue();
-    for (Resource newResource : newResources)
-    {
-      if (newResource instanceof CDOResourceImpl)
-      {
-        if (!oldResources.contains(newResource))
-        {
-          CDOResourceImpl cdoResource = (CDOResourceImpl)newResource;
-          CDOStateMachine.INSTANCE.attach(cdoResource, cdoResource, this);
-        }
-      }
-    }
-  }
-
-  private void notifyRemove(Notification msg)
-  {
-    if (msg.getOldValue() instanceof CDOResourceImpl)
-    {
-      CDOResourceImpl cdoResource = (CDOResourceImpl)msg.getOldValue();
-      CDOStateMachine.INSTANCE.detach(cdoResource, cdoResource, this);
-    }
-  }
-
-  private void notifyRemoveMany(Notification msg)
-  {
-    EList<Resource> newResources = (EList<Resource>)msg.getNewValue();
-    EList<Resource> oldResources = (EList<Resource>)msg.getOldValue();
-    for (Resource oldResource : oldResources)
-    {
-      if (oldResource instanceof CDOResourceImpl)
-      {
-        if (!newResources.contains(oldResource))
-        {
-          CDOResourceImpl cdoResource = (CDOResourceImpl)oldResource;
-          CDOStateMachine.INSTANCE.detach(cdoResource, cdoResource, this);
-        }
-      }
-    }
-  }
-
-  private CDOObjectImpl createObjectFromView(CDOID id)
-  {
-    if (TRACER.isEnabled())
-    {
-      TRACER.format("Creating object from view: ID={0}", id);
-    }
-
-    CDORevisionImpl revision = view.resolve(id);
-    CDOClass cdoClass = revision.getCDOClass();
-    CDOID resourceID = revision.getResourceID();
-
-    CDOObjectImpl object = (CDOObjectImpl)CDOUtil.createObject(cdoClass);
-    if (object instanceof CDOResourceImpl)
-    {
-      object.setResource((CDOResourceImpl)object);
-    }
-    else
-    {
-      CDOResourceImpl resource = getResource(resourceID);
-      object.setResource(resource);
-    }
-
-    object.setRevision(revision);
-    object.setID(revision.getID());
-    object.setState(CDOState.CLEAN);
-    return object;
-  }
-
-  private void checkWritable()
-  {
-    if (isReadOnly())
-    {
-      throw new IllegalStateException("CDO adapter is read only");
-    }
-  }
-
-  public static class CDOInvalidationEventImpl extends CDOEventImpl implements CDOInvalidationEvent
-  {
-    private long timeStamp;
-
-    private Set<CDOID> dirtyOIDs;
-
-    public CDOInvalidationEventImpl(long timeStamp, Set<CDOID> dirtyOIDs)
-    {
-      this.timeStamp = timeStamp;
-      this.dirtyOIDs = dirtyOIDs;
-    }
-
-    public long getTimeStamp()
-    {
-      return timeStamp;
-    }
-
-    public Set<CDOID> getDirtyOIDs()
-    {
-      return dirtyOIDs;
-    }
-
-    @Override
-    public String toString()
-    {
-      return "CDOInvalidationEvent" + dirtyOIDs;
-    }
-  }
-}