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

Return to StatisticalData.h CVS log

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

Diff for /pegasus/src/Pegasus/Common/StatisticalData.h between version 1.4 and 1.33

version 1.4, 2002/07/19 23:00:25

version 1.33, 2008/12/02 09:00:52

Line 1

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

//%LICENSE////////////////////////////////////////////////////////////////

// The Open Group, Tivoli Systems

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

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

// deal in the Software without restriction, including without limitation the

// rights to use, copy, modify, merge, publish, distribute, sublicense, and/or

// sell copies of the Software, and to permit persons to whom the Software is

// furnished to do so, subject to the following conditions:

// THE ABOVE COPYRIGHT NOTICE AND THIS PERMISSION NOTICE SHALL BE INCLUDED IN

// ALL COPIES OR SUBSTANTIAL PORTIONS OF THE SOFTWARE. THE SOFTWARE IS PROVIDED

// "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT

// LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR

// PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT

// HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN

// ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION

// WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.

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

// Author: Arthur Pichlkostner

// Licensed to The Open Group (TOG) under one or more contributor license

// (checked in: Markus Mueller sedgewick_de@yahoo.de)

// agreements. Refer to the OpenPegasusNOTICE.txt file distributed with

// this work for additional information regarding copyright ownership.

// Each contributor licenses this file to you under the OpenPegasus Open

// Source License; you may not use this file except in compliance with the

// License.

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

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

// to deal in the Software without restriction, including without limitation

// the rights to use, copy, modify, merge, publish, distribute, sublicense,

// and/or sell copies of the Software, and to permit persons to whom the

// Software is furnished to do so, subject to the following conditions:

// The above copyright notice and this permission notice shall be included

// in all copies or substantial portions of the Software.

// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS

// OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF

// MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.

// IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY

// CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT,

// TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE

// SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.

// Modified By:

//////////////////////////////////////////////////////////////////////////

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

#ifndef STATISTICAL_DATA_H

#ifndef Pegasus_StatisticalData_h

#define STATISTICAL_DATA_H

#define Pegasus_StatisticalData_h

#include <Pegasus/Common/Config.h>

#include <iostream>

#include <cstring>

#include <Pegasus/Common/Exception.h>

#include <Pegasus/Common/Linkage.h>

#include <Pegasus/Common/IPC.h>

#include <Pegasus/Common/InternalException.h>

#include <Pegasus/Common/String.h>

#include <Pegasus/Common/CIMProperty.h>

#include <Pegasus/Common/CIMInstance.h>

#include <Pegasus/Common/CIMDateTime.h>

#include <Pegasus/Common/CIMMessage.h>

#include <Pegasus/Common/Mutex.h>

#include <Pegasus/Common/Time.h>

#include <Pegasus/Common/TimeValue.h>

PEGASUS_NAMESPACE_BEGIN

#ifdef PEGASUS_HAS_PERFINST

#ifndef PEGASUS_DISABLE_PERFINST

#define STAT_GETSTARTTIME \

timeval startTime; \

Uint64 serverStartTimeMicroseconds = \

pegasus_gettimeofday(&startTime);

TimeValue::getCurrentTime().toMicroseconds();

#define STAT_PMS_PROVIDEREND \

#define STAT_SERVERSTART \

response->endProvider(); \

request->setServerStartTime(serverStartTimeMicroseconds);

response->setStartServerTime(request->getStartServerTime()); \

response->setStartProviderTime(startTime);

#define STAT_SERVERSTART request->setStartServerTime(startTime);

#define STAT_SERVEREND \

response->endServer(); \

Array<Sint8> timeOut; \

timeOut.reserveCapacity(10); \

#define STAT_BYTESSENT \

timeOut << response->getTotalTime(); \

Uint16 statType = (response->getType() >= CIM_GET_CLASS_RESPONSE_MESSAGE) ? \

message.insert(30, timeOut.getData(), timeOut.size()); \

Uint32 statType = (response->getType() > CIM_GET_CLASS_RESPONSE_MESSAGE)? \

response->getType() - CIM_GET_CLASS_RESPONSE_MESSAGE: \

response->getType()-1; \

StatisticalData::current()->addToValue(message.size(), \

StatisticalData::current()->addToValue( \

statType, StatisticalData::BYTES_SENT);

message.size(), statType, StatisticalData::PEGASUS_STATDATA_BYTES_SENT);

#define STAT_SERVEREND_ERROR response->endServer();

#define STAT_PROVIDERSTART request->startProvider();

#define STAT_SERVEREND_ERROR \

response->endServer();

#define STAT_PROVIDEREND request->endProvider();

