[246406] Thread-safe support for Lazy Loading

releng/org.eclipse.rse.updatesite/site.xml

@@ -405,7 +405,7 @@
    </category-def>
 <!-- END_3_0_1 -->
 <!-- BEGIN_3_1 -->
-   <feature url="features/org.eclipse.rse.core_3.0.100.qualifier.jar" id="org.eclipse.rse.core" version="3.0.100.qualifier">
+   <feature url="features/org.eclipse.rse.core_3.1.0.qualifier.jar" id="org.eclipse.rse.core" version="3.1.0.qualifier">
       <category name="TM and RSE 3.1"/>
    </feature>
    <feature url="features/org.eclipse.rse.dstore_3.0.100.qualifier.jar" id="org.eclipse.rse.dstore" version="3.0.100.qualifier">
@@ -417,10 +417,10 @@
    <feature url="features/org.eclipse.rse.local_2.1.1.qualifier.jar" id="org.eclipse.rse.local" version="2.1.1.qualifier">
       <category name="TM and RSE 3.1"/>
    </feature>
-   <feature url="features/org.eclipse.rse_3.0.100.qualifier.jar" id="org.eclipse.rse" version="3.0.100.qualifier">
+   <feature url="features/org.eclipse.rse_3.1.0.qualifier.jar" id="org.eclipse.rse" version="3.1.0.qualifier">
       <category name="TM and RSE 3.1"/>
    </feature>
-   <feature url="features/org.eclipse.rse.sdk_3.0.100.qualifier.jar" id="org.eclipse.rse.sdk" version="3.0.100.qualifier">
+   <feature url="features/org.eclipse.rse.sdk_3.1.0.qualifier.jar" id="org.eclipse.rse.sdk" version="3.1.0.qualifier">
       <category name="TM and RSE 3.1"/>
    </feature>
    <feature url="features/org.eclipse.rse.ssh_2.1.100.qualifier.jar" id="org.eclipse.rse.ssh" version="2.1.100.qualifier">

rse/features/org.eclipse.rse-feature/feature.xml

@@ -2,7 +2,7 @@
 <feature
       id="org.eclipse.rse"
       label="%featureName"
-      version="3.0.100.qualifier"
+      version="3.1.0.qualifier"
       provider-name="%providerName"
       plugin="org.eclipse.rse"
       image="eclipse_update_120.jpg">

rse/features/org.eclipse.rse.core-feature/feature.xml

@@ -2,7 +2,7 @@
 <feature
       id="org.eclipse.rse.core"
       label="%featureName"
-      version="3.0.100.qualifier"
+      version="3.1.0.qualifier"
       provider-name="%providerName"
       plugin="org.eclipse.rse.core">
 

rse/features/org.eclipse.rse.sdk-feature/feature.xml

@@ -2,7 +2,7 @@
 <feature
       id="org.eclipse.rse.sdk"
       label="%featureName"
-      version="3.0.100.qualifier"
+      version="3.1.0.qualifier"
       provider-name="%providerName"
       image="eclipse_update_120.jpg">
 

rse/plugins/org.eclipse.rse.services/META-INF/MANIFEST.MF

@@ -2,7 +2,7 @@ Manifest-Version: 1.0
 Bundle-ManifestVersion: 2
 Bundle-Name: %pluginName
 Bundle-SymbolicName: org.eclipse.rse.services;singleton:=true
-Bundle-Version: 3.0.100.qualifier
+Bundle-Version: 3.1.0.qualifier
 Bundle-Activator: org.eclipse.rse.internal.services.Activator
 Bundle-Vendor: %providerName
 Bundle-Localization: plugin

rse/plugins/org.eclipse.rse.services/clientserver/org/eclipse/rse/services/clientserver/messages/SystemMessageFile.java

@@ -1,5 +1,5 @@
 /*******************************************************************************
- * Copyright (c) 2002, 2007 IBM Corporation and others.
+ * Copyright (c) 2002, 2008 IBM Corporation 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
@@ -12,7 +12,8 @@
  * Emily Bruner, Mazen Faraj, Adrian Storisteanu, Li Ding, and Kent Hawley.
  *
  * Contributors:
- * {Name} (company) - description of contribution.
+ * David McKnight   (IBM)  [246406] [performance] Timeout waiting when loading SystemPreferencesManager$ModelChangeListener during startup
+ * Martin Oberhuber (Wind River) - [246406] Thread-safe support for Lazy Loading
  *******************************************************************************/
 
 package org.eclipse.rse.services.clientserver.messages;
