bulkDataNTDDSLoggable.h

Go to the documentation of this file.

#ifndef BULKDATA_NT_DDS_LOGGABLE
#define BULKDATA_NT_DDS_LOGGABLE

/*******************************************************************************
* ALMA - Atacama Large Millimiter Array
* (c) European Southern Observatory, 2011
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
* License as published by the Free Software Foundation; either
* version 2.1 of the License, or (at your option) any later version.
*
* This library is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with this library; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307  USA
*
* "@(#) $Id: bulkDataNTDDSLoggable.h,v 1.4 2012/04/25 12:28:53 bjeram Exp $"
*
* who       when      what
* --------  --------  ----------------------------------------------
* bjeram  2011-04-19  created
*/


#include <loggingLoggable.h>
#include <logging.h>

#define BDNT_LISTENER_USER_ERR(call)                                                                            \
    try { call;                                                                                                                                         \
    }catch(const ACSErr::ACSbaseExImpl &ex){                                                                            \
        UserCallbackErrorCompletion ucb(ex, __FILE__, __LINE__, __FUNCTION__);          \
        ucb.setCall("#call");                                                                                                           \
        ucb.setStreamFlowName(topicName_m.c_str());                                                                     \
        callback_mp->onError(ucb);                                                                                                      \
    }catch(const std::exception &stdex){                                                                                        \
        ACSErrTypeCommon::StdExceptionExImpl ex(__FILE__, __LINE__, __FUNCTION__);  \
        ex.setWhat(stdex.what());                                                                                                       \
        UserCallbackErrorCompletion ucb(ex, __FILE__, __LINE__, __FUNCTION__);          \
        ucb.setCall("#call");                                                                                                           \
        ucb.setStreamFlowName(topicName_m.c_str());                                                                     \
        callback_mp->onError(ucb);                                                                                                      \
    }catch(...){                                                                                                                                        \
        ACSErrTypeCommon::UnknownExImpl ex(__FILE__, __LINE__, __FUNCTION__);           \
        UserCallbackErrorCompletion ucb(ex, __FILE__, __LINE__, __FUNCTION__);          \
        ucb.setCall("#call");                                                                                                           \
        ucb.setStreamFlowName(topicName_m.c_str());                                                                     \
        callback_mp->onError(ucb);                                                                                                      \
    }


class BulkDataNTDDSLoggable
  : public Logging::Loggable
{
public:
  //Constructor
          BulkDataNTDDSLoggable (const std::string &loggerName) :       Logging::Loggable(loggerName){}

  //destructor
  virtual ~BulkDataNTDDSLoggable ();

  void initalizeLogging();

 virtual Logging::Logger::LoggerSmartPtr getLogger ();

  static LoggingProxy *logger_mp; //we need separate logger, because we are in separate thread  ...
  // ... other is one logger for all DDS reader thread
  static unsigned int loggerInitCount_m; // we need to count how many time we call LoggerProxy::init
};

#endif //BULKDATA_NT_DDS_LOGGABLE