import org.eclipse.emf.cdo.CDOObject; //导入依赖的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.CDOObject; //导入依赖的package包/类
@Override
public void sendCurrentlyFocusedElement() {
    Optional<Element> element = focusManager.getFocusedElement();
    if (!element.isPresent()) {
        LOGGER.info("No element focused.");
        return;
    }

    Optional<IDiagramType> currentDiagramType = focusManager.getDiagramType();
    if (!currentDiagramType.isPresent()) {
        LOGGER.info("Diagram type could not be detected.");
        return;
    }

    Element focusedElement = element.get();

    try {
        CDOObject cdoObject = CDOUtil.getCDOObject(focusedElement);
        messageHandler.sendFocus(cdoObject);
        LOGGER.debug("sendCurrentlyFocusedElement element={}", cdoObject);

    } catch (Exception e) {
        LOGGER.error("Could not send focus request.", e);
    }

}
 

import org.eclipse.emf.cdo.CDOObject; //导入依赖的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.CDOObject; //导入依赖的package包/类
private static void fixStaleReference(CDOObject eObject, CrossReferenceSetting setting) {
    EReference eReference = setting.getReference();
    if (eObject == null) {
        return;
    }
    Object value = eObject.eGet(eReference, true);
    if (value instanceof EObject && CDOUtil.isStaleObject(value)) {
        CDOUtil.cleanStaleReference(eObject, eReference);
    } else if (value instanceof List<?>) {
        List<?> list = (List<?>) value;
        for (Object o : list) {
            if (CDOUtil.isStaleObject(o)) {
                int index = list.indexOf(o);
                CDOUtil.cleanStaleReference(eObject, eReference, index);
            }
        }
    }
}
 

import org.eclipse.emf.cdo.CDOObject; //导入依赖的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.CDOObject; //导入依赖的package包/类
@Override
	public boolean tryLock(QJob job, QSystem object, long time, LockType lockType) {
		try {
			CDOObject cdoSystem = CDOUtil.getCDOObject((EObject)object);		
//				cdoSystem = transaction.getObject(cdoSystem.cdoID(), true);
			
			// lock system for shared synchronization
			CDOLock lock = cdoSystem.cdoWriteLock();
			
			// locked by this view or others
			if(lock.isLocked() || lock.isLockedByOthers())
				return false;

			return lock.tryLock(time);
		} catch (InterruptedException e) {
			System.err.println(e.getMessage());
			return false;
		}
		
	}
 

import org.eclipse.emf.cdo.CDOObject; //导入依赖的package包/类
@Override
	public boolean tryLock(QJob job, T object, long time, LockType lockType) {
		try {

			CDOObject cdoObject = CDOUtil.getCDOObject((EObject)object);
//				cdoSystem = transaction.getObject(cdoSystem.cdoID(), true);

			// lock system for shared synchronization
			CDOLock lock = cdoObject.cdoWriteLock();

			// locked by this view or others
//			if(lock.isLocked() || lock.isLockedByOthers())
//				return false;

			return lock.tryLock(time, TimeUnit.SECONDS);
		}
		catch (InterruptedException e) {
			System.err.println(e.getMessage());
			return false;
		}

	}
 

import org.eclipse.emf.cdo.CDOObject; //导入依赖的package包/类
private static JsonNode data(ObjectMapper mapper, EObject o) {
	CDOObject oo = CDOUtil.getCDOObject(o);
	long i = CDOIDUtil.getLong(CDOIDUtil.getCDOID(oo));

	return mapper.createObjectNode()
			.put("eClass", "org.emfjson.sample.model#//User")
			.put("name", "Frank")
			.set("friends", mapper.createArrayNode()
					.add(i));
}
 

import org.eclipse.emf.cdo.CDOObject; //导入依赖的package包/类
@Override
public void serialize(EObject source, EObject value, JsonGenerator jg, SerializerProvider provider) throws IOException {
	final CDOObject cdoObject = CDOUtil.getCDOObject(value);
	final CDOID cdoid = CDOIDUtil.getCDOID(cdoObject);

	if (cdoid != null) {
		jg.writeNumber(CDOIDUtil.getLong(cdoid));
	} else {
		jg.writeNull();
	}
}
 

import org.eclipse.emf.cdo.CDOObject; //导入依赖的package包/类
@Override
public void serialize(EObject object, JsonGenerator jg, SerializerProvider provider) throws IOException {
	final JacksonOptions options = (JacksonOptions) provider.getAttribute("options");
	final CDOObject cdoObject = CDOUtil.getCDOObject(object);
	final CDOID cdoid = CDOIDUtil.getCDOID(cdoObject);

	jg.writeNumberField(options.idField, CDOIDUtil.getLong(cdoid));
}
 

import org.eclipse.emf.cdo.CDOObject; //导入依赖的package包/类
/**
 * Checks for {@link CDOSessionInvalidationEvent#getNewObjects() attached objects}.
 * 
 * @param cdoSessionInvalidationEvent
 *            the {@link CDOSessionInvalidationEvent}
 */
protected void checkAttachedObjects(CDOSessionInvalidationEvent cdoSessionInvalidationEvent) {
	final CDOView view = cdoSessionInvalidationEvent.getLocalTransaction();

	for (CDOIDAndVersion cdoidAndVersion : cdoSessionInvalidationEvent.getNewObjects()) {
		final CDOObject object = view.getObject(cdoidAndVersion.getID());
		if (object instanceof BaseImpl) {
			registerBase(view, (BaseImpl)object);
		}
	}
}
 

