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.50 and 1.51

version 1.50, 2006/01/30 16:17:05

version 1.51, 2006/07/11 18:39:28

Line 47

#include <Pegasus/Common/Thread.h>

#include <Pegasus/Common/AsyncOpNode.h>

#include <Pegasus/Common/Cimom.h>

#include <Pegasus/Common/Mutex.h>

#include <Pegasus/Common/CimomMessage.h>

#include <Pegasus/Common/Linkage.h>

#include <Pegasus/Common/RecursiveMutex.h>

#include <Pegasus/Common/IDFactory.h>

PEGASUS_NAMESPACE_BEGIN

Line 56

Line 59

class message_module;

class PEGASUS_COMMON_LINKAGE MessageQueueService : public MessageQueue

class PEGASUS_COMMON_LINKAGE MessageQueueService :

public Linkable, public MessageQueue

{

public:

Line 168

Line 173

static Mutex _meta_dispatcher_mutex;

private:

AsyncDQueue<AsyncOpNode> _incoming;

AsyncQueue<AsyncOpNode> _incoming;

static Thread* _polling_thread;

static Semaphore _polling_sem;

static AtomicInt _stop_polling;

static AtomicInt _check_idle_flag;

static DQueue<MessageQueueService> _polling_list;

typedef List<MessageQueueService, RecursiveMutex> PollingList;

static PollingList* _polling_list;

static Mutex _polling_list_mutex;

PollingList* _get_polling_list();

static PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL _req_proc(void *);

Line 187

Line 196

private:

struct timeval _default_op_timeout;

static AtomicInt _xid;

static IDFactory _xidFactory;

friend class cimom;

friend class CIMServer;

};

Legend:

Removed from v.1.50
changed lines
	Added in v.1.51

No CVS admin address has been configured