MessageFacility.h

#ifndef OTSDAQ_CORE_MESSAGEFACILITY_MESSAGEFACILITY_H
#define OTSDAQ_CORE_MESSAGEFACILITY_MESSAGEFACILITY_H
 
#include "otsdaq/Macros/CoutMacros.h"
 
#include <messagefacility/MessageLogger/MessageLogger.h>
#include "artdaq-core/Utilities/configureMessageFacility.hh"
 
namespace ots
{
static bool MESSAGE_FACILITY_INITIALIZED;
 
inline void INIT_MF(const char* name)
{
    if(MESSAGE_FACILITY_INITIALIZED)
        return;
 
    char* logRootString = getenv("OTSDAQ_LOG_ROOT");
    if(logRootString == nullptr)
    {
        __COUT_WARN__ << "WARNING: OTSDAQ_LOG_ROOT environment variable was not set!"
                      << std::endl;
        // exit(0);
    }
    else
        setenv("ARTDAQ_LOG_ROOT", logRootString, 1);
 
    char* logFhiclCode = getenv("OTSDAQ_LOG_FHICL");
    if(logFhiclCode == nullptr)
    {
        __COUT_WARN__ << "WARNING: OTSDAQ_LOG_FHICL environment variable was not set!"
                      << std::endl;
        // exit(0);
    }
    else
    {
        setenv("ARTDAQ_LOG_FHICL", logFhiclCode, 1);
 
        char* userDataString = getenv("USER_DATA");
        if(userDataString == nullptr)
        {
            __SS__ << "ERROR: USER_DATA environment variable was not set!" << std::endl;
            __SS_THROW__;
        }
 
        setenv(
            "DAQINTERFACE_MESSAGEFACILITY_FHICL",  
            (std::string(userDataString) +
             "/MessageFacilityConfigurations/ARTDAQInterfaceMessageFacilityGen.fcl")
                .c_str(),
            1);
 
        __COUT__ << "Configuring message facility with " << logFhiclCode << __E__;
        //display Message Facility fcl settings
        if(TTEST(0))
        {
            FILE*        fp        = fopen(logFhiclCode, "r");
            unsigned int charCount = 0;
            while(fp)
            {
                std::cout << "Message Facility fcl:" << __E__;
                ++charCount;
                char line[100];
                while(fgets(line, 100, fp))
                {
                    std::cout << line;
                    charCount += strlen(line);
                }
                std::cout << __E__;
 
                fclose(fp);
                fp = 0;
 
                if(charCount < 10)
                {
                    std::cout << "Retry - Was file really empty? " << logFhiclCode
                              << __E__;
                    sleep(1);
                    fp = fopen(logFhiclCode, "r");
                }
            }
        }
    }
 
    artdaq::configureMessageFacility(name /*application name*/,
                                     false /*cout display*/,
                                     true /*enable debug messages*/);
 
    artdaq::setMsgFacAppName(name, 0);
 
    MESSAGE_FACILITY_INITIALIZED = true;
 
}  // end INIT_MF()
 
}  // namespace ots
 
#endif