JobResultAggregator.h

Go to the documentation of this file.

/*
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 3 of the License, or
 * (at your option) any later version.
 *
 * Written (W) 2013 Soumyajit De
 */

#ifndef JOB_RESULT_AGGREGATOR_H_
#define JOB_RESULT_AGGREGATOR_H_

#include <shogun/lib/config.h>
#include <shogun/base/SGObject.h>
#include <shogun/lib/computation/jobresult/JobResult.h>
#include <shogun/base/Parameter.h>

namespace shogun
{

class CJobResultAggregator : public CSGObject
{
public:
    CJobResultAggregator()
    : CSGObject()
    {
        init();

        SG_GCDEBUG("%s created (%p)\n", this->get_name(), this)
    }

    virtual ~CJobResultAggregator()
    {
        SG_UNREF(m_result);

        SG_GCDEBUG("%s destroyed (%p)\n", this->get_name(), this)
    }

    virtual void submit_result(CJobResult* result) = 0;

    virtual void finalize() = 0;

    CJobResult* get_final_result() const
    {
        return m_result;
    }

    virtual const char* get_name() const
    {
        return "JobResultAggregator";
    }
protected:
    CJobResult* m_result;

private:
    void init()
    {
        m_result=NULL;

        SG_ADD((CSGObject**)&m_result, "final_result",
            "Aggregation of computation job results", MS_NOT_AVAILABLE);
    }
};

}

#endif // JOB_RESULT_AGGREGATOR_H_