18 #include <zypp-core/base/Logger.h> 19 #include <zypp-core/base/LogControl.h> 20 #include <zypp-core/base/ProfilingFormater.h> 21 #include <zypp-core/base/String.h> 22 #include <zypp-core/Date.h> 23 #include <zypp-core/TriBool.h> 24 #include <zypp-core/AutoDispose.h> 26 #include <zypp-core/zyppng/io/Socket> 27 #include <zypp-core/zyppng/io/SockAddr> 28 #include <zypp-core/zyppng/base/EventLoop> 29 #include <zypp-core/zyppng/base/EventDispatcher> 30 #include <zypp-core/zyppng/base/Timer> 31 #include <zypp-core/zyppng/base/private/linuxhelpers_p.h> 32 #include <zypp-core/zyppng/thread/Wakeup> 33 #include <zypp-core/zyppng/base/private/threaddata_p.h> 34 #include <zypp-core/zyppng/base/SocketNotifier> 43 #include <sys/types.h> 70 std::this_thread::yield();
109 if (
_thread.get_id() != std::this_thread::get_id() )
128 _thread = std::thread( [
this] () {
136 zyppng::blockSignalsForCurrentThread( { SIGTERM, SIGINT, SIGPIPE, } );
138 zyppng::ThreadData::current().setName(
"Zypp-Log");
140 auto ev = zyppng::EventLoop::create();
141 auto server = zyppng::Socket::create( AF_UNIX, SOCK_STREAM, 0 );
142 auto stopNotifyWatch =
_stopSignal.makeNotifier( );
144 std::vector<zyppng::Socket::Ptr> clients;
147 server->bind( std::make_shared<zyppng::UnixSockAddr>(
sockPath(),
true ) );
151 server->connectFunc( &zyppng::Socket::sigIncomingConnection, [&](){
153 auto cl = server->accept();
155 clients.push_back( cl );
159 cl->connectFunc( &zyppng::Socket::sigReadyRead, [
this, sock = cl.get() ](){
161 if ( !writer )
return;
162 while ( sock->canReadLine() ) {
163 auto br = sock->readLine();
164 writer->writeOut( std::string( br.data(), br.size() - 1 ) );
169 cl->connectFunc( &zyppng::Socket::sigDisconnected, [&clients, sock = std::weak_ptr(cl)](){
170 auto lock = sock.lock();
174 auto idx = std::find_if( clients.begin(), clients.end(), [lock](
const auto &s ){
return lock.get() == s.get(); } );
175 clients.erase( idx );
180 stopNotifyWatch->connectFunc( &zyppng::SocketNotifier::sigActivated, [&ev](
const auto &,
auto ) {
189 for (
auto &sock : clients ){
190 while ( sock->canReadLine() ) {
191 auto br = sock->readLine();
192 writer->writeOut( std::string( br.data(), br.size() - 1 ) );
230 _sockFD = ::socket( AF_UNIX, SOCK_STREAM, 0 );
235 return zyppng::trySocketConnection(
_sockFD, addr, 100 );
255 writer->writeOut( msg );
262 if ( msg.back() !=
'\n' )
266 while ( written < msg.size() ) {
267 const auto res = zyppng::eintrSafeCall( ::send,
_sockFD, msg.data() + written, msg.size() - written, MSG_NOSIGNAL );
295 static constexpr std::string_view
OO {
"\033[0m" };
296 static constexpr std::string_view
WH {
"\033[37;40m" };
297 static constexpr std::string_view
CY {
"\033[36;40m" };
298 static constexpr std::string_view
YE {
"\033[33;1;40m" };
299 static constexpr std::string_view
GR {
"\033[32;40m" };
300 static constexpr std::string_view
RE {
"\033[31;1;40m" };
301 static constexpr std::string_view
MA {
"\033[35;40m" };
305 std::string
tracestr(
char tag_r,
unsigned depth_r,
const char * file_r,
const char * fnc_r,
int line_r )
308 fmt % std::string(depth_r,tag_r) % file_r % fnc_r % line_r;
314 , _fnc(
std::move(fnc_r) )
330 : _strout { std::cerr }
332 { _strout << (i?
WH:
YE); }
344 #endif // ZYPP_NDEBUG 370 int fd = ::open( file_r.
c_str(), O_CREAT|O_EXCL, mode_r );
375 std::ofstream * fstr = 0;
376 _outs.reset( (fstr =
new std::ofstream( file_r.
asString().c_str(), std::ios_base::app )) );
377 fstr->rdbuf()->pubsetbuf(0,0);
394 const char * file_r,
const char * func_r,
int line_r,
395 const std::string & buffer_r );
420 void tagSet(
const char * fil_r,
const char * fnc_r,
int lne_r )
429 virtual std::streamsize
xsputn(
const char * s, std::streamsize n )
442 virtual int writeout(
const char* s, std::streamsize n )
449 for (
int i = 0; i < n; ++i, ++c )
452 _buffer += std::string( s, c-s );
460 _buffer += std::string( s, c-s );
486 :
_mybuf( group_r, level_r )
495 std::ostream &
getStream(
const char * fil_r,
const char * fnc_r,
int lne_r )
520 static thread_local
int logControlValid = 0;
521 return logControlValid;
561 return impl ? impl->hideThreadName() :
false;
567 if ( impl ) impl->hideThreadName( onOff_r );
589 if ( logfile_r.
empty() )
591 else if ( logfile_r ==
Pathname(
"-" ) )
626 ret <<
"---<RESET LOGSTREAM FROM FAILED STATE]" << endl;
637 const std::string & message_r )
640 file_r, func_r, line_r,
655 if ( getenv(
"ZYPP_LOGFILE") )
656 logfile( getenv(
"ZYPP_LOGFILE") );
658 if ( getenv(
"ZYPP_PROFILING") )
707 return str <<
"LogControlImpl";
722 static std::ostream nstream(NULL);
724 if ( !control || !group_r || strlen(group_r ) == 0 ) {
730 return control->getStream( group_r,
739 const char * file_r,
const char * func_r,
int line_r,
740 const std::string & buffer_r )
746 control->putStream( group_r, level_r,
747 file_r, func_r, line_r,
756 return impl->isExcessive();
763 using logger::LogControlImpl;
773 const std::string & message_r )
775 static char hostname[1024];
776 static char nohostname[] =
"unknown";
780 ret =
str::form(
"%s <%d> %s(%d) [%s] %s(%s):%d %s",
781 now.c_str(), level_r,
782 ( gethostname( hostname, 1024 ) ? nohostname : hostname ),
785 file_r, func_r, line_r,
788 ret =
str::form(
"%s <%d> %s(%d) [%s] %s(%s):%d {T:%s} %s",
789 now.c_str(), level_r,
790 ( gethostname( hostname, 1024 ) ? nohostname : hostname ),
793 file_r, func_r, line_r,
794 zyppng::ThreadData::current().name().c_str(),
813 impl->logfile( logfile_r );
822 impl->logfile( logfile_r, mode_r );
831 return impl->getLineWriter();
839 impl->setLineWriter( writer_r );
847 impl->setLineFormater( formater_r );
855 impl->setLineWriter( shared_ptr<LineWriter>() );
881 impl->excessive(
true );
888 impl->excessive(
false );
std::map< LogLevel, StreamPtr > StreamSet
std::atomic_flag _atomicLock
Osd & operator<<(Tp &&val)
LogLevel
Definition of log levels.
constexpr bool always_false_v
std::ostream & getStream(const std::string &group_r, LogLevel level_r, const char *file_r, const char *func_r, const int line_r)
Provide the log stream to write (logger interface)
static constexpr std::string_view MA
Base class for ostream based LineWriter.
static bool instanceHideThreadName()
void tagSet(const char *fil_r, const char *fnc_r, int lne_r)
Loglinestream(const std::string &group_r, LogLevel level_r)
static constexpr std::string_view WH
const char * c_str() const
String representation.
String related utilities and Regular expression matching.
void excessive(bool onOff_r)
static void instanceHideThreadName(bool onOff_r)
std::string form(const char *format,...) __attribute__((format(printf
Printf style construction of std::string.
LogControlImpl()
Singleton ctor.
Osd(std::ostream &, int=0)
void setLineWriter(const shared_ptr< LogControl::LineWriter > &writer_r)
NULL _lineWriter indicates no loggin.
static std::string sockPath()
void logfile(const Pathname &logfile_r, mode_t mode_r=0640)
void logfile(const Pathname &logfile_r)
Set path for the logfile.
boost::logic::tribool TriBool
3-state boolean logic (true, false and indeterminate).
void setLineWriter(const shared_ptr< LineWriter > &writer_r)
Assign a LineWriter.
void logToStdErr()
Log to std::err.
bool empty() const
Test for an empty path.
TraceLeave(const TraceLeave &)=delete
std::thread::id threadId()
shared_ptr< LogControl::LineWriter > getLineWriter() const
zyppng::Wakeup _stopSignal
const std::string & asString() const
String representation.
static constexpr std::string_view GR
friend std::ostream & operator<<(std::ostream &str, const LogControl &obj)
static constexpr std::string_view YE
virtual int overflow(int ch=EOF)
void setLineFormater(const shared_ptr< LogControl::LineFormater > &format_r)
Assert _lineFormater is not NULL.
shared_ptr< LogControl::LineFormater > _lineFormater
std::ostream & getStream(const char *fil_r, const char *fnc_r, int lne_r)
bool hideThreadName() const
Hint for Formater whether to hide the thread name.
static LogControlImpl * instance()
The LogControlImpl singleton.
boost::shared_ptr< log::LineWriter > _lineWriter
boost::shared_ptr< log::LineWriter > getLineWriter()
std::once_flag flagReadEnvAutomatically
TriBool _hideThreadName
Hint for Formater whether to hide the thread name.
std::map< std::string, StreamSet > StreamTable
static constexpr std::string_view RE
void logNothing()
Turn off logging.
void setLineWriter(boost::shared_ptr< log::LineWriter > writer)
Maintain logfile related options.
virtual int writeout(const char *s, std::streamsize n)
static constexpr std::string_view OO
void putStream(const std::string &group_r, LogLevel level_r, const char *file_r, const char *func_r, int line_r, const std::string &buffer_r)
That's what Loglinebuf calls.
static Date now()
Return the current time.
void putStream(const std::string &group_r, LogLevel level_r, const char *file_r, const char *func_r, int line_r, const std::string &message_r)
Format and write out a logline from Loglinebuf.
virtual std::streamsize xsputn(const char *s, std::streamsize n)
void hideThreadName(bool onOff_r)
shared_ptr< LineWriter > getLineWriter() const
Get the current LineWriter.
Reference counted access to a Tp object calling a custom Dispose function when the last AutoDispose h...
Loglinebuf(const std::string &group_r, LogLevel level_r)
int & logControlValidFlag()
void setLineFormater(const shared_ptr< LineFormater > &formater_r)
Assign a LineFormater.
shared_ptr< Loglinestream > StreamPtr
constexpr std::string_view ZYPP_MAIN_THREAD_NAME("Zypp-main")
void pushMessage(std::string &&msg)
Easy-to use interface to the ZYPP dependency resolver.
void emergencyShutdown()
will cause the log thread to exit and flush all sockets
std::string tracestr(char tag_r, unsigned depth_r, const char *file_r, const char *fnc_r, int line_r)
static constexpr std::string_view CY
zyppng::Socket::Ptr _sock
std::ostream & getStream(const char *group_r, LogLevel level_r, const char *file_r, const char *func_r, const int line_r)
Return a log stream to write on.
static LogThread & instance()
LogControl implementation (thread_local Singleton).
FileLineWriter(const Pathname &file_r, mode_t mode_r=0)
std::ostream & operator<<(std::ostream &str, const LogControlImpl &)
StreamTable _streamtable
one streambuffer per group and level