version 1.41.2.1, 2006/07/27 23:12:05
|
version 1.46, 2006/12/01 22:40:26
|
|
|
// | // |
//============================================================================== | //============================================================================== |
// | // |
// Author: Dong Xiang, EMC Corporation (xiang_dong@emc.com) |
|
// |
|
// Modified By: Dan Gorey (djgorey@us.ibm.com) |
|
// Amit K Arora, IBM (amita@in.ibm.com) for PEP#183 |
|
// Roger Kumpf, Hewlett-Packard Company (roger_kumpf@hp.com) |
|
// David Dillard, VERITAS Software Corp. |
|
// (david.dillard@veritas.com) |
|
// Vijay Eli, IBM (vijay.eli@in.ibm.com) for bug#3425 |
|
// Aruran, IBM (ashanmug@in.ibm.com) for Bug# 3604 |
|
// |
|
//%///////////////////////////////////////////////////////////////////////////// | //%///////////////////////////////////////////////////////////////////////////// |
| |
#include "CIMListener.h" | #include "CIMListener.h" |
|
|
#include <Pegasus/Common/HTTPAcceptor.h> | #include <Pegasus/Common/HTTPAcceptor.h> |
#include <Pegasus/Common/PegasusVersion.h> | #include <Pegasus/Common/PegasusVersion.h> |
#include <Pegasus/Common/MessageLoader.h> | #include <Pegasus/Common/MessageLoader.h> |
|
#include <Pegasus/Common/Time.h> |
#include <Pegasus/ExportServer/CIMExportResponseEncoder.h> | #include <Pegasus/ExportServer/CIMExportResponseEncoder.h> |
#include <Pegasus/ExportServer/CIMExportRequestDecoder.h> | #include <Pegasus/ExportServer/CIMExportRequestDecoder.h> |
#include <Pegasus/Consumer/CIMIndicationConsumer.h> | #include <Pegasus/Consumer/CIMIndicationConsumer.h> |
|
|
| |
void CIMListenerService::runForever() | void CIMListenerService::runForever() |
{ | { |
static int modulator = 0; |
|
|
|
if (!_dieNow) | if (!_dieNow) |
{ | { |
if (false == _monitor->run(500000)) |
_monitor->run(500000); |
|
static struct timeval lastIdleCleanupTime = {0, 0}; |
|
struct timeval now; |
|
Time::gettimeofday(&now); |
|
if (now.tv_sec - lastIdleCleanupTime.tv_sec > 300) |
{ | { |
modulator++; |
lastIdleCleanupTime.tv_sec = now.tv_sec; |
try | try |
{ | { |
MessageQueueService::get_thread_pool()->cleanupIdleThreads(); | MessageQueueService::get_thread_pool()->cleanupIdleThreads(); |
|
|
// svc->init(); bug 1394 | // svc->init(); bug 1394 |
while (!svc->terminated()) | while (!svc->terminated()) |
{ | { |
#if defined(PEGASUS_PLATFORM_DARWIN_PPC_GNU) |
#if defined(PEGASUS_OS_DARWIN) |
pthread_testcancel(); | pthread_testcancel(); |
#endif | #endif |
svc->runForever(); | svc->runForever(); |
|
|
// _dieNow to true and called Monitor::tickle(). We must wait until we | // _dieNow to true and called Monitor::tickle(). We must wait until we |
// can obtain the _monitorMutex, indicating that we are no longer inside | // can obtain the _monitorMutex, indicating that we are no longer inside |
// Monitor::tickle(). | // Monitor::tickle(). |
svc->_monitorMutex.lock(Threads::self()); |
svc->_monitorMutex.lock(); |
svc->_monitorMutex.unlock(); | svc->_monitorMutex.unlock(); |
delete svc; | delete svc; |
| |
|
|
!= PEGASUS_THREAD_OK) | != PEGASUS_THREAD_OK) |
{ | { |
Logger::put( | Logger::put( |
Logger::STANDARD_LOG, System::CIMSERVER, |
Logger::STANDARD_LOG, System::CIMLISTENER, |
Logger::TRACE, | Logger::TRACE, |
"Not enough threads to start CIMListernerService."); | "Not enough threads to start CIMListernerService."); |
| |