import org.eclipse.emf.cdo.view.CDOView; //导入依赖的package包/类
/**
 * Checks for {@link CDOSessionInvalidationEvent#getDetachedObjects() detached objects}.
 * 
 * @param cdoSessionInvalidationEvent
 *            the {@link CDOSessionInvalidationEvent}
 */
protected void checkDetachedObjects(final CDOSessionInvalidationEvent cdoSessionInvalidationEvent) {
	final CDOView view = cdoSessionInvalidationEvent.getSource().openView(cdoSessionInvalidationEvent
			.getBranch(), cdoSessionInvalidationEvent.getPreviousTimeStamp());

	for (CDOIDAndVersion cdoidAndVersion : cdoSessionInvalidationEvent.getDetachedObjects()) {
		final CDOObject object = view.getObject(cdoidAndVersion.getID());
		if (object instanceof CDOResourceNode) {
			final CDOResourceNode node = (CDOResourceNode)object;
			for (IBase base : bases) {
				final ILocation repositoryLocation = MappingUtils.getConnectorRegistry().getLocation(base,
						view);
				if (repositoryLocation != null) {
					deleteResourceNode(repositoryLocation, node);
				}
			}
		} else {
			// TODO other deletions/resource change
		}
	}

	view.close();
}
 

import org.eclipse.emf.cdo.view.CDOView; //导入依赖的package包/类
/**
 * Renames the given {@link CDOResourceNode} and its contents if any.
 * 
 * @param newView
 *            the {@link CDOView} before changes
 * @param repositoryLocation
 *            the repository location
 * @param oldNode
 *            the {@link CDOResourceNode} before changes
 * @param newNode
 *            the {@link CDOResourceNode} after changes
 */
private void renameResourceNode(CDOView newView, ILocation repositoryLocation, CDOResourceNode oldNode,
		CDOResourceNode newNode) {
	final ILocation location = MappingUtils.getConnectorRegistry().getLocation(repositoryLocation,
			oldNode);
	if (location != null) {
		MappingUtils.getConnectorRegistry().updateLocation(location, newNode);
	}
	if (oldNode instanceof CDOResourceFolder) {
		for (CDOResourceNode oldChild : ((CDOResourceFolder)oldNode).getNodes()) {
			final CDOResourceNode newChild = (CDOResourceNode)newView.getObject(oldChild.cdoID());
			if (newChild != null) {
				renameResourceNode(newView, repositoryLocation, oldChild, newChild);
			}
		}
	}
}
 

import org.eclipse.emf.cdo.view.CDOView; //导入依赖的package包/类
/**
 * Updates changed {@link CDOResource}.
 * 
 * @param base
 *            the {@link IBase}
 * @param changedElements
 *            the {@link Set} of changed elements per {@link CDOView}
 */
private void resourceContentChanged(IBase base, Map<CDOView, Set<Object>> changedElements) {
	for (Entry<CDOView, Set<Object>> entry : changedElements.entrySet()) {
		final ILocation repositoryLocation = MappingUtils.getConnectorRegistry().getLocation(base, entry
				.getKey());
		if (repositoryLocation != null) {
			for (Object element : entry.getValue()) {
				final ILocation location = MappingUtils.getConnectorRegistry().getLocation(
						repositoryLocation, element);
				if (location != null) {
					MappingUtils.getConnectorRegistry().updateLocation(location, element);
				}
			}
		}
	}
}
 

import org.eclipse.emf.cdo.view.CDOView; //导入依赖的package包/类
/**
 * {@link IBaseRegistry#register(IBase) Registers} the given {@link BaseImpl}.
 * 
 * @param view
 *            the {@link CDOView}
 * @param base
 *            the {@link BaseImpl}
 */
protected void registerBase(CDOView view, BaseImpl base) {
	MappingUtils.getMappingRegistry().register(base);
	final CDOID cdoID = base.cdoID();
	Map<String, Map<Integer, BaseImpl>> repoMap = bases.get(cdoID);
	if (repoMap == null) {
		repoMap = new HashMap<String, Map<Integer, BaseImpl>>();
		bases.put(cdoID, repoMap);
	}
	final String uuid = view.getSession().getRepositoryInfo().getUUID();
	Map<Integer, BaseImpl> branchMap = repoMap.get(uuid);
	if (branchMap == null) {
		branchMap = new HashMap<Integer, BaseImpl>();
		repoMap.put(uuid, branchMap);
	}
	branchMap.put(view.getBranch().getID(), base);
	MappingUtils.getMappingRegistry().register(base);
}
 

