/**
 * @file AtcaIopConfig.h
 * @brief Header file for class AtcaIopConfig
 * @date 19/04/2024
 * @author Andre Neto / Bernardo Carvalho
 *
 * Based on Example:
 *
 *
 * @copyright Copyright 2015 F4E | European Joint Undertaking for ITER and
 * the Development of Fusion Energy ('Fusion for Energy').
 * Licensed under the EUPL, Version 1.1 or - as soon they will be approved
 * by the European Commission - subsequent versions of the EUPL (the "Licence")
 * You may not use this work except in compliance with the Licence.
 * You may obtain a copy of the Licence at: http://ec.europa.eu/idabc/eupl
 *
 * @warning Unless required by applicable law or agreed to in writing, 
 * software distributed under the Licence is distributed on an "AS IS"
 * basis, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
 * or implied. See the Licence permissions and limitations under the Licence.

 * @details This header file contains the declaration of the class AtcaIopConfig
 * with all of its public, protected and private members. It may also include
 * definitions for inline methods which need to be visible to the compiler.
 */

#ifndef ATCA_IOP_DAC_H
#define ATCA_IOP_DAC_H

/*---------------------------------------------------------------------------*/
/*                        Standard header includes                           */
/*-------DTYP--------------------------------------------------------------------*/

/*---------------------------------------------------------------------------*/
/*                        Project header includes                            */
/*---------------------------------------------------------------------------*/
#include "AdvancedErrorManagement.h"
#include "CLASSMETHODREGISTER.h"
#include "DataSourceI.h"
//#include "EventSem.h"
//#include "EmbeddedServiceMethodBinderI.h"
//#include "SingleThreadService.h"
#include "MessageI.h"
#include "RegisteredMethodsMessageFilter.h"

/*---------------------------------------------------------------------------*/
/*                           Class declaration                               */
/*---------------------------------------------------------------------------*/
namespace MARTe {

    /**
     * The number of signals 
     */

    //const uint32 ATCA_IOP_N_DACs = 2u;
    const uint32 ATCA_IOP_EOWO_N_SIGNALS = 2u;
    //const uint32 ATCA_IOP_MAX_DAC_CHANNELS = 16u;
    const uint32 ATCA_IOP_MAX_ADC_CHANNELS = 16u;

/**
 * @brief A DataSource which provides an analogue output interface to the ATCA IOP  boards.
 * @details The configuration syntax is (names are only given as an example):
 *
 * <pre>
 * +AtcaIopConfig_2 = {
 *     Class = AtcaIop::AtcaIopConfig
 *     DeviceName = "/dev/atca_v6" //Mandatory
 *     BoardId = 0 //Mandatory
 *     Signals = {
 *         EO = {
 *             Type = int32 //Mandatory. Only type that is supported.
 *         }
 *         WO = {
 *             Type = float32 //Mandatory. Only type that is supported.
 *         }
 *     }
 * }
 * </pre>
 * Note that at least one of the GAMs writing to this DataSource must have set one of the signals with Trigger=1 (which forces the writing of all the signals to the DAC).
 */
    class AtcaIopConfig: public DataSourceI, public MessageI {
        public:
            CLASS_REGISTER_DECLARATION()
                /**
                 * @brief Default constructor
                 * @post
                 *   Counter = 0
                 *   Time = 0
                 */
                AtcaIopConfig    ();

            /**
             * @brief Destructor. Stops the EmbeddedThread.
             */
            virtual ~AtcaIopConfig();

            /**
             * @brief See DataSourceI::AllocateMemory.
             *  * @return true.
             */
            virtual bool AllocateMemory();

            /**
              gg* @brief See DataSourceI::GetNumberOfMemoryBuffers.
             * @return 1.
             */
            virtual uint32 GetNumberOfMemoryBuffers();

            /**
             * @brief See DataSourceI::GetSignalMemoryBuffer.
             */
            virtual bool GetSignalMemoryBuffer(const uint32 signalIdx,
                    const uint32 bufferIdx,
                    void *&signalAddress);


