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.47 and 1.58

version 1.47, 2005/05/18 15:56:51

version 1.58, 2006/10/03 18:16:03

Line 1

//%2005////////////////////////////////////////////////////////////////////////

//%2006////////////////////////////////////////////////////////////////////////

// Company, L.P.; IBM Corp.; The Open Group; Tivoli Systems.

Line 8

// IBM Corp.; EMC Corporation; VERITAS Software Corporation; The Open Group.

// EMC Corporation; VERITAS Software Corporation; The Open Group.

// EMC Corporation; Symantec Corporation; The Open Group.

// Permission is hereby granted, free of charge, to any person obtaining a copy

// of this software and associated documentation files (the "Software"), to

Line 27

Line 29

//==============================================================================

// Author: Mike Day (mdday@us.ibm.com)

// Modified By: David Dillard, VERITAS Software Corp.

// (david.dillard@veritas.com)

//%/////////////////////////////////////////////////////////////////////////////

#ifndef Pegasus_MessageQueue_Service_h

Line 40

Line 37

#include <Pegasus/Common/Config.h>

#include <Pegasus/Common/Message.h>

#include <Pegasus/Common/InternalException.h>

#include <Pegasus/Common/IPC.h>

#include <Pegasus/Common/Thread.h>

#include <Pegasus/Common/ThreadPool.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/Mutex.h>

PEGASUS_NAMESPACE_BEGIN

extern const Uint32 CIMOM_Q_ID;

class message_module;

class cimom;

class PEGASUS_COMMON_LINKAGE MessageQueueService : public MessageQueue

class PEGASUS_COMMON_LINKAGE MessageQueueService :

public Linkable, public MessageQueue

{

public:

typedef MessageQueue Base;

MessageQueueService(const char *name,

MessageQueueService(

const char *name,

Uint32 queueID = MessageQueue::getNextQueueId(),

Uint32 capabilities = 0,

Uint32 mask = message_mask::type_cimom |

Uint32 mask = MessageMask::type_cimom |

message_mask::type_service |

MessageMask::type_service |

message_mask::ha_request |

MessageMask::ha_request |

message_mask::ha_reply |

MessageMask::ha_reply |

message_mask::ha_async );

MessageMask::ha_async);

virtual ~MessageQueueService();

Line 89

Line 92

void *parameter);

Boolean SendForget(Message *msg);

Boolean ForwardOp(AsyncOpNode *, Uint32 destination);

Boolean register_service(String name, Uint32 capabilities, Uint32 mask);

Line 102

Line 104

Uint32 mask,

Array<Uint32> *results);

void enumerate_service(Uint32 queue, message_module *result);

Uint32 get_next_xid();

static AsyncOpNode *get_op();

void return_op(AsyncOpNode *op);

Boolean operator ==(const MessageQueueService & svce) const

{

return operator==((const void *)&svce);

}

Boolean operator ==(const void *svce) const

{

if((const void *)this == svce)

return true;

return false;

}

static PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL polling_routine(void *);

static PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL kill_idle_threads(void *);

static ThreadPool *get_thread_pool();

Uint32 _mask;

AtomicInt _die;

AtomicInt _threads;

Uint32 getIncomingCount() {return _incoming.count(); }

protected:

virtual Boolean accept_async(AsyncOpNode *op);

Line 161

Line 150

static cimom *_meta_dispatcher;

static AtomicInt _service_count;

static Mutex _meta_dispatcher_mutex;

static ThreadPool *_thread_pool;

private:

AsyncDQueue<AsyncOpNode> _incoming;

static ThreadReturnType PEGASUS_THREAD_CDECL polling_routine(void *);

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, Mutex> PollingList;

static PollingList* _polling_list;

static Mutex _polling_list_mutex;

PollingList* _get_polling_list();

static PEGASUS_THREAD_RETURN PEGASUS_THREAD_CDECL _req_proc(void *);

static ThreadReturnType PEGASUS_THREAD_CDECL _req_proc(void *);

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

AtomicInt _incoming_queue_shutdown;

protected:

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.47
changed lines
	Added in v.1.58

No CVS admin address has been configured