in airavata-api/airavata-data-models/src/main/java/org/apache/airavata/model/process/ProcessModel.java [2796:3019]
public void write(org.apache.thrift.protocol.TProtocol oprot, ProcessModel struct) throws org.apache.thrift.TException {
struct.validate();
oprot.writeStructBegin(STRUCT_DESC);
if (struct.processId != null) {
oprot.writeFieldBegin(PROCESS_ID_FIELD_DESC);
oprot.writeString(struct.processId);
oprot.writeFieldEnd();
}
if (struct.experimentId != null) {
oprot.writeFieldBegin(EXPERIMENT_ID_FIELD_DESC);
oprot.writeString(struct.experimentId);
oprot.writeFieldEnd();
}
if (struct.isSetCreationTime()) {
oprot.writeFieldBegin(CREATION_TIME_FIELD_DESC);
oprot.writeI64(struct.creationTime);
oprot.writeFieldEnd();
}
if (struct.isSetLastUpdateTime()) {
oprot.writeFieldBegin(LAST_UPDATE_TIME_FIELD_DESC);
oprot.writeI64(struct.lastUpdateTime);
oprot.writeFieldEnd();
}
if (struct.processStatuses != null) {
if (struct.isSetProcessStatuses()) {
oprot.writeFieldBegin(PROCESS_STATUSES_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.processStatuses.size()));
for (org.apache.airavata.model.status.ProcessStatus _iter21 : struct.processStatuses)
{
_iter21.write(oprot);
}
oprot.writeListEnd();
}
oprot.writeFieldEnd();
}
}
if (struct.processDetail != null) {
if (struct.isSetProcessDetail()) {
oprot.writeFieldBegin(PROCESS_DETAIL_FIELD_DESC);
oprot.writeString(struct.processDetail);
oprot.writeFieldEnd();
}
}
if (struct.applicationInterfaceId != null) {
if (struct.isSetApplicationInterfaceId()) {
oprot.writeFieldBegin(APPLICATION_INTERFACE_ID_FIELD_DESC);
oprot.writeString(struct.applicationInterfaceId);
oprot.writeFieldEnd();
}
}
if (struct.applicationDeploymentId != null) {
if (struct.isSetApplicationDeploymentId()) {
oprot.writeFieldBegin(APPLICATION_DEPLOYMENT_ID_FIELD_DESC);
oprot.writeString(struct.applicationDeploymentId);
oprot.writeFieldEnd();
}
}
if (struct.computeResourceId != null) {
if (struct.isSetComputeResourceId()) {
oprot.writeFieldBegin(COMPUTE_RESOURCE_ID_FIELD_DESC);
oprot.writeString(struct.computeResourceId);
oprot.writeFieldEnd();
}
}
if (struct.processInputs != null) {
if (struct.isSetProcessInputs()) {
oprot.writeFieldBegin(PROCESS_INPUTS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.processInputs.size()));
for (org.apache.airavata.model.application.io.InputDataObjectType _iter22 : struct.processInputs)
{
_iter22.write(oprot);
}
oprot.writeListEnd();
}
oprot.writeFieldEnd();
}
}
if (struct.processOutputs != null) {
if (struct.isSetProcessOutputs()) {
oprot.writeFieldBegin(PROCESS_OUTPUTS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.processOutputs.size()));
for (org.apache.airavata.model.application.io.OutputDataObjectType _iter23 : struct.processOutputs)
{
_iter23.write(oprot);
}
oprot.writeListEnd();
}
oprot.writeFieldEnd();
}
}
if (struct.processResourceSchedule != null) {
if (struct.isSetProcessResourceSchedule()) {
oprot.writeFieldBegin(PROCESS_RESOURCE_SCHEDULE_FIELD_DESC);
struct.processResourceSchedule.write(oprot);
oprot.writeFieldEnd();
}
}
if (struct.tasks != null) {
if (struct.isSetTasks()) {
oprot.writeFieldBegin(TASKS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.tasks.size()));
for (org.apache.airavata.model.task.TaskModel _iter24 : struct.tasks)
{
_iter24.write(oprot);
}
oprot.writeListEnd();
}
oprot.writeFieldEnd();
}
}
if (struct.taskDag != null) {
if (struct.isSetTaskDag()) {
oprot.writeFieldBegin(TASK_DAG_FIELD_DESC);
oprot.writeString(struct.taskDag);
oprot.writeFieldEnd();
}
}
if (struct.processErrors != null) {
if (struct.isSetProcessErrors()) {
oprot.writeFieldBegin(PROCESS_ERRORS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.processErrors.size()));
for (org.apache.airavata.model.commons.ErrorModel _iter25 : struct.processErrors)
{
_iter25.write(oprot);
}
oprot.writeListEnd();
}
oprot.writeFieldEnd();
}
}
if (struct.gatewayExecutionId != null) {
if (struct.isSetGatewayExecutionId()) {
oprot.writeFieldBegin(GATEWAY_EXECUTION_ID_FIELD_DESC);
oprot.writeString(struct.gatewayExecutionId);
oprot.writeFieldEnd();
}
}
if (struct.isSetEnableEmailNotification()) {
oprot.writeFieldBegin(ENABLE_EMAIL_NOTIFICATION_FIELD_DESC);
oprot.writeBool(struct.enableEmailNotification);
oprot.writeFieldEnd();
}
if (struct.emailAddresses != null) {
if (struct.isSetEmailAddresses()) {
oprot.writeFieldBegin(EMAIL_ADDRESSES_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.emailAddresses.size()));
for (java.lang.String _iter26 : struct.emailAddresses)
{
oprot.writeString(_iter26);
}
oprot.writeListEnd();
}
oprot.writeFieldEnd();
}
}
if (struct.storageResourceId != null) {
if (struct.isSetStorageResourceId()) {
oprot.writeFieldBegin(STORAGE_RESOURCE_ID_FIELD_DESC);
oprot.writeString(struct.storageResourceId);
oprot.writeFieldEnd();
}
}
if (struct.userDn != null) {
if (struct.isSetUserDn()) {
oprot.writeFieldBegin(USER_DN_FIELD_DESC);
oprot.writeString(struct.userDn);
oprot.writeFieldEnd();
}
}
if (struct.isSetGenerateCert()) {
oprot.writeFieldBegin(GENERATE_CERT_FIELD_DESC);
oprot.writeBool(struct.generateCert);
oprot.writeFieldEnd();
}
if (struct.experimentDataDir != null) {
if (struct.isSetExperimentDataDir()) {
oprot.writeFieldBegin(EXPERIMENT_DATA_DIR_FIELD_DESC);
oprot.writeString(struct.experimentDataDir);
oprot.writeFieldEnd();
}
}
if (struct.userName != null) {
if (struct.isSetUserName()) {
oprot.writeFieldBegin(USER_NAME_FIELD_DESC);
oprot.writeString(struct.userName);
oprot.writeFieldEnd();
}
}
if (struct.isSetUseUserCRPref()) {
oprot.writeFieldBegin(USE_USER_CRPREF_FIELD_DESC);
oprot.writeBool(struct.useUserCRPref);
oprot.writeFieldEnd();
}
if (struct.groupResourceProfileId != null) {
if (struct.isSetGroupResourceProfileId()) {
oprot.writeFieldBegin(GROUP_RESOURCE_PROFILE_ID_FIELD_DESC);
oprot.writeString(struct.groupResourceProfileId);
oprot.writeFieldEnd();
}
}
if (struct.processWorkflows != null) {
if (struct.isSetProcessWorkflows()) {
oprot.writeFieldBegin(PROCESS_WORKFLOWS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.processWorkflows.size()));
for (ProcessWorkflow _iter27 : struct.processWorkflows)
{
_iter27.write(oprot);
}
oprot.writeListEnd();
}
oprot.writeFieldEnd();
}
}
oprot.writeFieldStop();
oprot.writeStructEnd();
}