import org.eclipse.emf.cdo.view.CDOView; //导入依赖的package包/类
/**
 * {@link IBaseRegistry#unregister(IBase) Unregisters} the given {@link BaseImpl}.
 * 
 * @param view
 *            the {@link CDOView}
 * @param base
 *            the {@link BaseImpl}
 */
protected void unregisterBase(CDOView view, BaseImpl base) {
	final CDOID cdoID = base.cdoID();
	final Map<String, Map<Integer, BaseImpl>> repoMap = bases.get(cdoID);
	if (repoMap != null) {
		final String uuid = view.getSession().getRepositoryInfo().getUUID();
		final Map<Integer, BaseImpl> branchMap = repoMap.get(uuid);
		if (branchMap != null) {
			final BaseImpl toRemove = branchMap.remove(view.getBranch().getID());
			if (toRemove != null) {
				MappingUtils.getMappingRegistry().unregister(toRemove);
				removeFromMap(cdoID, repoMap, uuid, branchMap);
			}
		}
	}
}
 

import org.eclipse.emf.cdo.view.CDOView; //导入依赖的package包/类
/**
 * Gets the resource of the textual diagram in the commit's current version.
 * 
 * @param commit
 *            the commit info of the commit
 * @param currentView
 *            the current view on the diagram
 * @return the corresponding resource
 */
public CDOResource getResource(CDOView currentView, IFile file) {
    ConcreteSyntaxModel concreteSyntaxModel = getConcreteSyntaxModel(currentView, file);
    if (concreteSyntaxModel == null) {
        return null;
    }
    EObject rootElement = concreteSyntaxModel.getRootElement();
    URI rootURI = EcoreUtil.getURI(rootElement);
    String resourcePath = CDOURIUtil.extractResourcePath(rootURI);
    try {
        return currentView.getResource(resourcePath);
    } catch (InvalidURIException e) {
        LOGGER.trace(e.getMessage(), e);
        return null;
    }
}
 

import org.eclipse.emf.cdo.view.CDOView; //导入依赖的package包/类
private static void reset(CDOView historicView, CDOTransaction transaction, IResource resource)
        throws IOException, ConcreteSyntaxTypeNotAvailableException {
    // configure resource sets
    ResourceSet historicRS = historicView.getResourceSet();
    ResourceSet currentRS = transaction.getResourceSet();
    historicRS.setResourceFactoryRegistry(
            CDOResourceHandler.createFactoryWrapper(historicRS.getResourceFactoryRegistry()));
    currentRS.setResourceFactoryRegistry(
            CDOResourceHandler.createFactoryWrapper(currentRS.getResourceFactoryRegistry()));

    // determine resources to reset
    Collection<URI> relevantUris;
    if (resource instanceof IFile) {
        relevantUris = findRelevantURIs(transaction, (IFile) resource);
    } else if (resource instanceof IProject) {
        relevantUris = findRelevantURIs(transaction, (IProject) resource);
    } else {
        throw new IllegalArgumentException("The selected resource is neither a project nor a file.");
    }

    reset(historicView, transaction, relevantUris);
}
 

import org.eclipse.emf.cdo.view.CDOView; //导入依赖的package包/类
private static CDOResourceFolder createCDOResource(IProject project, String cdoRepoPath,
		IListener listener) throws CommitException {
	CDOSession cdoSession = CDOConnectionManager.getInstance().acquireSession(project);
	CDOResourceFolder result = null;
	try {
		CDOView cdoView = cdoSession.openView();
		cdoView.addListener(listener);
		cdoView.options().addChangeSubscriptionPolicy(CDOAdapterPolicy.ALL);
		if (!cdoView.hasResource(cdoRepoPath)) {
			CDOTransaction transaction = cdoSession.openTransaction();
			transaction.createResourceFolder(cdoRepoPath);
			transaction.commit();
			transaction.close();
		}
		result = cdoView.getResourceFolder(cdoRepoPath);
		return result;
	} finally {
		if (result == null) {
			CDOConnectionManager.getInstance().releaseSession(cdoSession);
		}
	}
}
 

