(file) Return to CMPIProviderManager.cpp CVS log (file) (dir) Up to [Pegasus] / pegasus / src / Pegasus / ProviderManager2 / CMPI

Diff for /pegasus/src/Pegasus/ProviderManager2/CMPI/CMPIProviderManager.cpp between version 1.25 and 1.26

version 1.25, 2004/03/24 17:51:01 version 1.26, 2004/03/30 15:29:57
Line 60 
Line 60 
  
 #include <Pegasus/Server/ProviderRegistrationManager/ProviderRegistrationManager.h> #include <Pegasus/Server/ProviderRegistrationManager/ProviderRegistrationManager.h>
  
   #ifdef PEGASUS_ZOS_THREADLEVEL_SECURITY
   #include <Pegasus/ProviderManager2/ProviderManagerzOS_inline.h>
   #endif
   
 PEGASUS_USING_STD; PEGASUS_USING_STD;
 PEGASUS_NAMESPACE_BEGIN PEGASUS_NAMESPACE_BEGIN
  
Line 348 
Line 352 
  
         CMPIProvider::pm_service_op_lock op_lock(&pr);         CMPIProvider::pm_service_op_lock op_lock(&pr);
  
   #ifdef PEGASUS_ZOS_THREADLEVEL_SECURITY
                   CIMGetInstanceRequestMessage * req = dynamic_cast<CIMGetInstanceRequestMessage *>(const_cast<Message *>(message));
                   int err_num=enablePThreadSecurity(req->userName);
                   if (err_num!=0)
                   {
                           // need a new CIMException for this
                           throw CIMException(CIM_ERR_ACCESS_DENIED,String(strerror(err_num)));
                   }
   #endif
   
         STAT_GETSTARTTIME;         STAT_GETSTARTTIME;
  
         rc=pr.miVector.instMI->ft->getInstance         rc=pr.miVector.instMI->ft->getInstance
Line 355 
Line 369 
  
         STAT_PMS_PROVIDEREND;         STAT_PMS_PROVIDEREND;
  
   #ifdef PEGASUS_ZOS_THREADLEVEL_SECURITY
                   disablePThreadSecurity(req->userName);
   #endif
         if (rc.rc!=CMPI_RC_OK)         if (rc.rc!=CMPI_RC_OK)
            throw CIMException((CIMStatusCode)rc.rc,            throw CIMException((CIMStatusCode)rc.rc,
                rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY);                rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY);
Line 430 
Line 447 
  
         CMPIProvider::pm_service_op_lock op_lock(&pr);         CMPIProvider::pm_service_op_lock op_lock(&pr);
  
   #ifdef PEGASUS_ZOS_THREADLEVEL_SECURITY
                   CIMEnumerateInstancesRequestMessage * req = dynamic_cast<CIMEnumerateInstancesRequestMessage *>(const_cast<Message *>(message));
                   int err_num=enablePThreadSecurity(req->userName);
                   if (err_num!=0)
                   {
                           // need a new CIMException for this
                           throw CIMException(CIM_ERR_ACCESS_DENIED,String(strerror(err_num)));
                   }
   #endif
   
         STAT_GETSTARTTIME;         STAT_GETSTARTTIME;
  
         rc=pr.miVector.instMI->ft->enumInstances         rc=pr.miVector.instMI->ft->enumInstances
Line 437 
Line 464 
  
         STAT_PMS_PROVIDEREND;         STAT_PMS_PROVIDEREND;
  
   #ifdef PEGASUS_ZOS_THREADLEVEL_SECURITY
                   disablePThreadSecurity(req->userName);
   #endif
   
         if (rc.rc!=CMPI_RC_OK)         if (rc.rc!=CMPI_RC_OK)
         throw CIMException((CIMStatusCode)rc.rc,         throw CIMException((CIMStatusCode)rc.rc,
                rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY);                rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY);
Line 506 
Line 537 
  
         CMPIProvider::pm_service_op_lock op_lock(&pr);         CMPIProvider::pm_service_op_lock op_lock(&pr);
  
   #ifdef PEGASUS_ZOS_THREADLEVEL_SECURITY
                   CIMEnumerateInstanceNamesRequestMessage * req = dynamic_cast<CIMEnumerateInstanceNamesRequestMessage *>(const_cast<Message *>(message));
                   int err_num=enablePThreadSecurity(req->userName);
                   if (err_num!=0)
                   {
                           // need a new CIMException for this
                           throw CIMException(CIM_ERR_ACCESS_DENIED,String(strerror(err_num)));
                   }
   #endif
         STAT_GETSTARTTIME;         STAT_GETSTARTTIME;
  
         rc=pr.miVector.instMI->ft->enumInstanceNames(pr.miVector.instMI,&eCtx,&eRes,&eRef);         rc=pr.miVector.instMI->ft->enumInstanceNames(pr.miVector.instMI,&eCtx,&eRes,&eRef);
  
         STAT_PMS_PROVIDEREND;         STAT_PMS_PROVIDEREND;
  
   #ifdef PEGASUS_ZOS_THREADLEVEL_SECURITY
                   disablePThreadSecurity(req->userName);
   #endif
   
         if (rc.rc!=CMPI_RC_OK)         if (rc.rc!=CMPI_RC_OK)
            throw CIMException((CIMStatusCode)rc.rc,            throw CIMException((CIMStatusCode)rc.rc,
                rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY);                rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY);
Line 584 
Line 628 
  
         CMPIProvider::pm_service_op_lock op_lock(&pr);         CMPIProvider::pm_service_op_lock op_lock(&pr);
  
   #ifdef PEGASUS_ZOS_THREADLEVEL_SECURITY
                   CIMCreateInstanceRequestMessage * req = dynamic_cast<CIMCreateInstanceRequestMessage *>(const_cast<Message *>(message));
                   int err_num=enablePThreadSecurity(req->userName);
                   if (err_num!=0)
                   {
                           // need a new CIMException for this
                           throw CIMException(CIM_ERR_ACCESS_DENIED,String(strerror(err_num)));
                   }
   #endif
   
         STAT_GETSTARTTIME;         STAT_GETSTARTTIME;
  
         rc=pr.miVector.instMI->ft->createInstance         rc=pr.miVector.instMI->ft->createInstance
Line 591 
Line 645 
  
         STAT_PMS_PROVIDEREND;         STAT_PMS_PROVIDEREND;
  
   #ifdef PEGASUS_ZOS_THREADLEVEL_SECURITY
                   disablePThreadSecurity(req->userName);
   #endif
   
         if (rc.rc!=CMPI_RC_OK)         if (rc.rc!=CMPI_RC_OK)
            throw CIMException((CIMStatusCode)rc.rc,            throw CIMException((CIMStatusCode)rc.rc,
                rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY);                rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY);
Line 664 
Line 722 
  
         CMPIProvider::pm_service_op_lock op_lock(&pr);         CMPIProvider::pm_service_op_lock op_lock(&pr);
  
   #ifdef PEGASUS_ZOS_THREADLEVEL_SECURITY
                   CIMModifyInstanceRequestMessage * req = dynamic_cast<CIMModifyInstanceRequestMessage *>(const_cast<Message *>(message));
                   int err_num=enablePThreadSecurity(req->userName);
                   if (err_num!=0)
                   {
                           // need a new CIMException for this
                           throw CIMException(CIM_ERR_ACCESS_DENIED,String(strerror(err_num)));
                   }
   #endif
   
         STAT_GETSTARTTIME;         STAT_GETSTARTTIME;
  
         rc=pr.miVector.instMI->ft->setInstance         rc=pr.miVector.instMI->ft->setInstance
Line 671 
Line 739 
  
         STAT_PMS_PROVIDEREND;         STAT_PMS_PROVIDEREND;
  
   #ifdef PEGASUS_ZOS_THREADLEVEL_SECURITY
                   disablePThreadSecurity(req->userName);
   #endif
   
         if (rc.rc!=CMPI_RC_OK)         if (rc.rc!=CMPI_RC_OK)
            throw CIMException((CIMStatusCode)rc.rc,            throw CIMException((CIMStatusCode)rc.rc,
                rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY);                rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY);
