(file) Return to StatisticalData.h CVS log (file) (dir) Up to [Pegasus] / pegasus / src / Pegasus / Common

Diff for /pegasus/src/Pegasus/Common/StatisticalData.h between version 1.7 and 1.31

version 1.7, 2003/10/22 14:26:04 version 1.31, 2007/11/30 18:48:56
Line 1 
Line 1 
 //%2003////////////////////////////////////////////////////////////////////////  //%2006////////////////////////////////////////////////////////////////////////
 // //
 // Copyright (c) 2000, 2001, 2002  BMC Software, Hewlett-Packard Development  // Copyright (c) 2000, 2001, 2002 BMC Software; Hewlett-Packard Development
 // Company, L. P., IBM Corp., The Open Group, Tivoli Systems.  // Company, L.P.; IBM Corp.; The Open Group; Tivoli Systems.
 // Copyright (c) 2003 BMC Software; Hewlett-Packard Development Company, L. P.; // Copyright (c) 2003 BMC Software; Hewlett-Packard Development Company, L. P.;
 // IBM Corp.; EMC Corporation, The Open Group. // IBM Corp.; EMC Corporation, The Open Group.
   // Copyright (c) 2004 BMC Software; Hewlett-Packard Development Company, L.P.;
   // IBM Corp.; EMC Corporation; VERITAS Software Corporation; The Open Group.
   // Copyright (c) 2005 Hewlett-Packard Development Company, L.P.; IBM Corp.;
   // EMC Corporation; VERITAS Software Corporation; The Open Group.
   // Copyright (c) 2006 Hewlett-Packard Development Company, L.P.; IBM Corp.;
   // EMC Corporation; Symantec Corporation; The Open Group.
 // //
 // Permission is hereby granted, free of charge, to any person obtaining a copy // Permission is hereby granted, free of charge, to any person obtaining a copy
 // of this software and associated documentation files (the "Software"), to // of this software and associated documentation files (the "Software"), to
Line 23 
Line 29 
 // //
 //============================================================================== //==============================================================================
 // //
 // Author: Arthur Pichlkostner  
 //             (checked in: Markus Mueller sedgewick_de@yahoo.de)  
 //  
 // Modified By:  
 //  
 //%///////////////////////////////////////////////////////////////////////////// //%/////////////////////////////////////////////////////////////////////////////
  
 #ifndef STATISTICAL_DATA_H  #ifndef Pegasus_StatisticalData_h
 #define STATISTICAL_DATA_H  #define Pegasus_StatisticalData_h
  
 #include <Pegasus/Common/Config.h> #include <Pegasus/Common/Config.h>
 #include <iostream> #include <iostream>
 #include <cstring> #include <cstring>
   #include <Pegasus/Common/Linkage.h>
 #include <Pegasus/Common/InternalException.h> #include <Pegasus/Common/InternalException.h>
 #include <Pegasus/Common/IPC.h>  
 #include <Pegasus/Common/String.h> #include <Pegasus/Common/String.h>
 #include <Pegasus/Common/CIMProperty.h> #include <Pegasus/Common/CIMProperty.h>
 #include <Pegasus/Common/CIMInstance.h> #include <Pegasus/Common/CIMInstance.h>
 #include <Pegasus/Common/Linkage.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 PEGASUS_NAMESPACE_BEGIN
  
 #ifdef PEGASUS_HAS_PERFINST  #ifndef PEGASUS_DISABLE_PERFINST
  
 #define STAT_GETSTARTTIME \ #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 \ #define STAT_SERVEREND \
 response->endServer(); \ 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() - CIM_GET_CLASS_RESPONSE_MESSAGE: \
     response->getType()-1; \     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 \ #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() - CIM_GET_CLASS_RESPONSE_MESSAGE: \
     request->getType()-1; \     request->getType()-1; \
 StatisticalData::current()->addToValue(contentLength, \  StatisticalData::current()->requSize = contentLength;
     statType, StatisticalData::BYTES_READ);  
   
  
 #define STAT_SERVERTIME out << "Servertime:  \r\n";  
 #else #else
 #define STAT_GETSTARTTIME #define STAT_GETSTARTTIME
 #define STAT_PMS_PROVIDEREND  
 #define STAT_SERVERSTART #define STAT_SERVERSTART
 #define STAT_SERVEREND #define STAT_SERVEREND
 #define STAT_SERVEREND_ERROR #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_BYTESREAD
 #define STAT_SERVERTIME  #define STAT_BYTESSENT
 #endif #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 class PEGASUS_COMMON_LINKAGE StatisticalData
 { {
    public:    public:
       enum StatRequestType{      enum StatRequestType
       {
          GET_CLASS,          GET_CLASS,
          GET_INSTANCE,          GET_INSTANCE,
           INDICATION_DELIVERY,
          DELETE_CLASS,          DELETE_CLASS,
          DELETE_INSTANCE,          DELETE_INSTANCE,
          CREATE_CLASS,          CREATE_CLASS,
Line 138 
Line 153 
          SET_QUALIFIER,          SET_QUALIFIER,
          DELETE_QUALIFIER,          DELETE_QUALIFIER,
          ENUMERATE_QUALIFIERS,          ENUMERATE_QUALIFIERS,
           INVOKE_METHOD,
          NUMBER_OF_TYPES          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;       static const Uint32 length;
Line 155 
Line 172 
  
       timeval timestamp;       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;       static StatisticalData* cur;
       void addToValue(Uint64 value, Uint16 type, Uint32 t);      void addToValue(Sint64 value, Uint16 type, Uint32 t);
       static String requestName[];       static String requestName[];
       void setCopyGSD(Boolean flag);
  
    protected:    protected:
       Mutex _mutex;       Mutex _mutex;

Legend:
Removed from v.1.7  
changed lines
  Added in v.1.31
No CVS admin address has been configured
 Powered by
ViewCVS 0.9.2