You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by sc...@apache.org on 2016/05/01 19:40:23 UTC
airavata git commit: changing info logs in AiravataServerHandler to
debug logs
Repository: airavata
Updated Branches:
refs/heads/develop e93e071a7 -> 63825ce32
changing info logs in AiravataServerHandler to debug logs
Project: http://git-wip-us.apache.org/repos/asf/airavata/repo
Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/63825ce3
Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/63825ce3
Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/63825ce3
Branch: refs/heads/develop
Commit: 63825ce32a4e129c663b6d23b3b15fbbede683a1
Parents: e93e071
Author: scnakandala <su...@gmail.com>
Authored: Sun May 1 13:40:17 2016 -0400
Committer: scnakandala <su...@gmail.com>
Committed: Sun May 1 13:40:17 2016 -0400
----------------------------------------------------------------------
.../server/handler/AiravataServerHandler.java | 222 +++++++++----------
1 file changed, 111 insertions(+), 111 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/airavata/blob/63825ce3/airavata-api/airavata-api-server/src/main/java/org/apache/airavata/api/server/handler/AiravataServerHandler.java
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-api-server/src/main/java/org/apache/airavata/api/server/handler/AiravataServerHandler.java b/airavata-api/airavata-api-server/src/main/java/org/apache/airavata/api/server/handler/AiravataServerHandler.java
index fed0696..a8b3375 100644
--- a/airavata-api/airavata-api-server/src/main/java/org/apache/airavata/api/server/handler/AiravataServerHandler.java
+++ b/airavata-api/airavata-api-server/src/main/java/org/apache/airavata/api/server/handler/AiravataServerHandler.java
@@ -151,7 +151,7 @@ public class AiravataServerHandler implements Airavata.Iface {
GatewayResourceProfile gatewayResourceProfile = new GatewayResourceProfile();
gatewayResourceProfile.setGatewayID(gatewayId);
appCatalog.getGatewayProfile().addGatewayResourceProfile(gatewayResourceProfile);
- logger.info("Airavata added gateway with gateway id : " + gateway.getGatewayId());
+ logger.debug("Airavata added gateway with gateway id : " + gateway.getGatewayId());
return gatewayId;
} catch (RegistryException e) {
logger.error("Error while adding gateway", e);
@@ -182,7 +182,7 @@ public class AiravataServerHandler implements Airavata.Iface {
throw exception;
}
experimentCatalog.update(ExperimentCatalogModelType.GATEWAY, updatedGateway, gatewayId);
- logger.info("Airavata update gateway with gateway id : " + gatewayId);
+ logger.debug("Airavata update gateway with gateway id : " + gatewayId);
} catch (RegistryException e) {
logger.error("Error while updating the gateway", e);
AiravataSystemException exception = new AiravataSystemException();
@@ -206,7 +206,7 @@ public class AiravataServerHandler implements Airavata.Iface {
throw exception;
}
Gateway gateway = (Gateway) experimentCatalog.get(ExperimentCatalogModelType.GATEWAY, gatewayId);
- logger.info("Airavata retrieved gateway with gateway id : " + gateway.getGatewayId());
+ logger.debug("Airavata retrieved gateway with gateway id : " + gateway.getGatewayId());
return gateway;
} catch (RegistryException e) {
logger.error("Error while getting the gateway", e);
@@ -230,7 +230,7 @@ public class AiravataServerHandler implements Airavata.Iface {
throw exception;
}
experimentCatalog.remove(ExperimentCatalogModelType.GATEWAY, gatewayId);
- logger.info("Airavata deleted gateway with gateway id : " + gatewayId);
+ logger.debug("Airavata deleted gateway with gateway id : " + gatewayId);
return true;
} catch (RegistryException e) {
logger.error("Error while deleting the gateway", e);
@@ -252,7 +252,7 @@ public class AiravataServerHandler implements Airavata.Iface {
for (Object gateway : list){
gateways.add((Gateway)gateway);
}
- logger.info("Airavata retrieved all available gateways...");
+ logger.debug("Airavata retrieved all available gateways...");
return gateways;
} catch (RegistryException e) {
logger.error("Error while getting all the gateways", e);
@@ -394,7 +394,7 @@ public class AiravataServerHandler implements Airavata.Iface {
sshCredential.setUsername(userName);
sshCredential.setGatewayId(gatewayId);
String key = csClient.addSSHCredential(sshCredential);
- logger.info("Airavata generated SSH keys for gateway : " + gatewayId + " and for user : " + userName);
+ logger.debug("Airavata generated SSH keys for gateway : " + gatewayId + " and for user : " + userName);
return key;
}catch (Exception e){
logger.error("Error occurred while registering SSH Credential", e);
@@ -413,7 +413,7 @@ public class AiravataServerHandler implements Airavata.Iface {
csClient = getCredentialStoreServiceClient();
}
SSHCredential sshCredential = csClient.getSSHCredential(airavataCredStoreToken, gatewayId);
- logger.info("Airavata retrieved SSH pub key for gateway id : " + gatewayId + " and for token : " + airavataCredStoreToken);
+ logger.debug("Airavata retrieved SSH pub key for gateway id : " + gatewayId + " and for token : " + airavataCredStoreToken);
return sshCredential.getPublicKey();
}catch (Exception e){
logger.error("Error occurred while retrieving SSH credential", e);
@@ -431,7 +431,7 @@ public class AiravataServerHandler implements Airavata.Iface {
if (csClient == null){
csClient = getCredentialStoreServiceClient();
}
- logger.info("Airavata retrieved all SSH pub keys for user name : " + userName);
+ logger.debug("Airavata retrieved all SSH pub keys for user name : " + userName);
return csClient.getAllSSHKeysForUser(userName);
}catch (Exception e){
logger.error("Error occurred while retrieving SSH public keys for user : " + userName , e);
@@ -449,7 +449,7 @@ public class AiravataServerHandler implements Airavata.Iface {
csClient = getCredentialStoreServiceClient();
}
Map<String, String> allSSHKeysForGateway = csClient.getAllSSHKeysForGateway(gatewayId);
- logger.info("Airavata retrieved all SSH pub keys for gateway Id : " + gatewayId);
+ logger.debug("Airavata retrieved all SSH pub keys for gateway Id : " + gatewayId);
return allSSHKeysForGateway;
}catch (Exception e){
logger.error("Error occurred while retrieving SSH public keys for gateway : " + gatewayId , e);
@@ -466,7 +466,7 @@ public class AiravataServerHandler implements Airavata.Iface {
if (csClient == null){
csClient = getCredentialStoreServiceClient();
}
- logger.info("Airavata deleted SSH pub key for gateway Id : " + gatewayId + " and with token id : " + airavataCredStoreToken);
+ logger.debug("Airavata deleted SSH pub key for gateway Id : " + gatewayId + " and with token id : " + airavataCredStoreToken);
return csClient.deleteSSHCredential(airavataCredStoreToken, gatewayId);
}catch (Exception e){
logger.error("Error occurred while deleting SSH credential", e);
@@ -502,7 +502,7 @@ public class AiravataServerHandler implements Airavata.Iface {
throw new AiravataSystemException(AiravataErrorType.INTERNAL_ERROR);
}
String projectId = (String) experimentCatalog.add(ExpCatParentDataType.PROJECT, project, gatewayId);
- logger.info("Airavata created project with project Id : " + projectId + " for gateway Id : " + gatewayId);
+ logger.debug("Airavata created project with project Id : " + projectId + " for gateway Id : " + gatewayId);
return projectId;
} catch (RegistryException e) {
logger.error("Error while creating the project", e);
@@ -533,7 +533,7 @@ public class AiravataServerHandler implements Airavata.Iface {
throw exception;
}
experimentCatalog.update(ExperimentCatalogModelType.PROJECT, updatedProject, projectId);
- logger.info("Airavata updated project with project Id : " + projectId );
+ logger.debug("Airavata updated project with project Id : " + projectId );
} catch (RegistryException e) {
logger.error("Error while updating the project", e);
AiravataSystemException exception = new AiravataSystemException();
@@ -558,7 +558,7 @@ public class AiravataServerHandler implements Airavata.Iface {
throw exception;
}
experimentCatalog.remove(ExperimentCatalogModelType.PROJECT, projectId);
- logger.info("Airavata deleted project with project Id : " + projectId );
+ logger.debug("Airavata deleted project with project Id : " + projectId );
return true;
} catch (RegistryException e) {
logger.error("Error while removing the project", e);
@@ -593,7 +593,7 @@ public class AiravataServerHandler implements Airavata.Iface {
exception.setMessage("Project does not exist in the system. Please provide a valid project ID...");
throw exception;
}
- logger.info("Airavata retrieved project with project Id : " + projectId );
+ logger.debug("Airavata retrieved project with project Id : " + projectId );
return (Project) experimentCatalog.get(ExperimentCatalogModelType.PROJECT, projectId);
} catch (RegistryException e) {
logger.error("Error while retrieving the project", e);
@@ -653,7 +653,7 @@ public class AiravataServerHandler implements Airavata.Iface {
projects.add((Project) o);
}
}
- logger.info("Airavata retrieved projects for user : " + userName + " and gateway id : " + gatewayId );
+ logger.debug("Airavata retrieved projects for user : " + userName + " and gateway id : " + gatewayId );
return projects;
} catch (RegistryException e) {
logger.error("Error while retrieving projects", e);
@@ -714,7 +714,7 @@ public class AiravataServerHandler implements Airavata.Iface {
for (Object object : results) {
projects.add((Project)object);
}
- logger.info("Airavata retrieved projects for user : " + userName + " and gateway id : " + gatewayId + " with project name : " + projectName);
+ logger.debug("Airavata retrieved projects for user : " + userName + " and gateway id : " + gatewayId + " with project name : " + projectName);
return projects;
}catch (Exception e) {
logger.error("Error while retrieving projects", e);
@@ -775,7 +775,7 @@ public class AiravataServerHandler implements Airavata.Iface {
for (Object object : results) {
projects.add((Project)object);
}
- logger.info("Airavata retrieved projects for user : " + userName + " and gateway id : " + gatewayId + " with project description : " + description);
+ logger.debug("Airavata retrieved projects for user : " + userName + " and gateway id : " + gatewayId + " with project description : " + description);
return projects;
}catch (Exception e) {
logger.error("Error while retrieving projects", e);
@@ -836,7 +836,7 @@ public class AiravataServerHandler implements Airavata.Iface {
for (Object object : results) {
summaries.add((ExperimentSummaryModel) object);
}
- logger.info("Airavata retrieved experiments for user : " + userName + " and gateway id : " + gatewayId + " with experiment name : " + expName);
+ logger.debug("Airavata retrieved experiments for user : " + userName + " and gateway id : " + gatewayId + " with experiment name : " + expName);
return summaries;
}catch (Exception e) {
logger.error("Error while retrieving experiments", e);
@@ -897,7 +897,7 @@ public class AiravataServerHandler implements Airavata.Iface {
for (Object object : results) {
summaries.add((ExperimentSummaryModel) object);
}
- logger.info("Airavata retrieved experiments for user : " + userName + " and gateway id : " + gatewayId + " with experiment description : " + description);
+ logger.debug("Airavata retrieved experiments for user : " + userName + " and gateway id : " + gatewayId + " with experiment description : " + description);
return summaries;
}catch (Exception e) {
logger.error("Error while retrieving experiments", e);
@@ -959,7 +959,7 @@ public class AiravataServerHandler implements Airavata.Iface {
for (Object object : results) {
summaries.add((ExperimentSummaryModel) object);
}
- logger.info("Airavata retrieved experiments for user : " + userName + " and gateway id : " + gatewayId + " with application id : " + applicationId);
+ logger.debug("Airavata retrieved experiments for user : " + userName + " and gateway id : " + gatewayId + " with application id : " + applicationId);
return summaries;
}catch (Exception e) {
logger.error("Error while retrieving experiments", e);
@@ -1021,7 +1021,7 @@ public class AiravataServerHandler implements Airavata.Iface {
for (Object object : results) {
summaries.add((ExperimentSummaryModel) object);
}
- logger.info("Airavata retrieved experiments for user : " + userName + " and gateway id : " + gatewayId + " with experiment status : " + experimentState);
+ logger.debug("Airavata retrieved experiments for user : " + userName + " and gateway id : " + gatewayId + " with experiment status : " + experimentState);
return summaries;
}catch (Exception e) {
logger.error("Error while retrieving experiments", e);
@@ -1086,7 +1086,7 @@ public class AiravataServerHandler implements Airavata.Iface {
for (Object object : results) {
summaries.add((ExperimentSummaryModel) object);
}
- logger.info("Airavata retrieved experiments for user : " + userName + " and gateway id : " + gatewayId + " with experiment creation time : " + AiravataUtils.getTime(fromTime));
+ logger.debug("Airavata retrieved experiments for user : " + userName + " and gateway id : " + gatewayId + " with experiment creation time : " + AiravataUtils.getTime(fromTime));
return summaries;
}catch (Exception e) {
logger.error("Error while retrieving experiments", e);
@@ -1164,7 +1164,7 @@ public class AiravataServerHandler implements Airavata.Iface {
for (Object object : results) {
summaries.add((ExperimentSummaryModel) object);
}
- logger.info("Airavata retrieved experiments for user : " + userName + " and gateway id : " + gatewayId );
+ logger.debug("Airavata retrieved experiments for user : " + userName + " and gateway id : " + gatewayId );
return summaries;
}catch (Exception e) {
logger.error("Error while retrieving experiments", e);
@@ -1203,7 +1203,7 @@ public class AiravataServerHandler implements Airavata.Iface {
filters.put(Constants.FieldConstants.ExperimentConstants.TO_DATE, toTime+"");
List<Object> results = experimentCatalog.search(ExperimentCatalogModelType.EXPERIMENT_STATISTICS, filters);
- logger.info("Airavata retrieved experiments for gateway id : " + gatewayId + " between : " + AiravataUtils.getTime(fromTime) + " and " + AiravataUtils.getTime(toTime));
+ logger.debug("Airavata retrieved experiments for gateway id : " + gatewayId + " between : " + AiravataUtils.getTime(fromTime) + " and " + AiravataUtils.getTime(toTime));
return (ExperimentStatistics) results.get(0);
}catch (Exception e) {
logger.error("Error while retrieving experiments", e);
@@ -1254,7 +1254,7 @@ public class AiravataServerHandler implements Airavata.Iface {
experiments.add((ExperimentModel) o);
}
}
- logger.info("Airavata retrieved experiments for project : " + projectId);
+ logger.debug("Airavata retrieved experiments for project : " + projectId);
return experiments;
} catch (Exception e) {
logger.error("Error while retrieving the experiments", e);
@@ -1312,7 +1312,7 @@ public class AiravataServerHandler implements Airavata.Iface {
experiments.add((ExperimentModel)o);
}
}
- logger.info("Airavata retrieved experiments for user : " + userName);
+ logger.debug("Airavata retrieved experiments for user : " + userName);
return experiments;
} catch (Exception e) {
logger.error("Error while retrieving the experiments", e);
@@ -1389,7 +1389,7 @@ public class AiravataServerHandler implements Airavata.Iface {
if(publisher!=null) {
publisher.publish(messageContext);
}
- logger.info(experimentId, "Created new experiment with experiment name {}", experiment.getExperimentName());
+ logger.debug(experimentId, "Created new experiment with experiment name {}", experiment.getExperimentName());
return experimentId;
} catch (Exception e) {
logger.error("Error while creating the experiment with experiment name {}", experiment.getExperimentName());
@@ -1424,7 +1424,7 @@ public class AiravataServerHandler implements Airavata.Iface {
throw new ExperimentCatalogException("Experiment is not in CREATED state. Hence cannot deleted. ID:"+ experimentId);
}
experimentCatalog.remove(ExperimentCatalogModelType.EXPERIMENT, experimentId);
- logger.info("Airavata removed experiment with experiment id : " + experimentId);
+ logger.debug("Airavata removed experiment with experiment id : " + experimentId);
return true;
} catch (Exception e) {
logger.error("Error while deleting the experiment", e);
@@ -1517,7 +1517,7 @@ public class AiravataServerHandler implements Airavata.Iface {
});
experimentModel.setProcesses(processList);
}
- logger.info("Airavata retrieved detailed experiment with experiment id : " + airavataExperimentId);
+ logger.debug("Airavata retrieved detailed experiment with experiment id : " + airavataExperimentId);
return experimentModel;
} catch (Exception e) {
logger.error("Error while retrieving the experiment", e);
@@ -1601,7 +1601,7 @@ public class AiravataServerHandler implements Airavata.Iface {
}
}
experimentCatalog.update(ExperimentCatalogModelType.EXPERIMENT, experiment, airavataExperimentId);
- logger.info(airavataExperimentId, "Successfully updated experiment {} ", experiment.getExperimentName());
+ logger.debug(airavataExperimentId, "Successfully updated experiment {} ", experiment.getExperimentName());
break;
default:
logger.error(airavataExperimentId, "Error while updating experiment. Update experiment is only valid for experiments " +
@@ -1640,7 +1640,7 @@ public class AiravataServerHandler implements Airavata.Iface {
switch (experimentState){
case CREATED: case VALIDATED: case CANCELED: case FAILED:
experimentCatalog.add(ExpCatChildDataType.USER_CONFIGURATION_DATA, userConfiguration, airavataExperimentId);
- logger.info(airavataExperimentId, "Successfully updated experiment configuration for experiment {}.", airavataExperimentId);
+ logger.debug(airavataExperimentId, "Successfully updated experiment configuration for experiment {}.", airavataExperimentId);
break;
default:
logger.error(airavataExperimentId, "Error while updating experiment {}. Update experiment is only valid for experiments " +
@@ -1673,7 +1673,7 @@ public class AiravataServerHandler implements Airavata.Iface {
try {
experimentCatalog = RegistryFactory.getDefaultExpCatalog();
if (!experimentCatalog.isExist(ExperimentCatalogModelType.EXPERIMENT, airavataExperimentId)){
- logger.info(airavataExperimentId, "Update resource scheduling failed, experiment {} doesn't exist.", airavataExperimentId);
+ logger.debug(airavataExperimentId, "Update resource scheduling failed, experiment {} doesn't exist.", airavataExperimentId);
throw new ExperimentNotFoundException("Requested experiment id " + airavataExperimentId + " does not exist in the system..");
}
ExperimentStatus experimentStatus = getExperimentStatusInternal(airavataExperimentId);
@@ -1682,7 +1682,7 @@ public class AiravataServerHandler implements Airavata.Iface {
switch (experimentState){
case CREATED: case VALIDATED: case CANCELED: case FAILED:
experimentCatalog.add(ExpCatChildDataType.PROCESS_RESOURCE_SCHEDULE, resourceScheduling, airavataExperimentId);
- logger.info(airavataExperimentId, "Successfully updated resource scheduling for the experiment {}.", airavataExperimentId);
+ logger.debug(airavataExperimentId, "Successfully updated resource scheduling for the experiment {}.", airavataExperimentId);
break;
default:
logger.error(airavataExperimentId, "Error while updating scheduling info. Update experiment is only valid for experiments " +
@@ -1740,10 +1740,10 @@ public class AiravataServerHandler implements Airavata.Iface {
Client orchestratorClient = getOrchestratorClient();
try{
if (orchestratorClient.validateExperiment(airavataExperimentId)) {
- logger.info(airavataExperimentId, "Experiment validation succeed.");
+ logger.debug(airavataExperimentId, "Experiment validation succeed.");
return true;
} else {
- logger.info(airavataExperimentId, "Experiment validation failed.");
+ logger.debug(airavataExperimentId, "Experiment validation failed.");
return false;
}}catch (TException e){
throw e;
@@ -1782,7 +1782,7 @@ public class AiravataServerHandler implements Airavata.Iface {
public ExperimentStatus getExperimentStatus(AuthzToken authzToken, String airavataExperimentId) throws InvalidRequestException,
ExperimentNotFoundException, AiravataClientException, AiravataSystemException, AuthorizationException, TException {
ExperimentStatus experimentStatus = getExperimentStatusInternal(airavataExperimentId);
- logger.info("Airavata retrieved experiment status for experiment id : " + airavataExperimentId);
+ logger.debug("Airavata retrieved experiment status for experiment id : " + airavataExperimentId);
return experimentStatus;
}
@@ -1816,7 +1816,7 @@ public class AiravataServerHandler implements Airavata.Iface {
logger.error(airavataExperimentId, "Get experiment outputs failed, experiment {} doesn't exit.", airavataExperimentId);
throw new ExperimentNotFoundException("Requested experiment id " + airavataExperimentId + " does not exist in the system..");
}
- logger.info("Airavata retrieved experiment outputs for experiment id : " + airavataExperimentId);
+ logger.debug("Airavata retrieved experiment outputs for experiment id : " + airavataExperimentId);
return (List<OutputDataObjectType>) experimentCatalog.get(ExperimentCatalogModelType.EXPERIMENT_OUTPUT, airavataExperimentId);
} catch (Exception e) {
logger.error(airavataExperimentId, "Error while retrieving the experiment outputs", e);
@@ -1867,7 +1867,7 @@ public class AiravataServerHandler implements Airavata.Iface {
}
}
}
- logger.info("Airavata retrieved job statuses for experiment with experiment id : " + airavataExperimentId);
+ logger.debug("Airavata retrieved job statuses for experiment with experiment id : " + airavataExperimentId);
return jobStatus;
} catch (Exception e) {
logger.error(airavataExperimentId, "Error while retrieving the job statuses", e);
@@ -1905,7 +1905,7 @@ public class AiravataServerHandler implements Airavata.Iface {
}
}
}
- logger.info("Airavata retrieved job models for experiment with experiment id : " + airavataExperimentId);
+ logger.debug("Airavata retrieved job models for experiment with experiment id : " + airavataExperimentId);
return jobList;
} catch (Exception e) {
logger.error(airavataExperimentId, "Error while retrieving the job details", e);
@@ -1972,7 +1972,7 @@ public class AiravataServerHandler implements Airavata.Iface {
OrchestratorService.Client orchestratorClient = getOrchestratorClient();
if (orchestratorClient.validateExperiment(airavataExperimentId)) {
orchestratorClient.launchExperiment(airavataExperimentId, gatewayId);
- logger.info("Airavata launched experiment with experiment id : " + airavataExperimentId);
+ logger.debug("Airavata launched experiment with experiment id : " + airavataExperimentId);
}else {
logger.error(airavataExperimentId, "Couldn't identify experiment type, experiment {} is neither single application nor workflow.", airavataExperimentId);
throw new InvalidRequestException("Experiment '" + airavataExperimentId + "' launch failed. Unable to figureout execution type for application " + applicationID);
@@ -2078,7 +2078,7 @@ public class AiravataServerHandler implements Airavata.Iface {
existingExperiment.getUserConfigurationData().setComputationalResourceScheduling(null);
}
}
- logger.info("Airavata cloned experiment with experiment id : " + existingExperimentID);
+ logger.debug("Airavata cloned experiment with experiment id : " + existingExperimentID);
return (String) experimentCatalog.add(ExpCatParentDataType.EXPERIMENT, existingExperiment, gatewayId);
} catch (Exception e) {
@@ -2122,7 +2122,7 @@ public class AiravataServerHandler implements Airavata.Iface {
}
Client client = getOrchestratorClient();
client.terminateExperiment(airavataExperimentId, gatewayId);
- logger.info("Airavata cancelled experiment with experiment id : " + airavataExperimentId);
+ logger.debug("Airavata cancelled experiment with experiment id : " + airavataExperimentId);
} catch (RegistryException e) {
logger.error(airavataExperimentId, "Error while cancelling the experiment...", e);
AiravataSystemException exception = new AiravataSystemException();
@@ -2150,7 +2150,7 @@ public class AiravataServerHandler implements Airavata.Iface {
try {
appCatalog = RegistryFactory.getAppCatalog();
String module = appCatalog.getApplicationInterface().addApplicationModule(applicationModule, gatewayId);
- logger.info("Airavata registered application module for gateway id : " + gatewayId);
+ logger.debug("Airavata registered application module for gateway id : " + gatewayId);
return module;
} catch (AppCatalogException e) {
logger.error("Error while adding application module...", e);
@@ -2175,7 +2175,7 @@ public class AiravataServerHandler implements Airavata.Iface {
try {
appCatalog = RegistryFactory.getAppCatalog();
ApplicationModule module = appCatalog.getApplicationInterface().getApplicationModule(appModuleId);
- logger.info("Airavata retrieved application module with module id : " + appModuleId);
+ logger.debug("Airavata retrieved application module with module id : " + appModuleId);
return module;
} catch (AppCatalogException e) {
logger.error(appModuleId, "Error while retrieving application module...", e);
@@ -2201,7 +2201,7 @@ public class AiravataServerHandler implements Airavata.Iface {
try {
appCatalog = RegistryFactory.getAppCatalog();
appCatalog.getApplicationInterface().updateApplicationModule(appModuleId, applicationModule);
- logger.info("Airavata updated application module with module id: " + appModuleId);
+ logger.debug("Airavata updated application module with module id: " + appModuleId);
return true;
} catch (AppCatalogException e) {
logger.error(appModuleId, "Error while updating application module...", e);
@@ -2223,7 +2223,7 @@ public class AiravataServerHandler implements Airavata.Iface {
try {
appCatalog = RegistryFactory.getAppCatalog();
List<ApplicationModule> moduleList = appCatalog.getApplicationInterface().getAllApplicationModules(gatewayId);
- logger.info("Airavata retrieved modules for gateway id : " + gatewayId);
+ logger.debug("Airavata retrieved modules for gateway id : " + gatewayId);
return moduleList;
} catch (AppCatalogException e) {
logger.error("Error while retrieving all application modules...", e);
@@ -2247,7 +2247,7 @@ public class AiravataServerHandler implements Airavata.Iface {
AiravataClientException, AiravataSystemException, AuthorizationException, TException {
try {
appCatalog = RegistryFactory.getAppCatalog();
- logger.info("Airavata deleted application module with module id : " + appModuleId);
+ logger.debug("Airavata deleted application module with module id : " + appModuleId);
return appCatalog.getApplicationInterface().removeApplicationModule(appModuleId);
} catch (AppCatalogException e) {
logger.error(appModuleId, "Error while deleting application module...", e);
@@ -2275,7 +2275,7 @@ public class AiravataServerHandler implements Airavata.Iface {
try {
appCatalog = RegistryFactory.getAppCatalog();
String deployment = appCatalog.getApplicationDeployment().addApplicationDeployment(applicationDeployment, gatewayId);
- logger.info("Airavata registered application deployment for gateway id : " + gatewayId);
+ logger.debug("Airavata registered application deployment for gateway id : " + gatewayId);
return deployment;
} catch (AppCatalogException e) {
logger.error("Error while adding application deployment...", e);
@@ -2300,7 +2300,7 @@ public class AiravataServerHandler implements Airavata.Iface {
try {
appCatalog = RegistryFactory.getAppCatalog();
ApplicationDeploymentDescription deployement = appCatalog.getApplicationDeployment().getApplicationDeployement(appDeploymentId);
- logger.info("Airavata registered application deployment for deployment id : " + appDeploymentId);
+ logger.debug("Airavata registered application deployment for deployment id : " + appDeploymentId);
return deployement;
} catch (AppCatalogException e) {
logger.error(appDeploymentId, "Error while retrieving application deployment...", e);
@@ -2327,7 +2327,7 @@ public class AiravataServerHandler implements Airavata.Iface {
try {
appCatalog = RegistryFactory.getAppCatalog();
appCatalog.getApplicationDeployment().updateApplicationDeployment(appDeploymentId, applicationDeployment);
- logger.info("Airavata updated application deployment for deployment id : " + appDeploymentId);
+ logger.debug("Airavata updated application deployment for deployment id : " + appDeploymentId);
return true;
} catch (AppCatalogException e) {
logger.error(appDeploymentId, "Error while updating application deployment...", e);
@@ -2352,7 +2352,7 @@ public class AiravataServerHandler implements Airavata.Iface {
try {
appCatalog = RegistryFactory.getAppCatalog();
appCatalog.getApplicationDeployment().removeAppDeployment(appDeploymentId);
- logger.info("Airavata removed application deployment with deployment id : " + appDeploymentId);
+ logger.debug("Airavata removed application deployment with deployment id : " + appDeploymentId);
return true;
} catch (AppCatalogException e) {
logger.error(appDeploymentId, "Error while deleting application deployment...", e);
@@ -2380,7 +2380,7 @@ public class AiravataServerHandler implements Airavata.Iface {
try {
appCatalog = RegistryFactory.getAppCatalog();
List<ApplicationDeploymentDescription> deployements = appCatalog.getApplicationDeployment().getAllApplicationDeployements(gatewayId);
- logger.info("Airavata retrieved application deployments for gateway id : " + gatewayId);
+ logger.debug("Airavata retrieved application deployments for gateway id : " + gatewayId);
return deployements;
} catch (AppCatalogException e) {
logger.error("Error while retrieving application deployments...", e);
@@ -2411,7 +2411,7 @@ public class AiravataServerHandler implements Airavata.Iface {
for (ApplicationDeploymentDescription description : applicationDeployments){
appDeployments.add(description.getAppDeploymentId());
}
- logger.info("Airavata retrieved application deployments for module id : " + appModuleId);
+ logger.debug("Airavata retrieved application deployments for module id : " + appModuleId);
return appDeployments;
} catch (AppCatalogException e) {
logger.error(appModuleId, "Error while retrieving application deployments...", e);
@@ -2440,7 +2440,7 @@ public class AiravataServerHandler implements Airavata.Iface {
try {
appCatalog = RegistryFactory.getAppCatalog();
String interfaceId = appCatalog.getApplicationInterface().addApplicationInterface(applicationInterface, gatewayId);
- logger.info("Airavata registered application interface for gateway id : " + gatewayId);
+ logger.debug("Airavata registered application interface for gateway id : " + gatewayId);
return interfaceId;
} catch (AppCatalogException e) {
logger.error("Error while adding application interface...", e);
@@ -2467,7 +2467,7 @@ public class AiravataServerHandler implements Airavata.Iface {
existingInterface.setApplicationName(newApplicationName);
existingInterface.setApplicationInterfaceId(airavata_commonsConstants.DEFAULT_ID);
String interfaceId = appCatalog.getApplicationInterface().addApplicationInterface(existingInterface, gatewayId);
- logger.info("Airavata cloned application interface : " + existingAppInterfaceID + " for gateway id : " + gatewayId );
+ logger.debug("Airavata cloned application interface : " + existingAppInterfaceID + " for gateway id : " + gatewayId );
return interfaceId;
} catch (AppCatalogException e) {
logger.error("Error while adding application interface...", e);
@@ -2492,7 +2492,7 @@ public class AiravataServerHandler implements Airavata.Iface {
try {
appCatalog = RegistryFactory.getAppCatalog();
ApplicationInterfaceDescription interfaceDescription = appCatalog.getApplicationInterface().getApplicationInterface(appInterfaceId);
- logger.info("Airavata retrieved application interface with interface id : " + appInterfaceId);
+ logger.debug("Airavata retrieved application interface with interface id : " + appInterfaceId);
return interfaceDescription;
} catch (AppCatalogException e) {
logger.error(appInterfaceId, "Error while retrieving application interface...", e);
@@ -2519,7 +2519,7 @@ public class AiravataServerHandler implements Airavata.Iface {
try {
appCatalog = RegistryFactory.getAppCatalog();
appCatalog.getApplicationInterface().updateApplicationInterface(appInterfaceId, applicationInterface);
- logger.info("Airavata updated application interface with interface id : " + appInterfaceId);
+ logger.debug("Airavata updated application interface with interface id : " + appInterfaceId);
return true;
} catch (AppCatalogException e) {
logger.error(appInterfaceId, "Error while updating application interface...", e);
@@ -2544,7 +2544,7 @@ public class AiravataServerHandler implements Airavata.Iface {
try {
appCatalog = RegistryFactory.getAppCatalog();
boolean removeApplicationInterface = appCatalog.getApplicationInterface().removeApplicationInterface(appInterfaceId);
- logger.info("Airavata removed application interface with interface id : " + appInterfaceId);
+ logger.debug("Airavata removed application interface with interface id : " + appInterfaceId);
return removeApplicationInterface;
} catch (AppCatalogException e) {
logger.error(appInterfaceId, "Error while deleting application interface...", e);
@@ -2578,7 +2578,7 @@ public class AiravataServerHandler implements Airavata.Iface {
allApplicationInterfacesMap.put(interfaceDescription.getApplicationInterfaceId(), interfaceDescription.getApplicationName());
}
}
- logger.info("Airavata retrieved application interfaces for gateway id : " + gatewayId);
+ logger.debug("Airavata retrieved application interfaces for gateway id : " + gatewayId);
return allApplicationInterfacesMap;
} catch (AppCatalogException e) {
logger.error("Error while retrieving application interfaces...", e);
@@ -2606,7 +2606,7 @@ public class AiravataServerHandler implements Airavata.Iface {
try {
appCatalog = RegistryFactory.getAppCatalog();
List<ApplicationInterfaceDescription> interfaces = appCatalog.getApplicationInterface().getAllApplicationInterfaces(gatewayId);
- logger.info("Airavata retrieved application interfaces for gateway id : " + gatewayId);
+ logger.debug("Airavata retrieved application interfaces for gateway id : " + gatewayId);
return interfaces;
} catch (AppCatalogException e) {
logger.error("Error while retrieving application interfaces...", e);
@@ -2631,7 +2631,7 @@ public class AiravataServerHandler implements Airavata.Iface {
try {
appCatalog = RegistryFactory.getAppCatalog();
List<InputDataObjectType> applicationInputs = appCatalog.getApplicationInterface().getApplicationInputs(appInterfaceId);
- logger.info("Airavata retrieved application inputs for application interface id : " + appInterfaceId);
+ logger.debug("Airavata retrieved application inputs for application interface id : " + appInterfaceId);
return applicationInputs;
} catch (AppCatalogException e) {
logger.error(appInterfaceId, "Error while retrieving application inputs...", e);
@@ -2654,7 +2654,7 @@ public class AiravataServerHandler implements Airavata.Iface {
public List<OutputDataObjectType> getApplicationOutputs(AuthzToken authzToken, String appInterfaceId) throws InvalidRequestException,
AiravataClientException, AiravataSystemException, AuthorizationException, TException {
List<OutputDataObjectType> list = getApplicationOutputsInternal(appInterfaceId);
- logger.info("Airavata retrieved application outputs for app interface id : " + appInterfaceId);
+ logger.debug("Airavata retrieved application outputs for app interface id : " + appInterfaceId);
return list;
}
@@ -2706,7 +2706,7 @@ public class AiravataServerHandler implements Airavata.Iface {
}
}
}
- logger.info("Airavata retrieved available compute resources for application interface id : " + appInterfaceId);
+ logger.debug("Airavata retrieved available compute resources for application interface id : " + appInterfaceId);
return availableComputeResources;
} catch (AppCatalogException e) {
logger.error(appInterfaceId, "Error while saving compute resource...", e);
@@ -2731,7 +2731,7 @@ public class AiravataServerHandler implements Airavata.Iface {
try {
appCatalog = RegistryFactory.getAppCatalog();
String computeResource = appCatalog.getComputeResource().addComputeResource(computeResourceDescription);
- logger.info("Airavata registered compute resource with compute resource Id : " + computeResource);
+ logger.debug("Airavata registered compute resource with compute resource Id : " + computeResource);
return computeResource;
} catch (AppCatalogException e) {
logger.error("Error while saving compute resource...", e);
@@ -2756,7 +2756,7 @@ public class AiravataServerHandler implements Airavata.Iface {
try {
appCatalog = RegistryFactory.getAppCatalog();
ComputeResourceDescription computeResource = appCatalog.getComputeResource().getComputeResource(computeResourceId);
- logger.info("Airavata retrieved compute resource with compute resource Id : " + computeResourceId);
+ logger.debug("Airavata retrieved compute resource with compute resource Id : " + computeResourceId);
return computeResource;
} catch (AppCatalogException e) {
logger.error(computeResourceId, "Error while retrieving compute resource...", e);
@@ -2780,7 +2780,7 @@ public class AiravataServerHandler implements Airavata.Iface {
try {
appCatalog = RegistryFactory.getAppCatalog();
Map<String, String> computeResourceIdList = appCatalog.getComputeResource().getAllComputeResourceIdList();
- logger.info("Airavata retrieved all the available compute resources...");
+ logger.debug("Airavata retrieved all the available compute resources...");
return computeResourceIdList;
} catch (AppCatalogException e) {
logger.error("Error while retrieving compute resource...", e);
@@ -2806,7 +2806,7 @@ public class AiravataServerHandler implements Airavata.Iface {
try {
appCatalog = RegistryFactory.getAppCatalog();
appCatalog.getComputeResource().updateComputeResource(computeResourceId, computeResourceDescription);
- logger.info("Airavata updated compute resource with compute resource Id : " + computeResourceId);
+ logger.debug("Airavata updated compute resource with compute resource Id : " + computeResourceId);
return true;
} catch (AppCatalogException e) {
logger.error(computeResourceId, "Error while updating compute resource...", e);
@@ -2831,7 +2831,7 @@ public class AiravataServerHandler implements Airavata.Iface {
try {
appCatalog = RegistryFactory.getAppCatalog();
appCatalog.getComputeResource().removeComputeResource(computeResourceId);
- logger.info("Airavata deleted compute resource with compute resource Id : " + computeResourceId);
+ logger.debug("Airavata deleted compute resource with compute resource Id : " + computeResourceId);
return true;
} catch (AppCatalogException e) {
logger.error(computeResourceId, "Error while deleting compute resource...", e);
@@ -2855,7 +2855,7 @@ public class AiravataServerHandler implements Airavata.Iface {
try {
appCatalog = RegistryFactory.getAppCatalog();
String storageResource = appCatalog.getStorageResource().addStorageResource(storageResourceDescription);
- logger.info("Airavata registered storage resource with storage resource Id : " + storageResource);
+ logger.debug("Airavata registered storage resource with storage resource Id : " + storageResource);
return storageResource;
} catch (AppCatalogException e) {
logger.error("Error while saving storage resource...", e);
@@ -2879,7 +2879,7 @@ public class AiravataServerHandler implements Airavata.Iface {
try {
appCatalog = RegistryFactory.getAppCatalog();
StorageResourceDescription storageResource = appCatalog.getStorageResource().getStorageResource(storageResourceId);
- logger.info("Airavata retrieved storage resource with storage resource Id : " + storageResourceId);
+ logger.debug("Airavata retrieved storage resource with storage resource Id : " + storageResourceId);
return storageResource;
} catch (AppCatalogException e) {
logger.error(storageResourceId, "Error while retrieving storage resource...", e);
@@ -2902,7 +2902,7 @@ public class AiravataServerHandler implements Airavata.Iface {
try {
appCatalog = RegistryFactory.getAppCatalog();
Map<String, String> resourceIdList = appCatalog.getStorageResource().getAllStorageResourceIdList();
- logger.info("Airavata retrieved storage resources list...");
+ logger.debug("Airavata retrieved storage resources list...");
return resourceIdList;
} catch (AppCatalogException e) {
logger.error("Error while retrieving storage resource...", e);
@@ -2927,7 +2927,7 @@ public class AiravataServerHandler implements Airavata.Iface {
try {
appCatalog = RegistryFactory.getAppCatalog();
appCatalog.getStorageResource().updateStorageResource(storageResourceId, storageResourceDescription);
- logger.info("Airavata updated storage resource with storage resource Id : " + storageResourceId);
+ logger.debug("Airavata updated storage resource with storage resource Id : " + storageResourceId);
return true;
} catch (AppCatalogException e) {
logger.error(storageResourceId, "Error while updating storage resource...", e);
@@ -2951,7 +2951,7 @@ public class AiravataServerHandler implements Airavata.Iface {
try {
appCatalog = RegistryFactory.getAppCatalog();
appCatalog.getStorageResource().removeStorageResource(storageResourceId);
- logger.info("Airavata deleted storage resource with storage resource Id : " + storageResourceId);
+ logger.debug("Airavata deleted storage resource with storage resource Id : " + storageResourceId);
return true;
} catch (AppCatalogException e) {
logger.error(storageResourceId, "Error while deleting storage resource...", e);
@@ -2981,7 +2981,7 @@ public class AiravataServerHandler implements Airavata.Iface {
ComputeResource computeResource = appCatalog.getComputeResource();
String submissionInterface = addJobSubmissionInterface(computeResource, computeResourceId,
computeResource.addLocalJobSubmission(localSubmission), JobSubmissionProtocol.LOCAL, priorityOrder);
- logger.info("Airavata added local job submission for compute resource id: " + computeResourceId);
+ logger.debug("Airavata added local job submission for compute resource id: " + computeResourceId);
return submissionInterface;
} catch (AppCatalogException e) {
logger.error(computeResourceId, "Error while adding job submission interface to resource compute resource...", e);
@@ -3008,7 +3008,7 @@ public class AiravataServerHandler implements Airavata.Iface {
LocalSubmissionResource submission = AppCatalogThriftConversion.getLocalJobSubmission(localSubmission);
submission.setJobSubmissionInterfaceId(jobSubmissionInterfaceId);
submission.save();
- logger.info("Airavata updated local job submission for job submission interface id: " + jobSubmissionInterfaceId);
+ logger.debug("Airavata updated local job submission for job submission interface id: " + jobSubmissionInterfaceId);
return true;
} catch (Exception e) {
logger.error(jobSubmissionInterfaceId, "Error while adding job submission interface to resource compute resource...", e);
@@ -3026,7 +3026,7 @@ public class AiravataServerHandler implements Airavata.Iface {
try {
appCatalog = RegistryFactory.getAppCatalog();
LOCALSubmission localJobSubmission = appCatalog.getComputeResource().getLocalJobSubmission(jobSubmissionId);
- logger.info("Airavata retrieved local job submission for job submission interface id: " + jobSubmissionId);
+ logger.debug("Airavata retrieved local job submission for job submission interface id: " + jobSubmissionId);
return localJobSubmission;
} catch (AppCatalogException e) {
String errorMsg = "Error while retrieving local job submission interface to resource compute resource...";
@@ -3068,7 +3068,7 @@ public class AiravataServerHandler implements Airavata.Iface {
ComputeResource computeResource = appCatalog.getComputeResource();
String submissionInterface = addJobSubmissionInterface(computeResource, computeResourceId,
computeResource.addSSHJobSubmission(sshJobSubmission), JobSubmissionProtocol.SSH, priorityOrder);
- logger.info("Airavata registered SSH job submission for compute resource id: " + computeResourceId);
+ logger.debug("Airavata registered SSH job submission for compute resource id: " + computeResourceId);
return submissionInterface;
} catch (AppCatalogException e) {
logger.error(computeResourceId, "Error while adding job submission interface to resource compute resource...", e);
@@ -3098,7 +3098,7 @@ public class AiravataServerHandler implements Airavata.Iface {
ComputeResource computeResource = appCatalog.getComputeResource();
String submissionDetails = addJobSubmissionInterface(computeResource, computeResourceId,
computeResource.addSSHJobSubmission(sshJobSubmission), JobSubmissionProtocol.SSH_FORK, priorityOrder);
- logger.info("Airavata registered Fork job submission for compute resource id: " + computeResourceId);
+ logger.debug("Airavata registered Fork job submission for compute resource id: " + computeResourceId);
return submissionDetails;
} catch (AppCatalogException e) {
logger.error(computeResourceId, "Error while adding job submission interface to resource compute resource...", e);
@@ -3116,7 +3116,7 @@ public class AiravataServerHandler implements Airavata.Iface {
try {
appCatalog = RegistryFactory.getAppCatalog();
SSHJobSubmission sshJobSubmission = appCatalog.getComputeResource().getSSHJobSubmission(jobSubmissionId);
- logger.info("Airavata retrieved SSH job submission for job submission interface id: " + jobSubmissionId);
+ logger.debug("Airavata retrieved SSH job submission for job submission interface id: " + jobSubmissionId);
return sshJobSubmission;
} catch (AppCatalogException e) {
String errorMsg = "Error while retrieving SSH job submission interface to resource compute resource...";
@@ -3148,7 +3148,7 @@ public class AiravataServerHandler implements Airavata.Iface {
ComputeResource computeResource = appCatalog.getComputeResource();
String submissionInterface = addJobSubmissionInterface(computeResource, computeResourceId,
computeResource.addCloudJobSubmission(cloudJobSubmission), JobSubmissionProtocol.CLOUD, priorityOrder);
- logger.info("Airavata registered Cloud job submission for compute resource id: " + computeResourceId);
+ logger.debug("Airavata registered Cloud job submission for compute resource id: " + computeResourceId);
return submissionInterface;
} catch (AppCatalogException e) {
logger.error(computeResourceId, "Error while adding job submission interface to resource compute resource...", e);
@@ -3166,7 +3166,7 @@ public class AiravataServerHandler implements Airavata.Iface {
try {
appCatalog = RegistryFactory.getAppCatalog();
CloudJobSubmission cloudJobSubmission = appCatalog.getComputeResource().getCloudJobSubmission(jobSubmissionId);
- logger.info("Airavata retrieved cloud job submission for job submission interface id: " + jobSubmissionId);
+ logger.debug("Airavata retrieved cloud job submission for job submission interface id: " + jobSubmissionId);
return cloudJobSubmission;
} catch (AppCatalogException e) {
String errorMsg = "Error while retrieving Cloud job submission interface to resource compute resource...";
@@ -3188,7 +3188,7 @@ public class AiravataServerHandler implements Airavata.Iface {
ComputeResource computeResource = appCatalog.getComputeResource();
String submissionInterface = addJobSubmissionInterface(computeResource, computeResourceId,
computeResource.addUNICOREJobSubmission(unicoreJobSubmission), JobSubmissionProtocol.UNICORE, priorityOrder);
- logger.info("Airavata registered UNICORE job submission for compute resource id: " + computeResourceId);
+ logger.debug("Airavata registered UNICORE job submission for compute resource id: " + computeResourceId);
return submissionInterface;
} catch (AppCatalogException e) {
logger.error("Error while adding job submission interface to resource compute resource...", e);
@@ -3206,7 +3206,7 @@ public class AiravataServerHandler implements Airavata.Iface {
try {
appCatalog = RegistryFactory.getAppCatalog();
UnicoreJobSubmission unicoreJobSubmission = appCatalog.getComputeResource().getUNICOREJobSubmission(jobSubmissionId);
- logger.info("Airavata retrieved UNICORE job submission for job submission interface id: " + jobSubmissionId);
+ logger.debug("Airavata retrieved UNICORE job submission for job submission interface id: " + jobSubmissionId);
return unicoreJobSubmission;
} catch (AppCatalogException e) {
String errorMsg = "Error while retrieving Unicore job submission interface to resource compute resource...";
@@ -3234,7 +3234,7 @@ public class AiravataServerHandler implements Airavata.Iface {
SshJobSubmissionResource submission = AppCatalogThriftConversion.getSSHJobSubmission(sshJobSubmission);
submission.setJobSubmissionInterfaceId(jobSubmissionInterfaceId);
submission.save();
- logger.info("Airavata updated SSH job submission for job submission interface id: " + jobSubmissionInterfaceId);
+ logger.debug("Airavata updated SSH job submission for job submission interface id: " + jobSubmissionInterfaceId);
return true;
} catch (Exception e) {
logger.error(jobSubmissionInterfaceId, "Error while adding job submission interface to resource compute resource...", e);
@@ -3261,7 +3261,7 @@ public class AiravataServerHandler implements Airavata.Iface {
CloudSubmissionResource submission = AppCatalogThriftConversion.getCloudJobSubmission(cloudJobSubmission);
submission.setJobSubmissionInterfaceId(jobSubmissionInterfaceId);
submission.save();
- logger.info("Airavata updated Cloud job submission for job submission interface id: " + jobSubmissionInterfaceId);
+ logger.debug("Airavata updated Cloud job submission for job submission interface id: " + jobSubmissionInterfaceId);
return true;
} catch (Exception e) {
logger.error(jobSubmissionInterfaceId, "Error while adding job submission interface to resource compute resource...", e);
@@ -3280,7 +3280,7 @@ public class AiravataServerHandler implements Airavata.Iface {
UnicoreJobSubmissionResource submission = AppCatalogThriftConversion.getUnicoreJobSubmission(unicoreJobSubmission);
submission.setjobSubmissionInterfaceId(jobSubmissionInterfaceId);
submission.save();
- logger.info("Airavata updated UNICORE job submission for job submission interface id: " + jobSubmissionInterfaceId);
+ logger.debug("Airavata updated UNICORE job submission for job submission interface id: " + jobSubmissionInterfaceId);
return true;
} catch (Exception e) {
logger.error(jobSubmissionInterfaceId, "Error while adding job submission interface to resource compute resource...", e);
@@ -3311,7 +3311,7 @@ public class AiravataServerHandler implements Airavata.Iface {
ComputeResource computeResource = appCatalog.getComputeResource();
String movementInterface = addDataMovementInterface(computeResource, resourceId, dmType,
computeResource.addLocalDataMovement(localDataMovement), DataMovementProtocol.LOCAL, priorityOrder);
- logger.info("Airavata registered local data movement for resource Id: " + resourceId);
+ logger.debug("Airavata registered local data movement for resource Id: " + resourceId);
return movementInterface;
} catch (AppCatalogException e) {
logger.error(resourceId, "Error while adding data movement interface to resource resource...", e);
@@ -3338,7 +3338,7 @@ public class AiravataServerHandler implements Airavata.Iface {
LocalDataMovementResource movment = AppCatalogThriftConversion.getLocalDataMovement(localDataMovement);
movment.setDataMovementInterfaceId(dataMovementInterfaceId);
movment.save();
- logger.info("Airavata updated local data movement with data movement id: " + dataMovementInterfaceId);
+ logger.debug("Airavata updated local data movement with data movement id: " + dataMovementInterfaceId);
return true;
} catch (Exception e) {
logger.error(dataMovementInterfaceId, "Error while updating local data movement interface..", e);
@@ -3356,7 +3356,7 @@ public class AiravataServerHandler implements Airavata.Iface {
try {
appCatalog = RegistryFactory.getAppCatalog();
LOCALDataMovement localDataMovement = appCatalog.getComputeResource().getLocalDataMovement(dataMovementId);
- logger.info("Airavata retrieved local data movement with data movement id: " + dataMovementId);
+ logger.debug("Airavata retrieved local data movement with data movement id: " + dataMovementId);
return localDataMovement;
} catch (AppCatalogException e) {
String errorMsg = "Error while retrieving local data movement interface to resource compute resource...";
@@ -3398,7 +3398,7 @@ public class AiravataServerHandler implements Airavata.Iface {
ComputeResource computeResource = appCatalog.getComputeResource();
String movementInterface = addDataMovementInterface(computeResource, resourceId, dmType,
computeResource.addScpDataMovement(scpDataMovement), DataMovementProtocol.SCP, priorityOrder);
- logger.info("Airavata registered SCP data movement for resource Id: " + resourceId);
+ logger.debug("Airavata registered SCP data movement for resource Id: " + resourceId);
return movementInterface;
} catch (AppCatalogException e) {
logger.error(resourceId, "Error while adding data movement interface to resource compute resource...", e);
@@ -3426,7 +3426,7 @@ public class AiravataServerHandler implements Airavata.Iface {
ScpDataMovementResource movment = AppCatalogThriftConversion.getSCPDataMovementDescription(scpDataMovement);
movment.setDataMovementInterfaceId(dataMovementInterfaceId);
movment.save();
- logger.info("Airavata updated SCP data movement with data movement id: " + dataMovementInterfaceId);
+ logger.debug("Airavata updated SCP data movement with data movement id: " + dataMovementInterfaceId);
return true;
} catch (Exception e) {
logger.error(dataMovementInterfaceId, "Error while adding job submission interface to resource compute resource...", e);
@@ -3444,7 +3444,7 @@ public class AiravataServerHandler implements Airavata.Iface {
try {
appCatalog = RegistryFactory.getAppCatalog();
SCPDataMovement scpDataMovement = appCatalog.getComputeResource().getSCPDataMovement(dataMovementId);
- logger.info("Airavata retrieved SCP data movement with data movement id: " + dataMovementId);
+ logger.debug("Airavata retrieved SCP data movement with data movement id: " + dataMovementId);
return scpDataMovement;
} catch (AppCatalogException e) {
String errorMsg = "Error while retrieving SCP data movement interface to resource compute resource...";
@@ -3465,7 +3465,7 @@ public class AiravataServerHandler implements Airavata.Iface {
ComputeResource computeResource = appCatalog.getComputeResource();
String movementInterface = addDataMovementInterface(computeResource, resourceId, dmType,
computeResource.addUnicoreDataMovement(unicoreDataMovement), DataMovementProtocol.UNICORE_STORAGE_SERVICE, priorityOrder);
- logger.info("Airavata registered UNICORE data movement for resource Id: " + resourceId);
+ logger.debug("Airavata registered UNICORE data movement for resource Id: " + resourceId);
return movementInterface;
} catch (AppCatalogException e) {
logger.error(resourceId, "Error while adding data movement interface to resource compute resource...", e);
@@ -3484,7 +3484,7 @@ public class AiravataServerHandler implements Airavata.Iface {
UnicoreDataMovementResource movment = AppCatalogThriftConversion.getUnicoreDMResource(unicoreDataMovement);
movment.setDataMovementId(dataMovementInterfaceId);
movment.save();
- logger.info("Airavata updated UNICORE data movement with data movement id: " + dataMovementInterfaceId);
+ logger.debug("Airavata updated UNICORE data movement with data movement id: " + dataMovementInterfaceId);
return true;
} catch (Exception e) {
logger.error(dataMovementInterfaceId, "Error while updating unicore data movement to compute resource...", e);
@@ -3502,7 +3502,7 @@ public class AiravataServerHandler implements Airavata.Iface {
try {
appCatalog = RegistryFactory.getAppCatalog();
UnicoreDataMovement unicoreDataMovement = appCatalog.getComputeResource().getUNICOREDataMovement(dataMovementId);
- logger.info("Airavata retrieved UNICORE data movement with data movement id: " + dataMovementId);
+ logger.debug("Airavata retrieved UNICORE data movement with data movement id: " + dataMovementId);
return unicoreDataMovement;
} catch (AppCatalogException e) {
String errorMsg = "Error while retrieving UNICORE data movement interface...";
@@ -3534,7 +3534,7 @@ public class AiravataServerHandler implements Airavata.Iface {
ComputeResource computeResource = appCatalog.getComputeResource();
String addDataMovementInterface = addDataMovementInterface(computeResource, computeResourceId, dmType,
computeResource.addGridFTPDataMovement(gridFTPDataMovement), DataMovementProtocol.GridFTP, priorityOrder);
- logger.info("Airavata registered GridFTP data movement for resource Id: " + computeResourceId);
+ logger.debug("Airavata registered GridFTP data movement for resource Id: " + computeResourceId);
return addDataMovementInterface;
} catch (AppCatalogException e) {
logger.error(computeResourceId, "Error while adding data movement interface to resource compute resource...", e);
@@ -3562,7 +3562,7 @@ public class AiravataServerHandler implements Airavata.Iface {
GridftpDataMovementResource movment = AppCatalogThriftConversion.getGridFTPDataMovementDescription(gridFTPDataMovement);
movment.setDataMovementInterfaceId(dataMovementInterfaceId);
movment.save();
- logger.info("Airavata updated GRIDFTP data movement with data movement id: " + dataMovementInterfaceId );
+ logger.debug("Airavata updated GRIDFTP data movement with data movement id: " + dataMovementInterfaceId );
return true;
} catch (Exception e) {
logger.error(dataMovementInterfaceId, "Error while adding job submission interface to resource compute resource...", e);
@@ -3580,7 +3580,7 @@ public class AiravataServerHandler implements Airavata.Iface {
try {
appCatalog = RegistryFactory.getAppCatalog();
GridFTPDataMovement gridFTPDataMovement = appCatalog.getComputeResource().getGridFTPDataMovement(dataMovementId);
- logger.info("Airavata retrieved GRIDFTP data movement with data movement id: " + dataMovementId);
+ logger.debug("Airavata retrieved GRIDFTP data movement with data movement id: " + dataMovementId);
return gridFTPDataMovement;
} catch (AppCatalogException e) {
String errorMsg = "Error while retrieving GridFTP data movement interface to resource compute resource...";
@@ -3664,7 +3664,7 @@ public class AiravataServerHandler implements Airavata.Iface {
try {
appCatalog = RegistryFactory.getAppCatalog();
appCatalog.getComputeResource().removeJobSubmissionInterface(computeResourceId, jobSubmissionInterfaceId);
- logger.info("Airavata deleted job submission interface with interface id : " + jobSubmissionInterfaceId);
+ logger.debug("Airavata deleted job submission interface with interface id : " + jobSubmissionInterfaceId);
return true;
} catch (AppCatalogException e) {
logger.error(jobSubmissionInterfaceId, "Error while deleting job submission interface...", e);
@@ -3691,11 +3691,11 @@ public class AiravataServerHandler implements Airavata.Iface {
switch (dmType){
case COMPUTE_RESOURCE:
appCatalog.getComputeResource().removeDataMovementInterface(resourceId, dataMovementInterfaceId);
- logger.info("Airavata deleted data movement interface with interface id : " + dataMovementInterfaceId);
+ logger.debug("Airavata deleted data movement interface with interface id : " + dataMovementInterfaceId);
return true;
case STORAGE_RESOURCE:
appCatalog.getStorageResource().removeDataMovementInterface(resourceId, dataMovementInterfaceId);
- logger.info("Airavata deleted data movement interface with interface id : " + dataMovementInterfaceId);
+ logger.debug("Airavata deleted data movement interface with interface id : " + dataMovementInterfaceId);
return true;
default:
logger.error("Unsupported data movement type specifies.. Please provide the correct data movement type... ");
@@ -3821,7 +3821,7 @@ public class AiravataServerHandler implements Airavata.Iface {
appCatalog = RegistryFactory.getAppCatalog();
GwyResourceProfile gatewayProfile = appCatalog.getGatewayProfile();
String resourceProfile = gatewayProfile.addGatewayResourceProfile(gatewayResourceProfile);
- logger.info("Airavata registered gateway profile with gateway id : " + gatewayResourceProfile.getGatewayID());
+ logger.debug("Airavata registered gateway profile with gateway id : " + gatewayResourceProfile.getGatewayID());
return resourceProfile;
} catch (AppCatalogException e) {
logger.error("Error while registering gateway resource profile...", e);
@@ -3851,7 +3851,7 @@ public class AiravataServerHandler implements Airavata.Iface {
appCatalog = RegistryFactory.getAppCatalog();
GwyResourceProfile gatewayProfile = appCatalog.getGatewayProfile();
GatewayResourceProfile gatewayResourceProfile = gatewayProfile.getGatewayProfile(gatewayID);
- logger.info("Airavata retrieved gateway profile with gateway id : " + gatewayID);
+ logger.debug("Airavata retrieved gateway profile with gateway id : " + gatewayID);
return gatewayResourceProfile;
} catch (AppCatalogException e) {
logger.error(gatewayID, "Error while retrieving gateway resource profile...", e);
@@ -3882,7 +3882,7 @@ public class AiravataServerHandler implements Airavata.Iface {
appCatalog = RegistryFactory.getAppCatalog();
GwyResourceProfile gatewayProfile = appCatalog.getGatewayProfile();
gatewayProfile.updateGatewayResourceProfile(gatewayID, gatewayResourceProfile);
- logger.info("Airavata updated gateway profile with gateway id : " + gatewayID);
+ logger.debug("Airavata updated gateway profile with gateway id : " + gatewayID);
return true;
} catch (AppCatalogException e) {
logger.error(gatewayID, "Error while updating gateway resource profile...", e);
@@ -3912,7 +3912,7 @@ public class AiravataServerHandler implements Airavata.Iface {
appCatalog = RegistryFactory.getAppCatalog();
GwyResourceProfile gatewayProfile = appCatalog.getGatewayProfile();
gatewayProfile.removeGatewayResourceProfile(gatewayID);
- logger.info("Airavata deleted gateway profile with gateway id : " + gatewayID);
+ logger.debug("Airavata deleted gateway profile with gateway id : " + gatewayID);
return true;
} catch (AppCatalogException e) {
logger.error(gatewayID, "Error while removing gateway resource profile...", e);
@@ -3952,7 +3952,7 @@ public class AiravataServerHandler implements Airavata.Iface {
// gatewayProfile.removeGatewayResourceProfile(gatewayID);
profile.addToComputeResourcePreferences(computeResourcePreference);
gatewayProfile.updateGatewayResourceProfile(gatewayID, profile);
- logger.info("Airavata added gateway compute resource preference with gateway id : " + gatewayID + " and for compute resource id : " + computeResourceId );
+ logger.debug("Airavata added gateway compute resource preference with gateway id : " + gatewayID + " and for compute resource id : " + computeResourceId );
return true;
} catch (AppCatalogException e) {
logger.error(gatewayID, "Error while registering gateway resource profile preference...", e);
@@ -3980,7 +3980,7 @@ public class AiravataServerHandler implements Airavata.Iface {
dataStoragePreference.setStorageResourceId(storageResourceId);
profile.addToStoragePreferences(dataStoragePreference);
gatewayProfile.updateGatewayResourceProfile(gatewayID, profile);
- logger.info("Airavata added storage resource preference with gateway id : " + gatewayID + " and for storage resource id : " + storageResourceId );
+ logger.debug("Airavata added storage resource preference with gateway id : " + gatewayID + " and for storage resource id : " + storageResourceId );
return true;
} catch (AppCatalogException e) {
logger.error(gatewayID, "Error while registering gateway resource profile preference...", e);
@@ -4026,7 +4026,7 @@ public class AiravataServerHandler implements Airavata.Iface {
throw exception;
}
ComputeResourcePreference computeResourcePreference = gatewayProfile.getComputeResourcePreference(gatewayID, computeResourceId);
- logger.info("Airavata retrieved gateway compute resource preference with gateway id : " + gatewayID + " and for compute resoruce id : " + computeResourceId );
+ logger.debug("Airavata retrieved gateway compute resource preference with gateway id : " + gatewayID + " and for compute resoruce id : " + computeResourceId );
return computeResourcePreference;
} catch (AppCatalogException e) {
logger.error(gatewayID, "Error while reading gateway compute resource preference...", e);
@@ -4055,7 +4055,7 @@ public class AiravataServerHandler implements Airavata.Iface {
}
StoragePreference storagePreference = gatewayProfile.getStoragePreference(gatewayID, storageId);
- logger.info("Airavata retrieved storage resource preference with gateway id : " + gatewayID + " and for storage resource id : " + storageId);
+ logger.debug("Airavata retrieved storage resource preference with gateway id : " + gatewayID + " and for storage resource id : " + storageId);
return storagePreference;
} catch (AppCatalogException e) {
logger.error(gatewayID, "Error while reading gateway data storage preference...", e);
@@ -4165,7 +4165,7 @@ public class AiravataServerHandler implements Airavata.Iface {
}
profile.getComputeResourcePreferences().add(computeResourcePreference);
gatewayProfile.updateGatewayResourceProfile(gatewayID, profile);
- logger.info("Airavata updated compute resource preference with gateway id : " + gatewayID + " and for compute resource id : " + computeResourceId );
+ logger.debug("Airavata updated compute resource preference with gateway id : " + gatewayID + " and for compute resource id : " + computeResourceId );
return true;
} catch (AppCatalogException e) {
logger.error(gatewayID, "Error while reading gateway compute resource preference...", e);
@@ -4200,7 +4200,7 @@ public class AiravataServerHandler implements Airavata.Iface {
}
profile.getStoragePreferences().add(dataStoragePreference);
gatewayProfile.updateGatewayResourceProfile(gatewayID, profile);
- logger.info("Airavata updated storage resource preference with gateway id : " + gatewayID + " and for storage resource id : " + storageId );
+ logger.debug("Airavata updated storage resource preference with gateway id : " + gatewayID + " and for storage resource id : " + storageId );
return true;
} catch (AppCatalogException e) {
logger.error(gatewayID, "Error while reading gateway data storage preference...", e);