| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128 |
- /*
- Copyright (c) 2013 Daniele Bartolini, Michele Rossi
- Copyright (c) 2012 Daniele Bartolini, Simone Boscaratto
- Permission is hereby granted, free of charge, to any person
- obtaining a copy of this software and associated documentation
- files (the "Software"), to deal in the Software without
- restriction, including without limitation the rights to use,
- copy, modify, merge, publish, distribute, sublicense, and/or sell
- copies of the Software, and to permit persons to whom the
- Software is furnished to do so, subject to the following
- conditions:
- The above copyright notice and this permission notice shall be
- included in all copies or substantial portions of the Software.
- THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
- EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES
- OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
- NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT
- HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY,
- WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
- FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR
- OTHER DEALINGS IN THE SOFTWARE.
- */
- #include "Log.h"
- #include "LinearAllocator.h"
- #include "StringStream.h"
- #include "RPCServer.h"
- namespace crown
- {
- static char g_buffer[16 * 1024];
- static LinearAllocator g_allocator(g_buffer, 16 * 1024);
- static StringStream g_stream(g_allocator);
- LogLevel Log::m_threshold = LL_DEBUG;
- //-----------------------------------------------------------------------------
- LogLevel Log::threshold()
- {
- return m_threshold;
- }
- //-----------------------------------------------------------------------------
- void Log::set_threshold(LogLevel threshold)
- {
- m_threshold = threshold;
- }
- //-----------------------------------------------------------------------------
- void Log::log_message(LogLevel level, const char* message, ::va_list arg)
- {
- if (level > m_threshold)
- {
- return;
- }
- switch (level)
- {
- case LL_DEBUG: g_stream << "D: "; break;
- case LL_ERROR: g_stream << "E: "; break;
- case LL_WARN: g_stream << "W: "; break;
- case LL_INFO: g_stream << "I: "; break;
- default: break;
- }
- char buf[1024];
- int len = vsnprintf(buf, 1024 - 2, message, arg);
- buf[len] = '\n';
- buf[len + 1] = '\0';
- g_stream << buf;
- }
- //-----------------------------------------------------------------------------
- void Log::d(const char* message, ...)
- {
- va_list args;
- va_start (args, message);
- log_message(LL_DEBUG, message, args);
- va_end (args);
- }
- //-----------------------------------------------------------------------------
- void Log::e(const char* message, ...)
- {
- va_list args;
- va_start (args, message);
- log_message(LL_ERROR, message, args);
- va_end (args);
- }
- //-----------------------------------------------------------------------------
- void Log::w(const char* message, ...)
- {
- va_list args;
- va_start (args, message);
- log_message(LL_WARN, message, args);
- va_end (args);
- }
- //-----------------------------------------------------------------------------
- void Log::i(const char* message, ...)
- {
- va_list args;
- va_start (args, message);
- log_message(LL_INFO, message, args);
- va_end (args);
- }
- //-----------------------------------------------------------------------------
- void Log::flush(RPCServer* server)
- {
- os::printf(g_stream.c_str());
- ::fflush(stdout);
- if (server != NULL)
- {
- server->send_message_to_all(g_stream.c_str());
- }
- g_stream.clear();
- g_allocator.clear();
- }
- } // namespace crown
|