renaming the module
Project: http://git-wip-us.apache.org/repos/asf/airavata/repo Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/1ad9ae5d Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/1ad9ae5d Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/1ad9ae5d Branch: refs/heads/develop Commit: 1ad9ae5d0891b89462c6cdfa8e1961475c3493b2 Parents: 312d7a2 Author: scnakandala <[email protected]> Authored: Tue Jan 12 10:40:49 2016 -0500 Committer: scnakandala <[email protected]> Committed: Tue Jan 12 10:40:51 2016 -0500 ---------------------------------------------------------------------- .../java/org/apache/airavata/api/Airavata.java | 2 +- .../file__transfer_models_constants.cpp | 2 +- .../airavata/file__transfer_models_constants.h | 2 +- .../airavata/file__transfer_models_types.cpp | 2 +- .../lib/airavata/file__transfer_models_types.h | 2 +- .../lib/airavata/metadata_models_constants.cpp | 2 +- .../lib/airavata/metadata_models_constants.h | 2 +- .../lib/airavata/metadata_models_types.cpp | 2 +- .../lib/airavata/metadata_models_types.h | 2 +- .../lib/airavata/replica_models_constants.cpp | 2 +- .../lib/airavata/replica_models_constants.h | 2 +- .../lib/airavata/replica_models_types.cpp | 2 +- .../lib/airavata/replica_models_types.h | 2 +- .../lib/Airavata/Model/File/Replica/Types.php | 1028 ------- .../lib/Airavata/Model/File/Transfer/Types.php | 890 ------ .../lib/Airavata/Model/File/metadata/Types.php | 371 --- .../lib/apache/airavata/model/file/__init__.py | 0 .../airavata/model/file/metadata/__init__.py | 1 - .../airavata/model/file/metadata/constants.py | 11 - .../airavata/model/file/metadata/ttypes.py | 232 -- .../airavata/model/file/replica/__init__.py | 1 - .../airavata/model/file/replica/constants.py | 11 - .../airavata/model/file/replica/ttypes.py | 663 ----- .../airavata/model/file/transfer/__init__.py | 1 - .../airavata/model/file/transfer/constants.py | 11 - .../airavata/model/file/transfer/ttypes.py | 597 ---- .../lib/apache/airavata/model/ttypes.py | 6 +- .../org/apache/airavata/model/Workflow.java | 2 +- .../ApplicationDeploymentDescription.java | 2 +- .../appdeployment/ApplicationModule.java | 2 +- .../appcatalog/appdeployment/CommandObject.java | 2 +- .../appcatalog/appdeployment/SetEnvPaths.java | 2 +- .../ApplicationInterfaceDescription.java | 2 +- .../appcatalog/computeresource/BatchQueue.java | 2 +- .../computeresource/CloudJobSubmission.java | 2 +- .../ComputeResourceDescription.java | 2 +- .../computeresource/GlobusJobSubmission.java | 2 +- .../computeresource/JobSubmissionInterface.java | 2 +- .../computeresource/LOCALSubmission.java | 2 +- .../computeresource/ResourceJobManager.java | 2 +- .../computeresource/SSHJobSubmission.java | 2 +- .../computeresource/UnicoreJobSubmission.java | 2 +- .../ComputeResourcePreference.java | 2 +- .../gatewayprofile/GatewayResourceProfile.java | 2 +- .../gatewayprofile/StoragePreference.java | 2 +- .../StorageResourceDescription.java | 2 +- .../application/io/InputDataObjectType.java | 2 +- .../application/io/OutputDataObjectType.java | 2 +- .../airavata/model/commons/ErrorModel.java | 2 +- .../model/commons/ValidationResults.java | 2 +- .../airavata/model/commons/ValidatorResult.java | 2 +- .../data/movement/DataMovementInterface.java | 2 +- .../data/movement/GridFTPDataMovement.java | 2 +- .../model/data/movement/LOCALDataMovement.java | 2 +- .../model/data/movement/SCPDataMovement.java | 2 +- .../data/movement/UnicoreDataMovement.java | 2 +- .../model/error/AiravataClientException.java | 2 +- .../model/error/AiravataSystemException.java | 2 +- .../model/error/AuthenticationException.java | 2 +- .../model/error/AuthorizationException.java | 2 +- .../error/ExperimentNotFoundException.java | 2 +- .../model/error/InvalidRequestException.java | 2 +- .../model/error/LaunchValidationException.java | 2 +- .../model/error/ProjectNotFoundException.java | 2 +- .../airavata/model/error/TimedOutException.java | 2 +- .../airavata/model/error/ValidationResults.java | 2 +- .../airavata/model/error/ValidatorResult.java | 2 +- .../model/experiment/ExperimentModel.java | 2 +- .../model/experiment/ExperimentStatistics.java | 2 +- .../experiment/ExperimentSummaryModel.java | 2 +- .../experiment/UserConfigurationDataModel.java | 2 +- .../model/file/metadata/MetadataModel.java | 1474 ---------- .../model/file/metadata/MetadataType.java | 62 - .../model/file/replica/FileCollectionModel.java | 1247 -------- .../airavata/model/file/replica/FileModel.java | 1879 ------------ .../model/file/replica/FileModelType.java | 62 - .../model/file/replica/FileReplicaModel.java | 1272 --------- .../file/replica/ReplicaPersistentType.java | 62 - .../model/file/replica/StorageResourceType.java | 71 - .../model/file/transfer/FileTransferMode.java | 62 - .../file/transfer/FileTransferRequestModel.java | 2695 ------------------ .../model/file/transfer/FileTransferStatus.java | 71 - .../model/file/transfer/LSEntryModel.java | 1147 -------- .../model/file/transfer/LSEntryType.java | 62 - .../file/transfer/StorageResourceProtocol.java | 74 - .../org/apache/airavata/model/job/JobModel.java | 2 +- .../event/ExperimentStatusChangeEvent.java | 2 +- .../model/messaging/event/JobIdentifier.java | 2 +- .../messaging/event/JobStatusChangeEvent.java | 2 +- .../event/JobStatusChangeRequestEvent.java | 2 +- .../airavata/model/messaging/event/Message.java | 2 +- .../messaging/event/ProcessIdentifier.java | 2 +- .../event/ProcessStatusChangeEvent.java | 2 +- .../event/ProcessStatusChangeRequestEvent.java | 2 +- .../messaging/event/ProcessSubmitEvent.java | 2 +- .../messaging/event/ProcessTerminateEvent.java | 2 +- .../model/messaging/event/TaskIdentifier.java | 2 +- .../messaging/event/TaskOutputChangeEvent.java | 2 +- .../messaging/event/TaskStatusChangeEvent.java | 2 +- .../event/TaskStatusChangeRequestEvent.java | 2 +- .../airavata/model/process/ProcessModel.java | 2 +- .../ComputationalResourceSchedulingModel.java | 2 +- .../airavata/model/security/AuthzToken.java | 2 +- .../airavata/model/status/ExperimentStatus.java | 2 +- .../apache/airavata/model/status/JobStatus.java | 2 +- .../airavata/model/status/ProcessStatus.java | 2 +- .../airavata/model/status/TaskStatus.java | 2 +- .../model/task/DataStagingTaskModel.java | 2 +- .../model/task/EnvironmentSetupTaskModel.java | 2 +- .../model/task/JobSubmissionTaskModel.java | 2 +- .../airavata/model/task/MonitorTaskModel.java | 2 +- .../apache/airavata/model/task/TaskModel.java | 2 +- .../airavata/model/workspace/Gateway.java | 2 +- .../apache/airavata/model/workspace/Group.java | 2 +- .../airavata/model/workspace/Project.java | 2 +- .../apache/airavata/model/workspace/User.java | 2 +- modules/data-manager/data-manager-core/pom.xml | 95 + .../data/manager/core/FileManagerFactory.java | 34 + .../data/manager/core/FileManagerImpl.java | 78 + .../manager/core/FileTransferServiceImpl.java | 484 ++++ .../manager/core/MetadataCatalogService.java | 76 + .../core/MetadataCatalogServiceImpl.java | 105 + .../manager/core/ReplicaCatalogServiceImpl.java | 172 ++ .../conversion/AbstractThriftDeserializer.java | 151 + .../db/conversion/AbstractThriftSerializer.java | 122 + .../db/conversion/ModelConversionHelper.java | 102 + .../metadata/MetadataDeserializer.java | 44 + .../conversion/metadata/MetadataSerializer.java | 41 + .../replica/FileCollectionDeserializer.java | 44 + .../replica/FileCollectionSerializer.java | 41 + .../db/conversion/replica/FileDeserializer.java | 44 + .../db/conversion/replica/FileSerializer.java | 41 + .../FileTransferRequestDeserializer.java | 44 + .../transfer/FileTransferRequestSerializer.java | 41 + .../manager/core/db/dao/FileCollectionDao.java | 93 + .../data/manager/core/db/dao/FileDao.java | 93 + .../core/db/dao/FileTransferRequestDao.java | 92 + .../data/manager/core/db/dao/MetadataDao.java | 93 + .../data/manager/core/db/utils/MongoUtils.java | 69 + .../core/remote/client/RemoteStorageClient.java | 107 + .../remote/client/gridftp/ExecutionContext.java | 184 ++ .../core/remote/client/gridftp/GridFTP.java | 430 +++ .../remote/client/gridftp/GridFTPConstants.java | 45 + .../client/gridftp/GridFTPContactInfo.java | 60 + .../gridftp/myproxy/CertificateManager.java | 87 + .../gridftp/myproxy/MyProxyCredentials.java | 296 ++ .../client/gridftp/myproxy/SecurityContext.java | 211 ++ .../remote/client/http/HTTPStorageClient.java | 215 ++ .../core/remote/client/scp/CommandOutput.java | 34 + .../core/remote/client/scp/SCPApiException.java | 33 + .../remote/client/scp/SCPStorageClient.java | 405 +++ .../remote/client/scp/StandardOutReader.java | 86 + .../remote/client/sftp/SFTPStorageClient.java | 209 ++ .../core/utils/FileManagerConstants.java | 33 + .../core/utils/FileManagerProperties.java | 55 + .../src/main/resources/file-manager.properties | 24 + .../main/resources/gridftp-client.properties | 30 + .../core/db/dao/FileTransferRequestDaoTest.java | 45 + .../remote/client/gridftp/CertFileReadTest.java | 126 + .../remote/client/gridftp/FileTransferTest.java | 168 ++ .../client/http/HTTPStorageClientTest.java | 45 + .../remote/client/scp/SCPStorageClientTest.java | 55 + .../airavata-myproxy-client.properties | 28 + .../data-manager-core/src/test/resources/dummy | 0 modules/data-manager/data-manager-cpi/pom.xml | 30 + .../airavata/data/manager/cpi/DataManager.java | 42 + .../data/manager/cpi/DataManagerConstants.java | 32 + .../data/manager/cpi/DataManagerException.java | 35 + .../data/manager/cpi/FileTransferService.java | 212 ++ .../manager/cpi/MetadataCatalogService.java | 56 + .../data/manager/cpi/ReplicaCatalogService.java | 86 + modules/data-manager/pom.xml | 54 + modules/file-manager/file-manager-core/pom.xml | 95 - .../file/manager/core/FileManagerFactory.java | 34 - .../file/manager/core/FileManagerImpl.java | 75 - .../manager/core/FileTransferServiceImpl.java | 484 ---- .../manager/core/MetadataCatalogService.java | 76 - .../core/MetadataCatalogServiceImpl.java | 105 - .../manager/core/ReplicaCatalogServiceImpl.java | 172 -- .../conversion/AbstractThriftDeserializer.java | 154 - .../db/conversion/AbstractThriftSerializer.java | 122 - .../db/conversion/ModelConversionHelper.java | 102 - .../metadata/MetadataDeserializer.java | 45 - .../conversion/metadata/MetadataSerializer.java | 42 - .../replica/FileCollectionDeserializer.java | 44 - .../replica/FileCollectionSerializer.java | 41 - .../db/conversion/replica/FileDeserializer.java | 44 - .../db/conversion/replica/FileSerializer.java | 41 - .../FileTransferRequestDeserializer.java | 44 - .../transfer/FileTransferRequestSerializer.java | 41 - .../manager/core/db/dao/FileCollectionDao.java | 93 - .../file/manager/core/db/dao/FileDao.java | 93 - .../core/db/dao/FileTransferRequestDao.java | 92 - .../file/manager/core/db/dao/MetadataDao.java | 94 - .../file/manager/core/db/utils/MongoUtils.java | 69 - .../core/remote/client/RemoteStorageClient.java | 107 - .../remote/client/gridftp/ExecutionContext.java | 184 -- .../core/remote/client/gridftp/GridFTP.java | 430 --- .../remote/client/gridftp/GridFTPConstants.java | 45 - .../client/gridftp/GridFTPContactInfo.java | 60 - .../gridftp/myproxy/CertificateManager.java | 87 - .../gridftp/myproxy/MyProxyCredentials.java | 296 -- .../client/gridftp/myproxy/SecurityContext.java | 211 -- .../remote/client/http/HTTPStorageClient.java | 215 -- .../core/remote/client/scp/CommandOutput.java | 34 - .../core/remote/client/scp/SCPApiException.java | 33 - .../remote/client/scp/SCPStorageClient.java | 406 --- .../remote/client/scp/StandardOutReader.java | 86 - .../remote/client/sftp/SFTPStorageClient.java | 209 -- .../core/utils/FileManagerConstants.java | 33 - .../core/utils/FileManagerProperties.java | 58 - .../src/main/resources/file-manager.properties | 24 - .../main/resources/gridftp-client.properties | 30 - .../core/db/dao/FileTransferRequestDaoTest.java | 45 - .../remote/client/gridftp/CertFileReadTest.java | 126 - .../remote/client/gridftp/FileTransferTest.java | 168 -- .../client/http/HTTPStorageClientTest.java | 45 - .../remote/client/scp/SCPStorageClientTest.java | 55 - .../airavata-myproxy-client.properties | 28 - .../file-manager-core/src/test/resources/dummy | 0 modules/file-manager/file-manager-cpi/pom.xml | 30 - .../airavata/file/manager/cpi/FileManager.java | 42 - .../file/manager/cpi/FileManagerConstants.java | 32 - .../file/manager/cpi/FileManagerException.java | 35 - .../file/manager/cpi/FileTransferService.java | 212 -- .../manager/cpi/MetadataCatalogService.java | 56 - .../file/manager/cpi/ReplicaCatalogService.java | 86 - modules/file-manager/pom.xml | 54 - pom.xml | 2 +- .../data-models/airavata_data_models.thrift | 6 +- .../file__transfer_models.thrift | 77 + .../data-manager-models/metadata_models.thrift | 41 + .../data-manager-models/replica_models.thrift | 83 + .../file__transfer_models.thrift | 77 - .../file-manager-models/metadata_models.thrift | 41 - .../file-manager-models/replica_models.thrift | 83 - 236 files changed, 6053 insertions(+), 20117 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/airavata/blob/1ad9ae5d/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/api/Airavata.java ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/api/Airavata.java b/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/api/Airavata.java index 5180921..acf770d 100644 --- a/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/api/Airavata.java +++ b/airavata-api/airavata-api-stubs/src/main/java/org/apache/airavata/api/Airavata.java @@ -51,7 +51,7 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) -@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2015-12-23") +@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2016-01-12") public class Airavata { public interface Iface { http://git-wip-us.apache.org/repos/asf/airavata/blob/1ad9ae5d/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/file__transfer_models_constants.cpp ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/file__transfer_models_constants.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/file__transfer_models_constants.cpp index c2927ce..a1a0d0f 100644 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/file__transfer_models_constants.cpp +++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/file__transfer_models_constants.cpp @@ -23,7 +23,7 @@ */ #include "file__transfer_models_constants.h" -namespace apache { namespace airavata { namespace model { namespace file { namespace transfer { +namespace apache { namespace airavata { namespace model { namespace data { namespace transfer { const file__transfer_modelsConstants g_file__transfer_models_constants; http://git-wip-us.apache.org/repos/asf/airavata/blob/1ad9ae5d/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/file__transfer_models_constants.h ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/file__transfer_models_constants.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/file__transfer_models_constants.h index eb49228..52a10b6 100644 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/file__transfer_models_constants.h +++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/file__transfer_models_constants.h @@ -26,7 +26,7 @@ #include "file__transfer_models_types.h" -namespace apache { namespace airavata { namespace model { namespace file { namespace transfer { +namespace apache { namespace airavata { namespace model { namespace data { namespace transfer { class file__transfer_modelsConstants { public: http://git-wip-us.apache.org/repos/asf/airavata/blob/1ad9ae5d/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/file__transfer_models_types.cpp ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/file__transfer_models_types.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/file__transfer_models_types.cpp index f8e894f..375401c 100644 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/file__transfer_models_types.cpp +++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/file__transfer_models_types.cpp @@ -28,7 +28,7 @@ #include <thrift/TToString.h> -namespace apache { namespace airavata { namespace model { namespace file { namespace transfer { +namespace apache { namespace airavata { namespace model { namespace data { namespace transfer { int _kStorageResourceProtocolValues[] = { StorageResourceProtocol::SCP, http://git-wip-us.apache.org/repos/asf/airavata/blob/1ad9ae5d/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/file__transfer_models_types.h ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/file__transfer_models_types.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/file__transfer_models_types.h index 18f1b8b..01f7cca 100644 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/file__transfer_models_types.h +++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/file__transfer_models_types.h @@ -34,7 +34,7 @@ #include <thrift/cxxfunctional.h> -namespace apache { namespace airavata { namespace model { namespace file { namespace transfer { +namespace apache { namespace airavata { namespace model { namespace data { namespace transfer { struct StorageResourceProtocol { enum type { http://git-wip-us.apache.org/repos/asf/airavata/blob/1ad9ae5d/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/metadata_models_constants.cpp ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/metadata_models_constants.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/metadata_models_constants.cpp index b067323..b4f0d68 100644 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/metadata_models_constants.cpp +++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/metadata_models_constants.cpp @@ -23,7 +23,7 @@ */ #include "metadata_models_constants.h" -namespace apache { namespace airavata { namespace model { namespace file { namespace metadata { +namespace apache { namespace airavata { namespace model { namespace data { namespace metadata { const metadata_modelsConstants g_metadata_models_constants; http://git-wip-us.apache.org/repos/asf/airavata/blob/1ad9ae5d/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/metadata_models_constants.h ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/metadata_models_constants.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/metadata_models_constants.h index a43c422..9d7bf9a 100644 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/metadata_models_constants.h +++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/metadata_models_constants.h @@ -26,7 +26,7 @@ #include "metadata_models_types.h" -namespace apache { namespace airavata { namespace model { namespace file { namespace metadata { +namespace apache { namespace airavata { namespace model { namespace data { namespace metadata { class metadata_modelsConstants { public: http://git-wip-us.apache.org/repos/asf/airavata/blob/1ad9ae5d/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/metadata_models_types.cpp ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/metadata_models_types.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/metadata_models_types.cpp index fdf959e..f7d964e 100644 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/metadata_models_types.cpp +++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/metadata_models_types.cpp @@ -28,7 +28,7 @@ #include <thrift/TToString.h> -namespace apache { namespace airavata { namespace model { namespace file { namespace metadata { +namespace apache { namespace airavata { namespace model { namespace data { namespace metadata { int _kMetadataTypeValues[] = { MetadataType::FILE, http://git-wip-us.apache.org/repos/asf/airavata/blob/1ad9ae5d/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/metadata_models_types.h ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/metadata_models_types.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/metadata_models_types.h index c8651f6..2be82d9 100644 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/metadata_models_types.h +++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/metadata_models_types.h @@ -34,7 +34,7 @@ #include <thrift/cxxfunctional.h> -namespace apache { namespace airavata { namespace model { namespace file { namespace metadata { +namespace apache { namespace airavata { namespace model { namespace data { namespace metadata { struct MetadataType { enum type { http://git-wip-us.apache.org/repos/asf/airavata/blob/1ad9ae5d/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/replica_models_constants.cpp ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/replica_models_constants.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/replica_models_constants.cpp index 175292b..b0b67df 100644 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/replica_models_constants.cpp +++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/replica_models_constants.cpp @@ -23,7 +23,7 @@ */ #include "replica_models_constants.h" -namespace apache { namespace airavata { namespace model { namespace file { namespace replica { +namespace apache { namespace airavata { namespace model { namespace data { namespace replica { const replica_modelsConstants g_replica_models_constants; http://git-wip-us.apache.org/repos/asf/airavata/blob/1ad9ae5d/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/replica_models_constants.h ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/replica_models_constants.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/replica_models_constants.h index aee0d7e..0dfb956 100644 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/replica_models_constants.h +++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/replica_models_constants.h @@ -26,7 +26,7 @@ #include "replica_models_types.h" -namespace apache { namespace airavata { namespace model { namespace file { namespace replica { +namespace apache { namespace airavata { namespace model { namespace data { namespace replica { class replica_modelsConstants { public: http://git-wip-us.apache.org/repos/asf/airavata/blob/1ad9ae5d/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/replica_models_types.cpp ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/replica_models_types.cpp b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/replica_models_types.cpp index b5c3027..d5a1762 100644 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/replica_models_types.cpp +++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/replica_models_types.cpp @@ -28,7 +28,7 @@ #include <thrift/TToString.h> -namespace apache { namespace airavata { namespace model { namespace file { namespace replica { +namespace apache { namespace airavata { namespace model { namespace data { namespace replica { int _kFileModelTypeValues[] = { FileModelType::FILE, http://git-wip-us.apache.org/repos/asf/airavata/blob/1ad9ae5d/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/replica_models_types.h ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/replica_models_types.h b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/replica_models_types.h index 73569cc..dad3e27 100644 --- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/replica_models_types.h +++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/replica_models_types.h @@ -35,7 +35,7 @@ #include "data_movement_models_types.h" -namespace apache { namespace airavata { namespace model { namespace file { namespace replica { +namespace apache { namespace airavata { namespace model { namespace data { namespace replica { struct FileModelType { enum type { http://git-wip-us.apache.org/repos/asf/airavata/blob/1ad9ae5d/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/File/Replica/Types.php ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/File/Replica/Types.php b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/File/Replica/Types.php deleted file mode 100644 index 7ccf94c..0000000 --- a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/File/Replica/Types.php +++ /dev/null @@ -1,1028 +0,0 @@ -<?php -namespace Airavata\Model\File\Replica; - -/** - * Autogenerated by Thrift Compiler (0.9.3) - * - * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * @generated - */ -use Thrift\Base\TBase; -use Thrift\Type\TType; -use Thrift\Type\TMessageType; -use Thrift\Exception\TException; -use Thrift\Exception\TProtocolException; -use Thrift\Protocol\TProtocol; -use Thrift\Protocol\TBinaryProtocolAccelerated; -use Thrift\Exception\TApplicationException; - - -final class FileModelType { - const FILE = 0; - const DIRECTORY = 1; - static public $__names = array( - 0 => 'FILE', - 1 => 'DIRECTORY', - ); -} - -final class StorageResourceType { - const GATEWAY_DATA_STORE = 0; - const BACKUP_GATEWAY_DATA_STORE = 1; - const COMPUTE_RESOURCE = 2; - const LONG_TERM_STORAGE_RESOURCE = 3; - const OTHER = 4; - static public $__names = array( - 0 => 'GATEWAY_DATA_STORE', - 1 => 'BACKUP_GATEWAY_DATA_STORE', - 2 => 'COMPUTE_RESOURCE', - 3 => 'LONG_TERM_STORAGE_RESOURCE', - 4 => 'OTHER', - ); -} - -final class ReplicaPersistentType { - const TRANSIENT = 0; - const PERSISTENT = 1; - static public $__names = array( - 0 => 'TRANSIENT', - 1 => 'PERSISTENT', - ); -} - -class FileCollectionModel { - static $_TSPEC; - - /** - * @var string - */ - public $collectionId = null; - /** - * @var string - */ - public $gatewayId = null; - /** - * @var string - */ - public $username = null; - /** - * @var string[] - */ - public $sharedUsers = null; - /** - * @var bool - */ - public $sharedPublic = null; - /** - * @var string - */ - public $collectionName = null; - /** - * @var string - */ - public $collectionDescription = null; - /** - * @var string[] - */ - public $fileIdList = null; - - public function __construct($vals=null) { - if (!isset(self::$_TSPEC)) { - self::$_TSPEC = array( - 1 => array( - 'var' => 'collectionId', - 'type' => TType::STRING, - ), - 2 => array( - 'var' => 'gatewayId', - 'type' => TType::STRING, - ), - 3 => array( - 'var' => 'username', - 'type' => TType::STRING, - ), - 4 => array( - 'var' => 'sharedUsers', - 'type' => TType::LST, - 'etype' => TType::STRING, - 'elem' => array( - 'type' => TType::STRING, - ), - ), - 5 => array( - 'var' => 'sharedPublic', - 'type' => TType::BOOL, - ), - 6 => array( - 'var' => 'collectionName', - 'type' => TType::STRING, - ), - 7 => array( - 'var' => 'collectionDescription', - 'type' => TType::STRING, - ), - 8 => array( - 'var' => 'fileIdList', - 'type' => TType::LST, - 'etype' => TType::STRING, - 'elem' => array( - 'type' => TType::STRING, - ), - ), - ); - } - if (is_array($vals)) { - if (isset($vals['collectionId'])) { - $this->collectionId = $vals['collectionId']; - } - if (isset($vals['gatewayId'])) { - $this->gatewayId = $vals['gatewayId']; - } - if (isset($vals['username'])) { - $this->username = $vals['username']; - } - if (isset($vals['sharedUsers'])) { - $this->sharedUsers = $vals['sharedUsers']; - } - if (isset($vals['sharedPublic'])) { - $this->sharedPublic = $vals['sharedPublic']; - } - if (isset($vals['collectionName'])) { - $this->collectionName = $vals['collectionName']; - } - if (isset($vals['collectionDescription'])) { - $this->collectionDescription = $vals['collectionDescription']; - } - if (isset($vals['fileIdList'])) { - $this->fileIdList = $vals['fileIdList']; - } - } - } - - public function getName() { - return 'FileCollectionModel'; - } - - public function read($input) - { - $xfer = 0; - $fname = null; - $ftype = 0; - $fid = 0; - $xfer += $input->readStructBegin($fname); - while (true) - { - $xfer += $input->readFieldBegin($fname, $ftype, $fid); - if ($ftype == TType::STOP) { - break; - } - switch ($fid) - { - case 1: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->collectionId); - } else { - $xfer += $input->skip($ftype); - } - break; - case 2: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->gatewayId); - } else { - $xfer += $input->skip($ftype); - } - break; - case 3: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->username); - } else { - $xfer += $input->skip($ftype); - } - break; - case 4: - if ($ftype == TType::LST) { - $this->sharedUsers = array(); - $_size0 = 0; - $_etype3 = 0; - $xfer += $input->readListBegin($_etype3, $_size0); - for ($_i4 = 0; $_i4 < $_size0; ++$_i4) - { - $elem5 = null; - $xfer += $input->readString($elem5); - $this->sharedUsers []= $elem5; - } - $xfer += $input->readListEnd(); - } else { - $xfer += $input->skip($ftype); - } - break; - case 5: - if ($ftype == TType::BOOL) { - $xfer += $input->readBool($this->sharedPublic); - } else { - $xfer += $input->skip($ftype); - } - break; - case 6: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->collectionName); - } else { - $xfer += $input->skip($ftype); - } - break; - case 7: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->collectionDescription); - } else { - $xfer += $input->skip($ftype); - } - break; - case 8: - if ($ftype == TType::LST) { - $this->fileIdList = array(); - $_size6 = 0; - $_etype9 = 0; - $xfer += $input->readListBegin($_etype9, $_size6); - for ($_i10 = 0; $_i10 < $_size6; ++$_i10) - { - $elem11 = null; - $xfer += $input->readString($elem11); - $this->fileIdList []= $elem11; - } - $xfer += $input->readListEnd(); - } else { - $xfer += $input->skip($ftype); - } - break; - default: - $xfer += $input->skip($ftype); - break; - } - $xfer += $input->readFieldEnd(); - } - $xfer += $input->readStructEnd(); - return $xfer; - } - - public function write($output) { - $xfer = 0; - $xfer += $output->writeStructBegin('FileCollectionModel'); - if ($this->collectionId !== null) { - $xfer += $output->writeFieldBegin('collectionId', TType::STRING, 1); - $xfer += $output->writeString($this->collectionId); - $xfer += $output->writeFieldEnd(); - } - if ($this->gatewayId !== null) { - $xfer += $output->writeFieldBegin('gatewayId', TType::STRING, 2); - $xfer += $output->writeString($this->gatewayId); - $xfer += $output->writeFieldEnd(); - } - if ($this->username !== null) { - $xfer += $output->writeFieldBegin('username', TType::STRING, 3); - $xfer += $output->writeString($this->username); - $xfer += $output->writeFieldEnd(); - } - if ($this->sharedUsers !== null) { - if (!is_array($this->sharedUsers)) { - throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); - } - $xfer += $output->writeFieldBegin('sharedUsers', TType::LST, 4); - { - $output->writeListBegin(TType::STRING, count($this->sharedUsers)); - { - foreach ($this->sharedUsers as $iter12) - { - $xfer += $output->writeString($iter12); - } - } - $output->writeListEnd(); - } - $xfer += $output->writeFieldEnd(); - } - if ($this->sharedPublic !== null) { - $xfer += $output->writeFieldBegin('sharedPublic', TType::BOOL, 5); - $xfer += $output->writeBool($this->sharedPublic); - $xfer += $output->writeFieldEnd(); - } - if ($this->collectionName !== null) { - $xfer += $output->writeFieldBegin('collectionName', TType::STRING, 6); - $xfer += $output->writeString($this->collectionName); - $xfer += $output->writeFieldEnd(); - } - if ($this->collectionDescription !== null) { - $xfer += $output->writeFieldBegin('collectionDescription', TType::STRING, 7); - $xfer += $output->writeString($this->collectionDescription); - $xfer += $output->writeFieldEnd(); - } - if ($this->fileIdList !== null) { - if (!is_array($this->fileIdList)) { - throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); - } - $xfer += $output->writeFieldBegin('fileIdList', TType::LST, 8); - { - $output->writeListBegin(TType::STRING, count($this->fileIdList)); - { - foreach ($this->fileIdList as $iter13) - { - $xfer += $output->writeString($iter13); - } - } - $output->writeListEnd(); - } - $xfer += $output->writeFieldEnd(); - } - $xfer += $output->writeFieldStop(); - $xfer += $output->writeStructEnd(); - return $xfer; - } - -} - -class FileModel { - static $_TSPEC; - - /** - * @var string - */ - public $fileId = null; - /** - * @var string - */ - public $gatewayId = null; - /** - * @var string - */ - public $username = null; - /** - * @var string[] - */ - public $sharedUsers = null; - /** - * @var bool - */ - public $sharedPublic = null; - /** - * @var string - */ - public $fileName = null; - /** - * @var string - */ - public $fileDescription = null; - /** - * @var string - */ - public $sha256Checksum = null; - /** - * @var int - */ - public $fileType = null; - /** - * @var int - */ - public $fileSize = null; - /** - * @var string - */ - public $dataType = null; - /** - * @var int - */ - public $creationTime = null; - /** - * @var int - */ - public $lastModifiedTime = null; - /** - * @var \Airavata\Model\File\Replica\FileReplicaModel[] - */ - public $fileReplicas = null; - - public function __construct($vals=null) { - if (!isset(self::$_TSPEC)) { - self::$_TSPEC = array( - 1 => array( - 'var' => 'fileId', - 'type' => TType::STRING, - ), - 2 => array( - 'var' => 'gatewayId', - 'type' => TType::STRING, - ), - 3 => array( - 'var' => 'username', - 'type' => TType::STRING, - ), - 4 => array( - 'var' => 'sharedUsers', - 'type' => TType::LST, - 'etype' => TType::STRING, - 'elem' => array( - 'type' => TType::STRING, - ), - ), - 5 => array( - 'var' => 'sharedPublic', - 'type' => TType::BOOL, - ), - 6 => array( - 'var' => 'fileName', - 'type' => TType::STRING, - ), - 7 => array( - 'var' => 'fileDescription', - 'type' => TType::STRING, - ), - 8 => array( - 'var' => 'sha256Checksum', - 'type' => TType::STRING, - ), - 9 => array( - 'var' => 'fileType', - 'type' => TType::I32, - ), - 10 => array( - 'var' => 'fileSize', - 'type' => TType::I32, - ), - 11 => array( - 'var' => 'dataType', - 'type' => TType::STRING, - ), - 12 => array( - 'var' => 'creationTime', - 'type' => TType::I64, - ), - 13 => array( - 'var' => 'lastModifiedTime', - 'type' => TType::I64, - ), - 14 => array( - 'var' => 'fileReplicas', - 'type' => TType::LST, - 'etype' => TType::STRUCT, - 'elem' => array( - 'type' => TType::STRUCT, - 'class' => '\Airavata\Model\File\Replica\FileReplicaModel', - ), - ), - ); - } - if (is_array($vals)) { - if (isset($vals['fileId'])) { - $this->fileId = $vals['fileId']; - } - if (isset($vals['gatewayId'])) { - $this->gatewayId = $vals['gatewayId']; - } - if (isset($vals['username'])) { - $this->username = $vals['username']; - } - if (isset($vals['sharedUsers'])) { - $this->sharedUsers = $vals['sharedUsers']; - } - if (isset($vals['sharedPublic'])) { - $this->sharedPublic = $vals['sharedPublic']; - } - if (isset($vals['fileName'])) { - $this->fileName = $vals['fileName']; - } - if (isset($vals['fileDescription'])) { - $this->fileDescription = $vals['fileDescription']; - } - if (isset($vals['sha256Checksum'])) { - $this->sha256Checksum = $vals['sha256Checksum']; - } - if (isset($vals['fileType'])) { - $this->fileType = $vals['fileType']; - } - if (isset($vals['fileSize'])) { - $this->fileSize = $vals['fileSize']; - } - if (isset($vals['dataType'])) { - $this->dataType = $vals['dataType']; - } - if (isset($vals['creationTime'])) { - $this->creationTime = $vals['creationTime']; - } - if (isset($vals['lastModifiedTime'])) { - $this->lastModifiedTime = $vals['lastModifiedTime']; - } - if (isset($vals['fileReplicas'])) { - $this->fileReplicas = $vals['fileReplicas']; - } - } - } - - public function getName() { - return 'FileModel'; - } - - public function read($input) - { - $xfer = 0; - $fname = null; - $ftype = 0; - $fid = 0; - $xfer += $input->readStructBegin($fname); - while (true) - { - $xfer += $input->readFieldBegin($fname, $ftype, $fid); - if ($ftype == TType::STOP) { - break; - } - switch ($fid) - { - case 1: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->fileId); - } else { - $xfer += $input->skip($ftype); - } - break; - case 2: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->gatewayId); - } else { - $xfer += $input->skip($ftype); - } - break; - case 3: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->username); - } else { - $xfer += $input->skip($ftype); - } - break; - case 4: - if ($ftype == TType::LST) { - $this->sharedUsers = array(); - $_size14 = 0; - $_etype17 = 0; - $xfer += $input->readListBegin($_etype17, $_size14); - for ($_i18 = 0; $_i18 < $_size14; ++$_i18) - { - $elem19 = null; - $xfer += $input->readString($elem19); - $this->sharedUsers []= $elem19; - } - $xfer += $input->readListEnd(); - } else { - $xfer += $input->skip($ftype); - } - break; - case 5: - if ($ftype == TType::BOOL) { - $xfer += $input->readBool($this->sharedPublic); - } else { - $xfer += $input->skip($ftype); - } - break; - case 6: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->fileName); - } else { - $xfer += $input->skip($ftype); - } - break; - case 7: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->fileDescription); - } else { - $xfer += $input->skip($ftype); - } - break; - case 8: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->sha256Checksum); - } else { - $xfer += $input->skip($ftype); - } - break; - case 9: - if ($ftype == TType::I32) { - $xfer += $input->readI32($this->fileType); - } else { - $xfer += $input->skip($ftype); - } - break; - case 10: - if ($ftype == TType::I32) { - $xfer += $input->readI32($this->fileSize); - } else { - $xfer += $input->skip($ftype); - } - break; - case 11: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->dataType); - } else { - $xfer += $input->skip($ftype); - } - break; - case 12: - if ($ftype == TType::I64) { - $xfer += $input->readI64($this->creationTime); - } else { - $xfer += $input->skip($ftype); - } - break; - case 13: - if ($ftype == TType::I64) { - $xfer += $input->readI64($this->lastModifiedTime); - } else { - $xfer += $input->skip($ftype); - } - break; - case 14: - if ($ftype == TType::LST) { - $this->fileReplicas = array(); - $_size20 = 0; - $_etype23 = 0; - $xfer += $input->readListBegin($_etype23, $_size20); - for ($_i24 = 0; $_i24 < $_size20; ++$_i24) - { - $elem25 = null; - $elem25 = new \Airavata\Model\File\Replica\FileReplicaModel(); - $xfer += $elem25->read($input); - $this->fileReplicas []= $elem25; - } - $xfer += $input->readListEnd(); - } else { - $xfer += $input->skip($ftype); - } - break; - default: - $xfer += $input->skip($ftype); - break; - } - $xfer += $input->readFieldEnd(); - } - $xfer += $input->readStructEnd(); - return $xfer; - } - - public function write($output) { - $xfer = 0; - $xfer += $output->writeStructBegin('FileModel'); - if ($this->fileId !== null) { - $xfer += $output->writeFieldBegin('fileId', TType::STRING, 1); - $xfer += $output->writeString($this->fileId); - $xfer += $output->writeFieldEnd(); - } - if ($this->gatewayId !== null) { - $xfer += $output->writeFieldBegin('gatewayId', TType::STRING, 2); - $xfer += $output->writeString($this->gatewayId); - $xfer += $output->writeFieldEnd(); - } - if ($this->username !== null) { - $xfer += $output->writeFieldBegin('username', TType::STRING, 3); - $xfer += $output->writeString($this->username); - $xfer += $output->writeFieldEnd(); - } - if ($this->sharedUsers !== null) { - if (!is_array($this->sharedUsers)) { - throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); - } - $xfer += $output->writeFieldBegin('sharedUsers', TType::LST, 4); - { - $output->writeListBegin(TType::STRING, count($this->sharedUsers)); - { - foreach ($this->sharedUsers as $iter26) - { - $xfer += $output->writeString($iter26); - } - } - $output->writeListEnd(); - } - $xfer += $output->writeFieldEnd(); - } - if ($this->sharedPublic !== null) { - $xfer += $output->writeFieldBegin('sharedPublic', TType::BOOL, 5); - $xfer += $output->writeBool($this->sharedPublic); - $xfer += $output->writeFieldEnd(); - } - if ($this->fileName !== null) { - $xfer += $output->writeFieldBegin('fileName', TType::STRING, 6); - $xfer += $output->writeString($this->fileName); - $xfer += $output->writeFieldEnd(); - } - if ($this->fileDescription !== null) { - $xfer += $output->writeFieldBegin('fileDescription', TType::STRING, 7); - $xfer += $output->writeString($this->fileDescription); - $xfer += $output->writeFieldEnd(); - } - if ($this->sha256Checksum !== null) { - $xfer += $output->writeFieldBegin('sha256Checksum', TType::STRING, 8); - $xfer += $output->writeString($this->sha256Checksum); - $xfer += $output->writeFieldEnd(); - } - if ($this->fileType !== null) { - $xfer += $output->writeFieldBegin('fileType', TType::I32, 9); - $xfer += $output->writeI32($this->fileType); - $xfer += $output->writeFieldEnd(); - } - if ($this->fileSize !== null) { - $xfer += $output->writeFieldBegin('fileSize', TType::I32, 10); - $xfer += $output->writeI32($this->fileSize); - $xfer += $output->writeFieldEnd(); - } - if ($this->dataType !== null) { - $xfer += $output->writeFieldBegin('dataType', TType::STRING, 11); - $xfer += $output->writeString($this->dataType); - $xfer += $output->writeFieldEnd(); - } - if ($this->creationTime !== null) { - $xfer += $output->writeFieldBegin('creationTime', TType::I64, 12); - $xfer += $output->writeI64($this->creationTime); - $xfer += $output->writeFieldEnd(); - } - if ($this->lastModifiedTime !== null) { - $xfer += $output->writeFieldBegin('lastModifiedTime', TType::I64, 13); - $xfer += $output->writeI64($this->lastModifiedTime); - $xfer += $output->writeFieldEnd(); - } - if ($this->fileReplicas !== null) { - if (!is_array($this->fileReplicas)) { - throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); - } - $xfer += $output->writeFieldBegin('fileReplicas', TType::LST, 14); - { - $output->writeListBegin(TType::STRUCT, count($this->fileReplicas)); - { - foreach ($this->fileReplicas as $iter27) - { - $xfer += $iter27->write($output); - } - } - $output->writeListEnd(); - } - $xfer += $output->writeFieldEnd(); - } - $xfer += $output->writeFieldStop(); - $xfer += $output->writeStructEnd(); - return $xfer; - } - -} - -class FileReplicaModel { - static $_TSPEC; - - /** - * @var string - */ - public $replicaName = null; - /** - * @var string - */ - public $replicaDescription = null; - /** - * @var string - */ - public $storageHostname = null; - /** - * @var string - */ - public $storageResourceId = null; - /** - * @var string - */ - public $filePath = null; - /** - * @var int - */ - public $creationTime = null; - /** - * @var int - */ - public $validUntilTime = null; - /** - * @var int - */ - public $storageResourceType = null; - /** - * @var int - */ - public $replicaPersistentType = null; - - public function __construct($vals=null) { - if (!isset(self::$_TSPEC)) { - self::$_TSPEC = array( - 1 => array( - 'var' => 'replicaName', - 'type' => TType::STRING, - ), - 2 => array( - 'var' => 'replicaDescription', - 'type' => TType::STRING, - ), - 3 => array( - 'var' => 'storageHostname', - 'type' => TType::STRING, - ), - 4 => array( - 'var' => 'storageResourceId', - 'type' => TType::STRING, - ), - 5 => array( - 'var' => 'filePath', - 'type' => TType::STRING, - ), - 6 => array( - 'var' => 'creationTime', - 'type' => TType::I64, - ), - 7 => array( - 'var' => 'validUntilTime', - 'type' => TType::I64, - ), - 8 => array( - 'var' => 'storageResourceType', - 'type' => TType::I32, - ), - 9 => array( - 'var' => 'replicaPersistentType', - 'type' => TType::I32, - ), - ); - } - if (is_array($vals)) { - if (isset($vals['replicaName'])) { - $this->replicaName = $vals['replicaName']; - } - if (isset($vals['replicaDescription'])) { - $this->replicaDescription = $vals['replicaDescription']; - } - if (isset($vals['storageHostname'])) { - $this->storageHostname = $vals['storageHostname']; - } - if (isset($vals['storageResourceId'])) { - $this->storageResourceId = $vals['storageResourceId']; - } - if (isset($vals['filePath'])) { - $this->filePath = $vals['filePath']; - } - if (isset($vals['creationTime'])) { - $this->creationTime = $vals['creationTime']; - } - if (isset($vals['validUntilTime'])) { - $this->validUntilTime = $vals['validUntilTime']; - } - if (isset($vals['storageResourceType'])) { - $this->storageResourceType = $vals['storageResourceType']; - } - if (isset($vals['replicaPersistentType'])) { - $this->replicaPersistentType = $vals['replicaPersistentType']; - } - } - } - - public function getName() { - return 'FileReplicaModel'; - } - - public function read($input) - { - $xfer = 0; - $fname = null; - $ftype = 0; - $fid = 0; - $xfer += $input->readStructBegin($fname); - while (true) - { - $xfer += $input->readFieldBegin($fname, $ftype, $fid); - if ($ftype == TType::STOP) { - break; - } - switch ($fid) - { - case 1: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->replicaName); - } else { - $xfer += $input->skip($ftype); - } - break; - case 2: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->replicaDescription); - } else { - $xfer += $input->skip($ftype); - } - break; - case 3: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->storageHostname); - } else { - $xfer += $input->skip($ftype); - } - break; - case 4: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->storageResourceId); - } else { - $xfer += $input->skip($ftype); - } - break; - case 5: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->filePath); - } else { - $xfer += $input->skip($ftype); - } - break; - case 6: - if ($ftype == TType::I64) { - $xfer += $input->readI64($this->creationTime); - } else { - $xfer += $input->skip($ftype); - } - break; - case 7: - if ($ftype == TType::I64) { - $xfer += $input->readI64($this->validUntilTime); - } else { - $xfer += $input->skip($ftype); - } - break; - case 8: - if ($ftype == TType::I32) { - $xfer += $input->readI32($this->storageResourceType); - } else { - $xfer += $input->skip($ftype); - } - break; - case 9: - if ($ftype == TType::I32) { - $xfer += $input->readI32($this->replicaPersistentType); - } else { - $xfer += $input->skip($ftype); - } - break; - default: - $xfer += $input->skip($ftype); - break; - } - $xfer += $input->readFieldEnd(); - } - $xfer += $input->readStructEnd(); - return $xfer; - } - - public function write($output) { - $xfer = 0; - $xfer += $output->writeStructBegin('FileReplicaModel'); - if ($this->replicaName !== null) { - $xfer += $output->writeFieldBegin('replicaName', TType::STRING, 1); - $xfer += $output->writeString($this->replicaName); - $xfer += $output->writeFieldEnd(); - } - if ($this->replicaDescription !== null) { - $xfer += $output->writeFieldBegin('replicaDescription', TType::STRING, 2); - $xfer += $output->writeString($this->replicaDescription); - $xfer += $output->writeFieldEnd(); - } - if ($this->storageHostname !== null) { - $xfer += $output->writeFieldBegin('storageHostname', TType::STRING, 3); - $xfer += $output->writeString($this->storageHostname); - $xfer += $output->writeFieldEnd(); - } - if ($this->storageResourceId !== null) { - $xfer += $output->writeFieldBegin('storageResourceId', TType::STRING, 4); - $xfer += $output->writeString($this->storageResourceId); - $xfer += $output->writeFieldEnd(); - } - if ($this->filePath !== null) { - $xfer += $output->writeFieldBegin('filePath', TType::STRING, 5); - $xfer += $output->writeString($this->filePath); - $xfer += $output->writeFieldEnd(); - } - if ($this->creationTime !== null) { - $xfer += $output->writeFieldBegin('creationTime', TType::I64, 6); - $xfer += $output->writeI64($this->creationTime); - $xfer += $output->writeFieldEnd(); - } - if ($this->validUntilTime !== null) { - $xfer += $output->writeFieldBegin('validUntilTime', TType::I64, 7); - $xfer += $output->writeI64($this->validUntilTime); - $xfer += $output->writeFieldEnd(); - } - if ($this->storageResourceType !== null) { - $xfer += $output->writeFieldBegin('storageResourceType', TType::I32, 8); - $xfer += $output->writeI32($this->storageResourceType); - $xfer += $output->writeFieldEnd(); - } - if ($this->replicaPersistentType !== null) { - $xfer += $output->writeFieldBegin('replicaPersistentType', TType::I32, 9); - $xfer += $output->writeI32($this->replicaPersistentType); - $xfer += $output->writeFieldEnd(); - } - $xfer += $output->writeFieldStop(); - $xfer += $output->writeStructEnd(); - return $xfer; - } - -} - - http://git-wip-us.apache.org/repos/asf/airavata/blob/1ad9ae5d/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/File/Transfer/Types.php ---------------------------------------------------------------------- diff --git a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/File/Transfer/Types.php b/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/File/Transfer/Types.php deleted file mode 100644 index 46eae5b..0000000 --- a/airavata-api/airavata-client-sdks/airavata-php-sdk/src/main/resources/lib/Airavata/Model/File/Transfer/Types.php +++ /dev/null @@ -1,890 +0,0 @@ -<?php -namespace Airavata\Model\File\Transfer; - -/** - * Autogenerated by Thrift Compiler (0.9.3) - * - * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING - * @generated - */ -use Thrift\Base\TBase; -use Thrift\Type\TType; -use Thrift\Type\TMessageType; -use Thrift\Exception\TException; -use Thrift\Exception\TProtocolException; -use Thrift\Protocol\TProtocol; -use Thrift\Protocol\TBinaryProtocolAccelerated; -use Thrift\Exception\TApplicationException; - - -final class StorageResourceProtocol { - const SCP = 0; - const SFTP = 1; - const HTTP = 2; - const HTTPS = 3; - const GridFTP = 4; - const LOCAL = 5; - static public $__names = array( - 0 => 'SCP', - 1 => 'SFTP', - 2 => 'HTTP', - 3 => 'HTTPS', - 4 => 'GridFTP', - 5 => 'LOCAL', - ); -} - -final class LSEntryType { - const DIRECTORY = 0; - const FILE = 1; - static public $__names = array( - 0 => 'DIRECTORY', - 1 => 'FILE', - ); -} - -final class FileTransferMode { - const SYNC = 0; - const ASYNC = 1; - static public $__names = array( - 0 => 'SYNC', - 1 => 'ASYNC', - ); -} - -final class FileTransferStatus { - const CREATED = 0; - const QUEUED = 1; - const RUNNING = 2; - const COMPLETED = 3; - const FAILED = 4; - static public $__names = array( - 0 => 'CREATED', - 1 => 'QUEUED', - 2 => 'RUNNING', - 3 => 'COMPLETED', - 4 => 'FAILED', - ); -} - -class FileTransferRequestModel { - static $_TSPEC; - - /** - * @var string - */ - public $transferId = null; - /** - * @var string - */ - public $gatewayId = null; - /** - * @var string - */ - public $username = null; - /** - * @var string - */ - public $srcHostname = null; - /** - * @var string - */ - public $srcLoginName = null; - /** - * @var int - */ - public $srcPort = null; - /** - * @var int - */ - public $srcProtocol = null; - /** - * @var string - */ - public $srcFilePath = null; - /** - * @var string - */ - public $srcHostCredToken = null; - /** - * @var string - */ - public $destHostname = null; - /** - * @var string - */ - public $destLoginName = null; - /** - * @var int - */ - public $destPort = null; - /** - * @var int - */ - public $destProtocol = null; - /** - * @var string - */ - public $destFilePath = null; - /** - * @var string - */ - public $destHostCredToken = null; - /** - * @var int - */ - public $fileTransferMode = null; - /** - * @var int - */ - public $transferStatus = null; - /** - * @var int - */ - public $fileSize = null; - /** - * @var int - */ - public $transferTime = null; - /** - * @var int - */ - public $createdTime = null; - /** - * @var int - */ - public $lastModifiedType = null; - /** - * @var string[] - */ - public $callbackEmails = null; - - public function __construct($vals=null) { - if (!isset(self::$_TSPEC)) { - self::$_TSPEC = array( - 1 => array( - 'var' => 'transferId', - 'type' => TType::STRING, - ), - 2 => array( - 'var' => 'gatewayId', - 'type' => TType::STRING, - ), - 3 => array( - 'var' => 'username', - 'type' => TType::STRING, - ), - 4 => array( - 'var' => 'srcHostname', - 'type' => TType::STRING, - ), - 5 => array( - 'var' => 'srcLoginName', - 'type' => TType::STRING, - ), - 6 => array( - 'var' => 'srcPort', - 'type' => TType::I64, - ), - 7 => array( - 'var' => 'srcProtocol', - 'type' => TType::I32, - ), - 8 => array( - 'var' => 'srcFilePath', - 'type' => TType::STRING, - ), - 9 => array( - 'var' => 'srcHostCredToken', - 'type' => TType::STRING, - ), - 10 => array( - 'var' => 'destHostname', - 'type' => TType::STRING, - ), - 11 => array( - 'var' => 'destLoginName', - 'type' => TType::STRING, - ), - 12 => array( - 'var' => 'destPort', - 'type' => TType::I64, - ), - 13 => array( - 'var' => 'destProtocol', - 'type' => TType::I32, - ), - 14 => array( - 'var' => 'destFilePath', - 'type' => TType::STRING, - ), - 15 => array( - 'var' => 'destHostCredToken', - 'type' => TType::STRING, - ), - 16 => array( - 'var' => 'fileTransferMode', - 'type' => TType::I32, - ), - 17 => array( - 'var' => 'transferStatus', - 'type' => TType::I32, - ), - 18 => array( - 'var' => 'fileSize', - 'type' => TType::I64, - ), - 19 => array( - 'var' => 'transferTime', - 'type' => TType::I64, - ), - 20 => array( - 'var' => 'createdTime', - 'type' => TType::I64, - ), - 21 => array( - 'var' => 'lastModifiedType', - 'type' => TType::I64, - ), - 22 => array( - 'var' => 'callbackEmails', - 'type' => TType::LST, - 'etype' => TType::STRING, - 'elem' => array( - 'type' => TType::STRING, - ), - ), - ); - } - if (is_array($vals)) { - if (isset($vals['transferId'])) { - $this->transferId = $vals['transferId']; - } - if (isset($vals['gatewayId'])) { - $this->gatewayId = $vals['gatewayId']; - } - if (isset($vals['username'])) { - $this->username = $vals['username']; - } - if (isset($vals['srcHostname'])) { - $this->srcHostname = $vals['srcHostname']; - } - if (isset($vals['srcLoginName'])) { - $this->srcLoginName = $vals['srcLoginName']; - } - if (isset($vals['srcPort'])) { - $this->srcPort = $vals['srcPort']; - } - if (isset($vals['srcProtocol'])) { - $this->srcProtocol = $vals['srcProtocol']; - } - if (isset($vals['srcFilePath'])) { - $this->srcFilePath = $vals['srcFilePath']; - } - if (isset($vals['srcHostCredToken'])) { - $this->srcHostCredToken = $vals['srcHostCredToken']; - } - if (isset($vals['destHostname'])) { - $this->destHostname = $vals['destHostname']; - } - if (isset($vals['destLoginName'])) { - $this->destLoginName = $vals['destLoginName']; - } - if (isset($vals['destPort'])) { - $this->destPort = $vals['destPort']; - } - if (isset($vals['destProtocol'])) { - $this->destProtocol = $vals['destProtocol']; - } - if (isset($vals['destFilePath'])) { - $this->destFilePath = $vals['destFilePath']; - } - if (isset($vals['destHostCredToken'])) { - $this->destHostCredToken = $vals['destHostCredToken']; - } - if (isset($vals['fileTransferMode'])) { - $this->fileTransferMode = $vals['fileTransferMode']; - } - if (isset($vals['transferStatus'])) { - $this->transferStatus = $vals['transferStatus']; - } - if (isset($vals['fileSize'])) { - $this->fileSize = $vals['fileSize']; - } - if (isset($vals['transferTime'])) { - $this->transferTime = $vals['transferTime']; - } - if (isset($vals['createdTime'])) { - $this->createdTime = $vals['createdTime']; - } - if (isset($vals['lastModifiedType'])) { - $this->lastModifiedType = $vals['lastModifiedType']; - } - if (isset($vals['callbackEmails'])) { - $this->callbackEmails = $vals['callbackEmails']; - } - } - } - - public function getName() { - return 'FileTransferRequestModel'; - } - - public function read($input) - { - $xfer = 0; - $fname = null; - $ftype = 0; - $fid = 0; - $xfer += $input->readStructBegin($fname); - while (true) - { - $xfer += $input->readFieldBegin($fname, $ftype, $fid); - if ($ftype == TType::STOP) { - break; - } - switch ($fid) - { - case 1: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->transferId); - } else { - $xfer += $input->skip($ftype); - } - break; - case 2: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->gatewayId); - } else { - $xfer += $input->skip($ftype); - } - break; - case 3: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->username); - } else { - $xfer += $input->skip($ftype); - } - break; - case 4: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->srcHostname); - } else { - $xfer += $input->skip($ftype); - } - break; - case 5: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->srcLoginName); - } else { - $xfer += $input->skip($ftype); - } - break; - case 6: - if ($ftype == TType::I64) { - $xfer += $input->readI64($this->srcPort); - } else { - $xfer += $input->skip($ftype); - } - break; - case 7: - if ($ftype == TType::I32) { - $xfer += $input->readI32($this->srcProtocol); - } else { - $xfer += $input->skip($ftype); - } - break; - case 8: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->srcFilePath); - } else { - $xfer += $input->skip($ftype); - } - break; - case 9: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->srcHostCredToken); - } else { - $xfer += $input->skip($ftype); - } - break; - case 10: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->destHostname); - } else { - $xfer += $input->skip($ftype); - } - break; - case 11: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->destLoginName); - } else { - $xfer += $input->skip($ftype); - } - break; - case 12: - if ($ftype == TType::I64) { - $xfer += $input->readI64($this->destPort); - } else { - $xfer += $input->skip($ftype); - } - break; - case 13: - if ($ftype == TType::I32) { - $xfer += $input->readI32($this->destProtocol); - } else { - $xfer += $input->skip($ftype); - } - break; - case 14: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->destFilePath); - } else { - $xfer += $input->skip($ftype); - } - break; - case 15: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->destHostCredToken); - } else { - $xfer += $input->skip($ftype); - } - break; - case 16: - if ($ftype == TType::I32) { - $xfer += $input->readI32($this->fileTransferMode); - } else { - $xfer += $input->skip($ftype); - } - break; - case 17: - if ($ftype == TType::I32) { - $xfer += $input->readI32($this->transferStatus); - } else { - $xfer += $input->skip($ftype); - } - break; - case 18: - if ($ftype == TType::I64) { - $xfer += $input->readI64($this->fileSize); - } else { - $xfer += $input->skip($ftype); - } - break; - case 19: - if ($ftype == TType::I64) { - $xfer += $input->readI64($this->transferTime); - } else { - $xfer += $input->skip($ftype); - } - break; - case 20: - if ($ftype == TType::I64) { - $xfer += $input->readI64($this->createdTime); - } else { - $xfer += $input->skip($ftype); - } - break; - case 21: - if ($ftype == TType::I64) { - $xfer += $input->readI64($this->lastModifiedType); - } else { - $xfer += $input->skip($ftype); - } - break; - case 22: - if ($ftype == TType::LST) { - $this->callbackEmails = array(); - $_size0 = 0; - $_etype3 = 0; - $xfer += $input->readListBegin($_etype3, $_size0); - for ($_i4 = 0; $_i4 < $_size0; ++$_i4) - { - $elem5 = null; - $xfer += $input->readString($elem5); - $this->callbackEmails []= $elem5; - } - $xfer += $input->readListEnd(); - } else { - $xfer += $input->skip($ftype); - } - break; - default: - $xfer += $input->skip($ftype); - break; - } - $xfer += $input->readFieldEnd(); - } - $xfer += $input->readStructEnd(); - return $xfer; - } - - public function write($output) { - $xfer = 0; - $xfer += $output->writeStructBegin('FileTransferRequestModel'); - if ($this->transferId !== null) { - $xfer += $output->writeFieldBegin('transferId', TType::STRING, 1); - $xfer += $output->writeString($this->transferId); - $xfer += $output->writeFieldEnd(); - } - if ($this->gatewayId !== null) { - $xfer += $output->writeFieldBegin('gatewayId', TType::STRING, 2); - $xfer += $output->writeString($this->gatewayId); - $xfer += $output->writeFieldEnd(); - } - if ($this->username !== null) { - $xfer += $output->writeFieldBegin('username', TType::STRING, 3); - $xfer += $output->writeString($this->username); - $xfer += $output->writeFieldEnd(); - } - if ($this->srcHostname !== null) { - $xfer += $output->writeFieldBegin('srcHostname', TType::STRING, 4); - $xfer += $output->writeString($this->srcHostname); - $xfer += $output->writeFieldEnd(); - } - if ($this->srcLoginName !== null) { - $xfer += $output->writeFieldBegin('srcLoginName', TType::STRING, 5); - $xfer += $output->writeString($this->srcLoginName); - $xfer += $output->writeFieldEnd(); - } - if ($this->srcPort !== null) { - $xfer += $output->writeFieldBegin('srcPort', TType::I64, 6); - $xfer += $output->writeI64($this->srcPort); - $xfer += $output->writeFieldEnd(); - } - if ($this->srcProtocol !== null) { - $xfer += $output->writeFieldBegin('srcProtocol', TType::I32, 7); - $xfer += $output->writeI32($this->srcProtocol); - $xfer += $output->writeFieldEnd(); - } - if ($this->srcFilePath !== null) { - $xfer += $output->writeFieldBegin('srcFilePath', TType::STRING, 8); - $xfer += $output->writeString($this->srcFilePath); - $xfer += $output->writeFieldEnd(); - } - if ($this->srcHostCredToken !== null) { - $xfer += $output->writeFieldBegin('srcHostCredToken', TType::STRING, 9); - $xfer += $output->writeString($this->srcHostCredToken); - $xfer += $output->writeFieldEnd(); - } - if ($this->destHostname !== null) { - $xfer += $output->writeFieldBegin('destHostname', TType::STRING, 10); - $xfer += $output->writeString($this->destHostname); - $xfer += $output->writeFieldEnd(); - } - if ($this->destLoginName !== null) { - $xfer += $output->writeFieldBegin('destLoginName', TType::STRING, 11); - $xfer += $output->writeString($this->destLoginName); - $xfer += $output->writeFieldEnd(); - } - if ($this->destPort !== null) { - $xfer += $output->writeFieldBegin('destPort', TType::I64, 12); - $xfer += $output->writeI64($this->destPort); - $xfer += $output->writeFieldEnd(); - } - if ($this->destProtocol !== null) { - $xfer += $output->writeFieldBegin('destProtocol', TType::I32, 13); - $xfer += $output->writeI32($this->destProtocol); - $xfer += $output->writeFieldEnd(); - } - if ($this->destFilePath !== null) { - $xfer += $output->writeFieldBegin('destFilePath', TType::STRING, 14); - $xfer += $output->writeString($this->destFilePath); - $xfer += $output->writeFieldEnd(); - } - if ($this->destHostCredToken !== null) { - $xfer += $output->writeFieldBegin('destHostCredToken', TType::STRING, 15); - $xfer += $output->writeString($this->destHostCredToken); - $xfer += $output->writeFieldEnd(); - } - if ($this->fileTransferMode !== null) { - $xfer += $output->writeFieldBegin('fileTransferMode', TType::I32, 16); - $xfer += $output->writeI32($this->fileTransferMode); - $xfer += $output->writeFieldEnd(); - } - if ($this->transferStatus !== null) { - $xfer += $output->writeFieldBegin('transferStatus', TType::I32, 17); - $xfer += $output->writeI32($this->transferStatus); - $xfer += $output->writeFieldEnd(); - } - if ($this->fileSize !== null) { - $xfer += $output->writeFieldBegin('fileSize', TType::I64, 18); - $xfer += $output->writeI64($this->fileSize); - $xfer += $output->writeFieldEnd(); - } - if ($this->transferTime !== null) { - $xfer += $output->writeFieldBegin('transferTime', TType::I64, 19); - $xfer += $output->writeI64($this->transferTime); - $xfer += $output->writeFieldEnd(); - } - if ($this->createdTime !== null) { - $xfer += $output->writeFieldBegin('createdTime', TType::I64, 20); - $xfer += $output->writeI64($this->createdTime); - $xfer += $output->writeFieldEnd(); - } - if ($this->lastModifiedType !== null) { - $xfer += $output->writeFieldBegin('lastModifiedType', TType::I64, 21); - $xfer += $output->writeI64($this->lastModifiedType); - $xfer += $output->writeFieldEnd(); - } - if ($this->callbackEmails !== null) { - if (!is_array($this->callbackEmails)) { - throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); - } - $xfer += $output->writeFieldBegin('callbackEmails', TType::LST, 22); - { - $output->writeListBegin(TType::STRING, count($this->callbackEmails)); - { - foreach ($this->callbackEmails as $iter6) - { - $xfer += $output->writeString($iter6); - } - } - $output->writeListEnd(); - } - $xfer += $output->writeFieldEnd(); - } - $xfer += $output->writeFieldStop(); - $xfer += $output->writeStructEnd(); - return $xfer; - } - -} - -class LSEntryModel { - static $_TSPEC; - - /** - * @var int - */ - public $type = null; - /** - * @var int - */ - public $size = null; - /** - * @var string - */ - public $nativeType = null; - /** - * @var string - */ - public $name = null; - /** - * @var string - */ - public $path = null; - /** - * @var string - */ - public $storageHostName = null; - /** - * @var int - */ - public $lastModifiedType = null; - /** - * @var int - */ - public $createdTime = null; - - public function __construct($vals=null) { - if (!isset(self::$_TSPEC)) { - self::$_TSPEC = array( - 1 => array( - 'var' => 'type', - 'type' => TType::I32, - ), - 2 => array( - 'var' => 'size', - 'type' => TType::I64, - ), - 3 => array( - 'var' => 'nativeType', - 'type' => TType::STRING, - ), - 4 => array( - 'var' => 'name', - 'type' => TType::STRING, - ), - 5 => array( - 'var' => 'path', - 'type' => TType::STRING, - ), - 6 => array( - 'var' => 'storageHostName', - 'type' => TType::STRING, - ), - 7 => array( - 'var' => 'lastModifiedType', - 'type' => TType::I64, - ), - 8 => array( - 'var' => 'createdTime', - 'type' => TType::I64, - ), - ); - } - if (is_array($vals)) { - if (isset($vals['type'])) { - $this->type = $vals['type']; - } - if (isset($vals['size'])) { - $this->size = $vals['size']; - } - if (isset($vals['nativeType'])) { - $this->nativeType = $vals['nativeType']; - } - if (isset($vals['name'])) { - $this->name = $vals['name']; - } - if (isset($vals['path'])) { - $this->path = $vals['path']; - } - if (isset($vals['storageHostName'])) { - $this->storageHostName = $vals['storageHostName']; - } - if (isset($vals['lastModifiedType'])) { - $this->lastModifiedType = $vals['lastModifiedType']; - } - if (isset($vals['createdTime'])) { - $this->createdTime = $vals['createdTime']; - } - } - } - - public function getName() { - return 'LSEntryModel'; - } - - public function read($input) - { - $xfer = 0; - $fname = null; - $ftype = 0; - $fid = 0; - $xfer += $input->readStructBegin($fname); - while (true) - { - $xfer += $input->readFieldBegin($fname, $ftype, $fid); - if ($ftype == TType::STOP) { - break; - } - switch ($fid) - { - case 1: - if ($ftype == TType::I32) { - $xfer += $input->readI32($this->type); - } else { - $xfer += $input->skip($ftype); - } - break; - case 2: - if ($ftype == TType::I64) { - $xfer += $input->readI64($this->size); - } else { - $xfer += $input->skip($ftype); - } - break; - case 3: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->nativeType); - } else { - $xfer += $input->skip($ftype); - } - break; - case 4: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->name); - } else { - $xfer += $input->skip($ftype); - } - break; - case 5: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->path); - } else { - $xfer += $input->skip($ftype); - } - break; - case 6: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->storageHostName); - } else { - $xfer += $input->skip($ftype); - } - break; - case 7: - if ($ftype == TType::I64) { - $xfer += $input->readI64($this->lastModifiedType); - } else { - $xfer += $input->skip($ftype); - } - break; - case 8: - if ($ftype == TType::I64) { - $xfer += $input->readI64($this->createdTime); - } else { - $xfer += $input->skip($ftype); - } - break; - default: - $xfer += $input->skip($ftype); - break; - } - $xfer += $input->readFieldEnd(); - } - $xfer += $input->readStructEnd(); - return $xfer; - } - - public function write($output) { - $xfer = 0; - $xfer += $output->writeStructBegin('LSEntryModel'); - if ($this->type !== null) { - $xfer += $output->writeFieldBegin('type', TType::I32, 1); - $xfer += $output->writeI32($this->type); - $xfer += $output->writeFieldEnd(); - } - if ($this->size !== null) { - $xfer += $output->writeFieldBegin('size', TType::I64, 2); - $xfer += $output->writeI64($this->size); - $xfer += $output->writeFieldEnd(); - } - if ($this->nativeType !== null) { - $xfer += $output->writeFieldBegin('nativeType', TType::STRING, 3); - $xfer += $output->writeString($this->nativeType); - $xfer += $output->writeFieldEnd(); - } - if ($this->name !== null) { - $xfer += $output->writeFieldBegin('name', TType::STRING, 4); - $xfer += $output->writeString($this->name); - $xfer += $output->writeFieldEnd(); - } - if ($this->path !== null) { - $xfer += $output->writeFieldBegin('path', TType::STRING, 5); - $xfer += $output->writeString($this->path); - $xfer += $output->writeFieldEnd(); - } - if ($this->storageHostName !== null) { - $xfer += $output->writeFieldBegin('storageHostName', TType::STRING, 6); - $xfer += $output->writeString($this->storageHostName); - $xfer += $output->writeFieldEnd(); - } - if ($this->lastModifiedType !== null) { - $xfer += $output->writeFieldBegin('lastModifiedType', TType::I64, 7); - $xfer += $output->writeI64($this->lastModifiedType); - $xfer += $output->writeFieldEnd(); - } - if ($this->createdTime !== null) { - $xfer += $output->writeFieldBegin('createdTime', TType::I64, 8); - $xfer += $output->writeI64($this->createdTime); - $xfer += $output->writeFieldEnd(); - } - $xfer += $output->writeFieldStop(); - $xfer += $output->writeStructEnd(); - return $xfer; - } - -} - -
