pegasus/src/Pegasus/Common/MessageQueueService.h - diff

Return to MessageQueueService.h CVS log

Up to [Pegasus] / pegasus / src / Pegasus / Common

version 1.34.4.1, 2002/10/28 22:41:43

version 1.35, 2003/04/03 20:54:39

Line 32

#include <Pegasus/Common/Config.h>

#include <Pegasus/Common/Message.h>

#include <Pegasus/Common/Exception.h>

#include <Pegasus/Common/InternalException.h>

#include <Pegasus/Common/IPC.h>

#include <Pegasus/Common/Thread.h>

#include <Pegasus/Common/AsyncOpNode.h>

#include <Pegasus/Common/Cimom.h>

#include <Pegasus/Common/CimomMessage.h>

#include <Pegasus/Common/Linkage.h>

PEGASUS_NAMESPACE_BEGIN

Line 111

Line 112

}

static PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL polling_routine(void *);

static PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL kill_idle_threads(void *);

static int kill_idle_threads(void);

static int pooled_threads(void)

{

return _thread_pool->running_count() + _thread_pool->dead_count() + _thread_pool->pool_count();

}

static ThreadPool *get_thread_pool(void);

static void force_shutdown(void);

Uint32 _mask;

Line 167

Line 168

static Thread* _polling_thread;

static Semaphore _polling_sem;

static AtomicInt _stop_polling;

static AtomicInt _check_idle_flag;

static DQueue<MessageQueueService> _polling_list;

Line 187

struct timeval _default_op_timeout;

static AtomicInt _xid;

friend class cimom;

friend class CIMServer;

};

PEGASUS_NAMESPACE_END

Legend: