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

Diff for /pegasus/src/Pegasus/Common/Message.h between version 1.49 and 1.55

version 1.49, 2004/04/16 22:17:41 version 1.55, 2004/06/24 19:49:53
Line 31 
Line 31 
 //              Mike Day (mdday@us.ibm.com) //              Mike Day (mdday@us.ibm.com)
 //              Roger Kumpf, Hewlett-Packard Company (roger_kumpf@hp.com) //              Roger Kumpf, Hewlett-Packard Company (roger_kumpf@hp.com)
 //              Arthur Pichlkostner (via Markus: sedgewick_de@yahoo.de) //              Arthur Pichlkostner (via Markus: sedgewick_de@yahoo.de)
   //                              Willis White (whiwill@us.ibm.com)
   //         Brian G. Campbell, EMC (campbell_brian@emc.com) - PEP140/phase1
 // //
 //%///////////////////////////////////////////////////////////////////////////// //%/////////////////////////////////////////////////////////////////////////////
  
Line 44 
Line 46 
 #include <Pegasus/Common/IPC.h> #include <Pegasus/Common/IPC.h>
 #include <Pegasus/Common/StatisticalData.h> #include <Pegasus/Common/StatisticalData.h>
 #include <Pegasus/Common/Linkage.h> #include <Pegasus/Common/Linkage.h>
   #include <Pegasus/Common/CIMDateTime.h>
  
 PEGASUS_NAMESPACE_BEGIN PEGASUS_NAMESPACE_BEGIN
  
Line 132 
Line 135 
          _next(0),          _next(0),
          _prev(0),          _prev(0),
          _async(0),          _async(0),
          dest(destination)           dest(destination),
            _isComplete(true),
            _index(0)
       {       {
  
       }       }
Line 149 
Line 154 
             _next = _prev = _async = 0;             _next = _prev = _async = 0;
             dest = msg.dest;             dest = msg.dest;
             _httpMethod = msg._httpMethod;             _httpMethod = msg._httpMethod;
                           _index = msg._index;
                           _isComplete = msg._isComplete;
  
          }          }
          return *this;          return *this;
Line 189 
Line 196 
  
       void endProvider();       void endProvider();
  
       timeval getStartServerTime() const { return _timeServerStart; }        CIMDateTime getStartServerTime() const { return _timeServerStart; }
  
       void setStartServerTime(timeval timeServerStart)        void setStartServerTime(CIMDateTime timeServerStart)
       {       {
            _timeServerStart = timeServerStart;            _timeServerStart = timeServerStart;
       }       }
  
       timeval getStartProviderTime() const { return _timeProviderStart; }        CIMDateTime getStartProviderTime() const { return _timeProviderStart; }
  
       void setStartProviderTime(timeval timeProviderStart)        void setStartProviderTime(CIMDateTime timeProviderStart)
       {       {
           _timeProviderStart = timeProviderStart;           _timeProviderStart = timeProviderStart;
       }       }
  
       timeval getEndServerTime() const { return _timeServerEnd; }        CIMDateTime getEndServerTime() const { return _timeServerEnd; }
  
       void setEndServerTime (timeval timeServerEnd)        void setEndServerTime (CIMDateTime timeServerEnd)
       {       {
           _timeServerEnd = timeServerEnd;           _timeServerEnd = timeServerEnd;
       }       }
  
       timeval getEndProviderTime() const { return _timeProviderEnd; }        CIMDateTime getEndProviderTime() const { return _timeProviderEnd; }
  
       void setEndProviderTime(timeval timeProviderEnd)        void setEndProviderTime(CIMDateTime timeProviderEnd)
       {       {
           _timeProviderEnd = timeProviderEnd;           _timeProviderEnd = timeProviderEnd;
       }       }
  
       Uint32 getTotalTime() { return _totalTime; }            CIMDateTime getProviderTime() { return _providerTime;}
   
         CIMDateTime getTotalTime() { return _totalTime; }
   
             CIMDateTime getServerTime() { return _serverTime; }
 // //
 #endif #endif
  
