1 chip  1.1 //%/////////////////////////////////////////////////////////////////////////////
  2           //

  3 kumpf 1.4 // Copyright (c) 2000, 2001, 2002 BMC Software, Hewlett-Packard Company, IBM,
  4           // The Open Group, Tivoli Systems

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

 12 kumpf 1.4 // 

 13 chip  1.1 // THE ABOVE COPYRIGHT NOTICE AND THIS PERMISSION NOTICE SHALL BE INCLUDED IN
 14           // ALL COPIES OR SUBSTANTIAL PORTIONS OF THE SOFTWARE. THE SOFTWARE IS PROVIDED
 15           // "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT
 16           // LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR
 17           // PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT
 18           // HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
 19           // ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
 20           // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 21           //
 22           //==============================================================================
 23           //
 24           // Author: Chip Vincent (cvincent@us.ibm.com)
 25           //
 26           // Modified By:
 27           //
 28           //%/////////////////////////////////////////////////////////////////////////////
 29           
 30           #include "RepositoryQueue.h"
 31           
 32           PEGASUS_NAMESPACE_BEGIN
 33           
 34 chip  1.1 RepositoryQueue::RepositoryQueue(void)

 35 mday  1.2    Base("RepositoryQueue", MessageQueue::getNextQueueId())

 36 chip  1.1 {

 37 mday  1.2 

 38 chip  1.1 }
 39           
 40           RepositoryQueue::~RepositoryQueue(void)
 41           {
 42           }
 43           

 44 mday  1.3 
 45           void RepositoryQueue::handleEnqueue(Message *message)

 46 chip  1.1 {

 47 mday  1.3    if( ! message )
 48                 return;
 49              
 50              switch(message->getType())
 51              {
 52                 case CIM_GET_CLASS_REQUEST_MESSAGE:
 53           	 handleGetClassRequest(message);
 54           
 55           	 break;
 56                 case CIM_ENUMERATE_CLASSES_REQUEST_MESSAGE:
 57           	 handleEnumerateClassesRequest(message);
 58           
 59           	 break;
 60                 case CIM_ENUMERATE_CLASS_NAMES_REQUEST_MESSAGE:
 61           	 handleEnumerateClassNamesRequest(message);
 62           
 63           	 break;
 64                 case CIM_CREATE_CLASS_REQUEST_MESSAGE:
 65           	 handleCreateClassRequest(message);
 66           
 67           	 break;
 68 mday  1.3       case CIM_MODIFY_CLASS_REQUEST_MESSAGE:
 69           	 handleModifyClassRequest(message);
 70           
 71           	 break;
 72                 case CIM_DELETE_CLASS_REQUEST_MESSAGE:
 73           	 handleDeleteClassRequest(message);
 74           
 75           	 break;
 76                 case CIM_GET_INSTANCE_REQUEST_MESSAGE:
 77           	 handleGetInstanceRequest(message);
 78           
 79           	 break;
 80                 case CIM_ENUMERATE_INSTANCES_REQUEST_MESSAGE:
 81           	 handleEnumerateInstancesRequest(message);
 82           
 83           	 break;
 84                 case CIM_ENUMERATE_INSTANCE_NAMES_REQUEST_MESSAGE:
 85           	 handleEnumerateInstanceNamesRequest(message);
 86           
 87           	 break;
 88                 case CIM_CREATE_INSTANCE_REQUEST_MESSAGE:
 89 mday  1.3 	 handleCreateInstanceRequest(message);
 90           
 91           	 break;
 92                 case CIM_MODIFY_INSTANCE_REQUEST_MESSAGE:
 93           	 handleModifyInstanceRequest(message);
 94           
 95           	 break;
 96                 case CIM_DELETE_INSTANCE_REQUEST_MESSAGE:
 97           	 handleDeleteInstanceRequest(message);
 98           
 99           	 break;
100                 case CIM_EXEC_QUERY_REQUEST_MESSAGE:
101           	 handleExecQueryRequest(message);
102           
103           	 break;
104                 case CIM_ASSOCIATORS_REQUEST_MESSAGE:
105           	 handleAssociatorsRequest(message);
106           
107           	 break;
108                 case CIM_ASSOCIATOR_NAMES_REQUEST_MESSAGE:
109           	 handleAssociatorNamesRequest(message);
110 mday  1.3 
111           	 break;
112                 case CIM_REFERENCES_REQUEST_MESSAGE:
113           	 handleReferencesRequest(message);
114           
115           	 break;
116                 case CIM_REFERENCE_NAMES_REQUEST_MESSAGE:
117           	 handleRefereceNamesRequest(message);
118           
119           	 break;
120                 case CIM_GET_PROPERTY_REQUEST_MESSAGE:
121           	 handleGetPropertyRequest(message);
122           
123           	 break;
124                 case CIM_SET_PROPERTY_REQUEST_MESSAGE:
125           	 handleSetPropertyRequest(message);
126           
127           	 break;
128                 case CIM_GET_QUALIFIER_REQUEST_MESSAGE:
129           	 handleGetQualifierRequest(message);
130           
131 mday  1.3 	 break;
132                 case CIM_SET_QUALIFIER_REQUEST_MESSAGE:
133           	 handleSetQualifierRequest(message);
134           
135           	 break;
136                 case CIM_DELETE_QUALIFIER_REQUEST_MESSAGE:
137           	 handleDeleteQualifierRequest(message);
138           
139           	 break;
140                 case CIM_ENUMERATE_QUALIFIERS_REQUEST_MESSAGE:
141           	 handleEnumerateQualifiersRequest(message);
142           
143           	 break;
144                 case CIM_INVOKE_METHOD_REQUEST_MESSAGE:
145           	 handleInvokeMethodRequest(message);
146           
147           	 break;
148                 default:
149           	 break;
150              }

151 chip  1.1 

152 mday  1.3    delete message;
153           }

