1 files changed, 112 insertions, 0 deletions
diff --git a/plugins/org.eclipse.emf.cdo.server/src/org/eclipse/emf/cdo/internal/server/protocol/OpenSessionIndication.java b/plugins/org.eclipse.emf.cdo.server/src/org/eclipse/emf/cdo/internal/server/protocol/OpenSessionIndication.java
new file mode 100644
index 0000000000..4e1c01d633
--- /dev/null
+++ b/plugins/org.eclipse.emf.cdo.server/src/org/eclipse/emf/cdo/internal/server/protocol/OpenSessionIndication.java
@@ -0,0 +1,112 @@
+/***************************************************************************
+ * 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.cdo.internal.server.protocol;
+
+import org.eclipse.emf.cdo.internal.protocol.bundle.CDOProtocol;
+import org.eclipse.emf.cdo.internal.server.RepositoryImpl;
+import org.eclipse.emf.cdo.internal.server.RepositoryManagerImpl;
+import org.eclipse.emf.cdo.internal.server.SessionImpl;
+import org.eclipse.emf.cdo.internal.server.SessionManagerImpl;
+import org.eclipse.emf.cdo.protocol.CDOProtocolConstants;
+import org.eclipse.emf.cdo.server.Repository;
+import org.eclipse.emf.cdo.server.Session;
+
+import org.eclipse.net4j.signal.IndicationWithResponse;
+import org.eclipse.net4j.util.om.trace.ContextTracer;
+import org.eclipse.net4j.util.stream.ExtendedDataInputStream;
+import org.eclipse.net4j.util.stream.ExtendedDataOutputStream;
+
+import java.io.IOException;
+
+/**
+ * @author Eike Stepper
+ */
+public class OpenSessionIndication extends IndicationWithResponse
+{
+  private static final ContextTracer PROTOCOL = new ContextTracer(CDOProtocol.DEBUG_PROTOCOL,
+      OpenSessionIndication.class);
+
+  private String repositoryName;
+
+  public OpenSessionIndication()
+  {
+  }
+
+  @Override
+  protected short getSignalID()
+  {
+    return CDOProtocolConstants.OPEN_SESSION_SIGNAL;
+  }
+
+  @Override
+  protected void indicating(ExtendedDataInputStream in) throws IOException
+  {
+    repositoryName = in.readString();
+    if (PROTOCOL.isEnabled())
+    {
+      PROTOCOL.format("Read repositoryName: {0}", repositoryName);
+    }
+  }
+
+  @Override
+  protected void responding(ExtendedDataOutputStream out) throws IOException
+  {
+    RepositoryImpl repository = RepositoryManagerImpl.INSTANCE.getRepository(repositoryName);
+    if (repository == null)
+    {
+      if (PROTOCOL.isEnabled())
+      {
+        PROTOCOL.format("Repository {0} not found", repositoryName);
+      }
+
+      out.writeInt(CDOProtocolConstants.ERROR_REPOSITORY_NOT_FOUND);
+      return;
+    }
+
+    CDOServerProtocol serverProtocol = (CDOServerProtocol)getProtocol();
+    SessionManagerImpl sessionManager = repository.getSessionManager();
+    SessionImpl session = sessionManager.openSession(serverProtocol);
+    if (session == null)
+    {
+      if (PROTOCOL.isEnabled())
+      {
+        PROTOCOL.format("Failed to open session for repository {0}", repositoryName);
+      }
+
+      out.writeInt(CDOProtocolConstants.ERROR_NO_SESSION);
+      return;
+    }
+
+    (serverProtocol).setSession(session);
+    writeSessionID(out, session);
+    writeRepositoryUUID(out, repository);
+  }
+
+  private void writeSessionID(ExtendedDataOutputStream out, Session session) throws IOException
+  {
+    if (PROTOCOL.isEnabled())
+    {
+      PROTOCOL.format("Writing sessionID: {0}", session.getSessionID());
+    }
+
+    out.writeInt(session.getSessionID());
+  }
+
+  private void writeRepositoryUUID(ExtendedDataOutputStream out, Repository repository) throws IOException
+  {
+    if (PROTOCOL.isEnabled())
+    {
+      PROTOCOL.format("Writing repositoryUUID: {0}", repository.getUUID());
+    }
+
+    out.writeString(repository.getUUID());
+  }
+}