(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.22.22.2

version 1.4, 2004/06/09 20:05:48 version 1.22.22.2, 2013/10/15 05:10:39
Line 1 
Line 1 
 //%2003////////////////////////////////////////////////////////////////////////  //%LICENSE////////////////////////////////////////////////////////////////
 // //
 // Copyright (c) 2000, 2001, 2002  BMC Software, Hewlett-Packard Development  // Licensed to The Open Group (TOG) under one or more contributor license
 // Company, L. P., IBM Corp., The Open Group, Tivoli Systems.  // agreements.  Refer to the OpenPegasusNOTICE.txt file distributed with
 // Copyright (c) 2003 BMC Software; Hewlett-Packard Development Company, L. P.;  // this work for additional information regarding copyright ownership.
 // IBM Corp.; EMC Corporation, The Open Group.  // Each contributor licenses this file to you under the OpenPegasus Open
 //  // Source License; you may not use this file except in compliance with the
 // Permission is hereby granted, free of charge, to any person obtaining a copy  // License.
 // of this software and associated documentation files (the "Software"), to  //
 // deal in the Software without restriction, including without limitation the  // Permission is hereby granted, free of charge, to any person obtaining a
 // rights to use, copy, modify, merge, publish, distribute, sublicense, and/or  // copy of this software and associated documentation files (the "Software"),
 // sell copies of the Software, and to permit persons to whom the Software is  // to deal in the Software without restriction, including without limitation
 // furnished to do so, subject to the following conditions:  // the rights to use, copy, modify, merge, publish, distribute, sublicense,
 //  // and/or sell copies of the Software, and to permit persons to whom the
 // THE ABOVE COPYRIGHT NOTICE AND THIS PERMISSION NOTICE SHALL BE INCLUDED IN  // Software is furnished to do so, subject to the following conditions:
 // 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  // The above copyright notice and this permission notice shall be included
 // LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR  // in all copies or substantial portions of the Software.
 // PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT  //
 // HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN  // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
 // ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION  // OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
 // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.  // 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  
 //             (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",  
     "GET_INSTANCE",  
         "EXPORT_INDICATION",  
     "DELETE_CLASS",  
     "DELETE_INSTANCE",  
     "CREATE_CLASS",  
     "CREATE_INSTANCE",  
     "MODIFY_CLASS",  
     "MODIFY_INSTANCE",  
     "ENUMERATE_CLASSES",  
     "ENUMERATE_CLASS_NAMES",  
     "ENUMERATE_INSTANCES",  
     "ENUMERATE_INSTANCE_NAMES",  
     "EXEC_QUERY",  
     "ASSOCIATORS",  
     "ASSOCIATOR_NAMES",  
     "REFERENCES",  
     "REFERENCE_NAMES",  
     "GET_PROPERTY",  
     "SET_PROPERTY",  
     "GET_QUALIFIER",  
     "SET_QUALIFIER",  
     "DELETE_QUALIFIER",  
     "ENUMERATE_QUALIFIERS"  
       };  
  
 const Uint32 StatisticalData::length = NUMBER_OF_TYPES;  // The table on the right represents the mapping from the enumerated types
   // in the CIM_CIMOMStatisticalDate class ValueMap versus the internal
   // message type defined in Message.h. This conversion is performed by
   // getOpType() in CIMOMStatDataProvider.cpp.
   //
   
   String StatisticalData::requestName[] =
   {
                                       // Enumerated     ValueMap Value
                                       // value from     from class
                                       // Pegasus        CIM_StatisticalData
                                       // message type
                                       // -------------- -------------------
   //"Unknown",                        //                 0   default
   //"Other",                          //                 1   mapped
   //"Batched",                        //                 2   not used
     "GetClass",                       //     1           3
     "GetInstance",                    //     2           4
     "IndicationDelivery",             //     3          26
     "DeleteClass",                    //     4           5
     "DeleteInstance",                 //     5           6
     "CreateClass",                    //     6           7
     "CreateInstance",                 //     7           8
     "ModifyClass",                    //     8           9
     "ModifyInstance",                 //     9          10
     "EnumerateClasses",               //    10          11
     "EnumerateClassNames",            //    12          12
     "EnumerateInstances",             //    13          13
     "EnumerateInstanceNames",         //    14          14
     "ExecQuery",                      //    15          15
     "Associators",                    //    16          16
     "AssociatorNames",                //    17          17
     "References",                     //    18          18
     "ReferenceNames",                 //    19          20
     "GetProperty",                    //    20          20
     "SetProperty",                    //    21          21
     "GetQualifier",                   //    22          22
     "SetQualifier",                   //    23          23
     "DeleteQualifier",                //    24          24
     "EnumerateQualifiers",            //    25          25
   // Entries below this point are not part of the CIM Class and are treated
   // as OtherOperationTypes in the CIM_CIMOMStatisticalData instance.
     "InvokeMethod"                    //    26          Not Present index = 26
  
 StatisticalData* StatisticalData::cur = NULL;  };
  
 StatisticalData* StatisticalData::current(){  const Uint32 StatisticalData::length = NUMBER_OF_TYPES;
    if (cur == NULL){  
       cur = new StatisticalData();  
    }  
    return cur;  
 }  
  
 StatisticalData::StatisticalData(){  // Pointer to StatisticalData table if it exists.
   StatisticalData* StatisticalData::table = NULL;
  
    for (unsigned int i=0; i<StatisticalData::length; i++){  // If first call, create the statistical data array
   StatisticalData* StatisticalData::current()
   {
       if (table == NULL)
       {
           table = new StatisticalData();
       }
       return table;
   }
   
   // Constructor clears the statisticalData Array and sets the gatherint
   // flag to zero
   StatisticalData::StatisticalData()
   {
       copyGSD = 0;
       clear();
   }
   
   void StatisticalData::clear()
   {
       AutoMutex autoMut(_mutex);
       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){  
    _mutex.lock( pegasus_thread_self() );  String StatisticalData::getRequestName(Uint16 i)
    switch(t){  {
           case SERVER:          numCalls[type] += 1;      return requestName[i];
   }
   
   void StatisticalData::addToValue(Sint64 value,
       MessageType msgType,
       StatDataType t)
   {
       // Map MessageType to statistic type. Requires multiple tests because
       // mapping request and responses to the request types.
       Uint16 type;
   
       // if is response type, substract starting point of responses.
       if (msgType >= CIM_GET_CLASS_RESPONSE_MESSAGE)
       {
           type = msgType - CIM_GET_CLASS_RESPONSE_MESSAGE;
       }
       else
       {
           type = msgType - 1;
       }
   
       // Test if valid statistic type
       if (type >= NUMBER_OF_TYPES)
       {
            PEG_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;
                   PEG_TRACE((TRC_STATISTICAL_DATA, Tracer::LEVEL4,
                       "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;
                   PEG_TRACE((TRC_STATISTICAL_DATA, Tracer::LEVEL4,
                       "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;
                   PEG_TRACE((TRC_STATISTICAL_DATA, Tracer::LEVEL4,
                       "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;
                   PEG_TRACE((TRC_STATISTICAL_DATA, Tracer::LEVEL4,
                       "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.22.22.2
No CVS admin address has been configured
 Powered by
ViewCVS 0.9.2