1 karl  1.18 //%2003////////////////////////////////////////////////////////////////////////

  2 kumpf 1.1  //

  3 karl  1.18 // Copyright (c) 2000, 2001, 2002  BMC Software, Hewlett-Packard Development
  4            // Company, L. P., IBM Corp., The Open Group, Tivoli Systems.
  5            // Copyright (c) 2003 BMC Software; Hewlett-Packard Development Company, L. P.;
  6            // IBM Corp.; EMC Corporation, The Open Group.

  7 kumpf 1.1  //
  8            // Permission is hereby granted, free of charge, to any person obtaining a copy
  9            // of this software and associated documentation files (the "Software"), to
 10            // deal in the Software without restriction, including without limitation the
 11            // rights to use, copy, modify, merge, publish, distribute, sublicense, and/or
 12            // sell copies of the Software, and to permit persons to whom the Software is
 13            // furnished to do so, subject to the following conditions:

 14 kumpf 1.10 // 

 15 kumpf 1.1  // THE ABOVE COPYRIGHT NOTICE AND THIS PERMISSION NOTICE SHALL BE INCLUDED IN
 16            // ALL COPIES OR SUBSTANTIAL PORTIONS OF THE SOFTWARE. THE SOFTWARE IS PROVIDED
 17            // "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT
 18            // LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR
 19            // PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT
 20            // HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
 21            // ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
 22            // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 23            //
 24            //==============================================================================
 25            //
 26            // Author: Nitin Upasani, Hewlett-Packard Company (Nitin_Upasani@hp.com)
 27            //

 28 kumpf 1.15 // Modified By: Carol Ann Krug Graves, Hewlett-Packard Company
 29            //                (carolann_graves@hp.com)

 30 kumpf 1.1  //
 31            //%/////////////////////////////////////////////////////////////////////////////
 32            
 33            

 34 kumpf 1.3  #ifndef Pegasus_IndicationHandlerService_h
 35            #define Pegasus_IndicationHandlerService_h

 36 kumpf 1.1  
 37            #include <Pegasus/Common/Config.h>
 38            #include <sys/types.h>

 39 kumpf 1.16 //#if defined(PEGASUS_PLATFORM_WIN32_IX86_MSVC)
 40            //#else
 41            //#include <unistd.h>
 42            //#endif 

 43 kumpf 1.1  #include <iostream>
 44            #include <stdio.h>
 45            #include <string.h>
 46            
 47            #include <Pegasus/Common/Config.h>

 48 kumpf 1.12 #include <Pegasus/Common/InternalException.h>

 49 kumpf 1.1  #include <Pegasus/Common/DQueue.h>
 50            #include <Pegasus/Common/Thread.h>

 51 kumpf 1.14 #include <Pegasus/Common/ArrayInternal.h>

 52 kumpf 1.1  #include <Pegasus/Common/AsyncOpNode.h>
 53            #include <Pegasus/Common/CimomMessage.h>
 54            #include <Pegasus/Common/Cimom.h>
 55            #include <Pegasus/Common/MessageQueueService.h>
 56            #include <Pegasus/Common/CIMMessage.h>
 57            #include <Pegasus/Common/XmlWriter.h>
 58            #include <Pegasus/Handler/CIMHandler.h>
 59            #include <Pegasus/Repository/CIMRepository.h>
 60            
 61            #include "HandlerTable.h"

 62 chuck 1.13 
 63            #include <Pegasus/HandlerService/Linkage.h>

 64 kumpf 1.1  
 65            PEGASUS_NAMESPACE_BEGIN
 66            
 67            class PEGASUS_HANDLER_SERVICE_LINKAGE IndicationHandlerService 

 68 mday  1.6     : public MessageQueueService

 69 kumpf 1.1  {

 70 mday  1.6     public:

 71 kumpf 1.1      

 72 mday  1.6        typedef MessageQueueService Base;

 73 kumpf 1.1      

 74 mday  1.6        IndicationHandlerService(CIMRepository* repository);

 75 kumpf 1.3  

 76 mday  1.6        IndicationHandlerService(void);

 77 kumpf 1.3  

 78 mday  1.6        ~IndicationHandlerService(void) { } ;

 79 kumpf 1.1        

 80 mday  1.6        virtual void _handle_async_request(AsyncRequest *req);

 81 kumpf 1.3  

 82 mday  1.6        virtual void handleEnqueue(Message *);

 83 kumpf 1.4  

 84 mday  1.6        virtual void handleEnqueue(void);

 85 kumpf 1.4  

 86 mday  1.8        static void _handleIndicationCallBack(AsyncOpNode *, 
 87            					    MessageQueue *, 
 88            					    void *);
 89                  

 90 mday  1.6        AtomicInt dienow;

 91 kumpf 1.1  

 92 mday  1.6     protected:

 93 kumpf 1.3  

 94 mday  1.6        void _handleIndication(const Message* message);

 95 kumpf 1.1  

 96 mday  1.6        HandlerTable _handlerTable;

 97 kumpf 1.1  

 98 kumpf 1.15       CIMHandler* _lookupHandlerForClass(const CIMName& className);

 99 kumpf 1.1  

100 tony  1.17       String _parseDestination(String dest);
101            

102 mday  1.6     private:
103                  CIMRepository* _repository;

104 kumpf 1.1  };
105            
106            PEGASUS_NAMESPACE_END
107            
108            #endif