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

Return to MessageQueueService.h CVS log

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

Diff for /pegasus/src/Pegasus/Common/MessageQueueService.h between version 1.28 and 1.36

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

version 1.36, 2003/04/07 20:29:23

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 int kill_idle_threads(void);

static PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL 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();

}

static ThreadPool *get_thread_pool(void);

static void force_shutdown(void);

Uint32 _mask;

AtomicInt _die;

Line 162

Line 165

AsyncDQueue<AsyncOpNode> _incoming;

DQueue<AsyncOpNode> _callback;

static Thread _polling_thread;

static Thread* _polling_thread;

static Semaphore _polling_sem;

static AtomicInt _stop_polling;

static AtomicInt _check_idle_flag;

static DQueue<MessageQueueService> _polling_list;

Line 172

Line 176

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;

friend class cimom;

friend class CIMServer;

};

PEGASUS_NAMESPACE_END

Legend:

Removed from v.1.28
changed lines
	Added in v.1.36

No CVS admin address has been configured