Line 738 
Line 810 
  
         CMPIProvider::pm_service_op_lock op_lock(&pr);         CMPIProvider::pm_service_op_lock op_lock(&pr);
  
   #ifdef PEGASUS_ZOS_THREADLEVEL_SECURITY
                   CIMDeleteInstanceRequestMessage * req = dynamic_cast<CIMDeleteInstanceRequestMessage *>(const_cast<Message *>(message));
                   int err_num=enablePThreadSecurity(req->userName);
                   if (err_num!=0)
                   {
                           // need a new CIMException for this
                           throw CIMException(CIM_ERR_ACCESS_DENIED,String(strerror(err_num)));
                   }
   #endif
   
         STAT_GETSTARTTIME;         STAT_GETSTARTTIME;
  
         rc=pr.miVector.instMI->ft->deleteInstance         rc=pr.miVector.instMI->ft->deleteInstance
Line 745 
Line 827 
  
         STAT_PMS_PROVIDEREND;         STAT_PMS_PROVIDEREND;
  
   #ifdef PEGASUS_ZOS_THREADLEVEL_SECURITY
                   disablePThreadSecurity(req->userName);
   #endif
   
         if (rc.rc!=CMPI_RC_OK)         if (rc.rc!=CMPI_RC_OK)
            throw CIMException((CIMStatusCode)rc.rc,            throw CIMException((CIMStatusCode)rc.rc,
                rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY);                rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY);
Line 819 
Line 905 
  
         CMPIProvider::pm_service_op_lock op_lock(&pr);         CMPIProvider::pm_service_op_lock op_lock(&pr);
  
   #ifdef PEGASUS_ZOS_THREADLEVEL_SECURITY
                   CIMExecQueryRequestMessage * req = dynamic_cast<CIMExecQueryRequestMessage *>(const_cast<Message *>(message));
                   int err_num=enablePThreadSecurity(req->userName);
                   if (err_num!=0)
                   {
                           // need a new CIMException for this
                           throw CIMException(CIM_ERR_ACCESS_DENIED,String(strerror(err_num)));
                   }
   #endif
   
         STAT_GETSTARTTIME;         STAT_GETSTARTTIME;
  
         rc=pr.miVector.instMI->ft->execQuery         rc=pr.miVector.instMI->ft->execQuery
Line 826 
Line 922 
  
         STAT_PMS_PROVIDEREND;         STAT_PMS_PROVIDEREND;
  
   #ifdef PEGASUS_ZOS_THREADLEVEL_SECURITY
                   disablePThreadSecurity(req->userName);
   #endif
   
         if (rc.rc!=CMPI_RC_OK)         if (rc.rc!=CMPI_RC_OK)
            throw CIMException((CIMStatusCode)rc.rc,            throw CIMException((CIMStatusCode)rc.rc,
                rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY);                rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY);
