(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.2 and 1.29

version 1.2, 2002/04/22 17:26:30 version 1.29, 2006/09/08 17:25:01
Line 1 
Line 1 
   //%2006////////////////////////////////////////////////////////////////////////
 // //
 // Copyright (c) 2000, 2001 The Open group, BMC Software, Tivoli Systems, IBM  // Copyright (c) 2000, 2001, 2002 BMC Software; Hewlett-Packard Development
   // Company, L.P.; IBM Corp.; The Open Group; Tivoli Systems.
   // Copyright (c) 2003 BMC Software; Hewlett-Packard Development Company, L.P.;
   // 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 19 
Line 29 
 // //
 //============================================================================== //==============================================================================
 // //
 // Author: Arthur Pichlkostner  
 //             (checked in: Markus Mueller sedgewick_de@yahoo.de)  
 //  
 //%///////////////////////////////////////////////////////////////////////////// //%/////////////////////////////////////////////////////////////////////////////
  
 #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/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/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/CIMDateTime.h>
   #include <Pegasus/Common/CIMMessage.h>
   #include <Pegasus/Common/Mutex.h>
   #include <Pegasus/Common/Time.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 \  
 response->endProvider();            \  
 response->setStartServerTime(request->getStartServerTime()); \  
 response->setStartProviderTime(startTime);  
  
 #define STAT_SERVERSTART request->setStartServerTime(startTime);  #define STAT_SERVERSTART \
   request->setServerStartTime(serverStartTimeMicroseconds);
  
 #define STAT_SERVEREND \ #define STAT_SERVEREND \
 response->endServer(); \ response->endServer(); \
 Array<Sint8> timeOut;  \  
 timeOut.reserve(10); \  
 timeOut << response->getTotalTime();      \  
 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(), \  
     statType, StatisticalData::BYTES_SENT);  
   
 #define STAT_SERVEREND_ERROR   response->endServer();  
   
   
 #define STAT_PROVIDERSTART request->startProvider();  
  
   #define STAT_BYTESSENT \
   Uint16 statType = (response->getType() >= CIM_GET_CLASS_RESPONSE_MESSAGE)? \
     response->getType() - CIM_GET_CLASS_RESPONSE_MESSAGE:response->getType() - 1;\
   StatisticalData::current()->addToValue(message.size(), statType, StatisticalData::PEGASUS_STATDATA_BYTES_SENT);
  
 #define STAT_PROVIDEREND   request->endProvider();  
  
 #define STAT_COPYDISPATCHER response->setStartServerTime(request->getStartServerTime());  
  
   #define STAT_SERVEREND_ERROR \
   response->endServer();
  
 // copy request timing info into response  /*the request size value must be stored (requSize) and passed to the StatisticalData object at the
 #define STAT_COPYDISPATCHER_REP \   end of processing other wise it will be the ONLY vlaue that is passed to the client which reports
 response->setStartServerTime(request->getStartServerTime());   \   the current state of the object, not the pevious (one command ago) state */
 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()->requSize = contentLength;
 StatisticalData::current()->addToValue(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 131 
Line 146 
          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,           PEGASUS_STATDATA_SERVER,
          PROVIDER,           PEGASUS_STATDATA_PROVIDER,
          BYTES_SENT,           PEGASUS_STATDATA_BYTES_SENT,
          BYTES_READ           PEGASUS_STATDATA_BYTES_READ
       };       };
  
       static const Uint32 length;       static const Uint32 length;
Line 148 
Line 164 
  
       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;
   //      Uint64 totalServTime;
       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.2  
changed lines
  Added in v.1.29
No CVS admin address has been configured
 Powered by
ViewCVS 0.9.2