|
version 1.42, 2006/08/09 21:12:59
|
version 1.46.4.1, 2007/04/04 11:04:49
|
|
|
|
| // | // |
| //============================================================================== | //============================================================================== |
| // | // |
| // 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(); |
|
|
|
| } | } |
| catch(...) | catch(...) |
| { | { |
| Tracer::trace(TRC_SERVER, Tracer::LEVEL2, |
PEG_TRACE_CSTRING(TRC_SERVER, Tracer::LEVEL2, |
| "Unknown exception thrown in _listener_routine."); | "Unknown exception thrown in _listener_routine."); |
| } | } |
| | |
|
|
|
| != 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."); |
| | |
| Tracer::trace( |
PEG_TRACE_CSTRING( |
| TRC_SERVER, | TRC_SERVER, |
| Tracer::LEVEL2, | Tracer::LEVEL2, |
| "Could not allocate thread for " | "Could not allocate thread for " |
Return to
CIMListener.cpp
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / Listener