rfPhaser.h

Go to the documentation of this file.

#ifndef RF_PHASER_H
#define RF_PHASER_H
#include "phaseInterface.h"
#include "jobSet.h"
#include <thread.h>
#include <eventq.h>
class ResultsDb;
namespace LOCK { class EnergyLocks; }
 
class RfPhaser : public PhaseInterface, public thrlib::Thread
{ public:
    RfPhaser(void);
    virtual void Halt(bool) override;
    
  public:                  // PhaseInterface implementation
    virtual void SetJob(Session &, PhaseJob *) override;
    virtual void StopJob(Session &) override;
    virtual void PauseJob(Session &) override;
    virtual void ResumeJob(Session &) override;
    virtual void SkipCavity(Session &) override;
    virtual void GetState(Session &) override;
    virtual std::vector<std::string> GetCavityNames(void) override;
    virtual void PostProgress(unsigned, const std::string &) override;
    virtual bool Peek(bool = false) override;
    virtual void ApplyCorrections(Session &, const DbIds *) override;
    
  private:
    enum class Cmd_t { C_set, C_stop, C_pause, C_resume, C_skip, C_halt, C_state,
      C_apply };
    
    struct Command
    { 
      Command(Session *client, Cmd_t type) : m_client(client), m_type(type)
      {
      }
      Session *m_client;    
      const Cmd_t m_type;   
    };
    
    struct JobCommand : public Command
    { 
      JobCommand(Session *client, PhaseJob *job) :
        Command(client, Cmd_t::C_set), m_job(job)
      {
      }
      PhaseJob * const m_job;  
    };
    
    struct ApplyCommand : public Command
    { 
      ApplyCommand(Session *client, const DbIds *ids)
        : Command(client, Cmd_t::C_apply), m_ids(ids)
      {
      }
      const DbIds *m_ids;    
    };
    
    virtual void ThreadMain(void) override;
    void MeasurePhaseError(void);
    bool ProcessCommand(Command *);
    std::string RemovalMessage(bool);
    void Handle(std::exception &);
    void PauseMeasurements(PhaseJob *);
    
  private:
    JobSet m_ps;                           
    thrlib::EventQueue<Command *> m_queue; 
};
 
#endif