@@ -24,8 +25,11 @@ import java.io.InputStream;
 import java.io.PrintWriter;
 import java.net.URI;
 import java.net.URISyntaxException;
+import java.net.URL;
+import java.util.Collections;
 import java.util.Hashtable;
 import java.util.LinkedList;
+import java.util.List;
 import java.util.Vector;
 
 import javax.xml.parsers.DocumentBuilder;
@@ -49,8 +53,11 @@ import org.xml.sax.SAXParseException;
 public class SystemMessageFile implements ErrorHandler
 {
 
-	
+	/**
-	private static final LinkedList msgfList=new LinkedList();
+	 * List<MessageFileInfo> of loaded message files to avoid double loading.
+	 * Must be synchronized since queried from multiple Threads.
+	 */
+	private static final List msgfList = Collections.synchronizedList(new LinkedList());
 	private MessageFileInfo msgFile;
 	private String defaultMsgFileLocation;
 	private InputStream dtdInputStream;
@@ -69,16 +76,21 @@ public class SystemMessageFile implements ErrorHandler
 	private static final String XML_ATTR_INDICATOR   = "Indicator"; //$NON-NLS-1$
 	private static final String XML_ATTR_NAME        = "Name"; //$NON-NLS-1$
 
+	// when using lazy loading, this is the thread that loads the message file
+	private final Thread fLoadThread;
 
+	// indicates whether the lazy load thread is done
+	private boolean fLoadThreadFinished = false;
 
 	/**
-	 * Inner class
+	 * File info node in msgfList to avoid duplicate loading.
+	 * Thread-safe since immutable.
 	 */
-	private class MessageFileInfo 
+	private static class MessageFileInfo
 	{
-		private String filename=null;
+		private final String filename;
-		private String shortName=null;
+		private final String shortName;
-		private Document xmlDocument=null;
+		private final Document xmlDocument;
 
 		public MessageFileInfo(String ucFileName, String lcFileName, Document doc)
 		{
@@ -108,6 +120,103 @@ public class SystemMessageFile implements ErrorHandler
 		}
 	}
 
+	/**
+	 * Thread for loading a message file asynchronously.
+	 *
+	 * Opens Streams, creates an internal message file info object holding the
+	 * DTD, and closes Streams. In case of error, the message file info object
+	 * is not set (remains <code>null</code>).
+	 *
+	 * As a result,
+	 * <ul>
+	 * <li>The {@link #msgFile} variable is set to the loaded message file info
+	 * node if successful.</li>
+	 * <li>The {@link #fLoadThreadFinished} is guaranteed to be set
+	 * <code>true</code>.</li>
+	 * <li>All waiting Threads are notified.</li>
+	 * </ul>
+	 */
+	private class LoadThread extends Thread {
+		private URL _messageFileURL;
+		private URL _dtdURL;
+		private String _messageFileName;
+
+		public LoadThread(String messageFileName, URL messageFileURL, URL dtdURL) {
+			_messageFileName = messageFileName;
+			_messageFileURL = messageFileURL;
+			_dtdURL = dtdURL;
+		}
+
+		public void run() {
+			InputStream messageFile = null;
+			InputStream dtdFile = null;
+			try {
+				messageFile = _messageFileURL.openStream();
+				dtdFile = _dtdURL.openStream();
+				SystemMessageFile realFile = new SystemMessageFile(_messageFileName, messageFile, dtdFile);
+				msgFile = realFile.msgFile;
+			} catch (IOException e) {
+				// problem loading message file -- msgFile is not set.
+			} finally {
+				// Notify that work is finished before closing Streams -
+				// Avoid not getting this set due to a RuntimeError
+				synchronized (this) {
+					fLoadThreadFinished = true;
+					notifyAll();
+				}
+				if (messageFile != null) {
+					try {
+						safeClose(messageFile);
+					} finally {
+						if (dtdFile != null)
+							safeClose(dtdFile);
+					}
+				}
+			}
+		}
+
+		private void safeClose(InputStream s) {
+			try {
+				s.close();
+			} catch (IOException e) {
+				/* ignore */
+			}
+		}
+	}
+
+
+
+	/**
+	 * Constructor to use for lazy loading of a system message file.
+	 *
+	 * The difference between the {@link #SystemMessageFile(String,InputStream,InputStream)}
+	 * constructor and this one is that the former loads the message file synchronously while
+	 * this one loads the message file in a thread.  The message file and DTD URLs are passed
+	 * in here so that the opening of their input streams can be deferred until the time when
+	 * the worker thread is started and able to load the message file.
+	 *
+	 * @param messageFileName the name of the system message file
+	 * @param msgFileURL the URL to the message file
+	 * @param dtdURL the URL to the DTD for the message file
+	 *
+	 * @since 3.1
+	 */
+	public SystemMessageFile(final String messageFileName, final URL msgFileURL, final URL dtdURL)
+	{
+		// have we already loaded this message file?
+		msgFile = getFromCache(messageFileName);
+		if (msgFile == null){
+			// will set msgFile variable and fLoadThreadFinished when done
+			fLoadThread = new LoadThread(messageFileName, msgFileURL, dtdURL);
+			fLoadThread.start();
+		}
+		else { // there's already a cached message file for this
+			// no need to load it, just use the msgFile
+			fLoadThread = null;
+		}
+	}
+
+
 	/**
 	 * Constructor
 	 * @param messageFileName - a key used to determine if a message file has already been loaded.
@@ -129,12 +238,13 @@ public class SystemMessageFile implements ErrorHandler
 			msgfList.add(msgFile);
 			//scanForDuplicates(); // don't keep this for production. Too expensive
 		}
+		fLoadThread = null;
 	}
 
 	/**
 	 * If the named message file has already been loaded return its
 	 * MessageFileInfo
-	 * @param messageFileName
+	 * @param messageFileName name of the message file
 	 * @return the MessageFileInfo for this message file
 	 */
 	protected MessageFileInfo getFromCache(String messageFileName)
@@ -150,27 +260,51 @@ public class SystemMessageFile implements ErrorHandler
 		return null;
 	}
 
