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

Diff for /pegasus/src/Pegasus/Common/StatisticalData.cpp between version 1.4 and 1.18

version 1.4, 2004/06/09 20:05:48 version 1.18, 2006/11/10 18:14:58
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)  
 //  
 //%///////////////////////////////////////////////////////////////////////////// //%/////////////////////////////////////////////////////////////////////////////
  
 #include "StatisticalData.h" #include "StatisticalData.h"
   #include "Tracer.h"
  
 PEGASUS_NAMESPACE_BEGIN PEGASUS_NAMESPACE_BEGIN
  
 String StatisticalData::requestName[] = {  
     "GET_CLASS",  // The table on the right represents the mapping from the enumerated types
     "GET_INSTANCE",  // in the CIM_CIMOMStatisticalDate class ValueMap versus the internal
         "EXPORT_INDICATION",  // message type defined in Message.h. This conversion is performed by
     "DELETE_CLASS",  // getOpType() in CIMOMStatDataProvider.cpp.
     "DELETE_INSTANCE",  //
     "CREATE_CLASS",  
     "CREATE_INSTANCE",  String StatisticalData::requestName[] =
     "MODIFY_CLASS",  {
     "MODIFY_INSTANCE",                                      // Enumerated     ValueMap Value
     "ENUMERATE_CLASSES",                                      // value from     from class
     "ENUMERATE_CLASS_NAMES",                                      // internal       CIM_StatisticalData
     "ENUMERATE_INSTANCES",                                      // message type
     "ENUMERATE_INSTANCE_NAMES",                                      // -------------- -------------------
     "EXEC_QUERY",    "GetClass",                       //     1           3
     "ASSOCIATORS",    "GetInstance",                    //     2           4
     "ASSOCIATOR_NAMES",    "IndicationDelivery",             //     3           26
     "REFERENCES",    "DeleteClass",                    //     4           5
     "REFERENCE_NAMES",    "DeleteInstance",                 //     5           6
     "GET_PROPERTY",    "CreateClass",                    //     6           7
     "SET_PROPERTY",    "CreateInstance",                 //     7           8
     "GET_QUALIFIER",    "ModifyClass",                    //     8           9
     "SET_QUALIFIER",    "ModifyInstance",                 //     9          10
     "DELETE_QUALIFIER",    "EnumerateClasses",               //    10          11
     "ENUMERATE_QUALIFIERS"    "EnumerateClassNames",            //    11          12
     "EnumerateInstances",             //    12          13
     "EnumerateInstanceNames",         //    13          14
     "ExecQuery",                      //    14          15
     "Associators",                    //    15          16
     "AssociatorNames",                //    16          17
     "References",                     //    17          18
     "ReferenceNames",                 //    18          19
     "GetProperty",                    //    19          20
     "SetProperty",                    //    20          21
     "GetQualifier",                   //    21          22
     "SetQualifier",                   //    22          23
     "DeleteQualifier",                //    23          24
     "EnumerateQualifiers",            //    24          25
     "InvokeMethod"                    //    25          Not Present
       };       };
  
 const Uint32 StatisticalData::length = NUMBER_OF_TYPES; const Uint32 StatisticalData::length = NUMBER_OF_TYPES;
  
 StatisticalData* StatisticalData::cur = NULL; StatisticalData* StatisticalData::cur = NULL;
  
 StatisticalData* StatisticalData::current(){  StatisticalData* StatisticalData::current()
    if (cur == NULL){  {
       if (cur == NULL)
       {
       cur = new StatisticalData();       cur = new StatisticalData();
    }    }
    return cur;    return cur;
 } }
  
 StatisticalData::StatisticalData(){  StatisticalData::StatisticalData()
   {
       copyGSD = 0;
  
    for (unsigned int i=0; i<StatisticalData::length; i++){      for (unsigned int i=0; i<StatisticalData::length; i++)
       {
       numCalls[i] = 0;       numCalls[i] = 0;
       cimomTime[i] = 0;       cimomTime[i] = 0;
           providerTime[i] = 0;           providerTime[i] = 0;
       responseSize[i] = 0;       responseSize[i] = 0;
       requestSize[i] = 0;       requestSize[i] = 0;
   
    }    }
 } }
  
 void StatisticalData::addToValue(Uint64 value, Uint16 type, Uint32 t){  void StatisticalData::addToValue(Sint64 value, Uint16 type, Uint32 t)
    _mutex.lock( pegasus_thread_self() );  {
    switch(t){      if (type >= NUMBER_OF_TYPES)
           case SERVER:          numCalls[type] += 1;      {
            Tracer::trace(TRC_DISCARDED_DATA, Tracer::LEVEL2,
                "StatData: Statistical Data Discarded.  "
                    "Invalid Request Type =  %u", type);
            return;
       }
   
       if (copyGSD)
       {
           AutoMutex autoMut(_mutex);
           switch (t)
           {
               case PEGASUS_STATDATA_SERVER:
                   numCalls[type] += 1;
                         cimomTime[type] += value;                         cimomTime[type] += value;
                   Tracer::trace(TRC_STATISTICAL_DATA, Tracer::LEVEL2,
                       "StatData: SERVER: %s(%d): count = %"
                           PEGASUS_64BIT_CONVERSION_WIDTH "d; value = %"
                           PEGASUS_64BIT_CONVERSION_WIDTH "d; total = %"
                           PEGASUS_64BIT_CONVERSION_WIDTH "d",
                       (const char *)requestName[type].getCString(), type,
                       numCalls[type], value, cimomTime[type]);
                         break;                         break;
       case PROVIDER:    providerTime[type] += value;              case PEGASUS_STATDATA_PROVIDER:
                   providerTime[type] += value;
                   Tracer::trace(TRC_STATISTICAL_DATA, Tracer::LEVEL2,
                       "StatData: PROVIDER: %s(%d): count = %"
                           PEGASUS_64BIT_CONVERSION_WIDTH "d; value = %"
                           PEGASUS_64BIT_CONVERSION_WIDTH "d; total = %"
                           PEGASUS_64BIT_CONVERSION_WIDTH "d",
                       (const char *)requestName[type].getCString(), type,
                       numCalls[type], value, providerTime[type]);
                         break;                         break;
       case BYTES_SENT:  responseSize[type] += value;          case PEGASUS_STATDATA_BYTES_SENT:
                   responseSize[type] += value;
                   Tracer::trace(TRC_STATISTICAL_DATA, Tracer::LEVEL2,
                       "StatData: BYTES_SENT: %s(%d): count = %"
                           PEGASUS_64BIT_CONVERSION_WIDTH "d; value = %"
                           PEGASUS_64BIT_CONVERSION_WIDTH "d; total = %"
                           PEGASUS_64BIT_CONVERSION_WIDTH "d",
                       (const char *)requestName[type].getCString(), type,
                       numCalls[type], value, responseSize[type]);
                         break;                         break;
       case BYTES_READ:  requestSize[type] += value;          case PEGASUS_STATDATA_BYTES_READ:
                   requestSize[type] += value;
                   Tracer::trace(TRC_STATISTICAL_DATA, Tracer::LEVEL2,
                       "StatData: BYTES_READ: %s(%d): count = %"
                           PEGASUS_64BIT_CONVERSION_WIDTH "d; value = %"
                           PEGASUS_64BIT_CONVERSION_WIDTH "d; total = %"
                           PEGASUS_64BIT_CONVERSION_WIDTH "d",
                       (const char *)requestName[type].getCString(), type,
                       numCalls[type], value, requestSize[type]);
                         break;                         break;
    }    }
    _mutex.unlock();      }
 } }
  
   void StatisticalData::setCopyGSD(Boolean flag)
   {
       copyGSD = flag;
   }
  
 PEGASUS_NAMESPACE_END PEGASUS_NAMESPACE_END

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