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

Return to Message.h CVS log

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

Diff for /pegasus/src/Pegasus/Common/Message.h between version 1.60.2.1 and 1.75.2.2

version 1.60.2.1, 2005/01/26 16:18:38

version 1.75.2.2, 2006/06/30 18:31:17

Line 1

//%2004////////////////////////////////////////////////////////////////////////

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

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

Line 6

// IBM Corp.; EMC Corporation, The Open Group.

// 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 36

Line 40

// Willis White (whiwill@us.ibm.com) PEP 127 and 128

// Brian G. Campbell, EMC (campbell_brian@emc.com) - PEP140/phase1

// Amit K Arora, IBM (amita@in.ibm.com) for Bug#1090

// John Alex, IBM (johnalex@us.ibm.com) - Bug#2290

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

Line 50

Line 55

#include <Pegasus/Common/IPC.h>

#include <Pegasus/Common/StatisticalData.h>

#include <Pegasus/Common/Linkage.h>

#include <Pegasus/Common/CIMDateTime.h>

#include <Pegasus/Common/TimeValue.h>

#include <Pegasus/Common/CIMOperationType.h>

#include <Pegasus/Common/Linkable.h>

#include <Pegasus/Common/IDFactory.h>

PEGASUS_NAMESPACE_BEGIN

Line 119

Line 127

The Message class also provides previous and next pointers which are

used to place the messages on a queue by the MessageQueue class.

class PEGASUS_COMMON_LINKAGE Message

class PEGASUS_COMMON_LINKAGE Message : public Linkable

