ClientWorkerItem.hpp

Go to the documentation of this file.

#ifndef CLIENT_WORKER_ITEM_HPP
#define CLIENT_WORKER_ITEM_HPP

#include <iostream>
#include <vector>
#include <deque>

#include "Dictionary.hpp"

namespace HCE
{
namespace handlers
{
//-----------------------------------------------------------------------------
class TimeoutShiftCounter
{
public:
  TimeoutShiftCounter(void);

  TimeoutShiftCounter& operator=(const TimeoutShiftCounter& rhs);
  TimeoutShiftCounter& operator=(TimeoutShiftCounter&& rhs);

  void reset(void);
  void responceTimeStamp(size_t rtimestamp);
  void recount(unsigned int timeout);

  size_t getRcounter(void) const {return rcounter;}
  size_t getRdiff(void) const {return rdiff;}
  unsigned int getShift(void) const {return shift;}
 private:
   size_t rcounter;
   size_t rdiff;
   unsigned int shift;
};
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
typedef HCE::handlers::Dictionary <std::string, double> ResourceUsageData;
typedef std::deque<ResourceUsageData> ResourceUsageCollection;
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
typedef struct ClientWorkerItem
{
  ClientWorkerItem(void);
  explicit ClientWorkerItem(const std::string& identity_, int64_t expiry_=0, unsigned long long frequency_=0, unsigned long long count_=0);
  ClientWorkerItem(const ClientWorkerItem& rhs);
  ClientWorkerItem(ClientWorkerItem&& rhs);

  ClientWorkerItem& operator=(const ClientWorkerItem& rhs);
  ClientWorkerItem& operator=(ClientWorkerItem&& rhs);

  void clear(void);

  static bool sortByFrequencyPredicate(const ClientWorkerItem& d1, const ClientWorkerItem& d2);

  std::string identity;                 
  int64_t expiry;                       
  unsigned long long frequency;         
  unsigned long long count;             
  std::vector<ClientWorkerItem> route;  
  ResourceUsageCollection resources;    
  size_t rtimestamp;                    
  TimeoutShiftCounter shiftCounter;     
  std::string property;                 
  double cpu;                           
  double iowait;                        

} ClientWorkerItem;
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
} // end namespace handlers
} // end namespace HCE 

#endif // CLIENT_WORKER_ITEM_HPP