+	/**
+	 * Waits until the message file is loaded or canceled due to error
+	 */
+	private void waitUntilLoaded() {
+		// fastpath: returns immediately if constructed synchronously
+		if (fLoadThread != null) {
+			// asynchronous load pending: wait until loaded or load canceled
+			synchronized (fLoadThread) {
+				while (!fLoadThreadFinished) {
+					try {
+						fLoadThread.wait();
+					} catch (InterruptedException e) {
+						// ignore since the Thread is guaranteed to finish
+					}
+				}
+			}
+		}
+	}
 
 	/**
-	 * Use this method to retrieve a message from the message file.
+	 * Use this method to retrieve a message from the message file. If this
-	 * @param msgId - the ID of the message to retrieve. This is the concatenation of the 
+	 * SystemMessageFile loaded from a thread, then the method will wait until
-	 *   message's component abbreviation, subcomponent abbreviation, and message ID as declared
+	 * the loading is complete before returning the message.
-	 *   in the message xml file.
+	 *
-	 * @return SystemMessage object
+	 * @param msgId - the ID of the message to retrieve. This is the
+	 *            concatenation of the message's component abbreviation,
+	 *            subcomponent abbreviation, and message ID as declared in the
+	 *            message XML file.
+	 * @return SystemMessage the SysteMessage object that corresponds to the
+	 *         message ID
 	 */
 	public SystemMessage getMessage(String msgId)
 	{
+		waitUntilLoaded();
 		boolean echoErrorsToStandardOut = true;
 		// DY Defect 42605
-		if (msgFile.getXMLDocument() == null) 
+		if (msgFile == null || msgFile.getXMLDocument() == null)
 	    {
-	    	issueErrorMessage("No XML document for message file", echoErrorsToStandardOut); //$NON-NLS-1$
+	    	issueErrorMessage("No XML document for message file", echoErrorsToStandardOut);
             return null;
 	    }
 
 	    // caching added by Phil to increase performance, and not to leave a trail of SystemMessage objects for
 	    //  the garbage collector. Hopefully, the extra memory for the cache does not defeat these benefits.
-	    SystemMessage msg = (SystemMessage)messages.get(msgFile.getMessageShortFileName()+":"+msgId); //$NON-NLS-1$
+		SystemMessage msg = (SystemMessage) messages.get(msgId);
 	    if (msg != null)
 	    {
 	    	//System.out.println("Reusing msg " + msgId);
@@ -186,7 +320,7 @@ public class SystemMessageFile implements ErrorHandler
 	    NodeList componentElementList = msgFile.getXMLDocument().getElementsByTagName(XML_TAG_COMPONENT);
 	    if ((componentElementList == null) || (componentElementList.getLength() == 0))
 	    {
-	    	issueErrorMessage("Unable to find any Component elements",echoErrorsToStandardOut); //$NON-NLS-1$
+	    	issueErrorMessage("Unable to find any Component elements",echoErrorsToStandardOut);
             return null;
 	    }
 
@@ -198,7 +332,7 @@ public class SystemMessageFile implements ErrorHandler
 
         if ((subComponentList == null) || (subComponentList.getLength() == 0))
         {
-	    	issueErrorMessage("Unable to find any Subcomponent elements",echoErrorsToStandardOut); //$NON-NLS-1$
+	    	issueErrorMessage("Unable to find any Subcomponent elements",echoErrorsToStandardOut);
             return null;
         }
 
@@ -243,7 +377,7 @@ public class SystemMessageFile implements ErrorHandler
         		  messageListNode = (Element)msgListNodes.item(0);
         		else
         		{
-	    	        issueWarningMessage("unable to find MessageList nodes for subComponent " + subComponentElement.getAttribute(XML_ATTR_NAME),echoErrorsToStandardOut); //$NON-NLS-1$
+	    	        issueWarningMessage("unable to find MessageList nodes for subComponent " + subComponentElement.getAttribute(XML_ATTR_NAME),echoErrorsToStandardOut);
         			continue;
         		}
 
@@ -253,7 +387,7 @@ public class SystemMessageFile implements ErrorHandler
         		NodeList msgNodes = messageListNode.getElementsByTagName(XML_TAG_MESSAGE);
         		if ((msgNodes==null) || (msgNodes.getLength()==0))
         		{
-	    	        issueWarningMessage("unable to find Message nodes for subComponent " + subComponentElement.getAttribute(XML_ATTR_NAME),echoErrorsToStandardOut); //$NON-NLS-1$
+	    	        issueWarningMessage("unable to find Message nodes for subComponent " + subComponentElement.getAttribute(XML_ATTR_NAME),echoErrorsToStandardOut);
         			continue;
         		}
         		boolean match = false; // I added this so we stop looping when we find what we are looking for!!! Phil.
@@ -289,20 +423,11 @@ public class SystemMessageFile implements ErrorHandler
         			*/
         			return null;
         		}
-        		try 
+
-        		{   
 		       	msg = loadSystemMessage(componentAbbr, subComponentAbbr, msgNumber, msgIndicator, msgL1, msgL2);
-		       		messages.put(msgFile.getMessageShortFileName()+":"+msgId, msg); // add to cache so we find it immediately next time!! //$NON-NLS-1$
+				messages.put(msgId, msg); // add to cache so we find it immediately next time!!
 		       	return msg;
         	}
-        		catch (IndicatorException e) 
-        		{
-        			/** TODO - DKM move this somewhere else since system message now needs to be eclipse independent
-        			SystemBasePlugin.logError("MessageFile:getMessage: "+e.toString(), e);
-        			*/
-        		}
-       			break;
-        	}
        	}
 		return null;
 	}
