dae.h

Go to the documentation of this file.

// dae.h : Declaration of the Cdae

#pragma once
#include "resource.h"       // main symbols



#include "isisicp_i.h"
#include "_IdaeEvents_CP.h"


class DAEstatus;
class ISISinstrumentControl;

using namespace ATL;


// Cdae

class ATL_NO_VTABLE Cdae :
        public CComObjectRootEx<CComMultiThreadModel>,
        public CComCoClass<Cdae, &CLSID_dae>,
        public ISupportErrorInfo,
        public IConnectionPointContainerImpl<Cdae>,
        public CProxy_IdaeEvents<Cdae>,
        public IDispatchImpl<Idae, &IID_Idae, &LIBID_isisicpLib, /*wMajor =*/ 1, /*wMinor =*/ 0>
{
public:
        Cdae()
        {
        }

DECLARE_REGISTRY_RESOURCEID(IDR_DAE)

BEGIN_COM_MAP(Cdae)
        COM_INTERFACE_ENTRY(Idae)
        COM_INTERFACE_ENTRY(IDispatch)
        COM_INTERFACE_ENTRY(ISupportErrorInfo)
        COM_INTERFACE_ENTRY(IConnectionPointContainer)
END_COM_MAP()

BEGIN_CONNECTION_POINT_MAP(Cdae)
        CONNECTION_POINT_ENTRY(__uuidof(_IdaeEvents))
END_CONNECTION_POINT_MAP()
// ISupportsErrorInfo
        STDMETHOD(InterfaceSupportsErrorInfo)(REFIID riid);


        DECLARE_PROTECT_FINAL_CONSTRUCT()

        HRESULT FinalConstruct()
        {
                if (m_critical == NULL)
                {
                        m_critical = new CRITICAL_SECTION;
                        InitializeCriticalSection(m_critical);
                }
                registerICPCallbacks();
                return S_OK;
        }

        void FinalRelease()
        {
// This is now shared, so we cannot remove it without reference counting
//              if (m_critical != NULL)
//              {
//                      DeleteCriticalSection(m_critical);
//                      delete m_critical;
//                      m_critical = NULL;
//              }
                unregisterICPCallbacks();
        }

        static CRITICAL_SECTION* m_critical;
        std::list<boost::signals2::connection> m_connection;

protected:

        template <typename T> HRESULT callICP(BSTR* messages, T& result, boost::function<T(ISISinstrumentControl*, DAEstatus&)> func);
        template <typename T> HRESULT callICP(BSTR* messages, boost::function<T(ISISinstrumentControl*, DAEstatus&)> func);

        HRESULT makeResult(DAEstatus& status, BSTR* messages, bool force_success_result = false);
        int getValueMain(ISISinstrumentControl* the_icp, const char* item_name, VARIANT* result, DAEstatus& status);
        int getArrayValueMain(ISISinstrumentControl* the_icp, const char* item_name, long args[], int nargs, VARIANT* result, DAEstatus& status);
        int reallocBSTR(BSTR* bstr, const char* str);

        typedef int (ISISinstrumentControl::*xml_get_func_t)(const std::string& xml_in, std::string& xml_out, DAEstatus& status);
        typedef int (ISISinstrumentControl::*xml_set_func_t)(const std::string& xml_in, DAEstatus& status);
        HRESULT getSettings(BSTR xml_in, BSTR* xml_out, BSTR* messages, xml_get_func_t func);
        HRESULT updateSettings(BSTR xml_in, BSTR* messages, xml_set_func_t func);

        typedef int (ISISinstrumentControl::*spec_int_func_t)(long n, const long spec_no[], long period, const float t_low[], const float t_high[], long integral[], long max_val[], DAEstatus& status);
        HRESULT getSpectraIntegralHelper(spec_int_func_t func, VARIANT spectrum_numbers, LONG period, VARIANT time_low, VARIANT time_high, VARIANT* counts, BSTR* messages);

public:

        void registerICPCallbacks();
        void unregisterICPCallbacks();


        static BSTR makeBSTR(const char* str);

        STDMETHOD(updateStatusXML)(BSTR* cluster_xml, BSTR* messages);
        STDMETHOD(beginRun)(BSTR* messages);
        STDMETHOD(endRun)(BSTR* messages);
        STDMETHOD(pauseRun)(BSTR* messages);
        STDMETHOD(resumeRun)(BSTR* messages);
        STDMETHOD(saveRun)(BSTR* messages);
        STDMETHOD(abortRun)(BSTR* messages);
        STDMETHOD(startSEWait)(BSTR* messages);
        STDMETHOD(endSEWait)(BSTR* messages);
        STDMETHOD(getSpectrum)(LONG spectrum_number, LONG period, VARIANT* time_channels, VARIANT* signal, LONG as_histogram, LONG as_distribution, LONG* sum, BSTR* messages);
        STDMETHOD(changeTCB)(BSTR tcb_xml, BSTR* messages);
        STDMETHOD(changeDAEsettings)(BSTR dae_xml, BSTR* messages);
        STDMETHOD(getSpectrumIntegral)(LONG spectrum_number, LONG period, FLOAT time_low, FLOAT time_high, LONG* counts, BSTR* messages);
        STDMETHOD(getSpectraIntegral)(VARIANT spectrum_numbers, LONG period, VARIANT time_low, VARIANT time_high, VARIANT* counts, BSTR* messages);
        STDMETHOD(getsect)(LONG start, LONG length, VARIANT* values, BSTR* messages);
        STDMETHOD(rio)(LONG address, LONG* value, BSTR* messages);
        STDMETHOD(getValue)(BSTR name, BSTR* messages, VARIANT* result);
        STDMETHOD(getRawFramesTotal)(BSTR* messages, LONG* value);
        STDMETHOD(getGoodFramesTotal)(BSTR* messages, LONG* value);
        STDMETHOD(getGoodUAmpH)(BSTR* messages, DOUBLE* value);
        STDMETHOD(getSpectraSum)(LONG period, LONG first_spec, LONG num_spec, LONG spec_type, DOUBLE time_low, DOUBLE time_high, VARIANT* sums, VARIANT* max_vals, VARIANT* spec_nums, BSTR* messages);
        STDMETHOD(changeSample)(BSTR sample_xml, BSTR* messages);
        STDMETHOD(changeUser)(BSTR user_xml, BSTR* messages);
        STDMETHOD(changeHardwarePeriods)(BSTR periods_xml, BSTR* messages);
        STDMETHOD(changePeriod)(LONG period_number, BSTR* messages);
        STDMETHOD(dumpDebugInfo)(BSTR* messages);
        STDMETHOD(VMEWriteValue)(ULONG card_id, ULONG card_address, ULONG word_size, ULONG value, ULONG mode, BSTR* messages);
        STDMETHOD(VMEReadValue)(ULONG card_id, ULONG card_address, ULONG word_size, ULONG* value, BSTR* messages);
        STDMETHOD(sumAllSpectra)(LONG* counts, LONG* bin0_counts, BSTR* messages);
        STDMETHOD(sumAllHistogramMemory)(LONG* counts, BSTR* messages);
        STDMETHOD(VMEReadArray)(ULONG card_id, ULONG card_address, VARIANT* values, ULONG num_values, BSTR* messages);
        STDMETHOD(VMEWriteArray)(ULONG card_id, ULONG card_address, VARIANT values, BSTR* messages);
        STDMETHOD(VMEReadValuesToString)(ULONG card_id, ULONG card_address, ULONG word_size, ULONG num_values, BSTR* values, BSTR* messages);
        STDMETHOD(refreshCachedValues)(BSTR* messages);
        STDMETHOD(setOptions)(BSTR options_xml, BSTR* messages);
        STDMETHOD(getOptions)(BSTR* options_xml, BSTR* messages);
        STDMETHOD(getArrayValue)(BSTR name, VARIANT arg, BSTR* messages, VARIANT* result);
        STDMETHOD(updateCRPT)(BSTR* messages);
        STDMETHOD(storeCRPT)(BSTR* messages);
        STDMETHOD(setICPValueLong)(BSTR name, LONG value, BSTR* messages);
        STDMETHOD(notifyICP)(LONG event_id, BSTR param, BSTR* messages);
        STDMETHOD(setBlocksTable)(VARIANT table, BSTR* messages);
        STDMETHOD(setSampleParameters)(VARIANT table, BSTR* messages);
        STDMETHOD(setBeamlineParameters)(VARIANT table, BSTR* messages);
        STDMETHOD(setUserParameters)(LONG rbno, VARIANT table, BSTR* messages);
        STDMETHOD(areYouThere)(void);
        STDMETHOD(changeUpdateSettings)(BSTR update_xml, BSTR* messages);
        STDMETHOD(getNPRatio)(FLOAT* current, FLOAT* average, BSTR* messages);
        STDMETHOD(getTotalCounts)(BSTR* messages, LONG* counts);
        STDMETHOD(getMEvents)(BSTR* messages, DOUBLE* mevents);
        STDMETHOD(getCurrentPeriodNumber)(LONG* period, LONG* daq_period, BSTR* messages);
        STDMETHOD(snapshotCRPT)(BSTR filename, LONG do_update, LONG do_pause, BSTR* messages);
        STDMETHOD(changePeriodWhileRunning)(LONG period, LONG pause_first, BSTR* messages);
        STDMETHOD(getDAEsettings)(BSTR dae_xml_in, BSTR* dae_xml_out, BSTR* messages);
        STDMETHOD(getHardwarePeriods)(BSTR periods_xml_in, BSTR* periods_xml_out, BSTR* messages);
        STDMETHOD(getTCB)(BSTR tcb_xml_in, BSTR* tcb_xml_out, BSTR* messages);
        STDMETHOD(getUpdateSettings)(BSTR update_xml_in, BSTR* update_xml_out, BSTR* messages);
        STDMETHOD(changeNumberOfSoftwarePeriods)(LONG nperiod, BSTR* messages);
        STDMETHOD(getRunState)(BSTR* messages, LONG* state);
        STDMETHOD(beginRunEx)(LONG options, LONG period, BSTR* messages);
        STDMETHOD(fillWithTestPattern)(ULONG pattern, BSTR* messages);
        STDMETHOD(getVetoStatus)(BSTR* veto_status, BSTR* messages);
        STDMETHOD(loadDAEWithData)(BSTR file_name, LONG options, BSTR* messages);
        STDMETHOD(setVeto)(BSTR name, LONG enable, BSTR* messages);
        STDMETHOD(checkTestPattern)(ULONG pattern, BSTR* messages);
        STDMETHOD(getRunNumber)(BSTR* messages, LONG* run_number);
        STDMETHOD(changeMonitoringSettings)(BSTR monitor_xml, BSTR* messages);
        STDMETHOD(getMonitoringSettings)(BSTR monitor_xml_in, BSTR* monitor_xml_out, BSTR* messages);
        STDMETHOD(getStatusMessages)(LONG stream, VARIANT* messages);
        STDMETHOD(getGoodFramesPeriod)(BSTR* messages, LONG* value);
        STDMETHOD(getGoodUAmpHPeriod)(BSTR* messages, DOUBLE* value);
        STDMETHOD(getFramesAllPeriods)(VARIANT* good_frames, VARIANT* raw_frames, BSTR* messages);
        STDMETHOD(getUAmpHAllPeriods)(VARIANT* good_uamph, VARIANT* raw_uamph, BSTR* messages);
        STDMETHOD(getMEventsPeriod)(LONG period, BSTR* messages, DOUBLE* mevents);
        STDMETHOD(updateCRPTSpectra)(LONG period, LONG spec_start, LONG nspec, BSTR* messages);
        STDMETHOD(getCRPTSpectraIntegral)(VARIANT spectrum_numbers, LONG period, VARIANT time_low, VARIANT time_high, VARIANT* counts, BSTR* messages);
        STDMETHOD(quit)(BSTR* messages);
        STDMETHOD(requestEndRunAfterNextSequenceCompletes)(BSTR* messages);
        STDMETHOD(isFinalSequenceComplete)(BSTR* messages, LONG* complete);
        STDMETHOD(getSpectrumNumbersForTR)(LONG time_regime, LONG* spec_min, LONG* spec_max, BSTR* messages);
        STDMETHOD(getSpectraIntegral2)(LONG spec_start, LONG nspectra, LONG period, FLOAT time_low, FLOAT time_high, VARIANT* counts, BSTR* messages);
    STDMETHOD(getNumberOfPeriods)(BSTR* messages, LONG* nperiod);
        STDMETHOD(updateStatusXML2)(BSTR status_xml_in, BSTR* status_xml_out, BSTR* messages);
};

OBJECT_ENTRY_AUTO(__uuidof(dae), Cdae)