{

public:

Line 135

Line 143

_routing_code(routing_code),

_mask(mask),

_httpMethod (HTTP_METHOD__POST),

_close_connect(false),

_last_thread_id(pegasus_thread_self()),

_next(0),

_prev(0),

Line 167

Line 176

virtual ~Message();

Boolean getCloseConnect() const { return _close_connect; }

void setCloseConnect(Boolean close_connect)

{

_close_connect = close_connect;

}

Uint32 getType() const { return _type; }

Line 187

Line 201

void setHttpMethod(HttpMethod httpMethod) {_httpMethod = httpMethod;}

#ifndef PEGASUS_DISABLE_PERFINST

// Needed for performance measurement

Line 200

Line 215

void endProvider();

CIMDateTime getStartServerTime() const { return _timeServerStart; }

TimeValue getStartServerTime() const { return _timeServerStart; }

void setStartServerTime(CIMDateTime timeServerStart)

void setStartServerTime(TimeValue timeServerStart)

{

_timeServerStart = timeServerStart;

}

CIMDateTime getStartProviderTime() const { return _timeProviderStart; }

TimeValue getStartProviderTime() const { return _timeProviderStart; }

void setStartProviderTime(CIMDateTime timeProviderStart)

void setStartProviderTime(TimeValue timeProviderStart)

{

_timeProviderStart = timeProviderStart;

}

CIMDateTime getEndServerTime() const { return _timeServerEnd; }

TimeValue getEndServerTime() const { return _timeServerEnd; }

void setEndServerTime (CIMDateTime timeServerEnd)

void setEndServerTime (TimeValue timeServerEnd)

{

_timeServerEnd = timeServerEnd;

}

CIMDateTime getEndProviderTime() const { return _timeProviderEnd; }

TimeValue getEndProviderTime() const { return _timeProviderEnd; }

void setEndProviderTime(CIMDateTime timeProviderEnd)

void setEndProviderTime(TimeValue timeProviderEnd)

{

_timeProviderEnd = timeProviderEnd;

}

CIMDateTime getProviderTime() { return _providerTime;}

TimeValue getServerTime() { return _serverTime; }

CIMDateTime getTotalTime() { return _totalTime; }

CIMDateTime getServerTime() { return _serverTime; }

#endif

Line 244

Line 255

const Message* getPrevious() const { return _prev; }

static Uint32 getNextKey()

static Uint32 getNextKey();

{

AutoMutex autoMut(_mut);

static CIMOperationType convertMessageTypetoCIMOpType(Uint32 type);

Uint32 ret = _nextKey++;

return ret;

}

#ifdef PEGASUS_DEBUG

virtual void print(

PEGASUS_STD(ostream)& os,

Boolean printHeader = true) const;

#endif

// << Thu Dec 27 10:46:04 2001 mdd >> for use with DQueue container

// as used by AsyncOpNode

Boolean operator == (const void *msg )

{

if (reinterpret_cast<void *>(this) == msg )

Line 326

Line 334

Uint32 _mask;

HttpMethod _httpMethod;

// Needed for performance measurement

CIMDateTime _timeServerStart;

TimeValue _timeServerStart;

CIMDateTime _timeServerEnd;

TimeValue _timeServerEnd;

CIMDateTime _timeProviderStart;

TimeValue _timeProviderStart;

CIMDateTime _timeProviderEnd;

TimeValue _timeProviderEnd;

CIMDateTime _providerTime;

TimeValue _serverTime;

CIMDateTime _serverTime;

Boolean _close_connect;

CIMDateTime _totalTime;

// << Tue Jul 1 11:02:35 2003 mdd >> pep_88 and helper for i18n and l10n

Line 353

Line 361

MessageQueue* _owner;

Boolean _isComplete;

Uint32 _index;

static Uint32 _nextKey;

static IDFactory _keyFactory;

static Mutex _mut;

friend class cimom;

friend class MessageQueue;

Line 398

Line 403

CIM_DELETE_QUALIFIER_REQUEST_MESSAGE,

CIM_ENUMERATE_QUALIFIERS_REQUEST_MESSAGE,

CIM_INVOKE_METHOD_REQUEST_MESSAGE,

CIM_ENABLE_INDICATION_SUBSCRIPTION_REQUEST_MESSAGE,

CIM_MODIFY_INDICATION_SUBSCRIPTION_REQUEST_MESSAGE,

CIM_DISABLE_INDICATION_SUBSCRIPTION_REQUEST_MESSAGE,

CIM_PROCESS_INDICATION_REQUEST_MESSAGE,

CIM_HANDLE_INDICATION_REQUEST_MESSAGE, // 30

CIM_HANDLE_INDICATION_REQUEST_MESSAGE,

CIM_NOTIFY_PROVIDER_REGISTRATION_REQUEST_MESSAGE,

CIM_NOTIFY_PROVIDER_TERMINATION_REQUEST_MESSAGE,

CIM_CREATE_SUBSCRIPTION_REQUEST_MESSAGE, // 30

// new

CIM_ENABLE_INDICATIONS_REQUEST_MESSAGE,

CIM_DISABLE_INDICATIONS_REQUEST_MESSAGE,

CIM_CREATE_SUBSCRIPTION_REQUEST_MESSAGE,

CIM_MODIFY_SUBSCRIPTION_REQUEST_MESSAGE,

CIM_DELETE_SUBSCRIPTION_REQUEST_MESSAGE,

// new

CIM_DISABLE_MODULE_REQUEST_MESSAGE,

CIM_ENABLE_MODULE_REQUEST_MESSAGE,

CIM_STOP_ALL_PROVIDERS_REQUEST_MESSAGE,

CIM_STOP_ALL_PROVIDERS_REQUEST_MESSAGE, // 40

CIM_GET_CLASS_RESPONSE_MESSAGE,

CIM_GET_INSTANCE_RESPONSE_MESSAGE,

CIM_EXPORT_INDICATION_RESPONSE_MESSAGE,

CIM_DELETE_CLASS_RESPONSE_MESSAGE,

CIM_DELETE_INSTANCE_RESPONSE_MESSAGE,

CIM_DELETE_INSTANCE_RESPONSE_MESSAGE, // 40

CIM_CREATE_CLASS_RESPONSE_MESSAGE,

CIM_CREATE_INSTANCE_RESPONSE_MESSAGE,

CIM_MODIFY_CLASS_RESPONSE_MESSAGE,

CIM_MODIFY_INSTANCE_RESPONSE_MESSAGE,

CIM_ENUMERATE_CLASSES_RESPONSE_MESSAGE, // 50

CIM_ENUMERATE_CLASSES_RESPONSE_MESSAGE,

CIM_ENUMERATE_CLASS_NAMES_RESPONSE_MESSAGE,

CIM_ENUMERATE_INSTANCES_RESPONSE_MESSAGE,

CIM_ENUMERATE_INSTANCE_NAMES_RESPONSE_MESSAGE,

CIM_EXEC_QUERY_RESPONSE_MESSAGE,

CIM_ASSOCIATORS_RESPONSE_MESSAGE,

CIM_ASSOCIATORS_RESPONSE_MESSAGE, // 50

CIM_ASSOCIATOR_NAMES_RESPONSE_MESSAGE,

CIM_REFERENCES_RESPONSE_MESSAGE,

CIM_REFERENCE_NAMES_RESPONSE_MESSAGE,

CIM_GET_PROPERTY_RESPONSE_MESSAGE,

CIM_SET_PROPERTY_RESPONSE_MESSAGE, // 60

CIM_SET_PROPERTY_RESPONSE_MESSAGE,

CIM_GET_QUALIFIER_RESPONSE_MESSAGE,

CIM_SET_QUALIFIER_RESPONSE_MESSAGE,

CIM_DELETE_QUALIFIER_RESPONSE_MESSAGE,

CIM_ENUMERATE_QUALIFIERS_RESPONSE_MESSAGE,

CIM_INVOKE_METHOD_RESPONSE_MESSAGE,

CIM_INVOKE_METHOD_RESPONSE_MESSAGE, // 60

CIM_ENABLE_INDICATION_SUBSCRIPTION_RESPONSE_MESSAGE,

CIM_MODIFY_INDICATION_SUBSCRIPTION_RESPONSE_MESSAGE,

CIM_DISABLE_INDICATION_SUBSCRIPTION_RESPONSE_MESSAGE,

CIM_PROCESS_INDICATION_RESPONSE_MESSAGE,

CIM_NOTIFY_PROVIDER_REGISTRATION_RESPONSE_MESSAGE, // 70

CIM_NOTIFY_PROVIDER_REGISTRATION_RESPONSE_MESSAGE,

CIM_NOTIFY_PROVIDER_TERMINATION_RESPONSE_MESSAGE,

CIM_HANDLE_INDICATION_RESPONSE_MESSAGE,

// new

CIM_ENABLE_INDICATIONS_RESPONSE_MESSAGE,

CIM_DISABLE_INDICATIONS_RESPONSE_MESSAGE,

CIM_CREATE_SUBSCRIPTION_RESPONSE_MESSAGE,

CIM_MODIFY_SUBSCRIPTION_RESPONSE_MESSAGE,

CIM_DELETE_SUBSCRIPTION_RESPONSE_MESSAGE,

// new

CIM_DISABLE_MODULE_RESPONSE_MESSAGE,

CIM_ENABLE_MODULE_RESPONSE_MESSAGE,

CIM_STOP_ALL_PROVIDERS_RESPONSE_MESSAGE, // 70

CIM_STOP_ALL_PROVIDERS_RESPONSE_MESSAGE, // 80

// Monitor-related messages:

Line 486

Line 471

ASYNC_DEREGISTER_CIM_SERVICE,

ASYNC_UPDATE_CIM_SERVICE,

ASYNC_IOCTL,

ASYNC_CIMSERVICE_START, // 90

ASYNC_CIMSERVICE_START, // 80

ASYNC_CIMSERVICE_STOP,

ASYNC_CIMSERVICE_PAUSE,

ASYNC_CIMSERVICE_RESUME,

Line 498

Line 483

ASYNC_FIND_SERVICE_Q,

ASYNC_FIND_SERVICE_Q_RESULT,

ASYNC_ENUMERATE_SERVICE, // 100

ASYNC_ENUMERATE_SERVICE, // 90

ASYNC_ENUMERATE_SERVICE_RESULT,

ASYNC_REGISTERED_MODULE,

Line 512

Line 497

CIM_NOTIFY_PROVIDER_ENABLE_REQUEST_MESSAGE,

CIM_NOTIFY_PROVIDER_ENABLE_RESPONSE_MESSAGE,

CIM_NOTIFY_PROVIDER_FAIL_REQUEST_MESSAGE, // 100

CIM_NOTIFY_PROVIDER_FAIL_RESPONSE_MESSAGE,

CIM_INITIALIZE_PROVIDER_REQUEST_MESSAGE,

CIM_INITIALIZE_PROVIDER_RESPONSE_MESSAGE,

Line 521

Line 509

CIM_NOTIFY_CONFIG_CHANGE_REQUEST_MESSAGE,

CIM_NOTIFY_CONFIG_CHANGE_RESPONSE_MESSAGE,

CIM_SUBSCRIPTION_INIT_COMPLETE_REQUEST_MESSAGE,

CIM_SUBSCRIPTION_INIT_COMPLETE_RESPONSE_MESSAGE,

NUMBER_OF_MESSAGES

};

Legend:

Removed from v.1.60.2.1
changed lines
	Added in v.1.75.2.2

No CVS admin address has been configured