import org.eclipse.emf.cdo.CDOObject; //导入依赖的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 BaseImpl) {
			unregisterBase(view, (BaseImpl)object);
		}
	}

	view.close();
}
 

import org.eclipse.emf.cdo.CDOObject; //导入依赖的package包/类
private static void initStateOfObject(CDOView view, CDOID cdoid) {
    CDOObject cdoObject = getCDOObjectById(view, cdoid);
    if (cdoObject == null) {
        return;
    }
    String nsURI = cdoObject.eClass().getEPackage().getNsURI();

    Optional<IDerivedStateProcessor> extension = DerivedStateCalculatorRegistry.INSTANCE.getExtension(nsURI);
    if (extension.isPresent()) {
        IDerivedStateProcessor prevDerivedStateProcessor = extension.get();
        prevDerivedStateProcessor.initState(cdoObject, true);
    }
}
 

import org.eclipse.emf.cdo.CDOObject; //导入依赖的package包/类
private static CDOObject getCDOObjectById(CDOView view, CDOID cdoid) {
    try {
        return view.getObject(cdoid);
    } catch (Exception e) {
        LOGGER.warn(e.getMessage(), e);
        return null;
    }
}
 

import org.eclipse.emf.cdo.CDOObject; //导入依赖的package包/类
private static CDOID getResourceCDOId(ConcreteSyntaxModel textModel) {
    CDOObject textRoot = CDOUtil.getCDOObject(textModel.getRootElement());
    CDOResource cdoResource = textRoot.cdoResource();
    if (cdoResource == null) {
        return null;
    }
    return cdoResource.cdoID();
}
 

import org.eclipse.emf.cdo.CDOObject; //导入依赖的package包/类
private void handleFocusRequest(CDOObject object, long timestamp) {
    LOGGER.debug("handleFocusRequest for id={} at t={}", object.cdoID(), timestamp);
    history.add(new HistoryElement(object, timestamp));
    historyChangedListeners.forEach(l -> l.historyChanged(this));
    if (!mute) {
        Display.getDefault().syncExec(() -> showFocusDialog(object));
    }
}
 

import org.eclipse.emf.cdo.CDOObject; //导入依赖的package包/类
private void showFocusDialog(CDOObject object) {
    Shell shell = PlatformUI.getWorkbench().getActiveWorkbenchWindow().getShell();
    String elementLabel = LabelUtils.getEObjectLabel(object);
    String message = elementLabel + " has been focused. Would you like to jump to it?";
    Toolkit.getDefaultToolkit().beep();
    if (MessageDialog.openConfirm(shell, "Incoming element focus", message)) {
        setFocusedElement(object);
    }
}
 

import org.eclipse.emf.cdo.CDOObject; //导入依赖的package包/类
@Override
public void handleFocusRequest(String diagramIdentifier, CDOID elementID) {
    Optional<CDOView> cdoView = viewProvider.get();
    if (!cdoView.isPresent()) {
        LOGGER.warn("Could not recover object by ID because of missing CDO view.");
        return;
    }
    CDOObject object = cdoView.get().getObject(elementID);
    focusRequestHandler.handleFocusRequest(object, System.currentTimeMillis());
}
 

import org.eclipse.emf.cdo.CDOObject; //导入依赖的package包/类
private void selectAppropriateModel(IEditorPart editorPart) throws PartInitException {
    try {
        ServicesRegistry servicesRegistry = getServicesRegistery(editorPart);
        EObject rootObject = getConcreteSyntaxModel().getRootElement();
        CDOObject rootObjectCDO = CDOUtil.getCDOObject(rootObject);
        final CDOID rootObjectID = rootObjectCDO.cdoID();
        IPageManager pageManager = servicesRegistry.getService(IPageManager.class);
        Optional<CDOObject> pagedElement = pageManager.allPages().stream().filter(p -> p instanceof EObject)
                .map(p -> (EObject) p).map(CDOUtil::getCDOObject).filter(o -> rootObjectID.equals(o.cdoID()))
                .findFirst();

        if (pagedElement.isPresent()) {
            pageManager.closeOtherPages(pagedElement.get());
            rootObject = pagedElement.get();
        }

        // enforce loading of primitive types
        ResourceSet rs = rootObject.eResource().getResourceSet();
        if (rs != null) {
            rs.getResource(UML_PRIMITIVE_TYPES_URI, true);
        } else {
            LOGGER.warn("The element about to be selected is not contained in a resource set.");
        }

        OpenElementService openElementService = servicesRegistry.getService(OpenElementService.class);
        openElementService.openElement(rootObject);
    } catch (ServiceException e) {
        throw new PartInitException("Could not select the correct diagram.", e);
    }
}
 

import org.eclipse.emf.cdo.CDOObject; //导入依赖的package包/类
private boolean isDirectlyContainedInRepositoryFolder(CDOObject o) {
	if (!o.cdoInvalid()) {
		URI resourceURI = null;
		if (o.cdoResource() != null) {
			resourceURI = o.cdoResource().getURI();
		}
		if (o instanceof CDOResourceNode) {
			resourceURI = ((CDOResourceNode)o).getURI();
		}
		return isChild(repositoryFolder.getURI(), resourceURI);
	}

	return false;
}