1 karl 1.6 //%2004////////////////////////////////////////////////////////////////////////
|
2 chip 1.1 //
|
3 karl 1.6 // 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 karl 1.5 // IBM Corp.; EMC Corporation, The Open Group.
|
7 karl 1.6 // Copyright (c) 2004 BMC Software; Hewlett-Packard Development Company, L.P.;
8 // IBM Corp.; EMC Corporation; VERITAS Software Corporation; The Open Group.
|
9 chip 1.1 //
10 // Permission is hereby granted, free of charge, to any person obtaining a copy
11 // of this software and associated documentation files (the "Software"), to
12 // deal in the Software without restriction, including without limitation the
13 // rights to use, copy, modify, merge, publish, distribute, sublicense, and/or
14 // sell copies of the Software, and to permit persons to whom the Software is
15 // furnished to do so, subject to the following conditions:
|
16 kumpf 1.4 //
|
17 chip 1.1 // THE ABOVE COPYRIGHT NOTICE AND THIS PERMISSION NOTICE SHALL BE INCLUDED IN
18 // ALL COPIES OR SUBSTANTIAL PORTIONS OF THE SOFTWARE. THE SOFTWARE IS PROVIDED
19 // "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT
20 // LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR
21 // PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT
22 // HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
23 // ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
24 // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
25 //
26 //==============================================================================
27 //
28 // Author: Chip Vincent (cvincent@us.ibm.com)
29 //
30 // Modified By:
31 //
32 //%/////////////////////////////////////////////////////////////////////////////
33
34 #include "RepositoryQueue.h"
35
36 PEGASUS_NAMESPACE_BEGIN
37
38 chip 1.1 RepositoryQueue::RepositoryQueue(void)
|
39 mday 1.2 Base("RepositoryQueue", MessageQueue::getNextQueueId())
|
40 chip 1.1 {
|
41 mday 1.2
|
42 chip 1.1 }
43
44 RepositoryQueue::~RepositoryQueue(void)
45 {
46 }
47
|
48 mday 1.3
49 void RepositoryQueue::handleEnqueue(Message *message)
|
50 chip 1.1 {
|
51 mday 1.3 if( ! message )
52 return;
53
54 switch(message->getType())
55 {
56 case CIM_GET_CLASS_REQUEST_MESSAGE:
57 handleGetClassRequest(message);
58
59 break;
60 case CIM_ENUMERATE_CLASSES_REQUEST_MESSAGE:
61 handleEnumerateClassesRequest(message);
62
63 break;
64 case CIM_ENUMERATE_CLASS_NAMES_REQUEST_MESSAGE:
65 handleEnumerateClassNamesRequest(message);
66
67 break;
68 case CIM_CREATE_CLASS_REQUEST_MESSAGE:
69 handleCreateClassRequest(message);
70
71 break;
72 mday 1.3 case CIM_MODIFY_CLASS_REQUEST_MESSAGE:
73 handleModifyClassRequest(message);
74
75 break;
76 case CIM_DELETE_CLASS_REQUEST_MESSAGE:
77 handleDeleteClassRequest(message);
78
79 break;
80 case CIM_GET_INSTANCE_REQUEST_MESSAGE:
81 handleGetInstanceRequest(message);
82
83 break;
84 case CIM_ENUMERATE_INSTANCES_REQUEST_MESSAGE:
85 handleEnumerateInstancesRequest(message);
86
87 break;
88 case CIM_ENUMERATE_INSTANCE_NAMES_REQUEST_MESSAGE:
89 handleEnumerateInstanceNamesRequest(message);
90
91 break;
92 case CIM_CREATE_INSTANCE_REQUEST_MESSAGE:
93 mday 1.3 handleCreateInstanceRequest(message);
94
95 break;
96 case CIM_MODIFY_INSTANCE_REQUEST_MESSAGE:
97 handleModifyInstanceRequest(message);
98
99 break;
100 case CIM_DELETE_INSTANCE_REQUEST_MESSAGE:
101 handleDeleteInstanceRequest(message);
102
103 break;
104 case CIM_EXEC_QUERY_REQUEST_MESSAGE:
105 handleExecQueryRequest(message);
106
107 break;
108 case CIM_ASSOCIATORS_REQUEST_MESSAGE:
109 handleAssociatorsRequest(message);
110
111 break;
112 case CIM_ASSOCIATOR_NAMES_REQUEST_MESSAGE:
113 handleAssociatorNamesRequest(message);
114 mday 1.3
115 break;
116 case CIM_REFERENCES_REQUEST_MESSAGE:
117 handleReferencesRequest(message);
118
119 break;
120 case CIM_REFERENCE_NAMES_REQUEST_MESSAGE:
121 handleRefereceNamesRequest(message);
122
123 break;
124 case CIM_GET_PROPERTY_REQUEST_MESSAGE:
125 handleGetPropertyRequest(message);
126
127 break;
128 case CIM_SET_PROPERTY_REQUEST_MESSAGE:
129 handleSetPropertyRequest(message);
130
131 break;
132 case CIM_GET_QUALIFIER_REQUEST_MESSAGE:
133 handleGetQualifierRequest(message);
134
135 mday 1.3 break;
136 case CIM_SET_QUALIFIER_REQUEST_MESSAGE:
137 handleSetQualifierRequest(message);
138
139 break;
140 case CIM_DELETE_QUALIFIER_REQUEST_MESSAGE:
141 handleDeleteQualifierRequest(message);
142
143 break;
144 case CIM_ENUMERATE_QUALIFIERS_REQUEST_MESSAGE:
145 handleEnumerateQualifiersRequest(message);
146
147 break;
148 case CIM_INVOKE_METHOD_REQUEST_MESSAGE:
149 handleInvokeMethodRequest(message);
150
151 break;
152 default:
153 break;
154 }
|
155 chip 1.1
|
156 mday 1.3 delete message;
157 }
|
158 chip 1.1
159
|
160 mday 1.3 void RepositoryQueue::handleEnqueue(void)
161 {
162 Message * message = dequeue();
|
163 chip 1.1
|
164 mday 1.3 PEGASUS_ASSERT(message != 0);
165 if(message)
166 handleEnqueue(message);
167
|
168 chip 1.1
169 }
170
171 void RepositoryQueue::handleGetClassRequest(const Message * message)
172 {
173 }
174
175 void RepositoryQueue::handleEnumerateClassesRequest(const Message * message)
176 {
177 }
178
179 void RepositoryQueue::handleEnumerateClassNamesRequest(const Message * message)
180 {
181 }
182
183 void RepositoryQueue::handleCreateClassRequest(const Message * message)
184 {
185 }
186
187 void RepositoryQueue::handleModifyClassRequest(const Message * message)
188 {
189 chip 1.1 }
190
191 void RepositoryQueue::handleDeleteClassRequest(const Message * message)
192 {
193 }
194
195 void RepositoryQueue::handleGetInstanceRequest(const Message * message)
196 {
197 }
198
199 void RepositoryQueue::handleEnumerateInstancesRequest(const Message * message)
200 {
201 }
202
203 void RepositoryQueue::handleEnumerateInstanceNamesRequest(const Message * message)
204 {
205 }
206
207 void RepositoryQueue::handleCreateInstanceRequest(const Message * message)
208 {
209 }
210 chip 1.1
211 void RepositoryQueue::handleModifyInstanceRequest(const Message * message)
212 {
213 }
214
215 void RepositoryQueue::handleDeleteInstanceRequest(const Message * message)
216 {
217 }
218
219 void RepositoryQueue::handleGetPropertyRequest(const Message * message)
220 {
221 }
222
223 void RepositoryQueue::handleSetPropertyRequest(const Message * message)
224 {
225 }
226
227 void RepositoryQueue::handleAssociatorsRequest(const Message * message)
228 {
229 }
230
231 chip 1.1 void RepositoryQueue::handleAssociatorNamesRequest(const Message * message)
232 {
233 }
234
235 void RepositoryQueue::handleReferencesRequest(const Message * message)
236 {
237 }
238
239 void RepositoryQueue::handleReferenceNamesRequest(const Message * message)
240 {
241 }
242
243 void RepositoryQueue::handleGetQualifier(const Message * message)
244 {
245 }
246
247 void RepositoryQueue::handleEnumerateQualifiers(const Message * message)
248 {
249 }
250
251 void RepositoryQueue::handleSetQualifier(const Message * message)
252 chip 1.1 {
253 }
254
255 void RepositoryQueue::handleEnumerateNameSpacesRequest(const Message * message)
256 {
257 }
258
259 void RepositoryQueue::handleCreateNameSpaceRequest(const Message * message)
260 {
261 }
262
263 void RepositoryQueue::handleModifyNameSpaceRequest(const Message * message)
264 {
265 }
266
267 void RepositoryQueue::handleDeleteNameSpaceRequest(const Message * message)
268 {
269 }
270
271 PEGASUS_NAMESPACE_END
|