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

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