damaris-backends/machines/magnexgrad_backend_dds.cpp

/* **************************************************************************

 Author: Achim Gaedke
 Created: June 2004

 ****************************************************************************/
#include <unistd.h>
#include "machines/hardware.h"
#include "core/core.h"
#include "drivers/Eurotherm-2000Series/Eurotherm-2000Series.h"
#include "drivers/PTS-Synthesizer/PTS.h"
#include "drivers/Spectrum-MI40xxSeries/Spectrum-MI40xxSeries.h"
#include "drivers/SpinCore-PulseBlasterDDSIII/SpinCore-PulseBlasterDDSIII.h"

/**
 \defgroup magnexgradmachine Magnex Static Gradient NMR Spectrometer
 \ingroup machines
 Uses Spincore Pulseblaster 24 Bit and Spectrum MI4021 together with PTS phase and frequency cable driver
 Also implements Eurotherm temperature control

 \par Starting the hardware
 Switch on the amplifier
 @{
 */

/**
 line 0 for gate
 line 1 for pulse
 line 2 for trigger
 line 3 free
 line 9 for syncronization
 */
class magnexgrad_hardware: public hardware
{

    SpectrumMI40xxSeries* my_adc;
    SpinCorePulseBlasterDDSIII* my_dds;
public:
    magnexgrad_hardware()
    {
        ttlout trigger;
        trigger.id = 0;
        trigger.ttls = 1 << 2; /* line 2 */
        my_adc = new SpectrumMI40xxSeries(trigger, 50); // 50 Ohm termination
        the_adc = my_adc;
        my_dds = new SpinCorePulseBlasterDDSIII(0, 1e8, 1 << 9); //sync line on bit 17
        the_pg = my_dds;
        //PTS* my_pts=new PTS_latched(0);
        //the_fg=my_pts;
        the_tc = NULL; //new Eurotherm2000Series("/dev/ttyS0",2,0x0);

        //configurable_devices["T"]=the_tc;
    }

    /**
     print out a temperature line
     */
    virtual result* experiment(const state& exp)
    {
        result* r = NULL;
        for (size_t tries = 0; r == NULL && core::term_signal == 0 && tries < 102; ++tries)
        {
            state* work_copy = exp.copy_flat();
            if (work_copy == NULL)
                return new error_result(1, "could create work copy of experiment sequence");
            try
            {
                if (the_adc != NULL)
                    the_adc->set_daq(*work_copy);
                // the pulse generator is necessary
                my_dds->run_pulse_program_w_sync(*work_copy, my_adc->get_sample_clock_frequency());
                // wait for pulse generator
                the_pg->wait_till_end();
                // after that, the result must be available
                if (the_adc != NULL)
                    r = the_adc->get_samples();
                else
                    r = new adc_result(1, 0, NULL);
            }
            catch (const RecoverableException &e)
            {
                r = new error_result(1, e.what());
            }
            delete work_copy;
            if (core::quit_signal != 0)
                break;
        }

        /**
         make a timestamp
         */
        time_t timestamp;
        time(&timestamp);
        tm timestamp_broken;
        localtime_r(&timestamp, &timestamp_broken);
        char timestamp_string[254];
        strftime(timestamp_string, 254, "%F %T", &timestamp_broken);
        timeval exact_time;
        gettimeofday(&exact_time, NULL);

        if (the_tc != NULL)
        {
            try
            {
                double temp = the_tc->get_temperature();
                fprintf(stdout, "%s.%03ld temperature=%f\n", timestamp_string, exact_time.tv_usec / 1000, temp);
            }
            catch (const Eurotherm2000Series_error& e)
            {
                fprintf(stdout, "%s.%03ld temperature=0.0 (error %s)\n", timestamp_string, exact_time.tv_usec / 1000, e.what());
            }
            fflush(stdout);
        }
        return r;
    }

    virtual ~magnexgrad_hardware()
    {
        if (the_adc != NULL)
            delete the_adc;
        if (the_pg != NULL)
            delete the_pg;
        if (the_fg != NULL)
            delete the_fg;
        if (the_tc != NULL)
            delete the_tc;
    }

};

/**
 \brief brings standard core together with the Mobile NMR hardware
 */
class magnexgrad_core: public core
{
    std::string the_name;
public:
    magnexgrad_core(const core_config& conf) :
        core(conf)
    {
        the_hardware = new magnexgrad_hardware();
        the_name = "magnexgrad";
    }
    virtual const std::string& core_name() const
    {
        return the_name;
    }
};

/**
 @}
 */

int main(int argc, const char** argv)
{
    int return_result = 0;
    // renice and strip of suid rights

    if (nice(-10) == -1)
    {
        fprintf(stderr, "warning: could not increase priority (no setuid?)\n");
    }

    if (getuid() != geteuid())
    {
        if (setuid(getuid()) != 0)
        {
            fprintf(stderr, "warning: could not switch back to uid=%d\n", getuid());
        }
    }
    try
    {
        core_config my_conf(argv, argc);
        // setup input and output
        magnexgrad_core my_core(my_conf);
        // start core application
        my_core.run();
    }
    catch (const DamarisException& e)
    {
        fprintf(stderr, "%s\n", e.what());
        return_result = 1;
    }
    return return_result;
}