@@ -316,11 +441,10 @@ public class SystemMessageFile implements ErrorHandler
 	 * @param msgL1 the first level text that describes the error
 	 * @param msgL2 the second level text that provides details about the error and possible recovery
 	 * @return the SystemMessage
-	 * @throws IndicatorException if the message type indicator is invalid.
 	 * @see SystemMessage for message type indicator constants
 	 */
 	protected SystemMessage loadSystemMessage(String componentAbbr, String subComponentAbbr, String msgNumber, char msgIndicator,
-			String msgL1, String msgL2) throws IndicatorException
+			String msgL1, String msgL2)
 	{
 		return new SystemMessage(componentAbbr, subComponentAbbr, msgNumber, msgIndicator, msgL1, msgL2);
 	}
@@ -349,13 +473,14 @@ public class SystemMessageFile implements ErrorHandler
 	public boolean scanForDuplicates()
 	{
 		boolean echoErrorsToStandardOut = true;
-		if (msgFile.getXMLDocument() == null) 
+		waitUntilLoaded();
-	    	return issueErrorMessage("No XML document for message file", echoErrorsToStandardOut); //$NON-NLS-1$
+		if (msgFile == null || msgFile.getXMLDocument() == null)
+	    	return issueErrorMessage("No XML document for message file", echoErrorsToStandardOut);
 
         // parse out the Abbr attr of the first Component element
 	    NodeList componentElementList = msgFile.getXMLDocument().getElementsByTagName(XML_TAG_COMPONENT);
 	    if ((componentElementList == null) || (componentElementList.getLength() == 0))
-	    	return issueErrorMessage("Unable to find any Component elements",echoErrorsToStandardOut); //$NON-NLS-1$
+	    	return issueErrorMessage("Unable to find any Component elements",echoErrorsToStandardOut);
 
 	    Element componentElement = (Element)componentElementList.item(0);
         String componentAbbr = componentElement.getAttribute(XML_ATTR_ABBR);
@@ -364,7 +489,7 @@ public class SystemMessageFile implements ErrorHandler
         NodeList subComponentList=msgFile.getXMLDocument().getElementsByTagName(XML_TAG_SUBCOMPONENT);
 
         if ((subComponentList == null) || (subComponentList.getLength() == 0))
-	    	return issueErrorMessage("Unable to find any Subcomponent elements",echoErrorsToStandardOut); //$NON-NLS-1$
+	    	return issueErrorMessage("Unable to find any Subcomponent elements",echoErrorsToStandardOut);
 
         // scan all subcomponents...
         boolean anyDupes = false;
@@ -382,14 +507,14 @@ public class SystemMessageFile implements ErrorHandler
         	  messageListNode = (Element)msgListNodes.item(0);
         	else
         	{
-	    	    issueWarningMessage("unable to find MessageList nodes for subComponent " + subComponentElement.getAttribute(XML_ATTR_NAME),echoErrorsToStandardOut); //$NON-NLS-1$
+	    	    issueWarningMessage("unable to find MessageList nodes for subComponent " + subComponentElement.getAttribute(XML_ATTR_NAME),echoErrorsToStandardOut);
         		continue;
         	}
 
         	NodeList msgNodes = messageListNode.getElementsByTagName(XML_TAG_MESSAGE);
         	if ((msgNodes==null) || (msgNodes.getLength()==0))
         	{
-	    	        issueWarningMessage("unable to find Message nodes for subComponent " + subComponentElement.getAttribute(XML_ATTR_NAME),echoErrorsToStandardOut); //$NON-NLS-1$
+	    	        issueWarningMessage("unable to find Message nodes for subComponent " + subComponentElement.getAttribute(XML_ATTR_NAME),echoErrorsToStandardOut);
         			continue;
         	}
             for (int msgIdx = 0; (msgIdx < msgNodes.getLength()); msgIdx++)
@@ -399,7 +524,7 @@ public class SystemMessageFile implements ErrorHandler
         		 if (msgsById.contains(msgId))
         		 {
         		 	anyDupes = true;
-	    	        issueWarningMessage("Warning: duplicate message " + msgId + " found", echoErrorsToStandardOut); //$NON-NLS-1$ //$NON-NLS-2$
+	    	        issueWarningMessage("Warning: duplicate message " + msgId + " found", echoErrorsToStandardOut);
         		 }
         		 else
         		   msgsById.addElement(msgId);
@@ -417,13 +542,14 @@ public class SystemMessageFile implements ErrorHandler
 	public boolean printHTML(String fullFileName)
 	{
 		boolean echoErrorsToStandardOut = true;
-		if (msgFile.getXMLDocument() == null) 
+		waitUntilLoaded();
-	    	return issueErrorMessage("No XML document for message file", echoErrorsToStandardOut); //$NON-NLS-1$
+		if (msgFile == null || msgFile.getXMLDocument() == null)
+	    	return issueErrorMessage("No XML document for message file", echoErrorsToStandardOut);
 
         // parse out the Abbr attr of the first Component element
 	    NodeList componentElementList = msgFile.getXMLDocument().getElementsByTagName(XML_TAG_COMPONENT);
 	    if ((componentElementList == null) || (componentElementList.getLength() == 0))
-	    	return issueErrorMessage("Unable to find any Component elements",echoErrorsToStandardOut); //$NON-NLS-1$
+	    	return issueErrorMessage("Unable to find any Component elements",echoErrorsToStandardOut);
 
 	    Element componentElement = (Element)componentElementList.item(0);
         String componentAbbr = componentElement.getAttribute(XML_ATTR_ABBR);
@@ -432,7 +558,7 @@ public class SystemMessageFile implements ErrorHandler
         NodeList subComponentList=msgFile.getXMLDocument().getElementsByTagName(XML_TAG_SUBCOMPONENT);
 
         if ((subComponentList == null) || (subComponentList.getLength() == 0))
-	    	return issueErrorMessage("Unable to find any Subcomponent elements",echoErrorsToStandardOut); //$NON-NLS-1$
+	    	return issueErrorMessage("Unable to find any Subcomponent elements",echoErrorsToStandardOut);
 
 		File outFile = new File(fullFileName);
 		PrintWriter outFileStream = null;
@@ -454,7 +580,7 @@ public class SystemMessageFile implements ErrorHandler
 		}
 		catch (IOException exc)
 		{
-			return issueErrorMessage("Unable to open given html file in printHTML: " + exc.getMessage(), echoErrorsToStandardOut); //$NON-NLS-1$
+			return issueErrorMessage("Unable to open given html file in printHTML: " + exc.getMessage(), echoErrorsToStandardOut);
 		}
 
         // pre-scan all subcomponents...
@@ -486,14 +612,14 @@ public class SystemMessageFile implements ErrorHandler
         	  messageListNode = (Element)msgListNodes.item(0);
         	else
         	{
-	    	    issueWarningMessage("unable to find MessageList nodes for subComponent " + subComponentElement.getAttribute(XML_ATTR_NAME),echoErrorsToStandardOut); //$NON-NLS-1$
+	    	    issueWarningMessage("unable to find MessageList nodes for subComponent " + subComponentElement.getAttribute(XML_ATTR_NAME),echoErrorsToStandardOut);
         		continue;
         	}
 
         	NodeList msgNodes = messageListNode.getElementsByTagName(XML_TAG_MESSAGE);
         	if ((msgNodes==null) || (msgNodes.getLength()==0))
         	{
-	    	        issueWarningMessage("unable to find Message nodes for subComponent " + subComponentElement.getAttribute(XML_ATTR_NAME),echoErrorsToStandardOut); //$NON-NLS-1$
+	    	        issueWarningMessage("unable to find Message nodes for subComponent " + subComponentElement.getAttribute(XML_ATTR_NAME),echoErrorsToStandardOut);
         			continue;
         	}
         	if (subComponentIdx > 0)
@@ -507,17 +633,17 @@ public class SystemMessageFile implements ErrorHandler
         		 char msgIndicator=node.getAttribute(XML_ATTR_INDICATOR).toUpperCase().charAt(0);
         		 String msgSeverity = "Unknown"; //$NON-NLS-1$
         		 if (msgIndicator == SystemMessage.ERROR)
-        		   msgSeverity = "Error"; //$NON-NLS-1$
+        		   msgSeverity = "Error";
         		 else if (msgIndicator == SystemMessage.WARNING)
-        		   msgSeverity = "Warning"; //$NON-NLS-1$
+        		   msgSeverity = "Warning";
         		 else if (msgIndicator == SystemMessage.INQUIRY)
-        		   msgSeverity = "Question"; //$NON-NLS-1$
+        		   msgSeverity = "Question";
         		 else if (msgIndicator == SystemMessage.INFORMATION)
-        		   msgSeverity = "Information"; //$NON-NLS-1$
+        		   msgSeverity = "Information";
         		 else if (msgIndicator == SystemMessage.COMPLETION)
-         		   msgSeverity = "Completion"; //$NON-NLS-1$
+         		   msgSeverity = "Completion";
         		 else if (msgIndicator == SystemMessage.UNEXPECTED)
-        		   msgSeverity = "Unexpected"; //$NON-NLS-1$
+        		   msgSeverity = "Unexpected";
 
         		 String msgL1 = ""; //$NON-NLS-1$
         		 String msgL2 = ""; //$NON-NLS-1$
@@ -555,7 +681,7 @@ public class SystemMessageFile implements ErrorHandler
         SystemBasePlugin.logError("MessageFile error for msg file " + msgFile.getMessageShortFileName() + ": " + errormsg);
         **/
         if (echoStandardOut)
-          System.out.println("MessageFile error for msg file " + msgFile.getMessageShortFileName() + ": " + errormsg); //$NON-NLS-1$ //$NON-NLS-2$
+          System.out.println("MessageFile error for msg file " + msgFile.getMessageShortFileName() + ": " + errormsg);
         return false;
 	}
 	/**
@@ -567,7 +693,7 @@ public class SystemMessageFile implements ErrorHandler
         SystemBasePlugin.logError("MessageFile warning for msg file " + msgFile.getMessageShortFileName() + ": " + errormsg);
         */
         if (echoStandardOut)
