(file) Return to ModuleController.h CVS log (file) (dir) Up to [Pegasus] / pegasus / src / Pegasus / Common

Diff for /pegasus/src/Pegasus/Common/ModuleController.h between version 1.30 and 1.37

version 1.30, 2002/06/07 00:03:34 version 1.37, 2004/05/18 11:03:38
Line 1 
Line 1 
 //%///////////-*-c++-*-/////////////////////////////////////////////////////////  //%2003////////////////////////////////////////////////////////////////////////
 // //
 // Copyright (c) 2000, 2001, 2002 BMC Software, Hewlett-Packard Company, IBM,  // Copyright (c) 2000, 2001, 2002  BMC Software, Hewlett-Packard Development
 // The Open Group, Tivoli Systems  // Company, L. P., IBM Corp., The Open Group, Tivoli Systems.
   // Copyright (c) 2003 BMC Software; Hewlett-Packard Development Company, L. P.;
   // IBM Corp.; EMC Corporation, The Open Group.
 // //
 // Permission is hereby granted, free of charge, to any person obtaining a copy // Permission is hereby granted, free of charge, to any person obtaining a copy
 // of this software and associated documentation files (the "Software"), to // of this software and associated documentation files (the "Software"), to
Line 23 
Line 25 
 // //
 // Author: Mike Day (mdday@us.ibm.com) <<< Wed Mar 13 20:49:40 2002 mdd >>> // Author: Mike Day (mdday@us.ibm.com) <<< Wed Mar 13 20:49:40 2002 mdd >>>
 // //
 // Modified By:  // Modified By: Amit K Arora, IBM (amita@in.ibm.com)
 // //
 //%///////////////////////////////////////////////////////////////////////////// //%/////////////////////////////////////////////////////////////////////////////
  
Line 33 
Line 35 
 #include <Pegasus/Common/Config.h> #include <Pegasus/Common/Config.h>
 #include <Pegasus/Common/Constants.h> #include <Pegasus/Common/Constants.h>
 #include <Pegasus/Common/Message.h> #include <Pegasus/Common/Message.h>
 #include <Pegasus/Common/Exception.h>  #include <Pegasus/Common/InternalException.h>
 #include <Pegasus/Common/IPC.h> #include <Pegasus/Common/IPC.h>
 #include <Pegasus/Common/Thread.h> #include <Pegasus/Common/Thread.h>
 #include <Pegasus/Common/AsyncOpNode.h> #include <Pegasus/Common/AsyncOpNode.h>
Line 41 
Line 43 
 #include <Pegasus/Common/CimomMessage.h> #include <Pegasus/Common/CimomMessage.h>
 #include <Pegasus/Common/MessageQueueService.h> #include <Pegasus/Common/MessageQueueService.h>
 #include <Pegasus/Common/peg_authorization.h> #include <Pegasus/Common/peg_authorization.h>
   #include <Pegasus/Common/Linkage.h>
   #include <Pegasus/Common/AutoPtr.h>
  
  
 PEGASUS_NAMESPACE_BEGIN PEGASUS_NAMESPACE_BEGIN
Line 99 
Line 103 
  
  
             Mutex _thread_safety;             Mutex _thread_safety;
             ModuleController *_controller;              AutoPtr<ModuleController> _controller;//PEP101
             String _name;             String _name;
             AtomicInt _reference_count;             AtomicInt _reference_count;
             AtomicInt _shutting_down;             AtomicInt _shutting_down;
Line 155 
Line 159 
  
    private:    private:
  
       module_rep *_rep;        AutoPtr<module_rep> _rep;//PEP101
  
       pegasus_module(void)       pegasus_module(void)
       {       {
Line 224 
Line 228 
                                     CLIENT_SEND_ASYNC |                                     CLIENT_SEND_ASYNC |
                                     CLIENT_SEND_ASYNC_MODULE |                                     CLIENT_SEND_ASYNC_MODULE |
                                     CLIENT_BLOCKING_THREAD_EXEC |                                     CLIENT_BLOCKING_THREAD_EXEC |
                                     CLIENT_ASYNC_THREAD_EXEC)                                      CLIENT_ASYNC_THREAD_EXEC),
                   reference_count(1)
             {             {
             }             }
  
Line 232 
Line 237 
             {             {
             }             }
  
               client_handle & operator=(const client_handle & handle)
               {
                  if(this == &handle)
                     return *this;
                  reference_count++;
                  return *this;
               }
   
   
             virtual Boolean authorized(Uint32, Uint32);             virtual Boolean authorized(Uint32, Uint32);
             virtual Boolean authorized(Uint32 operation);             virtual Boolean authorized(Uint32 operation);
             virtual Boolean authorized(void);             virtual Boolean authorized(void);
             PEGASUS_STD(bitset<32>) allowed_operations;             PEGASUS_STD(bitset<32>) allowed_operations;
               AtomicInt reference_count;
   
       };       };
  
       class callback_handle       class callback_handle
Line 257 
Line 273 
             ~callback_handle()             ~callback_handle()
             {             {
                if( _module->get_name() == String(PEGASUS_MODULENAME_TEMP) )                if( _module->get_name() == String(PEGASUS_MODULENAME_TEMP) )
                   delete _module;                   // delete _module;
                    _module.reset();
             }             }
  
             pegasus_module * _module;              AutoPtr<pegasus_module> _module;//PEP101
             void *_parm;             void *_parm;
       };       };
  
Line 291 
Line 308 
                                                 void (*shutdown_notify)(Uint32, void *),                                                 void (*shutdown_notify)(Uint32, void *),
                                                 pegasus_module **instance = NULL)                                                 pegasus_module **instance = NULL)
  
          throw(AlreadyExists, IncompatibleTypes);           throw(AlreadyExistsException, IncompatibleTypesException);
  
       Boolean deregister_module(const String & module_name)       Boolean deregister_module(const String & module_name)
          throw(Permission);          throw(Permission);
Line 355 
Line 372 
  
       static ModuleController & get_client_handle(const pegasus_identity & id,       static ModuleController & get_client_handle(const pegasus_identity & id,
                                                   client_handle **handle)                                                   client_handle **handle)
          throw(IncompatibleTypes);           throw(IncompatibleTypesException);
  
       static ModuleController & get_client_handle(const char *controller,       static ModuleController & get_client_handle(const char *controller,
                                                   const pegasus_identity & id,                                                   const pegasus_identity & id,
                                                   client_handle **handle)                                                   client_handle **handle)
          throw(IncompatibleTypes);           throw(IncompatibleTypesException);
  
  
       void return_client_handle(client_handle *handle);       void return_client_handle(client_handle *handle);
Line 425 
Line 442 
       virtual void _handle_async_callback(AsyncOpNode *op);       virtual void _handle_async_callback(AsyncOpNode *op);
  
    private:    private:
   
   
         class _module_lock
         {
            public:
               _module_lock(DQueue<pegasus_module> * list)
                  :_list(list)
               {
                  _list->lock();
   
               }
               ~_module_lock(void)
               {
                  _list->unlock();
               }
   
   
            private:
               _module_lock();
               DQueue<pegasus_module> * _list;
         };
   
   
   
       static void _async_handleEnqueue(AsyncOpNode *h, MessageQueue *q, void *parm);       static void _async_handleEnqueue(AsyncOpNode *h, MessageQueue *q, void *parm);
       DQueue<pegasus_module> _modules;       DQueue<pegasus_module> _modules;
       pegasus_module _internal_module;       pegasus_module _internal_module;
Line 447 
Line 488 
  
  
  
   
   
 PEGASUS_NAMESPACE_END PEGASUS_NAMESPACE_END
  
  

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