fc::dmlog_appender Class Reference

#include <dmlog_appender.hpp>

Inheritance diagram for fc::dmlog_appender:

Collaboration diagram for fc::dmlog_appender:

Classes
struct	config
class	impl

Public Member Functions
	dmlog_appender (const variant &args)
	dmlog_appender (const std::optional< config > &args)
virtual	~dmlog_appender ()
virtual void	initialize (boost::asio::io_service &io_service) override
virtual void	log (const log_message &m) override
Public Member Functions inherited from fc::appender

Additional Inherited Members
Public Types inherited from fc::appender
typedef std::shared_ptr< appender >	ptr

Detailed Description

Specialized appender for deep mind tracer that sends log messages through stdout correctly formatted for latter consumption by deep mind postprocessing tools from dfuse.

Definition at line 12 of file dmlog_appender.hpp.

Constructor & Destructor Documentation

dmlog_appender() [1/2]

fc::dmlog_appender::dmlog_appender ( const variant & args )

explicit

Definition at line 46 of file dmlog_appender.cpp.

   :dmlog_appender(args.as<std::optional<config>>()){}

dmlog_appender() [2/2]

fc::dmlog_appender::dmlog_appender ( const std::optional< config > & args )

explicit

~dmlog_appender()

fc::dmlog_appender::~dmlog_appender ( )

virtual

Definition at line 52 of file dmlog_appender.cpp.

                                   {
      if (my->owns_out)
      {
         std::fclose(my->out);
      }
   }

Member Function Documentation

initialize()

void fc::dmlog_appender::initialize ( boost::asio::io_service & io_service )

overridevirtual

Implements fc::appender.

Definition at line 59 of file dmlog_appender.cpp.

{}

log()

void fc::dmlog_appender::log ( const log_message & m )

overridevirtual

Implements fc::appender.

Definition at line 61 of file dmlog_appender.cpp.

                                                  {
      FILE* out = my->out;
 
      string message = format_string( "DMLOG " + m.get_format() + "\n", m.get_data() );
 
      auto remaining_size = message.size();
      auto message_ptr = message.c_str();
      while (!my->is_stopped && remaining_size) {
         auto written = fwrite(message_ptr, sizeof(char), remaining_size, out);
 
         // EINTR shouldn't happen anymore, but keep this detection, just in case.
         if(written == 0 && errno != EINTR)
         {
            my->is_stopped = true;
         }
 
         if(written != remaining_size)
         {
            fprintf(stderr, "DMLOG FPRINTF_FAILED failed written=%lu remaining=%lu %d %s\n", written, remaining_size, ferror(out), strerror(errno));
            clearerr(out);
         }
 
         if(my->is_stopped)
         {
            fprintf(stderr, "DMLOG FPRINTF_FAILURE_TERMINATED\n");
            // Depending on the error, we might have already gotten a SIGPIPE
            // An extra signal is harmless, though.  Use a process targeted
            // signal (not raise) because the SIGTERM may be blocked in this
            // thread.
            kill(getpid(), SIGTERM);
         }
 
         message_ptr = &message_ptr[written];
         remaining_size -= written;
      }
   }

Here is the call graph for this function:

---

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

• libraries/fc/include/fc/log/dmlog_appender.hpp
• libraries/fc/src/log/dmlog_appender.cpp