diff options
Diffstat (limited to 'plugins/org.eclipse.osee.framework.core.client/src/org/eclipse/osee/framework/core/client/internal/OseeApplicationServer.java')
| -rw-r--r-- | plugins/org.eclipse.osee.framework.core.client/src/org/eclipse/osee/framework/core/client/internal/OseeApplicationServer.java | 362 |
1 files changed, 181 insertions, 181 deletions
diff --git a/plugins/org.eclipse.osee.framework.core.client/src/org/eclipse/osee/framework/core/client/internal/OseeApplicationServer.java b/plugins/org.eclipse.osee.framework.core.client/src/org/eclipse/osee/framework/core/client/internal/OseeApplicationServer.java index 884dc3aab28..e997bb108a4 100644 --- a/plugins/org.eclipse.osee.framework.core.client/src/org/eclipse/osee/framework/core/client/internal/OseeApplicationServer.java +++ b/plugins/org.eclipse.osee.framework.core.client/src/org/eclipse/osee/framework/core/client/internal/OseeApplicationServer.java @@ -1,181 +1,181 @@ -/*******************************************************************************
- * Copyright (c) 2004, 2007 Boeing.
- * 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:
- * Boeing - initial API and implementation
- *******************************************************************************/
-
-package org.eclipse.osee.framework.core.client.internal;
-
-import java.io.ByteArrayInputStream;
-import java.io.ByteArrayOutputStream;
-import java.io.IOException;
-import java.io.InputStream;
-import java.net.HttpURLConnection;
-import java.net.URL;
-import java.sql.Timestamp;
-import java.text.DateFormat;
-import java.text.SimpleDateFormat;
-import java.util.Arrays;
-import java.util.Date;
-import java.util.HashMap;
-import java.util.Map;
-import java.util.logging.Level;
-import java.util.regex.Matcher;
-import java.util.regex.Pattern;
-
-import org.eclipse.osee.framework.core.client.CoreClientActivator;
-import org.eclipse.osee.framework.core.client.OseeClientProperties;
-import org.eclipse.osee.framework.core.client.server.HttpUrlBuilderClient;
-import org.eclipse.osee.framework.core.data.OseeCodeVersion;
-import org.eclipse.osee.framework.core.data.OseeServerContext;
-import org.eclipse.osee.framework.core.data.OseeServerInfo;
-import org.eclipse.osee.framework.core.exception.OseeArbitrationServerException;
-import org.eclipse.osee.framework.core.exception.OseeDataStoreException;
-import org.eclipse.osee.framework.core.util.HttpProcessor;
-import org.eclipse.osee.framework.core.util.HttpProcessor.AcquireResult;
-import org.eclipse.osee.framework.jdk.core.util.Strings;
-import org.eclipse.osee.framework.logging.BaseStatus;
-import org.eclipse.osee.framework.logging.OseeLog;
-
-/**
- * @author Andrew M. Finkbeiner
- */
-public class OseeApplicationServer {
-
- private static String oseeServer = null;
- private static boolean isServerAlive = false;
- private static OseeServerInfo serverInfo = null;
- private static final String ArbitrationService = "Arbitration Server";
- private static final String ApplicationServer = "Application Server";
-
- private OseeApplicationServer() {
- }
-
- public static String getOseeApplicationServer() throws OseeArbitrationServerException {
- checkAndUpdateStatus();
- if (Strings.isValid(oseeServer) != true) {
- throw new OseeArbitrationServerException("Invalid resource server address");
- }
- return oseeServer;
- }
-
- public static boolean isApplicationServerAlive() {
- checkAndUpdateStatus();
- return isServerAlive;
- }
-
- private static void checkAndUpdateStatus() {
- isServerAlive = false;
- if (serverInfo == null) {
- String overrideValue = OseeClientProperties.getOseeApplicationServer();
- if (Strings.isValid(overrideValue)) {
- serverInfo = fromString(overrideValue);
- }
- else {
- serverInfo = getOseeServerAddress();
- }
- if (serverInfo != null) {
- oseeServer = String.format("http://%s:%s/", serverInfo.getServerAddress(),
- serverInfo.getPort());
- }
- }
- DateFormat format = new SimpleDateFormat("MM/dd/yyyy hh:mm a");
- if (serverInfo == null) {
- OseeLog.reportStatus(new BaseStatus(ApplicationServer, Level.SEVERE,
- "Application server address was null"));
- }
- else {
- isServerAlive = HttpProcessor.isAlive(serverInfo.getServerAddress(), serverInfo.getPort());
- if (isServerAlive) {
- OseeLog.reportStatus(new BaseStatus(ApplicationServer, Level.INFO,
- "%s %s Running Since: %s", oseeServer,
- Arrays.deepToString(serverInfo.getVersion()),
- format.format(serverInfo.getDateStarted())));
- }
- else {
- OseeLog.reportStatus(new BaseStatus(ApplicationServer, Level.SEVERE,
- "Unable to Connect to [%s]", oseeServer));
- }
- }
- }
-
- public static OseeServerInfo fromString(String value) {
- OseeServerInfo toReturn = null;
- String rawAddress = value;
- if (rawAddress.startsWith("http")) {
- rawAddress = value.replace("http://", "");
- }
- Pattern pattern = Pattern.compile("(.*):(\\d+)");
- Matcher matcher = pattern.matcher(rawAddress);
- if (matcher.find()) {
- String address = matcher.group(1);
- int port = Integer.valueOf(matcher.group(2));
- toReturn = new OseeServerInfo("OVERRIDE", address, port, new String[] {"OVERRIDE"},
- new Timestamp(new Date().getTime()), true);
- }
- return toReturn;
- }
-
- private static OseeServerInfo getOseeServerAddress() {
- OseeServerInfo oseeServerInfo = null;
- ByteArrayOutputStream outputStream = null;
- InputStream inputStream = null;
- try {
- Map<String, String> parameters = new HashMap<String, String>();
- parameters.put("version", OseeCodeVersion.getVersion());
- String url = HttpUrlBuilderClient.getInstance().getOsgiArbitrationServiceUrl(
- OseeServerContext.LOOKUP_CONTEXT,
- parameters);
-
- outputStream = new ByteArrayOutputStream();
- AcquireResult result = HttpProcessor.acquire(new URL(url), outputStream);
- try {
- OseeLog.reportStatus(new BaseStatus(
- ArbitrationService,
- Level.INFO,
- "%s",
- HttpUrlBuilderClient.getInstance().getArbitrationServerPrefix()));
- }
- catch (OseeDataStoreException ex) {
- OseeLog.log(CoreClientActivator.class, Level.SEVERE, ex);
- }
- if (result.getCode() == HttpURLConnection.HTTP_OK) {
- inputStream = new ByteArrayInputStream(outputStream.toByteArray());
- oseeServerInfo = OseeServerInfo.fromXml(inputStream);
- }
- }
- catch (Exception ex) {
- OseeLog.log(CoreClientActivator.class, Level.SEVERE, ex);
- OseeLog.reportStatus(new BaseStatus(
- ArbitrationService,
- Level.SEVERE,
- ex,
- "Error requesting application server for version [%s]",
- OseeCodeVersion.getVersion()));
- }
- finally {
- if (inputStream != null) {
- try {
- inputStream.close();
- }
- catch (IOException ex) {
- OseeLog.log(CoreClientActivator.class, Level.SEVERE, ex);
- }
- }
- if (outputStream != null) {
- try {
- outputStream.close();
- }
- catch (IOException ex) {
- OseeLog.log(CoreClientActivator.class, Level.SEVERE, ex);
- }
- }
- }
- return oseeServerInfo;
- }
-}
+/******************************************************************************* + * Copyright (c) 2004, 2007 Boeing. + * 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: + * Boeing - initial API and implementation + *******************************************************************************/ + +package org.eclipse.osee.framework.core.client.internal; + +import java.io.ByteArrayInputStream; +import java.io.ByteArrayOutputStream; +import java.io.IOException; +import java.io.InputStream; +import java.net.HttpURLConnection; +import java.net.URL; +import java.sql.Timestamp; +import java.text.DateFormat; +import java.text.SimpleDateFormat; +import java.util.Arrays; +import java.util.Date; +import java.util.HashMap; +import java.util.Map; +import java.util.logging.Level; +import java.util.regex.Matcher; +import java.util.regex.Pattern; + +import org.eclipse.osee.framework.core.client.CoreClientActivator; +import org.eclipse.osee.framework.core.client.OseeClientProperties; +import org.eclipse.osee.framework.core.client.server.HttpUrlBuilderClient; +import org.eclipse.osee.framework.core.data.OseeCodeVersion; +import org.eclipse.osee.framework.core.data.OseeServerContext; +import org.eclipse.osee.framework.core.data.OseeServerInfo; +import org.eclipse.osee.framework.core.exception.OseeArbitrationServerException; +import org.eclipse.osee.framework.core.exception.OseeDataStoreException; +import org.eclipse.osee.framework.core.util.HttpProcessor; +import org.eclipse.osee.framework.core.util.HttpProcessor.AcquireResult; +import org.eclipse.osee.framework.jdk.core.util.Strings; +import org.eclipse.osee.framework.logging.BaseStatus; +import org.eclipse.osee.framework.logging.OseeLog; + +/** + * @author Andrew M. Finkbeiner + */ +public class OseeApplicationServer { + + private static String oseeServer = null; + private static boolean isServerAlive = false; + private static OseeServerInfo serverInfo = null; + private static final String ArbitrationService = "Arbitration Server"; + private static final String ApplicationServer = "Application Server"; + + private OseeApplicationServer() { + } + + public static String getOseeApplicationServer() throws OseeArbitrationServerException { + checkAndUpdateStatus(); + if (Strings.isValid(oseeServer) != true) { + throw new OseeArbitrationServerException("Invalid resource server address"); + } + return oseeServer; + } + + public static boolean isApplicationServerAlive() { + checkAndUpdateStatus(); + return isServerAlive; + } + + private static void checkAndUpdateStatus() { + isServerAlive = false; + if (serverInfo == null) { + String overrideValue = OseeClientProperties.getOseeApplicationServer(); + if (Strings.isValid(overrideValue)) { + serverInfo = fromString(overrideValue); + } + else { + serverInfo = getOseeServerAddress(); + } + if (serverInfo != null) { + oseeServer = String.format("http://%s:%s/", serverInfo.getServerAddress(), + serverInfo.getPort()); + } + } + DateFormat format = new SimpleDateFormat("MM/dd/yyyy hh:mm a"); + if (serverInfo == null) { + OseeLog.reportStatus(new BaseStatus(ApplicationServer, Level.SEVERE, + "Application server address was null")); + } + else { + isServerAlive = HttpProcessor.isAlive(serverInfo.getServerAddress(), serverInfo.getPort()); + if (isServerAlive) { + OseeLog.reportStatus(new BaseStatus(ApplicationServer, Level.INFO, + "%s %s Running Since: %s", oseeServer, + Arrays.deepToString(serverInfo.getVersion()), + format.format(serverInfo.getDateStarted()))); + } + else { + OseeLog.reportStatus(new BaseStatus(ApplicationServer, Level.SEVERE, + "Unable to Connect to [%s]", oseeServer)); + } + } + } + + public static OseeServerInfo fromString(String value) { + OseeServerInfo toReturn = null; + String rawAddress = value; + if (rawAddress.startsWith("http")) { + rawAddress = value.replace("http://", ""); + } + Pattern pattern = Pattern.compile("(.*):(\\d+)"); + Matcher matcher = pattern.matcher(rawAddress); + if (matcher.find()) { + String address = matcher.group(1); + int port = Integer.valueOf(matcher.group(2)); + toReturn = new OseeServerInfo("OVERRIDE", address, port, new String[] {"OVERRIDE"}, + new Timestamp(new Date().getTime()), true); + } + return toReturn; + } + + private static OseeServerInfo getOseeServerAddress() { + OseeServerInfo oseeServerInfo = null; + ByteArrayOutputStream outputStream = null; + InputStream inputStream = null; + try { + Map<String, String> parameters = new HashMap<String, String>(); + parameters.put("version", OseeCodeVersion.getVersion()); + String url = HttpUrlBuilderClient.getInstance().getOsgiArbitrationServiceUrl( + OseeServerContext.LOOKUP_CONTEXT, + parameters); + + outputStream = new ByteArrayOutputStream(); + AcquireResult result = HttpProcessor.acquire(new URL(url), outputStream); + try { + OseeLog.reportStatus(new BaseStatus( + ArbitrationService, + Level.INFO, + "%s", + HttpUrlBuilderClient.getInstance().getArbitrationServerPrefix())); + } + catch (OseeDataStoreException ex) { + OseeLog.log(CoreClientActivator.class, Level.SEVERE, ex); + } + if (result.getCode() == HttpURLConnection.HTTP_OK) { + inputStream = new ByteArrayInputStream(outputStream.toByteArray()); + oseeServerInfo = OseeServerInfo.fromXml(inputStream); + } + } + catch (Exception ex) { + OseeLog.log(CoreClientActivator.class, Level.SEVERE, ex); + OseeLog.reportStatus(new BaseStatus( + ArbitrationService, + Level.SEVERE, + ex, + "Error requesting application server for version [%s]", + OseeCodeVersion.getVersion())); + } + finally { + if (inputStream != null) { + try { + inputStream.close(); + } + catch (IOException ex) { + OseeLog.log(CoreClientActivator.class, Level.SEVERE, ex); + } + } + if (outputStream != null) { + try { + outputStream.close(); + } + catch (IOException ex) { + OseeLog.log(CoreClientActivator.class, Level.SEVERE, ex); + } + } + } + return oseeServerInfo; + } +} |