import org.eclipse.emf.cdo.view.CDOView; //导入依赖的package包/类
private void doFullCheckout() throws CoreException {
    CDOView view = getRepositoryFolder().cdoView();
    try {
        CDOTransferSystem target = new PathmapFilteringTransferSystem(WorkspaceTransferSystem.INSTANCE);
        RepositoryTransferSystem source = new RepositoryTransferSystem(view);

        cleanUpFolder(workspaceFolder);

        CDOTransfer transfer = new CDOTransferUMLFirst(source, target);
        transfer.setTargetPath(workspaceFolder.getFullPath());
        getRepositoryFolder().getNodes().forEach(n -> transfer.map(n.getPath(), new NullProgressMonitor()));

        // no default factory is registered in the CDO utilities
        transfer.getModelTransferContext().registerTargetExtension("*", new XMIResourceFactoryImpl());
        UMLUtil.init(transfer.getModelTransferContext().getTargetResourceSet());
        transfer.getModelTransferContext().getTargetResourceSet().getResource(UML_PRIMITIVE_TYPES_URI, true);

        transfer.perform();

        refreshFolder(workspaceFolder);
    } catch (RuntimeException e) {
        throw new CoreException(new Status(IStatus.ERROR, Activator.PLUGIN_ID, "Failed to transfer models", e));
    }
}
 

import org.eclipse.emf.cdo.view.CDOView; //导入依赖的package包/类
private static ModelNode[] createModelNodes(IProject project) {
	String resourceName = project.getName(); //TODO this should not be located here but at a central location
	CDOSession session = CDOConnectionManager.getInstance().acquireSession(project);
	try {
		CDOView view = session.openView();
		try {
			if (!view.hasResource(resourceName)) {
				return ArrayUtils.toArray();
			}
			CDOResourceFolder cdoFolder = view.getResourceFolder(resourceName);
			return cdoFolder.getNodes().stream().filter(n -> "notation".equals(n.getExtension())).filter(CDOResource.class::isInstance).map(r -> new ModelNode(getBaseName(r))).toArray(ModelNode[]::new);
		} finally {
			IOUtil.closeSilent(view);
		}
	} finally {
		CDOConnectionManager.getInstance().releaseSession(session);
	}
}
 

import org.eclipse.emf.cdo.view.CDOView; //导入依赖的package包/类
private void fixStaleReferences(CDOTransaction transaction) {
    Collection<CDOCommitInfo> infos = Lists.newArrayList();
    transaction.getSession().getCommitInfoManager().getCommitInfos(transaction.getBranch(), lastMergeTimeBranch,
            CDOView.UNSPECIFIED_DATE, infos::add);
    Set<CrossReferenceSetting> candidates = infos.stream()
            .flatMap(i -> findPossibleStaleReferences(transaction.getSession(), i).stream())
            .collect(Collectors.toSet());
    for (CrossReferenceSetting setting : candidates) {
        try {
            CDOObject eObject = transaction.getObject(setting.getObject());
            fixStaleReference(eObject, setting);
        } catch (ObjectNotFoundException e) {
            LOGGER.warn("Attempt to fix a stale reference on an non existing object.", e);
        }
    }
}
 

import org.eclipse.emf.cdo.view.CDOView; //导入依赖的package包/类
private static Set<CrossReferenceSetting> findPossibleStaleReferences(CDOSession session,
        CDOCommitInfo commitInfo) {
    CDOView historicView = session.openView(commitInfo.getBranch(), commitInfo.getTimeStamp() - 1);
    try {
        Set<CDOObject> detachedObjects = commitInfo.getDetachedObjects().stream().map(CDOIDAndVersion::getID)
                .map(historicView::getObject).collect(Collectors.toSet());
        if (detachedObjects.isEmpty()) {
            return Collections.emptySet();
        }
        return historicView.queryXRefs(detachedObjects, new EReference[0]).stream()
                .map(ref -> new CrossReferenceSetting((EReference) ref.getSourceFeature(),
                        ref.getSourceObject().cdoID()))
                .collect(Collectors.toSet());
    } finally {
        IOUtil.closeSilent(historicView);
    }
}
 

import org.eclipse.emf.cdo.view.CDOView; //导入依赖的package包/类
public static boolean isReadOnlyRequired(IFile launcherFile)
        throws IOException, ConcreteSyntaxTypeNotAvailableException {
    CDOSession session = CDOConnectionManager.getInstance().acquireSession(launcherFile.getProject());
    try {
        CDOView temporaryView = session.openView();
        try {
            Diagram launcherModel = loadDiagram(temporaryView, launcherFile);
            URI umlURI = determineUMLURI(launcherModel);
            return getWriteLock(temporaryView, umlURI).isLockedByOthers();
        } finally {
            IOUtil.closeSilent(temporaryView);
        }
    } finally {
        CDOConnectionManager.getInstance().releaseSession(session);
    }
}
 

