1 karl 1.59 //%2006////////////////////////////////////////////////////////////////////////
|
2 chip 1.1 //
|
3 karl 1.43 // 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.7 // IBM Corp.; EMC Corporation, The Open Group.
|
7 karl 1.43 // 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.47 // Copyright (c) 2005 Hewlett-Packard Development Company, L.P.; IBM Corp.;
10 // EMC Corporation; VERITAS Software Corporation; The Open Group.
|
11 karl 1.59 // Copyright (c) 2006 Hewlett-Packard Development Company, L.P.; IBM Corp.;
12 // EMC Corporation; Symantec Corporation; The Open Group.
|
13 chip 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.43 //
|
21 chip 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 // Author: Chip Vincent (cvincent@us.ibm.com)
33 //
34 // Modified By: Carol Ann Krug Graves, Hewlett-Packard Company
35 // (carolann_graves@hp.com)
36 // Mike Day, IBM (mdday@us.ibm.com)
37 // Karl Schopmeyer(k.schopmeyer@opengroup.org) - Fix associators.
|
38 kumpf 1.28 // Yi Zhou, Hewlett-Packard Company (yi_zhou@hp.com)
|
39 kumpf 1.31 // Roger Kumpf, Hewlett-Packard Company (roger_kumpf@hp.com)
|
40 carolann.graves 1.49 // Seema Gupta (gseema@in.ibm.com) for PEP135
41 // Willis White (whiwill@us.ibm.com)
42 // Josephine Eskaline Joyce (jojustin@in.ibm.com) for PEP#101
|
43 chip 1.1 //
44 //%/////////////////////////////////////////////////////////////////////////////
45
46 #include "DefaultProviderManager.h"
47
48 #include <Pegasus/Common/CIMMessage.h>
49 #include <Pegasus/Common/OperationContext.h>
50 #include <Pegasus/Common/Tracer.h>
51 #include <Pegasus/Common/StatisticalData.h>
52 #include <Pegasus/Common/Logger.h>
53 #include <Pegasus/Common/MessageLoader.h> //l10n
|
54 kumpf 1.38 #include <Pegasus/Common/Constants.h>
|
55 chip 1.1
|
56 chuck 1.44 #include <Pegasus/Query/QueryExpression/QueryExpression.h>
|
57 schuur 1.12 #include <Pegasus/ProviderManager2/QueryExpressionFactory.h>
58
|
59 chip 1.1 #include <Pegasus/ProviderManager2/Default/Provider.h>
|
60 schuur 1.21 #include <Pegasus/ProviderManager2/OperationResponseHandler.h>
|
61 chip 1.1
|
62 schuur 1.14 #include <Pegasus/ProviderManager2/ProviderManagerService.h>
|
63 kumpf 1.28 #include <Pegasus/ProviderManager2/ProviderType.h>
|
64 chip 1.1
|
65 a.dunfey 1.58 #define HandleCatch(handler) \
66 catch(CIMException & e) \
67 { \
68 PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4, \
69 "Exception: " + e.getMessage()); \
70 handler.setStatus(e.getCode(), e.getContentLanguages(), e.getMessage()); \
71 } \
72 catch(Exception & e) \
73 { \
74 PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4, \
75 "Exception: " + e.getMessage()); \
76 handler.setStatus(CIM_ERR_FAILED, e.getContentLanguages(), e.getMessage());\
77 } \
78 catch(...) \
79 { \
80 PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4, \
81 "Exception: Unknown"); \
82 handler.setStatus(CIM_ERR_FAILED, "Unknown error."); \
83 } \
|
84 a.dunfey 1.60 STAT_RESPONSEEND
|
85 a.dunfey 1.58
86
|
87 chip 1.1 PEGASUS_NAMESPACE_BEGIN
88
89 // auto variable to protect provider during operations
90 class pm_service_op_lock
91 {
92 private:
93 pm_service_op_lock(void);
94
95 public:
96 pm_service_op_lock(Provider *provider) : _provider(provider)
97 {
98 _provider->protect();
99 }
100
101 ~pm_service_op_lock(void)
102 {
103 _provider->unprotect();
104 }
105
106 Provider * _provider;
107 };
108 chip 1.1
109 //
|
110 kumpf 1.31 // Default Provider Manager
111 //
|
112 chip 1.1 DefaultProviderManager::DefaultProviderManager(void)
113 {
|
114 carolann.graves 1.49 _subscriptionInitComplete = false;
|
115 chip 1.1 }
116
117 DefaultProviderManager::~DefaultProviderManager(void)
118 {
119 }
120
|
121 dj.gorey 1.25 Message * DefaultProviderManager::processMessage(Message * request)
|
122 chip 1.1 {
123 PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,
124 "DefaultProviderManager::processMessage()");
125
126 Message * response = 0;
127
128 // pass the request message to a handler method based on message type
129 switch(request->getType())
130 {
131 case CIM_GET_INSTANCE_REQUEST_MESSAGE:
|
132 dj.gorey 1.25 response = handleGetInstanceRequest(request);
|
133 chip 1.1
134 break;
135 case CIM_ENUMERATE_INSTANCES_REQUEST_MESSAGE:
|
136 dj.gorey 1.25 response = handleEnumerateInstancesRequest(request);
|
137 chip 1.1
138 break;
139 case CIM_ENUMERATE_INSTANCE_NAMES_REQUEST_MESSAGE:
|
140 dj.gorey 1.25 response = handleEnumerateInstanceNamesRequest(request);
|
141 chip 1.1
142 break;
143 case CIM_CREATE_INSTANCE_REQUEST_MESSAGE:
|
144 dj.gorey 1.25 response = handleCreateInstanceRequest(request);
|
145 chip 1.1
146 break;
147 case CIM_MODIFY_INSTANCE_REQUEST_MESSAGE:
|
148 dj.gorey 1.25 response = handleModifyInstanceRequest(request);
|
149 chip 1.1
150 break;
151 case CIM_DELETE_INSTANCE_REQUEST_MESSAGE:
|
152 dj.gorey 1.25 response = handleDeleteInstanceRequest(request);
|
153 chip 1.1
154 break;
155 case CIM_EXEC_QUERY_REQUEST_MESSAGE:
|
156 dj.gorey 1.25 response = handleExecQueryRequest(request);
|
157 chip 1.1
158 break;
159 case CIM_ASSOCIATORS_REQUEST_MESSAGE:
|
160 dj.gorey 1.25 response = handleAssociatorsRequest(request);
|
161 chip 1.1
162 break;
163 case CIM_ASSOCIATOR_NAMES_REQUEST_MESSAGE:
|
164 dj.gorey 1.25 response = handleAssociatorNamesRequest(request);
|
165 chip 1.1
166 break;
167 case CIM_REFERENCES_REQUEST_MESSAGE:
|
168 dj.gorey 1.25 response = handleReferencesRequest(request);
|
169 chip 1.1
170 break;
171 case CIM_REFERENCE_NAMES_REQUEST_MESSAGE:
|
172 dj.gorey 1.25 response = handleReferenceNamesRequest(request);
|
173 chip 1.1
174 break;
175 case CIM_GET_PROPERTY_REQUEST_MESSAGE:
|
176 dj.gorey 1.25 response = handleGetPropertyRequest(request);
|
177 chip 1.1
178 break;
179 case CIM_SET_PROPERTY_REQUEST_MESSAGE:
|
180 dj.gorey 1.25 response = handleSetPropertyRequest(request);
|
181 chip 1.1
182 break;
183 case CIM_INVOKE_METHOD_REQUEST_MESSAGE:
|
184 dj.gorey 1.25 response = handleInvokeMethodRequest(request);
|
185 chip 1.1
186 break;
187 case CIM_CREATE_SUBSCRIPTION_REQUEST_MESSAGE:
|
188 dj.gorey 1.25 response = handleCreateSubscriptionRequest(request);
|
189 chip 1.1
190 break;
191 case CIM_MODIFY_SUBSCRIPTION_REQUEST_MESSAGE:
|
192 dj.gorey 1.25 response = handleModifySubscriptionRequest(request);
|
193 chip 1.1
194 break;
195 case CIM_DELETE_SUBSCRIPTION_REQUEST_MESSAGE:
|
196 dj.gorey 1.25 response = handleDeleteSubscriptionRequest(request);
|
197 chip 1.1
198 break;
|
199 schuur 1.14 case CIM_EXPORT_INDICATION_REQUEST_MESSAGE:
|
200 dj.gorey 1.25 response = handleExportIndicationRequest(request);
|
201 schuur 1.14 break;
202
|
203 chip 1.1 case CIM_DISABLE_MODULE_REQUEST_MESSAGE:
|
204 dj.gorey 1.25 response = handleDisableModuleRequest(request);
|
205 chip 1.1
206 break;
207 case CIM_ENABLE_MODULE_REQUEST_MESSAGE:
|
208 dj.gorey 1.25 response = handleEnableModuleRequest(request);
|
209 chip 1.1
210 break;
211 case CIM_STOP_ALL_PROVIDERS_REQUEST_MESSAGE:
|
212 dj.gorey 1.25 response = handleStopAllProvidersRequest(request);
|
213 chip 1.1
214 break;
|
215 kumpf 1.30 case CIM_INITIALIZE_PROVIDER_REQUEST_MESSAGE:
216 response = handleInitializeProviderRequest(request);
217
218 break;
|
219 carolann.graves 1.49 case CIM_SUBSCRIPTION_INIT_COMPLETE_REQUEST_MESSAGE:
220 response = handleSubscriptionInitCompleteRequest (request);
221
222 break;
|
223 chip 1.1 default:
|
224 dj.gorey 1.25 response = handleUnsupportedRequest(request);
|
225 chip 1.1
226 break;
227 }
228
229 PEG_METHOD_EXIT();
230
231 return(response);
232 }
233
|
234 dj.gorey 1.25 Message * DefaultProviderManager::handleUnsupportedRequest(const Message * message)
|
235 chip 1.1 {
236 PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleUnsupportedRequest");
237
238 PEG_METHOD_EXIT();
239
240 // a null response implies unsupported or unknown operation
241 return(0);
242 }
243
|
244 kumpf 1.30 Message * DefaultProviderManager::handleInitializeProviderRequest(
245 const Message * message)
246 {
247 PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,
248 "DefaultProviderManager::handleInitializeProviderRequest");
249
250 CIMInitializeProviderRequestMessage * request =
251 dynamic_cast<CIMInitializeProviderRequestMessage *>
252 (const_cast<Message *>(message));
253
254 PEGASUS_ASSERT(request != 0);
255
|
256 kumpf 1.54 CIMInitializeProviderResponseMessage* response =
257 dynamic_cast<CIMInitializeProviderResponseMessage*>(
258 request->buildResponse());
259 PEGASUS_ASSERT(response != 0);
|
260 kumpf 1.30
|
261 kumpf 1.62 OperationResponseHandler handler(
262 request, response, _responseChunkCallback);
|
263 kumpf 1.30
264 try
265 {
266 // resolve provider name
267 ProviderName name = _resolveProviderName(
268 request->operationContext.get(ProviderIdContainer::NAME));
269
270 // get cached or load new provider module
|
271 kumpf 1.50 OpProviderHolder ph = providerManager.getProvider(
272 name.getPhysicalName(), name.getLogicalName());
|
273 kumpf 1.30 }
274 catch(CIMException & e)
275 {
276 PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL3,
277 "CIMException: " + e.getMessage());
278
279 handler.setStatus(e.getCode(), e.getContentLanguages(), e.getMessage());
280 }
281 catch(Exception & e)
282 {
283 PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL3,
284 "Exception: " + e.getMessage());
285
286 handler.setStatus(CIM_ERR_FAILED, e.getContentLanguages(), e.getMessage());
287 }
288 catch(...)
289 {
290 PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL3,
291 "Exception: Unknown");
292
293 handler.setStatus(CIM_ERR_FAILED, "Unknown error.");
294 kumpf 1.30 }
295
296 PEG_METHOD_EXIT();
297
298 return(response);
299 }
300
|
301 dj.gorey 1.25 Message * DefaultProviderManager::handleGetInstanceRequest(const Message * message)
|
302 chip 1.1 {
303 PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleGetInstanceRequest");
304
305 CIMGetInstanceRequestMessage * request =
306 dynamic_cast<CIMGetInstanceRequestMessage *>(const_cast<Message *>(message));
307
308 PEGASUS_ASSERT(request != 0);
309
|
310 kumpf 1.54 CIMGetInstanceResponseMessage* response =
311 dynamic_cast<CIMGetInstanceResponseMessage*>(
312 request->buildResponse());
|
313 chip 1.1 PEGASUS_ASSERT(response != 0);
314
315 // create a handler for this request
|
316 kumpf 1.62 GetInstanceResponseHandler handler(
317 request, response, _responseChunkCallback);
|
318 chip 1.1
319 try
320 {
321 Logger::put(Logger::STANDARD_LOG, System::CIMSERVER, Logger::TRACE,
322 "DefaultProviderManager::handleGetInstanceRequest - Host name: $0 Name space: $1 Class name: $2",
323 System::getHostName(),
324 request->nameSpace.getString(),
325 request->instanceName.getClassName().getString());
326
327 // make target object path
328 CIMObjectPath objectPath(
329 System::getHostName(),
330 request->nameSpace,
331 request->instanceName.getClassName(),
332 request->instanceName.getKeyBindings());
333
|
334 chip 1.5 // resolve provider name
|
335 kumpf 1.28 ProviderName name = _resolveProviderName(
336 request->operationContext.get(ProviderIdContainer::NAME));
|
337 chip 1.1
338 // get cached or load new provider module
|
339 kumpf 1.50 OpProviderHolder ph = providerManager.getProvider(
340 name.getPhysicalName(), name.getLogicalName());
|
341 chip 1.1
342 // convert arguments
343 OperationContext context;
344
|
345 se.gupta 1.34 context.insert(request->operationContext.get(IdentityContainer::NAME));
346 context.insert(request->operationContext.get(AcceptLanguageListContainer::NAME));
347 context.insert(request->operationContext.get(ContentLanguageListContainer::NAME));
|
348 chip 1.1
349 CIMPropertyList propertyList(request->propertyList);
350
351 // forward request
352 PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,
353 "Calling provider.getInstance: " +
354 ph.GetProvider().getName());
355
356 pm_service_op_lock op_lock(&ph.GetProvider());
357
|
358 a.dunfey 1.58 STAT_PMS_PROVIDERSTART;
|
359 chip 1.1
360 ph.GetProvider().getInstance(
361 context,
362 objectPath,
363 request->includeQualifiers,
364 request->includeClassOrigin,
365 propertyList,
366 handler);
367 }
|
368 a.dunfey 1.58 HandleCatch(handler);
|
369 chip 1.1
370 PEG_METHOD_EXIT();
371
|
372 w.white 1.53 STAT_COPYDISPATCHER
373
|
374 chip 1.1 return(response);
375 }
376
|
377 dj.gorey 1.25 Message * DefaultProviderManager::handleEnumerateInstancesRequest(const Message * message)
|
378 chip 1.1 {
379 PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleEnumerateInstanceRequest");
380
381 CIMEnumerateInstancesRequestMessage * request =
382 dynamic_cast<CIMEnumerateInstancesRequestMessage *>(const_cast<Message *>(message));
383
384 PEGASUS_ASSERT(request != 0);
385
|
386 kumpf 1.54 CIMEnumerateInstancesResponseMessage* response =
387 dynamic_cast<CIMEnumerateInstancesResponseMessage*>(
388 request->buildResponse());
|
389 chip 1.1 PEGASUS_ASSERT(response != 0);
390
391 // create a handler for this request
|
392 kumpf 1.62 EnumerateInstancesResponseHandler handler(
393 request, response, _responseChunkCallback);
|
394 chip 1.1
395 try
396 {
|
397 mike 1.56 PEG_LOGGER_TRACE((Logger::STANDARD_LOG, System::CIMSERVER,
398 Logger::TRACE,
399 "DefaultProviderManager::handleEnumerateInstancesRequest - "
400 "Host name: $0 Name space: $1 Class name: $2",
|
401 chip 1.1 System::getHostName(),
402 request->nameSpace.getString(),
|
403 mike 1.56 request->className.getString()));
|
404 chip 1.1
405 // make target object path
406 CIMObjectPath objectPath(
407 System::getHostName(),
408 request->nameSpace,
409 request->className);
410
|
411 chip 1.5 // resolve provider name
|
412 kumpf 1.28 ProviderName name = _resolveProviderName(
413 request->operationContext.get(ProviderIdContainer::NAME));
|
414 chip 1.1
415 // get cached or load new provider module
|
416 kumpf 1.50 OpProviderHolder ph = providerManager.getProvider(
417 name.getPhysicalName(), name.getLogicalName());
|
418 chip 1.1
419 // convert arguments
420 OperationContext context;
421
|
422 se.gupta 1.34 context.insert(request->operationContext.get(IdentityContainer::NAME));
423 context.insert(request->operationContext.get(AcceptLanguageListContainer::NAME));
424 context.insert(request->operationContext.get(ContentLanguageListContainer::NAME));
|
425 chip 1.1
426 CIMPropertyList propertyList(request->propertyList);
427
428 // forward request
429 PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,
430 "Calling provider.enumerateInstances: " +
431 ph.GetProvider().getName());
432
433 pm_service_op_lock op_lock(&ph.GetProvider());
434
|
435 a.dunfey 1.58 STAT_PMS_PROVIDERSTART;
|
436 chip 1.1
437 ph.GetProvider().enumerateInstances(
438 context,
439 objectPath,
440 request->includeQualifiers,
441 request->includeClassOrigin,
442 propertyList,
443 handler);
444 }
|
445 a.dunfey 1.58 HandleCatch(handler);
|
446 chip 1.1
447 PEG_METHOD_EXIT();
448
|
449 w.white 1.53 STAT_COPYDISPATCHER
450
|
451 chip 1.1 return(response);
452 }
453
|
454 dj.gorey 1.25 Message * DefaultProviderManager::handleEnumerateInstanceNamesRequest(const Message * message)
|
455 chip 1.1 {
456 PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleEnumerateInstanceNamesRequest");
457
458 CIMEnumerateInstanceNamesRequestMessage * request =
459 dynamic_cast<CIMEnumerateInstanceNamesRequestMessage *>(const_cast<Message *>(message));
460
461 PEGASUS_ASSERT(request != 0);
462
|
463 kumpf 1.54 CIMEnumerateInstanceNamesResponseMessage* response =
464 dynamic_cast<CIMEnumerateInstanceNamesResponseMessage*>(
465 request->buildResponse());
|
466 chip 1.1 PEGASUS_ASSERT(response != 0);
467
468 // create a handler for this request
|
469 kumpf 1.62 EnumerateInstanceNamesResponseHandler handler(
470 request, response, _responseChunkCallback);
|
471 chip 1.1
472 // process the request
473 try
474 {
|
475 mike 1.56 PEG_LOGGER_TRACE((Logger::STANDARD_LOG, System::CIMSERVER,
476 Logger::TRACE,
477 "DefaultProviderManager::handleEnumerateInstanceNamesRequest - "
478 "Host name: $0 Name space: $1 Class name: $2",
|
479 chip 1.1 System::getHostName(),
480 request->nameSpace.getString(),
|
481 mike 1.56 request->className.getString()));
|
482 chip 1.1
483 // make target object path
484 CIMObjectPath objectPath(
485 System::getHostName(),
486 request->nameSpace,
487 request->className);
488
|
489 chip 1.5 // resolve provider name
|
490 kumpf 1.28 ProviderName name = _resolveProviderName(
491 request->operationContext.get(ProviderIdContainer::NAME));
|
492 chip 1.1
493 // get cached or load new provider module
|
494 kumpf 1.50 OpProviderHolder ph = providerManager.getProvider(
495 name.getPhysicalName(), name.getLogicalName());
|
496 chip 1.1
497 // convert arguments
498 OperationContext context;
499
|
500 se.gupta 1.34 context.insert(request->operationContext.get(IdentityContainer::NAME));
501 context.insert(request->operationContext.get(AcceptLanguageListContainer::NAME));
502 context.insert(request->operationContext.get(ContentLanguageListContainer::NAME));
503
|
504 chip 1.1 // forward request
505 PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,
506 "Calling provider.enumerateInstanceNames: " +
507 ph.GetProvider().getName());
508
509 pm_service_op_lock op_lock(&ph.GetProvider());
510
|
511 a.dunfey 1.58 STAT_PMS_PROVIDERSTART;
|
512 chip 1.1
513 ph.GetProvider().enumerateInstanceNames(
514 context,
515 objectPath,
516 handler);
517 }
|
518 a.dunfey 1.58 HandleCatch(handler);
|
519 chip 1.1
520 PEG_METHOD_EXIT();
521
|
522 w.white 1.53 STAT_COPYDISPATCHER
523
|
524 chip 1.1 return(response);
525 }
526
|
527 dj.gorey 1.25 Message * DefaultProviderManager::handleCreateInstanceRequest(const Message * message)
|
528 chip 1.1 {
529 PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleCreateInstanceRequest");
530
531 CIMCreateInstanceRequestMessage * request =
532 dynamic_cast<CIMCreateInstanceRequestMessage *>(const_cast<Message *>(message));
533
534 PEGASUS_ASSERT(request != 0);
535
536 // create response message
|
537 kumpf 1.54 CIMCreateInstanceResponseMessage* response =
538 dynamic_cast<CIMCreateInstanceResponseMessage*>(
539 request->buildResponse());
|
540 chip 1.1 PEGASUS_ASSERT(response != 0);
541
542 // create a handler for this request
|
543 kumpf 1.62 CreateInstanceResponseHandler handler(
544 request, response, _responseChunkCallback);
|
545 chip 1.1
546 try
547 {
|
548 mike 1.56 PEG_LOGGER_TRACE((Logger::STANDARD_LOG, System::CIMSERVER,
549 Logger::TRACE,
550 "DefaultProviderManager::handleCreateInstanceRequest - "
551 "Host name: $0 Name space: $1 Class name: $2",
|
552 chip 1.1 System::getHostName(),
553 request->nameSpace.getString(),
|
554 mike 1.56 request->newInstance.getPath().getClassName().getString()));
|
555 chip 1.1
556 // make target object path
557 CIMObjectPath objectPath(
558 System::getHostName(),
559 request->nameSpace,
560 request->newInstance.getPath().getClassName(),
561 request->newInstance.getPath().getKeyBindings());
562
|
563 chip 1.5 // resolve provider name
|
564 kumpf 1.28 ProviderName name = _resolveProviderName(
565 request->operationContext.get(ProviderIdContainer::NAME));
|
566 chip 1.1
567 // get cached or load new provider module
|
568 kumpf 1.50 OpProviderHolder ph = providerManager.getProvider(
569 name.getPhysicalName(), name.getLogicalName());
|
570 chip 1.1
571 // convert arguments
572 OperationContext context;
573
|
574 se.gupta 1.34 context.insert(request->operationContext.get(IdentityContainer::NAME));
575 context.insert(request->operationContext.get(AcceptLanguageListContainer::NAME));
576 context.insert(request->operationContext.get(ContentLanguageListContainer::NAME));
|
577 chip 1.1
578 // forward request
579 PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,
580 "Calling provider.createInstance: " +
581 ph.GetProvider().getName());
582
583 pm_service_op_lock op_lock(&ph.GetProvider());
584
|
585 a.dunfey 1.58 STAT_PMS_PROVIDERSTART;
|
586 chip 1.1
587 ph.GetProvider().createInstance(
588 context,
589 objectPath,
590 request->newInstance,
591 handler);
592 }
|
593 a.dunfey 1.58 HandleCatch(handler);
|
594 chip 1.1
595 PEG_METHOD_EXIT();
596
|
597 w.white 1.53 STAT_COPYDISPATCHER
598
|
599 chip 1.1 return(response);
600 }
601
|
602 dj.gorey 1.25 Message * DefaultProviderManager::handleModifyInstanceRequest(const Message * message)
|
603 chip 1.1 {
604 PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleModifyInstanceRequest");
605
606 CIMModifyInstanceRequestMessage * request =
607 dynamic_cast<CIMModifyInstanceRequestMessage *>(const_cast<Message *>(message));
608
609 PEGASUS_ASSERT(request != 0);
610
611 // create response message
|
612 kumpf 1.54 CIMModifyInstanceResponseMessage* response =
613 dynamic_cast<CIMModifyInstanceResponseMessage*>(
614 request->buildResponse());
|
615 chip 1.1 PEGASUS_ASSERT(response != 0);
616
617 // create a handler for this request
|
618 kumpf 1.62 ModifyInstanceResponseHandler handler(
619 request, response, _responseChunkCallback);
|
620 chip 1.1
621 try
622 {
|
623 mike 1.56 PEG_LOGGER_TRACE((Logger::STANDARD_LOG, System::CIMSERVER,
624 Logger::TRACE,
625 "DefaultProviderManager::handleModifyInstanceRequest - "
626 "Host name: $0 Name space: $1 Class name: $2",
|
627 chip 1.1 System::getHostName(),
628 request->nameSpace.getString(),
|
629 mike 1.56 request->modifiedInstance.getPath().getClassName().getString()));
|
630 chip 1.1
631 // make target object path
632 CIMObjectPath objectPath(
633 System::getHostName(),
634 request->nameSpace,
635 request->modifiedInstance.getPath ().getClassName(),
636 request->modifiedInstance.getPath ().getKeyBindings());
637
|
638 chip 1.5 // resolve provider name
|
639 kumpf 1.28 ProviderName name = _resolveProviderName(
640 request->operationContext.get(ProviderIdContainer::NAME));
|
641 chip 1.1
642 // get cached or load new provider module
|
643 kumpf 1.50 OpProviderHolder ph = providerManager.getProvider(
644 name.getPhysicalName(), name.getLogicalName());
|
645 chip 1.1
646 // convert arguments
647 OperationContext context;
648
|
649 se.gupta 1.34 context.insert(request->operationContext.get(IdentityContainer::NAME));
650 context.insert(request->operationContext.get(AcceptLanguageListContainer::NAME));
651 context.insert(request->operationContext.get(ContentLanguageListContainer::NAME));
|
652 chip 1.1
653 CIMPropertyList propertyList(request->propertyList);
654
655 // forward request
656 PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,
657 "Calling provider.modifyInstance: " +
658 ph.GetProvider().getName());
659
660 pm_service_op_lock op_lock(&ph.GetProvider());
661
|
662 a.dunfey 1.58 STAT_PMS_PROVIDERSTART;
|
663 chip 1.1
664 ph.GetProvider().modifyInstance(
665 context,
666 objectPath,
667 request->modifiedInstance,
668 request->includeQualifiers,
669 propertyList,
670 handler);
671 }
|
672 a.dunfey 1.58 HandleCatch(handler);
|
673 chip 1.1
674 PEG_METHOD_EXIT();
675
|
676 w.white 1.53 STAT_COPYDISPATCHER
677
|
678 chip 1.1 return(response);
679 }
680
|
681 dj.gorey 1.25 Message * DefaultProviderManager::handleDeleteInstanceRequest(const Message * message)
|
682 chip 1.1 {
683 PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleDeleteInstanceRequest");
684
685 CIMDeleteInstanceRequestMessage * request =
686 dynamic_cast<CIMDeleteInstanceRequestMessage *>(const_cast<Message *>(message));
687
688 PEGASUS_ASSERT(request != 0);
689
690 // create response message
|
691 kumpf 1.54 CIMDeleteInstanceResponseMessage* response =
692 dynamic_cast<CIMDeleteInstanceResponseMessage*>(
693 request->buildResponse());
|
694 chip 1.1 PEGASUS_ASSERT(response != 0);
695
696 // create a handler for this request
|
697 kumpf 1.62 DeleteInstanceResponseHandler handler(
698 request, response, _responseChunkCallback);
|
699 chip 1.1
700 try
701 {
|
702 mike 1.56 PEG_LOGGER_TRACE((Logger::STANDARD_LOG, System::CIMSERVER,
703 Logger::TRACE,
704 "DefaultProviderManager::handleDeleteInstanceRequest - "
705 "Host name: $0 Name space: $1 Class name: $2",
|
706 chip 1.1 System::getHostName(),
707 request->nameSpace.getString(),
|
708 mike 1.56 request->instanceName.getClassName().getString()));
|
709 chip 1.1
710 // make target object path
711 CIMObjectPath objectPath(
712 System::getHostName(),
713 request->nameSpace,
714 request->instanceName.getClassName(),
715 request->instanceName.getKeyBindings());
716
|
717 chip 1.5 // resolve provider name
|
718 kumpf 1.28 ProviderName name = _resolveProviderName(
719 request->operationContext.get(ProviderIdContainer::NAME));
|
720 chip 1.1
721 // get cached or load new provider module
|
722 kumpf 1.50 OpProviderHolder ph = providerManager.getProvider(
723 name.getPhysicalName(), name.getLogicalName());
|
724 chip 1.1
725 // convert arguments
726 OperationContext context;
727
|
728 se.gupta 1.34 context.insert(request->operationContext.get(IdentityContainer::NAME));
729 context.insert(request->operationContext.get(AcceptLanguageListContainer::NAME));
730 context.insert(request->operationContext.get(ContentLanguageListContainer::NAME));
|
731 chip 1.1
732 // forward request
733 PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,
734 "Calling provider.deleteInstance: " +
735 ph.GetProvider().getName());
736
737 pm_service_op_lock op_lock(&ph.GetProvider());
738
|
739 a.dunfey 1.58 STAT_PMS_PROVIDERSTART;
|
740 chip 1.1
741 ph.GetProvider().deleteInstance(
742 context,
743 objectPath,
744 handler);
745 }
|
746 a.dunfey 1.58 HandleCatch(handler);
|
747 chip 1.1
748 PEG_METHOD_EXIT();
749
|
750 w.white 1.53 STAT_COPYDISPATCHER
751
|
752 chip 1.1 return(response);
753 }
754
|
755 dj.gorey 1.25 Message * DefaultProviderManager::handleExecQueryRequest(const Message * message)
|
756 chip 1.1 {
|
757 schuur 1.12 PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleExecQueryRequest");
|
758 chip 1.1
759 CIMExecQueryRequestMessage * request =
760 dynamic_cast<CIMExecQueryRequestMessage *>(const_cast<Message *>(message));
761
762 PEGASUS_ASSERT(request != 0);
763
|
764 kumpf 1.54 CIMExecQueryResponseMessage* response =
765 dynamic_cast<CIMExecQueryResponseMessage*>(
766 request->buildResponse());
|
767 chip 1.1 PEGASUS_ASSERT(response != 0);
768
|
769 schuur 1.12 // create a handler for this request
|
770 kumpf 1.62 ExecQueryResponseHandler handler(
771 request, response, _responseChunkCallback);
|
772 schuur 1.12
773 try
774 {
|
775 mike 1.56 PEG_LOGGER_TRACE((Logger::STANDARD_LOG, System::CIMSERVER,
776 Logger::TRACE,
777 "DefaultProviderManager::handleExecQueryRequest - "
778 "Host name: $0 Name space: $1 Class name: $2",
|
779 schuur 1.12 System::getHostName(),
780 request->nameSpace.getString(),
|
781 mike 1.56 request->className.getString()));
|
782 schuur 1.12
783 // make target object path
784 CIMObjectPath objectPath(
785 System::getHostName(),
786 request->nameSpace,
787 request->className);
788
789 // resolve provider name
|
790 kumpf 1.28 ProviderName name = _resolveProviderName(
791 request->operationContext.get(ProviderIdContainer::NAME));
|
792 schuur 1.12
793 // get cached or load new provider module
|
794 kumpf 1.50 OpProviderHolder ph = providerManager.getProvider(
795 name.getPhysicalName(), name.getLogicalName());
|
796 schuur 1.12
797 if (dynamic_cast<CIMInstanceQueryProvider*>(ph.GetCIMProvider()) == 0) {
798 String errorString = " instance provider is registered supporting execQuery "
|
799 dj.gorey 1.25 "but is not a CIMQueryInstanceProvider subclass.";
|
800 schuur 1.12 throw CIMException(CIM_ERR_FAILED,"ProviderLoadFailure (" + name.getPhysicalName() + ":" +
|
801 dj.gorey 1.25 name.getLogicalName() + "):" + errorString);
|
802 schuur 1.12 }
803
804 // convert arguments
805 OperationContext context;
806
|
807 se.gupta 1.34 context.insert(request->operationContext.get(IdentityContainer::NAME));
808 context.insert(request->operationContext.get(AcceptLanguageListContainer::NAME));
809 context.insert(request->operationContext.get(ContentLanguageListContainer::NAME));
|
810 schuur 1.12
|
811 chuck 1.44 QueryExpression qx(request->queryLanguage,request->query);
|
812 schuur 1.12
813 // forward request
814 PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,
815 "Calling provider.executeQueryRequest: " +
816 ph.GetProvider().getName());
817
818 pm_service_op_lock op_lock(&ph.GetProvider());
819
|
820 a.dunfey 1.58 STAT_PMS_PROVIDERSTART;
|
821 schuur 1.12
822 ph.GetProvider().execQuery(
823 context,
824 objectPath,
825 qx,
826 handler);
827 }
|
828 a.dunfey 1.58 HandleCatch(handler);
|
829 chip 1.1
830 PEG_METHOD_EXIT();
831
832 return(response);
833 }
834
|
835 dj.gorey 1.25 Message * DefaultProviderManager::handleAssociatorsRequest(const Message * message)
|
836 chip 1.1 {
837 PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleAssociatorsRequest");
838
839 CIMAssociatorsRequestMessage * request =
840 dynamic_cast<CIMAssociatorsRequestMessage *>(const_cast<Message *>(message));
841
842 PEGASUS_ASSERT(request != 0);
843
|
844 kumpf 1.54 CIMAssociatorsResponseMessage* response =
845 dynamic_cast<CIMAssociatorsResponseMessage*>(
846 request->buildResponse());
|
847 chip 1.1 PEGASUS_ASSERT(response != 0);
848
849 // create a handler for this request
|
850 kumpf 1.62 AssociatorsResponseHandler handler(
851 request, response, _responseChunkCallback);
|
852 chip 1.1
853 // process the request
854 try
855 {
|
856 mike 1.56 PEG_LOGGER_TRACE((Logger::STANDARD_LOG, System::CIMSERVER,
857 Logger::TRACE,
858 "DefaultProviderManager::handleAssociatorsRequest - "
859 "Host name: $0 Name space: $1 Class name: $2",
|
860 chip 1.1 System::getHostName(),
861 request->nameSpace.getString(),
|
862 mike 1.56 request->objectName.getClassName().getString()));
|
863 chip 1.1
864 // make target object path
865 CIMObjectPath objectPath(
866 System::getHostName(),
867 request->nameSpace,
868 request->objectName.getClassName());
869
870 objectPath.setKeyBindings(request->objectName.getKeyBindings());
871
|
872 schuur 1.19 CIMObjectPath assocPath(
873 System::getHostName(),
874 request->nameSpace,
875 request->assocClass.getString());
876
|
877 chip 1.5 // resolve provider name
|
878 kumpf 1.28 ProviderName name = _resolveProviderName(
879 request->operationContext.get(ProviderIdContainer::NAME));
|
880 chip 1.2
881 // get cached or load new provider module
|
882 kumpf 1.50 OpProviderHolder ph = providerManager.getProvider(
883 name.getPhysicalName(), name.getLogicalName());
|
884 chip 1.2
885 // convert arguments
886 OperationContext context;
887
|
888 se.gupta 1.34 context.insert(request->operationContext.get(IdentityContainer::NAME));
889 context.insert(request->operationContext.get(AcceptLanguageListContainer::NAME));
890 context.insert(request->operationContext.get(ContentLanguageListContainer::NAME));
891
|
892 a.dunfey 1.58 STAT_PMS_PROVIDERSTART;
|
893 chip 1.2 pm_service_op_lock op_lock(&ph.GetProvider());
|
894 chip 1.1
|
895 chip 1.2 ph.GetProvider().associators(
896 context,
897 objectPath,
898 request->assocClass,
899 request->resultClass,
900 request->role,
901 request->resultRole,
902 request->includeQualifiers,
903 request->includeClassOrigin,
|
904 a.dunfey 1.39 request->propertyList,
|
905 chip 1.2 handler);
|
906 chip 1.1 }
|
907 a.dunfey 1.58 HandleCatch(handler);
|
908 chip 1.1
909 PEG_METHOD_EXIT();
910
|
911 w.white 1.53 STAT_COPYDISPATCHER
912
|
913 chip 1.1 return(response);
914 }
915
|
916 dj.gorey 1.25 Message * DefaultProviderManager::handleAssociatorNamesRequest(const Message * message)
|
917 chip 1.1 {
918 PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleAssociatorNamesRequest");
919
920 CIMAssociatorNamesRequestMessage * request =
921 dynamic_cast<CIMAssociatorNamesRequestMessage *>(const_cast<Message *>(message));
922
923 PEGASUS_ASSERT(request != 0);
924
|
925 kumpf 1.54 CIMAssociatorNamesResponseMessage* response =
926 dynamic_cast<CIMAssociatorNamesResponseMessage*>(
927 request->buildResponse());
|
928 chip 1.1 PEGASUS_ASSERT(response != 0);
929
930 // create a handler for this request
|
931 kumpf 1.62 AssociatorNamesResponseHandler handler(
932 request, response, _responseChunkCallback);
|
933 chip 1.1
934 // process the request
935 try
936 {
|
937 mike 1.56 PEG_LOGGER_TRACE((Logger::STANDARD_LOG, System::CIMSERVER,
938 Logger::TRACE,
939 "DefaultProviderManager::handleAssociationNamesRequest - "
940 "Host name: $0 Name space: $1 Class name: $2",
|
941 chip 1.1 System::getHostName(),
942 request->nameSpace.getString(),
|
943 mike 1.56 request->objectName.getClassName().getString()));
|
944 chip 1.1
945 // make target object path
946 CIMObjectPath objectPath(
947 System::getHostName(),
948 request->nameSpace,
949 request->objectName.getClassName());
950
951 objectPath.setKeyBindings(request->objectName.getKeyBindings());
952
|
953 schuur 1.19 CIMObjectPath assocPath(
954 System::getHostName(),
955 request->nameSpace,
956 request->assocClass.getString());
957
|
958 chip 1.5 // resolve provider name
|
959 kumpf 1.28 ProviderName name = _resolveProviderName(
960 request->operationContext.get(ProviderIdContainer::NAME));
|
961 chip 1.2
962 // get cached or load new provider module
|
963 kumpf 1.50 OpProviderHolder ph = providerManager.getProvider(
964 name.getPhysicalName(), name.getLogicalName());
|
965 chip 1.2
966 // convert arguments
967 OperationContext context;
|
968 chip 1.1
|
969 se.gupta 1.34 context.insert(request->operationContext.get(IdentityContainer::NAME));
970 context.insert(request->operationContext.get(AcceptLanguageListContainer::NAME));
971 context.insert(request->operationContext.get(ContentLanguageListContainer::NAME));
|
972 chip 1.1
|
973 a.dunfey 1.58 STAT_PMS_PROVIDERSTART;
|
974 chip 1.2 pm_service_op_lock op_lock(&ph.GetProvider());
|
975 chip 1.1
|
976 chip 1.2 ph.GetProvider().associatorNames(
977 context,
978 objectPath,
979 request->assocClass,
980 request->resultClass,
981 request->role,
982 request->resultRole,
983 handler);
|
984 chip 1.1 }
|
985 a.dunfey 1.58 HandleCatch(handler);
|
986 chip 1.1
987 PEG_METHOD_EXIT();
988
|
989 w.white 1.53 STAT_COPYDISPATCHER
990
|
991 chip 1.1 return(response);
992 }
993
|
994 dj.gorey 1.25 Message * DefaultProviderManager::handleReferencesRequest(const Message * message)
|
995 chip 1.1 {
996 PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleReferencesRequest");
997
998 CIMReferencesRequestMessage * request =
999 dynamic_cast<CIMReferencesRequestMessage *>(const_cast<Message *>(message));
1000
1001 PEGASUS_ASSERT(request != 0);
1002
|
1003 kumpf 1.54 CIMReferencesResponseMessage* response =
1004 dynamic_cast<CIMReferencesResponseMessage*>(
1005 request->buildResponse());
|
1006 chip 1.1 PEGASUS_ASSERT(response != 0);
1007
1008 // create a handler for this request
|
1009 kumpf 1.62 ReferencesResponseHandler handler(
1010 request, response, _responseChunkCallback);
|
1011 chip 1.1
1012 // process the request
1013 try
1014 {
|
1015 mike 1.56 PEG_LOGGER_TRACE((Logger::STANDARD_LOG, System::CIMSERVER,
1016 Logger::TRACE,
1017 "DefaultProviderManager::handleReferencesRequest - "
1018 "Host name: $0 Name space: $1 Class name: $2",
|
1019 chip 1.1 System::getHostName(),
1020 request->nameSpace.getString(),
|
1021 mike 1.56 request->objectName.getClassName().getString()));
|
1022 chip 1.1
1023 // make target object path
1024 CIMObjectPath objectPath(
1025 System::getHostName(),
1026 request->nameSpace,
1027 request->objectName.getClassName());
1028
1029 objectPath.setKeyBindings(request->objectName.getKeyBindings());
1030
|
1031 schuur 1.19 CIMObjectPath resultPath(
1032 System::getHostName(),
1033 request->nameSpace,
1034 request->resultClass.getString());
1035
|
1036 chip 1.5 // resolve provider name
|
1037 kumpf 1.28 ProviderName name = _resolveProviderName(
1038 request->operationContext.get(ProviderIdContainer::NAME));
|
1039 chip 1.2
1040 // get cached or load new provider module
|
1041 kumpf 1.50 OpProviderHolder ph = providerManager.getProvider(
1042 name.getPhysicalName(), name.getLogicalName());
|
1043 chip 1.2
1044 // convert arguments
1045 OperationContext context;
1046
|
1047 se.gupta 1.34 context.insert(request->operationContext.get(IdentityContainer::NAME));
1048 context.insert(request->operationContext.get(AcceptLanguageListContainer::NAME));
1049 context.insert(request->operationContext.get(ContentLanguageListContainer::NAME));
|
1050 chip 1.2
|
1051 a.dunfey 1.58 STAT_PMS_PROVIDERSTART;
|
1052 chip 1.1
|
1053 chip 1.2 PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,
1054 "Calling provider.references: " +
1055 ph.GetProvider().getName());
|
1056 chip 1.1
|
1057 chip 1.2 pm_service_op_lock op_lock(&ph.GetProvider());
|
1058 chip 1.1
|
1059 chip 1.2 ph.GetProvider().references(
1060 context,
1061 objectPath,
1062 request->resultClass,
1063 request->role,
1064 request->includeQualifiers,
1065 request->includeClassOrigin,
|
1066 a.dunfey 1.42 request->propertyList,
|
1067 chip 1.2 handler);
|
1068 chip 1.1 }
|
1069 a.dunfey 1.58 HandleCatch(handler);
|
1070 chip 1.1
1071 PEG_METHOD_EXIT();
1072
|
1073 w.white 1.53 STAT_COPYDISPATCHER
1074
|
1075 chip 1.1 return(response);
1076 }
1077
|
1078 dj.gorey 1.25 Message * DefaultProviderManager::handleReferenceNamesRequest(const Message * message)
|
1079 chip 1.1 {
1080 PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleReferenceNamesRequest");
1081
1082 CIMReferenceNamesRequestMessage * request =
1083 dynamic_cast<CIMReferenceNamesRequestMessage *>(const_cast<Message *>(message));
1084
1085 PEGASUS_ASSERT(request != 0);
1086
|
1087 kumpf 1.54 CIMReferenceNamesResponseMessage* response =
1088 dynamic_cast<CIMReferenceNamesResponseMessage*>(
1089 request->buildResponse());
1090 PEGASUS_ASSERT(response != 0);
|
1091 chip 1.1
1092 // create a handler for this request
|
1093 kumpf 1.62 ReferenceNamesResponseHandler handler(
1094 request, response, _responseChunkCallback);
|
1095 chip 1.1
1096 // process the request
1097 try
1098 {
|
1099 mike 1.56 PEG_LOGGER_TRACE((Logger::STANDARD_LOG, System::CIMSERVER,
1100 Logger::TRACE,
1101 "DefaultProviderManager::handleReferenceNamesRequest - "
1102 "Host name: $0 Name space: $1 Class name: $2",
|
1103 chip 1.1 System::getHostName(),
1104 request->nameSpace.getString(),
|
1105 mike 1.56 request->objectName.getClassName().getString()));
|
1106 chip 1.1
1107 // make target object path
1108 CIMObjectPath objectPath(
1109 System::getHostName(),
1110 request->nameSpace,
1111 request->objectName.getClassName());
1112
1113 objectPath.setKeyBindings(request->objectName.getKeyBindings());
1114
|
1115 schuur 1.19 CIMObjectPath resultPath(
1116 System::getHostName(),
1117 request->nameSpace,
1118 request->resultClass.getString());
1119
|
1120 chip 1.5 // resolve provider name
|
1121 kumpf 1.28 ProviderName name = _resolveProviderName(
1122 request->operationContext.get(ProviderIdContainer::NAME));
|
1123 chip 1.1
|
1124 chip 1.2 // get cached or load new provider module
|
1125 kumpf 1.50 OpProviderHolder ph = providerManager.getProvider(
1126 name.getPhysicalName(), name.getLogicalName());
|
1127 chip 1.1
|
1128 chip 1.2 // convert arguments
1129 OperationContext context;
|
1130 chip 1.1
|
1131 se.gupta 1.34 context.insert(request->operationContext.get(IdentityContainer::NAME));
1132 context.insert(request->operationContext.get(AcceptLanguageListContainer::NAME));
1133 context.insert(request->operationContext.get(ContentLanguageListContainer::NAME));
|
1134 chip 1.1
|
1135 a.dunfey 1.58 STAT_PMS_PROVIDERSTART;
|
1136 chip 1.1
|
1137 chip 1.2 PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,
1138 "Calling provider.referenceNames: " +
1139 ph.GetProvider().getName());
|
1140 chip 1.1
|
1141 chip 1.2 pm_service_op_lock op_lock(&ph.GetProvider());
|
1142 chip 1.1
|
1143 chip 1.2 ph.GetProvider().referenceNames(
1144 context,
1145 objectPath,
1146 request->resultClass,
1147 request->role,
1148 handler);
|
1149 chip 1.1 }
|
1150 a.dunfey 1.58 HandleCatch(handler);
|
1151 chip 1.1
1152 PEG_METHOD_EXIT();
1153
|
1154 w.white 1.53 STAT_COPYDISPATCHER
1155
|
1156 chip 1.1 return(response);
1157 }
1158
|
1159 dj.gorey 1.25 Message * DefaultProviderManager::handleGetPropertyRequest(const Message * message)
|
1160 chip 1.1 {
1161 PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleGetPropertyRequest");
1162
1163 CIMGetPropertyRequestMessage * request =
1164 dynamic_cast<CIMGetPropertyRequestMessage *>(const_cast<Message *>(message));
1165
1166 PEGASUS_ASSERT(request != 0);
1167
1168 // create response message
|
1169 kumpf 1.54 CIMGetPropertyResponseMessage* response =
1170 dynamic_cast<CIMGetPropertyResponseMessage*>(
1171 request->buildResponse());
|
1172 chip 1.1 PEGASUS_ASSERT(response != 0);
1173
|
1174 kumpf 1.62 GetPropertyResponseHandler handler(
1175 request, response, _responseChunkCallback);
|
1176 chip 1.1
1177 try
1178 {
|
1179 mike 1.56 PEG_LOGGER_TRACE((Logger::STANDARD_LOG, System::CIMSERVER,
1180 Logger::TRACE,
1181 "DefaultProviderManager::handleGetPropertyRequest - "
1182 "Host name: $0 Name space: $1 Class name: $2",
|
1183 chip 1.1 System::getHostName(),
1184 request->nameSpace.getString(),
|
1185 mike 1.56 request->instanceName.getClassName().getString()));
|
1186 chip 1.1
1187 // make target object path
1188 CIMObjectPath objectPath(
1189 System::getHostName(),
1190 request->nameSpace,
1191 request->instanceName.getClassName(),
1192 request->instanceName.getKeyBindings());
1193
|
1194 chip 1.5 // resolve provider name
|
1195 kumpf 1.28 ProviderName name = _resolveProviderName(
1196 request->operationContext.get(ProviderIdContainer::NAME));
|
1197 chip 1.1
1198 // get cached or load new provider module
|
1199 kumpf 1.50 OpProviderHolder ph = providerManager.getProvider(
1200 name.getPhysicalName(), name.getLogicalName());
|
1201 chip 1.1
1202 // convert arguments
1203 OperationContext context;
1204
|
1205 se.gupta 1.34 context.insert(request->operationContext.get(IdentityContainer::NAME));
1206 context.insert(request->operationContext.get(AcceptLanguageListContainer::NAME));
1207 context.insert(request->operationContext.get(ContentLanguageListContainer::NAME));
|
1208 chip 1.1
1209 CIMName propertyName = request->propertyName;
1210
|
1211 a.dunfey 1.58 STAT_PMS_PROVIDERSTART;
|
1212 chip 1.1
1213 PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,
1214 "Calling provider.getProperty: " +
1215 ph.GetProvider().getName());
1216
1217 // forward request
1218 pm_service_op_lock op_lock(&ph.GetProvider());
1219
1220 ph.GetProvider().getProperty(
1221 context,
1222 objectPath,
1223 propertyName,
1224 handler);
1225 }
|
1226 a.dunfey 1.58 HandleCatch(handler);
|
1227 chip 1.1
1228 PEG_METHOD_EXIT();
1229
|
1230 w.white 1.53 STAT_COPYDISPATCHER
1231
|
1232 chip 1.1 return(response);
1233 }
1234
|
1235 dj.gorey 1.25 Message * DefaultProviderManager::handleSetPropertyRequest(const Message * message)
|
1236 chip 1.1 {
1237 PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleSetPropertyRequest");
1238
1239 CIMSetPropertyRequestMessage * request =
1240 dynamic_cast<CIMSetPropertyRequestMessage *>(const_cast<Message *>(message));
1241
1242 PEGASUS_ASSERT(request != 0);
1243
1244 // create response message
|
1245 kumpf 1.54 CIMSetPropertyResponseMessage* response =
1246 dynamic_cast<CIMSetPropertyResponseMessage*>(
1247 request->buildResponse());
|
1248 chip 1.1 PEGASUS_ASSERT(response != 0);
1249
|
1250 kumpf 1.62 SetPropertyResponseHandler handler(
1251 request, response, _responseChunkCallback);
|
1252 chip 1.1
1253 try
1254 {
|
1255 mike 1.56 PEG_LOGGER_TRACE((Logger::STANDARD_LOG, System::CIMSERVER,
1256 Logger::TRACE,
1257 "DefaultProviderManager::handleSetPropertyRequest - "
1258 "Host name: $0 Name space: $1 Class name: $2",
|
1259 chip 1.1 System::getHostName(),
1260 request->nameSpace.getString(),
|
1261 mike 1.56 request->instanceName.getClassName().getString()));
|
1262 chip 1.1
1263 // make target object path
1264 CIMObjectPath objectPath(
1265 System::getHostName(),
1266 request->nameSpace,
1267 request->instanceName.getClassName(),
1268 request->instanceName.getKeyBindings());
1269
|
1270 chip 1.5 // resolve provider name
|
1271 kumpf 1.28 ProviderName name = _resolveProviderName(
1272 request->operationContext.get(ProviderIdContainer::NAME));
|
1273 chip 1.1
1274 // get cached or load new provider module
|
1275 kumpf 1.50 OpProviderHolder ph = providerManager.getProvider(
1276 name.getPhysicalName(), name.getLogicalName());
|
1277 chip 1.1
1278 // convert arguments
1279 OperationContext context;
1280
|
1281 se.gupta 1.34 context.insert(request->operationContext.get(IdentityContainer::NAME));
1282 context.insert(request->operationContext.get(AcceptLanguageListContainer::NAME));
1283 context.insert(request->operationContext.get(ContentLanguageListContainer::NAME));
|
1284 chip 1.1
1285 CIMName propertyName = request->propertyName;
1286 CIMValue propertyValue = request->newValue;
1287
|
1288 a.dunfey 1.58 STAT_PMS_PROVIDERSTART;
|
1289 chip 1.1
1290 PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,
1291 "Calling provider.setProperty: " +
1292 ph.GetProvider().getName());
1293
1294 // forward request
1295 pm_service_op_lock op_lock(&ph.GetProvider());
1296
1297 ph.GetProvider().setProperty(
1298 context,
1299 objectPath,
1300 propertyName,
1301 propertyValue,
1302 handler);
1303 }
|
1304 a.dunfey 1.58 HandleCatch(handler);
|
1305 chip 1.1
1306 PEG_METHOD_EXIT();
1307
|
1308 w.white 1.53 STAT_COPYDISPATCHER
1309
|
1310 chip 1.1 return(response);
1311 }
1312
|
1313 dj.gorey 1.25 Message * DefaultProviderManager::handleInvokeMethodRequest(const Message * message)
|
1314 chip 1.1 {
1315 PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleInvokeMethodRequest");
1316
1317 CIMInvokeMethodRequestMessage * request =
1318 dynamic_cast<CIMInvokeMethodRequestMessage *>(const_cast<Message *>(message));
1319
1320 PEGASUS_ASSERT(request != 0);
1321
1322 // create response message
|
1323 kumpf 1.54 CIMInvokeMethodResponseMessage* response =
1324 dynamic_cast<CIMInvokeMethodResponseMessage*>(
1325 request->buildResponse());
|
1326 chip 1.1 PEGASUS_ASSERT(response != 0);
1327
1328 // create a handler for this request
|
1329 kumpf 1.62 InvokeMethodResponseHandler handler(
1330 request, response, _responseChunkCallback);
|
1331 chip 1.1
1332 try
1333 {
|
1334 mike 1.56 PEG_LOGGER_TRACE((Logger::STANDARD_LOG, System::CIMSERVER,
1335 Logger::TRACE,
1336 "DefaultProviderManager::handleInvokeMethodRequest - "
1337 "Host name: $0 Name space: $1 Class name: $2",
|
1338 chip 1.1 System::getHostName(),
1339 request->nameSpace.getString(),
|
1340 mike 1.56 request->instanceName.getClassName().getString()));
|
1341 chip 1.1
1342 // make target object path
1343 CIMObjectPath objectPath(
1344 System::getHostName(),
1345 request->nameSpace,
1346 request->instanceName.getClassName(),
1347 request->instanceName.getKeyBindings());
1348
|
1349 chip 1.5 // resolve provider name
|
1350 kumpf 1.28 ProviderName name = _resolveProviderName(
1351 request->operationContext.get(ProviderIdContainer::NAME));
|
1352 chip 1.1
1353 // get cached or load new provider module
|
1354 kumpf 1.50 OpProviderHolder ph = providerManager.getProvider(
1355 name.getPhysicalName(), name.getLogicalName());
|
1356 chip 1.1
1357 // convert arguments
1358 OperationContext context;
1359
|
1360 se.gupta 1.34 context.insert(request->operationContext.get(IdentityContainer::NAME));
1361 context.insert(request->operationContext.get(AcceptLanguageListContainer::NAME));
1362 context.insert(request->operationContext.get(ContentLanguageListContainer::NAME));
|
1363 chip 1.1
1364 CIMObjectPath instanceReference(request->instanceName);
1365
1366 // ATTN: propagate namespace
1367 instanceReference.setNameSpace(request->nameSpace);
1368
1369 // forward request
|
1370 a.dunfey 1.58 STAT_PMS_PROVIDERSTART;
|
1371 chip 1.1
1372 PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,
1373 "Calling provider.invokeMethod: " +
1374 ph.GetProvider().getName());
1375
1376 pm_service_op_lock op_lock(&ph.GetProvider());
1377
1378 ph.GetProvider().invokeMethod(
1379 context,
1380 instanceReference,
1381 request->methodName,
1382 request->inParameters,
1383 handler);
1384 }
|
1385 a.dunfey 1.58 HandleCatch(handler);
|
1386 chip 1.1
1387 PEG_METHOD_EXIT();
1388
1389 return(response);
1390 }
1391
|
1392 dj.gorey 1.25 Message * DefaultProviderManager::handleCreateSubscriptionRequest(const Message * message)
|
1393 chip 1.1 {
1394 PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleCreateSubscriptionRequest");
1395
1396 CIMCreateSubscriptionRequestMessage * request =
1397 dynamic_cast<CIMCreateSubscriptionRequestMessage *>(const_cast<Message *>(message));
1398
1399 PEGASUS_ASSERT(request != 0);
1400
|
1401 kumpf 1.54 CIMCreateSubscriptionResponseMessage* response =
1402 dynamic_cast<CIMCreateSubscriptionResponseMessage*>(
1403 request->buildResponse());
|
1404 chip 1.1 PEGASUS_ASSERT(response != 0);
1405
|
1406 kumpf 1.62 OperationResponseHandler handler(
1407 request, response, _responseChunkCallback);
|
1408 chip 1.1
1409 try
1410 {
|
1411 chip 1.2 String temp;
1412
1413 for(Uint32 i = 0, n = request->classNames.size(); i < n; i++)
1414 {
1415 temp.append(request->classNames[i].getString());
1416
1417 if(i == (n - 1))
1418 {
1419 temp.append(", ");
1420 }
1421 }
1422
|
1423 mike 1.56 PEG_LOGGER_TRACE((Logger::STANDARD_LOG, System::CIMSERVER,
1424 Logger::TRACE,
1425 "DefaultProviderManager::handleCreateSubscriptionRequest - "
1426 "Host name: $0 Name space: $1 Class name(s): $2",
|
1427 chip 1.2 System::getHostName(),
1428 request->nameSpace.getString(),
|
1429 mike 1.56 temp));
|
1430 chip 1.2
|
1431 se.gupta 1.33 CIMInstance req_provider, req_providerModule;
|
1432 se.gupta 1.34 ProviderIdContainer pidc = (ProviderIdContainer)request->operationContext.get(ProviderIdContainer::NAME);
1433 req_provider = pidc.getProvider();
1434 req_providerModule = pidc.getModule();
|
1435 schuur 1.18
|
1436 se.gupta 1.33 String physicalName=_resolvePhysicalName( req_providerModule.getProperty(
1437 req_providerModule.findProperty("Location")).getValue().toString());
1438
1439 ProviderName name(req_provider.getProperty(req_provider.findProperty("Name")).getValue ().toString (),
1440 physicalName,
1441 req_providerModule.getProperty(req_providerModule.findProperty
1442 ("InterfaceType")).getValue().toString(),
1443 0);
|
1444 kumpf 1.50
1445 // get cached or load new provider module
1446 OpProviderHolder ph = providerManager.getProvider(
1447 name.getPhysicalName(), name.getLogicalName());
|
1448 dj.gorey 1.25
|
1449 carolann.graves 1.49 //
1450 // Save the provider instance from the request
1451 //
1452 ph.GetProvider ().setProviderInstance (req_provider);
1453
|
1454 chip 1.1 // convert arguments
1455 OperationContext context;
1456
|
1457 se.gupta 1.34 context.insert(request->operationContext.get(IdentityContainer::NAME));
1458 context.insert(request->operationContext.get(AcceptLanguageListContainer::NAME));
1459 context.insert(request->operationContext.get(ContentLanguageListContainer::NAME));
1460 context.insert(request->operationContext.get(SubscriptionInstanceContainer::NAME));
1461 context.insert(request->operationContext.get(SubscriptionFilterConditionContainer::NAME));
|
1462 humberto 1.45 context.insert(request->operationContext.get(SubscriptionFilterQueryContainer::NAME));
|
1463 chip 1.1
1464 CIMObjectPath subscriptionName = request->subscriptionInstance.getPath();
1465
1466 Array<CIMObjectPath> classNames;
1467
1468 for(Uint32 i = 0, n = request->classNames.size(); i < n; i++)
1469 {
1470 CIMObjectPath className(
1471 System::getHostName(),
1472 request->nameSpace,
1473 request->classNames[i]);
1474
1475 classNames.append(className);
1476 }
1477
1478 CIMPropertyList propertyList = request->propertyList;
1479
1480 Uint16 repeatNotificationPolicy = request->repeatNotificationPolicy;
1481
1482 PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,
1483 "Calling provider.createSubscription: " +
1484 chip 1.1 ph.GetProvider().getName());
1485
1486 pm_service_op_lock op_lock(&ph.GetProvider());
1487
1488 ph.GetProvider().createSubscription(
1489 context,
1490 subscriptionName,
1491 classNames,
1492 propertyList,
1493 repeatNotificationPolicy);
|
1494 carolann.graves 1.49
1495 //
1496 // Increment count of current subscriptions for this provider
1497 //
1498 if (ph.GetProvider ().testIfZeroAndIncrementSubscriptions ())
1499 {
1500 //
1501 // If there were no current subscriptions before the increment,
1502 // the first subscription has been created
1503 // Call the provider's enableIndications method
1504 //
1505 if (_subscriptionInitComplete)
1506 {
1507 _callEnableIndications (req_provider,
1508 _indicationCallback, ph);
1509 }
1510 }
|
1511 chip 1.1 }
1512 catch(CIMException & e)
1513 {
1514 PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,
1515 "Exception: " + e.getMessage());
|
1516 chip 1.2
|
1517 chip 1.1 handler.setStatus(e.getCode(), e.getContentLanguages(), e.getMessage()); // l10n
1518 }
1519 catch(Exception & e)
1520 {
1521 PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,
1522 "Exception: " + e.getMessage());
|
1523 chip 1.2
|
1524 chip 1.1 handler.setStatus(CIM_ERR_FAILED, e.getContentLanguages(), e.getMessage()); // l10n
1525 }
1526 catch(...)
1527 {
1528 PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,
1529 "Exception: Unknown");
|
1530 chip 1.2
|
1531 chip 1.1 handler.setStatus(CIM_ERR_FAILED, "Unknown Error");
1532 }
1533
1534 PEG_METHOD_EXIT();
1535
1536 return(response);
1537 }
1538
|
1539 dj.gorey 1.25 Message * DefaultProviderManager::handleModifySubscriptionRequest( const Message * message)
|
1540 chip 1.1 {
1541 PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleModifySubscriptionRequest");
1542
1543 CIMModifySubscriptionRequestMessage * request =
1544 dynamic_cast<CIMModifySubscriptionRequestMessage *>(const_cast<Message *>(message));
1545
1546 PEGASUS_ASSERT(request != 0);
1547
|
1548 kumpf 1.54 CIMModifySubscriptionResponseMessage* response =
1549 dynamic_cast<CIMModifySubscriptionResponseMessage*>(
1550 request->buildResponse());
|
1551 chip 1.1 PEGASUS_ASSERT(response != 0);
1552
|
1553 kumpf 1.62 OperationResponseHandler handler(
1554 request, response, _responseChunkCallback);
|
1555 chip 1.1
1556 try
1557 {
|
1558 chip 1.2 String temp;
1559
1560 for(Uint32 i = 0, n = request->classNames.size(); i < n; i++)
1561 {
1562 temp.append(request->classNames[i].getString());
1563
1564 if(i == (n - 1))
1565 {
1566 temp.append(", ");
1567 }
1568 }
1569
|
1570 mike 1.56 PEG_LOGGER_TRACE((Logger::STANDARD_LOG, System::CIMSERVER,
1571 Logger::TRACE,
1572 "DefaultProviderManager::handleCreateSubscriptionRequest - "
1573 "Host name: $0 Name space: $1 Class name(s): $2",
|
1574 chip 1.2 System::getHostName(),
1575 request->nameSpace.getString(),
|
1576 mike 1.56 temp));
|
1577 se.gupta 1.33
|
1578 se.gupta 1.34 CIMInstance req_provider, req_providerModule;
1579 ProviderIdContainer pidc = (ProviderIdContainer)request->operationContext.get(ProviderIdContainer::NAME);
1580 req_provider = pidc.getProvider();
1581 req_providerModule = pidc.getModule();
1582
1583 String physicalName=_resolvePhysicalName( req_providerModule.getProperty(
|
1584 se.gupta 1.33 req_providerModule.findProperty("Location")).getValue().toString());
1585
|
1586 se.gupta 1.34 ProviderName name(req_provider.getProperty(req_provider.findProperty("Name")).getValue ().toString (),
|
1587 se.gupta 1.33 physicalName,
1588 req_providerModule.getProperty(req_providerModule.findProperty
1589 ("InterfaceType")).getValue().toString(),
1590 0);
|
1591 chip 1.1
1592 // get cached or load new provider module
|
1593 kumpf 1.50 OpProviderHolder ph = providerManager.getProvider(
1594 name.getPhysicalName(), name.getLogicalName());
|
1595 dj.gorey 1.25
|
1596 chip 1.1 // convert arguments
1597 OperationContext context;
|
1598 se.gupta 1.34 context.insert(request->operationContext.get(IdentityContainer::NAME));
1599 context.insert(request->operationContext.get(AcceptLanguageListContainer::NAME));
1600 context.insert(request->operationContext.get(ContentLanguageListContainer::NAME));
1601 context.insert(request->operationContext.get(SubscriptionInstanceContainer::NAME));
1602 context.insert(request->operationContext.get(SubscriptionFilterConditionContainer::NAME));
|
1603 humberto 1.45 context.insert(request->operationContext.get(SubscriptionFilterQueryContainer::NAME));
|
1604 chip 1.1
1605 CIMObjectPath subscriptionName = request->subscriptionInstance.getPath();
1606
1607 Array<CIMObjectPath> classNames;
1608
1609 for(Uint32 i = 0, n = request->classNames.size(); i < n; i++)
1610 {
1611 CIMObjectPath className(
1612 System::getHostName(),
1613 request->nameSpace,
1614 request->classNames[i]);
1615
1616 classNames.append(className);
1617 }
1618
1619 CIMPropertyList propertyList = request->propertyList;
1620
1621 Uint16 repeatNotificationPolicy = request->repeatNotificationPolicy;
1622
1623 PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,
1624 "Calling provider.modifySubscription: " +
1625 chip 1.1 ph.GetProvider().getName());
1626
1627 pm_service_op_lock op_lock(&ph.GetProvider());
1628
1629 ph.GetProvider().modifySubscription(
1630 context,
1631 subscriptionName,
1632 classNames,
1633 propertyList,
1634 repeatNotificationPolicy);
1635 }
1636 catch(CIMException & e)
1637 {
1638 PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,
1639 "Exception: " + e.getMessage());
|
1640 chip 1.2
|
1641 chip 1.1 handler.setStatus(e.getCode(), e.getContentLanguages(), e.getMessage()); // l10n
1642 }
1643 catch(Exception & e)
1644 {
1645 PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,
1646 "Exception: " + e.getMessage());
|
1647 chip 1.2
|
1648 chip 1.1 handler.setStatus(CIM_ERR_FAILED, e.getContentLanguages(), e.getMessage()); // l10n
1649 }
1650 catch(...)
1651 {
1652 PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,
1653 "Exception: Unknown");
|
1654 chip 1.2
|
1655 chip 1.1 handler.setStatus(CIM_ERR_FAILED, "Unknown Error");
1656 }
1657
1658 PEG_METHOD_EXIT();
1659
1660 return(response);
1661 }
1662
|
1663 dj.gorey 1.25 Message * DefaultProviderManager::handleDeleteSubscriptionRequest(const Message * message)
|
1664 chip 1.1 {
1665 PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleDeleteSubscriptionRequest");
1666
1667 CIMDeleteSubscriptionRequestMessage * request =
1668 dynamic_cast<CIMDeleteSubscriptionRequestMessage *>(const_cast<Message *>(message));
1669
1670 PEGASUS_ASSERT(request != 0);
1671
|
1672 kumpf 1.54 CIMDeleteSubscriptionResponseMessage* response =
1673 dynamic_cast<CIMDeleteSubscriptionResponseMessage*>(
1674 request->buildResponse());
|
1675 chip 1.1 PEGASUS_ASSERT(response != 0);
1676
|
1677 kumpf 1.62 OperationResponseHandler handler(
1678 request, response, _responseChunkCallback);
|
1679 chip 1.1
1680 try
1681 {
|
1682 chip 1.2 String temp;
1683
1684 for(Uint32 i = 0, n = request->classNames.size(); i < n; i++)
1685 {
1686 temp.append(request->classNames[i].getString());
1687
1688 if(i == (n - 1))
1689 {
1690 temp.append(", ");
1691 }
1692 }
1693
|
1694 mike 1.56 PEG_LOGGER_TRACE((Logger::STANDARD_LOG, System::CIMSERVER,
1695 Logger::TRACE,
1696 "DefaultProviderManager::handleDeleteSubscriptionRequest - "
1697 "Host name: $0 Name space: $1 Class name(s): $2",
|
1698 chip 1.2 System::getHostName(),
1699 request->nameSpace.getString(),
|
1700 mike 1.56 temp));
|
1701 chip 1.2
|
1702 se.gupta 1.34 CIMInstance req_provider, req_providerModule;
1703 ProviderIdContainer pidc = (ProviderIdContainer)request->operationContext.get(ProviderIdContainer::NAME);
1704
1705 req_provider = pidc.getProvider();
1706 req_providerModule = pidc.getModule();
|
1707 se.gupta 1.33
1708 String physicalName=_resolvePhysicalName( req_providerModule.getProperty(
1709 req_providerModule.findProperty("Location")).getValue().toString());
1710
1711 ProviderName name(req_provider.getProperty(req_provider.findProperty("Name")).getValue ().toString (),
1712 physicalName,
1713 req_providerModule.getProperty(req_providerModule.findProperty
1714 ("InterfaceType")).getValue().toString(),
1715 0);
|
1716 chip 1.1
1717 // get cached or load new provider module
|
1718 kumpf 1.50 OpProviderHolder ph = providerManager.getProvider(
1719 name.getPhysicalName(), name.getLogicalName());
|
1720 dj.gorey 1.25
|
1721 chip 1.1 // convert arguments
1722 OperationContext context;
1723
|
1724 se.gupta 1.34 context.insert(request->operationContext.get(IdentityContainer::NAME));
1725 context.insert(request->operationContext.get(AcceptLanguageListContainer::NAME));
1726 context.insert(request->operationContext.get(ContentLanguageListContainer::NAME));
1727 context.insert(request->operationContext.get(SubscriptionInstanceContainer::NAME));
1728
|
1729 chip 1.1 CIMObjectPath subscriptionName = request->subscriptionInstance.getPath();
1730
1731 Array<CIMObjectPath> classNames;
1732
1733 for(Uint32 i = 0, n = request->classNames.size(); i < n; i++)
1734 {
1735 CIMObjectPath className(
1736 System::getHostName(),
1737 request->nameSpace,
1738 request->classNames[i]);
1739
1740 classNames.append(className);
1741 }
1742
1743 PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,
1744 "Calling provider.deleteSubscription: " +
1745 ph.GetProvider().getName());
1746
1747 pm_service_op_lock op_lock(&ph.GetProvider());
1748
1749 ph.GetProvider().deleteSubscription(
1750 chip 1.1 context,
1751 subscriptionName,
1752 classNames);
|
1753 carolann.graves 1.49
1754 //
1755 // Decrement count of current subscriptions for this provider
1756 //
1757 if (ph.GetProvider ().decrementSubscriptionsAndTestIfZero ())
1758 {
1759 //
1760 // If there are no current subscriptions after the decrement,
1761 // the last subscription has been deleted
1762 // Call the provider's disableIndications method
1763 //
1764 if (_subscriptionInitComplete)
1765 {
1766 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
1767 "Calling provider.disableIndications: " +
1768 ph.GetProvider ().getName ());
1769
1770 ph.GetProvider ().disableIndications ();
1771
1772 ph.GetProvider ().unprotect ();
1773
1774 carolann.graves 1.49 //
1775 //
1776 //
1777 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
1778 "Removing and Destroying indication handler for " +
1779 ph.GetProvider ().getName ());
1780
1781 delete _removeEntry (_generateKey (ph.GetProvider ()));
1782 }
1783 }
|
1784 chip 1.1 }
1785 catch(CIMException & e)
1786 {
1787 PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,
1788 "Exception: " + e.getMessage());
|
1789 chip 1.2
|
1790 chip 1.1 handler.setStatus(e.getCode(), e.getContentLanguages(), e.getMessage()); // l10n
1791 }
1792 catch(Exception & e)
1793 {
1794 PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,
1795 "Exception: " + e.getMessage());
|
1796 chip 1.2
|
1797 chip 1.1 handler.setStatus(CIM_ERR_FAILED, e.getContentLanguages(), e.getMessage()); // l10n
1798 }
1799 catch(...)
1800 {
1801 PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,
1802 "Exception: Unknown");
|
1803 chip 1.2
|
1804 chip 1.1 handler.setStatus(CIM_ERR_FAILED, "Unknown Error");
1805 }
1806
1807 PEG_METHOD_EXIT();
1808
1809 return(response);
1810 }
1811
|
1812 dj.gorey 1.25 Message *DefaultProviderManager::handleExportIndicationRequest(const Message *message)
|
1813 schuur 1.14 {
1814 PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManagerService::handlExportIndicationRequest");
1815
1816 CIMExportIndicationRequestMessage * request =
1817 dynamic_cast<CIMExportIndicationRequestMessage *>(const_cast<Message *>(message));
1818
1819 PEGASUS_ASSERT(request != 0);
1820
|
1821 kumpf 1.54 CIMExportIndicationResponseMessage* response =
1822 dynamic_cast<CIMExportIndicationResponseMessage*>(
1823 request->buildResponse());
|
1824 schuur 1.14 PEGASUS_ASSERT(response != 0);
1825
|
1826 kumpf 1.62 OperationResponseHandler handler(
1827 request, response, _responseChunkCallback);
|
1828 schuur 1.14
1829 try
1830 {
|
1831 kumpf 1.28 // resolve provider name
1832 ProviderName name = _resolveProviderName(
1833 request->operationContext.get(ProviderIdContainer::NAME));
|
1834 schuur 1.14
|
1835 kumpf 1.28 // get cached or load new provider module
|
1836 kumpf 1.50 OpProviderHolder ph = providerManager.getProvider(
1837 name.getPhysicalName(), name.getLogicalName());
|
1838 schuur 1.14
|
1839 a.dunfey 1.58 STAT_PMS_PROVIDERSTART
|
1840 w.white 1.40
|
1841 schuur 1.14 PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,
|
1842 dj.gorey 1.25 "Calling provider.: " +
1843 ph.GetProvider().getName());
|
1844 schuur 1.14
1845 OperationContext context;
1846
|
1847 denise.eckstein 1.55 context.insert(request->operationContext.get(IdentityContainer::NAME));
1848
|
1849 schuur 1.14 //L10N_TODO
1850 //l10n
1851 // ATTN-CEC 06/04/03 NOTE: I can't find where the consume msg is sent. This
1852 // does not appear to be hooked-up. When it is added, need to
1853 // make sure that Content-Language is set in the consume msg.
1854 // NOTE: A-L is not needed to be set in the consume msg.
1855 // add the langs to the context
|
1856 se.gupta 1.33
|
1857 se.gupta 1.34 context.insert(request->operationContext.get(ContentLanguageListContainer::NAME));
|
1858 schuur 1.14
1859 CIMInstance indication_copy = request->indicationInstance;
1860 pm_service_op_lock op_lock(&ph.GetProvider());
1861
1862 ph.GetProvider().consumeIndication(context,
|
1863 dj.gorey 1.25 request->destinationPath,
1864 indication_copy);
|
1865 schuur 1.14 }
|
1866 a.dunfey 1.58 HandleCatch(handler);
|
1867 schuur 1.14
1868 PEG_METHOD_EXIT();
1869
1870 return(response);
1871 }
1872
1873
1874
1875
|
1876 chip 1.1 //
1877 // This function disables a provider module if disableProviderOnly is not true,
1878 // otherwise, disables a provider. Disable provider module means that
1879 // block all the providers which contain in the module and unload the
1880 // providers.
1881 // Disable provider means unload the provider and the provider is not blocked.
1882 //
1883 // ATTN-YZ-P2-20030519: Provider needs to be blocked when disable a provider.
1884 //
|
1885 dj.gorey 1.25 Message * DefaultProviderManager::handleDisableModuleRequest(const Message * message)
|
1886 chip 1.1 {
1887 PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleDisableModuleRequest");
|
1888 schuur 1.19
|
1889 chip 1.1 CIMDisableModuleRequestMessage * request =
1890 dynamic_cast<CIMDisableModuleRequestMessage *>(const_cast<Message *>(message));
1891
1892 PEGASUS_ASSERT(request != 0);
|
1893 dj.gorey 1.25
|
1894 schuur 1.18 Array<Uint16> operationalStatus;
1895 CIMException cimException;
|
1896 chip 1.1
|
1897 schuur 1.18 try
|
1898 chip 1.1 {
|
1899 schuur 1.18 // get provider module name
1900 String moduleName;
1901 CIMInstance mInstance = request->providerModule;
1902 Uint32 pos = mInstance.findProperty(CIMName ("Name"));
|
1903 kumpf 1.28 PEGASUS_ASSERT(pos != PEG_NOT_FOUND);
1904 mInstance.getProperty(pos).getValue().get(moduleName);
|
1905 chip 1.1
|
1906 schuur 1.18 Boolean disableProviderOnly = request->disableProviderOnly;
1907
|
1908 chip 1.1 //
|
1909 kumpf 1.28 // Unload providers
|
1910 chip 1.1 //
|
1911 schuur 1.18 Array<CIMInstance> _pInstances = request->providers;
1912 Array<Boolean> _indicationProviders = request->indicationProviders;
|
1913 dj.gorey 1.25
|
1914 schuur 1.18 String physicalName=_resolvePhysicalName(
1915 mInstance.getProperty(
1916 mInstance.findProperty("Location")).getValue().toString());
|
1917 dj.gorey 1.25
|
1918 schuur 1.18 for(Uint32 i = 0, n = _pInstances.size(); i < n; i++)
|
1919 chip 1.1 {
|
1920 schuur 1.18 String pName(_pInstances[i].getProperty(
1921 _pInstances[i].findProperty("Name")).getValue().toString());
|
1922 chip 1.1
|
1923 kumpf 1.51 Sint16 ret_value = providerManager.disableProvider(pName);
|
1924 chip 1.1
|
1925 schuur 1.18 if (ret_value == 0)
1926 {
|
1927 schuur 1.23 // disable failed since there are pending requests,
|
1928 kumpf 1.28 // stop trying to disable other providers in this module.
|
1929 kumpf 1.38 operationalStatus.append(CIM_MSE_OPSTATUS_VALUE_OK);
|
1930 kumpf 1.28 break;
|
1931 dj.gorey 1.25 }
|
1932 kumpf 1.28 else if (ret_value == 1) // Success
|
1933 dj.gorey 1.25 {
|
1934 schuur 1.18 if (_indicationProviders[i])
|
1935 dj.gorey 1.25 {
|
1936 carolann.graves 1.49 //
1937 // Reset the indication provider's count of current
1938 // subscriptions since it has been disabled
1939 //
1940 if (physicalName.size () > 0)
1941 {
|
1942 kumpf 1.50 OpProviderHolder ph = providerManager.getProvider(
1943 physicalName, pName);
|
1944 carolann.graves 1.49
1945 ph.GetProvider ().resetSubscriptions ();
1946 }
1947
1948 //
1949 // If it is an indication provider
1950 // remove the entry from the table since the
1951 // provider has been disabled
1952 //
|
1953 kumpf 1.27 delete _removeEntry(_generateKey(pName,physicalName));
|
1954 dj.gorey 1.25 }
1955 }
|
1956 schuur 1.18 else
1957 {
|
1958 dj.gorey 1.25 // disable failed for other reason, throw exception
|
1959 schuur 1.18 throw PEGASUS_CIM_EXCEPTION_L(
1960 CIM_ERR_FAILED,
1961 MessageLoaderParms(
1962 "ProviderManager.ProviderManagerService."
1963 "DISABLE_PROVIDER_FAILED",
1964 "Failed to disable the provider."));
1965 }
1966 }
1967 }
1968 catch(CIMException & e)
1969 {
|
1970 dj.gorey 1.25 PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,
|
1971 schuur 1.18 "Exception: " + e.getMessage());
1972 cimException = e;
1973 }
1974 catch(Exception & e)
1975 {
|
1976 dj.gorey 1.25 PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,
|
1977 schuur 1.18 "Exception: " + e.getMessage());
1978 cimException = CIMException(CIM_ERR_FAILED, e.getMessage());
1979 }
1980 catch(...)
1981 {
|
1982 dj.gorey 1.25 PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL4,
|
1983 schuur 1.18 "Exception: Unknown");
1984 //l10n
1985 //response->cimException = CIMException(CIM_ERR_FAILED, "Unknown Error");
1986 cimException = PEGASUS_CIM_EXCEPTION_L(
1987 CIM_ERR_FAILED,
1988 MessageLoaderParms(
1989 "ProviderManager.ProviderManagerService.UNKNOWN_ERROR",
1990 "Unknown Error"));
|
1991 chip 1.1 }
1992
|
1993 kumpf 1.28 if (cimException.getCode() == CIM_ERR_SUCCESS)
1994 {
1995 // Status is set to OK if a provider was busy
1996 if (operationalStatus.size() == 0)
1997 {
|
1998 kumpf 1.38 operationalStatus.append(CIM_MSE_OPSTATUS_VALUE_STOPPED);
|
1999 kumpf 1.28 }
2000 }
2001 else
2002 {
2003 // If exception occurs, module is not stopped
|
2004 kumpf 1.38 operationalStatus.append(CIM_MSE_OPSTATUS_VALUE_OK);
|
2005 kumpf 1.28 }
2006
|
2007 kumpf 1.54 CIMDisableModuleResponseMessage* response =
2008 dynamic_cast<CIMDisableModuleResponseMessage*>(
2009 request->buildResponse());
2010 PEGASUS_ASSERT(response != 0);
|
2011 chip 1.1
|
2012 kumpf 1.54 response->operationalStatus = operationalStatus;
|
2013 chip 1.1
2014 PEG_METHOD_EXIT();
2015
2016 return(response);
2017 }
2018
|
2019 dj.gorey 1.25 Message * DefaultProviderManager::handleEnableModuleRequest(const Message * message)
|
2020 chip 1.1 {
2021 PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleEnableModuleRequest");
2022
2023 CIMEnableModuleRequestMessage * request =
2024 dynamic_cast<CIMEnableModuleRequestMessage *>(const_cast<Message *>(message));
2025
2026 PEGASUS_ASSERT(request != 0);
2027
2028 Array<Uint16> operationalStatus;
|
2029 kumpf 1.38 operationalStatus.append(CIM_MSE_OPSTATUS_VALUE_OK);
|
2030 chip 1.1
|
2031 kumpf 1.54 CIMEnableModuleResponseMessage* response =
2032 dynamic_cast<CIMEnableModuleResponseMessage*>(
2033 request->buildResponse());
2034 PEGASUS_ASSERT(response != 0);
|
2035 chip 1.1
|
2036 kumpf 1.54 response->operationalStatus = operationalStatus;
|
2037 chip 1.1
2038 PEG_METHOD_EXIT();
2039 return(response);
2040 }
2041
|
2042 dj.gorey 1.25 Message * DefaultProviderManager::handleStopAllProvidersRequest(const Message * message)
|
2043 chip 1.1 {
2044 PEG_METHOD_ENTER(TRC_PROVIDERMANAGER, "DefaultProviderManager::handleStopAllProvidersRequest");
2045
2046 CIMStopAllProvidersRequestMessage * request =
2047 dynamic_cast<CIMStopAllProvidersRequestMessage *>(const_cast<Message *>(message));
2048
2049 PEGASUS_ASSERT(request != 0);
2050
|
2051 kumpf 1.54 CIMStopAllProvidersResponseMessage* response =
2052 dynamic_cast<CIMStopAllProvidersResponseMessage*>(
2053 request->buildResponse());
|
2054 chip 1.1 PEGASUS_ASSERT(response != 0);
2055
2056 // tell the provider manager to shutdown all the providers
|
2057 schuur 1.10 providerManager.shutdownAllProviders();
|
2058 kumpf 1.57
2059 try
2060 {
2061 // Delete the response handlers that were not explicitly disabled.
2062 AutoMutex lock(_responseTableMutex);
2063
2064 for (IndicationResponseTable::Iterator i = _responseTable.start();
2065 i != 0; i++)
2066 {
2067 EnableIndicationsResponseHandler *handler = i.value();
2068 delete handler;
2069 }
2070
2071 _responseTable.clear();
2072 }
2073 catch (...) { }
|
2074 chip 1.1
2075 PEG_METHOD_EXIT();
2076
2077 return(response);
2078 }
2079
|
2080 carolann.graves 1.49 Message *
2081 DefaultProviderManager::handleSubscriptionInitCompleteRequest
2082 (const Message * message)
2083 {
2084 PEG_METHOD_ENTER (TRC_PROVIDERMANAGER,
2085 "DefaultProviderManager::handleSubscriptionInitCompleteRequest");
2086
2087 CIMSubscriptionInitCompleteRequestMessage * request =
2088 dynamic_cast <CIMSubscriptionInitCompleteRequestMessage *>
2089 (const_cast <Message *> (message));
2090
2091 PEGASUS_ASSERT (request != 0);
2092
2093 CIMSubscriptionInitCompleteResponseMessage * response =
2094 dynamic_cast <CIMSubscriptionInitCompleteResponseMessage *>
2095 (request->buildResponse ());
2096
2097 PEGASUS_ASSERT (response != 0);
2098
2099 //
2100 // Set indicator
2101 carolann.graves 1.49 //
2102 _subscriptionInitComplete = true;
2103
2104 //
2105 // For each provider that has at least one subscription, call
2106 // provider's enableIndications method
2107 //
2108 Array <Provider *> enableProviders;
2109 enableProviders = providerManager.getIndicationProvidersToEnable ();
2110
2111 Uint32 numProviders = enableProviders.size ();
2112 for (Uint32 i = 0; i < numProviders; i++)
2113 {
2114 try
2115 {
2116 CIMInstance provider;
2117 provider = enableProviders [i]->getProviderInstance ();
2118
2119 //
2120 // Get cached or load new provider module
2121 //
|
2122 kumpf 1.50 OpProviderHolder ph = providerManager.getProvider(
2123 enableProviders[i]->getModule()->getFileName(),
2124 enableProviders[i]->getName());
|
2125 carolann.graves 1.49
2126 _callEnableIndications (provider, _indicationCallback, ph);
2127 }
2128 catch (CIMException & e)
2129 {
2130 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL2,
2131 "CIMException: " + e.getMessage ());
2132 }
2133 catch (Exception & e)
2134 {
2135 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL2,
2136 "Exception: " + e.getMessage ());
2137 }
2138 catch(...)
2139 {
2140 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL2,
2141 "Unknown error in handleSubscriptionInitCompleteRequest");
2142 }
2143 }
2144
2145 PEG_METHOD_EXIT ();
2146 carolann.graves 1.49 return (response);
2147 }
2148
|
2149 chip 1.1 void DefaultProviderManager::_insertEntry (
2150 const Provider & provider,
|
2151 kumpf 1.57 EnableIndicationsResponseHandler* handler)
|
2152 chip 1.1 {
|
2153 carolann.graves 1.41 PEG_METHOD_ENTER (TRC_PROVIDERMANAGER,
|
2154 chip 1.1 "DefaultProviderManager::_insertEntry");
2155
|
2156 kumpf 1.57 String tableKey = _generateKey(provider);
|
2157 chip 1.1
|
2158 kumpf 1.57 AutoMutex lock(_responseTableMutex);
2159 _responseTable.insert(tableKey, handler);
|
2160 chip 1.1
2161 PEG_METHOD_EXIT();
2162 }
2163
2164 EnableIndicationsResponseHandler * DefaultProviderManager::_removeEntry(
2165 const String & key)
2166 {
|
2167 carolann.graves 1.41 PEG_METHOD_ENTER (TRC_PROVIDERMANAGER,
|
2168 chip 1.1 "DefaultProviderManager::_removeEntry");
2169 EnableIndicationsResponseHandler *ret = 0;
2170
|
2171 kumpf 1.57 AutoMutex lock(_responseTableMutex);
|
2172 chip 1.1 _responseTable.lookup(key, ret);
|
2173 kumpf 1.57 _responseTable.remove(key);
|
2174 chip 1.1
2175 PEG_METHOD_EXIT();
2176
2177 return(ret);
2178 }
2179
2180 String DefaultProviderManager::_generateKey (
2181 const Provider & provider)
2182 {
2183 String tableKey;
2184
|
2185 carolann.graves 1.41 PEG_METHOD_ENTER (TRC_PROVIDERMANAGER,
|
2186 chip 1.1 "DefaultProviderManager::_generateKey");
2187
2188 //
2189 // Append provider key values to key
2190 //
2191 String providerName = provider.getName();
2192 String providerFileName = provider.getModule()->getFileName();
2193 tableKey.append (providerName);
2194 tableKey.append (providerFileName);
2195
2196 PEG_METHOD_EXIT();
2197
2198 return(tableKey);
|
2199 schuur 1.18 }
2200
2201 String DefaultProviderManager::_generateKey (
2202 const String & providerName,
2203 const String & providerFileName)
2204 {
2205 String tableKey;
2206
|
2207 carolann.graves 1.41 PEG_METHOD_ENTER (TRC_PROVIDERMANAGER,
|
2208 schuur 1.18 "DefaultProviderManagerService::_generateKey");
2209
2210 //
2211 // Append providerName and providerFileName to key
2212 //
2213 tableKey.append (providerName);
2214 tableKey.append (providerFileName);
2215
2216 PEG_METHOD_EXIT ();
2217 return tableKey;
|
2218 chip 1.5 }
2219
|
2220 kumpf 1.28 ProviderName DefaultProviderManager::_resolveProviderName(
2221 const ProviderIdContainer & providerId)
|
2222 chip 1.5 {
|
2223 kumpf 1.28 String providerName;
2224 String fileName;
2225 String interfaceName;
2226 CIMValue genericValue;
2227
2228 genericValue = providerId.getProvider().getProperty(
2229 providerId.getProvider().findProperty("Name")).getValue();
2230 genericValue.get(providerName);
2231
2232 genericValue = providerId.getModule().getProperty(
2233 providerId.getModule().findProperty("Location")).getValue();
2234 genericValue.get(fileName);
2235 fileName = _resolvePhysicalName(fileName);
2236
2237 // ATTN: This attribute is probably not required
2238 genericValue = providerId.getModule().getProperty(
2239 providerId.getModule().findProperty("InterfaceType")).getValue();
2240 genericValue.get(interfaceName);
|
2241 chip 1.5
|
2242 kumpf 1.28 return ProviderName(providerName, fileName, interfaceName, 0);
|
2243 schuur 1.23 }
2244
|
2245 kumpf 1.31 Boolean DefaultProviderManager::hasActiveProviders()
2246 {
2247 return providerManager.hasActiveProviders();
2248 }
2249
2250 void DefaultProviderManager::unloadIdleProviders()
|
2251 schuur 1.23 {
|
2252 kumpf 1.31 providerManager.unloadIdleProviders();
|
2253 chip 1.1 }
2254
|
2255 carolann.graves 1.49 void DefaultProviderManager::_callEnableIndications
2256 (CIMInstance & req_provider,
|
2257 kumpf 1.62 PEGASUS_INDICATION_CALLBACK_T _indicationCallback,
|
2258 carolann.graves 1.49 OpProviderHolder & ph)
2259 {
2260 PEG_METHOD_ENTER (TRC_PROVIDERMANAGER,
2261 "DefaultProviderManager::_callEnableIndications");
2262
2263 try
2264 {
2265 CIMRequestMessage * request = 0;
2266 CIMResponseMessage * response = 0;
2267 EnableIndicationsResponseHandler * enableHandler =
|
2268 kumpf 1.62 new EnableIndicationsResponseHandler(
2269 request,
2270 response,
2271 req_provider,
2272 _indicationCallback,
2273 _responseChunkCallback);
|
2274 carolann.graves 1.49
2275 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
2276 "Calling provider.enableIndications: " +
2277 ph.GetProvider ().getName ());
2278
2279 pm_service_op_lock op_lock (& ph.GetProvider ());
2280 ph.GetProvider ().protect ();
2281 ph.GetProvider ().enableIndications (* enableHandler);
2282
2283 //
2284 // Store the handler so it is persistent for as
2285 // long as the provider has indications enabled
2286 //
2287 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
2288 "Storing indication handler for " +
2289 ph.GetProvider ().getName ());
2290
2291 _insertEntry (ph.GetProvider (), enableHandler);
2292 }
2293 catch (CIMException & e)
2294 {
2295 carolann.graves 1.49 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL2,
2296 "CIMException: " + e.getMessage ());
2297
|
2298 mike 1.56 Logger::put_l(Logger::ERROR_LOG, System::CIMSERVER, Logger::WARNING,
|
2299 carolann.graves 1.49 "ProviderManager.Default.DefaultProviderManager."
2300 "ENABLE_INDICATIONS_FAILED",
2301 "Failed to enable indications for provider $0: $1.",
2302 ph.GetProvider ().getName (), e.getMessage ());
2303 }
2304 catch (Exception & e)
2305 {
2306 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL2,
2307 "Exception: " + e.getMessage ());
2308
2309 Logger::put_l (Logger::ERROR_LOG, System::CIMSERVER, Logger::WARNING,
2310 "ProviderManager.Default.DefaultProviderManager."
2311 "ENABLE_INDICATIONS_FAILED",
2312 "Failed to enable indications for provider $0: $1.",
2313 ph.GetProvider ().getName (), e.getMessage ());
2314 }
2315 catch(...)
2316 {
2317 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL2,
2318 "Unexpected error in _callEnableIndications");
2319
2320 carolann.graves 1.49 Logger::put_l (Logger::ERROR_LOG, System::CIMSERVER, Logger::WARNING,
2321 "ProviderManager.Default.DefaultProviderManager."
2322 "ENABLE_INDICATIONS_FAILED_UNKNOWN",
2323 "Failed to enable indications for provider $0.",
2324 ph.GetProvider ().getName ());
2325 }
2326
2327 PEG_METHOD_EXIT ();
2328 }
2329
|
2330 mike 1.63 ProviderManager* DefaultProviderManager::createDefaultProviderManagerCallback()
2331 {
2332 return new DefaultProviderManager();
2333 }
2334
|
2335 kumpf 1.26 PEGASUS_NAMESPACE_END
|
Return to
DefaultProviderManager.cpp
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / ProviderManager2 / Default