[27/31] airavata git commit: updating local to upstream develop

[sh...@apache.org]

http://git-wip-us.apache.org/repos/asf/airavata/blob/fa5a1e0f/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata.cpp
----------------------------------------------------------------------
diff --cc airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata.cpp
index 34499ed,cac0f48..ed775e8
--- a/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata.cpp
+++ b/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata.cpp
@@@ -46135,8772 -46214,3269 +46135,9024 @@@ uint32_t Airavata_isWorkflowExistWithNa
  }
  
  
++<<<<<<< HEAD
 +Airavata_registerDataProduct_args::~Airavata_registerDataProduct_args() throw() {
++=======
+ Airavata_isDataSharingEnabled_args::~Airavata_isDataSharingEnabled_args() throw() {
+ }
+ 
+ 
+ uint32_t Airavata_isDataSharingEnabled_args::read(::apache::thrift::protocol::TProtocol* iprot) {
+ 
+   apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
+   uint32_t xfer = 0;
+   std::string fname;
+   ::apache::thrift::protocol::TType ftype;
+   int16_t fid;
+ 
+   xfer += iprot->readStructBegin(fname);
+ 
+   using ::apache::thrift::protocol::TProtocolException;
+ 
+ 
+   while (true)
+   {
+     xfer += iprot->readFieldBegin(fname, ftype, fid);
+     if (ftype == ::apache::thrift::protocol::T_STOP) {
+       break;
+     }
+     xfer += iprot->skip(ftype);
+     xfer += iprot->readFieldEnd();
+   }
+ 
+   xfer += iprot->readStructEnd();
+ 
+   return xfer;
+ }
+ 
+ uint32_t Airavata_isDataSharingEnabled_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
+   uint32_t xfer = 0;
+   apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
+   xfer += oprot->writeStructBegin("Airavata_isDataSharingEnabled_args");
+ 
+   xfer += oprot->writeFieldStop();
+   xfer += oprot->writeStructEnd();
+   return xfer;
+ }
+ 
+ 
+ Airavata_isDataSharingEnabled_pargs::~Airavata_isDataSharingEnabled_pargs() throw() {
+ }
+ 
+ 
+ uint32_t Airavata_isDataSharingEnabled_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
+   uint32_t xfer = 0;
+   apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
+   xfer += oprot->writeStructBegin("Airavata_isDataSharingEnabled_pargs");
+ 
+   xfer += oprot->writeFieldStop();
+   xfer += oprot->writeStructEnd();
+   return xfer;
+ }
+ 
+ 
+ Airavata_isDataSharingEnabled_result::~Airavata_isDataSharingEnabled_result() throw() {
+ }
+ 
+ 
+ uint32_t Airavata_isDataSharingEnabled_result::read(::apache::thrift::protocol::TProtocol* iprot) {
+ 
+   apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
+   uint32_t xfer = 0;
+   std::string fname;
+   ::apache::thrift::protocol::TType ftype;
+   int16_t fid;
+ 
+   xfer += iprot->readStructBegin(fname);
+ 
+   using ::apache::thrift::protocol::TProtocolException;
+ 
+ 
+   while (true)
+   {
+     xfer += iprot->readFieldBegin(fname, ftype, fid);
+     if (ftype == ::apache::thrift::protocol::T_STOP) {
+       break;
+     }
+     switch (fid)
+     {
+       case 0:
+         if (ftype == ::apache::thrift::protocol::T_BOOL) {
+           xfer += iprot->readBool(this->success);
+           this->__isset.success = true;
+         } else {
+           xfer += iprot->skip(ftype);
+         }
+         break;
+       case 1:
+         if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+           xfer += this->ire.read(iprot);
+           this->__isset.ire = true;
+         } else {
+           xfer += iprot->skip(ftype);
+         }
+         break;
+       case 2:
+         if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+           xfer += this->ace.read(iprot);
+           this->__isset.ace = true;
+         } else {
+           xfer += iprot->skip(ftype);
+         }
+         break;
+       case 3:
+         if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+           xfer += this->ase.read(iprot);
+           this->__isset.ase = true;
+         } else {
+           xfer += iprot->skip(ftype);
+         }
+         break;
+       case 4:
+         if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+           xfer += this->ae.read(iprot);
+           this->__isset.ae = true;
+         } else {
+           xfer += iprot->skip(ftype);
+         }
+         break;
+       default:
+         xfer += iprot->skip(ftype);
+         break;
+     }
+     xfer += iprot->readFieldEnd();
+   }
+ 
+   xfer += iprot->readStructEnd();
+ 
+   return xfer;
+ }
+ 
+ uint32_t Airavata_isDataSharingEnabled_result::write(::apache::thrift::protocol::TProtocol* oprot) const {
+ 
+   uint32_t xfer = 0;
+ 
+   xfer += oprot->writeStructBegin("Airavata_isDataSharingEnabled_result");
+ 
+   if (this->__isset.success) {
+     xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_BOOL, 0);
+     xfer += oprot->writeBool(this->success);
+     xfer += oprot->writeFieldEnd();
+   } else if (this->__isset.ire) {
+     xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1);
+     xfer += this->ire.write(oprot);
+     xfer += oprot->writeFieldEnd();
+   } else if (this->__isset.ace) {
+     xfer += oprot->writeFieldBegin("ace", ::apache::thrift::protocol::T_STRUCT, 2);
+     xfer += this->ace.write(oprot);
+     xfer += oprot->writeFieldEnd();
+   } else if (this->__isset.ase) {
+     xfer += oprot->writeFieldBegin("ase", ::apache::thrift::protocol::T_STRUCT, 3);
+     xfer += this->ase.write(oprot);
+     xfer += oprot->writeFieldEnd();
+   } else if (this->__isset.ae) {
+     xfer += oprot->writeFieldBegin("ae", ::apache::thrift::protocol::T_STRUCT, 4);
+     xfer += this->ae.write(oprot);
+     xfer += oprot->writeFieldEnd();
+   }
+   xfer += oprot->writeFieldStop();
+   xfer += oprot->writeStructEnd();
+   return xfer;
+ }
+ 
+ 
+ Airavata_isDataSharingEnabled_presult::~Airavata_isDataSharingEnabled_presult() throw() {
+ }
+ 
+ 
+ uint32_t Airavata_isDataSharingEnabled_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
+ 
+   apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
+   uint32_t xfer = 0;
+   std::string fname;
+   ::apache::thrift::protocol::TType ftype;
+   int16_t fid;
+ 
+   xfer += iprot->readStructBegin(fname);
+ 
+   using ::apache::thrift::protocol::TProtocolException;
+ 
+ 
+   while (true)
+   {
+     xfer += iprot->readFieldBegin(fname, ftype, fid);
+     if (ftype == ::apache::thrift::protocol::T_STOP) {
+       break;
+     }
+     switch (fid)
+     {
+       case 0:
+         if (ftype == ::apache::thrift::protocol::T_BOOL) {
+           xfer += iprot->readBool((*(this->success)));
+           this->__isset.success = true;
+         } else {
+           xfer += iprot->skip(ftype);
+         }
+         break;
+       case 1:
+         if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+           xfer += this->ire.read(iprot);
+           this->__isset.ire = true;
+         } else {
+           xfer += iprot->skip(ftype);
+         }
+         break;
+       case 2:
+         if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+           xfer += this->ace.read(iprot);
+           this->__isset.ace = true;
+         } else {
+           xfer += iprot->skip(ftype);
+         }
+         break;
+       case 3:
+         if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+           xfer += this->ase.read(iprot);
+           this->__isset.ase = true;
+         } else {
+           xfer += iprot->skip(ftype);
+         }
+         break;
+       case 4:
+         if (ftype == ::apache::thrift::protocol::T_STRUCT) {
+           xfer += this->ae.read(iprot);
+           this->__isset.ae = true;
+         } else {
+           xfer += iprot->skip(ftype);
+         }
+         break;
+       default:
+         xfer += iprot->skip(ftype);
+         break;
+     }
+     xfer += iprot->readFieldEnd();
+   }
+ 
+   xfer += iprot->readStructEnd();
+ 
+   return xfer;
+ }
+ 
+ void AiravataClient::getAPIVersion(std::string& _return, const  ::apache::airavata::model::security::AuthzToken& authzToken)
+ {
+   send_getAPIVersion(authzToken);
+   recv_getAPIVersion(_return);
++>>>>>>> upstream/develop
  }
  
 -void AiravataClient::send_getAPIVersion(const  ::apache::airavata::model::security::AuthzToken& authzToken)
 -{
 -  int32_t cseqid = 0;
 -  oprot_->writeMessageBegin("getAPIVersion", ::apache::thrift::protocol::T_CALL, cseqid);
 -
 -  Airavata_getAPIVersion_pargs args;
 -  args.authzToken = &authzToken;
 -  args.write(oprot_);
 -
 -  oprot_->writeMessageEnd();
 -  oprot_->getTransport()->writeEnd();
 -  oprot_->getTransport()->flush();
 -}
  
 -void AiravataClient::recv_getAPIVersion(std::string& _return)
 -{
 +uint32_t Airavata_registerDataProduct_args::read(::apache::thrift::protocol::TProtocol* iprot) {
  
 -  int32_t rseqid = 0;
 +  apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
 +  uint32_t xfer = 0;
    std::string fname;
 -  ::apache::thrift::protocol::TMessageType mtype;
 +  ::apache::thrift::protocol::TType ftype;
 +  int16_t fid;
  
 -  iprot_->readMessageBegin(fname, mtype, rseqid);
 -  if (mtype == ::apache::thrift::protocol::T_EXCEPTION) {
 -    ::apache::thrift::TApplicationException x;
 -    x.read(iprot_);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -    throw x;
 -  }
 -  if (mtype != ::apache::thrift::protocol::T_REPLY) {
 -    iprot_->skip(::apache::thrift::protocol::T_STRUCT);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -  }
 -  if (fname.compare("getAPIVersion") != 0) {
 -    iprot_->skip(::apache::thrift::protocol::T_STRUCT);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -  }
 -  Airavata_getAPIVersion_presult result;
 -  result.success = &_return;
 -  result.read(iprot_);
 -  iprot_->readMessageEnd();
 -  iprot_->getTransport()->readEnd();
 +  xfer += iprot->readStructBegin(fname);
  
 -  if (result.__isset.success) {
 -    // _return pointer has now been filled
 -    return;
 -  }
 -  if (result.__isset.ire) {
 -    throw result.ire;
 -  }
 -  if (result.__isset.ace) {
 -    throw result.ace;
 -  }
 -  if (result.__isset.ase) {
 -    throw result.ase;
 -  }
 -  if (result.__isset.ae) {
 -    throw result.ae;
 -  }
 -  throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "getAPIVersion failed: unknown result");
 -}
 +  using ::apache::thrift::protocol::TProtocolException;
  
 -bool AiravataClient::isUserExists(const  ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId, const std::string& userName)
 -{
 -  send_isUserExists(authzToken, gatewayId, userName);
 -  return recv_isUserExists();
 -}
 +  bool isset_authzToken = false;
 +  bool isset_dataProductModel = false;
  
 -void AiravataClient::send_isUserExists(const  ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId, const std::string& userName)
 -{
 -  int32_t cseqid = 0;
 -  oprot_->writeMessageBegin("isUserExists", ::apache::thrift::protocol::T_CALL, cseqid);
 +  while (true)
 +  {
 +    xfer += iprot->readFieldBegin(fname, ftype, fid);
 +    if (ftype == ::apache::thrift::protocol::T_STOP) {
 +      break;
 +    }
 +    switch (fid)
 +    {
 +      case 1:
 +        if (ftype == ::apache::thrift::protocol::T_STRUCT) {
 +          xfer += this->authzToken.read(iprot);
 +          isset_authzToken = true;
 +        } else {
 +          xfer += iprot->skip(ftype);
 +        }
 +        break;
 +      case 2:
 +        if (ftype == ::apache::thrift::protocol::T_STRUCT) {
 +          xfer += this->dataProductModel.read(iprot);
 +          isset_dataProductModel = true;
 +        } else {
 +          xfer += iprot->skip(ftype);
 +        }
 +        break;
 +      default:
 +        xfer += iprot->skip(ftype);
 +        break;
 +    }
 +    xfer += iprot->readFieldEnd();
 +  }
  
 -  Airavata_isUserExists_pargs args;
 -  args.authzToken = &authzToken;
 -  args.gatewayId = &gatewayId;
 -  args.userName = &userName;
 -  args.write(oprot_);
 +  xfer += iprot->readStructEnd();
  
 -  oprot_->writeMessageEnd();
 -  oprot_->getTransport()->writeEnd();
 -  oprot_->getTransport()->flush();
 +  if (!isset_authzToken)
 +    throw TProtocolException(TProtocolException::INVALID_DATA);
 +  if (!isset_dataProductModel)
 +    throw TProtocolException(TProtocolException::INVALID_DATA);
 +  return xfer;
  }
  
 -bool AiravataClient::recv_isUserExists()
 -{
 +uint32_t Airavata_registerDataProduct_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
 +  uint32_t xfer = 0;
 +  apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
 +  xfer += oprot->writeStructBegin("Airavata_registerDataProduct_args");
  
 -  int32_t rseqid = 0;
 -  std::string fname;
 -  ::apache::thrift::protocol::TMessageType mtype;
 +  xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1);
 +  xfer += this->authzToken.write(oprot);
 +  xfer += oprot->writeFieldEnd();
  
 -  iprot_->readMessageBegin(fname, mtype, rseqid);
 -  if (mtype == ::apache::thrift::protocol::T_EXCEPTION) {
 -    ::apache::thrift::TApplicationException x;
 -    x.read(iprot_);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -    throw x;
 -  }
 -  if (mtype != ::apache::thrift::protocol::T_REPLY) {
 -    iprot_->skip(::apache::thrift::protocol::T_STRUCT);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -  }
 -  if (fname.compare("isUserExists") != 0) {
 -    iprot_->skip(::apache::thrift::protocol::T_STRUCT);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -  }
 -  bool _return;
 -  Airavata_isUserExists_presult result;
 -  result.success = &_return;
 -  result.read(iprot_);
 -  iprot_->readMessageEnd();
 -  iprot_->getTransport()->readEnd();
 +  xfer += oprot->writeFieldBegin("dataProductModel", ::apache::thrift::protocol::T_STRUCT, 2);
 +  xfer += this->dataProductModel.write(oprot);
 +  xfer += oprot->writeFieldEnd();
  
 -  if (result.__isset.success) {
 -    return _return;
 -  }
 -  if (result.__isset.ire) {
 -    throw result.ire;
 -  }
 -  if (result.__isset.ace) {
 -    throw result.ace;
 -  }
 -  if (result.__isset.ase) {
 -    throw result.ase;
 -  }
 -  if (result.__isset.ae) {
 -    throw result.ae;
 -  }
 -  throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "isUserExists failed: unknown result");
 +  xfer += oprot->writeFieldStop();
 +  xfer += oprot->writeStructEnd();
 +  return xfer;
  }
  
 -void AiravataClient::addGateway(std::string& _return, const  ::apache::airavata::model::security::AuthzToken& authzToken, const  ::apache::airavata::model::workspace::Gateway& gateway)
 -{
 -  send_addGateway(authzToken, gateway);
 -  recv_addGateway(_return);
 +
 +Airavata_registerDataProduct_pargs::~Airavata_registerDataProduct_pargs() throw() {
  }
  
 -void AiravataClient::send_addGateway(const  ::apache::airavata::model::security::AuthzToken& authzToken, const  ::apache::airavata::model::workspace::Gateway& gateway)
 -{
 -  int32_t cseqid = 0;
 -  oprot_->writeMessageBegin("addGateway", ::apache::thrift::protocol::T_CALL, cseqid);
  
 -  Airavata_addGateway_pargs args;
 -  args.authzToken = &authzToken;
 -  args.gateway = &gateway;
 -  args.write(oprot_);
 +uint32_t Airavata_registerDataProduct_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
 +  uint32_t xfer = 0;
 +  apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
 +  xfer += oprot->writeStructBegin("Airavata_registerDataProduct_pargs");
  
 -  oprot_->writeMessageEnd();
 -  oprot_->getTransport()->writeEnd();
 -  oprot_->getTransport()->flush();
 -}
 +  xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1);
 +  xfer += (*(this->authzToken)).write(oprot);
 +  xfer += oprot->writeFieldEnd();
  
 -void AiravataClient::recv_addGateway(std::string& _return)
 -{
 +  xfer += oprot->writeFieldBegin("dataProductModel", ::apache::thrift::protocol::T_STRUCT, 2);
 +  xfer += (*(this->dataProductModel)).write(oprot);
 +  xfer += oprot->writeFieldEnd();
  
 -  int32_t rseqid = 0;
 -  std::string fname;
 -  ::apache::thrift::protocol::TMessageType mtype;
 +  xfer += oprot->writeFieldStop();
 +  xfer += oprot->writeStructEnd();
 +  return xfer;
 +}
  
 -  iprot_->readMessageBegin(fname, mtype, rseqid);
 -  if (mtype == ::apache::thrift::protocol::T_EXCEPTION) {
 -    ::apache::thrift::TApplicationException x;
 -    x.read(iprot_);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -    throw x;
 -  }
 -  if (mtype != ::apache::thrift::protocol::T_REPLY) {
 -    iprot_->skip(::apache::thrift::protocol::T_STRUCT);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -  }
 -  if (fname.compare("addGateway") != 0) {
 -    iprot_->skip(::apache::thrift::protocol::T_STRUCT);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -  }
 -  Airavata_addGateway_presult result;
 -  result.success = &_return;
 -  result.read(iprot_);
 -  iprot_->readMessageEnd();
 -  iprot_->getTransport()->readEnd();
  
 -  if (result.__isset.success) {
 -    // _return pointer has now been filled
 -    return;
 -  }
 -  if (result.__isset.ire) {
 -    throw result.ire;
 -  }
 -  if (result.__isset.ace) {
 -    throw result.ace;
 -  }
 -  if (result.__isset.ase) {
 -    throw result.ase;
 -  }
 -  if (result.__isset.ae) {
 -    throw result.ae;
 -  }
 -  throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "addGateway failed: unknown result");
 +Airavata_registerDataProduct_result::~Airavata_registerDataProduct_result() throw() {
  }
  
 -void AiravataClient::getAllUsersInGateway(std::vector<std::string> & _return, const  ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId)
 -{
 -  send_getAllUsersInGateway(authzToken, gatewayId);
 -  recv_getAllUsersInGateway(_return);
 -}
  
 -void AiravataClient::send_getAllUsersInGateway(const  ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId)
 -{
 -  int32_t cseqid = 0;
 -  oprot_->writeMessageBegin("getAllUsersInGateway", ::apache::thrift::protocol::T_CALL, cseqid);
 +uint32_t Airavata_registerDataProduct_result::read(::apache::thrift::protocol::TProtocol* iprot) {
  
 -  Airavata_getAllUsersInGateway_pargs args;
 -  args.authzToken = &authzToken;
 -  args.gatewayId = &gatewayId;
 -  args.write(oprot_);
 +  apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
 +  uint32_t xfer = 0;
 +  std::string fname;
 +  ::apache::thrift::protocol::TType ftype;
 +  int16_t fid;
  
 -  oprot_->writeMessageEnd();
 -  oprot_->getTransport()->writeEnd();
 -  oprot_->getTransport()->flush();
 -}
 +  xfer += iprot->readStructBegin(fname);
  
 -void AiravataClient::recv_getAllUsersInGateway(std::vector<std::string> & _return)
 -{
 +  using ::apache::thrift::protocol::TProtocolException;
  
 -  int32_t rseqid = 0;
 -  std::string fname;
 -  ::apache::thrift::protocol::TMessageType mtype;
  
 -  iprot_->readMessageBegin(fname, mtype, rseqid);
 -  if (mtype == ::apache::thrift::protocol::T_EXCEPTION) {
 -    ::apache::thrift::TApplicationException x;
 -    x.read(iprot_);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -    throw x;
 -  }
 -  if (mtype != ::apache::thrift::protocol::T_REPLY) {
 -    iprot_->skip(::apache::thrift::protocol::T_STRUCT);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -  }
 -  if (fname.compare("getAllUsersInGateway") != 0) {
 -    iprot_->skip(::apache::thrift::protocol::T_STRUCT);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 +  while (true)
 +  {
 +    xfer += iprot->readFieldBegin(fname, ftype, fid);
 +    if (ftype == ::apache::thrift::protocol::T_STOP) {
 +      break;
 +    }
 +    switch (fid)
 +    {
 +      case 0:
 +        if (ftype == ::apache::thrift::protocol::T_STRING) {
 +          xfer += iprot->readString(this->success);
 +          this->__isset.success = true;
 +        } else {
 +          xfer += iprot->skip(ftype);
 +        }
 +        break;
 +      case 1:
 +        if (ftype == ::apache::thrift::protocol::T_STRUCT) {
 +          xfer += this->ire.read(iprot);
 +          this->__isset.ire = true;
 +        } else {
 +          xfer += iprot->skip(ftype);
 +        }
 +        break;
 +      case 2:
 +        if (ftype == ::apache::thrift::protocol::T_STRUCT) {
 +          xfer += this->ace.read(iprot);
 +          this->__isset.ace = true;
 +        } else {
 +          xfer += iprot->skip(ftype);
 +        }
 +        break;
 +      case 3:
 +        if (ftype == ::apache::thrift::protocol::T_STRUCT) {
 +          xfer += this->ase.read(iprot);
 +          this->__isset.ase = true;
 +        } else {
 +          xfer += iprot->skip(ftype);
 +        }
 +        break;
 +      case 4:
 +        if (ftype == ::apache::thrift::protocol::T_STRUCT) {
 +          xfer += this->ae.read(iprot);
 +          this->__isset.ae = true;
 +        } else {
 +          xfer += iprot->skip(ftype);
 +        }
 +        break;
 +      default:
 +        xfer += iprot->skip(ftype);
 +        break;
 +    }
 +    xfer += iprot->readFieldEnd();
    }
 -  Airavata_getAllUsersInGateway_presult result;
 -  result.success = &_return;
 -  result.read(iprot_);
 -  iprot_->readMessageEnd();
 -  iprot_->getTransport()->readEnd();
  
 -  if (result.__isset.success) {
 -    // _return pointer has now been filled
 -    return;
 -  }
 -  if (result.__isset.ire) {
 -    throw result.ire;
 -  }
 -  if (result.__isset.ace) {
 -    throw result.ace;
 -  }
 -  if (result.__isset.ase) {
 -    throw result.ase;
 -  }
 -  if (result.__isset.ae) {
 -    throw result.ae;
 -  }
 -  throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "getAllUsersInGateway failed: unknown result");
 -}
 +  xfer += iprot->readStructEnd();
  
 -bool AiravataClient::updateGateway(const  ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId, const  ::apache::airavata::model::workspace::Gateway& updatedGateway)
 -{
 -  send_updateGateway(authzToken, gatewayId, updatedGateway);
 -  return recv_updateGateway();
 +  return xfer;
  }
  
 -void AiravataClient::send_updateGateway(const  ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId, const  ::apache::airavata::model::workspace::Gateway& updatedGateway)
 -{
 -  int32_t cseqid = 0;
 -  oprot_->writeMessageBegin("updateGateway", ::apache::thrift::protocol::T_CALL, cseqid);
 +uint32_t Airavata_registerDataProduct_result::write(::apache::thrift::protocol::TProtocol* oprot) const {
  
 -  Airavata_updateGateway_pargs args;
 -  args.authzToken = &authzToken;
 -  args.gatewayId = &gatewayId;
 -  args.updatedGateway = &updatedGateway;
 -  args.write(oprot_);
 -
 -  oprot_->writeMessageEnd();
 -  oprot_->getTransport()->writeEnd();
 -  oprot_->getTransport()->flush();
 -}
 -
 -bool AiravataClient::recv_updateGateway()
 -{
 -
 -  int32_t rseqid = 0;
 -  std::string fname;
 -  ::apache::thrift::protocol::TMessageType mtype;
 +  uint32_t xfer = 0;
  
 -  iprot_->readMessageBegin(fname, mtype, rseqid);
 -  if (mtype == ::apache::thrift::protocol::T_EXCEPTION) {
 -    ::apache::thrift::TApplicationException x;
 -    x.read(iprot_);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -    throw x;
 -  }
 -  if (mtype != ::apache::thrift::protocol::T_REPLY) {
 -    iprot_->skip(::apache::thrift::protocol::T_STRUCT);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -  }
 -  if (fname.compare("updateGateway") != 0) {
 -    iprot_->skip(::apache::thrift::protocol::T_STRUCT);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -  }
 -  bool _return;
 -  Airavata_updateGateway_presult result;
 -  result.success = &_return;
 -  result.read(iprot_);
 -  iprot_->readMessageEnd();
 -  iprot_->getTransport()->readEnd();
 +  xfer += oprot->writeStructBegin("Airavata_registerDataProduct_result");
  
 -  if (result.__isset.success) {
 -    return _return;
 -  }
 -  if (result.__isset.ire) {
 -    throw result.ire;
 -  }
 -  if (result.__isset.ace) {
 -    throw result.ace;
 -  }
 -  if (result.__isset.ase) {
 -    throw result.ase;
 -  }
 -  if (result.__isset.ae) {
 -    throw result.ae;
 +  if (this->__isset.success) {
 +    xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRING, 0);
 +    xfer += oprot->writeString(this->success);
 +    xfer += oprot->writeFieldEnd();
 +  } else if (this->__isset.ire) {
 +    xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1);
 +    xfer += this->ire.write(oprot);
 +    xfer += oprot->writeFieldEnd();
 +  } else if (this->__isset.ace) {
 +    xfer += oprot->writeFieldBegin("ace", ::apache::thrift::protocol::T_STRUCT, 2);
 +    xfer += this->ace.write(oprot);
 +    xfer += oprot->writeFieldEnd();
 +  } else if (this->__isset.ase) {
 +    xfer += oprot->writeFieldBegin("ase", ::apache::thrift::protocol::T_STRUCT, 3);
 +    xfer += this->ase.write(oprot);
 +    xfer += oprot->writeFieldEnd();
 +  } else if (this->__isset.ae) {
 +    xfer += oprot->writeFieldBegin("ae", ::apache::thrift::protocol::T_STRUCT, 4);
 +    xfer += this->ae.write(oprot);
 +    xfer += oprot->writeFieldEnd();
    }
 -  throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "updateGateway failed: unknown result");
 +  xfer += oprot->writeFieldStop();
 +  xfer += oprot->writeStructEnd();
 +  return xfer;
  }
  
 -void AiravataClient::getGateway( ::apache::airavata::model::workspace::Gateway& _return, const  ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId)
 -{
 -  send_getGateway(authzToken, gatewayId);
 -  recv_getGateway(_return);
 +
 +Airavata_registerDataProduct_presult::~Airavata_registerDataProduct_presult() throw() {
  }
  
 -void AiravataClient::send_getGateway(const  ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId)
 -{
 -  int32_t cseqid = 0;
 -  oprot_->writeMessageBegin("getGateway", ::apache::thrift::protocol::T_CALL, cseqid);
  
 -  Airavata_getGateway_pargs args;
 -  args.authzToken = &authzToken;
 -  args.gatewayId = &gatewayId;
 -  args.write(oprot_);
 +uint32_t Airavata_registerDataProduct_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
  
 -  oprot_->writeMessageEnd();
 -  oprot_->getTransport()->writeEnd();
 -  oprot_->getTransport()->flush();
 -}
 +  apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
 +  uint32_t xfer = 0;
 +  std::string fname;
 +  ::apache::thrift::protocol::TType ftype;
 +  int16_t fid;
  
 -void AiravataClient::recv_getGateway( ::apache::airavata::model::workspace::Gateway& _return)
 -{
 +  xfer += iprot->readStructBegin(fname);
  
 -  int32_t rseqid = 0;
 -  std::string fname;
 -  ::apache::thrift::protocol::TMessageType mtype;
 +  using ::apache::thrift::protocol::TProtocolException;
  
 -  iprot_->readMessageBegin(fname, mtype, rseqid);
 -  if (mtype == ::apache::thrift::protocol::T_EXCEPTION) {
 -    ::apache::thrift::TApplicationException x;
 -    x.read(iprot_);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -    throw x;
 -  }
 -  if (mtype != ::apache::thrift::protocol::T_REPLY) {
 -    iprot_->skip(::apache::thrift::protocol::T_STRUCT);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -  }
 -  if (fname.compare("getGateway") != 0) {
 -    iprot_->skip(::apache::thrift::protocol::T_STRUCT);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -  }
 -  Airavata_getGateway_presult result;
 -  result.success = &_return;
 -  result.read(iprot_);
 -  iprot_->readMessageEnd();
 -  iprot_->getTransport()->readEnd();
  
 -  if (result.__isset.success) {
 -    // _return pointer has now been filled
 -    return;
 -  }
 -  if (result.__isset.ire) {
 -    throw result.ire;
 -  }
 -  if (result.__isset.ace) {
 -    throw result.ace;
 -  }
 -  if (result.__isset.ase) {
 -    throw result.ase;
 -  }
 -  if (result.__isset.ae) {
 -    throw result.ae;
 +  while (true)
 +  {
 +    xfer += iprot->readFieldBegin(fname, ftype, fid);
 +    if (ftype == ::apache::thrift::protocol::T_STOP) {
 +      break;
 +    }
 +    switch (fid)
 +    {
 +      case 0:
 +        if (ftype == ::apache::thrift::protocol::T_STRING) {
 +          xfer += iprot->readString((*(this->success)));
 +          this->__isset.success = true;
 +        } else {
 +          xfer += iprot->skip(ftype);
 +        }
 +        break;
 +      case 1:
 +        if (ftype == ::apache::thrift::protocol::T_STRUCT) {
 +          xfer += this->ire.read(iprot);
 +          this->__isset.ire = true;
 +        } else {
 +          xfer += iprot->skip(ftype);
 +        }
 +        break;
 +      case 2:
 +        if (ftype == ::apache::thrift::protocol::T_STRUCT) {
 +          xfer += this->ace.read(iprot);
 +          this->__isset.ace = true;
 +        } else {
 +          xfer += iprot->skip(ftype);
 +        }
 +        break;
 +      case 3:
 +        if (ftype == ::apache::thrift::protocol::T_STRUCT) {
 +          xfer += this->ase.read(iprot);
 +          this->__isset.ase = true;
 +        } else {
 +          xfer += iprot->skip(ftype);
 +        }
 +        break;
 +      case 4:
 +        if (ftype == ::apache::thrift::protocol::T_STRUCT) {
 +          xfer += this->ae.read(iprot);
 +          this->__isset.ae = true;
 +        } else {
 +          xfer += iprot->skip(ftype);
 +        }
 +        break;
 +      default:
 +        xfer += iprot->skip(ftype);
 +        break;
 +    }
 +    xfer += iprot->readFieldEnd();
    }
 -  throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "getGateway failed: unknown result");
 -}
  
 -bool AiravataClient::deleteGateway(const  ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId)
 -{
 -  send_deleteGateway(authzToken, gatewayId);
 -  return recv_deleteGateway();
 -}
 +  xfer += iprot->readStructEnd();
  
 -void AiravataClient::send_deleteGateway(const  ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId)
 -{
 -  int32_t cseqid = 0;
 -  oprot_->writeMessageBegin("deleteGateway", ::apache::thrift::protocol::T_CALL, cseqid);
 +  return xfer;
 +}
  
 -  Airavata_deleteGateway_pargs args;
 -  args.authzToken = &authzToken;
 -  args.gatewayId = &gatewayId;
 -  args.write(oprot_);
  
 -  oprot_->writeMessageEnd();
 -  oprot_->getTransport()->writeEnd();
 -  oprot_->getTransport()->flush();
 +Airavata_getDataProduct_args::~Airavata_getDataProduct_args() throw() {
  }
  
 -bool AiravataClient::recv_deleteGateway()
 -{
  
 -  int32_t rseqid = 0;
 +uint32_t Airavata_getDataProduct_args::read(::apache::thrift::protocol::TProtocol* iprot) {
 +
 +  apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
 +  uint32_t xfer = 0;
    std::string fname;
 -  ::apache::thrift::protocol::TMessageType mtype;
 +  ::apache::thrift::protocol::TType ftype;
 +  int16_t fid;
  
 -  iprot_->readMessageBegin(fname, mtype, rseqid);
 -  if (mtype == ::apache::thrift::protocol::T_EXCEPTION) {
 -    ::apache::thrift::TApplicationException x;
 -    x.read(iprot_);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -    throw x;
 -  }
 -  if (mtype != ::apache::thrift::protocol::T_REPLY) {
 -    iprot_->skip(::apache::thrift::protocol::T_STRUCT);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -  }
 -  if (fname.compare("deleteGateway") != 0) {
 -    iprot_->skip(::apache::thrift::protocol::T_STRUCT);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -  }
 -  bool _return;
 -  Airavata_deleteGateway_presult result;
 -  result.success = &_return;
 -  result.read(iprot_);
 -  iprot_->readMessageEnd();
 -  iprot_->getTransport()->readEnd();
 +  xfer += iprot->readStructBegin(fname);
  
 -  if (result.__isset.success) {
 -    return _return;
 -  }
 -  if (result.__isset.ire) {
 -    throw result.ire;
 -  }
 -  if (result.__isset.ace) {
 -    throw result.ace;
 -  }
 -  if (result.__isset.ase) {
 -    throw result.ase;
 -  }
 -  if (result.__isset.ae) {
 -    throw result.ae;
 -  }
 -  throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "deleteGateway failed: unknown result");
 -}
 +  using ::apache::thrift::protocol::TProtocolException;
  
 -void AiravataClient::getAllGateways(std::vector< ::apache::airavata::model::workspace::Gateway> & _return, const  ::apache::airavata::model::security::AuthzToken& authzToken)
 -{
 -  send_getAllGateways(authzToken);
 -  recv_getAllGateways(_return);
 -}
 +  bool isset_authzToken = false;
 +  bool isset_dataProductUri = false;
  
 -void AiravataClient::send_getAllGateways(const  ::apache::airavata::model::security::AuthzToken& authzToken)
 -{
 -  int32_t cseqid = 0;
 -  oprot_->writeMessageBegin("getAllGateways", ::apache::thrift::protocol::T_CALL, cseqid);
 +  while (true)
 +  {
 +    xfer += iprot->readFieldBegin(fname, ftype, fid);
 +    if (ftype == ::apache::thrift::protocol::T_STOP) {
 +      break;
 +    }
 +    switch (fid)
 +    {
 +      case 1:
 +        if (ftype == ::apache::thrift::protocol::T_STRUCT) {
 +          xfer += this->authzToken.read(iprot);
 +          isset_authzToken = true;
 +        } else {
 +          xfer += iprot->skip(ftype);
 +        }
 +        break;
 +      case 2:
 +        if (ftype == ::apache::thrift::protocol::T_STRING) {
 +          xfer += iprot->readString(this->dataProductUri);
 +          isset_dataProductUri = true;
 +        } else {
 +          xfer += iprot->skip(ftype);
 +        }
 +        break;
 +      default:
 +        xfer += iprot->skip(ftype);
 +        break;
 +    }
 +    xfer += iprot->readFieldEnd();
 +  }
  
 -  Airavata_getAllGateways_pargs args;
 -  args.authzToken = &authzToken;
 -  args.write(oprot_);
 +  xfer += iprot->readStructEnd();
  
 -  oprot_->writeMessageEnd();
 -  oprot_->getTransport()->writeEnd();
 -  oprot_->getTransport()->flush();
 +  if (!isset_authzToken)
 +    throw TProtocolException(TProtocolException::INVALID_DATA);
 +  if (!isset_dataProductUri)
 +    throw TProtocolException(TProtocolException::INVALID_DATA);
 +  return xfer;
  }
  
 -void AiravataClient::recv_getAllGateways(std::vector< ::apache::airavata::model::workspace::Gateway> & _return)
 -{
 +uint32_t Airavata_getDataProduct_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
 +  uint32_t xfer = 0;
 +  apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
 +  xfer += oprot->writeStructBegin("Airavata_getDataProduct_args");
  
 -  int32_t rseqid = 0;
 -  std::string fname;
 -  ::apache::thrift::protocol::TMessageType mtype;
 +  xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1);
 +  xfer += this->authzToken.write(oprot);
 +  xfer += oprot->writeFieldEnd();
  
 -  iprot_->readMessageBegin(fname, mtype, rseqid);
 -  if (mtype == ::apache::thrift::protocol::T_EXCEPTION) {
 -    ::apache::thrift::TApplicationException x;
 -    x.read(iprot_);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -    throw x;
 -  }
 -  if (mtype != ::apache::thrift::protocol::T_REPLY) {
 -    iprot_->skip(::apache::thrift::protocol::T_STRUCT);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -  }
 -  if (fname.compare("getAllGateways") != 0) {
 -    iprot_->skip(::apache::thrift::protocol::T_STRUCT);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -  }
 -  Airavata_getAllGateways_presult result;
 -  result.success = &_return;
 -  result.read(iprot_);
 -  iprot_->readMessageEnd();
 -  iprot_->getTransport()->readEnd();
 +  xfer += oprot->writeFieldBegin("dataProductUri", ::apache::thrift::protocol::T_STRING, 2);
 +  xfer += oprot->writeString(this->dataProductUri);
 +  xfer += oprot->writeFieldEnd();
  
 -  if (result.__isset.success) {
 -    // _return pointer has now been filled
 -    return;
 -  }
 -  if (result.__isset.ire) {
 -    throw result.ire;
 -  }
 -  if (result.__isset.ace) {
 -    throw result.ace;
 -  }
 -  if (result.__isset.ase) {
 -    throw result.ase;
 -  }
 -  if (result.__isset.ae) {
 -    throw result.ae;
 -  }
 -  throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "getAllGateways failed: unknown result");
 +  xfer += oprot->writeFieldStop();
 +  xfer += oprot->writeStructEnd();
 +  return xfer;
  }
  
 -bool AiravataClient::isGatewayExist(const  ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId)
 -{
 -  send_isGatewayExist(authzToken, gatewayId);
 -  return recv_isGatewayExist();
 +
 +Airavata_getDataProduct_pargs::~Airavata_getDataProduct_pargs() throw() {
  }
  
 -void AiravataClient::send_isGatewayExist(const  ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId)
 -{
 -  int32_t cseqid = 0;
 -  oprot_->writeMessageBegin("isGatewayExist", ::apache::thrift::protocol::T_CALL, cseqid);
  
 -  Airavata_isGatewayExist_pargs args;
 -  args.authzToken = &authzToken;
 -  args.gatewayId = &gatewayId;
 -  args.write(oprot_);
 +uint32_t Airavata_getDataProduct_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
 +  uint32_t xfer = 0;
 +  apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
 +  xfer += oprot->writeStructBegin("Airavata_getDataProduct_pargs");
  
 -  oprot_->writeMessageEnd();
 -  oprot_->getTransport()->writeEnd();
 -  oprot_->getTransport()->flush();
 -}
 +  xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1);
 +  xfer += (*(this->authzToken)).write(oprot);
 +  xfer += oprot->writeFieldEnd();
  
 -bool AiravataClient::recv_isGatewayExist()
 -{
 +  xfer += oprot->writeFieldBegin("dataProductUri", ::apache::thrift::protocol::T_STRING, 2);
 +  xfer += oprot->writeString((*(this->dataProductUri)));
 +  xfer += oprot->writeFieldEnd();
  
 -  int32_t rseqid = 0;
 -  std::string fname;
 -  ::apache::thrift::protocol::TMessageType mtype;
 +  xfer += oprot->writeFieldStop();
 +  xfer += oprot->writeStructEnd();
 +  return xfer;
 +}
  
 -  iprot_->readMessageBegin(fname, mtype, rseqid);
 -  if (mtype == ::apache::thrift::protocol::T_EXCEPTION) {
 -    ::apache::thrift::TApplicationException x;
 -    x.read(iprot_);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -    throw x;
 -  }
 -  if (mtype != ::apache::thrift::protocol::T_REPLY) {
 -    iprot_->skip(::apache::thrift::protocol::T_STRUCT);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -  }
 -  if (fname.compare("isGatewayExist") != 0) {
 -    iprot_->skip(::apache::thrift::protocol::T_STRUCT);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -  }
 -  bool _return;
 -  Airavata_isGatewayExist_presult result;
 -  result.success = &_return;
 -  result.read(iprot_);
 -  iprot_->readMessageEnd();
 -  iprot_->getTransport()->readEnd();
  
 -  if (result.__isset.success) {
 -    return _return;
 -  }
 -  if (result.__isset.ire) {
 -    throw result.ire;
 -  }
 -  if (result.__isset.ace) {
 -    throw result.ace;
 -  }
 -  if (result.__isset.ase) {
 -    throw result.ase;
 -  }
 -  if (result.__isset.ae) {
 -    throw result.ae;
 -  }
 -  throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "isGatewayExist failed: unknown result");
 +Airavata_getDataProduct_result::~Airavata_getDataProduct_result() throw() {
  }
  
 -void AiravataClient::createNotification(std::string& _return, const  ::apache::airavata::model::security::AuthzToken& authzToken, const  ::apache::airavata::model::workspace::Notification& notification)
 -{
 -  send_createNotification(authzToken, notification);
 -  recv_createNotification(_return);
 -}
  
 -void AiravataClient::send_createNotification(const  ::apache::airavata::model::security::AuthzToken& authzToken, const  ::apache::airavata::model::workspace::Notification& notification)
 -{
 -  int32_t cseqid = 0;
 -  oprot_->writeMessageBegin("createNotification", ::apache::thrift::protocol::T_CALL, cseqid);
 +uint32_t Airavata_getDataProduct_result::read(::apache::thrift::protocol::TProtocol* iprot) {
  
 -  Airavata_createNotification_pargs args;
 -  args.authzToken = &authzToken;
 -  args.notification = &notification;
 -  args.write(oprot_);
 +  apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
 +  uint32_t xfer = 0;
 +  std::string fname;
 +  ::apache::thrift::protocol::TType ftype;
 +  int16_t fid;
  
 -  oprot_->writeMessageEnd();
 -  oprot_->getTransport()->writeEnd();
 -  oprot_->getTransport()->flush();
 -}
 +  xfer += iprot->readStructBegin(fname);
  
 -void AiravataClient::recv_createNotification(std::string& _return)
 -{
 +  using ::apache::thrift::protocol::TProtocolException;
  
 -  int32_t rseqid = 0;
 -  std::string fname;
 -  ::apache::thrift::protocol::TMessageType mtype;
  
 -  iprot_->readMessageBegin(fname, mtype, rseqid);
 -  if (mtype == ::apache::thrift::protocol::T_EXCEPTION) {
 -    ::apache::thrift::TApplicationException x;
 -    x.read(iprot_);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -    throw x;
 -  }
 -  if (mtype != ::apache::thrift::protocol::T_REPLY) {
 -    iprot_->skip(::apache::thrift::protocol::T_STRUCT);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -  }
 -  if (fname.compare("createNotification") != 0) {
 -    iprot_->skip(::apache::thrift::protocol::T_STRUCT);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -  }
 -  Airavata_createNotification_presult result;
 -  result.success = &_return;
 -  result.read(iprot_);
 -  iprot_->readMessageEnd();
 -  iprot_->getTransport()->readEnd();
 -
 -  if (result.__isset.success) {
 -    // _return pointer has now been filled
 -    return;
 -  }
 -  if (result.__isset.ire) {
 -    throw result.ire;
 -  }
 -  if (result.__isset.ace) {
 -    throw result.ace;
 -  }
 -  if (result.__isset.ase) {
 -    throw result.ase;
 -  }
 -  if (result.__isset.ae) {
 -    throw result.ae;
 +  while (true)
 +  {
 +    xfer += iprot->readFieldBegin(fname, ftype, fid);
 +    if (ftype == ::apache::thrift::protocol::T_STOP) {
 +      break;
 +    }
 +    switch (fid)
 +    {
 +      case 0:
 +        if (ftype == ::apache::thrift::protocol::T_STRUCT) {
 +          xfer += this->success.read(iprot);
 +          this->__isset.success = true;
 +        } else {
 +          xfer += iprot->skip(ftype);
 +        }
 +        break;
 +      case 1:
 +        if (ftype == ::apache::thrift::protocol::T_STRUCT) {
 +          xfer += this->ire.read(iprot);
 +          this->__isset.ire = true;
 +        } else {
 +          xfer += iprot->skip(ftype);
 +        }
 +        break;
 +      case 2:
 +        if (ftype == ::apache::thrift::protocol::T_STRUCT) {
 +          xfer += this->ace.read(iprot);
 +          this->__isset.ace = true;
 +        } else {
 +          xfer += iprot->skip(ftype);
 +        }
 +        break;
 +      case 3:
 +        if (ftype == ::apache::thrift::protocol::T_STRUCT) {
 +          xfer += this->ase.read(iprot);
 +          this->__isset.ase = true;
 +        } else {
 +          xfer += iprot->skip(ftype);
 +        }
 +        break;
 +      case 4:
 +        if (ftype == ::apache::thrift::protocol::T_STRUCT) {
 +          xfer += this->ae.read(iprot);
 +          this->__isset.ae = true;
 +        } else {
 +          xfer += iprot->skip(ftype);
 +        }
 +        break;
 +      default:
 +        xfer += iprot->skip(ftype);
 +        break;
 +    }
 +    xfer += iprot->readFieldEnd();
    }
 -  throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "createNotification failed: unknown result");
 -}
 -
 -bool AiravataClient::updateNotification(const  ::apache::airavata::model::security::AuthzToken& authzToken, const  ::apache::airavata::model::workspace::Notification& notification)
 -{
 -  send_updateNotification(authzToken, notification);
 -  return recv_updateNotification();
 -}
 -
 -void AiravataClient::send_updateNotification(const  ::apache::airavata::model::security::AuthzToken& authzToken, const  ::apache::airavata::model::workspace::Notification& notification)
 -{
 -  int32_t cseqid = 0;
 -  oprot_->writeMessageBegin("updateNotification", ::apache::thrift::protocol::T_CALL, cseqid);
  
 -  Airavata_updateNotification_pargs args;
 -  args.authzToken = &authzToken;
 -  args.notification = &notification;
 -  args.write(oprot_);
 +  xfer += iprot->readStructEnd();
  
 -  oprot_->writeMessageEnd();
 -  oprot_->getTransport()->writeEnd();
 -  oprot_->getTransport()->flush();
 +  return xfer;
  }
  
 -bool AiravataClient::recv_updateNotification()
 -{
 +uint32_t Airavata_getDataProduct_result::write(::apache::thrift::protocol::TProtocol* oprot) const {
  
 -  int32_t rseqid = 0;
 -  std::string fname;
 -  ::apache::thrift::protocol::TMessageType mtype;
 +  uint32_t xfer = 0;
  
 -  iprot_->readMessageBegin(fname, mtype, rseqid);
 -  if (mtype == ::apache::thrift::protocol::T_EXCEPTION) {
 -    ::apache::thrift::TApplicationException x;
 -    x.read(iprot_);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -    throw x;
 -  }
 -  if (mtype != ::apache::thrift::protocol::T_REPLY) {
 -    iprot_->skip(::apache::thrift::protocol::T_STRUCT);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -  }
 -  if (fname.compare("updateNotification") != 0) {
 -    iprot_->skip(::apache::thrift::protocol::T_STRUCT);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -  }
 -  bool _return;
 -  Airavata_updateNotification_presult result;
 -  result.success = &_return;
 -  result.read(iprot_);
 -  iprot_->readMessageEnd();
 -  iprot_->getTransport()->readEnd();
 +  xfer += oprot->writeStructBegin("Airavata_getDataProduct_result");
  
 -  if (result.__isset.success) {
 -    return _return;
 -  }
 -  if (result.__isset.ire) {
 -    throw result.ire;
 -  }
 -  if (result.__isset.ace) {
 -    throw result.ace;
 -  }
 -  if (result.__isset.ase) {
 -    throw result.ase;
 -  }
 -  if (result.__isset.ae) {
 -    throw result.ae;
 +  if (this->__isset.success) {
 +    xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRUCT, 0);
 +    xfer += this->success.write(oprot);
 +    xfer += oprot->writeFieldEnd();
 +  } else if (this->__isset.ire) {
 +    xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1);
 +    xfer += this->ire.write(oprot);
 +    xfer += oprot->writeFieldEnd();
 +  } else if (this->__isset.ace) {
 +    xfer += oprot->writeFieldBegin("ace", ::apache::thrift::protocol::T_STRUCT, 2);
 +    xfer += this->ace.write(oprot);
 +    xfer += oprot->writeFieldEnd();
 +  } else if (this->__isset.ase) {
 +    xfer += oprot->writeFieldBegin("ase", ::apache::thrift::protocol::T_STRUCT, 3);
 +    xfer += this->ase.write(oprot);
 +    xfer += oprot->writeFieldEnd();
 +  } else if (this->__isset.ae) {
 +    xfer += oprot->writeFieldBegin("ae", ::apache::thrift::protocol::T_STRUCT, 4);
 +    xfer += this->ae.write(oprot);
 +    xfer += oprot->writeFieldEnd();
    }
 -  throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "updateNotification failed: unknown result");
 +  xfer += oprot->writeFieldStop();
 +  xfer += oprot->writeStructEnd();
 +  return xfer;
  }
  
 -bool AiravataClient::deleteNotification(const  ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId, const std::string& notificationId)
 -{
 -  send_deleteNotification(authzToken, gatewayId, notificationId);
 -  return recv_deleteNotification();
 +
 +Airavata_getDataProduct_presult::~Airavata_getDataProduct_presult() throw() {
  }
  
 -void AiravataClient::send_deleteNotification(const  ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId, const std::string& notificationId)
 -{
 -  int32_t cseqid = 0;
 -  oprot_->writeMessageBegin("deleteNotification", ::apache::thrift::protocol::T_CALL, cseqid);
  
 -  Airavata_deleteNotification_pargs args;
 -  args.authzToken = &authzToken;
 -  args.gatewayId = &gatewayId;
 -  args.notificationId = &notificationId;
 -  args.write(oprot_);
 +uint32_t Airavata_getDataProduct_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
  
 -  oprot_->writeMessageEnd();
 -  oprot_->getTransport()->writeEnd();
 -  oprot_->getTransport()->flush();
 -}
 +  apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
 +  uint32_t xfer = 0;
 +  std::string fname;
 +  ::apache::thrift::protocol::TType ftype;
 +  int16_t fid;
  
 -bool AiravataClient::recv_deleteNotification()
 -{
 +  xfer += iprot->readStructBegin(fname);
  
 -  int32_t rseqid = 0;
 -  std::string fname;
 -  ::apache::thrift::protocol::TMessageType mtype;
 +  using ::apache::thrift::protocol::TProtocolException;
  
 -  iprot_->readMessageBegin(fname, mtype, rseqid);
 -  if (mtype == ::apache::thrift::protocol::T_EXCEPTION) {
 -    ::apache::thrift::TApplicationException x;
 -    x.read(iprot_);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -    throw x;
 -  }
 -  if (mtype != ::apache::thrift::protocol::T_REPLY) {
 -    iprot_->skip(::apache::thrift::protocol::T_STRUCT);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -  }
 -  if (fname.compare("deleteNotification") != 0) {
 -    iprot_->skip(::apache::thrift::protocol::T_STRUCT);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -  }
 -  bool _return;
 -  Airavata_deleteNotification_presult result;
 -  result.success = &_return;
 -  result.read(iprot_);
 -  iprot_->readMessageEnd();
 -  iprot_->getTransport()->readEnd();
  
 -  if (result.__isset.success) {
 -    return _return;
 -  }
 -  if (result.__isset.ire) {
 -    throw result.ire;
 -  }
 -  if (result.__isset.ace) {
 -    throw result.ace;
 -  }
 -  if (result.__isset.ase) {
 -    throw result.ase;
 -  }
 -  if (result.__isset.ae) {
 -    throw result.ae;
 +  while (true)
 +  {
 +    xfer += iprot->readFieldBegin(fname, ftype, fid);
 +    if (ftype == ::apache::thrift::protocol::T_STOP) {
 +      break;
 +    }
 +    switch (fid)
 +    {
 +      case 0:
 +        if (ftype == ::apache::thrift::protocol::T_STRUCT) {
 +          xfer += (*(this->success)).read(iprot);
 +          this->__isset.success = true;
 +        } else {
 +          xfer += iprot->skip(ftype);
 +        }
 +        break;
 +      case 1:
 +        if (ftype == ::apache::thrift::protocol::T_STRUCT) {
 +          xfer += this->ire.read(iprot);
 +          this->__isset.ire = true;
 +        } else {
 +          xfer += iprot->skip(ftype);
 +        }
 +        break;
 +      case 2:
 +        if (ftype == ::apache::thrift::protocol::T_STRUCT) {
 +          xfer += this->ace.read(iprot);
 +          this->__isset.ace = true;
 +        } else {
 +          xfer += iprot->skip(ftype);
 +        }
 +        break;
 +      case 3:
 +        if (ftype == ::apache::thrift::protocol::T_STRUCT) {
 +          xfer += this->ase.read(iprot);
 +          this->__isset.ase = true;
 +        } else {
 +          xfer += iprot->skip(ftype);
 +        }
 +        break;
 +      case 4:
 +        if (ftype == ::apache::thrift::protocol::T_STRUCT) {
 +          xfer += this->ae.read(iprot);
 +          this->__isset.ae = true;
 +        } else {
 +          xfer += iprot->skip(ftype);
 +        }
 +        break;
 +      default:
 +        xfer += iprot->skip(ftype);
 +        break;
 +    }
 +    xfer += iprot->readFieldEnd();
    }
 -  throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "deleteNotification failed: unknown result");
 -}
  
 -void AiravataClient::getNotification( ::apache::airavata::model::workspace::Notification& _return, const  ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId, const std::string& notificationId)
 -{
 -  send_getNotification(authzToken, gatewayId, notificationId);
 -  recv_getNotification(_return);
 -}
 +  xfer += iprot->readStructEnd();
  
 -void AiravataClient::send_getNotification(const  ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId, const std::string& notificationId)
 -{
 -  int32_t cseqid = 0;
 -  oprot_->writeMessageBegin("getNotification", ::apache::thrift::protocol::T_CALL, cseqid);
 +  return xfer;
 +}
  
 -  Airavata_getNotification_pargs args;
 -  args.authzToken = &authzToken;
 -  args.gatewayId = &gatewayId;
 -  args.notificationId = &notificationId;
 -  args.write(oprot_);
  
 -  oprot_->writeMessageEnd();
 -  oprot_->getTransport()->writeEnd();
 -  oprot_->getTransport()->flush();
 +Airavata_registerReplicaLocation_args::~Airavata_registerReplicaLocation_args() throw() {
  }
  
 -void AiravataClient::recv_getNotification( ::apache::airavata::model::workspace::Notification& _return)
 -{
  
 -  int32_t rseqid = 0;
 +uint32_t Airavata_registerReplicaLocation_args::read(::apache::thrift::protocol::TProtocol* iprot) {
 +
 +  apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
 +  uint32_t xfer = 0;
    std::string fname;
 -  ::apache::thrift::protocol::TMessageType mtype;
 +  ::apache::thrift::protocol::TType ftype;
 +  int16_t fid;
  
 -  iprot_->readMessageBegin(fname, mtype, rseqid);
 -  if (mtype == ::apache::thrift::protocol::T_EXCEPTION) {
 -    ::apache::thrift::TApplicationException x;
 -    x.read(iprot_);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -    throw x;
 -  }
 -  if (mtype != ::apache::thrift::protocol::T_REPLY) {
 -    iprot_->skip(::apache::thrift::protocol::T_STRUCT);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -  }
 -  if (fname.compare("getNotification") != 0) {
 -    iprot_->skip(::apache::thrift::protocol::T_STRUCT);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -  }
 -  Airavata_getNotification_presult result;
 -  result.success = &_return;
 -  result.read(iprot_);
 -  iprot_->readMessageEnd();
 -  iprot_->getTransport()->readEnd();
 +  xfer += iprot->readStructBegin(fname);
  
 -  if (result.__isset.success) {
 -    // _return pointer has now been filled
 -    return;
 -  }
 -  if (result.__isset.ire) {
 -    throw result.ire;
 -  }
 -  if (result.__isset.ace) {
 -    throw result.ace;
 -  }
 -  if (result.__isset.ase) {
 -    throw result.ase;
 -  }
 -  if (result.__isset.ae) {
 -    throw result.ae;
 -  }
 -  throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "getNotification failed: unknown result");
 -}
 +  using ::apache::thrift::protocol::TProtocolException;
  
 -void AiravataClient::getAllNotifications(std::vector< ::apache::airavata::model::workspace::Notification> & _return, const  ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId)
 -{
 -  send_getAllNotifications(authzToken, gatewayId);
 -  recv_getAllNotifications(_return);
 -}
 +  bool isset_authzToken = false;
 +  bool isset_replicaLocationModel = false;
  
 -void AiravataClient::send_getAllNotifications(const  ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId)
 -{
 -  int32_t cseqid = 0;
 -  oprot_->writeMessageBegin("getAllNotifications", ::apache::thrift::protocol::T_CALL, cseqid);
 +  while (true)
 +  {
 +    xfer += iprot->readFieldBegin(fname, ftype, fid);
 +    if (ftype == ::apache::thrift::protocol::T_STOP) {
 +      break;
 +    }
 +    switch (fid)
 +    {
 +      case 1:
 +        if (ftype == ::apache::thrift::protocol::T_STRUCT) {
 +          xfer += this->authzToken.read(iprot);
 +          isset_authzToken = true;
 +        } else {
 +          xfer += iprot->skip(ftype);
 +        }
 +        break;
 +      case 2:
 +        if (ftype == ::apache::thrift::protocol::T_STRUCT) {
 +          xfer += this->replicaLocationModel.read(iprot);
 +          isset_replicaLocationModel = true;
 +        } else {
 +          xfer += iprot->skip(ftype);
 +        }
 +        break;
 +      default:
 +        xfer += iprot->skip(ftype);
 +        break;
 +    }
 +    xfer += iprot->readFieldEnd();
 +  }
  
 -  Airavata_getAllNotifications_pargs args;
 -  args.authzToken = &authzToken;
 -  args.gatewayId = &gatewayId;
 -  args.write(oprot_);
 +  xfer += iprot->readStructEnd();
  
 -  oprot_->writeMessageEnd();
 -  oprot_->getTransport()->writeEnd();
 -  oprot_->getTransport()->flush();
 +  if (!isset_authzToken)
 +    throw TProtocolException(TProtocolException::INVALID_DATA);
 +  if (!isset_replicaLocationModel)
 +    throw TProtocolException(TProtocolException::INVALID_DATA);
 +  return xfer;
  }
  
 -void AiravataClient::recv_getAllNotifications(std::vector< ::apache::airavata::model::workspace::Notification> & _return)
 -{
 +uint32_t Airavata_registerReplicaLocation_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
 +  uint32_t xfer = 0;
 +  apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
 +  xfer += oprot->writeStructBegin("Airavata_registerReplicaLocation_args");
  
 -  int32_t rseqid = 0;
 -  std::string fname;
 -  ::apache::thrift::protocol::TMessageType mtype;
 +  xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1);
 +  xfer += this->authzToken.write(oprot);
 +  xfer += oprot->writeFieldEnd();
  
 -  iprot_->readMessageBegin(fname, mtype, rseqid);
 -  if (mtype == ::apache::thrift::protocol::T_EXCEPTION) {
 -    ::apache::thrift::TApplicationException x;
 -    x.read(iprot_);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -    throw x;
 -  }
 -  if (mtype != ::apache::thrift::protocol::T_REPLY) {
 -    iprot_->skip(::apache::thrift::protocol::T_STRUCT);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -  }
 -  if (fname.compare("getAllNotifications") != 0) {
 -    iprot_->skip(::apache::thrift::protocol::T_STRUCT);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -  }
 -  Airavata_getAllNotifications_presult result;
 -  result.success = &_return;
 -  result.read(iprot_);
 -  iprot_->readMessageEnd();
 -  iprot_->getTransport()->readEnd();
 +  xfer += oprot->writeFieldBegin("replicaLocationModel", ::apache::thrift::protocol::T_STRUCT, 2);
 +  xfer += this->replicaLocationModel.write(oprot);
 +  xfer += oprot->writeFieldEnd();
  
 -  if (result.__isset.success) {
 -    // _return pointer has now been filled
 -    return;
 -  }
 -  if (result.__isset.ire) {
 -    throw result.ire;
 -  }
 -  if (result.__isset.ace) {
 -    throw result.ace;
 -  }
 -  if (result.__isset.ase) {
 -    throw result.ase;
 -  }
 -  if (result.__isset.ae) {
 -    throw result.ae;
 -  }
 -  throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "getAllNotifications failed: unknown result");
 +  xfer += oprot->writeFieldStop();
 +  xfer += oprot->writeStructEnd();
 +  return xfer;
  }
  
 -void AiravataClient::generateAndRegisterSSHKeys(std::string& _return, const  ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId, const std::string& userName)
 -{
 -  send_generateAndRegisterSSHKeys(authzToken, gatewayId, userName);
 -  recv_generateAndRegisterSSHKeys(_return);
 +
 +Airavata_registerReplicaLocation_pargs::~Airavata_registerReplicaLocation_pargs() throw() {
  }
  
 -void AiravataClient::send_generateAndRegisterSSHKeys(const  ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId, const std::string& userName)
 -{
 -  int32_t cseqid = 0;
 -  oprot_->writeMessageBegin("generateAndRegisterSSHKeys", ::apache::thrift::protocol::T_CALL, cseqid);
  
 -  Airavata_generateAndRegisterSSHKeys_pargs args;
 -  args.authzToken = &authzToken;
 -  args.gatewayId = &gatewayId;
 -  args.userName = &userName;
 -  args.write(oprot_);
 +uint32_t Airavata_registerReplicaLocation_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
 +  uint32_t xfer = 0;
 +  apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
 +  xfer += oprot->writeStructBegin("Airavata_registerReplicaLocation_pargs");
  
 -  oprot_->writeMessageEnd();
 -  oprot_->getTransport()->writeEnd();
 -  oprot_->getTransport()->flush();
 -}
 +  xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1);
 +  xfer += (*(this->authzToken)).write(oprot);
 +  xfer += oprot->writeFieldEnd();
  
 -void AiravataClient::recv_generateAndRegisterSSHKeys(std::string& _return)
 -{
 +  xfer += oprot->writeFieldBegin("replicaLocationModel", ::apache::thrift::protocol::T_STRUCT, 2);
 +  xfer += (*(this->replicaLocationModel)).write(oprot);
 +  xfer += oprot->writeFieldEnd();
  
 -  int32_t rseqid = 0;
 -  std::string fname;
 -  ::apache::thrift::protocol::TMessageType mtype;
 +  xfer += oprot->writeFieldStop();
 +  xfer += oprot->writeStructEnd();
 +  return xfer;
 +}
  
 -  iprot_->readMessageBegin(fname, mtype, rseqid);
 -  if (mtype == ::apache::thrift::protocol::T_EXCEPTION) {
 -    ::apache::thrift::TApplicationException x;
 -    x.read(iprot_);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -    throw x;
 -  }
 -  if (mtype != ::apache::thrift::protocol::T_REPLY) {
 -    iprot_->skip(::apache::thrift::protocol::T_STRUCT);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -  }
 -  if (fname.compare("generateAndRegisterSSHKeys") != 0) {
 -    iprot_->skip(::apache::thrift::protocol::T_STRUCT);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -  }
 -  Airavata_generateAndRegisterSSHKeys_presult result;
 -  result.success = &_return;
 -  result.read(iprot_);
 -  iprot_->readMessageEnd();
 -  iprot_->getTransport()->readEnd();
  
 -  if (result.__isset.success) {
 -    // _return pointer has now been filled
 -    return;
 -  }
 -  if (result.__isset.ire) {
 -    throw result.ire;
 -  }
 -  if (result.__isset.ace) {
 -    throw result.ace;
 -  }
 -  if (result.__isset.ase) {
 -    throw result.ase;
 -  }
 -  throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "generateAndRegisterSSHKeys failed: unknown result");
 +Airavata_registerReplicaLocation_result::~Airavata_registerReplicaLocation_result() throw() {
  }
  
 -void AiravataClient::registerPwdCredential(std::string& _return, const  ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId, const std::string& portalUserName, const std::string& loginUserName, const std::string& password, const std::string& description)
 -{
 -  send_registerPwdCredential(authzToken, gatewayId, portalUserName, loginUserName, password, description);
 -  recv_registerPwdCredential(_return);
 -}
  
 -void AiravataClient::send_registerPwdCredential(const  ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId, const std::string& portalUserName, const std::string& loginUserName, const std::string& password, const std::string& description)
 -{
 -  int32_t cseqid = 0;
 -  oprot_->writeMessageBegin("registerPwdCredential", ::apache::thrift::protocol::T_CALL, cseqid);
 +uint32_t Airavata_registerReplicaLocation_result::read(::apache::thrift::protocol::TProtocol* iprot) {
  
 -  Airavata_registerPwdCredential_pargs args;
 -  args.authzToken = &authzToken;
 -  args.gatewayId = &gatewayId;
 -  args.portalUserName = &portalUserName;
 -  args.loginUserName = &loginUserName;
 -  args.password = &password;
 -  args.description = &description;
 -  args.write(oprot_);
 +  apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
 +  uint32_t xfer = 0;
 +  std::string fname;
 +  ::apache::thrift::protocol::TType ftype;
 +  int16_t fid;
  
 -  oprot_->writeMessageEnd();
 -  oprot_->getTransport()->writeEnd();
 -  oprot_->getTransport()->flush();
 -}
 +  xfer += iprot->readStructBegin(fname);
  
 -void AiravataClient::recv_registerPwdCredential(std::string& _return)
 -{
 +  using ::apache::thrift::protocol::TProtocolException;
  
 -  int32_t rseqid = 0;
 -  std::string fname;
 -  ::apache::thrift::protocol::TMessageType mtype;
  
 -  iprot_->readMessageBegin(fname, mtype, rseqid);
 -  if (mtype == ::apache::thrift::protocol::T_EXCEPTION) {
 -    ::apache::thrift::TApplicationException x;
 -    x.read(iprot_);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -    throw x;
 -  }
 -  if (mtype != ::apache::thrift::protocol::T_REPLY) {
 -    iprot_->skip(::apache::thrift::protocol::T_STRUCT);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -  }
 -  if (fname.compare("registerPwdCredential") != 0) {
 -    iprot_->skip(::apache::thrift::protocol::T_STRUCT);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 +  while (true)
 +  {
 +    xfer += iprot->readFieldBegin(fname, ftype, fid);
 +    if (ftype == ::apache::thrift::protocol::T_STOP) {
 +      break;
 +    }
 +    switch (fid)
 +    {
 +      case 0:
 +        if (ftype == ::apache::thrift::protocol::T_STRING) {
 +          xfer += iprot->readString(this->success);
 +          this->__isset.success = true;
 +        } else {
 +          xfer += iprot->skip(ftype);
 +        }
 +        break;
 +      case 1:
 +        if (ftype == ::apache::thrift::protocol::T_STRUCT) {
 +          xfer += this->ire.read(iprot);
 +          this->__isset.ire = true;
 +        } else {
 +          xfer += iprot->skip(ftype);
 +        }
 +        break;
 +      case 2:
 +        if (ftype == ::apache::thrift::protocol::T_STRUCT) {
 +          xfer += this->ace.read(iprot);
 +          this->__isset.ace = true;
 +        } else {
 +          xfer += iprot->skip(ftype);
 +        }
 +        break;
 +      case 3:
 +        if (ftype == ::apache::thrift::protocol::T_STRUCT) {
 +          xfer += this->ase.read(iprot);
 +          this->__isset.ase = true;
 +        } else {
 +          xfer += iprot->skip(ftype);
 +        }
 +        break;
 +      case 4:
 +        if (ftype == ::apache::thrift::protocol::T_STRUCT) {
 +          xfer += this->ae.read(iprot);
 +          this->__isset.ae = true;
 +        } else {
 +          xfer += iprot->skip(ftype);
 +        }
 +        break;
 +      default:
 +        xfer += iprot->skip(ftype);
 +        break;
 +    }
 +    xfer += iprot->readFieldEnd();
    }
 -  Airavata_registerPwdCredential_presult result;
 -  result.success = &_return;
 -  result.read(iprot_);
 -  iprot_->readMessageEnd();
 -  iprot_->getTransport()->readEnd();
  
 -  if (result.__isset.success) {
 -    // _return pointer has now been filled
 -    return;
 -  }
 -  if (result.__isset.ire) {
 -    throw result.ire;
 -  }
 -  if (result.__isset.ace) {
 -    throw result.ace;
 -  }
 -  if (result.__isset.ase) {
 -    throw result.ase;
 -  }
 -  throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "registerPwdCredential failed: unknown result");
 -}
 +  xfer += iprot->readStructEnd();
  
 -void AiravataClient::getSSHPubKey(std::string& _return, const  ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& airavataCredStoreToken, const std::string& gatewayId)
 -{
 -  send_getSSHPubKey(authzToken, airavataCredStoreToken, gatewayId);
 -  recv_getSSHPubKey(_return);
 +  return xfer;
  }
  
 -void AiravataClient::send_getSSHPubKey(const  ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& airavataCredStoreToken, const std::string& gatewayId)
 -{
 -  int32_t cseqid = 0;
 -  oprot_->writeMessageBegin("getSSHPubKey", ::apache::thrift::protocol::T_CALL, cseqid);
 +uint32_t Airavata_registerReplicaLocation_result::write(::apache::thrift::protocol::TProtocol* oprot) const {
  
 -  Airavata_getSSHPubKey_pargs args;
 -  args.authzToken = &authzToken;
 -  args.airavataCredStoreToken = &airavataCredStoreToken;
 -  args.gatewayId = &gatewayId;
 -  args.write(oprot_);
 +  uint32_t xfer = 0;
  
 -  oprot_->writeMessageEnd();
 -  oprot_->getTransport()->writeEnd();
 -  oprot_->getTransport()->flush();
 +  xfer += oprot->writeStructBegin("Airavata_registerReplicaLocation_result");
 +
 +  if (this->__isset.success) {
 +    xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRING, 0);
 +    xfer += oprot->writeString(this->success);
 +    xfer += oprot->writeFieldEnd();
 +  } else if (this->__isset.ire) {
 +    xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1);
 +    xfer += this->ire.write(oprot);
 +    xfer += oprot->writeFieldEnd();
 +  } else if (this->__isset.ace) {
 +    xfer += oprot->writeFieldBegin("ace", ::apache::thrift::protocol::T_STRUCT, 2);
 +    xfer += this->ace.write(oprot);
 +    xfer += oprot->writeFieldEnd();
 +  } else if (this->__isset.ase) {
 +    xfer += oprot->writeFieldBegin("ase", ::apache::thrift::protocol::T_STRUCT, 3);
 +    xfer += this->ase.write(oprot);
 +    xfer += oprot->writeFieldEnd();
 +  } else if (this->__isset.ae) {
 +    xfer += oprot->writeFieldBegin("ae", ::apache::thrift::protocol::T_STRUCT, 4);
 +    xfer += this->ae.write(oprot);
 +    xfer += oprot->writeFieldEnd();
 +  }
 +  xfer += oprot->writeFieldStop();
 +  xfer += oprot->writeStructEnd();
 +  return xfer;
  }
  
 -void AiravataClient::recv_getSSHPubKey(std::string& _return)
 -{
  
 -  int32_t rseqid = 0;
 +Airavata_registerReplicaLocation_presult::~Airavata_registerReplicaLocation_presult() throw() {
 +}
 +
 +
 +uint32_t Airavata_registerReplicaLocation_presult::read(::apache::thrift::protocol::TProtocol* iprot) {
 +
 +  apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
 +  uint32_t xfer = 0;
    std::string fname;
 -  ::apache::thrift::protocol::TMessageType mtype;
 +  ::apache::thrift::protocol::TType ftype;
 +  int16_t fid;
  
 -  iprot_->readMessageBegin(fname, mtype, rseqid);
 -  if (mtype == ::apache::thrift::protocol::T_EXCEPTION) {
 -    ::apache::thrift::TApplicationException x;
 -    x.read(iprot_);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -    throw x;
 -  }
 -  if (mtype != ::apache::thrift::protocol::T_REPLY) {
 -    iprot_->skip(::apache::thrift::protocol::T_STRUCT);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -  }
 -  if (fname.compare("getSSHPubKey") != 0) {
 -    iprot_->skip(::apache::thrift::protocol::T_STRUCT);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -  }
 -  Airavata_getSSHPubKey_presult result;
 -  result.success = &_return;
 -  result.read(iprot_);
 -  iprot_->readMessageEnd();
 -  iprot_->getTransport()->readEnd();
 +  xfer += iprot->readStructBegin(fname);
  
 -  if (result.__isset.success) {
 -    // _return pointer has now been filled
 -    return;
 -  }
 -  if (result.__isset.ire) {
 -    throw result.ire;
 -  }
 -  if (result.__isset.ace) {
 -    throw result.ace;
 -  }
 -  if (result.__isset.ase) {
 -    throw result.ase;
 +  using ::apache::thrift::protocol::TProtocolException;
 +
 +
 +  while (true)
 +  {
 +    xfer += iprot->readFieldBegin(fname, ftype, fid);
 +    if (ftype == ::apache::thrift::protocol::T_STOP) {
 +      break;
 +    }
 +    switch (fid)
 +    {
 +      case 0:
 +        if (ftype == ::apache::thrift::protocol::T_STRING) {
 +          xfer += iprot->readString((*(this->success)));
 +          this->__isset.success = true;
 +        } else {
 +          xfer += iprot->skip(ftype);
 +        }
 +        break;
 +      case 1:
 +        if (ftype == ::apache::thrift::protocol::T_STRUCT) {
 +          xfer += this->ire.read(iprot);
 +          this->__isset.ire = true;
 +        } else {
 +          xfer += iprot->skip(ftype);
 +        }
 +        break;
 +      case 2:
 +        if (ftype == ::apache::thrift::protocol::T_STRUCT) {
 +          xfer += this->ace.read(iprot);
 +          this->__isset.ace = true;
 +        } else {
 +          xfer += iprot->skip(ftype);
 +        }
 +        break;
 +      case 3:
 +        if (ftype == ::apache::thrift::protocol::T_STRUCT) {
 +          xfer += this->ase.read(iprot);
 +          this->__isset.ase = true;
 +        } else {
 +          xfer += iprot->skip(ftype);
 +        }
 +        break;
 +      case 4:
 +        if (ftype == ::apache::thrift::protocol::T_STRUCT) {
 +          xfer += this->ae.read(iprot);
 +          this->__isset.ae = true;
 +        } else {
 +          xfer += iprot->skip(ftype);
 +        }
 +        break;
 +      default:
 +        xfer += iprot->skip(ftype);
 +        break;
 +    }
 +    xfer += iprot->readFieldEnd();
    }
 -  throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "getSSHPubKey failed: unknown result");
 -}
  
 -void AiravataClient::getAllGatewaySSHPubKeys(std::map<std::string, std::string> & _return, const  ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId)
 -{
 -  send_getAllGatewaySSHPubKeys(authzToken, gatewayId);
 -  recv_getAllGatewaySSHPubKeys(_return);
 -}
 +  xfer += iprot->readStructEnd();
  
 -void AiravataClient::send_getAllGatewaySSHPubKeys(const  ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId)
 -{
 -  int32_t cseqid = 0;
 -  oprot_->writeMessageBegin("getAllGatewaySSHPubKeys", ::apache::thrift::protocol::T_CALL, cseqid);
 +  return xfer;
 +}
  
 -  Airavata_getAllGatewaySSHPubKeys_pargs args;
 -  args.authzToken = &authzToken;
 -  args.gatewayId = &gatewayId;
 -  args.write(oprot_);
  
 -  oprot_->writeMessageEnd();
 -  oprot_->getTransport()->writeEnd();
 -  oprot_->getTransport()->flush();
 +Airavata_getParentDataProduct_args::~Airavata_getParentDataProduct_args() throw() {
  }
  
 -void AiravataClient::recv_getAllGatewaySSHPubKeys(std::map<std::string, std::string> & _return)
 -{
  
 -  int32_t rseqid = 0;
 +uint32_t Airavata_getParentDataProduct_args::read(::apache::thrift::protocol::TProtocol* iprot) {
 +
 +  apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
 +  uint32_t xfer = 0;
    std::string fname;
 -  ::apache::thrift::protocol::TMessageType mtype;
 +  ::apache::thrift::protocol::TType ftype;
 +  int16_t fid;
  
 -  iprot_->readMessageBegin(fname, mtype, rseqid);
 -  if (mtype == ::apache::thrift::protocol::T_EXCEPTION) {
 -    ::apache::thrift::TApplicationException x;
 -    x.read(iprot_);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -    throw x;
 -  }
 -  if (mtype != ::apache::thrift::protocol::T_REPLY) {
 -    iprot_->skip(::apache::thrift::protocol::T_STRUCT);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -  }
 -  if (fname.compare("getAllGatewaySSHPubKeys") != 0) {
 -    iprot_->skip(::apache::thrift::protocol::T_STRUCT);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -  }
 -  Airavata_getAllGatewaySSHPubKeys_presult result;
 -  result.success = &_return;
 -  result.read(iprot_);
 -  iprot_->readMessageEnd();
 -  iprot_->getTransport()->readEnd();
 +  xfer += iprot->readStructBegin(fname);
  
 -  if (result.__isset.success) {
 -    // _return pointer has now been filled
 -    return;
 -  }
 -  if (result.__isset.ire) {
 -    throw result.ire;
 -  }
 -  if (result.__isset.ace) {
 -    throw result.ace;
 -  }
 -  if (result.__isset.ase) {
 -    throw result.ase;
 -  }
 -  throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "getAllGatewaySSHPubKeys failed: unknown result");
 -}
 +  using ::apache::thrift::protocol::TProtocolException;
  
 -void AiravataClient::getAllGatewayPWDCredentials(std::map<std::string, std::string> & _return, const  ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId)
 -{
 -  send_getAllGatewayPWDCredentials(authzToken, gatewayId);
 -  recv_getAllGatewayPWDCredentials(_return);
 -}
 +  bool isset_authzToken = false;
 +  bool isset_productUri = false;
  
 -void AiravataClient::send_getAllGatewayPWDCredentials(const  ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& gatewayId)
 -{
 -  int32_t cseqid = 0;
 -  oprot_->writeMessageBegin("getAllGatewayPWDCredentials", ::apache::thrift::protocol::T_CALL, cseqid);
 +  while (true)
 +  {
 +    xfer += iprot->readFieldBegin(fname, ftype, fid);
 +    if (ftype == ::apache::thrift::protocol::T_STOP) {
 +      break;
 +    }
 +    switch (fid)
 +    {
 +      case 1:
 +        if (ftype == ::apache::thrift::protocol::T_STRUCT) {
 +          xfer += this->authzToken.read(iprot);
 +          isset_authzToken = true;
 +        } else {
 +          xfer += iprot->skip(ftype);
 +        }
 +        break;
 +      case 2:
 +        if (ftype == ::apache::thrift::protocol::T_STRING) {
 +          xfer += iprot->readString(this->productUri);
 +          isset_productUri = true;
 +        } else {
 +          xfer += iprot->skip(ftype);
 +        }
 +        break;
 +      default:
 +        xfer += iprot->skip(ftype);
 +        break;
 +    }
 +    xfer += iprot->readFieldEnd();
 +  }
  
 -  Airavata_getAllGatewayPWDCredentials_pargs args;
 -  args.authzToken = &authzToken;
 -  args.gatewayId = &gatewayId;
 -  args.write(oprot_);
 +  xfer += iprot->readStructEnd();
  
 -  oprot_->writeMessageEnd();
 -  oprot_->getTransport()->writeEnd();
 -  oprot_->getTransport()->flush();
 +  if (!isset_authzToken)
 +    throw TProtocolException(TProtocolException::INVALID_DATA);
 +  if (!isset_productUri)
 +    throw TProtocolException(TProtocolException::INVALID_DATA);
 +  return xfer;
  }
  
 -void AiravataClient::recv_getAllGatewayPWDCredentials(std::map<std::string, std::string> & _return)
 -{
 +uint32_t Airavata_getParentDataProduct_args::write(::apache::thrift::protocol::TProtocol* oprot) const {
 +  uint32_t xfer = 0;
 +  apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
 +  xfer += oprot->writeStructBegin("Airavata_getParentDataProduct_args");
  
 -  int32_t rseqid = 0;
 -  std::string fname;
 -  ::apache::thrift::protocol::TMessageType mtype;
 +  xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1);
 +  xfer += this->authzToken.write(oprot);
 +  xfer += oprot->writeFieldEnd();
  
 -  iprot_->readMessageBegin(fname, mtype, rseqid);
 -  if (mtype == ::apache::thrift::protocol::T_EXCEPTION) {
 -    ::apache::thrift::TApplicationException x;
 -    x.read(iprot_);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -    throw x;
 -  }
 -  if (mtype != ::apache::thrift::protocol::T_REPLY) {
 -    iprot_->skip(::apache::thrift::protocol::T_STRUCT);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -  }
 -  if (fname.compare("getAllGatewayPWDCredentials") != 0) {
 -    iprot_->skip(::apache::thrift::protocol::T_STRUCT);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -  }
 -  Airavata_getAllGatewayPWDCredentials_presult result;
 -  result.success = &_return;
 -  result.read(iprot_);
 -  iprot_->readMessageEnd();
 -  iprot_->getTransport()->readEnd();
 +  xfer += oprot->writeFieldBegin("productUri", ::apache::thrift::protocol::T_STRING, 2);
 +  xfer += oprot->writeString(this->productUri);
 +  xfer += oprot->writeFieldEnd();
  
 -  if (result.__isset.success) {
 -    // _return pointer has now been filled
 -    return;
 -  }
 -  if (result.__isset.ire) {
 -    throw result.ire;
 -  }
 -  if (result.__isset.ace) {
 -    throw result.ace;
 -  }
 -  if (result.__isset.ase) {
 -    throw result.ase;
 -  }
 -  throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "getAllGatewayPWDCredentials failed: unknown result");
 +  xfer += oprot->writeFieldStop();
 +  xfer += oprot->writeStructEnd();
 +  return xfer;
  }
  
 -bool AiravataClient::deleteSSHPubKey(const  ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& airavataCredStoreToken, const std::string& gatewayId)
 -{
 -  send_deleteSSHPubKey(authzToken, airavataCredStoreToken, gatewayId);
 -  return recv_deleteSSHPubKey();
 +
 +Airavata_getParentDataProduct_pargs::~Airavata_getParentDataProduct_pargs() throw() {
  }
  
 -void AiravataClient::send_deleteSSHPubKey(const  ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& airavataCredStoreToken, const std::string& gatewayId)
 -{
 -  int32_t cseqid = 0;
 -  oprot_->writeMessageBegin("deleteSSHPubKey", ::apache::thrift::protocol::T_CALL, cseqid);
  
 -  Airavata_deleteSSHPubKey_pargs args;
 -  args.authzToken = &authzToken;
 -  args.airavataCredStoreToken = &airavataCredStoreToken;
 -  args.gatewayId = &gatewayId;
 -  args.write(oprot_);
 +uint32_t Airavata_getParentDataProduct_pargs::write(::apache::thrift::protocol::TProtocol* oprot) const {
 +  uint32_t xfer = 0;
 +  apache::thrift::protocol::TOutputRecursionTracker tracker(*oprot);
 +  xfer += oprot->writeStructBegin("Airavata_getParentDataProduct_pargs");
  
 -  oprot_->writeMessageEnd();
 -  oprot_->getTransport()->writeEnd();
 -  oprot_->getTransport()->flush();
 +  xfer += oprot->writeFieldBegin("authzToken", ::apache::thrift::protocol::T_STRUCT, 1);
 +  xfer += (*(this->authzToken)).write(oprot);
 +  xfer += oprot->writeFieldEnd();
 +
 +  xfer += oprot->writeFieldBegin("productUri", ::apache::thrift::protocol::T_STRING, 2);
 +  xfer += oprot->writeString((*(this->productUri)));
 +  xfer += oprot->writeFieldEnd();
 +
 +  xfer += oprot->writeFieldStop();
 +  xfer += oprot->writeStructEnd();
 +  return xfer;
  }
  
 -bool AiravataClient::recv_deleteSSHPubKey()
 -{
  
 -  int32_t rseqid = 0;
 +Airavata_getParentDataProduct_result::~Airavata_getParentDataProduct_result() throw() {
 +}
 +
 +
 +uint32_t Airavata_getParentDataProduct_result::read(::apache::thrift::protocol::TProtocol* iprot) {
 +
 +  apache::thrift::protocol::TInputRecursionTracker tracker(*iprot);
 +  uint32_t xfer = 0;
    std::string fname;
 -  ::apache::thrift::protocol::TMessageType mtype;
 +  ::apache::thrift::protocol::TType ftype;
 +  int16_t fid;
  
 -  iprot_->readMessageBegin(fname, mtype, rseqid);
 -  if (mtype == ::apache::thrift::protocol::T_EXCEPTION) {
 -    ::apache::thrift::TApplicationException x;
 -    x.read(iprot_);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -    throw x;
 -  }
 -  if (mtype != ::apache::thrift::protocol::T_REPLY) {
 -    iprot_->skip(::apache::thrift::protocol::T_STRUCT);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -  }
 -  if (fname.compare("deleteSSHPubKey") != 0) {
 -    iprot_->skip(::apache::thrift::protocol::T_STRUCT);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -  }
 -  bool _return;
 -  Airavata_deleteSSHPubKey_presult result;
 -  result.success = &_return;
 -  result.read(iprot_);
 -  iprot_->readMessageEnd();
 -  iprot_->getTransport()->readEnd();
 +  xfer += iprot->readStructBegin(fname);
  
 -  if (result.__isset.success) {
 -    return _return;
 -  }
 -  if (result.__isset.ire) {
 -    throw result.ire;
 -  }
 -  if (result.__isset.ace) {
 -    throw result.ace;
 -  }
 -  if (result.__isset.ase) {
 -    throw result.ase;
 -  }
 -  throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "deleteSSHPubKey failed: unknown result");
 -}
 +  using ::apache::thrift::protocol::TProtocolException;
  
 -bool AiravataClient::deletePWDCredential(const  ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& airavataCredStoreToken, const std::string& gatewayId)
 -{
 -  send_deletePWDCredential(authzToken, airavataCredStoreToken, gatewayId);
 -  return recv_deletePWDCredential();
 -}
  
 -void AiravataClient::send_deletePWDCredential(const  ::apache::airavata::model::security::AuthzToken& authzToken, const std::string& airavataCredStoreToken, const std::string& gatewayId)
 -{
 -  int32_t cseqid = 0;
 -  oprot_->writeMessageBegin("deletePWDCredential", ::apache::thrift::protocol::T_CALL, cseqid);
 +  while (true)
 +  {
 +    xfer += iprot->readFieldBegin(fname, ftype, fid);
 +    if (ftype == ::apache::thrift::protocol::T_STOP) {
 +      break;
 +    }
 +    switch (fid)
 +    {
 +      case 0:
 +        if (ftype == ::apache::thrift::protocol::T_STRUCT) {
 +          xfer += this->success.read(iprot);
 +          this->__isset.success = true;
 +        } else {
 +          xfer += iprot->skip(ftype);
 +        }
 +        break;
 +      case 1:
 +        if (ftype == ::apache::thrift::protocol::T_STRUCT) {
 +          xfer += this->ire.read(iprot);
 +          this->__isset.ire = true;
 +        } else {
 +          xfer += iprot->skip(ftype);
 +        }
 +        break;
 +      case 2:
 +        if (ftype == ::apache::thrift::protocol::T_STRUCT) {
 +          xfer += this->ace.read(iprot);
 +          this->__isset.ace = true;
 +        } else {
 +          xfer += iprot->skip(ftype);
 +        }
 +        break;
 +      case 3:
 +        if (ftype == ::apache::thrift::protocol::T_STRUCT) {
 +          xfer += this->ase.read(iprot);
 +          this->__isset.ase = true;
 +        } else {
 +          xfer += iprot->skip(ftype);
 +        }
 +        break;
 +      case 4:
 +        if (ftype == ::apache::thrift::protocol::T_STRUCT) {
 +          xfer += this->ae.read(iprot);
 +          this->__isset.ae = true;
 +        } else {
 +          xfer += iprot->skip(ftype);
 +        }
 +        break;
 +      default:
 +        xfer += iprot->skip(ftype);
 +        break;
 +    }
 +    xfer += iprot->readFieldEnd();
 +  }
  
 -  Airavata_deletePWDCredential_pargs args;
 -  args.authzToken = &authzToken;
 -  args.airavataCredStoreToken = &airavataCredStoreToken;
 -  args.gatewayId = &gatewayId;
 -  args.write(oprot_);
 +  xfer += iprot->readStructEnd();
  
 -  oprot_->writeMessageEnd();
 -  oprot_->getTransport()->writeEnd();
 -  oprot_->getTransport()->flush();
 +  return xfer;
  }
  
 -bool AiravataClient::recv_deletePWDCredential()
 -{
 +uint32_t Airavata_getParentDataProduct_result::write(::apache::thrift::protocol::TProtocol* oprot) const {
  
 -  int32_t rseqid = 0;
 -  std::string fname;
 -  ::apache::thrift::protocol::TMessageType mtype;
 +  uint32_t xfer = 0;
  
 -  iprot_->readMessageBegin(fname, mtype, rseqid);
 -  if (mtype == ::apache::thrift::protocol::T_EXCEPTION) {
 -    ::apache::thrift::TApplicationException x;
 -    x.read(iprot_);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -    throw x;
 -  }
 -  if (mtype != ::apache::thrift::protocol::T_REPLY) {
 -    iprot_->skip(::apache::thrift::protocol::T_STRUCT);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -  }
 -  if (fname.compare("deletePWDCredential") != 0) {
 -    iprot_->skip(::apache::thrift::protocol::T_STRUCT);
 -    iprot_->readMessageEnd();
 -    iprot_->getTransport()->readEnd();
 -  }
 -  bool _return;
 -  Airavata_deletePWDCredential_presult result;
 -  result.success = &_return;
 -  result.read(iprot_);
 -  iprot_->readMessageEnd();
 -  iprot_->getTransport()->readEnd();
 +  xfer += oprot->writeStructBegin("Airavata_getParentDataProduct_result");
  
 -  if (result.__isset.success) {
 -    return _return;
 -  }
 -  if (result.__isset.ire) {
 -    throw result.ire;
 -  }
 -  if (result.__isset.ace) {
 -    throw result.ace;
 -  }
 -  if (result.__isset.ase) {
 -    throw result.ase;
 +  if (this->__isset.success) {
 +    xfer += oprot->writeFieldBegin("success", ::apache::thrift::protocol::T_STRUCT, 0);
 +    xfer += this->success.write(oprot);
 +    xfer += oprot->writeFieldEnd();
 +  } else if (this->__isset.ire) {
 +    xfer += oprot->writeFieldBegin("ire", ::apache::thrift::protocol::T_STRUCT, 1);
 +    xfer += this->ire.write(oprot);
 +    xfer += oprot->writeFieldEnd();
 +  } else if (this->__isset.ace) {
 +    xfer += oprot->writeFieldBegin("ace", ::apache::thrift::protocol::T_STRUCT, 2);
 +    xfer += this->ace.write(oprot);
 +    xfer += oprot->writeFieldEnd();
 +  } else if (this->__isset.ase) {
 +    xfer += oprot->writeFieldBegin("ase", ::apache::thrift::protocol::T_STRUCT, 3);
 +    xfer += this->ase.write(oprot);
 +    xfer += oprot->writeFieldEnd();
 +  } else if (this->__isset.ae) {
 +    xfer += oprot->writeFieldBegin("ae", ::apache::thrift::protocol::T_STRUCT, 4);
 +    xfer += this->ae.write(oprot);
 +    xfer += oprot->writeFieldEnd();
    }
 -  throw ::apache::thrift::TApplicationException(::apache::thrift::TApplicationException::MISSING_RESULT, "deletePWDCredential failed: unknown result");
 +  xfer += oprot->writeFieldStop();
 +  xfer += oprot->writeStructEnd();
 +  return xfer;
  }
  
 -void Aira

<TRUNCATED>
http://git-wip-us.apache.org/repos/asf/airavata/blob/fa5a1e0f/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata.h
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/airavata/blob/fa5a1e0f/airavata-api/airavata-client-sdks/airavata-cpp-sdk/src/main/resources/lib/airavata/Airavata_server.skeleton.cpp
----------------------------------------------------------------------