import org.eclipse.emf.cdo.view.CDOView; //导入依赖的package包/类
@Override
public Optional<CDOView> getCDOView() {
    try {
        IPageManager pageManager = getEditorPart().getServicesRegistry().getService(IPageManager.class);
        Set<CDOView> cdoViews = pageManager.allPages().stream().filter(EObject.class::isInstance)
                .map(EObject.class::cast).map(EObject::eResource).filter(CDOResource.class::isInstance)
                .map(CDOResource.class::cast).map(CDOResource::cdoView).filter(Objects::nonNull)
                .collect(Collectors.toSet());
        if (cdoViews.isEmpty()) {
            LOGGER.warn("Could not find CDO view.");
        } else {
            if (cdoViews.size() > 1) {
                LOGGER.warn("Got multiple CDO views. Taking the first one.");
            }
            return Optional.of(cdoViews.iterator().next());
        }
    } catch (ServiceException e) {
        LOGGER.warn("Could not load services registry.", e);
    }
    return Optional.empty();
}
 

import org.eclipse.emf.cdo.view.CDOView; //导入依赖的package包/类
protected CDOView getView(QJob job) {

		if(view == null) {

			Map<String, CDOView> typedViews = views.get(job);
			if(typedViews == null) {
				typedViews =  new HashMap<String, CDOView>();
				views.put(job, typedViews);
			}
			else
				view = typedViews.get(klass.getName());

			if(view == null) {
				view = getSession().openView();
				typedViews.put(klass.getName(), view);
			}
		}
		return view;
	}
 

import org.eclipse.emf.cdo.view.CDOView; //导入依赖的package包/类
protected CDOView getView() {
	if(view == null) {
		
		Map<String, CDOView> typedViews = views.get(Thread.currentThread());
		if(typedViews == null) {
			typedViews =  new HashMap<String, CDOView>();
			views.put(Thread.currentThread(),typedViews);
		}
		else
			view = typedViews.get(klass.getName());
		
		if(view == null) {
			view = getSession().openView();
			typedViews.put(klass.getName(), view);
		}
	}
	return view;
}
 

import org.eclipse.emf.cdo.view.CDOView; //导入依赖的package包/类
/**
 * Lists {@link CDOResource} of the given {@link CDOView}.
 * 
 * @param view
 *            the {@link CDOView}
 * @return the {@link List} of {@link CDOResource} from the given {@link CDOView}
 */
public static List<CDOResource> getResources(CDOView view) {
    final List<CDOResource> res = new ArrayList<CDOResource>();

    for (EObject eObj : view.getRootResource().eContents()) {
        res.add((CDOResource) eObj);
    }

    return res;
}
 

import org.eclipse.emf.cdo.view.CDOView; //导入依赖的package包/类
/**
 * Lists {@link CDOResource} of the given {@link CDOView}.
 * 
 * @param view
 *            the {@link CDOView}
 * @return the {@link List} of {@link CDOResource} from the given {@link CDOView}
 */
public static List<CDOResource> getResources(CDOView view) {
	final List<CDOResource> res = new ArrayList<CDOResource>();

	for (EObject eObj : view.getRootResource().eContents()) {
		res.add((CDOResource)eObj);
	}

	return res;
}
 

import org.eclipse.emf.cdo.view.CDOView; //导入依赖的package包/类
/**
 * {@inheritDoc}
 *
 * @see org.eclipse.mylyn.docs.intent.mapping.connector.IConnector#getElement(org.eclipse.mylyn.docs.intent.mapping.base.ILocation)
 */
public Object getElement(ILocation location) {
	final CDOView cdoview = (CDOView)MappingUtils.getConnectorRegistry().getElement(
			(ICDORepositoryLocation)location.getContainer());

	return cdoview.getResourceNode(((ICDOResourceNodeLocation)location).getPath());
}
 

import org.eclipse.emf.cdo.view.CDOView; //导入依赖的package包/类
/**
 * Adds the given {@link CDOView} to the cache.
 * 
 * @param view
 *            the {@link CDOView} to add
 */
public void addSessionToCache(CDOView view) {
	Map<Integer, CDOView> map = viewCache.get(view.getSession().getRepositoryInfo().getUUID());
	if (map == null) {
		map = new HashMap<Integer, CDOView>();
		viewCache.put(view.getSession().getRepositoryInfo().getUUID(), map);
	}
	map.put(view.getBranch().getID(), view);

	view.getSession().addListener(this);
}