154 chip  1.1 
155           

156 mday  1.3 void RepositoryQueue::handleEnqueue(void)
157           {
158              Message * message = dequeue();

159 chip  1.1 

160 mday  1.3    PEGASUS_ASSERT(message != 0);
161              if(message)
162                 handleEnqueue(message);
163           	

164 chip  1.1 
165           }
166           
167           void RepositoryQueue::handleGetClassRequest(const Message * message)
168           {
169           }
170           
171           void RepositoryQueue::handleEnumerateClassesRequest(const Message * message)
172           {
173           }
174           
175           void RepositoryQueue::handleEnumerateClassNamesRequest(const Message * message)
176           {
177           }
178           
179           void RepositoryQueue::handleCreateClassRequest(const Message * message)
180           {
181           }
182           
183           void RepositoryQueue::handleModifyClassRequest(const Message * message)
184           {
185 chip  1.1 }
186           
187           void RepositoryQueue::handleDeleteClassRequest(const Message * message)
188           {
189           }
190           
191           void RepositoryQueue::handleGetInstanceRequest(const Message * message)
192           {
193           }
194           
195           void RepositoryQueue::handleEnumerateInstancesRequest(const Message * message)
196           {
197           }
198           
199           void RepositoryQueue::handleEnumerateInstanceNamesRequest(const Message * message)
200           {
201           }
202           
203           void RepositoryQueue::handleCreateInstanceRequest(const Message * message)
204           {
205           }
206 chip  1.1 
207           void RepositoryQueue::handleModifyInstanceRequest(const Message * message)
208           {
209           }
210           
211           void RepositoryQueue::handleDeleteInstanceRequest(const Message * message)
212           {
213           }
214           
215           void RepositoryQueue::handleGetPropertyRequest(const Message * message)
216           {
217           }
218           
219           void RepositoryQueue::handleSetPropertyRequest(const Message * message)
220           {
221           }
222           
223           void RepositoryQueue::handleAssociatorsRequest(const Message * message)
224           {
225           }
226           
227 chip  1.1 void RepositoryQueue::handleAssociatorNamesRequest(const Message * message)
228           {
229           }
230           
231           void RepositoryQueue::handleReferencesRequest(const Message * message)
232           {
233           }
234           
235           void RepositoryQueue::handleReferenceNamesRequest(const Message * message)
236           {
237           }
238           
239           void RepositoryQueue::handleGetQualifier(const Message * message)
240           {
241           }
242           
243           void RepositoryQueue::handleEnumerateQualifiers(const Message * message)
244           {
245           }
246           
247           void RepositoryQueue::handleSetQualifier(const Message * message)
248 chip  1.1 {
249           }
250           
251           void RepositoryQueue::handleEnumerateNameSpacesRequest(const Message * message)
252           {
253           }
254           
255           void RepositoryQueue::handleCreateNameSpaceRequest(const Message * message)
256           {
257           }
258           
259           void RepositoryQueue::handleModifyNameSpaceRequest(const Message * message)
260           {
261           }
262           
263           void RepositoryQueue::handleDeleteNameSpaceRequest(const Message * message)
264           {
265           }
266           
267           PEGASUS_NAMESPACE_END