            /**
             * @brief See DataSourceI::GetNumberOfMemoryBuffers.
             * @details Only OutputSignals are supported.
             * @return MemoryMapSynchronisedOutputBroker if Trigger == 1 for any of the signals, MemoryMapOutputBroker otherwise.
             */
            virtual const char8 *GetBrokerName(StructuredDataI &data, const SignalDirection direction);

            /**
             * @brief See DataSourceI::GetInputBrokers.
             * @return false.
             */
            virtual bool GetInputBrokers(ReferenceContainer &inputBrokers,
                    const char8* const functionName,
                    void * const gamMemPtr);

            /**
             * @brief See DataSourceI::GetOutputBrokers.
             * @details If the functionName is one of the functions which requested a Trigger,
             * it adds a MemoryMapSynchronisedOutputBroker instance to the outputBrokers,
             * otherwise it adds a MemoryMapOutputBroker instance to the outputBrokers.
             * @param[out] outputBrokers where the BrokerI instances have to be added to.
             * @param[in] functionName name of the function being queried.
             * @param[in] gamMemPtr the GAM memory where the signals will be read from.
             * @return true if the outputBrokers can be successfully configured.
             */
            virtual bool GetOutputBrokers(ReferenceContainer &outputBrokers,
                    const char8* const functionName,
                    void * const gamMemPtr);


            /**
             * @brief See StatefulI::PrepareNextState.
             * @details NOOP.
             * @return true.
             */
            virtual bool PrepareNextState(const char8 * const currentStateName,
                    const char8 * const nextStateName);


            /**
             * @brief Loads and verifies the configuration parameters detailed in the class description.
             * @return true if all the mandatory parameters are correctly specified and if the specified optional parameters have valid values.
            uint32 synchCounter;
             */

            virtual bool Initialise(StructuredDataI & data);


            /**
             * @brief Final verification of all the parameters and setup of the board configuration.
             * @details This method verifies that all the parameters (e.g. number of samples) requested by the GAMs interacting with this DataSource
             *  are valid and consistent with the board parameters set during the initialisation phase.
             * In particular the following conditions shall be met:
             * - At least one triggering signal was requested by a GAM (with the property Trigger = 1)
             * - All the DAC channels have type float32.
            uint32 synchCounter;
             * - The number of samples of all the DAC channels is exactly one.
             * @return true if all the parameters are valid and consistent with the board parameters and if the board can be successfully configured with
             *  these parameters.
             */
            virtual bool SetConfiguredDatabase(StructuredDataI & data);


            /**
             * @details Writes the value of all the DAC channels to the board.
             * @return true if the writing of all the channels is successful.
             */
            virtual bool Synchronise();

             /**
              * @brief Set flag to write Eo, Wo Synchronisly
              * @details This method 
              * It can be called within a 
              * MARTe message.
              */
            //ErrorManagement::ErrorType Reset();
            ErrorManagement::ErrorType WriteEoWo();


        private:
            /**
             * The board device name
             */
            StreamString deviceName;
            /**
             * The board identifier
             */
            uint32 boardId;

            /**
             * The board file descriptor
             */
            int32 devFileDescriptor;

            uint32 synchCounter;
            /**
             * DAC values
             */
//            int32 dacValues[ATCA_IOP_N_DACs];

            /**
             * EO values Signal
             */
            int32 *eoValues;
            
            /**
             * WO valuesa Signal
             */
            float32 *woValues;

            bool eoWriteFlag;

            /**
             * The signal memory
             */
//            float32 *channelsMemory;


            /**
             * Filter to receive the RPC which allows to change the...
             */
            ReferenceT<RegisteredMethodsMessageFilter> filter;

            /**
             * True if at least one trigger was set.
             */
            bool triggerSet;
            
            bool IoWriteEoWo();
            //int32 SetDacReg(uint32 channel, float32 val) const;

    };
}

/*---------------------------------------------------------------------------*/
/*                        Inline method definitions                          */
/*---------------------------------------------------------------------------*/

#endif /* ATCA_IOP_DAC_H */

//  vim: syntax=cpp ts=4 sw=4 sts=4 sr et