Line 912 
Line 1012 
  
         CMPIProvider::pm_service_op_lock op_lock(&pr);         CMPIProvider::pm_service_op_lock op_lock(&pr);
  
   #ifdef PEGASUS_ZOS_THREADLEVEL_SECURITY
                   CIMAssociatorsRequestMessage * req = dynamic_cast<CIMAssociatorsRequestMessage *>(const_cast<Message *>(message));
                   int err_num=enablePThreadSecurity(req->userName);
                   if (err_num!=0)
                   {
                           // need a new CIMException for this
                           throw CIMException(CIM_ERR_ACCESS_DENIED,String(strerror(err_num)));
                   }
   #endif
   
         STAT_GETSTARTTIME;         STAT_GETSTARTTIME;
  
         rc=pr.miVector.assocMI->ft->associators(         rc=pr.miVector.assocMI->ft->associators(
Line 920 
Line 1030 
  
         STAT_PMS_PROVIDEREND;         STAT_PMS_PROVIDEREND;
  
   #ifdef PEGASUS_ZOS_THREADLEVEL_SECURITY
                   disablePThreadSecurity(req->userName);
   #endif
   
         if (rc.rc!=CMPI_RC_OK)         if (rc.rc!=CMPI_RC_OK)
            throw CIMException((CIMStatusCode)rc.rc,            throw CIMException((CIMStatusCode)rc.rc,
                rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY);                rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY);
Line 1000 
Line 1114 
  
         CMPIProvider::pm_service_op_lock op_lock(&pr);         CMPIProvider::pm_service_op_lock op_lock(&pr);
  
   #ifdef PEGASUS_ZOS_THREADLEVEL_SECURITY
                   CIMAssociatorNamesRequestMessage * req = dynamic_cast<CIMAssociatorNamesRequestMessage *>(const_cast<Message *>(message));
                   int err_num=enablePThreadSecurity(req->userName);
                   if (err_num!=0)
                   {
                           // need a new CIMException for this
                           throw CIMException(CIM_ERR_ACCESS_DENIED,String(strerror(err_num)));
                   }
   #endif
   
         STAT_GETSTARTTIME;         STAT_GETSTARTTIME;
  
         rc=pr.miVector.assocMI->ft->associatorNames(         rc=pr.miVector.assocMI->ft->associatorNames(
Line 1008 
Line 1132 
  
         STAT_PMS_PROVIDEREND;         STAT_PMS_PROVIDEREND;
  
   #ifdef PEGASUS_ZOS_THREADLEVEL_SECURITY
                   disablePThreadSecurity(req->userName);
   #endif
   
         if (rc.rc!=CMPI_RC_OK)         if (rc.rc!=CMPI_RC_OK)
            throw CIMException((CIMStatusCode)rc.rc,            throw CIMException((CIMStatusCode)rc.rc,
                rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY);                rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY);
Line 1090 
Line 1218 
  
         CMPIProvider::pm_service_op_lock op_lock(&pr);         CMPIProvider::pm_service_op_lock op_lock(&pr);
  
   #ifdef PEGASUS_ZOS_THREADLEVEL_SECURITY
                   CIMReferencesRequestMessage * req = dynamic_cast<CIMReferencesRequestMessage *>(const_cast<Message *>(message));
                   int err_num=enablePThreadSecurity(req->userName);
                   if (err_num!=0)
                   {
                           // need a new CIMException for this
                           throw CIMException(CIM_ERR_ACCESS_DENIED,String(strerror(err_num)));
                   }
   #endif
   
         STAT_GETSTARTTIME;         STAT_GETSTARTTIME;
  
         rc=pr.miVector.assocMI->ft->references(         rc=pr.miVector.assocMI->ft->references(
Line 1098 
Line 1236 
  
         STAT_PMS_PROVIDEREND;         STAT_PMS_PROVIDEREND;
  
   #ifdef PEGASUS_ZOS_THREADLEVEL_SECURITY
                   disablePThreadSecurity(req->userName);
   #endif
   
         if (rc.rc!=CMPI_RC_OK)         if (rc.rc!=CMPI_RC_OK)
             throw CIMException((CIMStatusCode)rc.rc,             throw CIMException((CIMStatusCode)rc.rc,
                rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY);                rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY);
Line 1175 
Line 1317 
  
         CMPIProvider::pm_service_op_lock op_lock(&pr);         CMPIProvider::pm_service_op_lock op_lock(&pr);
  
   #ifdef PEGASUS_ZOS_THREADLEVEL_SECURITY
                   CIMReferenceNamesRequestMessage * req = dynamic_cast<CIMReferenceNamesRequestMessage *>(const_cast<Message *>(message));
                   int err_num=enablePThreadSecurity(req->userName);
                   if (err_num!=0)
                   {
                           // need a new CIMException for this
                           throw CIMException(CIM_ERR_ACCESS_DENIED,String(strerror(err_num)));
                   }
   #endif
   
         STAT_GETSTARTTIME;         STAT_GETSTARTTIME;
  
         rc=pr.miVector.assocMI->ft->referenceNames(         rc=pr.miVector.assocMI->ft->referenceNames(
Line 1183 
Line 1335 
  
         STAT_PMS_PROVIDEREND;         STAT_PMS_PROVIDEREND;
  
   #ifdef PEGASUS_ZOS_THREADLEVEL_SECURITY
                   disablePThreadSecurity(req->userName);
   #endif
   
         if (rc.rc!=CMPI_RC_OK)         if (rc.rc!=CMPI_RC_OK)
            throw CIMException((CIMStatusCode)rc.rc,            throw CIMException((CIMStatusCode)rc.rc,
                rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY);                rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY);
Line 1260 
Line 1416 
  
         CMPIProvider::pm_service_op_lock op_lock(&pr);         CMPIProvider::pm_service_op_lock op_lock(&pr);
  
   #ifdef PEGASUS_ZOS_THREADLEVEL_SECURITY
                   CIMInvokeMethodRequestMessage * req = dynamic_cast<CIMInvokeMethodRequestMessage *>(const_cast<Message *>(message));
                   int err_num=enablePThreadSecurity(req->userName);
                   if (err_num!=0)
                   {
                           // need a new CIMException for this
                           throw CIMException(CIM_ERR_ACCESS_DENIED,String(strerror(err_num)));
                   }
   #endif
         STAT_GETSTARTTIME;         STAT_GETSTARTTIME;
  
         rc=pr.miVector.methMI->ft->invokeMethod(         rc=pr.miVector.methMI->ft->invokeMethod(
Line 1267 
Line 1432 
  
         STAT_PMS_PROVIDEREND;         STAT_PMS_PROVIDEREND;
  
   #ifdef PEGASUS_ZOS_THREADLEVEL_SECURITY
                   disablePThreadSecurity(req->userName);
   #endif
   
         if (rc.rc!=CMPI_RC_OK)         if (rc.rc!=CMPI_RC_OK)
            throw CIMException((CIMStatusCode)rc.rc,            throw CIMException((CIMStatusCode)rc.rc,
                rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY);                rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY);
Line 1413 
Line 1582 
  
         CMPIProvider::pm_service_op_lock op_lock(&pr);         CMPIProvider::pm_service_op_lock op_lock(&pr);
  
   #ifdef PEGASUS_ZOS_THREADLEVEL_SECURITY
                   CIMCreateSubscriptionRequestMessage * req = dynamic_cast<CIMCreateSubscriptionRequestMessage *>(const_cast<Message *>(message));
                   int err_num=enablePThreadSecurity(req->userName);
                   if (err_num!=0)
                   {
                           // need a new CIMException for this
                           throw CIMException(CIM_ERR_ACCESS_DENIED,String(strerror(err_num)));
                   }
   #endif
         STAT_GETSTARTTIME;         STAT_GETSTARTTIME;
  
         rc=pr.miVector.indMI->ft->activateFilter(         rc=pr.miVector.indMI->ft->activateFilter(
Line 1422 
Line 1600 
  
        STAT_PMS_PROVIDEREND;        STAT_PMS_PROVIDEREND;
  
   #ifdef PEGASUS_ZOS_THREADLEVEL_SECURITY
                   disablePThreadSecurity(req->userName);
   #endif
   
         if (rc.rc!=CMPI_RC_OK)         if (rc.rc!=CMPI_RC_OK)
            throw CIMException((CIMStatusCode)rc.rc,            throw CIMException((CIMStatusCode)rc.rc,
                rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY);                rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY);
Line 1500 
Line 1682 
  
         CMPIProvider::pm_service_op_lock op_lock(&pr);         CMPIProvider::pm_service_op_lock op_lock(&pr);
  
   #ifdef PEGASUS_ZOS_THREADLEVEL_SECURITY
                   CIMDeleteSubscriptionRequestMessage * req = dynamic_cast<CIMDeleteSubscriptionRequestMessage *>(const_cast<Message *>(message));
                   int err_num=enablePThreadSecurity(req->userName);
                   if (err_num!=0)
                   {
                           // need a new CIMException for this
                           throw CIMException(CIM_ERR_ACCESS_DENIED,String(strerror(err_num)));
                   }
   #endif
         STAT_GETSTARTTIME;         STAT_GETSTARTTIME;
         rc=pr.miVector.indMI->ft->deActivateFilter(         rc=pr.miVector.indMI->ft->deActivateFilter(
            pr.miVector.indMI,&eCtx,NULL,eSelx,            pr.miVector.indMI,&eCtx,NULL,eSelx,
Line 1510 
Line 1701 
  
        STAT_PMS_PROVIDEREND;        STAT_PMS_PROVIDEREND;
  
   #ifdef PEGASUS_ZOS_THREADLEVEL_SECURITY
                   disablePThreadSecurity(req->userName);
   #endif
   
         if (rc.rc!=CMPI_RC_OK)         if (rc.rc!=CMPI_RC_OK)
            throw CIMException((CIMStatusCode)rc.rc,            throw CIMException((CIMStatusCode)rc.rc,
                rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY);                rc.msg ? CMGetCharsPtr(rc.msg,NULL) : String::EMPTY);

Legend:
Removed from v.1.25  
changed lines
  Added in v.1.26
No CVS admin address has been configured
 Powered by
ViewCVS 0.9.2