dbe::interface::messenger::qt Class Reference

#include <messenger.hpp>

Inheritance diagram for dbe::interface::messenger::qt:

Collaboration diagram for dbe::interface::messenger::qt:

Public Types
typedef std::string	t_str
Public Types inherited from dbe::interface::messenger::msglevels
typedef std::string	t_str
typedef std::vector< t_str >	t_levels

Static Public Member Functions
static HAS_POST post_ret_type	post (t_str const &, t_str const &)
static std::unique_ptr< batch_guard >	batchmode ()

Private Types
typedef std::unordered_multiset< t_str >	t_message_bucket
typedef std::array< t_message_bucket, static_cast< int >(messages::sizeme) >	t_batches

Private Member Functions
	qt ()=delete
	qt (qt const &)=delete
qt	operator= (qt const &)=delete

Static Private Member Functions
static post_ret_type	direct_post (t_str const &m, t_str const &l)
static post_ret_type	merge_post (t_str const &m, t_str const &l)
static void	purge ()

Static Private Attributes
static std::mutex	m_block
static std::atomic< bool >	m_batch_mode
static t_batches	m_batches

Friends
class	batch_guard

Additional Inherited Members
Static Public Attributes inherited from dbe::interface::messenger::msglevels
static t_str const	debug = "DEBUG"
static t_str const	info = "INFO"
static t_str const	note = "NOTE"
static t_str const	warn = "WARN"
static t_str const	error = "ERROR"
static t_str const	fail = "FAIL"
static t_levels const	all_levels = {debug, info, note, warn, error, fail}

Detailed Description

Messenger handles posting of messages and delegates them to the main window according to their level to be displayed as needed

Definition at line 179 of file messenger.hpp.

Member Typedef Documentation

t_batches

typedef std::array<t_message_bucket, static_cast<int>( messages::sizeme ) > dbe::interface::messenger::qt::t_batches

private

Definition at line 223 of file messenger.hpp.

t_message_bucket

typedef std::unordered_multiset<t_str> dbe::interface::messenger::qt::t_message_bucket

private

Definition at line 222 of file messenger.hpp.

t_str

typedef std::string dbe::interface::messenger::qt::t_str

Definition at line 184 of file messenger.hpp.

Constructor & Destructor Documentation

qt() [1/2]

dbe::interface::messenger::qt::qt ( )

privatedelete

qt() [2/2]

dbe::interface::messenger::qt::qt ( qt const & )

privatedelete

Member Function Documentation

batchmode()

std::unique_ptr< batch_guard > dbe::interface::messenger::qt::batchmode ( )

static

Set returns a batch_guard object that sets m_batch_mode, which resets it batch object when it is destroyed.

Returns

a batch_guard object bound to this

Definition at line 162 of file messenger.cpp.

{
  return std::unique_ptr<batch_guard> ( new batch_guard() );
}

direct_post()

qt::post_ret_type dbe::interface::messenger::qt::direct_post ( t_str const & m, t_str const & l )

staticprivate

Definition at line 92 of file messenger.cpp.

{
  if ( warn == l )
  {
    TLOG_DEBUG(0) <<  static_cast<int> ( messages::WARN ) <<  m ;
    messenger_proxy::ref().warn ( titles[warn], m );
  }
  else if ( error == l )
  {
    TLOG_DEBUG(0) << static_cast<int> ( messages::ERROR ) << m ;
    messenger_proxy::ref().error ( titles[error], m );
  }
  else if ( info == l )
  {
    TLOG_DEBUG(0) << static_cast<int> ( messages::INFO ) << m ;
    messenger_proxy::ref().info ( titles[info], m );
  }
  else if ( fail == l )
  {
    TLOG_DEBUG(0) << static_cast<int> ( messages::FAIL ) << m ;
    messenger_proxy::ref().fail ( titles[fail], m );
  }
  else if ( note == l )
  {
    TLOG_DEBUG(0) << static_cast<int> ( messages::NOTE ) << m ;
    messenger_proxy::ref().fail ( titles[note], m );
  }
  else if ( debug == l )
  {
    TLOG_DEBUG(0) << static_cast<int> ( messages::DEBUG ) << m ;
    messenger_proxy::ref().fail ( titles[debug], m );
  }
}

merge_post()

qt::post_ret_type dbe::interface::messenger::qt::merge_post ( t_str const & m, t_str const & l )

staticprivate

Definition at line 128 of file messenger.cpp.

{
  auto codeit = codes.find ( l );
  assert ( codeit != codes.end() );
  m_batches[static_cast<int> ( codeit->second )].insert ( m );
}

operator=()

qt dbe::interface::messenger::qt::operator= ( qt const & )

privatedelete

post()

qt::post_ret_type dbe::interface::messenger::qt::post ( t_str const & m, t_str const & l )

static

This method provides posting facilities for messages

Parameters

the	level of the message to be treated
A	string message to be treatead

Returns

post_ret_type is void

Definition at line 76 of file messenger.cpp.

{
  std::lock_guard<std::mutex> lock ( m_block );
 
  if ( m_batch_mode )
  {
    merge_post ( m, l );
  }
  else
  {
    direct_post ( m, l );
  }
}

purge()

void dbe::interface::messenger::qt::purge ( )

staticprivate

Takes all messages and forms a message for each groups, that is then resent for direct_post

Definition at line 137 of file messenger.cpp.

{
  for ( auto clevel = m_batches.begin(); clevel != m_batches.end(); ++clevel )
  {
    if ( not clevel->empty() )
    {
        t_str merged ( "Summary of messages during batch mode" );
 
        for(auto it = clevel->begin(); it != clevel->end(); ) {
            auto cnt = clevel->count(*it);
 
            t_str cmessage = *it;
            merged += t_str ( "\n\n" ) + cmessage + t_str ( "\n\n #Occurances=" ) + std::to_string(cnt);
 
            std::advance(it, cnt);
        }
 
        direct_post ( merged, levels[static_cast<messages> ( clevel - m_batches.begin() )] );
        clevel->clear();
    }
  }
}

Friends And Related Symbol Documentation

batch_guard

friend class batch_guard

friend

Definition at line 182 of file messenger.hpp.

Member Data Documentation

m_batch_mode

std::atomic< bool > dbe::interface::messenger::qt::m_batch_mode

staticprivate

Definition at line 220 of file messenger.hpp.

m_batches

qt::t_batches dbe::interface::messenger::qt::m_batches

staticprivate

Definition at line 224 of file messenger.hpp.

m_block

std::mutex dbe::interface::messenger::qt::m_block

staticprivate

Definition at line 219 of file messenger.hpp.

---

The documentation for this class was generated from the following files:

• /github/workspace/dunedaq/sourcecode/dbe/include/dbe/messenger.hpp
• /github/workspace/dunedaq/sourcecode/dbe/src/internal/messenger.cpp