-          System.out.println("MessageFile warning for msg file " + msgFile.getMessageShortFileName() + ": " + errormsg); //$NON-NLS-1$ //$NON-NLS-2$
+          System.out.println("MessageFile warning for msg file " + msgFile.getMessageShortFileName() + ": " + errormsg);
         return false;
 	}
 

rse/plugins/org.eclipse.rse.ui/META-INF/MANIFEST.MF

@@ -2,7 +2,7 @@ Manifest-Version: 1.0
 Bundle-ManifestVersion: 2
 Bundle-Name: %pluginName
 Bundle-SymbolicName: org.eclipse.rse.ui;singleton:=true
-Bundle-Version: 3.0.100.qualifier
+Bundle-Version: 3.1.0.qualifier
 Bundle-Activator: org.eclipse.rse.ui.RSEUIPlugin
 Bundle-Localization: plugin
 Require-Bundle: org.eclipse.core.runtime,
@@ -14,7 +14,7 @@ Require-Bundle: org.eclipse.core.runtime,
  org.eclipse.ui.ide,
  org.eclipse.ui.views,
  org.eclipse.ui.workbench.texteditor,
- org.eclipse.rse.services;bundle-version="[3.0.0,4.0.0)",
+ org.eclipse.rse.services;bundle-version="[3.1.0,4.0.0)",
  org.eclipse.rse.core;bundle-version="[3.0.0,4.0.0)"
 Import-Package: com.ibm.icu.lang,
  com.ibm.icu.text,

