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

Return to MessageQueueService.h CVS log

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

version 1.28, 2002/06/07 00:56:01

version 1.33, 2002/07/26 20:01:19

Line 38

#include <Pegasus/Common/AsyncOpNode.h>

#include <Pegasus/Common/Cimom.h>

#include <Pegasus/Common/CimomMessage.h>

#include <Pegasus/Common/Linkage.h>

PEGASUS_NAMESPACE_BEGIN

Line 114

Line 115

static int kill_idle_threads(void);

static int pooled_threads(void)

{

return _thread_pool.running_count() + _thread_pool.dead_count() + _thread_pool.pool_count();

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

}

Uint32 _mask;

Line 162

Line 163

AsyncDQueue<AsyncOpNode> _incoming;

DQueue<AsyncOpNode> _callback;

static Thread _polling_thread;

static Thread* _polling_thread;

static Semaphore _polling_sem;

static AtomicInt _stop_polling;

Line 172

Line 173

static PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL _callback_proc(void *);

static void _sendwait_callback(AsyncOpNode *, MessageQueue *, void *);

AtomicInt _incoming_queue_shutdown;

Semaphore _callback_ready;

Thread _req_thread;

Thread _callback_thread;

protected:

static ThreadPool _thread_pool;

static ThreadPool *_thread_pool;

private:

struct timeval _default_op_timeout;

static AtomicInt _xid;

Legend: