gvtmanager.h

#ifndef _GVTMANAGER_H
#define _GVTMANAGER_H

#include "gvtmanager.decl.h"

extern CProxy_GVTManager gvt_manager_proxy;

class RemoteEvent;
class DistributedScheduler;

class Trigger;
typedef std::unique_ptr<Trigger> TriggerPtr;

class GVTManager : public CBase_GVTManager {
  protected:
    Time curr_gvt, prev_gvt;

    bool active, continuous;

    DistributedScheduler* scheduler;

    std::string gvt_name;

    TriggerPtr lb_trigger; 
  public:
    GVTManager();

    // TODO: Initialize?
    virtual void finalize() {}

    virtual void gvt_begin() { CkAbort("Cannot call GVTManager::begin()\n"); }

    Time current_gvt() const { return curr_gvt; }
    Time previous_gvt() const { return prev_gvt; }

    bool is_active() const { return active; }
    bool is_continuous() const { return continuous; }

    virtual void groups_created();

    virtual void consume(RemoteEvent* e) {}
    virtual bool produce(RemoteEvent* e) { return true; }
};

#endif