diff options
author | cvs2svn | 2011-05-14 04:08:22 +0000 |
---|---|---|
committer | cvs2svn | 2011-05-14 04:08:22 +0000 |
commit | 99ea42a960e0854997397e06713266d69b5e4af2 (patch) | |
tree | 7022ae29da12dce21bbb03a57fd9d4c2e3ff8e39 /rms/org.eclipse.ptp.rm.smoa.core/src/org/eclipse/ptp/rm/smoa/core/rmsystem/JobThread.java | |
parent | a9c149e5c06c8637d4848e4cafa86e7e8560ee3f (diff) | |
download | org.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.java | 442 |
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; - } -} |