Skip to main content
summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
Diffstat (limited to 'plugins/org.eclipse.emf.cdo.net4j/src/org/eclipse/emf/cdo/internal/net4j/CDONet4jSessionConfigurationImpl.java')
-rw-r--r--plugins/org.eclipse.emf.cdo.net4j/src/org/eclipse/emf/cdo/internal/net4j/CDONet4jSessionConfigurationImpl.java600
1 files changed, 300 insertions, 300 deletions
diff --git a/plugins/org.eclipse.emf.cdo.net4j/src/org/eclipse/emf/cdo/internal/net4j/CDONet4jSessionConfigurationImpl.java b/plugins/org.eclipse.emf.cdo.net4j/src/org/eclipse/emf/cdo/internal/net4j/CDONet4jSessionConfigurationImpl.java
index 06a7f3f059..a1b399775d 100644
--- a/plugins/org.eclipse.emf.cdo.net4j/src/org/eclipse/emf/cdo/internal/net4j/CDONet4jSessionConfigurationImpl.java
+++ b/plugins/org.eclipse.emf.cdo.net4j/src/org/eclipse/emf/cdo/internal/net4j/CDONet4jSessionConfigurationImpl.java
@@ -1,300 +1,300 @@
-/*
- * Copyright (c) 2004 - 2012 Eike Stepper (Berlin, Germany) and others.
- * All rights reserved. This program and the accompanying materials
- * are made available under the terms of the Eclipse Public License v1.0
- * which accompanies this distribution, and is available at
- * http://www.eclipse.org/legal/epl-v10.html
- *
- * Contributors:
- * Eike Stepper - initial API and implementation
- * Andre Dietisheim - bug 256649
- */
-package org.eclipse.emf.cdo.internal.net4j;
-
-import org.eclipse.emf.cdo.common.id.CDOID;
-import org.eclipse.emf.cdo.net4j.CDONet4jSession;
-import org.eclipse.emf.cdo.net4j.CDOSession;
-import org.eclipse.emf.cdo.session.CDORepositoryInfo;
-
-import org.eclipse.emf.internal.cdo.session.CDOSessionConfigurationImpl;
-
-import org.eclipse.net4j.connector.IConnector;
-import org.eclipse.net4j.signal.SignalProtocol;
-import org.eclipse.net4j.util.CheckUtil;
-import org.eclipse.net4j.util.io.IStreamWrapper;
-
-import org.eclipse.emf.spi.cdo.CDOSessionProtocol.OpenSessionResult;
-import org.eclipse.emf.spi.cdo.CDOSessionProtocol.RepositoryTimeResult;
-import org.eclipse.emf.spi.cdo.InternalCDOSession;
-
-import java.util.Set;
-
-/**
- * @author Eike Stepper
- */
-@SuppressWarnings("deprecation")
-public class CDONet4jSessionConfigurationImpl extends CDOSessionConfigurationImpl implements
- org.eclipse.emf.cdo.net4j.CDOSessionConfiguration
-{
- private String repositoryName;
-
- private IConnector connector;
-
- private IStreamWrapper streamWrapper;
-
- private long signalTimeout = SignalProtocol.DEFAULT_TIMEOUT;
-
- public CDONet4jSessionConfigurationImpl()
- {
- }
-
- public String getRepositoryName()
- {
- return repositoryName;
- }
-
- public void setRepositoryName(String repositoryName)
- {
- this.repositoryName = repositoryName;
- }
-
- public IConnector getConnector()
- {
- return connector;
- }
-
- public void setConnector(IConnector connector)
- {
- checkNotOpen();
- uncheckedSetConnector(connector);
- }
-
- protected void uncheckedSetConnector(IConnector connector)
- {
- this.connector = connector;
- }
-
- public IStreamWrapper getStreamWrapper()
- {
- return streamWrapper;
- }
-
- public void setStreamWrapper(IStreamWrapper streamWrapper)
- {
- checkNotOpen();
- this.streamWrapper = streamWrapper;
- }
-
- public long getSignalTimeout()
- {
- return signalTimeout;
- }
-
- public void setSignalTimeout(long signalTimeout)
- {
- this.signalTimeout = signalTimeout;
- }
-
- public CDONet4jSession openNet4jSession()
- {
- return (CDONet4jSession)super.openSession();
- }
-
- @Override
- public CDOSession openSession()
- {
- return (CDOSession)openNet4jSession();
- }
-
- public InternalCDOSession createSession()
- {
- if (isActivateOnOpen())
- {
- CheckUtil.checkState(connector, "connector"); //$NON-NLS-1$
- }
-
- return new CDONet4jSessionImpl();
- }
-
- @Override
- protected void configureSession(InternalCDOSession session)
- {
- super.configureSession(session);
-
- CDONet4jSessionImpl sessionImpl = (CDONet4jSessionImpl)session;
- sessionImpl.setStreamWrapper(streamWrapper);
- sessionImpl.setConnector(connector);
- sessionImpl.setRepositoryName(repositoryName);
- sessionImpl.setSignalTimeout(signalTimeout);
- }
-
- /**
- * @author Eike Stepper
- */
- public static class RepositoryInfo implements CDORepositoryInfo
- {
- private String name;
-
- private String uuid;
-
- private Type type;
-
- private State state;
-
- private String storeType;
-
- private Set<CDOID.ObjectType> objectIDTypes;
-
- private long creationTime;
-
- private RepositoryTimeResult timeResult;
-
- private CDOID rootResourceID;
-
- private boolean supportingAudits;
-
- private boolean supportingBranches;
-
- private boolean supportingEcore;
-
- private boolean ensuringReferentialIntegrity;
-
- private IDGenerationLocation idGenerationLocation;
-
- private InternalCDOSession session;
-
- public RepositoryInfo(String name, OpenSessionResult result, InternalCDOSession session)
- {
- this.name = name;
- uuid = result.getRepositoryUUID();
- type = result.getRepositoryType();
- state = result.getRepositoryState();
- storeType = result.getStoreType();
- objectIDTypes = result.getObjectIDTypes();
- creationTime = result.getRepositoryCreationTime();
- timeResult = result.getRepositoryTimeResult();
- rootResourceID = result.getRootResourceID();
- supportingAudits = result.isRepositorySupportingAudits();
- supportingBranches = result.isRepositorySupportingBranches();
- supportingEcore = result.isRepositorySupportingEcore();
- ensuringReferentialIntegrity = result.isRepositoryEnsuringReferentialIntegrity();
- idGenerationLocation = result.getRepositoryIDGenerationLocation();
- this.session = session;
- }
-
- public String getName()
- {
- return name;
- }
-
- /**
- * Must be callable before session activation has finished!
- */
- public String getUUID()
- {
- return uuid;
- }
-
- public Type getType()
- {
- return type;
- }
-
- public void setType(Type type)
- {
- this.type = type;
- }
-
- public State getState()
- {
- return state;
- }
-
- public void setState(State state)
- {
- this.state = state;
- }
-
- public String getStoreType()
- {
- return storeType;
- }
-
- public Set<CDOID.ObjectType> getObjectIDTypes()
- {
- return objectIDTypes;
- }
-
- public long getCreationTime()
- {
- return creationTime;
- }
-
- public long getTimeStamp()
- {
- return getTimeStamp(false);
- }
-
- public long getTimeStamp(boolean forceRefresh)
- {
- if (timeResult == null || forceRefresh)
- {
- timeResult = refreshTime();
- }
-
- return timeResult.getAproximateRepositoryTime();
- }
-
- public CDOID getRootResourceID()
- {
- return rootResourceID;
- }
-
- public void setRootResourceID(CDOID rootResourceID)
- {
- // The rootResourceID may only be set if it is currently null
- if (this.rootResourceID == null || this.rootResourceID.isNull())
- {
- this.rootResourceID = rootResourceID;
- }
- else if (this.rootResourceID != null && this.rootResourceID.equals(rootResourceID))
- {
- // Do nothing; it is the same.
- }
- else
- {
- throw new IllegalStateException("rootResourceID must not be changed unless it is null");
- }
- }
-
- public boolean isSupportingAudits()
- {
- return supportingAudits;
- }
-
- public boolean isSupportingBranches()
- {
- return supportingBranches;
- }
-
- public boolean isSupportingEcore()
- {
- return supportingEcore;
- }
-
- public boolean isEnsuringReferentialIntegrity()
- {
- return ensuringReferentialIntegrity;
- }
-
- public IDGenerationLocation getIDGenerationLocation()
- {
- return idGenerationLocation;
- }
-
- private RepositoryTimeResult refreshTime()
- {
- return session.getSessionProtocol().getRepositoryTime();
- }
- }
-}
+/*
+ * Copyright (c) 2004 - 2012 Eike Stepper (Berlin, Germany) and others.
+ * All rights reserved. This program and the accompanying materials
+ * are made available under the terms of the Eclipse Public License v1.0
+ * which accompanies this distribution, and is available at
+ * http://www.eclipse.org/legal/epl-v10.html
+ *
+ * Contributors:
+ * Eike Stepper - initial API and implementation
+ * Andre Dietisheim - bug 256649
+ */
+package org.eclipse.emf.cdo.internal.net4j;
+
+import org.eclipse.emf.cdo.common.id.CDOID;
+import org.eclipse.emf.cdo.net4j.CDONet4jSession;
+import org.eclipse.emf.cdo.net4j.CDOSession;
+import org.eclipse.emf.cdo.session.CDORepositoryInfo;
+
+import org.eclipse.emf.internal.cdo.session.CDOSessionConfigurationImpl;
+
+import org.eclipse.net4j.connector.IConnector;
+import org.eclipse.net4j.signal.SignalProtocol;
+import org.eclipse.net4j.util.CheckUtil;
+import org.eclipse.net4j.util.io.IStreamWrapper;
+
+import org.eclipse.emf.spi.cdo.CDOSessionProtocol.OpenSessionResult;
+import org.eclipse.emf.spi.cdo.CDOSessionProtocol.RepositoryTimeResult;
+import org.eclipse.emf.spi.cdo.InternalCDOSession;
+
+import java.util.Set;
+
+/**
+ * @author Eike Stepper
+ */
+@SuppressWarnings("deprecation")
+public class CDONet4jSessionConfigurationImpl extends CDOSessionConfigurationImpl implements
+ org.eclipse.emf.cdo.net4j.CDOSessionConfiguration
+{
+ private String repositoryName;
+
+ private IConnector connector;
+
+ private IStreamWrapper streamWrapper;
+
+ private long signalTimeout = SignalProtocol.DEFAULT_TIMEOUT;
+
+ public CDONet4jSessionConfigurationImpl()
+ {
+ }
+
+ public String getRepositoryName()
+ {
+ return repositoryName;
+ }
+
+ public void setRepositoryName(String repositoryName)
+ {
+ this.repositoryName = repositoryName;
+ }
+
+ public IConnector getConnector()
+ {
+ return connector;
+ }
+
+ public void setConnector(IConnector connector)
+ {
+ checkNotOpen();
+ uncheckedSetConnector(connector);
+ }
+
+ protected void uncheckedSetConnector(IConnector connector)
+ {
+ this.connector = connector;
+ }
+
+ public IStreamWrapper getStreamWrapper()
+ {
+ return streamWrapper;
+ }
+
+ public void setStreamWrapper(IStreamWrapper streamWrapper)
+ {
+ checkNotOpen();
+ this.streamWrapper = streamWrapper;
+ }
+
+ public long getSignalTimeout()
+ {
+ return signalTimeout;
+ }
+
+ public void setSignalTimeout(long signalTimeout)
+ {
+ this.signalTimeout = signalTimeout;
+ }
+
+ public CDONet4jSession openNet4jSession()
+ {
+ return (CDONet4jSession)super.openSession();
+ }
+
+ @Override
+ public CDOSession openSession()
+ {
+ return (CDOSession)openNet4jSession();
+ }
+
+ public InternalCDOSession createSession()
+ {
+ if (isActivateOnOpen())
+ {
+ CheckUtil.checkState(connector, "connector"); //$NON-NLS-1$
+ }
+
+ return new CDONet4jSessionImpl();
+ }
+
+ @Override
+ protected void configureSession(InternalCDOSession session)
+ {
+ super.configureSession(session);
+
+ CDONet4jSessionImpl sessionImpl = (CDONet4jSessionImpl)session;
+ sessionImpl.setStreamWrapper(streamWrapper);
+ sessionImpl.setConnector(connector);
+ sessionImpl.setRepositoryName(repositoryName);
+ sessionImpl.setSignalTimeout(signalTimeout);
+ }
+
+ /**
+ * @author Eike Stepper
+ */
+ public static class RepositoryInfo implements CDORepositoryInfo
+ {
+ private String name;
+
+ private String uuid;
+
+ private Type type;
+
+ private State state;
+
+ private String storeType;
+
+ private Set<CDOID.ObjectType> objectIDTypes;
+
+ private long creationTime;
+
+ private RepositoryTimeResult timeResult;
+
+ private CDOID rootResourceID;
+
+ private boolean supportingAudits;
+
+ private boolean supportingBranches;
+
+ private boolean supportingEcore;
+
+ private boolean ensuringReferentialIntegrity;
+
+ private IDGenerationLocation idGenerationLocation;
+
+ private InternalCDOSession session;
+
+ public RepositoryInfo(String name, OpenSessionResult result, InternalCDOSession session)
+ {
+ this.name = name;
+ uuid = result.getRepositoryUUID();
+ type = result.getRepositoryType();
+ state = result.getRepositoryState();
+ storeType = result.getStoreType();
+ objectIDTypes = result.getObjectIDTypes();
+ creationTime = result.getRepositoryCreationTime();
+ timeResult = result.getRepositoryTimeResult();
+ rootResourceID = result.getRootResourceID();
+ supportingAudits = result.isRepositorySupportingAudits();
+ supportingBranches = result.isRepositorySupportingBranches();
+ supportingEcore = result.isRepositorySupportingEcore();
+ ensuringReferentialIntegrity = result.isRepositoryEnsuringReferentialIntegrity();
+ idGenerationLocation = result.getRepositoryIDGenerationLocation();
+ this.session = session;
+ }
+
+ public String getName()
+ {
+ return name;
+ }
+
+ /**
+ * Must be callable before session activation has finished!
+ */
+ public String getUUID()
+ {
+ return uuid;
+ }
+
+ public Type getType()
+ {
+ return type;
+ }
+
+ public void setType(Type type)
+ {
+ this.type = type;
+ }
+
+ public State getState()
+ {
+ return state;
+ }
+
+ public void setState(State state)
+ {
+ this.state = state;
+ }
+
+ public String getStoreType()
+ {
+ return storeType;
+ }
+
+ public Set<CDOID.ObjectType> getObjectIDTypes()
+ {
+ return objectIDTypes;
+ }
+
+ public long getCreationTime()
+ {
+ return creationTime;
+ }
+
+ public long getTimeStamp()
+ {
+ return getTimeStamp(false);
+ }
+
+ public long getTimeStamp(boolean forceRefresh)
+ {
+ if (timeResult == null || forceRefresh)
+ {
+ timeResult = refreshTime();
+ }
+
+ return timeResult.getAproximateRepositoryTime();
+ }
+
+ public CDOID getRootResourceID()
+ {
+ return rootResourceID;
+ }
+
+ public void setRootResourceID(CDOID rootResourceID)
+ {
+ // The rootResourceID may only be set if it is currently null
+ if (this.rootResourceID == null || this.rootResourceID.isNull())
+ {
+ this.rootResourceID = rootResourceID;
+ }
+ else if (this.rootResourceID != null && this.rootResourceID.equals(rootResourceID))
+ {
+ // Do nothing; it is the same.
+ }
+ else
+ {
+ throw new IllegalStateException("rootResourceID must not be changed unless it is null");
+ }
+ }
+
+ public boolean isSupportingAudits()
+ {
+ return supportingAudits;
+ }
+
+ public boolean isSupportingBranches()
+ {
+ return supportingBranches;
+ }
+
+ public boolean isSupportingEcore()
+ {
+ return supportingEcore;
+ }
+
+ public boolean isEnsuringReferentialIntegrity()
+ {
+ return ensuringReferentialIntegrity;
+ }
+
+ public IDGenerationLocation getIDGenerationLocation()
+ {
+ return idGenerationLocation;
+ }
+
+ private RepositoryTimeResult refreshTime()
+ {
+ return session.getSessionProtocol().getRepositoryTime();
+ }
+ }
+}

Back to the top