1 //%2005////////////////////////////////////////////////////////////////////////
3 // 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 // Copyright (c) 2004 BMC Software; Hewlett-Packard Development Company, L.P.;
8 // IBM Corp.; EMC Corporation; VERITAS Software Corporation; The Open Group.
9 // Copyright (c) 2005 Hewlett-Packard Development Company, L.P.; IBM Corp.;
10 // EMC Corporation; VERITAS Software Corporation; The Open Group.
12 // Permission is hereby granted, free of charge, to any person obtaining a copy
13 // of this software and associated documentation files (the "Software"), to
14 // deal in the Software without restriction, including without limitation the
15 // rights to use, copy, modify, merge, publish, distribute, sublicense, and/or
16 // sell copies of the Software, and to permit persons to whom the Software is
17 // furnished to do so, subject to the following conditions:
19 // THE ABOVE COPYRIGHT NOTICE AND THIS PERMISSION NOTICE SHALL BE INCLUDED IN
20 // ALL COPIES OR SUBSTANTIAL PORTIONS OF THE SOFTWARE. THE SOFTWARE IS PROVIDED
21 // "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT
22 // LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR
23 // PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT
24 // HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
25 // ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
26 // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
28 //==============================================================================
30 // Author: Mike Brasher (mbrasher@bmc.com)
32 // Modified By: Nitin Upasani, Hewlett-Packard Company (Nitin_Upasani@hp.com)
33 // Nag Boranna, Hewlett-Packard Company (nagaraja_boranna@hp.com)
34 // Jenny Yu, Hewlett-Packard Company (jenny_yu@hp.com)
35 // Sushma Fernandes, Hewlett-Packard Company
36 // (sushma_fernandes@hp.com)
37 // Carol Ann Krug Graves, Hewlett-Packard Company
38 // (carolann_graves@hp.com)
39 // Jair Santos, Hewlett-Packard Company (jair.santos@hp.com)
40 // Amit K Arora, IBM (amita@in.ibm.com) for PEP#101
41 // Mateus Baur, Hewlett-Packard Company (mateus.baur@hp.com)
43 //%/////////////////////////////////////////////////////////////////////////////
45 #ifndef Pegasus_CIMOperationRequestDecoder_h
46 #define Pegasus_CIMOperationRequestDecoder_h
48 #include <Pegasus/Common/Config.h>
49 #include <Pegasus/Common/MessageQueueService.h>
50 #include <Pegasus/Common/CIMMessage.h>
51 #include <Pegasus/Common/HTTPMessage.h>
52 #include <Pegasus/Common/AcceptLanguageList.h>
53 #include <Pegasus/Common/ContentLanguageList.h>
54 #include <Pegasus/Common/AutoPtr.h>
56 PEGASUS_NAMESPACE_BEGIN
60 /** This class decodes CIM operation requests and passes them down-stream.
62 class CIMOperationRequestDecoder : public MessageQueueService
65 typedef MessageQueueService Base;
67 CIMOperationRequestDecoder(
68 MessageQueueService* outputQueue,
69 Uint32 returnQueueId);
71 ~CIMOperationRequestDecoder();
77 void sendIMethodError(
79 HttpMethod httpMethod,
80 const String& messageId,
81 const String& methodName,
82 const CIMException& cimException);
86 HttpMethod httpMethod,
87 const String& messageId,
88 const String& methodName,
89 const CIMException& cimException);
94 const String& cimError = String::EMPTY,
95 const String& messageBody = String::EMPTY);
97 virtual void handleEnqueue(Message *);
99 virtual void handleEnqueue();
101 void handleHTTPMessage(HTTPMessage* httpMessage);
104 void handleMethodCall(
106 HttpMethod httpMethod,
108 Uint32 contentLength,
109 const String& cimProtocolVersionInHeader,
110 const String& cimMethodInHeader,
111 const String& cimObjectInHeader,
115 const AcceptLanguageList& httpAcceptLanguages,
116 const ContentLanguageList& httpContentLanguages);
118 CIMCreateClassRequestMessage* decodeCreateClassRequest(
121 const String& messageId,
122 const CIMNamespaceName& nameSpace,
123 const String& authType,
124 const String& userName);
127 CIMGetClassRequestMessage* decodeGetClassRequest(
130 const String& messageId,
131 const CIMNamespaceName& nameSpace,
132 const String& authType,
133 const String& userName);
135 CIMModifyClassRequestMessage* decodeModifyClassRequest(
138 const String& messageId,
139 const CIMNamespaceName& nameSpace,
140 const String& authType,
141 const String& userName);
143 CIMEnumerateClassNamesRequestMessage* decodeEnumerateClassNamesRequest(
146 const String& messageId,
147 const CIMNamespaceName& nameSpace,
148 const String& authType,
149 const String& userName);
151 CIMEnumerateClassesRequestMessage* decodeEnumerateClassesRequest(
154 const String& messageId,
155 const CIMNamespaceName& nameSpace,
156 const String& authType,
157 const String& userName);
159 CIMDeleteClassRequestMessage* decodeDeleteClassRequest(
162 const String& messageId,
163 const CIMNamespaceName& nameSpace,
164 const String& authType,
165 const String& userName);
167 CIMCreateInstanceRequestMessage* decodeCreateInstanceRequest(
170 const String& messageId,
171 const CIMNamespaceName& nameSpace,
172 const String& authType,
173 const String& userName);
175 CIMGetInstanceRequestMessage* decodeGetInstanceRequest(
178 const String& messageId,
179 const CIMNamespaceName& nameSpace,
180 const String& authType,
181 const String& userName);
183 CIMModifyInstanceRequestMessage* decodeModifyInstanceRequest(
186 const String& messageId,
187 const CIMNamespaceName& nameSpace,
188 const String& authType,
189 const String& userName);
191 CIMEnumerateInstanceNamesRequestMessage* decodeEnumerateInstanceNamesRequest(
194 const String& messageId,
195 const CIMNamespaceName& nameSpace,
196 const String& authType,
197 const String& userName);
199 CIMEnumerateInstancesRequestMessage* decodeEnumerateInstancesRequest(
202 const String& messageId,
203 const CIMNamespaceName& nameSpace,
204 const String& authType,
205 const String& userName);
207 CIMDeleteInstanceRequestMessage* decodeDeleteInstanceRequest(
210 const String& messageId,
211 const CIMNamespaceName& nameSpace,
212 const String& authType,
213 const String& userName);
215 CIMSetQualifierRequestMessage* decodeSetQualifierRequest(
218 const String& messageId,
219 const CIMNamespaceName& nameSpace,
220 const String& authType,
221 const String& userName);
223 CIMGetQualifierRequestMessage* decodeGetQualifierRequest(
226 const String& messageId,
227 const CIMNamespaceName& nameSpace,
228 const String& authType,
229 const String& userName);
231 CIMEnumerateQualifiersRequestMessage* decodeEnumerateQualifiersRequest(
234 const String& messageId,
235 const CIMNamespaceName& nameSpace,
236 const String& authType,
237 const String& userName);
239 CIMDeleteQualifierRequestMessage* decodeDeleteQualifierRequest(
242 const String& messageId,
243 const CIMNamespaceName& nameSpace,
244 const String& authType,
245 const String& userName);
247 CIMReferenceNamesRequestMessage* decodeReferenceNamesRequest(
250 const String& messageId,
251 const CIMNamespaceName& nameSpace,
252 const String& authType,
253 const String& userName);
255 CIMReferencesRequestMessage* decodeReferencesRequest(
258 const String& messageId,
259 const CIMNamespaceName& nameSpace,
260 const String& authType,
261 const String& userName);
263 CIMAssociatorNamesRequestMessage* decodeAssociatorNamesRequest(
266 const String& messageId,
267 const CIMNamespaceName& nameSpace,
268 const String& authType,
269 const String& userName);
271 CIMAssociatorsRequestMessage* decodeAssociatorsRequest(
274 const String& messageId,
275 const CIMNamespaceName& nameSpace,
276 const String& authType,
277 const String& userName);
279 CIMGetPropertyRequestMessage* decodeGetPropertyRequest(
282 const String& messageId,
283 const CIMNamespaceName& nameSpace,
284 const String& authType,
285 const String& userName);
287 CIMSetPropertyRequestMessage* decodeSetPropertyRequest(
290 const String& messageId,
291 const CIMNamespaceName& nameSpace,
292 const String& authType,
293 const String& userName);
295 CIMExecQueryRequestMessage* decodeExecQueryRequest(
298 const String& messageId,
299 const CIMNamespaceName& nameSpace,
300 const String& authType,
301 const String& userName);
303 CIMInvokeMethodRequestMessage* decodeInvokeMethodRequest(
306 const String& messageId,
307 const CIMObjectPath& reference,
308 const String& cimMethodName,
309 const String& authType,
310 const String& userName);
312 /** Sets the flag to indicate whether or not the CIMServer is
315 void setServerTerminating(Boolean flag);
319 AutoPtr<MessageQueueService> _outputQueue; //PEP101
321 // Queue where responses should be enqueued.
322 Uint32 _returnQueueId;
324 // Flag to indicate whether or not the CIMServer is shutting down.
325 Boolean _serverTerminating;
328 PEGASUS_NAMESPACE_END
330 #endif /* Pegasus_CIMOperationRequestDecoder_h */