comparison vamp-sdk/hostext/PluginSummarisingAdapter.cpp @ 188:5a6446a2346a

* More work on summarising adapter -- fixes for segmentation &c

 PluginSummarisingAdapter::Impl::getSummaryForOutput(int output,
                                                     SummaryType type,
                                                     AveragingMethod avg)
 {
     if (!m_reduced) {
+        accumulateFinalDurations();
         segment();
         reduce();
         m_reduced = true;
     }
 

 Plugin::FeatureSet
 PluginSummarisingAdapter::Impl::getSummaryForAllOutputs(SummaryType type,
                                                         AveragingMethod avg)
 {
     if (!m_reduced) {
+        accumulateFinalDurations();
         segment();
         reduce();
         m_reduced = true;
     }
 

             std::cerr << "Pushing final duration from diff as " << m_lastTimestamp << " - " << m_prevTimestamps[output] << std::endl;
 
             m_accumulators[output].results[acount - 1].duration =
                 m_lastTimestamp - m_prevTimestamps[output];
         }
+        
+        std::cerr << "so duration for result no " << acount-1 << " is "
+                  << m_accumulators[output].results[acount-1].duration
+                  << std::endl;
     }
 }
 
 void
 PluginSummarisingAdapter::Impl::findSegmentBounds(RealTime t,

 
     start = RealTime::zeroTime;
     end = m_lastTimestamp;
 
     if (i != m_boundaries.end()) {
-
         end = *i;
-
-        if (i != m_boundaries.begin()) {
-            start = *--i;
-        }
+    }
+
+    if (i != m_boundaries.begin()) {
+        start = *--i;
     }
     
     std::cerr << "findSegmentBounds: " << t << " is in segment " << start << " -> " << end << std::endl;
 }
 

     for (OutputAccumulatorMap::iterator i = m_accumulators.begin();
          i != m_accumulators.end(); ++i) {
 
         int output = i->first;
         OutputAccumulator &source = i->second;
+
+        std::cerr << "segment: total results for output " << output << " = "
+                  << source.results.size() << std::endl;
 
         //!!! This is basically nonsense if the results have no values
         //!!! (i.e. their times and counts are the only things of
         //!!! interest) but perhaps it's the user's problem if they
         //!!! ask for segmentation in that case

 }
 
 void
 PluginSummarisingAdapter::Impl::reduce()
 {
-    accumulateFinalDurations();
-
     for (OutputSegmentAccumulatorMap::iterator i =
              m_segmentedAccumulators.begin();
          i != m_segmentedAccumulators.end(); ++i) {
 
         int output = i->first;

             RealTime segmentStart = j->first;
             OutputAccumulator &accumulator = j->second;
 
             int sz = accumulator.results.size();
 
+            std::cerr << "reduce: segment starting at " << segmentStart
+                      << " on output " << output << " has " << sz << " result(s)" << std::endl;
+
             double totalDuration = 0.0;
             //!!! is this right?
             if (sz > 0) {
-                totalDuration = toSec(accumulator.results[sz-1].time +
-                                      accumulator.results[sz-1].duration);
+                std::cerr << "last time = " << accumulator.results[sz-1].time 
+                          << ", duration = " << accumulator.results[sz-1].duration
+                          << std::endl;
+                totalDuration = toSec((accumulator.results[sz-1].time +
+                                       accumulator.results[sz-1].duration) -
+                                      segmentStart);
             }
 
             for (int bin = 0; bin < accumulator.bins; ++bin) {
 
                 // work on all values over time for a single bin

 
                 std::sort(valvec.begin(), valvec.end());
 
                 summary.minimum = valvec[0].value;
                 summary.maximum = valvec[sz-1].value;
+
+                std::cerr << "total duration = " << totalDuration << std::endl;
+
+                std::cerr << "value vector for medians:" << std::endl;
+                for (int k = 0; k < sz; ++k) {
+                    std::cerr << "(" << valvec[k].value << "," << valvec[k].duration << ") ";
+                }
+                std::cerr << std::endl;
 
                 if (sz % 2 == 1) {
                     summary.median = valvec[sz/2].value;
                 } else {
                     summary.median = (valvec[sz/2].value + valvec[sz/2 + 1].value) / 2;