1 karl 1.33 //%2006////////////////////////////////////////////////////////////////////////
|
2 schuur 1.1 //
|
3 karl 1.12 // Copyright (c) 2000, 2001, 2002 BMC Software; Hewlett-Packard Development
4 // Company, L.P.; IBM Corp.; The Open Group; Tivoli Systems.
5 // Copyright (c) 2003 BMC Software; Hewlett-Packard Development Company, L.P.;
6 // IBM Corp.; EMC Corporation, The Open Group.
7 // Copyright (c) 2004 BMC Software; Hewlett-Packard Development Company, L.P.;
8 // IBM Corp.; EMC Corporation; VERITAS Software Corporation; The Open Group.
|
9 karl 1.16 // Copyright (c) 2005 Hewlett-Packard Development Company, L.P.; IBM Corp.;
10 // EMC Corporation; VERITAS Software Corporation; The Open Group.
|
11 karl 1.33 // Copyright (c) 2006 Hewlett-Packard Development Company, L.P.; IBM Corp.;
12 // EMC Corporation; Symantec Corporation; The Open Group.
|
13 schuur 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.16 //
|
21 schuur 1.1 // THE ABOVE COPYRIGHT NOTICE AND THIS PERMISSION NOTICE SHALL BE INCLUDED IN
22 // ALL COPIES OR SUBSTANTIAL PORTIONS OF THE SOFTWARE. THE SOFTWARE IS PROVIDED
23 // "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT
24 // LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR
25 // PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT
26 // HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
27 // ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
28 // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
29 //
30 //==============================================================================
31 //
32 //%/////////////////////////////////////////////////////////////////////////////
33
|
34 schuur 1.10 #include "CMPI_Version.h"
35
|
36 schuur 1.1 #include <Pegasus/Common/Constants.h>
|
37 mike 1.38 #include <Pegasus/Common/Time.h>
|
38 schuur 1.1 #include <Pegasus/Common/Tracer.h>
39 #include <Pegasus/Common/PegasusVersion.h>
40
|
41 konrad.r 1.26 #include <Pegasus/Common/MessageLoader.h>
42
|
43 schuur 1.1 #include <Pegasus/ProviderManager2/CMPI/CMPIProvider.h>
44 #include <Pegasus/ProviderManager2/CMPI/CMPIProviderModule.h>
|
45 konrad.r 1.30 #include <Pegasus/ProviderManager2/CMPI/CMPILocalProviderManager.h>
|
46 kumpf 1.9
|
47 schuur 1.3 PEGASUS_USING_STD;
|
48 schuur 1.1 PEGASUS_NAMESPACE_BEGIN
|
49 konrad.r 1.27 #define DDD(X) if (_cmpi_trace) X;
50
51 extern int _cmpi_trace;
52
|
53 schuur 1.8 #undef IDLE_LIMIT
54 #define IDLE_LIMIT 50
|
55 konrad.r 1.30
56 /* Thread deletion specific */
57 Semaphore CMPILocalProviderManager::_pollingSem(0);
58 AtomicInt CMPILocalProviderManager::_stopPolling(0);
59 Thread *CMPILocalProviderManager::_reaperThread = 0;
|
60 mike 1.38 List<CMPILocalProviderManager::cleanupThreadRecord,Mutex> CMPILocalProviderManager::_finishedThreadList;
61 Mutex CMPILocalProviderManager::_reaperMutex;
|
62 konrad.r 1.30
|
63 konrad.r 1.24 CMPILocalProviderManager::CMPILocalProviderManager (void):
64 _idle_timeout (IDLE_LIMIT)
|
65 r.kieninger 1.14 {
|
66 schuur 1.1 }
67
|
68 konrad.r 1.24 CMPILocalProviderManager::~CMPILocalProviderManager (void)
|
69 r.kieninger 1.14 {
|
70 konrad.r 1.24 Uint32 ccode;
|
71 dj.gorey 1.6
|
72 konrad.r 1.24 _provider_ctrl (UNLOAD_ALL_PROVIDERS, this, &ccode);
73 // Since all of the providers are deleted we can delete the
74 // modules too.
75 for (ModuleTable::Iterator j = _modules.start (); j != 0; j++)
76 {
77 CMPIProviderModule *module = j.value ();
78 delete module;
79 }
|
80 konrad.r 1.30
81 if (_reaperThread)
82 {
83 AutoMutex lock(_reaperMutex);
84 _stopPolling++;
85 _pollingSem.signal();
86 // Wait until it finishes itself.
87 _reaperThread->join();
88 delete _reaperThread;
89 _reaperThread = 0;
90 }
91 PEGASUS_ASSERT(_finishedThreadList.size() == 0);
92
|
93 schuur 1.1 }
94
|
95 konrad.r 1.24 Sint32
96 CMPILocalProviderManager::_provider_ctrl (CTRL code, void *parm, void *ret)
|
97 r.kieninger 1.14 {
|
98 r.kieninger 1.13
|
99 konrad.r 1.24 static Uint32 quantum;
100 PEG_METHOD_ENTER (TRC_PROVIDERMANAGER, "_provider_ctrl");
|
101 r.kieninger 1.13
|
102 konrad.r 1.24 Sint32 ccode = 0;
103 CTRL_STRINGS *parms = reinterpret_cast < CTRL_STRINGS * >(parm);
|
104 r.kieninger 1.13
|
105 konrad.r 1.24 switch (code)
|
106 r.kieninger 1.14 {
107
108 case GET_PROVIDER:
|
109 konrad.r 1.24 {
|
110 r.kieninger 1.14
|
111 konrad.r 1.24 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL2,
112 "_provider_ctrl::GET_PROVIDER");
|
113 r.kieninger 1.14
|
114 konrad.r 1.24 String providerName = *(parms->providerName);
115 String moduleFileName = *(parms->fileName);
116 String location = *(parms->location);
|
117 r.kieninger 1.14
|
118 konrad.r 1.24 CMPIProvider *pr = 0;
119 CMPIProvider::OpProviderHolder * ph =
120 reinterpret_cast < CMPIProvider::OpProviderHolder * >(ret);
|
121 r.kieninger 1.14
|
122 konrad.r 1.24 pr = _lookupProvider (providerName);
|
123 r.kieninger 1.15
|
124 konrad.r 1.24 if (pr->getStatus () != CMPIProvider::INITIALIZED)
125 {
126 pr->setLocation (location);
127 _initProvider (pr, moduleFileName);
|
128 r.kieninger 1.13
|
129 konrad.r 1.24 if (pr->getStatus () != CMPIProvider::INITIALIZED)
130 {
131 PEG_METHOD_EXIT ();
132 throw PEGASUS_CIM_EXCEPTION (CIM_ERR_FAILED,
133 "provider initialization failed");
134 }
135 }
|
136 r.kieninger 1.13
137
|
138 konrad.r 1.24 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
139 "Returning Provider" + providerName);
|
140 schuur 1.1
|
141 r.kieninger 1.15
|
142 konrad.r 1.24 ph->SetProvider (pr);
143 ph->GetProvider ().update_idle_timer ();
144 break;
145 }
|
146 r.kieninger 1.14
147 case UNLOAD_PROVIDER:
|
148 konrad.r 1.24 {
149
150 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL2,
151 "_provider_ctrl::UNLOAD_PROVIDER");
|
152 konrad.r 1.30 CMPIProvider *pr = 0;
153 pr = _lookupProvider (*(parms->providerName));
|
154 konrad.r 1.24 if ((pr->getStatus () == CMPIProvider::INITIALIZED))
155 {
|
156 r.kieninger 1.14
|
157 konrad.r 1.24 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
|
158 konrad.r 1.26 "Unloading CMPIProvider: " + pr->getName());
|
159 r.kieninger 1.14
|
160 konrad.r 1.24 AutoMutex lock (_providerTableMutex);
161 // The provider table must be locked before unloading.
162 _providers.remove (pr->_name);
163 _unloadProvider (pr);
164 delete pr;
|
165 r.kieninger 1.14
|
166 konrad.r 1.24 }
|
167 konrad.r 1.25 else {
168 // No need to have a memory leak.
|
169 konrad.r 1.29 _providers.remove(pr->_name);
|
170 konrad.r 1.25 delete pr;
171 }
|
172 konrad.r 1.24 break;
173 }
|
174 schuur 1.1
|
175 r.kieninger 1.14 case LOOKUP_PROVIDER:
|
176 konrad.r 1.24 {
177
178 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL2,
179 "_provider_ctrl::LOOKUP_PROVIDER");
|
180 schuur 1.1
|
181 konrad.r 1.24 AutoMutex lock (_providerTableMutex);
|
182 schuur 1.1
|
183 konrad.r 1.24 if (true == _providers.lookup (*(parms->providerName),
184 *(reinterpret_cast <
185 CMPIProvider * *>(ret))))
186 {
187 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
188 "Found CMPIProvider in cache: " +
189 *(parms->providerName));
190
191 (*(reinterpret_cast < CMPIProvider * *>(ret)))->
192 update_idle_timer ();
193 }
194 else
195 {
196
197 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
198 "Could not find CMPIProvider in cache: " +
199 *(parms->providerName));
200 ccode = -1;
201 }
|
202 dj.gorey 1.6
|
203 konrad.r 1.24 break;
204 }
|
205 schuur 1.1
|
206 konrad.r 1.24 case LOOKUP_MODULE:
207 {
|
208 schuur 1.1
|
209 konrad.r 1.24 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL2,
210 "_provider_ctrl::LOOKUP_MODULE");
|
211 schuur 1.1
|
212 konrad.r 1.24 AutoMutex lock (_providerTableMutex);
|
213 schuur 1.1
|
214 konrad.r 1.24 if (false == _modules.lookup (*(parms->fileName),
215 *(reinterpret_cast <
216 CMPIProviderModule * *>(ret))))
217 {
218 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
219 "Could not find CMPIProvider Module in cache: "
220 + *(parms->fileName));
221 ccode = -1;
222 }
|
223 schuur 1.1
|
224 konrad.r 1.24 break;
225 }
|
226 schuur 1.1
|
227 konrad.r 1.24 case INSERT_PROVIDER:
228 {
|
229 r.kieninger 1.14
|
230 konrad.r 1.24 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL2,
231 "_provider_ctrl::INSERT_PROVIDER");
|
232 schuur 1.1
|
233 konrad.r 1.24 AutoMutex lock (_providerTableMutex);
|
234 konrad.r 1.26
|
235 konrad.r 1.24 if (false == _providers.insert (*(parms->providerName),
236 *reinterpret_cast <
237 CMPIProvider * *>(parm)))
238 ccode = -1;
239 break;
240 }
241 case INSERT_MODULE:
242 {
243 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL2,
244 "_provider_ctrl::INSERT_MODULE");
245 AutoMutex lock (_providerTableMutex);
246 if (false == _modules.insert (*(parms->fileName),
247 *reinterpret_cast <
248 CMPIProviderModule * *>(parm)))
249 ccode = -1;
250 break;
251 }
|
252 schuur 1.1
|
253 konrad.r 1.24 case UNLOAD_ALL_PROVIDERS:
254 {
255 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL2,
256 "_provider_ctrl::UNLOAD_ALL_PROVIDERS");
257 CMPILocalProviderManager *myself =
258 reinterpret_cast < CMPILocalProviderManager * >(parm);
259 CMPIProvider *provider = 0;
260 // Locked provider mutex.
261 AutoMutex lock (_providerTableMutex);
|
262 dj.gorey 1.6
|
263 konrad.r 1.24 Tracer::trace (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
264 "providers in cache = %d", myself->_providers.size ());
265 ProviderTable::Iterator i = myself->_providers.start ();
266 try
267 {
268 for (; i != 0; i++)
269 {
|
270 r.kieninger 1.15
|
271 konrad.r 1.24 provider = i.value ();
272 PEGASUS_ASSERT (provider != 0);
273 if (provider->getStatus () == CMPIProvider::UNINITIALIZED)
274 {
275 // Delete the skeleton.
|
276 konrad.r 1.30 delete provider;
|
277 konrad.r 1.24 continue;
278 }
279 else
280 {
281 _unloadProvider (provider);
282 delete provider;
283 }
284 }
285 // All the providers are removed. Clear the hash-table
286 _providers.clear ();
|
287 r.kieninger 1.14 }
|
288 konrad.r 1.24 catch (...)
|
289 r.kieninger 1.14 {
|
290 konrad.r 1.24 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
291 "Unexpected Exception in UNLOAD_ALL_PROVIDERS.");
|
292 r.kieninger 1.14 }
|
293 konrad.r 1.24 break;
294 }
295 case UNLOAD_IDLE_PROVIDERS:
296 {
297 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL2,
298 "_provider_ctrl::UNLOAD_IDLE_PROVIDERS");
299 AutoMutex lock (_providerTableMutex);
300
301 quantum++;
302 CMPILocalProviderManager *myself =
303 reinterpret_cast < CMPILocalProviderManager * >(parm);
|
304 kumpf 1.32 CMPIProvider *provider = 0;
|
305 konrad.r 1.24 Uint32 numProviders = myself->_providers.size ();
306
307 if (numProviders)
308 {
309 // Rather than removing the provider immediately while
310 // iterating through the list we remember all candidates
311 // for unload in a simple array.
312 CMPIProvider **unloadProviderArray =
313 new CMPIProvider *[numProviders];
314 Uint32 upaIndex = 0;
|
315 r.kieninger 1.15
|
316 r.kieninger 1.14 try
317 {
|
318 konrad.r 1.24 struct timeval now;
|
319 mike 1.38 Time::gettimeofday (&now);
|
320 konrad.r 1.24 ProviderTable::Iterator i = myself->_providers.start ();
321
322 for (; i != 0; i++)
|
323 r.kieninger 1.14 {
|
324 konrad.r 1.24 provider = i.value ();
325 PEGASUS_ASSERT (provider != 0);
326
327 if (provider->getStatus () == CMPIProvider::UNINITIALIZED)
|
328 r.kieninger 1.14 {
|
329 konrad.r 1.24 continue;
|
330 r.kieninger 1.14 }
|
331 konrad.r 1.24
332 if (provider->_quantum == quantum)
|
333 r.kieninger 1.14 {
|
334 konrad.r 1.24 continue;
|
335 r.kieninger 1.14 }
|
336 r.kieninger 1.15
|
337 konrad.r 1.24 provider->_quantum = quantum;
338
|
339 mike 1.31 if (provider->_current_operations.get ())
|
340 konrad.r 1.24 {
341 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
342 "CMPIProvider has pending operations: "
343 + provider->getName ());
|
344 r.kieninger 1.14
|
345 konrad.r 1.24 continue;
|
346 r.kieninger 1.15 }
|
347 r.kieninger 1.14
|
348 konrad.r 1.24 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
349 "Checking timeout data for CMPIProvider: "
350 + provider->getName ());
351 struct timeval timeout = { 0, 0 };
352 provider->get_idle_timer (&timeout);
353
354 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
355 " provider->unload_ok() returns: " +
356 provider->unload_ok ()? "true" : "false");
357
358 if (provider->unload_ok () == true &&
359 (now.tv_sec - timeout.tv_sec) >
360 ((Sint32) myself->_idle_timeout))
361 {
362 // Remember this provider to be unloaded
363 unloadProviderArray[upaIndex] = provider;
364 upaIndex++;
|
365 r.kieninger 1.14 }
|
366 konrad.r 1.24 //else cout<<"--- NOT unloaded: "+ provider->getName()<<endl;
|
367 r.kieninger 1.14 }
|
368 konrad.r 1.24
369 // Now finally we unload all providers that we identified as
370 // candidates above.
371 for (Uint32 index = 0; index < upaIndex; index++)
372 {
373 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
374 "Now trying to unload CMPIProvider " +
375 provider->getName ());
376 CMPIProvider *provider = unloadProviderArray[index];
377
|
378 dave.sudlik 1.39 {
379 // lock the provider mutex
380
381 AutoMutex pr_lock (provider->_statusMutex);
|
382 konrad.r 1.24
|
383 dave.sudlik 1.39 if (provider->tryTerminate () == false)
384 {
385 // provider not unloaded -- we are respecting this!
386 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
387 "Provider refused to unload: " +
388 unloadProviderArray[index]->getName());
389 continue;
390 }
391
392 PEGASUS_ASSERT (provider->_module != 0);
393
394 // unload provider module
395 provider->_module->unloadModule ();
396 Logger::put (Logger::STANDARD_LOG, System::CIMSERVER,
397 Logger::TRACE,
398 "CMPILocalProviderManager::_provider_crtl - Unload provider $0",
399 provider->getName ());
|
400 konrad.r 1.24
|
401 dave.sudlik 1.42 // Note: The deleting of the cimom handle is being
402 // moved after the call to unloadModule() based on
403 // a previous fix for bug 3669 and consistency with
404 // other provider managers. Do not move it back before
405 // the call to unloadModule().
406 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
407 "Destroying CMPIProvider's CIMOM Handle "
408 + provider->getName());
409 delete provider->_cimom_handle;
410
|
411 dave.sudlik 1.39 // set provider status to UNINITIALIZED
412 provider->reset ();
|
413 mark.hamzy 1.28 }
|
414 r.kieninger 1.14 }
|
415 konrad.r 1.24 }
416 catch (...)
417 {
418 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
419 "Unexpected Exception in UNLOAD_IDLE_PROVIDERS.");
420 }
|
421 dave.sudlik 1.42 delete [] unloadProviderArray;
|
422 konrad.r 1.24 } // if there are any providers
423 break;
424 }
|
425 r.kieninger 1.14
426 default:
|
427 konrad.r 1.24 ccode = -1;
428 break;
|
429 r.kieninger 1.14 }
|
430 konrad.r 1.24 PEG_METHOD_EXIT ();
431 return (ccode);
|
432 schuur 1.1 }
433
|
434 konrad.r 1.30
435
436 /*
437 * The reaper function polls out the threads from the global list (_finishedThreadList),
438 * joins them deletes them, and removes them from the CMPIProvider specific list.
439 */
|
440 mike 1.38 ThreadReturnType PEGASUS_THREAD_CDECL CMPILocalProviderManager::_reaper(void *parm)
|
441 konrad.r 1.30 {
442 Thread *myself = reinterpret_cast<Thread *>(parm);
443 do {
444 _pollingSem.wait();
445 // All of the threads are finished working. We just need to reap 'em
446 cleanupThreadRecord *rec = 0;
447
448 while (_finishedThreadList.size() >0 )
449 {
450 // Pull of the the threads from the global list.
|
451 mike 1.35 rec = _finishedThreadList.remove_front();
|
452 konrad.r 1.30 DDD(cerr << "Reaping the thread " << rec->thread << " from " << rec->provider->getName() << endl);
453 rec->thread->join();
|
454 mike 1.35
455 // Remove the thread for the CMPIProvider.
|
456 dave.sudlik 1.34 rec->provider->threadDelete(rec->thread);
|
457 mike 1.35
458 // Delete the thread.
|
459 konrad.r 1.30 delete rec->thread;
460 delete rec;
461 }
462 }
|
463 mike 1.31 while (_stopPolling.get() == 0);
|
464 mike 1.38 myself->exit_self( (ThreadReturnType) 0);
|
465 konrad.r 1.30 return (0);
466 }
467 /*
468 // Cleanup the thread and upon deletion of it, call the CMPIProvider' "threadDeleted".
469 // to not, all the CMPIProvider '
470 // Note that this function is called from the thread that finished with
471 // running the providers function, and returns immediately while scheduling the
472 // a cleanup procedure. If you want to wait until the thread is truly deleted,
473 // call 'waitUntilThreadsDone' - but DO NOT do it in the the thread that
474 // the Thread owns - you will wait forever.
475 //
476 // @argument t Thread that is not NULL and finished with running the provider function.
477 // @argument p CMPIProvider in which the 't' Thread was running.
478 */
479 void
480 CMPILocalProviderManager::cleanupThread(Thread *t, CMPIProvider *p)
481 {
482 PEGASUS_ASSERT( t != 0 && p != 0 );
483
484 PEGASUS_ASSERT ( p->isThreadOwner(t) );
485 // The mutex guards against a race condition for _reaperThread creation.
486 konrad.r 1.30 AutoMutex lock(_reaperMutex);
487
488 // Put the Thread and the CMPIProvider on the global list.
489 cleanupThreadRecord *record = new cleanupThreadRecord(t, p);
|
490 mike 1.35 _finishedThreadList.insert_back(record);
|
491 konrad.r 1.30
492 if (_reaperThread == 0)
493 {
494 _reaperThread = new Thread(_reaper, NULL, false);
495 ThreadStatus rtn = PEGASUS_THREAD_OK;
496 while ( (rtn = _reaperThread->run()) != PEGASUS_THREAD_OK)
497 {
498 if (rtn == PEGASUS_THREAD_INSUFFICIENT_RESOURCES)
|
499 mike 1.38 Threads::yield();
|
500 konrad.r 1.30 else
501 {
502 PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL2, \
503 "Could not allocate thread to take care of deleting user threads. ");
504 delete _reaperThread; _reaperThread = 0;
505 return;
506 }
507 }
508 }/*
509 Tracer::trace(TRC_PROVIDERMANAGER, Tracer::LEVEL2, \
510 "Cleaning up provider thread (%p) from provider %s.",
511 t, (const char *)p->getName().getCString());*/
512 // Wake up the reaper.
513 _pollingSem.signal();
514
515 }
516
|
517 konrad.r 1.24 CMPIProvider::OpProviderHolder CMPILocalProviderManager::
518 getRemoteProvider (const String & location, const String & providerName)
519 {
520 CMPIProvider::OpProviderHolder ph;
521 CTRL_STRINGS
522 strings;
523 Sint32
524 ccode;
525 const String
526 proxy ("CMPIRProxyProvider");
527
528 String
529 rproviderName ("R");
530 PEG_METHOD_ENTER (TRC_PROVIDERMANAGER,
531 "ProvidertManager::getRemoteProvider");
532
533 rproviderName.append (providerName);
534
535 strings.fileName = &proxy;
536 strings.providerName = &rproviderName;
537 strings.location = &location;
538 konrad.r 1.24
539 try
540 {
541 ccode = _provider_ctrl (GET_PROVIDER, &strings, &ph);
542 }
543 catch (const Exception & e)
544 {
|
545 konrad.r 1.27 DDD(cerr << "--- loading proxy: " << e.getMessage () << endl);
|
546 konrad.r 1.24 PEG_METHOD_EXIT ();
547 throw;
548 }
549 catch (...)
550 {
551 PEG_METHOD_EXIT ();
552 throw;
|
553 kumpf 1.43 }
|
554 schuur 1.10
|
555 konrad.r 1.24 PEG_METHOD_EXIT ();
|
556 kumpf 1.43 return ph;
|
557 schuur 1.1 }
558
|
559 konrad.r 1.24 CMPIProvider::OpProviderHolder CMPILocalProviderManager::
560 getProvider (const String & fileName, const String & providerName)
|
561 r.kieninger 1.14 {
|
562 konrad.r 1.24 CMPIProvider::OpProviderHolder ph;
563 CTRL_STRINGS
564 strings;
565 Sint32
566 ccode;
|
567 r.kieninger 1.15
|
568 konrad.r 1.24 String
569 lproviderName ("L");
570 PEG_METHOD_ENTER (TRC_PROVIDERMANAGER, "ProviderManager::getProvider");
|
571 konrad.r 1.26 if (fileName.size() == 0)
572 {
|
573 thilo.boehm 1.36 throw Exception(MessageLoaderParms(
574 "ProviderManager.CMPI.CMPILocalProviderManager.CANNOT_FIND_LIBRARY",
575 "For provider $0 the library name was empty. Check provider registered location.",
576 providerName));
|
577 r.kieninger 1.15
|
578 konrad.r 1.26 }
|
579 konrad.r 1.24 lproviderName.append (providerName);
580 strings.fileName = &fileName;
581 strings.providerName = &lproviderName;
582 strings.location = &String::EMPTY;
|
583 r.kieninger 1.14
|
584 konrad.r 1.24 try
585 {
586 ccode = _provider_ctrl (GET_PROVIDER, &strings, &ph);
587 }
588 catch (const Exception & e)
589 {
|
590 konrad.r 1.27 DDD(cerr << "--- loading proxy: " << e.getMessage () << endl);
|
591 konrad.r 1.24 PEG_METHOD_EXIT ();
592 throw;
593 }
594 catch (...)
595 {
596 PEG_METHOD_EXIT ();
597 throw;
598 }
|
599 schuur 1.1
600
|
601 konrad.r 1.24 PEG_METHOD_EXIT ();
602 return (ph);
|
603 schuur 1.1
604 }
605
|
606 konrad.r 1.24 void
607 CMPILocalProviderManager::unloadProvider (const String & fileName,
608 const String & providerName)
|
609 r.kieninger 1.14 {
|
610 konrad.r 1.24 CTRL_STRINGS strings;
611 PEG_METHOD_ENTER (TRC_PROVIDERMANAGER, "ProviderManager::unloadProvider");
|
612 konrad.r 1.25
613 String lproviderName ("L");
614 String rproviderName ("R");
615 lproviderName.append (providerName);
616 rproviderName.append (providerName);
617
|
618 konrad.r 1.24 strings.fileName = &fileName;
|
619 konrad.r 1.25 strings.providerName = &lproviderName;
620 strings.location = &String::EMPTY;
|
621 konrad.r 1.24 _provider_ctrl (UNLOAD_PROVIDER, &strings, (void *) 0);
|
622 konrad.r 1.25
623 strings.providerName = &rproviderName;
624
625 _provider_ctrl (UNLOAD_PROVIDER, &strings, (void *) 0);
626
|
627 konrad.r 1.24 PEG_METHOD_EXIT ();
|
628 r.kieninger 1.14 }
629
|
630 konrad.r 1.24 void
631 CMPILocalProviderManager::shutdownAllProviders (void)
|
632 r.kieninger 1.14 {
633
|
634 konrad.r 1.24 PEG_METHOD_ENTER (TRC_PROVIDERMANAGER,
635 "ProviderManager::shutdownAllProviders");
636 _provider_ctrl (UNLOAD_ALL_PROVIDERS, (void *) this, (void *) 0);
637 PEG_METHOD_EXIT ();
|
638 r.kieninger 1.13 }
639
640
|
641 konrad.r 1.24 Boolean
642 CMPILocalProviderManager::hasActiveProviders ()
|
643 r.kieninger 1.14 {
|
644 konrad.r 1.24 PEG_METHOD_ENTER (TRC_PROVIDERMANAGER,
645 "ProviderManager::hasActiveProviders");
|
646 r.kieninger 1.14
|
647 konrad.r 1.24 try
648 {
649 AutoMutex lock (_providerTableMutex);
650 Tracer::trace (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
651 "providers in _providers table = %d", _providers.size ());
|
652 r.kieninger 1.14
|
653 konrad.r 1.24 // Iterate through the _providers table looking for an active provider
654 for (ProviderTable::Iterator i = _providers.start (); i != 0; i++)
655 {
656 if (i.value ()->getStatus () == CMPIProvider::INITIALIZED)
657 {
658 PEG_METHOD_EXIT ();
659 return true;
660 }
661 }
662 }
663 catch (...)
664 {
665 // Unexpected exception; do not assume that no providers are loaded
666 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL2,
667 "Unexpected Exception in hasActiveProviders.");
668 PEG_METHOD_EXIT ();
669 return true;
670 }
|
671 r.kieninger 1.14
|
672 konrad.r 1.24 // No active providers were found in the _providers table
673 PEG_METHOD_EXIT ();
674 return false;
|
675 r.kieninger 1.14 }
676
|
677 konrad.r 1.24 void
678 CMPILocalProviderManager::unloadIdleProviders (void)
|
679 r.kieninger 1.14 {
|
680 kumpf 1.41 PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,
681 "ProviderManager::unloadIdleProviders");
|
682 r.kieninger 1.14
|
683 kumpf 1.41 try
|
684 r.kieninger 1.14 {
|
685 kumpf 1.41 _provider_ctrl (UNLOAD_IDLE_PROVIDERS, this, (void *) 0);
|
686 r.kieninger 1.14 }
|
687 kumpf 1.41 catch (...)
|
688 r.kieninger 1.14 {
|
689 kumpf 1.41 PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL2,
690 "Caught unexpected exception from UNLOAD_IDLE_PROVIDERS.");
|
691 r.kieninger 1.14 }
|
692 kumpf 1.41
693 PEG_METHOD_EXIT ();
|
694 schuur 1.1 }
695
|
696 konrad.r 1.24 Array <
697 CMPIProvider * >CMPILocalProviderManager::getIndicationProvidersToEnable ()
|
698 carolann.graves 1.17 {
|
699 konrad.r 1.24 PEG_METHOD_ENTER (TRC_PROVIDERMANAGER,
700 "CMPILocalProviderManager::getIndicationProvidersToEnable");
|
701 carolann.graves 1.17
|
702 konrad.r 1.24 Array < CMPIProvider * >enableProviders;
|
703 carolann.graves 1.17
|
704 konrad.r 1.24 Tracer::trace (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
705 "Number of providers in _providers table = %d",
706 _providers.size ());
|
707 carolann.graves 1.17
|
708 konrad.r 1.24 try
709 {
710 AutoMutex
711 lock (_providerTableMutex);
|
712 carolann.graves 1.17
|
713 konrad.r 1.24 //
714 // Iterate through the _providers table
715 //
716 for (ProviderTable::Iterator i = _providers.start (); i != 0; i++)
717 {
|
718 carolann.graves 1.17 //
|
719 konrad.r 1.24 // Enable any indication provider with current subscriptions
|
720 carolann.graves 1.17 //
|
721 konrad.r 1.24 CMPIProvider *
722 provider = i.value ();
723 if (provider->testSubscriptions ())
724 {
725 enableProviders.append (provider);
726 }
727 }
728
729 }
730 catch (const CIMException & e)
731 {
732 PEG_TRACE_STRING (TRC_DISCARDED_DATA, Tracer::LEVEL2,
733 "CIMException: " + e.getMessage ());
734 }
735 catch (const Exception & e)
736 {
737 PEG_TRACE_STRING (TRC_DISCARDED_DATA, Tracer::LEVEL2,
738 "Exception: " + e.getMessage ());
739 }
740 catch (...)
741 {
742 konrad.r 1.24 PEG_TRACE_STRING (TRC_DISCARDED_DATA, Tracer::LEVEL2,
743 "Unexpected error in getIndicationProvidersToEnable");
744 }
745
746 Tracer::trace (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
747 "Number of indication providers to enable = %d",
748 enableProviders.size ());
749
750 PEG_METHOD_EXIT ();
751 return enableProviders;
752 }
753
754 CMPIProvider *
755 CMPILocalProviderManager::_initProvider (CMPIProvider * provider,
756 const String & moduleFileName)
757 {
758 PEG_METHOD_ENTER (TRC_PROVIDERMANAGER, "_initProvider");
|
759 carolann.graves 1.17
|
760 konrad.r 1.24 CMPIProviderModule *module = 0;
761 ProviderVector base;
|
762 carolann.graves 1.17
|
763 konrad.r 1.24 {
764 // lock the providerTable mutex
765 AutoMutex lock (_providerTableMutex);
|
766 carolann.graves 1.17
|
767 konrad.r 1.24 // lookup provider module
768 module = _lookupModule (moduleFileName);
769 } // unlock the providerTable mutex
|
770 schuur 1.1
|
771 kumpf 1.37 Boolean moduleLoaded = false;
|
772 konrad.r 1.24 Boolean deleteProvider = false;
|
773 konrad.r 1.26 String exceptionMsg = moduleFileName;
|
774 konrad.r 1.24 {
775 // lock the provider status mutex
776 AutoMutex lock (provider->_statusMutex);
|
777 r.kieninger 1.14
|
778 konrad.r 1.24 if (provider->_status == CMPIProvider::INITIALIZED)
779 {
780 // Initialization is already complete
781 return provider;
782 }
|
783 r.kieninger 1.14
|
784 konrad.r 1.24 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
785 "Loading/Linking Provider Module " + moduleFileName);
|
786 kumpf 1.18
|
787 konrad.r 1.24 // load the provider
788 try
789 {
790 base = module->load (provider->_name);
|
791 kumpf 1.37 moduleLoaded = true;
|
792 konrad.r 1.24 }
|
793 konrad.r 1.26 catch (const Exception &e)
794 {
795 exceptionMsg = e.getMessage();
796 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
797 "Exception caught Loading/Linking Provider Module " +
798 moduleFileName+ " error is: "+exceptionMsg);
799 deleteProvider =true;
800 }
|
801 konrad.r 1.24 catch (...)
|
802 kumpf 1.18 {
|
803 konrad.r 1.24 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
|
804 konrad.r 1.26 "Unknown exception caught Loading/Linking Provider Module " +
|
805 konrad.r 1.24 moduleFileName);
|
806 konrad.r 1.26 exceptionMsg = moduleFileName;
|
807 kumpf 1.37 deleteProvider = true;
|
808 konrad.r 1.24 }
|
809 kumpf 1.37
|
810 konrad.r 1.26 if (!deleteProvider)
811 {
812 // initialize the provider
813 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL2,
814 "Initializing Provider " + provider->getName());
|
815 r.kieninger 1.14
|
816 konrad.r 1.26 CIMOMHandle *cimomHandle = new CIMOMHandle ();
817 provider->set (module, base, cimomHandle);
818 provider->_quantum = 0;
|
819 konrad.r 1.24
|
820 konrad.r 1.26 try
821 {
822 provider->initialize (*(provider->_cimom_handle));
823 }
824 catch (const Exception &e)
825 {
826 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL2,
827 "Problem initializing: " + e.getMessage());
828 deleteProvider = true;
829 exceptionMsg = e.getMessage();
830 }
831 catch (...)
832 {
833 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL2,
834 "Unknown problem initializing " + provider->getName());
835 deleteProvider = true;
836 exceptionMsg = provider->getName();
837 }
838 } // unlock the provider status mutex
839 }
840 /* We wait until this moment to delete the provider b/c we need
841 konrad.r 1.26 be outside the scope for the AutoMutex for the provider. */
842 if (deleteProvider)
843 {
|
844 konrad.r 1.24 // delete the cimom handle
845 delete provider->_cimom_handle;
846 // set provider status to UNINITIALIZED
847 provider->reset ();
|
848 kumpf 1.37
|
849 konrad.r 1.24 // unload provider module
|
850 kumpf 1.37 if (moduleLoaded)
851 {
852 module->unloadModule();
853 }
|
854 r.kieninger 1.14
|
855 konrad.r 1.24 AutoMutex lock (_providerTableMutex);
|
856 konrad.r 1.26 _providers.remove (provider->_name);
|
857 konrad.r 1.24 delete provider;
|
858 konrad.r 1.26
859 PEG_METHOD_EXIT ();
860 throw Exception(exceptionMsg);
|
861 r.kieninger 1.14 }
862
|
863 konrad.r 1.24 PEG_METHOD_EXIT ();
864 return (provider);
|
865 r.kieninger 1.14 }
866
867
|
868 konrad.r 1.24 void
869 CMPILocalProviderManager::_unloadProvider (CMPIProvider * provider)
|
870 r.kieninger 1.14 {
|
871 konrad.r 1.24 //
872 // NOTE: It is the caller's responsibility to make sure that
873 // the ProviderTable mutex is locked before calling this method.
874 //
875 PEG_METHOD_ENTER (TRC_PROVIDERMANAGER, "_unloadProvider");
|
876 r.kieninger 1.14
|
877 konrad.r 1.24 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
|
878 konrad.r 1.26 "Unloading Provider " + provider->getName());
|
879 r.kieninger 1.14
|
880 mike 1.31 if (provider->_current_operations.get ())
|
881 r.kieninger 1.14 {
|
882 konrad.r 1.24 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
883 "Provider cannot be unloaded due to pending operations: "
|
884 konrad.r 1.26 + provider->getName());
|
885 r.kieninger 1.14 }
|
886 konrad.r 1.24 else
|
887 r.kieninger 1.14 {
|
888 konrad.r 1.24 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
|
889 konrad.r 1.26 "Terminating Provider " + provider->getName());
|
890 konrad.r 1.24
|
891 r.kieninger 1.14
|
892 konrad.r 1.24 // lock the provider mutex
893 AutoMutex pr_lock (provider->_statusMutex);
|
894 r.kieninger 1.14
|
895 konrad.r 1.24 try
896 {
897 provider->terminate ();
898 }
899 catch (...)
900 {
901 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL3,
902 "Error occured terminating CMPI provider " +
|
903 konrad.r 1.26 provider->getName());
|
904 konrad.r 1.24 }
|
905 r.kieninger 1.14
|
906 konrad.r 1.24 // delete the cimom handle
907 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
908 "Destroying CMPIProvider's CIMOM Handle " +
|
909 konrad.r 1.26 provider->getName());
|
910 r.kieninger 1.14
|
911 konrad.r 1.24 delete provider->_cimom_handle;
912 PEGASUS_ASSERT (provider->_module != 0);
|
913 r.kieninger 1.14
|
914 konrad.r 1.24 // unload provider module
915 provider->_module->unloadModule ();
916 Logger::put (Logger::STANDARD_LOG, System::CIMSERVER, Logger::TRACE,
917 "CMPILocalProviderManager::_provider_crtl - Unload provider $0",
918 provider->getName ());
|
919 r.kieninger 1.14
|
920 konrad.r 1.24 // set provider status to UNINITIALIZED
921 provider->reset ();
|
922 r.kieninger 1.14
|
923 konrad.r 1.24 // Do not delete the provider. The function calling this function
924 // takes care of that.
|
925 r.kieninger 1.14 }
|
926 r.kieninger 1.13
|
927 konrad.r 1.24 PEG_METHOD_EXIT ();
|
928 dj.gorey 1.6 }
929
|
930 konrad.r 1.24 CMPIProvider *
931 CMPILocalProviderManager::_lookupProvider (const String & providerName)
|
932 r.kieninger 1.14 {
|
933 konrad.r 1.24 PEG_METHOD_ENTER (TRC_PROVIDERMANAGER, "_lookupProvider");
934 // lock the providerTable mutex
935 AutoMutex lock (_providerTableMutex);
936 // look up provider in cache
937 CMPIProvider *pr = 0;
938 if (true == _providers.lookup (providerName, pr))
|
939 r.kieninger 1.14 {
|
940 konrad.r 1.24 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
941 "Found Provider " + providerName +
942 " in CMPI Provider Manager Cache");
|
943 r.kieninger 1.14 }
|
944 konrad.r 1.24 else
|
945 r.kieninger 1.14 {
|
946 konrad.r 1.24 // create provider
947 pr = new CMPIProvider (providerName, 0, 0);
948 // insert provider in provider table
949 _providers.insert (providerName, pr);
|
950 r.kieninger 1.14
|
951 konrad.r 1.24 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
952 "Created provider " + pr->getName ());
|
953 r.kieninger 1.14 }
|
954 dj.gorey 1.6
|
955 konrad.r 1.24 PEG_METHOD_EXIT ();
956 return (pr);
|
957 dj.gorey 1.6 }
958
959
|
960 konrad.r 1.24 CMPIProviderModule *
961 CMPILocalProviderManager::_lookupModule (const String & moduleFileName)
|
962 r.kieninger 1.14 {
|
963 konrad.r 1.24 PEG_METHOD_ENTER (TRC_PROVIDERMANAGER, "_lookupModule");
|
964 r.kieninger 1.14
|
965 konrad.r 1.24 // look up provider module in cache
966 CMPIProviderModule *module = 0;
|
967 r.kieninger 1.14
|
968 konrad.r 1.24 if (true == _modules.lookup (moduleFileName, module))
|
969 r.kieninger 1.14 {
|
970 konrad.r 1.24 // found provider module in cache
971 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
972 "Found Provider Module" + moduleFileName +
973 " in Provider Manager Cache");
|
974 dj.gorey 1.6
|
975 konrad.r 1.24 }
976 else
977 {
978 // provider module not found in cache, create provider module
979 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
980 "Creating CMPI Provider Module " + moduleFileName);
|
981 r.kieninger 1.14
|
982 konrad.r 1.24 module = new CMPIProviderModule (moduleFileName);
|
983 r.kieninger 1.14
|
984 konrad.r 1.24 // insert provider module in module table
985 _modules.insert (moduleFileName, module);
|
986 r.kieninger 1.14 }
|
987 dj.gorey 1.6
|
988 konrad.r 1.24 PEG_METHOD_EXIT ();
989 return (module);
|
990 schuur 1.1 }
991
992 PEGASUS_NAMESPACE_END
|
Return to
CMPILocalProviderManager.cpp
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / ProviderManager2 / CMPI