Skip to main content
summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorcvs2svn2011-05-14 04:08:22 +0000
committercvs2svn2011-05-14 04:08:22 +0000
commit99ea42a960e0854997397e06713266d69b5e4af2 (patch)
tree7022ae29da12dce21bbb03a57fd9d4c2e3ff8e39 /rms/org.eclipse.ptp.rm.smoa.core/src/org/eclipse/ptp/rm/smoa/core/rmsystem/JobThread.java
parenta9c149e5c06c8637d4848e4cafa86e7e8560ee3f (diff)
downloadorg.eclipse.ptp-99ea42a960e0854997397e06713266d69b5e4af2.tar.gz
org.eclipse.ptp-99ea42a960e0854997397e06713266d69b5e4af2.tar.xz
org.eclipse.ptp-99ea42a960e0854997397e06713266d69b5e4af2.zip
This commit was manufactured by cvs2svn to create tag 'v201105140018'.v201105140018
Sprout from master 2011-05-14 04:08:21 UTC Beth Tibbitts <tibbitts@us.ibm.com> 'update cdt version' Delete: core/org.eclipse.ptp.core.tests/.classpath core/org.eclipse.ptp.core.tests/.project core/org.eclipse.ptp.core.tests/.settings/org.eclipse.jdt.core.prefs core/org.eclipse.ptp.core.tests/META-INF/MANIFEST.MF core/org.eclipse.ptp.core.tests/build.properties core/org.eclipse.ptp.core.tests/plugin.properties core/org.eclipse.ptp.core.tests/src/org/eclipse/ptp/core/tests/AttributeIndexSetTests.java core/org.eclipse.ptp.core.tests/src/org/eclipse/ptp/core/tests/RangeSetTests.java core/org.eclipse.ptp.core.tests/src/org/eclipse/ptp/core/tests/suite/CoreTestSuite.java core/org.eclipse.ptp.remote.core.tests/.classpath core/org.eclipse.ptp.remote.core.tests/.project core/org.eclipse.ptp.remote.core.tests/.settings/org.eclipse.jdt.core.prefs core/org.eclipse.ptp.remote.core.tests/META-INF/MANIFEST.MF core/org.eclipse.ptp.remote.core.tests/build.properties core/org.eclipse.ptp.remote.core.tests/plugin.properties core/org.eclipse.ptp.remote.core.tests/src/org/eclipse/ptp/core/tests/FileStoreTests.java core/org.eclipse.ptp.remote.core.tests/src/org/eclipse/ptp/core/tests/RemoteConnectionTests.java core/org.eclipse.ptp.remote.core.tests/src/org/eclipse/ptp/core/tests/RemoteToolsTests.java core/org.eclipse.ptp.remote.core.tests/src/org/eclipse/ptp/core/tests/SFTPTests.java core/org.eclipse.ptp.remote.core.tests/src/org/eclipse/ptp/remote/core/tests/suite/RemoteCoreTestSuite.java core/org.eclipse.ptp.utils.core.tests/.classpath core/org.eclipse.ptp.utils.core.tests/.project core/org.eclipse.ptp.utils.core.tests/.settings/org.eclipse.jdt.core.prefs core/org.eclipse.ptp.utils.core.tests/META-INF/MANIFEST.MF core/org.eclipse.ptp.utils.core.tests/build.properties core/org.eclipse.ptp.utils.core.tests/plugin.properties core/org.eclipse.ptp.utils.core.tests/src/org/eclipse/ptp/utils/core/tests/ArgumentParserTests.java core/org.eclipse.ptp.utils.core.tests/src/org/eclipse/ptp/utils/core/tests/suite/UtilsCoreTestSuite.java debug/org.eclipse.ptp.debug.core.tests/.classpath debug/org.eclipse.ptp.debug.core.tests/.project debug/org.eclipse.ptp.debug.core.tests/.settings/org.eclipse.jdt.core.prefs debug/org.eclipse.ptp.debug.core.tests/META-INF/MANIFEST.MF debug/org.eclipse.ptp.debug.core.tests/build.properties debug/org.eclipse.ptp.debug.core.tests/plugin.properties debug/org.eclipse.ptp.debug.core.tests/src/org/eclipse/ptp/debug/core/tests/AIFTests.java debug/org.eclipse.ptp.debug.core.tests/src/org/eclipse/ptp/debug/core/tests/TaskSetTests.java debug/org.eclipse.ptp.debug.core.tests/src/org/eclipse/ptp/debug/core/tests/suite/DebugCoreTestSuite.java rdt/org.eclipse.ptp.rdt.sync.rsync.core/.classpath rdt/org.eclipse.ptp.rdt.sync.rsync.core/.project rdt/org.eclipse.ptp.rdt.sync.rsync.core/META-INF/MANIFEST.MF rdt/org.eclipse.ptp.rdt.sync.rsync.core/build.properties rdt/org.eclipse.ptp.rdt.sync.rsync.core/plugin.properties rdt/org.eclipse.ptp.rdt.sync.rsync.core/plugin.xml rdt/org.eclipse.ptp.rdt.sync.rsync.core/src/org/eclipse/ptp/rdt/sync/rsync/core/Activator.java rdt/org.eclipse.ptp.rdt.sync.rsync.core/src/org/eclipse/ptp/rdt/sync/rsync/core/RSyncServiceProvider.java rdt/org.eclipse.ptp.rdt.sync.rsync.ui/.classpath rdt/org.eclipse.ptp.rdt.sync.rsync.ui/.project rdt/org.eclipse.ptp.rdt.sync.rsync.ui/META-INF/MANIFEST.MF rdt/org.eclipse.ptp.rdt.sync.rsync.ui/build.properties rdt/org.eclipse.ptp.rdt.sync.rsync.ui/plugin.properties rdt/org.eclipse.ptp.rdt.sync.rsync.ui/plugin.xml rdt/org.eclipse.ptp.rdt.sync.rsync.ui/src/org/eclipse/ptp/rdt/sync/rsync/ui/Activator.java rdt/org.eclipse.ptp.rdt.sync.rsync.ui/src/org/eclipse/ptp/rdt/sync/rsync/ui/RSyncParticipant.java rdt/org.eclipse.ptp.rdt.sync.rsync.ui/src/org/eclipse/ptp/rdt/sync/rsync/ui/messages/Messages.java rdt/org.eclipse.ptp.rdt.sync.rsync.ui/src/org/eclipse/ptp/rdt/sync/rsync/ui/messages/messages.properties rdt/org.eclipse.ptp.rdt.ui.tests/.classpath rdt/org.eclipse.ptp.rdt.ui.tests/.project rdt/org.eclipse.ptp.rdt.ui.tests/.settings/org.eclipse.jdt.core.prefs rdt/org.eclipse.ptp.rdt.ui.tests/META-INF/MANIFEST.MF rdt/org.eclipse.ptp.rdt.ui.tests/build.properties rdt/org.eclipse.ptp.rdt.ui.tests/fixtures/navigation_test_project/test.c rdt/org.eclipse.ptp.rdt.ui.tests/fixtures/navigation_test_project/test.h rdt/org.eclipse.ptp.rdt.ui.tests/suite/org/eclipse/ptp/rdt/ui/tests/RDTUITestPlugin.java rdt/org.eclipse.ptp.rdt.ui.tests/suite/org/eclipse/ptp/rdt/ui/tests/suite/UIBasicTestSuite.java rdt/org.eclipse.ptp.rdt.ui.tests/suite/org/eclipse/ptp/rdt/ui/tests/suite/UIConnectionTestSuite.java rdt/org.eclipse.ptp.rdt.ui.tests/test/org/eclipse/ptp/rdt/ui/tests/navigation/NavigationTests.java releng/.cvsignore releng/org.eclipse.ptp.license-feature/.project releng/org.eclipse.ptp.license-feature/build.properties releng/org.eclipse.ptp.license-feature/eclipse_update_120.jpg releng/org.eclipse.ptp.license-feature/epl-v10.html releng/org.eclipse.ptp.license-feature/feature.properties releng/org.eclipse.ptp.license-feature/feature.xml releng/org.eclipse.ptp.license-feature/license.html releng/org.eclipse.ptp.rdt.sdk-feature/.project releng/org.eclipse.ptp.rdt.sdk-feature/build.properties releng/org.eclipse.ptp.rdt.sdk-feature/epl-v10.html releng/org.eclipse.ptp.rdt.sdk-feature/feature.properties releng/org.eclipse.ptp.rdt.sdk-feature/feature.xml releng/org.eclipse.ptp.rdt.sdk-feature/license.html releng/org.eclipse.ptp.rdt.sdk-feature/sourceTemplateFeature/eclipse_update_120.jpg releng/org.eclipse.ptp.rdt.sdk-feature/sourceTemplateFeature/epl-v10.html releng/org.eclipse.ptp.rdt.sdk-feature/sourceTemplateFeature/feature.properties releng/org.eclipse.ptp.rdt.sdk-feature/sourceTemplateFeature/license.html releng/org.eclipse.ptp.rdt.xlc.sdk-feature/.project releng/org.eclipse.ptp.rdt.xlc.sdk-feature/build.properties releng/org.eclipse.ptp.rdt.xlc.sdk-feature/epl-v10.html releng/org.eclipse.ptp.rdt.xlc.sdk-feature/feature.properties releng/org.eclipse.ptp.rdt.xlc.sdk-feature/feature.xml releng/org.eclipse.ptp.rdt.xlc.sdk-feature/license.html releng/org.eclipse.ptp.rdt.xlc.sdk-feature/sourceTemplateFeature/eclipse_update_120.jpg releng/org.eclipse.ptp.rdt.xlc.sdk-feature/sourceTemplateFeature/epl-v10.html releng/org.eclipse.ptp.rdt.xlc.sdk-feature/sourceTemplateFeature/feature.properties releng/org.eclipse.ptp.rdt.xlc.sdk-feature/sourceTemplateFeature/license.html releng/org.eclipse.ptp.releng/.cvsignore releng/org.eclipse.ptp.releng/.project releng/org.eclipse.ptp.releng/addDownloadStats.xsl releng/org.eclipse.ptp.releng/build.sh releng/org.eclipse.ptp.releng/build.xml releng/org.eclipse.ptp.releng/buildindex.html releng/org.eclipse.ptp.releng/buildsite.xml releng/org.eclipse.ptp.releng/index.html releng/org.eclipse.ptp.releng/maps/photran.map releng/org.eclipse.ptp.releng/maps/ptp.map releng/org.eclipse.ptp.releng/master/build.properties releng/org.eclipse.ptp.releng/master/customTargets.xml releng/org.eclipse.ptp.releng/pack.properties releng/org.eclipse.ptp.releng/ptpbuild releng/org.eclipse.ptp.releng/update_versions releng/org.eclipse.ptp.releng/web/site.css releng/org.eclipse.ptp.releng/web/site.xsl releng/org.eclipse.ptp.rm.ibm.bluegene-feature/.project releng/org.eclipse.ptp.rm.ibm.bluegene-feature/build.properties releng/org.eclipse.ptp.rm.ibm.bluegene-feature/epl-v10.html releng/org.eclipse.ptp.rm.ibm.bluegene-feature/feature.properties releng/org.eclipse.ptp.rm.ibm.bluegene-feature/feature.xml releng/org.eclipse.ptp.rm.ibm.bluegene-feature/license.html releng/org.eclipse.ptp.rm.lsf-feature/.project releng/org.eclipse.ptp.rm.lsf-feature/build.properties releng/org.eclipse.ptp.rm.lsf-feature/epl-v10.html releng/org.eclipse.ptp.rm.lsf-feature/feature.properties releng/org.eclipse.ptp.rm.lsf-feature/feature.xml releng/org.eclipse.ptp.rm.lsf-feature/license.html releng/org.eclipse.ptp.rm.orte-feature/.project releng/org.eclipse.ptp.rm.orte-feature/build.properties releng/org.eclipse.ptp.rm.orte-feature/epl-v10.html releng/org.eclipse.ptp.rm.orte-feature/feature.properties releng/org.eclipse.ptp.rm.orte-feature/feature.xml releng/org.eclipse.ptp.rm.orte-feature/license.html rms/org.eclipse.ptp.rm.jaxb.control.core/.classpath rms/org.eclipse.ptp.rm.jaxb.control.core/.project rms/org.eclipse.ptp.rm.jaxb.control.core/.settings/org.eclipse.jdt.core.prefs rms/org.eclipse.ptp.rm.jaxb.control.core/META-INF/MANIFEST.MF rms/org.eclipse.ptp.rm.jaxb.control.core/build.properties rms/org.eclipse.ptp.rm.jaxb.control.core/src/org/eclipse/ptp/rm/jaxb/control/Activator.java rms/org.eclipse.ptp.rm.jaxb.control.ui/.classpath rms/org.eclipse.ptp.rm.jaxb.control.ui/.project rms/org.eclipse.ptp.rm.jaxb.control.ui/.settings/org.eclipse.jdt.core.prefs rms/org.eclipse.ptp.rm.jaxb.control.ui/META-INF/MANIFEST.MF rms/org.eclipse.ptp.rm.jaxb.control.ui/build.properties rms/org.eclipse.ptp.rm.jaxb.control.ui/src/org/eclipse/ptp/rm/jaxb/control/Activator.java rms/org.eclipse.ptp.rm.jaxb.pbs/.project rms/org.eclipse.ptp.rm.jaxb.pbs/META-INF/MANIFEST.MF rms/org.eclipse.ptp.rm.jaxb.pbs/build.properties rms/org.eclipse.ptp.rm.jaxb.pbs/data/pbs-torque-generic.xml rms/org.eclipse.ptp.rm.jaxb.pbs/data/pbs-torque-interactive.xml rms/org.eclipse.ptp.rm.jaxb.pbs/plugin.xml rms/org.eclipse.ptp.rm.jaxb.tests/.classpath rms/org.eclipse.ptp.rm.jaxb.tests/.project rms/org.eclipse.ptp.rm.jaxb.tests/.settings/org.eclipse.jdt.core.prefs rms/org.eclipse.ptp.rm.jaxb.tests/META-INF/MANIFEST.MF rms/org.eclipse.ptp.rm.jaxb.tests/build.properties rms/org.eclipse.ptp.rm.jaxb.tests/data/qstat rms/org.eclipse.ptp.rm.jaxb.tests/data/qstatF rms/org.eclipse.ptp.rm.jaxb.tests/data/qstatId rms/org.eclipse.ptp.rm.jaxb.tests/data/qsub rms/org.eclipse.ptp.rm.jaxb.tests/data/tabbed-example.xml rms/org.eclipse.ptp.rm.jaxb.tests/data/test-pbs.xml rms/org.eclipse.ptp.rm.jaxb.tests/data/tokenizer-examples.xml rms/org.eclipse.ptp.rm.jaxb.tests/plugin.xml rms/org.eclipse.ptp.rm.jaxb.tests/src/org/eclipse/ptp/rm/jaxb/tests/JAXBTestsPlugin.java rms/org.eclipse.ptp.rm.jaxb.tests/src/org/eclipse/ptp/rm/jaxb/tests/ManagedFilesTest.java rms/org.eclipse.ptp.rm.jaxb.tests/src/org/eclipse/ptp/rm/jaxb/tests/Messages.java rms/org.eclipse.ptp.rm.jaxb.tests/src/org/eclipse/ptp/rm/jaxb/tests/RMDataTest.java rms/org.eclipse.ptp.rm.jaxb.tests/src/org/eclipse/ptp/rm/jaxb/tests/RMLaunchTest.java rms/org.eclipse.ptp.rm.jaxb.tests/src/org/eclipse/ptp/rm/jaxb/tests/StreamParserTest.java rms/org.eclipse.ptp.rm.jaxb.tests/src/org/eclipse/ptp/rm/jaxb/tests/messages.properties rms/org.eclipse.ptp.rm.pbs.proxy/.cproject rms/org.eclipse.ptp.rm.pbs.proxy/.cvsignore rms/org.eclipse.ptp.rm.pbs.proxy/.project rms/org.eclipse.ptp.rm.pbs.proxy/AUTHORS rms/org.eclipse.ptp.rm.pbs.proxy/COPYING rms/org.eclipse.ptp.rm.pbs.proxy/ChangeLog rms/org.eclipse.ptp.rm.pbs.proxy/INSTALL rms/org.eclipse.ptp.rm.pbs.proxy/META-INF/MANIFEST.MF rms/org.eclipse.ptp.rm.pbs.proxy/META-INF/eclipse.inf rms/org.eclipse.ptp.rm.pbs.proxy/Makefile.am rms/org.eclipse.ptp.rm.pbs.proxy/Makefile.in rms/org.eclipse.ptp.rm.pbs.proxy/NEWS rms/org.eclipse.ptp.rm.pbs.proxy/README rms/org.eclipse.ptp.rm.pbs.proxy/about.html rms/org.eclipse.ptp.rm.pbs.proxy/aclocal.m4 rms/org.eclipse.ptp.rm.pbs.proxy/build.properties rms/org.eclipse.ptp.rm.pbs.proxy/compile rms/org.eclipse.ptp.rm.pbs.proxy/config.guess rms/org.eclipse.ptp.rm.pbs.proxy/config.h.in rms/org.eclipse.ptp.rm.pbs.proxy/config.sub rms/org.eclipse.ptp.rm.pbs.proxy/configure rms/org.eclipse.ptp.rm.pbs.proxy/configure.in rms/org.eclipse.ptp.rm.pbs.proxy/depcomp rms/org.eclipse.ptp.rm.pbs.proxy/include/ptp_pbs_job.h rms/org.eclipse.ptp.rm.pbs.proxy/install-sh rms/org.eclipse.ptp.rm.pbs.proxy/missing rms/org.eclipse.ptp.rm.pbs.proxy/plugin.properties rms/org.eclipse.ptp.rm.pbs.proxy/src/ptp_pbs_job.c rms/org.eclipse.ptp.rm.pbs.proxy/src/ptp_pbs_job_tests.c rms/org.eclipse.ptp.rm.pbs.proxy/src/ptp_pbs_proxy.c rms/org.eclipse.ptp.rm.smoa.core/.classpath rms/org.eclipse.ptp.rm.smoa.core/.project rms/org.eclipse.ptp.rm.smoa.core/META-INF/MANIFEST.MF rms/org.eclipse.ptp.rm.smoa.core/NOTICE.txt rms/org.eclipse.ptp.rm.smoa.core/about.html rms/org.eclipse.ptp.rm.smoa.core/build.properties rms/org.eclipse.ptp.rm.smoa.core/plugin.properties rms/org.eclipse.ptp.rm.smoa.core/plugin.xml rms/org.eclipse.ptp.rm.smoa.core/src/org/eclipse/ptp/rm/smoa/core/SMOAConfiguration.java rms/org.eclipse.ptp.rm.smoa.core/src/org/eclipse/ptp/rm/smoa/core/SMOACoreActivator.java rms/org.eclipse.ptp.rm.smoa.core/src/org/eclipse/ptp/rm/smoa/core/SMOARemoteServicesFactory.java rms/org.eclipse.ptp.rm.smoa.core/src/org/eclipse/ptp/rm/smoa/core/attrib/Messages.java rms/org.eclipse.ptp.rm.smoa.core/src/org/eclipse/ptp/rm/smoa/core/attrib/SMOAJobAttributes.java rms/org.eclipse.ptp.rm.smoa.core/src/org/eclipse/ptp/rm/smoa/core/attrib/SMOAMachineAttributes.java rms/org.eclipse.ptp.rm.smoa.core/src/org/eclipse/ptp/rm/smoa/core/attrib/SMOANodeAttributes.java rms/org.eclipse.ptp.rm.smoa.core/src/org/eclipse/ptp/rm/smoa/core/attrib/SMOAQueueAttributes.java rms/org.eclipse.ptp.rm.smoa.core/src/org/eclipse/ptp/rm/smoa/core/attrib/SMOARMAttributes.java rms/org.eclipse.ptp.rm.smoa.core/src/org/eclipse/ptp/rm/smoa/core/attrib/StringMapAttribute.java rms/org.eclipse.ptp.rm.smoa.core/src/org/eclipse/ptp/rm/smoa/core/attrib/StringMapAttributeDefinition.java rms/org.eclipse.ptp.rm.smoa.core/src/org/eclipse/ptp/rm/smoa/core/attrib/messages.properties rms/org.eclipse.ptp.rm.smoa.core/src/org/eclipse/ptp/rm/smoa/core/rmsystem/JobThread.java rms/org.eclipse.ptp.rm.smoa.core/src/org/eclipse/ptp/rm/smoa/core/rmsystem/Messages.java rms/org.eclipse.ptp.rm.smoa.core/src/org/eclipse/ptp/rm/smoa/core/rmsystem/PoolingIntervals.java rms/org.eclipse.ptp.rm.smoa.core/src/org/eclipse/ptp/rm/smoa/core/rmsystem/PoolingIntervalsAndStatic.java rms/org.eclipse.ptp.rm.smoa.core/src/org/eclipse/ptp/rm/smoa/core/rmsystem/SMOAResourceManager.java rms/org.eclipse.ptp.rm.smoa.core/src/org/eclipse/ptp/rm/smoa/core/rmsystem/SMOAResourceManagerConfiguration.java rms/org.eclipse.ptp.rm.smoa.core/src/org/eclipse/ptp/rm/smoa/core/rmsystem/SMOAResourceManagerControl.java rms/org.eclipse.ptp.rm.smoa.core/src/org/eclipse/ptp/rm/smoa/core/rmsystem/SMOAResourceManagerFactory.java rms/org.eclipse.ptp.rm.smoa.core/src/org/eclipse/ptp/rm/smoa/core/rmsystem/SMOAResourceManagerMonitor.java rms/org.eclipse.ptp.rm.smoa.core/src/org/eclipse/ptp/rm/smoa/core/rmsystem/messages.properties rms/org.eclipse.ptp.rm.smoa.core/src/org/eclipse/ptp/rm/smoa/core/rservices/Messages.java rms/org.eclipse.ptp.rm.smoa.core/src/org/eclipse/ptp/rm/smoa/core/rservices/SMOAConnection.java rms/org.eclipse.ptp.rm.smoa.core/src/org/eclipse/ptp/rm/smoa/core/rservices/SMOAConnectionManager.java rms/org.eclipse.ptp.rm.smoa.core/src/org/eclipse/ptp/rm/smoa/core/rservices/SMOAFileManager.java rms/org.eclipse.ptp.rm.smoa.core/src/org/eclipse/ptp/rm/smoa/core/rservices/SMOAFileStagingHandler.java rms/org.eclipse.ptp.rm.smoa.core/src/org/eclipse/ptp/rm/smoa/core/rservices/SMOAFileStore.java rms/org.eclipse.ptp.rm.smoa.core/src/org/eclipse/ptp/rm/smoa/core/rservices/SMOARemoteServices.java rms/org.eclipse.ptp.rm.smoa.core/src/org/eclipse/ptp/rm/smoa/core/rservices/messages.properties rms/org.eclipse.ptp.rm.smoa.core/src/org/eclipse/ptp/rm/smoa/core/rtsystem/SMOARuntimeSystem.java rms/org.eclipse.ptp.rm.smoa.core/src/org/eclipse/ptp/rm/smoa/core/rtsystem/SMOARuntimeSystemFactory.java rms/org.eclipse.ptp.rm.smoa.core/src/org/eclipse/ptp/rm/smoa/core/util/NotifyShell.java rms/org.eclipse.ptp.rm.smoa.ui/.classpath rms/org.eclipse.ptp.rm.smoa.ui/.project rms/org.eclipse.ptp.rm.smoa.ui/META-INF/MANIFEST.MF rms/org.eclipse.ptp.rm.smoa.ui/NOTICE.txt rms/org.eclipse.ptp.rm.smoa.ui/about.html rms/org.eclipse.ptp.rm.smoa.ui/build.properties rms/org.eclipse.ptp.rm.smoa.ui/plugin.properties rms/org.eclipse.ptp.rm.smoa.ui/plugin.xml rms/org.eclipse.ptp.rm.smoa.ui/src/org/eclipse/ptp/rm/smoa/ui/SMOAUIPlugin.java rms/org.eclipse.ptp.rm.smoa.ui/src/org/eclipse/ptp/rm/smoa/ui/actions/Messages.java rms/org.eclipse.ptp.rm.smoa.ui/src/org/eclipse/ptp/rm/smoa/ui/actions/SMOACustomSyncAction.java rms/org.eclipse.ptp.rm.smoa.ui/src/org/eclipse/ptp/rm/smoa/ui/actions/SMOAToLocalSyncAction.java rms/org.eclipse.ptp.rm.smoa.ui/src/org/eclipse/ptp/rm/smoa/ui/actions/SMOAToRemoteSyncAction.java rms/org.eclipse.ptp.rm.smoa.ui/src/org/eclipse/ptp/rm/smoa/ui/actions/SelectConnetionAndDestDir.java rms/org.eclipse.ptp.rm.smoa.ui/src/org/eclipse/ptp/rm/smoa/ui/actions/messages.properties rms/org.eclipse.ptp.rm.smoa.ui/src/org/eclipse/ptp/rm/smoa/ui/launch/Messages.java rms/org.eclipse.ptp.rm.smoa.ui/src/org/eclipse/ptp/rm/smoa/ui/launch/SMOARMLaunchConfigurationDynamicTab.java rms/org.eclipse.ptp.rm.smoa.ui/src/org/eclipse/ptp/rm/smoa/ui/launch/SMOARMLaunchConfigurationFactory.java rms/org.eclipse.ptp.rm.smoa.ui/src/org/eclipse/ptp/rm/smoa/ui/launch/messages.properties rms/org.eclipse.ptp.rm.smoa.ui/src/org/eclipse/ptp/rm/smoa/ui/preferences/Messages.java rms/org.eclipse.ptp.rm.smoa.ui/src/org/eclipse/ptp/rm/smoa/ui/preferences/SMOAPreferencePage.java rms/org.eclipse.ptp.rm.smoa.ui/src/org/eclipse/ptp/rm/smoa/ui/preferences/messages.properties rms/org.eclipse.ptp.rm.smoa.ui/src/org/eclipse/ptp/rm/smoa/ui/rservices/SMOAUIConnectionManager.java rms/org.eclipse.ptp.rm.smoa.ui/src/org/eclipse/ptp/rm/smoa/ui/rservices/SMOAUIFileManager.java rms/org.eclipse.ptp.rm.smoa.ui/src/org/eclipse/ptp/rm/smoa/ui/rservices/SMOAUIServices.java rms/org.eclipse.ptp.rm.smoa.ui/src/org/eclipse/ptp/rm/smoa/ui/rservices/SMOAUIServicesFactory.java rms/org.eclipse.ptp.rm.smoa.ui/src/org/eclipse/ptp/rm/smoa/ui/wizards/Messages.java rms/org.eclipse.ptp.rm.smoa.ui/src/org/eclipse/ptp/rm/smoa/ui/wizards/SMOARMConfigurationWizardPageFactory.java rms/org.eclipse.ptp.rm.smoa.ui/src/org/eclipse/ptp/rm/smoa/ui/wizards/SMOAResourceManagerConfigurationWizardPage.java rms/org.eclipse.ptp.rm.smoa.ui/src/org/eclipse/ptp/rm/smoa/ui/wizards/SMOAResourceManagerFileServicesPage.java rms/org.eclipse.ptp.rm.smoa.ui/src/org/eclipse/ptp/rm/smoa/ui/wizards/messages.properties tools/etfw/org.eclipse.ptp.etfw.feedback.sample/.classpath tools/etfw/org.eclipse.ptp.etfw.feedback.sample/.project tools/etfw/org.eclipse.ptp.etfw.feedback.sample/.settings/org.eclipse.jdt.core.prefs tools/etfw/org.eclipse.ptp.etfw.feedback.sample/META-INF/MANIFEST.MF tools/etfw/org.eclipse.ptp.etfw.feedback.sample/build.properties tools/etfw/org.eclipse.ptp.etfw.feedback.sample/data/sample.c tools/etfw/org.eclipse.ptp.etfw.feedback.sample/data/sample.xml tools/etfw/org.eclipse.ptp.etfw.feedback.sample/icons/feedback_action.gif tools/etfw/org.eclipse.ptp.etfw.feedback.sample/icons/feedback_view.gif tools/etfw/org.eclipse.ptp.etfw.feedback.sample/icons/sample.gif tools/etfw/org.eclipse.ptp.etfw.feedback.sample/plugin.xml tools/etfw/org.eclipse.ptp.etfw.feedback.sample/src/org/eclipse/ptp/etfw/feedback/sample/Activator.java tools/etfw/org.eclipse.ptp.etfw.feedback.sample/src/org/eclipse/ptp/etfw/feedback/sample/SampleFeedbackItem.java tools/etfw/org.eclipse.ptp.etfw.feedback.sample/src/org/eclipse/ptp/etfw/feedback/sample/SampleFeedbackParser.java tools/etfw/org.eclipse.ptp.etfw.feedback.sample/src/org/eclipse/ptp/etfw/feedback/sample/SampleFeedbackView.java tools/etfw/org.eclipse.ptp.etfw.feedback.sample/src/org/eclipse/ptp/etfw/feedback/sample/SampleShowFeedbackHandler.java tools/etfw/org.eclipse.ptp.etfw.feedback.sample/src/org/eclipse/ptp/etfw/feedback/sample/actions/SampleFeedbackAction.java tools/pldt/org.eclipse.ptp.pldt.tests/.classpath tools/pldt/org.eclipse.ptp.pldt.tests/.project tools/pldt/org.eclipse.ptp.pldt.tests/.settings/org.eclipse.jdt.core.prefs tools/pldt/org.eclipse.ptp.pldt.tests/META-INF/MANIFEST.MF tools/pldt/org.eclipse.ptp.pldt.tests/build.properties tools/pldt/org.eclipse.ptp.pldt.tests/resources/HelloFortranMPI.f90 tools/pldt/org.eclipse.ptp.pldt.tests/resources/helloMPIcpp.cpp tools/pldt/org.eclipse.ptp.pldt.tests/resources/helloOpenMP.c tools/pldt/org.eclipse.ptp.pldt.tests/resources/helloOpenMPpragmas.c tools/pldt/org.eclipse.ptp.pldt.tests/resources/includes/readme.txt tools/pldt/org.eclipse.ptp.pldt.tests/resources/openMP.f90 tools/pldt/org.eclipse.ptp.pldt.tests/resources/testMPI.c tools/pldt/org.eclipse.ptp.pldt.tests/resources/testMPIMacro.c tools/pldt/org.eclipse.ptp.pldt.tests/resources/testMPIbarriers.c tools/pldt/org.eclipse.ptp.pldt.tests/resources/testMPIbarriersErr.c tools/pldt/org.eclipse.ptp.pldt.tests/resources/testMPIbarriersFnCall.c tools/pldt/org.eclipse.ptp.pldt.tests/resources/testMPIbarriersTiny.c tools/pldt/org.eclipse.ptp.pldt.tests/resources/testUPC.upc tools/pldt/org.eclipse.ptp.pldt.tests/resources/testUPCmacro.upc tools/pldt/org.eclipse.ptp.pldt.tests/src/org/eclipse/ptp/pldt/tests/Activator.java tools/pldt/org.eclipse.ptp.pldt.tests/src/org/eclipse/ptp/pldt/tests/PldtBaseTestFramework.java tools/pldt/org.eclipse.ptp.pldt.tests/src/org/eclipse/ptp/pldt/tests/TestFortran.java tools/pldt/org.eclipse.ptp.pldt.tests/src/org/eclipse/ptp/pldt/tests/Test_MPI.java tools/pldt/org.eclipse.ptp.pldt.tests/src/org/eclipse/ptp/pldt/tests/Test_MPI_barriers.java tools/pldt/org.eclipse.ptp.pldt.tests/src/org/eclipse/ptp/pldt/tests/Test_OpenMP.java tools/pldt/org.eclipse.ptp.pldt.tests/src/org/eclipse/ptp/pldt/tests/Test_UPC.java tools/samples/org.eclipse.ptp.pldt.sampleCDTstaticAnalysis/.classpath tools/samples/org.eclipse.ptp.pldt.sampleCDTstaticAnalysis/.project tools/samples/org.eclipse.ptp.pldt.sampleCDTstaticAnalysis/META-INF/MANIFEST.MF tools/samples/org.eclipse.ptp.pldt.sampleCDTstaticAnalysis/build.properties tools/samples/org.eclipse.ptp.pldt.sampleCDTstaticAnalysis/icons/calls.gif tools/samples/org.eclipse.ptp.pldt.sampleCDTstaticAnalysis/icons/callsC.gif tools/samples/org.eclipse.ptp.pldt.sampleCDTstaticAnalysis/icons/callsCF.gif tools/samples/org.eclipse.ptp.pldt.sampleCDTstaticAnalysis/icons/class_hi.gif tools/samples/org.eclipse.ptp.pldt.sampleCDTstaticAnalysis/icons/graphC.gif tools/samples/org.eclipse.ptp.pldt.sampleCDTstaticAnalysis/icons/graphW.gif tools/samples/org.eclipse.ptp.pldt.sampleCDTstaticAnalysis/icons/sample.gif tools/samples/org.eclipse.ptp.pldt.sampleCDTstaticAnalysis/plugin.xml tools/samples/org.eclipse.ptp.pldt.sampleCDTstaticAnalysis/samples/Hello.c tools/samples/org.eclipse.ptp.pldt.sampleCDTstaticAnalysis/samples/graph.c tools/samples/org.eclipse.ptp.pldt.sampleCDTstaticAnalysis/samples/walkast.c tools/samples/org.eclipse.ptp.pldt.sampleCDTstaticAnalysis/samples/walkast_edge.c tools/samples/org.eclipse.ptp.pldt.sampleCDTstaticAnalysis/samples/walkast_edge_comments.c tools/samples/org.eclipse.ptp.pldt.sampleCDTstaticAnalysis/src/org/eclipse/ptp/pldt/sampleCDTstaticAnalysis/Activator.java tools/samples/org.eclipse.ptp.pldt.sampleCDTstaticAnalysis/src/org/eclipse/ptp/pldt/sampleCDTstaticAnalysis/actions/ASTWalkerAction.java tools/samples/org.eclipse.ptp.pldt.sampleCDTstaticAnalysis/src/org/eclipse/ptp/pldt/sampleCDTstaticAnalysis/handlers/BuildCFGraphHandler.java tools/samples/org.eclipse.ptp.pldt.sampleCDTstaticAnalysis/src/org/eclipse/ptp/pldt/sampleCDTstaticAnalysis/handlers/BuildCallGraphHandler.java
Diffstat (limited to 'rms/org.eclipse.ptp.rm.smoa.core/src/org/eclipse/ptp/rm/smoa/core/rmsystem/JobThread.java')
-rw-r--r--rms/org.eclipse.ptp.rm.smoa.core/src/org/eclipse/ptp/rm/smoa/core/rmsystem/JobThread.java442
1 files changed, 0 insertions, 442 deletions
diff --git a/rms/org.eclipse.ptp.rm.smoa.core/src/org/eclipse/ptp/rm/smoa/core/rmsystem/JobThread.java b/rms/org.eclipse.ptp.rm.smoa.core/src/org/eclipse/ptp/rm/smoa/core/rmsystem/JobThread.java
deleted file mode 100644
index 95ce6ca9b..000000000
--- a/rms/org.eclipse.ptp.rm.smoa.core/src/org/eclipse/ptp/rm/smoa/core/rmsystem/JobThread.java
+++ /dev/null
@@ -1,442 +0,0 @@
-/*******************************************************************************
- * Copyright (c) 2010 Poznan Supercomputing and Networking Center
- * 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:
- * Jan Konczak (PSNC) - initial implementation
- ******************************************************************************/
-
-package org.eclipse.ptp.rm.smoa.core.rmsystem;
-
-import java.io.BufferedReader;
-import java.io.IOException;
-import java.io.InputStream;
-import java.io.InputStreamReader;
-import java.util.BitSet;
-import java.util.HashMap;
-import java.util.Map;
-
-import org.eclipse.core.filesystem.IFileStore;
-import org.eclipse.core.runtime.CoreException;
-import org.eclipse.ptp.core.attributes.AttributeManager;
-import org.eclipse.ptp.core.elements.IPJob;
-import org.eclipse.ptp.core.elements.IPMachine;
-import org.eclipse.ptp.core.elements.IPNode;
-import org.eclipse.ptp.core.elements.IPResourceManager;
-import org.eclipse.ptp.core.elements.attributes.JobAttributes;
-import org.eclipse.ptp.core.elements.attributes.ProcessAttributes;
-import org.eclipse.ptp.remote.core.IRemoteFileManager;
-import org.eclipse.ptp.remote.core.PTPRemoteCorePlugin;
-import org.eclipse.ptp.rm.smoa.core.rmsystem.PoolingIntervalsAndStatic.SMOAJobState;
-import org.eclipse.ptp.rm.smoa.core.rservices.SMOAFileStore;
-import org.eclipse.ptp.rm.smoa.core.util.NotifyShell;
-
-import com.smoa.comp.sdk.SMOAFactory;
-import com.smoa.comp.sdk.exceptions.FileNotFoundException;
-import com.smoa.comp.sdk.exceptions.NotAuthorizedException;
-import com.smoa.comp.sdk.exceptions.UnknownActivityIdentifierException;
-import com.smoa.comp.sdk.types.ActivityEndpointReference;
-import com.smoa.comp.sdk.types.SMOAActivityStatus;
-
-/**
- * Thread for monitoring a single job - checks state and transfers standard
- * output. Allows job's termination.
- */
-class JobThread extends Thread {
- // The RM that created the job
- private final SMOAResourceManager rm;
- private final IPResourceManager pRM;
-
- // The eclipse job control object
- private final IPJob jobControl;
-
- // The SMOA job control object
- private final ActivityEndpointReference activityIdentifier;
-
- private final SMOAFactory factory;
- private final IRemoteFileManager fileManager;
-
- // Remote files used by launch
- private final IFileStore out;
- private final IFileStore err;
- private final IFileStore sh;
- private final IFileStore machinefile;
-
- // Offsets for the output files
- private int stdOutOffset = 0;
- private int stdErrOffset = 0;
-
- /**
- * Constructs the job thread for monitoring a single job
- */
- public JobThread(SMOAResourceManager rm, SMOAFactory factory, ActivityEndpointReference activityEndpointReference,
- IPJob jobControl, String out, String err, String sh, String machinefile) {
- this.rm = rm;
- this.pRM = (IPResourceManager) rm.getAdapter(IPResourceManager.class);
- this.factory = factory;
- this.activityIdentifier = activityEndpointReference;
- this.jobControl = jobControl;
-
- this.setPriority(MIN_PRIORITY);
- this.setName("JobListener for " + activityIdentifier.getActivityUUID()); //$NON-NLS-1$
-
- final IRemoteFileManager fileManager_t = PTPRemoteCorePlugin.getDefault()
- .getRemoteServices(rm.getControlConfiguration().getRemoteServicesId())
- .getFileManager(rm.getControlConfiguration().getConnection());
-
- fileManager = fileManager_t;
-
- this.out = fileManager.getResource(out);
- this.err = fileManager.getResource(err);
- if (sh != null) {
- this.sh = fileManager.getResource(sh);
- } else {
- this.sh = null;
- }
- if (machinefile != null) {
- this.machinefile = fileManager.getResource(machinefile);
- } else {
- this.machinefile = null;
- }
-
- }
-
- /** Adds given text to standard error, and makes it appear on console */
- void appendStdErr(String stderr) {
- final AttributeManager outManager = new AttributeManager();
- outManager.addAttribute(ProcessAttributes.getStderrAttributeDefinition().create(stderr));
- final BitSet bs = new BitSet();
- bs.set(jobControl.getProcessJobRanks().nextSetBit(0));
- jobControl.addProcessAttributes(bs, outManager);
- }
-
- /** Adds given text to standard output, and makes it appear on console */
- void appendStdOut(String stdout) {
- final AttributeManager outManager = new AttributeManager();
- outManager.addAttribute(ProcessAttributes.getStdoutAttributeDefinition().create(stdout));
- final BitSet bs = new BitSet();
- bs.set(jobControl.getProcessJobRanks().nextSetBit(0));
- jobControl.addProcessAttributes(bs, outManager);
- }
-
- /**
- * Changes job state
- */
- void changeState(JobAttributes.State newState) {
- if (JobAttributes.State.RUNNING.equals(newState)) {
- enteredRunPhase();
- }
-
- final AttributeManager am = new AttributeManager();
- am.addAttribute(JobAttributes.getStateAttributeDefinition().create(newState));
- rm.getMonitor().getRuntimeSystem().changeJob(jobControl.getID(), am);
- }
-
- /**
- * Called when the process state becomes RUNNING.
- *
- * This is the proper moment for identifying where the processes are
- * located, so that debug routing files may be written.
- */
- private void enteredRunPhase() {
- if (machinefile != null) {
- try {
- final BufferedReader reader = new BufferedReader(new InputStreamReader(machinefile.openInputStream(0, null)));
-
- final IPMachine machine = pRM.getMachines()[0];
-
- final Map<String, String> nodesByName = new HashMap<String, String>();
- for (final IPNode ipNode : machine.getNodes()) {
- nodesByName.put(ipNode.getName(), ipNode.getID());
- }
-
- String line;
- int i = 0;
- while ((line = reader.readLine()) != null) {
- final BitSet bs = new BitSet();
- bs.set(i++);
- final AttributeManager attrs = new AttributeManager();
-
- if (!nodesByName.containsKey(line)) {
- rm.getMonitor().getRuntimeSystem().addUnknownNode(machine, line);
- nodesByName.put(line, ((Integer) nodesByName.size()).toString());
- NotifyShell.open(Messages.JobThread_UnknownNode_title, Messages.JobThread_UnknownNode_text_1 + line
- + Messages.JobThread_UnknownNode_text_2);
- attrs.addAttribute(ProcessAttributes.getNodeIdAttributeDefinition().create(nodesByName.get(line)));
- } else {
- attrs.addAttribute(ProcessAttributes.getNodeIdAttributeDefinition().create(nodesByName.get(line)));
- }
- jobControl.addProcessesByJobRanks(bs, attrs);
- }
- return;
- } catch (final CoreException e) {
- NotifyShell.open(Messages.JobThread_ErrorOpeningRemote, e.toString());
-
- final BitSet bs = new BitSet(1);
- bs.set(0);
- final AttributeManager jam = new AttributeManager();
- jam.addAttribute(ProcessAttributes.getNodeIdAttributeDefinition().create("0")); //$NON-NLS-1$
- jobControl.addProcessesByJobRanks(bs, jam);
- } catch (final IOException e) {
- NotifyShell.open(Messages.JobThread_ErrorReadingRemote, e.toString());
-
- if (jobControl.getProcessJobRanks() != null && !jobControl.getProcessJobRanks().isEmpty()) {
- return;
- }
-
- final BitSet bs = new BitSet(1);
- bs.set(0);
- final AttributeManager jam = new AttributeManager();
- jam.addAttribute(ProcessAttributes.getNodeIdAttributeDefinition().create("0")); //$NON-NLS-1$
- jobControl.addProcessesByJobRanks(bs, jam);
- }
- } else {
- final BitSet bs = new BitSet(1);
- bs.set(0);
- final AttributeManager jam = new AttributeManager();
- jam.addAttribute(ProcessAttributes.getNodeIdAttributeDefinition().create("0")); //$NON-NLS-1$
- jobControl.addProcessesByJobRanks(bs, jam);
- }
- }
-
- /**
- * Called if an exception has been thrown while monitoring job
- */
- void exceptionCaught(Exception e) {
- final AttributeManager am = new AttributeManager();
-
- am.addAttribute(JobAttributes.getStatusAttributeDefinition().create(Messages.JobThread_ExceptionByMonitoring));
-
- am.addAttribute(JobAttributes.getStateAttributeDefinition().create(JobAttributes.State.COMPLETED));
-
- am.addAttribute(PoolingIntervalsAndStatic.exceptionAttrDef.create(e.getLocalizedMessage()));
-
- NotifyShell.open(Messages.JobThread_ExceptionByMonitoring, e.getLocalizedMessage());
-
- rm.getMonitor().getRuntimeSystem().changeJob(jobControl.getID(), am);
- }
-
- /** Executed after the job reached terminal state */
- private void jobFinished(SMOAActivityStatus status) {
-
- try {
- // If the job jumped from queued to finished state, we didn't
- // add any processes yet
- if (jobControl.getProcessJobRanks() == null || jobControl.getProcessJobRanks().isEmpty()) {
- final BitSet bs = new BitSet(1);
- bs.set(0);
- final AttributeManager jam = new AttributeManager();
- jam.addAttribute(ProcessAttributes.getNodeIdAttributeDefinition().create("0")); //$NON-NLS-1$
- jobControl.addProcessesByJobRanks(bs, jam);
- }
-
- processOutAndErr();
-
- try {
- out.delete(0, null);
- err.delete(0, null);
- if (sh != null) {
- sh.delete(0, null);
- }
- if (machinefile != null) {
- machinefile.delete(0, null);
- }
- } catch (final CoreException e) {
- NotifyShell.open(Messages.JobThread_ErrorDeletingTempFiles_title, Messages.JobThread_ErrorDeletingTempFiles_text
- + e.getLocalizedMessage());
- e.printStackTrace();
- }
- } catch (final RuntimeException e) {
- // Happens if there is a problem with stdout/err file
- }
-
- final AttributeManager am = new AttributeManager();
-
- String jobStatus = null;
-
- switch (PoolingIntervalsAndStatic.getEquivalentJobState(status)) {
- case Finished:
- jobStatus = Messages.JobThread_JobStateFinisedWithStatus + status.getEndStatus().getExitStatus();
- break;
- case Failed:
- jobStatus = Messages.JobThread_JobStateFailed;
- break;
- case Cancelled:
- jobStatus = Messages.JobThread_JobStateCancelled;
- break;
- default:
- jobStatus = Messages.JobThread_JobStateUnknown;
- }
-
- am.addAttribute(JobAttributes.getStatusAttributeDefinition().create(jobStatus));
-
- JobAttributes.State state;
- state = JobAttributes.State.COMPLETED;
- am.addAttribute(JobAttributes.getStateAttributeDefinition().create(state));
-
- rm.getMonitor().getRuntimeSystem().changeJob(jobControl.getID(), am);
- }
-
- /**
- * Takes care about reading out and err streams and forwards them on console
- */
- private void processOutAndErr() {
-
- /* Out */
- InputStream is;
- try {
- if (out instanceof SMOAFileStore) {
- is = ((SMOAFileStore) out).openInputStream(0, null, stdOutOffset);
- } else {
- is = out.openInputStream(0, null);
- is.skip(stdOutOffset);
- }
-
- final byte[] buffer = new byte[512];
-
- for (int count = is.read(buffer); count > 0; count = is.read(buffer)) {
- stdOutOffset += count;
- appendStdOut(new String(buffer).substring(0, count));
- }
- } catch (final CoreException e) {
- if (e.getCause() instanceof FileNotFoundException) {
- return;
- }
- throw new RuntimeException(e);
- } catch (final IOException e) {
- NotifyShell.open(Messages.JobThread_ErrorOut, e.getLocalizedMessage());
- }
-
- /* Err */
-
- try {
- if (err instanceof SMOAFileStore) {
- is = ((SMOAFileStore) err).openInputStream(0, null, stdErrOffset);
- } else {
- is = err.openInputStream(0, null);
- is.skip(stdErrOffset);
- }
-
- final byte[] buffer = new byte[512];
-
- for (int count = is.read(buffer); count > 0; count = is.read(buffer)) {
- stdErrOffset += count;
- if (count == buffer.length) {
- appendStdErr(new String(buffer));
- } else {
- appendStdErr(new String(buffer).substring(0, count));
- }
- }
- } catch (final CoreException e) {
- if (e.getCause() instanceof FileNotFoundException) {
- return;
- }
- throw new RuntimeException(e);
- } catch (final IOException e) {
- NotifyShell.open(Messages.JobThread_ErrorErr, e.getLocalizedMessage());
- }
- }
-
- /** Loop for monitoring task */
- @Override
- public void run() {
- try {
-
- SMOAActivityStatus status = factory.getActivityStatus(activityIdentifier);
-
- SMOAActivityStatus prevStatus = null;
-
- long nextStateCheck = System.currentTimeMillis();
- long nextOutCheck = nextStateCheck;
-
- // Till the state is not final, we pool the job and out streams
- while (true) {
-
- // Status
- if (nextStateCheck <= System.currentTimeMillis()) {
- nextStateCheck = System.currentTimeMillis() + PoolingIntervalsAndStatic.getPoolingIntervalTask();
-
- final SMOAJobState statusS = PoolingIntervalsAndStatic.getEquivalentJobState(status);
-
- SMOAJobState prevstatusS = null;
-
- if (prevStatus != null) {
- prevstatusS = PoolingIntervalsAndStatic.getEquivalentJobState(prevStatus);
- }
-
- if (prevStatus == null || !statusS.equals(prevstatusS)) {
- switch (statusS) {
- case Stage_in:
- case Held:
- case Queued:
- changeState(JobAttributes.State.STARTING);
- break;
- case Stage_out:
- case Executing:
- changeState(JobAttributes.State.RUNNING);
- break;
- case Suspended:
- changeState(JobAttributes.State.SUSPENDED);
- break;
-
- case Cancelled:
- break;
- case Failed:
- break;
- case Finished:
- break;
- }
- prevStatus = status;
- }
- status = factory.getActivityStatus(activityIdentifier);
-
- if (status.isFinalState()) {
- break;
- }
- }
-
- // Out
- final JobAttributes.State state = jobControl.getAttribute(JobAttributes.getStateAttributeDefinition()).getValue();
- if (state == JobAttributes.State.RUNNING && nextOutCheck <= System.currentTimeMillis()) {
- nextOutCheck = System.currentTimeMillis() + PoolingIntervalsAndStatic.getPoolingIntervalOut();
-
- processOutAndErr();
- }
- try {
- final long nextCheck = Math.min(nextOutCheck - System.currentTimeMillis(),
- nextStateCheck - System.currentTimeMillis());
- if (nextCheck > 0) {
- sleep(nextCheck);
- }
- } catch (final InterruptedException e) {
- // The job has been terminated, ignore
- }
- }
-
- jobFinished(status);
-
- } catch (final NotAuthorizedException e) {
- exceptionCaught(e);
- } catch (final UnknownActivityIdentifierException e) {
- exceptionCaught(e);
- }
-
- rm.removeJobThread(jobControl.getID());
- }
-
- /**
- * Terminates the monitored job
- */
- public boolean terminate() {
- try {
- factory.terminateActivity(activityIdentifier);
- this.interrupt();
- } catch (final Exception e) {
- return false;
- }
- return true;
- }
-}

Back to the top