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 marek 1.44 CMPIProvider *provider = unloadProviderArray[index];
|
374 konrad.r 1.24 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
375 "Now trying to unload CMPIProvider " +
376 provider->getName ());
|
377 dave.sudlik 1.39 {
378 // lock the provider mutex
379
380 AutoMutex pr_lock (provider->_statusMutex);
|
381 konrad.r 1.24
|
382 dave.sudlik 1.39 if (provider->tryTerminate () == false)
383 {
384 // provider not unloaded -- we are respecting this!
385 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
386 "Provider refused to unload: " +
387 unloadProviderArray[index]->getName());
388 continue;
389 }
390
391 PEGASUS_ASSERT (provider->_module != 0);
392
393 // unload provider module
394 provider->_module->unloadModule ();
395 Logger::put (Logger::STANDARD_LOG, System::CIMSERVER,
396 Logger::TRACE,
397 "CMPILocalProviderManager::_provider_crtl - Unload provider $0",
398 provider->getName ());
|
399 konrad.r 1.24
|
400 dave.sudlik 1.42 // Note: The deleting of the cimom handle is being
401 // moved after the call to unloadModule() based on
402 // a previous fix for bug 3669 and consistency with
403 // other provider managers. Do not move it back before
404 // the call to unloadModule().
405 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
406 "Destroying CMPIProvider's CIMOM Handle "
407 + provider->getName());
408 delete provider->_cimom_handle;
409
|
410 dave.sudlik 1.39 // set provider status to UNINITIALIZED
411 provider->reset ();
|
412 mark.hamzy 1.28 }
|
413 r.kieninger 1.14 }
|
414 konrad.r 1.24 }
415 catch (...)
416 {
417 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
418 "Unexpected Exception in UNLOAD_IDLE_PROVIDERS.");
419 }
|
420 dave.sudlik 1.42 delete [] unloadProviderArray;
|
421 konrad.r 1.24 } // if there are any providers
422 break;
423 }
|
424 r.kieninger 1.14
425 default:
|
426 konrad.r 1.24 ccode = -1;
427 break;
|
428 r.kieninger 1.14 }
|
429 konrad.r 1.24 PEG_METHOD_EXIT ();
430 return (ccode);
|
431 schuur 1.1 }
432
|
433 konrad.r 1.30
434
435 /*
436 * The reaper function polls out the threads from the global list (_finishedThreadList),
437 * joins them deletes them, and removes them from the CMPIProvider specific list.
438 */
|
439 mike 1.38 ThreadReturnType PEGASUS_THREAD_CDECL CMPILocalProviderManager::_reaper(void *parm)
|
440 konrad.r 1.30 {
441 Thread *myself = reinterpret_cast<Thread *>(parm);
442 do {
443 _pollingSem.wait();
444 // All of the threads are finished working. We just need to reap 'em
445 cleanupThreadRecord *rec = 0;
446
447 while (_finishedThreadList.size() >0 )
448 {
449 // Pull of the the threads from the global list.
|
450 mike 1.35 rec = _finishedThreadList.remove_front();
|
451 konrad.r 1.30 DDD(cerr << "Reaping the thread " << rec->thread << " from " << rec->provider->getName() << endl);
452 rec->thread->join();
|
453 mike 1.35
454 // Remove the thread for the CMPIProvider.
|
455 dave.sudlik 1.34 rec->provider->threadDelete(rec->thread);
|
456 mike 1.35
457 // Delete the thread.
|
458 konrad.r 1.30 delete rec->thread;
459 delete rec;
460 }
461 }
|
462 mike 1.31 while (_stopPolling.get() == 0);
|
463 mike 1.38 myself->exit_self( (ThreadReturnType) 0);
|
464 konrad.r 1.30 return (0);
465 }
466 /*
467 // Cleanup the thread and upon deletion of it, call the CMPIProvider' "threadDeleted".
468 // to not, all the CMPIProvider '
469 // Note that this function is called from the thread that finished with
470 // running the providers function, and returns immediately while scheduling the
471 // a cleanup procedure. If you want to wait until the thread is truly deleted,
472 // call 'waitUntilThreadsDone' - but DO NOT do it in the the thread that
473 // the Thread owns - you will wait forever.
474 //
475 // @argument t Thread that is not NULL and finished with running the provider function.
476 // @argument p CMPIProvider in which the 't' Thread was running.
477 */
478 void
479 CMPILocalProviderManager::cleanupThread(Thread *t, CMPIProvider *p)
480 {
481 PEGASUS_ASSERT( t != 0 && p != 0 );
482
483 PEGASUS_ASSERT ( p->isThreadOwner(t) );
484 // The mutex guards against a race condition for _reaperThread creation.
485 konrad.r 1.30 AutoMutex lock(_reaperMutex);
486
487 // Put the Thread and the CMPIProvider on the global list.
488 cleanupThreadRecord *record = new cleanupThreadRecord(t, p);
|
489 mike 1.35 _finishedThreadList.insert_back(record);
|
490 konrad.r 1.30
491 if (_reaperThread == 0)
492 {
493 _reaperThread = new Thread(_reaper, NULL, false);
494 ThreadStatus rtn = PEGASUS_THREAD_OK;
495 while ( (rtn = _reaperThread->run()) != PEGASUS_THREAD_OK)
496 {
497 if (rtn == PEGASUS_THREAD_INSUFFICIENT_RESOURCES)
|
498 mike 1.38 Threads::yield();
|
499 konrad.r 1.30 else
500 {
501 PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL2, \
502 "Could not allocate thread to take care of deleting user threads. ");
503 delete _reaperThread; _reaperThread = 0;
504 return;
505 }
506 }
507 }/*
508 Tracer::trace(TRC_PROVIDERMANAGER, Tracer::LEVEL2, \
509 "Cleaning up provider thread (%p) from provider %s.",
510 t, (const char *)p->getName().getCString());*/
511 // Wake up the reaper.
512 _pollingSem.signal();
513
514 }
515
|
516 konrad.r 1.24 CMPIProvider::OpProviderHolder CMPILocalProviderManager::
517 getRemoteProvider (const String & location, const String & providerName)
518 {
519 CMPIProvider::OpProviderHolder ph;
520 CTRL_STRINGS
521 strings;
522 Sint32
523 ccode;
524 const String
525 proxy ("CMPIRProxyProvider");
526
527 String
528 rproviderName ("R");
529 PEG_METHOD_ENTER (TRC_PROVIDERMANAGER,
530 "ProvidertManager::getRemoteProvider");
531
532 rproviderName.append (providerName);
533
534 strings.fileName = &proxy;
535 strings.providerName = &rproviderName;
536 strings.location = &location;
537 konrad.r 1.24
538 try
539 {
540 ccode = _provider_ctrl (GET_PROVIDER, &strings, &ph);
541 }
542 catch (const Exception & e)
543 {
|
544 konrad.r 1.27 DDD(cerr << "--- loading proxy: " << e.getMessage () << endl);
|
545 konrad.r 1.24 PEG_METHOD_EXIT ();
546 throw;
547 }
548 catch (...)
549 {
550 PEG_METHOD_EXIT ();
551 throw;
|
552 kumpf 1.43 }
|
553 schuur 1.10
|
554 konrad.r 1.24 PEG_METHOD_EXIT ();
|
555 kumpf 1.43 return ph;
|
556 schuur 1.1 }
557
|
558 konrad.r 1.24 CMPIProvider::OpProviderHolder CMPILocalProviderManager::
559 getProvider (const String & fileName, const String & providerName)
|
560 r.kieninger 1.14 {
|
561 konrad.r 1.24 CMPIProvider::OpProviderHolder ph;
562 CTRL_STRINGS
563 strings;
564 Sint32
565 ccode;
|
566 r.kieninger 1.15
|
567 konrad.r 1.24 String
568 lproviderName ("L");
569 PEG_METHOD_ENTER (TRC_PROVIDERMANAGER, "ProviderManager::getProvider");
|
570 konrad.r 1.26 if (fileName.size() == 0)
571 {
|
572 thilo.boehm 1.36 throw Exception(MessageLoaderParms(
573 "ProviderManager.CMPI.CMPILocalProviderManager.CANNOT_FIND_LIBRARY",
574 "For provider $0 the library name was empty. Check provider registered location.",
575 providerName));
|
576 r.kieninger 1.15
|
577 konrad.r 1.26 }
|
578 konrad.r 1.24 lproviderName.append (providerName);
579 strings.fileName = &fileName;
580 strings.providerName = &lproviderName;
581 strings.location = &String::EMPTY;
|
582 r.kieninger 1.14
|
583 konrad.r 1.24 try
584 {
585 ccode = _provider_ctrl (GET_PROVIDER, &strings, &ph);
586 }
587 catch (const Exception & e)
588 {
|
589 konrad.r 1.27 DDD(cerr << "--- loading proxy: " << e.getMessage () << endl);
|
590 konrad.r 1.24 PEG_METHOD_EXIT ();
591 throw;
592 }
593 catch (...)
594 {
595 PEG_METHOD_EXIT ();
596 throw;
597 }
|
598 schuur 1.1
599
|
600 konrad.r 1.24 PEG_METHOD_EXIT ();
601 return (ph);
|
602 schuur 1.1
603 }
604
|
605 konrad.r 1.24 void
606 CMPILocalProviderManager::unloadProvider (const String & fileName,
607 const String & providerName)
|
608 r.kieninger 1.14 {
|
609 konrad.r 1.24 CTRL_STRINGS strings;
610 PEG_METHOD_ENTER (TRC_PROVIDERMANAGER, "ProviderManager::unloadProvider");
|
611 konrad.r 1.25
612 String lproviderName ("L");
613 String rproviderName ("R");
614 lproviderName.append (providerName);
615 rproviderName.append (providerName);
616
|
617 konrad.r 1.24 strings.fileName = &fileName;
|
618 konrad.r 1.25 strings.providerName = &lproviderName;
619 strings.location = &String::EMPTY;
|
620 konrad.r 1.24 _provider_ctrl (UNLOAD_PROVIDER, &strings, (void *) 0);
|
621 konrad.r 1.25
622 strings.providerName = &rproviderName;
623
624 _provider_ctrl (UNLOAD_PROVIDER, &strings, (void *) 0);
625
|
626 konrad.r 1.24 PEG_METHOD_EXIT ();
|
627 r.kieninger 1.14 }
628
|
629 konrad.r 1.24 void
630 CMPILocalProviderManager::shutdownAllProviders (void)
|
631 r.kieninger 1.14 {
632
|
633 konrad.r 1.24 PEG_METHOD_ENTER (TRC_PROVIDERMANAGER,
634 "ProviderManager::shutdownAllProviders");
635 _provider_ctrl (UNLOAD_ALL_PROVIDERS, (void *) this, (void *) 0);
636 PEG_METHOD_EXIT ();
|
637 r.kieninger 1.13 }
638
639
|
640 konrad.r 1.24 Boolean
641 CMPILocalProviderManager::hasActiveProviders ()
|
642 r.kieninger 1.14 {
|
643 konrad.r 1.24 PEG_METHOD_ENTER (TRC_PROVIDERMANAGER,
644 "ProviderManager::hasActiveProviders");
|
645 r.kieninger 1.14
|
646 konrad.r 1.24 try
647 {
648 AutoMutex lock (_providerTableMutex);
649 Tracer::trace (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
650 "providers in _providers table = %d", _providers.size ());
|
651 r.kieninger 1.14
|
652 konrad.r 1.24 // Iterate through the _providers table looking for an active provider
653 for (ProviderTable::Iterator i = _providers.start (); i != 0; i++)
654 {
655 if (i.value ()->getStatus () == CMPIProvider::INITIALIZED)
656 {
657 PEG_METHOD_EXIT ();
658 return true;
659 }
660 }
661 }
662 catch (...)
663 {
664 // Unexpected exception; do not assume that no providers are loaded
665 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL2,
666 "Unexpected Exception in hasActiveProviders.");
667 PEG_METHOD_EXIT ();
668 return true;
669 }
|
670 r.kieninger 1.14
|
671 konrad.r 1.24 // No active providers were found in the _providers table
672 PEG_METHOD_EXIT ();
673 return false;
|
674 r.kieninger 1.14 }
675
|
676 konrad.r 1.24 void
677 CMPILocalProviderManager::unloadIdleProviders (void)
|
678 r.kieninger 1.14 {
|
679 kumpf 1.41 PEG_METHOD_ENTER(TRC_PROVIDERMANAGER,
680 "ProviderManager::unloadIdleProviders");
|
681 r.kieninger 1.14
|
682 kumpf 1.41 try
|
683 r.kieninger 1.14 {
|
684 kumpf 1.41 _provider_ctrl (UNLOAD_IDLE_PROVIDERS, this, (void *) 0);
|
685 r.kieninger 1.14 }
|
686 kumpf 1.41 catch (...)
|
687 r.kieninger 1.14 {
|
688 kumpf 1.41 PEG_TRACE_STRING(TRC_PROVIDERMANAGER, Tracer::LEVEL2,
689 "Caught unexpected exception from UNLOAD_IDLE_PROVIDERS.");
|
690 r.kieninger 1.14 }
|
691 kumpf 1.41
692 PEG_METHOD_EXIT ();
|
693 schuur 1.1 }
694
|
695 konrad.r 1.24 Array <
696 CMPIProvider * >CMPILocalProviderManager::getIndicationProvidersToEnable ()
|
697 carolann.graves 1.17 {
|
698 konrad.r 1.24 PEG_METHOD_ENTER (TRC_PROVIDERMANAGER,
699 "CMPILocalProviderManager::getIndicationProvidersToEnable");
|
700 carolann.graves 1.17
|
701 konrad.r 1.24 Array < CMPIProvider * >enableProviders;
|
702 carolann.graves 1.17
|
703 konrad.r 1.24 Tracer::trace (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
704 "Number of providers in _providers table = %d",
705 _providers.size ());
|
706 carolann.graves 1.17
|
707 konrad.r 1.24 try
708 {
709 AutoMutex
710 lock (_providerTableMutex);
|
711 carolann.graves 1.17
|
712 konrad.r 1.24 //
713 // Iterate through the _providers table
714 //
715 for (ProviderTable::Iterator i = _providers.start (); i != 0; i++)
716 {
|
717 carolann.graves 1.17 //
|
718 konrad.r 1.24 // Enable any indication provider with current subscriptions
|
719 carolann.graves 1.17 //
|
720 konrad.r 1.24 CMPIProvider *
721 provider = i.value ();
722 if (provider->testSubscriptions ())
723 {
724 enableProviders.append (provider);
725 }
726 }
727
728 }
729 catch (const CIMException & e)
730 {
731 PEG_TRACE_STRING (TRC_DISCARDED_DATA, Tracer::LEVEL2,
732 "CIMException: " + e.getMessage ());
733 }
734 catch (const Exception & e)
735 {
736 PEG_TRACE_STRING (TRC_DISCARDED_DATA, Tracer::LEVEL2,
737 "Exception: " + e.getMessage ());
738 }
739 catch (...)
740 {
741 konrad.r 1.24 PEG_TRACE_STRING (TRC_DISCARDED_DATA, Tracer::LEVEL2,
742 "Unexpected error in getIndicationProvidersToEnable");
743 }
744
745 Tracer::trace (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
746 "Number of indication providers to enable = %d",
747 enableProviders.size ());
748
749 PEG_METHOD_EXIT ();
750 return enableProviders;
751 }
752
753 CMPIProvider *
754 CMPILocalProviderManager::_initProvider (CMPIProvider * provider,
755 const String & moduleFileName)
756 {
757 PEG_METHOD_ENTER (TRC_PROVIDERMANAGER, "_initProvider");
|
758 carolann.graves 1.17
|
759 konrad.r 1.24 CMPIProviderModule *module = 0;
760 ProviderVector base;
|
761 carolann.graves 1.17
|
762 konrad.r 1.24 {
763 // lock the providerTable mutex
764 AutoMutex lock (_providerTableMutex);
|
765 carolann.graves 1.17
|
766 konrad.r 1.24 // lookup provider module
767 module = _lookupModule (moduleFileName);
768 } // unlock the providerTable mutex
|
769 schuur 1.1
|
770 kumpf 1.37 Boolean moduleLoaded = false;
|
771 konrad.r 1.24 Boolean deleteProvider = false;
|
772 konrad.r 1.26 String exceptionMsg = moduleFileName;
|
773 konrad.r 1.24 {
774 // lock the provider status mutex
775 AutoMutex lock (provider->_statusMutex);
|
776 r.kieninger 1.14
|
777 konrad.r 1.24 if (provider->_status == CMPIProvider::INITIALIZED)
778 {
779 // Initialization is already complete
780 return provider;
781 }
|
782 r.kieninger 1.14
|
783 konrad.r 1.24 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
784 "Loading/Linking Provider Module " + moduleFileName);
|
785 kumpf 1.18
|
786 konrad.r 1.24 // load the provider
787 try
788 {
789 base = module->load (provider->_name);
|
790 kumpf 1.37 moduleLoaded = true;
|
791 konrad.r 1.24 }
|
792 konrad.r 1.26 catch (const Exception &e)
793 {
794 exceptionMsg = e.getMessage();
795 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
796 "Exception caught Loading/Linking Provider Module " +
797 moduleFileName+ " error is: "+exceptionMsg);
798 deleteProvider =true;
799 }
|
800 konrad.r 1.24 catch (...)
|
801 kumpf 1.18 {
|
802 konrad.r 1.24 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
|
803 konrad.r 1.26 "Unknown exception caught Loading/Linking Provider Module " +
|
804 konrad.r 1.24 moduleFileName);
|
805 konrad.r 1.26 exceptionMsg = moduleFileName;
|
806 kumpf 1.37 deleteProvider = true;
|
807 konrad.r 1.24 }
|
808 kumpf 1.37
|
809 konrad.r 1.26 if (!deleteProvider)
810 {
811 // initialize the provider
812 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL2,
813 "Initializing Provider " + provider->getName());
|
814 r.kieninger 1.14
|
815 konrad.r 1.26 CIMOMHandle *cimomHandle = new CIMOMHandle ();
816 provider->set (module, base, cimomHandle);
817 provider->_quantum = 0;
|
818 konrad.r 1.24
|
819 konrad.r 1.26 try
820 {
821 provider->initialize (*(provider->_cimom_handle));
822 }
823 catch (const Exception &e)
824 {
825 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL2,
826 "Problem initializing: " + e.getMessage());
827 deleteProvider = true;
828 exceptionMsg = e.getMessage();
829 }
830 catch (...)
831 {
832 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL2,
833 "Unknown problem initializing " + provider->getName());
834 deleteProvider = true;
835 exceptionMsg = provider->getName();
836 }
837 } // unlock the provider status mutex
838 }
839 /* We wait until this moment to delete the provider b/c we need
840 konrad.r 1.26 be outside the scope for the AutoMutex for the provider. */
841 if (deleteProvider)
842 {
|
843 konrad.r 1.24 // delete the cimom handle
844 delete provider->_cimom_handle;
845 // set provider status to UNINITIALIZED
846 provider->reset ();
|
847 kumpf 1.37
|
848 konrad.r 1.24 // unload provider module
|
849 kumpf 1.37 if (moduleLoaded)
850 {
851 module->unloadModule();
852 }
|
853 r.kieninger 1.14
|
854 konrad.r 1.24 AutoMutex lock (_providerTableMutex);
|
855 konrad.r 1.26 _providers.remove (provider->_name);
|
856 konrad.r 1.24 delete provider;
|
857 konrad.r 1.26
858 PEG_METHOD_EXIT ();
859 throw Exception(exceptionMsg);
|
860 r.kieninger 1.14 }
861
|
862 konrad.r 1.24 PEG_METHOD_EXIT ();
863 return (provider);
|
864 r.kieninger 1.14 }
865
866
|
867 konrad.r 1.24 void
868 CMPILocalProviderManager::_unloadProvider (CMPIProvider * provider)
|
869 r.kieninger 1.14 {
|
870 konrad.r 1.24 //
871 // NOTE: It is the caller's responsibility to make sure that
872 // the ProviderTable mutex is locked before calling this method.
873 //
874 PEG_METHOD_ENTER (TRC_PROVIDERMANAGER, "_unloadProvider");
|
875 r.kieninger 1.14
|
876 konrad.r 1.24 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
|
877 konrad.r 1.26 "Unloading Provider " + provider->getName());
|
878 r.kieninger 1.14
|
879 mike 1.31 if (provider->_current_operations.get ())
|
880 r.kieninger 1.14 {
|
881 konrad.r 1.24 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
882 "Provider cannot be unloaded due to pending operations: "
|
883 konrad.r 1.26 + provider->getName());
|
884 r.kieninger 1.14 }
|
885 konrad.r 1.24 else
|
886 r.kieninger 1.14 {
|
887 konrad.r 1.24 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
|
888 konrad.r 1.26 "Terminating Provider " + provider->getName());
|
889 konrad.r 1.24
|
890 r.kieninger 1.14
|
891 konrad.r 1.24 // lock the provider mutex
892 AutoMutex pr_lock (provider->_statusMutex);
|
893 r.kieninger 1.14
|
894 konrad.r 1.24 try
895 {
896 provider->terminate ();
897 }
898 catch (...)
899 {
900 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL3,
901 "Error occured terminating CMPI provider " +
|
902 konrad.r 1.26 provider->getName());
|
903 konrad.r 1.24 }
|
904 r.kieninger 1.14
|
905 konrad.r 1.24 // delete the cimom handle
906 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
907 "Destroying CMPIProvider's CIMOM Handle " +
|
908 konrad.r 1.26 provider->getName());
|
909 r.kieninger 1.14
|
910 konrad.r 1.24 delete provider->_cimom_handle;
911 PEGASUS_ASSERT (provider->_module != 0);
|
912 r.kieninger 1.14
|
913 konrad.r 1.24 // unload provider module
914 provider->_module->unloadModule ();
915 Logger::put (Logger::STANDARD_LOG, System::CIMSERVER, Logger::TRACE,
916 "CMPILocalProviderManager::_provider_crtl - Unload provider $0",
917 provider->getName ());
|
918 r.kieninger 1.14
|
919 konrad.r 1.24 // set provider status to UNINITIALIZED
920 provider->reset ();
|
921 r.kieninger 1.14
|
922 konrad.r 1.24 // Do not delete the provider. The function calling this function
923 // takes care of that.
|
924 r.kieninger 1.14 }
|
925 r.kieninger 1.13
|
926 konrad.r 1.24 PEG_METHOD_EXIT ();
|
927 dj.gorey 1.6 }
928
|
929 konrad.r 1.24 CMPIProvider *
930 CMPILocalProviderManager::_lookupProvider (const String & providerName)
|
931 r.kieninger 1.14 {
|
932 konrad.r 1.24 PEG_METHOD_ENTER (TRC_PROVIDERMANAGER, "_lookupProvider");
933 // lock the providerTable mutex
934 AutoMutex lock (_providerTableMutex);
935 // look up provider in cache
936 CMPIProvider *pr = 0;
937 if (true == _providers.lookup (providerName, pr))
|
938 r.kieninger 1.14 {
|
939 konrad.r 1.24 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
940 "Found Provider " + providerName +
941 " in CMPI Provider Manager Cache");
|
942 r.kieninger 1.14 }
|
943 konrad.r 1.24 else
|
944 r.kieninger 1.14 {
|
945 konrad.r 1.24 // create provider
946 pr = new CMPIProvider (providerName, 0, 0);
947 // insert provider in provider table
948 _providers.insert (providerName, pr);
|
949 r.kieninger 1.14
|
950 konrad.r 1.24 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
951 "Created provider " + pr->getName ());
|
952 r.kieninger 1.14 }
|
953 dj.gorey 1.6
|
954 konrad.r 1.24 PEG_METHOD_EXIT ();
955 return (pr);
|
956 dj.gorey 1.6 }
957
958
|
959 konrad.r 1.24 CMPIProviderModule *
960 CMPILocalProviderManager::_lookupModule (const String & moduleFileName)
|
961 r.kieninger 1.14 {
|
962 konrad.r 1.24 PEG_METHOD_ENTER (TRC_PROVIDERMANAGER, "_lookupModule");
|
963 r.kieninger 1.14
|
964 konrad.r 1.24 // look up provider module in cache
965 CMPIProviderModule *module = 0;
|
966 r.kieninger 1.14
|
967 konrad.r 1.24 if (true == _modules.lookup (moduleFileName, module))
|
968 r.kieninger 1.14 {
|
969 konrad.r 1.24 // found provider module in cache
970 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
971 "Found Provider Module" + moduleFileName +
972 " in Provider Manager Cache");
|
973 dj.gorey 1.6
|
974 konrad.r 1.24 }
975 else
976 {
977 // provider module not found in cache, create provider module
978 PEG_TRACE_STRING (TRC_PROVIDERMANAGER, Tracer::LEVEL4,
979 "Creating CMPI Provider Module " + moduleFileName);
|
980 r.kieninger 1.14
|
981 konrad.r 1.24 module = new CMPIProviderModule (moduleFileName);
|
982 r.kieninger 1.14
|
983 konrad.r 1.24 // insert provider module in module table
984 _modules.insert (moduleFileName, module);
|
985 r.kieninger 1.14 }
|
986 dj.gorey 1.6
|
987 konrad.r 1.24 PEG_METHOD_EXIT ();
988 return (module);
|
989 schuur 1.1 }
990
991 PEGASUS_NAMESPACE_END
|
Return to
CMPILocalProviderManager.cpp
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / ProviderManager2 / CMPI