1 karl  1.5 //%2006////////////////////////////////////////////////////////////////////////

  2 kumpf 1.1 //

  3 karl  1.2 // 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 kumpf 1.1 // IBM Corp.; EMC Corporation, The Open Group.

  7 karl  1.2 // Copyright (c) 2004 BMC Software; Hewlett-Packard Development Company, L.P.;
  8           // IBM Corp.; EMC Corporation; VERITAS Software Corporation; The Open Group.

  9 karl  1.3 // Copyright (c) 2005 Hewlett-Packard Development Company, L.P.; IBM Corp.;
 10           // EMC Corporation; VERITAS Software Corporation; The Open Group.

 11 karl  1.5 // Copyright (c) 2006 Hewlett-Packard Development Company, L.P.; IBM Corp.;
 12           // EMC Corporation; Symantec Corporation; The Open Group.

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

 20 karl  1.5 // 

 21 kumpf 1.1 // THE ABOVE COPYRIGHT NOTICE AND THIS PERMISSION NOTICE SHALL BE INCLUDED IN
 22           // ALL COPIES OR SUBSTANTIAL PORTIONS OF THE SOFTWARE. THE SOFTWARE IS PROVIDED
 23           // "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT
 24           // LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR
 25           // PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT
 26           // HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
 27           // ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
 28           // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 29           //
 30           //==============================================================================
 31           //
 32           //%/////////////////////////////////////////////////////////////////////////////
 33           
 34           #include <Pegasus/Common/Config.h>

 35 chip  1.4 #include <Pegasus/Common/CIMMessage.h>

 36 kumpf 1.1 #include <Pegasus/Common/OperationContext.h>

 37 mike  1.6 #include <Pegasus/Common/AsyncQueue.h>

 38 kumpf 1.1 #include <Pegasus/Common/MessageQueueService.h>
 39           
 40           #ifdef PEGASUS_OS_OS400
 41           #include <qycmutilu2.H>
 42           #include "OS400ConvertChar.h"
 43           #include "CIMOMHandleOS400UserState.h"
 44           #include "CIMOMHandleOS400SystemState.h"
 45           #endif
 46           
 47           #include "CIMOMHandleRep.h"
 48           
 49           PEGASUS_NAMESPACE_BEGIN
 50           

 51 chip  1.4 class InternalCIMOMHandleMessageQueue : public MessageQueue
 52           {
 53           public:
 54               InternalCIMOMHandleMessageQueue();
 55               virtual ~InternalCIMOMHandleMessageQueue();
 56           
 57               virtual void handleEnqueue();
 58           
 59               CIMResponseMessage * sendRequest(CIMRequestMessage * request);
 60           
 61           private:
 62               Uint32 _output_qid;
 63               Uint32 _return_qid;
 64           
 65               Mutex _mutex;

 66 mike  1.6     AsyncQueue<Message> _response;

 67 chip  1.4 
 68           };
 69           

 70 kumpf 1.1 /**
 71               InternalCIMOMHandleRep is the default, in-process CIMOMHandle
 72               implementation.  The code was extracted from CIMOMHandle.cpp to allow
 73               for polymorphic CIMOMHandleRep implementations.
 74            */

 75 chip  1.4 class InternalCIMOMHandleRep : public CIMOMHandleRep

 76 kumpf 1.1 {
 77           public:
 78               InternalCIMOMHandleRep();

 79 kumpf 1.8 #ifdef PEGASUS_OS_OS400

 80 kumpf 1.1     InternalCIMOMHandleRep(Uint32 os400key);

 81 kumpf 1.8 #endif

 82 kumpf 1.1     virtual ~InternalCIMOMHandleRep();
 83           
 84               virtual CIMClass getClass(
 85                   const OperationContext & context,
 86                   const CIMNamespaceName& nameSpace,
 87                   const CIMName& className,
 88                   Boolean localOnly,
 89                   Boolean includeQualifiers,
 90                   Boolean includeClassOrigin,
 91                   const CIMPropertyList& propertyList);
 92           
 93               virtual Array<CIMClass> enumerateClasses(
 94                   const OperationContext & context,
 95                   const CIMNamespaceName& nameSpace,
 96                   const CIMName& className,
 97                   Boolean deepInheritance,
 98                   Boolean localOnly,
 99                   Boolean includeQualifiers,
100                   Boolean includeClassOrigin);
101           
102               virtual Array<CIMName> enumerateClassNames(
103 kumpf 1.1         const OperationContext & context,
104                   const CIMNamespaceName& nameSpace,
105                   const CIMName& className,
106                   Boolean deepInheritance);
107           
108               virtual void createClass(
109                   const OperationContext & context,
110                   const CIMNamespaceName& nameSpace,
111                   const CIMClass& newClass);
112           
113               virtual void modifyClass(
114                   const OperationContext & context,
115                   const CIMNamespaceName& nameSpace,
116                   const CIMClass& modifiedClass);
117           
118               virtual void deleteClass(
119                   const OperationContext & context,
120                   const CIMNamespaceName& nameSpace,
121                   const CIMName& className);
122           
123               virtual CIMInstance getInstance(
124 kumpf 1.1         const OperationContext & context,
125                   const CIMNamespaceName& nameSpace,
126                   const CIMObjectPath& instanceName,
127                   Boolean localOnly,
128                   Boolean includeQualifiers,
129                   Boolean includeClassOrigin,
130                   const CIMPropertyList& propertyList);
131           
132               virtual Array<CIMInstance> enumerateInstances(
133                   const OperationContext & context,
134                   const CIMNamespaceName& nameSpace,
135                   const CIMName& className,
136                   Boolean deepInheritance,
137                   Boolean localOnly,
138                   Boolean includeQualifiers,
139                   Boolean includeClassOrigin,
140                   const CIMPropertyList& propertyList);
141           
142               virtual Array<CIMObjectPath> enumerateInstanceNames(
143                   const OperationContext & context,
144                   const CIMNamespaceName& nameSpace,
145 kumpf 1.1         const CIMName& className);
146           
147               virtual CIMObjectPath createInstance(
148                   const OperationContext & context,
149                   const CIMNamespaceName& nameSpace,
150                   const CIMInstance& newInstance);
151           
152               virtual void modifyInstance(
153                   const OperationContext & context,
154                   const CIMNamespaceName& nameSpace,
155                   const CIMInstance& modifiedInstance,
156                   Boolean includeQualifiers,
157                   const CIMPropertyList& propertyList);
158           
159               virtual void deleteInstance(
160                   const OperationContext & context,
161                   const CIMNamespaceName& nameSpace,
162                   const CIMObjectPath& instanceName);
163           
164               virtual Array<CIMObject> execQuery(
165                   const OperationContext & context,
166 kumpf 1.1         const CIMNamespaceName& nameSpace,
167                   const String& queryLanguage,
168                   const String& query);
169           
170               virtual Array<CIMObject> associators(
171                   const OperationContext & context,
172                   const CIMNamespaceName& nameSpace,
173                   const CIMObjectPath& objectName,
174                   const CIMName& assocClass,
175                   const CIMName& resultClass,
176                   const String& role,
177                   const String& resultRole,
178                   Boolean includeQualifiers,
179                   Boolean includeClassOrigin,
180                   const CIMPropertyList& propertyList);
181           
182               virtual Array<CIMObjectPath> associatorNames(
183                   const OperationContext & context,
184                   const CIMNamespaceName& nameSpace,
185                   const CIMObjectPath& objectName,
186                   const CIMName& assocClass,
187 kumpf 1.1         const CIMName& resultClass,
188                   const String& role,
189                   const String& resultRole);
190           
191               virtual Array<CIMObject> references(
192                   const OperationContext & context,
193                   const CIMNamespaceName& nameSpace,
194                   const CIMObjectPath& objectName,
195                   const CIMName& resultClass,
196                   const String& role,
197                   Boolean includeQualifiers,
198                   Boolean includeClassOrigin,
199                   const CIMPropertyList& propertyList);
200           
201               virtual Array<CIMObjectPath> referenceNames(
202                   const OperationContext & context,
203                   const CIMNamespaceName& nameSpace,
204                   const CIMObjectPath& objectName,
205                   const CIMName& resultClass,
206                   const String& role);
207           
208 kumpf 1.1     // property operations
209               virtual CIMValue getProperty(
210                   const OperationContext & context,
211                   const CIMNamespaceName& nameSpace,
212                   const CIMObjectPath& instanceName,
213                   const CIMName& propertyName);
214           
215               virtual void setProperty(
216                   const OperationContext & context,
217                   const CIMNamespaceName& nameSpace,
218                   const CIMObjectPath& instanceName,
219                   const CIMName& propertyName,
220                   const CIMValue& newValue);
221           
222               virtual CIMValue invokeMethod(
223                   const OperationContext & context,
224                   const CIMNamespaceName& nameSpace,
225                   const CIMObjectPath& instanceName,
226                   const CIMName& methodName,
227                   const Array<CIMParamValue>& inParameters,
228                   Array<CIMParamValue>& outParameters);
229 kumpf 1.1 
230               virtual void disallowProviderUnload();  // Overload for OS/400
231               virtual void allowProviderUnload();  // Overload for OS/400
232               virtual OperationContext getResponseContext();
233           

234 kumpf 1.8 #ifdef PEGASUS_OS_OS400

235 kumpf 1.1     virtual void setOS400ProfileHandle(const char* profileHandle);

236 kumpf 1.8 #endif

237 kumpf 1.1 
238           private:
239               InternalCIMOMHandleRep(const InternalCIMOMHandleRep& rep);
240               InternalCIMOMHandleRep& operator=(const InternalCIMOMHandleRep& rep);
241           

242 chip  1.4     CIMResponseMessage* do_request(CIMRequestMessage* request);

243 kumpf 1.1 

244 chip  1.4 private:

245 kumpf 1.8 #ifdef PEGASUS_OS_OS400

246 kumpf 1.1     char os400PH[12];
247               CIMOMHandleOS400UserState _chOS400;

248 kumpf 1.8 #endif

249 chip  1.4 
250               InternalCIMOMHandleMessageQueue _queue;
251           

252 kumpf 1.1 };
253           
254           PEGASUS_NAMESPACE_END