You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by sh...@apache.org on 2015/06/04 22:37:38 UTC
[52/52] [abbrv] airavata git commit: Resolved ModuleRefactor merge
conflicts
Resolved ModuleRefactor merge conflicts
Project: http://git-wip-us.apache.org/repos/asf/airavata/repo
Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/2835d09e
Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/2835d09e
Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/2835d09e
Branch: refs/heads/master
Commit: 2835d09ef16e218d7c2224bbebe2a13dd440d23d
Parents: b4ede9c ec8c620
Author: Shameera Rathanyaka <sh...@gmail.com>
Authored: Thu Jun 4 16:36:38 2015 -0400
Committer: Shameera Rathanyaka <sh...@gmail.com>
Committed: Thu Jun 4 16:36:38 2015 -0400
----------------------------------------------------------------------
.../server/handler/AiravataServerHandler.java | 195 +-
.../AiravataExperimentStatusUpdator.java | 24 +-
.../api/server/util/DataModelUtils.java | 4 +-
.../api/server/util/DatabaseCreator.java | 4 +-
.../api/server/util/RegistryInitUtil.java | 12 +-
.../client/samples/CreateLaunchExperiment.java | 2 +-
.../org/airavata/appcatalog/cpi/AppCatalog.java | 54 -
.../appcatalog/cpi/AppCatalogException.java | 36 -
.../appcatalog/cpi/ApplicationDeployment.java | 72 -
.../appcatalog/cpi/ApplicationInterface.java | 148 -
.../appcatalog/cpi/ComputeResource.java | 249 --
.../appcatalog/cpi/GwyResourceProfile.java | 81 -
.../appcatalog/cpi/WorkflowCatalog.java | 45 -
.../catalog/data/impl/AppCatalogFactory.java | 46 -
.../catalog/data/impl/AppCatalogImpl.java | 52 -
.../data/impl/ApplicationDeploymentImpl.java | 414 ---
.../data/impl/ApplicationInterfaceImpl.java | 450 ---
.../catalog/data/impl/ComputeResourceImpl.java | 888 ------
.../data/impl/GwyResourceProfileImpl.java | 252 --
.../catalog/data/impl/WorkflowCatalogImpl.java | 232 --
.../catalog/data/model/AppEnvironment.java | 76 -
.../catalog/data/model/AppEnvironment_PK.java | 64 -
.../catalog/data/model/AppInput_PK.java | 64 -
.../catalog/data/model/AppModuleMapping.java | 77 -
.../catalog/data/model/AppModuleMapping_PK.java | 64 -
.../catalog/data/model/AppOutput_PK.java | 64 -
.../data/model/ApplicationDeployment.java | 148 -
.../catalog/data/model/ApplicationInput.java | 166 -
.../data/model/ApplicationInterface.java | 97 -
.../catalog/data/model/ApplicationModule.java | 107 -
.../catalog/data/model/ApplicationOutput.java | 146 -
.../catalog/data/model/BatchQueue.java | 144 -
.../catalog/data/model/BatchQueue_PK.java | 63 -
.../catalog/data/model/CloudJobSubmission.java | 102 -
.../catalog/data/model/ComputeResource.java | 105 -
.../data/model/ComputeResourceFileSystem.java | 89 -
.../model/ComputeResourceFileSystem_PK.java | 62 -
.../data/model/ComputeResourcePreference.java | 154 -
.../data/model/ComputeResourcePreferencePK.java | 64 -
.../catalog/data/model/Configuration.java | 57 -
.../catalog/data/model/Configuration_PK.java | 65 -
.../data/model/DataMovementInterface.java | 124 -
.../data/model/DataMovementInterface_PK.java | 62 -
.../data/model/DataMovementProtocol.java | 76 -
.../data/model/DataMovementProtocolPK.java | 74 -
.../catalog/data/model/GSISSHExport.java | 73 -
.../catalog/data/model/GSISSHExportPK.java | 64 -
.../catalog/data/model/GSISSHSubmission.java | 82 -
.../catalog/data/model/GatewayProfile.java | 68 -
.../catalog/data/model/GlobusGKEndPointPK.java | 64 -
.../catalog/data/model/GlobusGKEndpoint.java | 65 -
.../catalog/data/model/GlobusJobSubmission.java | 62 -
.../catalog/data/model/GridftpDataMovement.java | 83 -
.../catalog/data/model/GridftpEndpoint.java | 102 -
.../catalog/data/model/GridftpEndpoint_PK.java | 62 -
.../catalog/data/model/HostAlias.java | 65 -
.../catalog/data/model/HostAliasPK.java | 64 -
.../catalog/data/model/HostIPAddress.java | 65 -
.../catalog/data/model/HostIPAddressPK.java | 64 -
.../catalog/data/model/JobManagerCommand.java | 89 -
.../data/model/JobManagerCommand_PK.java | 62 -
.../data/model/JobSubmissionInterface.java | 124 -
.../data/model/JobSubmissionInterface_PK.java | 62 -
.../data/model/JobSubmissionProtocol.java | 77 -
.../data/model/JobSubmissionProtocolPK.java | 74 -
.../catalog/data/model/LibraryApendPath.java | 76 -
.../catalog/data/model/LibraryApendPath_PK.java | 64 -
.../catalog/data/model/LibraryPrepandPath.java | 76 -
.../data/model/LibraryPrepandPath_PK.java | 64 -
.../catalog/data/model/LocalDataMovement.java | 49 -
.../catalog/data/model/LocalSubmission.java | 98 -
.../catalog/data/model/ModuleLoadCmd.java | 70 -
.../catalog/data/model/ModuleLoadCmd_PK.java | 63 -
.../catalog/data/model/PostJobCommand.java | 73 -
.../catalog/data/model/PostJobCommandPK.java | 64 -
.../catalog/data/model/PreJobCommand.java | 73 -
.../catalog/data/model/PreJobCommandPK.java | 64 -
.../catalog/data/model/ResourceJobManager.java | 106 -
.../catalog/data/model/ScpDataMovement.java | 117 -
.../catalog/data/model/SshJobSubmission.java | 144 -
.../catalog/data/model/UnicoreDataMovement.java | 65 -
.../data/model/UnicoreJobSubmission.java | 66 -
.../catalog/data/model/Workflow.java | 126 -
.../catalog/data/model/WorkflowInput.java | 167 -
.../catalog/data/model/WorkflowInput_PK.java | 64 -
.../catalog/data/model/WorkflowOutput.java | 117 -
.../catalog/data/model/WorkflowOutput_PK.java | 64 -
.../data/resources/AbstractResource.java | 382 ---
.../data/resources/AppDeploymentResource.java | 446 ---
.../data/resources/AppEnvironmentResource.java | 293 --
.../data/resources/AppInterfaceResource.java | 363 ---
.../resources/AppModuleMappingResource.java | 317 --
.../data/resources/AppModuleResource.java | 344 --
.../resources/ApplicationInputResource.java | 454 ---
.../resources/ApplicationOutputResource.java | 432 ---
.../data/resources/BatchQueueResource.java | 357 ---
.../data/resources/CloudSubmissionResource.java | 299 --
.../ComputeHostPreferenceResource.java | 413 ---
.../ComputeResourceFileSystemResource.java | 307 --
.../data/resources/ComputeResourceResource.java | 351 ---
.../DataMovementInterfaceResource.java | 339 --
.../resources/DataMovementProtocolResource.java | 360 ---
.../data/resources/GSISSHExportResource.java | 324 --
.../resources/GSISSHSubmissionResource.java | 374 ---
.../data/resources/GatewayProfileResource.java | 318 --
.../resources/GlobusGKEndpointResource.java | 321 --
.../resources/GlobusJobSubmissionResource.java | 316 --
.../resources/GridftpDataMovementResource.java | 279 --
.../data/resources/GridftpEndpointResource.java | 317 --
.../data/resources/HostAliasResource.java | 317 --
.../data/resources/HostIPAddressResource.java | 318 --
.../resources/JobManagerCommandResource.java | 307 --
.../JobSubmissionInterfaceResource.java | 339 --
.../JobSubmissionProtocolResource.java | 359 ---
.../resources/LibraryApendPathResource.java | 292 --
.../resources/LibraryPrepandPathResource.java | 291 --
.../resources/LocalDataMovementResource.java | 249 --
.../data/resources/LocalSubmissionResource.java | 293 --
.../data/resources/ModuleLoadCmdResource.java | 300 --
.../data/resources/PostJobCommandResource.java | 333 --
.../data/resources/PreJobCommandResource.java | 333 --
.../catalog/data/resources/Resource.java | 89 -
.../resources/ResourceJobManagerResource.java | 301 --
.../data/resources/ScpDataMovementResource.java | 308 --
.../resources/SshJobSubmissionResource.java | 332 --
.../resources/UnicoreDataMovementResource.java | 255 --
.../resources/UnicoreJobSubmissionResource.java | 328 --
.../data/resources/WorkflowInputResource.java | 451 ---
.../data/resources/WorkflowOutputResource.java | 410 ---
.../data/resources/WorkflowResource.java | 382 ---
.../catalog/data/util/AppCatalogJPAUtils.java | 911 ------
.../data/util/AppCatalogQueryGenerator.java | 90 -
.../data/util/AppCatalogResourceType.java | 66 -
.../data/util/AppCatalogThriftConversion.java | 800 -----
.../catalog/data/util/AppCatalogUtils.java | 31 -
.../src/main/resources/META-INF/persistence.xml | 67 -
.../src/main/resources/appcatalog-derby.sql | 460 ---
.../src/main/resources/appcatalog-mysql.sql | 453 ---
.../app/catalog/test/AppDeploymentTest.java | 147 -
.../app/catalog/test/AppInterfaceTest.java | 192 --
.../app/catalog/test/ComputeResourceTest.java | 298 --
.../app/catalog/test/GatewayProfileTest.java | 128 -
.../app/catalog/test/util/Initialize.java | 320 --
.../gaussian/handler/GaussianHandler.java | 4 +-
.../gfac/bes/handlers/AbstractSMSHandler.java | 2 +-
.../gfac/bes/provider/impl/BESProvider.java | 2 +-
.../org/apache/airavata/gfac/Scheduler.java | 4 +-
.../org/apache/airavata/gfac/core/GFac.java | 8 +-
.../apache/airavata/gfac/core/GFacUtils.java | 33 +-
...ava~30f9d70adbd9ee7dd6f7d3eccbfca4baf19b09fa | 475 +++
.../airavata/gfac/core/JobDescriptor.java~HEAD | 475 +++
...ava~30f9d70adbd9ee7dd6f7d3eccbfca4baf19b09fa | 52 +
.../gfac/core/JobManagerConfiguration.java~HEAD | 52 +
...ava~30f9d70adbd9ee7dd6f7d3eccbfca4baf19b09fa | 34 +
.../gfac/core/cluster/CommandInfo.java~HEAD | 34 +
...ava~30f9d70adbd9ee7dd6f7d3eccbfca4baf19b09fa | 49 +
.../gfac/core/cluster/CommandOutput.java~HEAD | 49 +
...ava~30f9d70adbd9ee7dd6f7d3eccbfca4baf19b09fa | 65 +
.../gfac/core/cluster/ServerInfo.java~HEAD | 65 +
.../gfac/core/context/JobExecutionContext.java | 16 +-
.../gfac/core/handler/AbstractHandler.java | 20 +-
.../gfac/core/provider/AbstractProvider.java | 12 +-
...ava~30f9d70adbd9ee7dd6f7d3eccbfca4baf19b09fa | 29 +
.../jsch/GSISSHIdentityRepository.java~HEAD | 29 +
.../handler/GSISSHDirectorySetupHandler.java | 6 +-
.../gfac/gsissh/handler/GSISSHInputHandler.java | 6 +-
.../gsissh/handler/GSISSHOutputHandler.java | 12 +-
.../gsissh/handler/NewGSISSHOutputHandler.java | 4 +-
.../gsissh/provider/impl/GSISSHProvider.java | 2 +-
.../gfac/gsissh/util/GFACGSISSHUtils.java | 2 +-
.../gfac/impl/AiravataJobStatusUpdator.java | 22 +-
.../gfac/impl/AiravataTaskStatusUpdator.java | 22 +-
.../impl/AiravataWorkflowNodeStatusUpdator.java | 22 +-
.../airavata/gfac/impl/BetterGfacImpl.java | 26 +-
.../gfac/local/provider/impl/LocalProvider.java | 10 +-
.../ssh/handler/AdvancedSCPInputHandler.java | 4 +-
.../ssh/handler/AdvancedSCPOutputHandler.java | 4 +-
.../gfac/ssh/handler/NewSSHOutputHandler.java | 4 +-
.../ssh/handler/SSHDirectorySetupHandler.java | 6 +-
.../gfac/ssh/handler/SSHInputHandler.java | 6 +-
.../gfac/ssh/handler/SSHOutputHandler.java | 12 +-
.../gfac/ssh/provider/impl/SSHProvider.java | 2 +-
.../airavata/gfac/ssh/util/GFACSSHUtils.java | 8 +-
.../apache/airavata/job/AMQPMonitorTest.java | 2 +-
.../airavata/gfac/server/GfacServerHandler.java | 32 +-
.../gfac/client/GfacClientFactoryTest.java | 4 +-
.../airavata/gfac/client/util/Initialize.java | 4 +-
.../airavata/integration/DataRetrievalIT.java | 2 +-
.../integration/tools/DocumentCreatorNew.java | 5 +-
.../integration/tools/DocumentCreatorUtils.java | 3 +-
.../validator/impl/BatchQueueValidator.java | 2 +-
.../cpi/impl/AbstractOrchestrator.java | 2 +-
.../orchestrator/core/util/Initialize.java | 4 +-
.../server/OrchestratorServerHandler.java | 96 +-
.../orchestrator/util/DataModelUtils.java | 4 +-
...ies~30f9d70adbd9ee7dd6f7d3eccbfca4baf19b09fa | 26 +
.../src/main/resources/gsissh.properties~HEAD | 26 +
.../orchestrator/client/util/Initialize.java | 4 +-
...ies~30f9d70adbd9ee7dd6f7d3eccbfca4baf19b09fa | 26 +
.../src/test/resources/gsissh.properties~HEAD | 26 +
...ies~30f9d70adbd9ee7dd6f7d3eccbfca4baf19b09fa | 30 +
.../src/test/resources/monitor.properties~HEAD | 30 +
...sql~30f9d70adbd9ee7dd6f7d3eccbfca4baf19b09fa | 361 +++
.../src/test/resources/registry-derby.sql~HEAD | 361 +++
modules/registry/experiment-catalog/pom.xml | 151 -
.../experiment/catalog/JPAConstants.java | 33 -
.../airavata/experiment/catalog/Resource.java | 71 -
.../experiment/catalog/ResourceType.java | 50 -
.../experiment/catalog/ResourceUtils.java | 525 ---
.../catalog/impl/ExperimentRegistry.java | 2983 ------------------
.../catalog/impl/GatewayRegistry.java | 115 -
.../catalog/impl/LoggingRegistryImpl.java | 97 -
.../catalog/impl/ProjectRegistry.java | 303 --
.../catalog/impl/RegistryFactory.java | 80 -
.../experiment/catalog/impl/RegistryImpl.java | 735 -----
.../experiment/catalog/impl/UserReg.java | 41 -
.../model/AdvancedInputDataHandling.java | 113 -
.../model/AdvancedOutputDataHandling.java | 104 -
.../catalog/model/ApplicationInput.java | 165 -
.../catalog/model/ApplicationInput_PK.java | 65 -
.../catalog/model/ApplicationOutput.java | 142 -
.../catalog/model/ApplicationOutput_PK.java | 64 -
.../Computational_Resource_Scheduling.java | 174 -
.../experiment/catalog/model/Configuration.java | 80 -
.../catalog/model/Configuration_PK.java | 74 -
.../catalog/model/DataTransferDetail.java | 91 -
.../experiment/catalog/model/ErrorDetail.java | 176 --
.../experiment/catalog/model/Experiment.java | 299 --
.../catalog/model/ExperimentConfigData.java | 142 -
.../catalog/model/Experiment_Input.java | 170 -
.../catalog/model/Experiment_Input_PK.java | 64 -
.../catalog/model/Experiment_Output.java | 143 -
.../catalog/model/Experiment_Output_PK.java | 64 -
.../experiment/catalog/model/Gateway.java | 76 -
.../catalog/model/Gateway_Worker.java | 82 -
.../catalog/model/Gateway_Worker_PK.java | 64 -
.../experiment/catalog/model/JobDetail.java | 135 -
.../experiment/catalog/model/JobDetails_PK.java | 64 -
.../experiment/catalog/model/NodeInput.java | 163 -
.../experiment/catalog/model/NodeInput_PK.java | 64 -
.../experiment/catalog/model/NodeOutput.java | 140 -
.../experiment/catalog/model/NodeOutput_PK.java | 64 -
.../catalog/model/Notification_Email.java | 81 -
.../experiment/catalog/model/Project.java | 125 -
.../experiment/catalog/model/ProjectUser.java | 81 -
.../catalog/model/ProjectUser_PK.java | 64 -
.../experiment/catalog/model/QosParam.java | 103 -
.../experiment/catalog/model/Status.java | 146 -
.../experiment/catalog/model/TaskDetail.java | 221 --
.../experiment/catalog/model/Users.java | 55 -
.../catalog/model/WorkflowNodeDetail.java | 155 -
.../catalog/resources/AbstractResource.java | 317 --
.../AdvanceInputDataHandlingResource.java | 160 -
.../AdvancedOutputDataHandlingResource.java | 150 -
.../resources/ApplicationInputResource.java | 230 --
.../resources/ApplicationOutputResource.java | 208 --
.../ComputationSchedulingResource.java | 221 --
.../catalog/resources/ConfigDataResource.java | 194 --
.../resources/ConfigurationResource.java | 204 --
.../resources/DataTransferDetailResource.java | 276 --
.../catalog/resources/ErrorDetailResource.java | 215 --
.../resources/ExperimentInputResource.java | 225 --
.../resources/ExperimentOutputResource.java | 204 --
.../catalog/resources/ExperimentResource.java | 831 -----
.../resources/ExperimentSummaryResource.java | 134 -
.../catalog/resources/GatewayResource.java | 437 ---
.../catalog/resources/JobDetailResource.java | 376 ---
.../catalog/resources/NodeInputResource.java | 227 --
.../catalog/resources/NodeOutputResource.java | 207 --
.../resources/NotificationEmailResource.java | 119 -
.../catalog/resources/ProjectResource.java | 508 ---
.../catalog/resources/ProjectUserResource.java | 123 -
.../catalog/resources/QosParamResource.java | 144 -
.../catalog/resources/StatusResource.java | 181 --
.../catalog/resources/TaskDetailResource.java | 748 -----
.../catalog/resources/UserResource.java | 186 --
.../experiment/catalog/resources/Utils.java | 1011 ------
.../catalog/resources/WorkerResource.java | 725 -----
.../resources/WorkflowNodeDetailResource.java | 515 ---
.../catalog/utils/QueryGenerator.java | 128 -
.../utils/ThriftDataModelConversion.java | 686 ----
.../src/main/resources/META-INF/persistence.xml | 65 -
.../src/main/resources/registry-derby.sql | 391 ---
.../src/main/resources/registry-mysql.sql | 392 ---
.../catalog/AbstractResourceTest.java | 91 -
.../catalog/ComputationalSchedulingTest.java | 84 -
.../catalog/ConfigurationResourceTest.java | 58 -
.../catalog/ExecutionErrorResourceTest.java | 95 -
.../catalog/ExperimentDataResourceTest.java | 107 -
.../catalog/ExperimentInputResourceTest.java | 75 -
.../catalog/ExperimentMetadataResourceTest.java | 87 -
.../catalog/ExperimentOutputResourceTest.java | 76 -
.../catalog/ExperimentResourceTest.java | 77 -
.../catalog/GFacJobDataResourceTest.java | 77 -
.../catalog/GFacJobStatusResourceTest.java | 87 -
.../experiment/catalog/GatewayResourceTest.java | 120 -
.../catalog/GramDataResourceTest.java | 72 -
.../catalog/NodeDataResourceTest.java | 72 -
.../catalog/OrchestratorDataResourceTest.java | 69 -
.../experiment/catalog/RegistryUseCaseTest.java | 296 --
.../catalog/TaskDetailResourceTest.java | 93 -
.../experiment/catalog/UserResourceTest.java | 54 -
.../experiment/catalog/WorkerResourceTest.java | 122 -
.../catalog/WorkflowDataResourceTest.java | 106 -
.../catalog/WorkflowNodeDetailResourceTest.java | 85 -
.../experiment/catalog/util/Initialize.java | 333 --
.../src/test/resources/registry-derby.sql | 391 ---
modules/registry/pom.xml | 2 +-
modules/registry/registry-core/pom.xml | 147 +
.../app/catalog/impl/AppCatalogFactory.java | 46 +
.../core/app/catalog/impl/AppCatalogImpl.java | 52 +
.../catalog/impl/ApplicationDeploymentImpl.java | 413 +++
.../catalog/impl/ApplicationInterfaceImpl.java | 450 +++
.../app/catalog/impl/ComputeResourceImpl.java | 888 ++++++
.../catalog/impl/GwyResourceProfileImpl.java | 252 ++
.../app/catalog/impl/WorkflowCatalogImpl.java | 232 ++
.../core/app/catalog/model/AppEnvironment.java | 76 +
.../app/catalog/model/AppEnvironment_PK.java | 64 +
.../core/app/catalog/model/AppInput_PK.java | 64 +
.../app/catalog/model/AppModuleMapping.java | 77 +
.../app/catalog/model/AppModuleMapping_PK.java | 64 +
.../core/app/catalog/model/AppOutput_PK.java | 64 +
.../catalog/model/ApplicationDeployment.java | 148 +
.../app/catalog/model/ApplicationInput.java | 166 +
.../app/catalog/model/ApplicationInterface.java | 97 +
.../app/catalog/model/ApplicationModule.java | 107 +
.../app/catalog/model/ApplicationOutput.java | 146 +
.../core/app/catalog/model/BatchQueue.java | 144 +
.../core/app/catalog/model/BatchQueue_PK.java | 63 +
.../app/catalog/model/CloudJobSubmission.java | 102 +
.../core/app/catalog/model/ComputeResource.java | 105 +
.../model/ComputeResourceFileSystem.java | 89 +
.../model/ComputeResourceFileSystem_PK.java | 62 +
.../model/ComputeResourcePreference.java | 154 +
.../model/ComputeResourcePreferencePK.java | 64 +
.../core/app/catalog/model/Configuration.java | 56 +
.../app/catalog/model/Configuration_PK.java | 65 +
.../catalog/model/DataMovementInterface.java | 124 +
.../catalog/model/DataMovementInterface_PK.java | 62 +
.../app/catalog/model/DataMovementProtocol.java | 76 +
.../catalog/model/DataMovementProtocolPK.java | 74 +
.../core/app/catalog/model/GSISSHExport.java | 73 +
.../core/app/catalog/model/GSISSHExportPK.java | 64 +
.../app/catalog/model/GSISSHSubmission.java | 82 +
.../core/app/catalog/model/GatewayProfile.java | 68 +
.../app/catalog/model/GlobusGKEndPointPK.java | 64 +
.../app/catalog/model/GlobusGKEndpoint.java | 65 +
.../app/catalog/model/GlobusJobSubmission.java | 62 +
.../app/catalog/model/GridftpDataMovement.java | 83 +
.../core/app/catalog/model/GridftpEndpoint.java | 102 +
.../app/catalog/model/GridftpEndpoint_PK.java | 62 +
.../core/app/catalog/model/HostAlias.java | 64 +
.../core/app/catalog/model/HostAliasPK.java | 64 +
.../core/app/catalog/model/HostIPAddress.java | 65 +
.../core/app/catalog/model/HostIPAddressPK.java | 64 +
.../app/catalog/model/JobManagerCommand.java | 89 +
.../app/catalog/model/JobManagerCommand_PK.java | 62 +
.../catalog/model/JobSubmissionInterface.java | 124 +
.../model/JobSubmissionInterface_PK.java | 62 +
.../catalog/model/JobSubmissionProtocol.java | 77 +
.../catalog/model/JobSubmissionProtocolPK.java | 74 +
.../app/catalog/model/LibraryApendPath.java | 76 +
.../app/catalog/model/LibraryApendPath_PK.java | 64 +
.../app/catalog/model/LibraryPrepandPath.java | 76 +
.../catalog/model/LibraryPrepandPath_PK.java | 64 +
.../app/catalog/model/LocalDataMovement.java | 49 +
.../core/app/catalog/model/LocalSubmission.java | 98 +
.../core/app/catalog/model/ModuleLoadCmd.java | 70 +
.../app/catalog/model/ModuleLoadCmd_PK.java | 63 +
.../core/app/catalog/model/PostJobCommand.java | 73 +
.../app/catalog/model/PostJobCommandPK.java | 64 +
.../core/app/catalog/model/PreJobCommand.java | 73 +
.../core/app/catalog/model/PreJobCommandPK.java | 64 +
.../app/catalog/model/ResourceJobManager.java | 106 +
.../core/app/catalog/model/ScpDataMovement.java | 117 +
.../app/catalog/model/SshJobSubmission.java | 144 +
.../app/catalog/model/UnicoreDataMovement.java | 65 +
.../app/catalog/model/UnicoreJobSubmission.java | 66 +
.../core/app/catalog/model/Workflow.java | 126 +
.../core/app/catalog/model/WorkflowInput.java | 167 +
.../app/catalog/model/WorkflowInput_PK.java | 64 +
.../core/app/catalog/model/WorkflowOutput.java | 117 +
.../app/catalog/model/WorkflowOutput_PK.java | 64 +
.../app/catalog/resources/AbstractResource.java | 382 +++
.../resources/AppCatAbstractResource.java | 382 +++
.../catalog/resources/AppCatalogResource.java | 90 +
.../AppDeploymentAppCatalogResourceAppCat.java | 446 +++
.../resources/AppDeploymentResource.java | 446 +++
.../AppEnvironmentAppCatalogResourceAppCat.java | 293 ++
.../resources/AppEnvironmentResource.java | 293 ++
.../AppInterfaceAppCatalogResourceAppCat.java | 363 +++
.../catalog/resources/AppInterfaceResource.java | 363 +++
.../AppModuleAppCatalogResourceAppCat.java | 344 ++
...ppModuleMappingAppCatalogResourceAppCat.java | 317 ++
.../resources/AppModuleMappingResource.java | 317 ++
.../catalog/resources/AppModuleResource.java | 344 ++
...pplicationInputAppCatalogResourceAppCat.java | 454 +++
.../resources/ApplicationInputResource.java | 454 +++
...plicationOutputAppCatalogResourceAppCat.java | 433 +++
.../resources/ApplicationOutputResource.java | 432 +++
.../BatchQueueAppCatalogResourceAppCat.java | 357 +++
.../catalog/resources/BatchQueueResource.java | 357 +++
...CloudSubmissionAppCatalogResourceAppCat.java | 298 ++
.../resources/CloudSubmissionResource.java | 298 ++
...eHostPreferenceAppCatalogResourceAppCat.java | 413 +++
.../ComputeHostPreferenceResource.java | 413 +++
...ComputeResourceAppCatalogResourceAppCat.java | 351 +++
...ourceFileSystemAppCatalogResourceAppCat.java | 307 ++
.../ComputeResourceFileSystemResource.java | 307 ++
.../resources/ComputeResourceResource.java | 351 +++
...vementInterfaceAppCatalogResourceAppCat.java | 339 ++
.../DataMovementInterfaceResource.java | 339 ++
.../resources/DataMovementProtocolResource.java | 360 +++
.../GSISSHExportAppCatalogResourceAppCat.java | 324 ++
.../catalog/resources/GSISSHExportResource.java | 324 ++
...SISSHSubmissionAppCatalogResourceAppCat.java | 373 +++
.../resources/GSISSHSubmissionResource.java | 373 +++
.../GatewayProfileAppCatalogResourceAppCat.java | 318 ++
.../resources/GatewayProfileResource.java | 318 ++
...lobusGKEndpointAppCatalogResourceAppCat.java | 323 ++
.../resources/GlobusGKEndpointResource.java | 321 ++
...usJobSubmissionAppCatalogResourceAppCat.java | 315 ++
.../resources/GlobusJobSubmissionResource.java | 315 ++
...ftpDataMovementAppCatalogResourceAppCat.java | 279 ++
.../resources/GridftpDataMovementResource.java | 279 ++
...GridftpEndpointAppCatalogResourceAppCat.java | 317 ++
.../resources/GridftpEndpointResource.java | 317 ++
.../HostAliasAppCatalogResourceAppCat.java | 317 ++
.../catalog/resources/HostAliasResource.java | 317 ++
.../HostIPAddressAppCatalogResourceAppCat.java | 318 ++
.../resources/HostIPAddressResource.java | 318 ++
...bManagerCommandAppCatalogResourceAppCat.java | 307 ++
.../resources/JobManagerCommandResource.java | 307 ++
...issionInterfaceAppCatalogResourceAppCat.java | 339 ++
.../JobSubmissionInterfaceResource.java | 339 ++
.../JobSubmissionProtocolResource.java | 359 +++
...ibraryApendPathAppCatalogResourceAppCat.java | 292 ++
.../resources/LibraryApendPathResource.java | 292 ++
...raryPrepandPathAppCatalogResourceAppCat.java | 291 ++
.../resources/LibraryPrepandPathResource.java | 291 ++
...calDataMovementAppCatalogResourceAppCat.java | 249 ++
.../resources/LocalDataMovementResource.java | 249 ++
...LocalSubmissionAppCatalogResourceAppCat.java | 293 ++
.../resources/LocalSubmissionResource.java | 293 ++
.../ModuleLoadCmdAppCatalogResourceAppCat.java | 300 ++
.../resources/ModuleLoadCmdResource.java | 300 ++
.../PostJobCommandAppCatalogResourceAppCat.java | 333 ++
.../resources/PostJobCommandResource.java | 333 ++
.../PreJobCommandAppCatalogResourceAppCat.java | 333 ++
.../resources/PreJobCommandResource.java | 333 ++
.../core/app/catalog/resources/Resource.java | 89 +
...ourceJobManagerAppCatalogResourceAppCat.java | 301 ++
.../resources/ResourceJobManagerResource.java | 301 ++
...ScpDataMovementAppCatalogResourceAppCat.java | 308 ++
.../resources/ScpDataMovementResource.java | 308 ++
...shJobSubmissionAppCatalogResourceAppCat.java | 332 ++
.../resources/SshJobSubmissionResource.java | 332 ++
...oreDataMovementAppCatalogResourceAppCat.java | 255 ++
.../resources/UnicoreDataMovementResource.java | 255 ++
...reJobSubmissionAppCatalogResourceAppCat.java | 328 ++
.../resources/UnicoreJobSubmissionResource.java | 328 ++
.../WorkflowAppCatalogResourceAppCat.java | 382 +++
.../WorkflowInputAppCatalogResourceAppCat.java | 451 +++
.../resources/WorkflowInputResource.java | 451 +++
.../WorkflowOutputAppCatalogResourceAppCat.java | 410 +++
.../resources/WorkflowOutputResource.java | 410 +++
.../app/catalog/resources/WorkflowResource.java | 382 +++
.../app/catalog/util/AppCatalogJPAUtils.java | 912 ++++++
.../catalog/util/AppCatalogQueryGenerator.java | 90 +
.../catalog/util/AppCatalogResourceType.java | 66 +
.../util/AppCatalogThriftConversion.java | 800 +++++
.../core/app/catalog/util/AppCatalogUtils.java | 31 +
.../experiment/catalog/ExpCatResourceUtils.java | 526 +++
.../catalog/ExperimentCatResource.java | 71 +
.../core/experiment/catalog/JPAConstants.java | 32 +
.../core/experiment/catalog/ResourceType.java | 49 +
.../catalog/impl/ExperimentCatalogImpl.java | 735 +++++
.../catalog/impl/ExperimentRegistry.java | 2983 ++++++++++++++++++
.../catalog/impl/GatewayRegistry.java | 115 +
.../impl/LoggingExperimentCatalogImpl.java | 97 +
.../catalog/impl/ProjectRegistry.java | 303 ++
.../catalog/impl/RegistryFactory.java | 80 +
.../core/experiment/catalog/impl/UserReg.java | 41 +
.../model/AdvancedInputDataHandling.java | 113 +
.../model/AdvancedOutputDataHandling.java | 105 +
.../catalog/model/ApplicationInput.java | 167 +
.../catalog/model/ApplicationInput_PK.java | 65 +
.../catalog/model/ApplicationOutput.java | 143 +
.../catalog/model/ApplicationOutput_PK.java | 64 +
.../Computational_Resource_Scheduling.java | 175 +
.../experiment/catalog/model/Configuration.java | 80 +
.../catalog/model/Configuration_PK.java | 74 +
.../catalog/model/DataTransferDetail.java | 93 +
.../experiment/catalog/model/ErrorDetail.java | 179 ++
.../experiment/catalog/model/Experiment.java | 299 ++
.../catalog/model/ExperimentConfigData.java | 142 +
.../catalog/model/Experiment_Input.java | 170 +
.../catalog/model/Experiment_Input_PK.java | 64 +
.../catalog/model/Experiment_Output.java | 143 +
.../catalog/model/Experiment_Output_PK.java | 64 +
.../core/experiment/catalog/model/Gateway.java | 76 +
.../catalog/model/Gateway_Worker.java | 82 +
.../catalog/model/Gateway_Worker_PK.java | 64 +
.../experiment/catalog/model/JobDetail.java | 135 +
.../experiment/catalog/model/JobDetails_PK.java | 64 +
.../experiment/catalog/model/NodeInput.java | 163 +
.../experiment/catalog/model/NodeInput_PK.java | 64 +
.../experiment/catalog/model/NodeOutput.java | 140 +
.../experiment/catalog/model/NodeOutput_PK.java | 64 +
.../catalog/model/Notification_Email.java | 81 +
.../core/experiment/catalog/model/Project.java | 125 +
.../experiment/catalog/model/ProjectUser.java | 81 +
.../catalog/model/ProjectUser_PK.java | 64 +
.../core/experiment/catalog/model/QosParam.java | 103 +
.../core/experiment/catalog/model/Status.java | 146 +
.../experiment/catalog/model/TaskDetail.java | 221 ++
.../core/experiment/catalog/model/Users.java | 55 +
.../catalog/model/WorkflowNodeDetail.java | 155 +
.../AbstractExperimentCatResource.java | 317 ++
...eInputDataHandlingExperimentCatResource.java | 160 +
...OutputDataHandlingExperimentCatResource.java | 150 +
.../ApplicationInputExperimentCatResource.java | 230 ++
.../ApplicationOutputExperimentCatResource.java | 208 ++
...putationSchedulingExperimentCatResource.java | 221 ++
.../ConfigDataExperimentCatResource.java | 194 ++
.../ConfigurationExperimentCatResource.java | 204 ++
...DataTransferDetailExperimentCatResource.java | 276 ++
.../ErrorDetailExperimentCatResource.java | 215 ++
.../ExperimentExperimentCatResource.java | 831 +++++
.../ExperimentInputExperimentCatResource.java | 225 ++
.../ExperimentOutputExperimentCatResource.java | 204 ++
.../ExperimentSummaryExperimentCatResource.java | 134 +
.../resources/GatewayExperimentCatResource.java | 437 +++
.../JobDetailExperimentCatResource.java | 376 +++
.../NodeInputExperimentCatResource.java | 227 ++
.../NodeOutputExperimentCatResource.java | 207 ++
.../NotificationEmailExperimentCatResource.java | 119 +
.../resources/ProjectExperimentCatResource.java | 508 +++
.../ProjectUserExperimentCatResource.java | 123 +
.../QosParamExperimentCatResource.java | 144 +
.../resources/StatusExperimentCatResource.java | 181 ++
.../TaskDetailExperimentCatResource.java | 748 +++++
.../resources/UserExperimentCatResource.java | 186 ++
.../experiment/catalog/resources/Utils.java | 1011 ++++++
.../resources/WorkerExperimentCatResource.java | 725 +++++
...WorkflowNodeDetailExperimentCatResource.java | 515 +++
.../catalog/utils/QueryGenerator.java | 128 +
.../utils/ThriftDataModelConversion.java | 686 ++++
.../core/experimet/catalog/JPAConstants.java | 33 +
.../core/experimet/catalog/Resource.java | 71 +
.../core/experimet/catalog/ResourceType.java | 50 +
.../core/experimet/catalog/ResourceUtils.java | 525 +++
.../catalog/impl/ExperimentCatalogImpl.java | 735 +++++
.../catalog/impl/ExperimentRegistry.java | 2983 ++++++++++++++++++
.../experimet/catalog/impl/GatewayRegistry.java | 115 +
.../impl/LoggingExperimentCatalogImpl.java | 97 +
.../experimet/catalog/impl/ProjectRegistry.java | 303 ++
.../experimet/catalog/impl/RegistryFactory.java | 80 +
.../core/experimet/catalog/impl/UserReg.java | 41 +
.../model/AdvancedInputDataHandling.java | 113 +
.../model/AdvancedOutputDataHandling.java | 104 +
.../catalog/model/ApplicationInput.java | 165 +
.../catalog/model/ApplicationInput_PK.java | 65 +
.../catalog/model/ApplicationOutput.java | 142 +
.../catalog/model/ApplicationOutput_PK.java | 64 +
.../Computational_Resource_Scheduling.java | 174 +
.../experimet/catalog/model/Configuration.java | 80 +
.../catalog/model/Configuration_PK.java | 74 +
.../catalog/model/DataTransferDetail.java | 91 +
.../experimet/catalog/model/ErrorDetail.java | 176 ++
.../experimet/catalog/model/Experiment.java | 299 ++
.../catalog/model/ExperimentConfigData.java | 142 +
.../catalog/model/Experiment_Input.java | 170 +
.../catalog/model/Experiment_Input_PK.java | 64 +
.../catalog/model/Experiment_Output.java | 143 +
.../catalog/model/Experiment_Output_PK.java | 64 +
.../core/experimet/catalog/model/Gateway.java | 76 +
.../experimet/catalog/model/Gateway_Worker.java | 82 +
.../catalog/model/Gateway_Worker_PK.java | 64 +
.../core/experimet/catalog/model/JobDetail.java | 135 +
.../experimet/catalog/model/JobDetails_PK.java | 64 +
.../core/experimet/catalog/model/NodeInput.java | 163 +
.../experimet/catalog/model/NodeInput_PK.java | 64 +
.../experimet/catalog/model/NodeOutput.java | 140 +
.../experimet/catalog/model/NodeOutput_PK.java | 64 +
.../catalog/model/Notification_Email.java | 81 +
.../core/experimet/catalog/model/Project.java | 125 +
.../experimet/catalog/model/ProjectUser.java | 81 +
.../experimet/catalog/model/ProjectUser_PK.java | 64 +
.../core/experimet/catalog/model/QosParam.java | 103 +
.../core/experimet/catalog/model/Status.java | 146 +
.../experimet/catalog/model/TaskDetail.java | 221 ++
.../core/experimet/catalog/model/Users.java | 55 +
.../catalog/model/WorkflowNodeDetail.java | 155 +
.../catalog/resources/AbstractResource.java | 317 ++
.../AdvanceInputDataHandlingResource.java | 160 +
.../AdvancedOutputDataHandlingResource.java | 150 +
.../resources/ApplicationInputResource.java | 230 ++
.../resources/ApplicationOutputResource.java | 208 ++
.../ComputationSchedulingResource.java | 221 ++
.../catalog/resources/ConfigDataResource.java | 194 ++
.../resources/ConfigurationResource.java | 204 ++
.../resources/DataTransferDetailResource.java | 276 ++
.../catalog/resources/ErrorDetailResource.java | 215 ++
.../resources/ExperimentInputResource.java | 225 ++
.../resources/ExperimentOutputResource.java | 204 ++
.../catalog/resources/ExperimentResource.java | 831 +++++
.../resources/ExperimentSummaryResource.java | 134 +
.../catalog/resources/GatewayResource.java | 437 +++
.../catalog/resources/JobDetailResource.java | 376 +++
.../catalog/resources/NodeInputResource.java | 227 ++
.../catalog/resources/NodeOutputResource.java | 207 ++
.../resources/NotificationEmailResource.java | 119 +
.../catalog/resources/ProjectResource.java | 508 +++
.../catalog/resources/ProjectUserResource.java | 123 +
.../catalog/resources/QosParamResource.java | 144 +
.../catalog/resources/StatusResource.java | 181 ++
.../catalog/resources/TaskDetailResource.java | 748 +++++
.../catalog/resources/UserResource.java | 186 ++
.../core/experimet/catalog/resources/Utils.java | 1011 ++++++
.../catalog/resources/WorkerResource.java | 725 +++++
.../resources/WorkflowNodeDetailResource.java | 515 +++
.../experimet/catalog/utils/QueryGenerator.java | 128 +
.../utils/ThriftDataModelConversion.java | 686 ++++
.../src/main/resources/META-INF/app-catalog.xml | 67 +
.../resources/META-INF/experiment-catalog.xml | 65 +
.../src/main/resources/META-INF/persistence.xml | 96 +
.../src/main/resources/appcatalog-derby.sql | 460 +++
.../src/main/resources/appcatalog-mysql.sql | 453 +++
.../src/main/resources/expcatalog-derby.sql | 391 +++
.../src/main/resources/expcatalog-mysql.sql | 392 +++
.../airavata/app/catalog/AppDeploymentTest.java | 146 +
.../airavata/app/catalog/AppInterfaceTest.java | 191 ++
...puteAppCatalogExperimentCatResourceTest.java | 297 ++
.../app/catalog/ComputeResourceTest.java | 297 ++
.../app/catalog/GatewayProfileTest.java | 127 +
.../airavata/app/catalog/util/Initialize.java | 320 ++
.../catalog/AbstractResourceTest.java | 91 +
.../catalog/ComputationalSchedulingTest.java | 85 +
.../ConfigurationExperimentCatResourceTest.java | 58 +
.../catalog/ConfigurationResourceTest.java | 58 +
.../catalog/ExecutionErrorResourceTest.java | 95 +
.../catalog/ExperimentCatalogUseCaseTest.java | 296 ++
.../catalog/ExperimentDataResourceTest.java | 107 +
.../ExperimentExperimentCatResourceTest.java | 78 +
...xperimentInputExperimentCatResourceTest.java | 77 +
.../catalog/ExperimentInputResourceTest.java | 75 +
.../catalog/ExperimentMetadataResourceTest.java | 87 +
...perimentOutputExperimentCatResourceTest.java | 77 +
.../catalog/ExperimentOutputResourceTest.java | 76 +
.../catalog/ExperimentResourceTest.java | 77 +
.../catalog/GFacJobDataResourceTest.java | 77 +
.../catalog/GFacJobStatusResourceTest.java | 87 +
.../GatewayExperimentCatResourceTest.java | 122 +
.../experiment/catalog/GatewayResourceTest.java | 120 +
.../catalog/GramDataResourceTest.java | 72 +
.../catalog/NodeDataResourceTest.java | 72 +
.../catalog/OrchestratorDataResourceTest.java | 69 +
.../TaskDetailExperimentCatResourceTest.java | 94 +
.../catalog/TaskDetailResourceTest.java | 93 +
.../catalog/UserExperimentCatResourceTest.java | 55 +
.../experiment/catalog/UserResourceTest.java | 54 +
.../experiment/catalog/WorkerResourceTest.java | 122 +
.../catalog/WorkflowDataResourceTest.java | 106 +
...flowNodeDetailExperimentCatResourceTest.java | 86 +
.../catalog/WorkflowNodeDetailResourceTest.java | 85 +
.../experiment/catalog/util/Initialize.java | 329 ++
.../src/test/resources/appcatalog-derby.sql | 460 +++
.../src/test/resources/expcatalog-derby.sql | 391 +++
modules/registry/registry-cpi/pom.xml | 5 +
.../airavata/registry/cpi/AppCatalog.java | 54 +
.../registry/cpi/AppCatalogException.java | 36 +
.../registry/cpi/ApplicationDeployment.java | 72 +
.../registry/cpi/ApplicationInterface.java | 148 +
.../airavata/registry/cpi/ChildDataType.java | 45 -
.../airavata/registry/cpi/ComputeResource.java | 249 ++
.../registry/cpi/ExpCatChildDataType.java | 45 +
.../registry/cpi/ExpCatParentDataType.java | 32 +
.../registry/cpi/ExperimentCatalog.java | 193 ++
.../cpi/ExperimentCatalogException.java | 38 +
.../cpi/ExperimentCatalogModelType.java | 51 +
.../registry/cpi/GwyResourceProfile.java | 81 +
.../airavata/registry/cpi/ParentDataType.java | 32 -
.../apache/airavata/registry/cpi/Registry.java | 178 +-
.../registry/cpi/RegistryModelType.java | 51 -
.../airavata/registry/cpi/WorkflowCatalog.java | 45 +
.../catalog/WorkflowCatalogFactory.java | 4 +-
.../workflow/engine/WorkflowEngineImpl.java | 10 +-
.../airavata/workflow/engine/WorkflowUtils.java | 4 +-
.../engine/interpretor/WorkflowInterpreter.java | 32 +-
pom.xml | 1 -
691 files changed, 86626 insertions(+), 50265 deletions(-)
----------------------------------------------------------------------