Line 285 
Line 296 
          _routing_code = req->_routing_code;          _routing_code = req->_routing_code;
       }       }
  
                           // set the message index indicating what piece (or sequence) this is
                           // message indexes start at zero
                           void setIndex(Uint32 index) { _index = index; }
   
                           // increment the message index
                           void incrementIndex() { _index++; }
   
                           // set the complete flag indicating if this message piece is the
                           // last or not
                           void setComplete(Boolean isComplete)
                                   { _isComplete = isComplete ? true:false; }
   
                           // get the message index (or sequence number)
                           Uint32 getIndex() const { return _index; }
   
                           // is this the first piece of the message ?
                           Boolean isFirst() const { return _index == 0 ? true : false; }
   
                           // is this message complete? (i.e the last in a one or more sequence)
                           Boolean isComplete() const { return _isComplete; }
  
    private:    private:
       Uint32 _type;       Uint32 _type;
Line 293 
Line 324 
       Uint32 _mask;       Uint32 _mask;
       HttpMethod _httpMethod;       HttpMethod _httpMethod;
 // Needed for performance measurement // Needed for performance measurement
       timeval _timeServerStart;        CIMDateTime _timeServerStart;
       timeval _timeServerEnd;        CIMDateTime _timeServerEnd;
       timeval _timeProviderStart;        CIMDateTime _timeProviderStart;
       timeval _timeProviderEnd;        CIMDateTime _timeProviderEnd;
       Uint64 _totalTime;            CIMDateTime _providerTime;
             CIMDateTime _serverTime;
         CIMDateTime _totalTime;
 // //
  
       // << Tue Jul  1 11:02:35 2003 mdd >> pep_88 and helper for i18n and l10n       // << Tue Jul  1 11:02:35 2003 mdd >> pep_88 and helper for i18n and l10n
Line 313 
Line 346 
       Uint32 dest;       Uint32 dest;
    private:    private:
       MessageQueue* _owner;       MessageQueue* _owner;
         Boolean _isComplete;
         Uint32 _index;
       static Uint32 _nextKey;       static Uint32 _nextKey;
       static Mutex _mut;       static Mutex _mut;
  
Line 468 
Line 503 
  
     ASYNC_ASYNC_MODULE_OP_START,     ASYNC_ASYNC_MODULE_OP_START,
     ASYNC_ASYNC_MODULE_OP_RESULT,     ASYNC_ASYNC_MODULE_OP_RESULT,
     // for indication consumers  
   
     CIM_CONSUME_INDICATION_REQUEST_MESSAGE,  
     CIM_CONSUME_INDICATION_RESPONSE_MESSAGE,  
  
     CIM_NOTIFY_PROVIDER_ENABLE_REQUEST_MESSAGE,     CIM_NOTIFY_PROVIDER_ENABLE_REQUEST_MESSAGE,
     CIM_NOTIFY_PROVIDER_ENABLE_RESPONSE_MESSAGE,     CIM_NOTIFY_PROVIDER_ENABLE_RESPONSE_MESSAGE,
  
       CIM_INITIALIZE_PROVIDER_REQUEST_MESSAGE,
       CIM_INITIALIZE_PROVIDER_RESPONSE_MESSAGE,
   
       CIM_INITIALIZE_PROVIDER_AGENT_REQUEST_MESSAGE,
       CIM_INITIALIZE_PROVIDER_AGENT_RESPONSE_MESSAGE,
   
       CIM_NOTIFY_CONFIG_CHANGE_REQUEST_MESSAGE,
       CIM_NOTIFY_CONFIG_CHANGE_RESPONSE_MESSAGE,
   
     NUMBER_OF_MESSAGES     NUMBER_OF_MESSAGES
 }; };
  

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