granicus.if.org Git - icinga2/blob - lib/livestatus/maxaggregator.cpp

   1 /* Icinga 2 | (c) 2012 Icinga GmbH | GPLv2+ */
   2
   3 #include "livestatus/maxaggregator.hpp"
   4
   5 using namespace icinga;
   6
   7 MaxAggregator::MaxAggregator(String attr)
   8         : m_MaxAttr(std::move(attr))
   9 { }
  10
  11 MaxAggregatorState *MaxAggregator::EnsureState(AggregatorState **state)
  12 {
  13         if (!*state)
  14                 *state = new MaxAggregatorState();
  15
  16         return static_cast<MaxAggregatorState *>(*state);
  17 }
  18
  19 void MaxAggregator::Apply(const Table::Ptr& table, const Value& row, AggregatorState **state)
  20 {
  21         Column column = table->GetColumn(m_MaxAttr);
  22
  23         Value value = column.ExtractValue(row);
  24
  25         MaxAggregatorState *pstate = EnsureState(state);
  26
  27         if (value > pstate->Max)
  28                 pstate->Max = value;
  29 }
  30
  31 double MaxAggregator::GetResultAndFreeState(AggregatorState *state) const
  32 {
  33         MaxAggregatorState *pstate = EnsureState(&state);
  34         double result = pstate->Max;
  35         delete pstate;
  36
  37         return result;
  38 }