The request size value must be stored (requSize) and passed to the

StatisticalData object at the end of processing other wise it will be

#define STAT_COPYDISPATCHER response->setStartServerTime(request->getStartServerTime());

the ONLY vlaue that is passed to the client which reports the current

state of the object, not the pevious (one command ago) state

// copy request timing info into response

#define STAT_COPYDISPATCHER_REP \

response->setStartServerTime(request->getStartServerTime()); \

response->setStartProviderTime(request->getStartProviderTime()); \

response->setEndProviderTime(request->getEndProviderTime());

#define STAT_BYTESREAD \

Uint32 statType = (request->getType() > CIM_GET_CLASS_RESPONSE_MESSAGE)? \

Uint16 statType = (request->getType() >= CIM_GET_CLASS_RESPONSE_MESSAGE) ? \

request->getType() - CIM_GET_CLASS_RESPONSE_MESSAGE: \

request->getType()-1; \

StatisticalData::current()->addToValue(contentLength, \

StatisticalData::current()->requSize = contentLength;

statType, StatisticalData::BYTES_READ);

#define STAT_SERVERTIME out << "Servertime: \r\n";

#else

#define STAT_GETSTARTTIME

#define STAT_PMS_PROVIDEREND

#define STAT_SERVERSTART

#define STAT_SERVEREND

#define STAT_SERVEREND_ERROR

#define STAT_PROVIDERSTART

#define STAT_PROVIDEREND

#define STAT_PROVIDEREND_REP

#define STAT_COPYDISPATCHER

#define STAT_COPYDISPATCHER_REP

#define STAT_BYTESREAD

#define STAT_SERVERTIME

#define STAT_BYTESSENT

#endif

class PEGASUS_COMMON_LINKAGE StatProviderTimeMeasurement

{

public:

StatProviderTimeMeasurement(CIMMessage* message)

: _message(message)

{

#ifndef PEGASUS_DISABLE_PERFINST

_startTimeMicroseconds = TimeValue::getCurrentTime().toMicroseconds();

#endif

}

~StatProviderTimeMeasurement()

{

#ifndef PEGASUS_DISABLE_PERFINST

_message->setProviderTime(

TimeValue::getCurrentTime().toMicroseconds() -

_startTimeMicroseconds);

#endif

}

private:

StatProviderTimeMeasurement();

StatProviderTimeMeasurement(const StatProviderTimeMeasurement&);

StatProviderTimeMeasurement& operator=(const StatProviderTimeMeasurement&);

CIMMessage* _message;

Uint64 _startTimeMicroseconds;

};

class PEGASUS_COMMON_LINKAGE StatisticalData

{

public:

enum StatRequestType{

enum StatRequestType

{

GET_CLASS,

GET_INSTANCE,

INDICATION_DELIVERY,

DELETE_CLASS,

DELETE_INSTANCE,

CREATE_CLASS,

Line 135

Line 151

SET_QUALIFIER,

DELETE_QUALIFIER,

ENUMERATE_QUALIFIERS,

INVOKE_METHOD,

NUMBER_OF_TYPES

};

enum StatDataType{

enum StatDataType

SERVER,

{

PROVIDER,

PEGASUS_STATDATA_SERVER,

BYTES_SENT,

PEGASUS_STATDATA_PROVIDER,

BYTES_READ

PEGASUS_STATDATA_BYTES_SENT,

PEGASUS_STATDATA_BYTES_READ

};

static const Uint32 length;

Line 152

Line 170

timeval timestamp;

Uint64 numCalls[NUMBER_OF_TYPES];

Sint64 numCalls[NUMBER_OF_TYPES];

Uint64 cimomTime[NUMBER_OF_TYPES];

Sint64 cimomTime[NUMBER_OF_TYPES];

Uint64 providerTime[NUMBER_OF_TYPES];

Sint64 providerTime[NUMBER_OF_TYPES];

Uint64 responseSize[NUMBER_OF_TYPES];

Sint64 responseSize[NUMBER_OF_TYPES];

Uint64 requestSize[NUMBER_OF_TYPES];

Sint64 requestSize[NUMBER_OF_TYPES];

Sint64 requSize; //tempory storage for requestSize vlaue

Boolean copyGSD;

static StatisticalData* cur;

void addToValue(Uint64 value, Uint16 type, Uint32 t);

void addToValue(Sint64 value, Uint16 type, Uint32 t);

static String requestName[];

void setCopyGSD(Boolean flag);

protected:

Mutex _mutex;

Legend:

Removed from v.1.4
changed lines
	Added in v.1.33

No CVS admin address has been configured