rse/plugins/org.eclipse.rse.ui/UI/org/eclipse/rse/ui/SystemBasePlugin.java

@@ -15,11 +15,11 @@
  * Martin Oberhuber (Wind River) - [168870] refactor org.eclipse.rse.core package of the UI plugin
  * David McKnight   (IBM)        - [243263] NPE on expanding a filter
  * David McKnight   (IBM)        - [244454] SystemBasePlugin.getWorkBench() incorrectly returns null when called during Eclipse startup
+ * David McKnight   (IBM)  [246406] [performance] Timeout waiting when loading SystemPreferencesManager$ModelChangeListener during startup
  ********************************************************************************/
 
 package org.eclipse.rse.ui;
 
-import java.io.InputStream;
 import java.net.URL;
 import java.util.Hashtable;
 import java.util.Locale;
@@ -302,9 +302,7 @@ public abstract class SystemBasePlugin extends AbstractUIPlugin
 		try {
 			URL url = resolveBundleNameNL(bundle, fileName);
 			if (url != null) {
-				InputStream messageFileStream = url.openStream();
+				mf = SystemUIMessageFile.getMessageFile(fileName, url);
-				mf = SystemUIMessageFile.getMessageFile(fileName, messageFileStream);
-				messageFileStream.close();
 				ok = true;
 			}
 		} catch (Throwable t) {
@@ -346,9 +344,7 @@ public abstract class SystemBasePlugin extends AbstractUIPlugin
 		try {
 			URL url = bundle.getEntry("/"+fileName); //$NON-NLS-1$
 			if (url != null) { 
-				InputStream messageFileStream = url.openStream();
+				mf = SystemUIMessageFile.getMessageFile(fileName, url);
-				mf = SystemUIMessageFile.getMessageFile(fileName, messageFileStream);
-				messageFileStream.close();
 				ok = true;
 			}
 		} catch (Throwable t) {

rse/plugins/org.eclipse.rse.ui/UI/org/eclipse/rse/ui/messages/SystemUIMessageFile.java

@@ -1,5 +1,5 @@
 /********************************************************************************
- * Copyright (c) 2004, 2007 IBM Corporation and others. All rights reserved.
+ * Copyright (c) 2004, 2008 IBM Corporation 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
@@ -12,6 +12,7 @@
  * 
  * Contributors:
  * Martin Oberhuber (Wind River) - [168870] refactor org.eclipse.rse.core package of the UI plugin
+ * David McKnight   (IBM)  [246406] [performance] Timeout waiting when loading SystemPreferencesManager$ModelChangeListener during startup
  ********************************************************************************/
 
 package org.eclipse.rse.ui.messages;
@@ -33,8 +34,8 @@ import org.eclipse.rse.ui.SystemBasePlugin;
 public class SystemUIMessageFile extends SystemMessageFile {
 	
 	/**
-	 * Factory method for constructing a SystemUIMessageFile. If an error occurs when
+	 * Factory method for constructing a SystemUIMessageFile that loads the message file synchronously. 
-	 * reading the message file DTD then that is logged.
+	 * If an error occurs when reading the message file DTD then that is logged.
 	 * @param messageFileName The "registered" name of the message file. Used to determine
 	 * if the message file has been loaded. 
 	 * @param messageFileStream The stream containing the message file. It is the
@@ -60,11 +61,56 @@ public class SystemUIMessageFile extends SystemMessageFile {
 		return result;
 	}
 	
+	/**
+	 * Factory method for constructing a SystemUIMessageFile that loads the message file in a thread.
+	 *  
+	 * The difference between {@link #getMessageFile(String,InputStream)} and this method
+	 * is that the former calls the constructor that loads the message file synchronously 
+	 * while this one loads the message file in a worker thread.  The message file URL is 
+	 * passed in here so that the opening of it's input stream can be deferred until the 
+	 * time when the worker thread is started and able to load the message file.
+	 * 
+	 * @param messageFileName The name of the message file to load. 
+	 * @param messageFileURL The URL to the message file.
+	 * @return The message file that was constructed.
+	 * 
+	 * @since 3.1
+	 */
+	public static SystemUIMessageFile getMessageFile(String messageFileName,
+			URL messageFileURL) {
+		SystemUIMessageFile result = null;
+		URL dtdURL = RSEUIPlugin.getDefault().getMessageFileDTD();
+		if (dtdURL != null) {
+			result = new SystemUIMessageFile(messageFileName,messageFileURL, dtdURL);
+		} else {
+			SystemBasePlugin.logError("Could not find mesage file DTD."); //$NON-NLS-1$
+		}
+		return result;
+	}
+	
+
+	/**
+	 * Constructor for synchronous loading of the message file.  
+	 * 
+	 * This is private because this is not to be called directly, but rather 
+	 * from {@link #getMessageFile(String, InputStream)}.
+	 */
 	private SystemUIMessageFile(String messageFileName,
 			InputStream messageFileStream, InputStream dtdStream) {
 		super(messageFileName, messageFileStream, dtdStream);
 	}
 
+	/**
+	 * Constructor for lazy loading of the message file.
+	 * 
+	 * This is private because this is not to be called directly, but rather 
+	 * from {@link #getMessageFile(String, URL)}.
+	 */
+	private SystemUIMessageFile(String messageFileName,
+			URL messageFileURL, URL dtdURL) {
+		super(messageFileName, messageFileURL, dtdURL);
+	}
+
 	/**
 	 * Override this to provide different extended SystemMessage implementation
 	 *