mas01cr@498: template <class T> class DBAccumulator : public Accumulator {
mas01cr@498: public:
mas01cr@498:   DBAccumulator(unsigned int pointNN);
mas01cr@498:   ~DBAccumulator();
mas01cr@498:   void add_point(adb_result_t *r);
mas01cr@498:   adb_query_results_t *get_points();
mas01cr@498: private:
mas01cr@498:   unsigned int pointNN;
mas01cr@498:   std::priority_queue< adb_result_t, std::vector<adb_result_t>, T > *queue;
mas01cr@498: };
mas01cr@498: 
mas01cr@498: template <class T> DBAccumulator<T>::DBAccumulator(unsigned int pointNN)
mas01cr@610:   : pointNN(pointNN), queue(0) {
mas01cr@498:   queue = new std::priority_queue< adb_result_t, std::vector<adb_result_t>, T>;
mas01cr@498: }
mas01cr@498: 
mas01cr@498: template <class T> DBAccumulator<T>::~DBAccumulator() {
mas01cr@498:   if(queue) {
mas01cr@498:     delete queue;
mas01cr@498:   }
mas01cr@498: }
mas01cr@498: 
mas01cr@498: template <class T> void DBAccumulator<T>::add_point(adb_result_t *r) {
mas01cr@498:   if(!isnan(r->dist)) {
mas01cr@610:     queue->push(*r);
mas01cr@610:     if(queue->size() > pointNN) {
mas01cr@610:       queue->pop();
mas01cr@498:     }
mas01cr@498:   }
mas01cr@498: }
mas01cr@498: 
mas01cr@498: template <class T> adb_query_results_t *DBAccumulator<T>::get_points() {
mas01cr@498:   unsigned int size = queue->size();
mas01cr@498:   adb_query_results_t *r = (adb_query_results_t *) malloc(sizeof(adb_query_results_t));
mas01cr@498:   adb_result_t *rs = (adb_result_t *) calloc(size, sizeof(adb_result_t));
mas01cr@498:   r->nresults = size;
mas01cr@498:   r->results = rs;
mas01cr@498: 
mas01cr@498:   for(unsigned int k = 0; k < size; k++) {
mas01cr@498:     rs[k] = queue->top();
mas01cr@498:     queue->pop();
mas01cr@498:   }
mas01cr@498:   return r;
mas01cr@498: }