[jira] [Assigned] (LOGCXX-534) Crashed in log->forcedLog function when running with multi-thread

["Robert Middleton (Jira)" <lo...@logging.apache.org>]

     [ https://issues.apache.org/jira/browse/LOGCXX-534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Robert Middleton reassigned LOGCXX-534:
---------------------------------------

    Assignee: Robert Middleton

> Crashed in  log->forcedLog function when running with multi-thread
> ------------------------------------------------------------------
>
>                 Key: LOGCXX-534
>                 URL: https://issues.apache.org/jira/browse/LOGCXX-534
>             Project: Log4cxx
>          Issue Type: Bug
>          Components: Core
>            Reporter: Lin Chen
>            Assignee: Robert Middleton
>            Priority: Critical
>
> Hi All,
>  
> I'm using the latest log4cxx 0.12.0 in win10 with vs2015
> When using log4cxx in multi-thread, the process will crash. 
> The crash point is *log->forcedLog* in bench_mt function
> My test coding is following.
>  
> {code:c++}
> // example.cpp : Defines the entry point for the console application.
> //
> #include "stdafx.h"
> #include "malloc.h"
> #include <stdarg.h>
> #include <string>
> #include <stdlib.h>
> #include <log4cxx/logger.h>
> #include <log4cxx/rollingfileappender.h>
> #include <log4cxx/patternlayout.h>
> #include <log4cxx/basicconfigurator.h>
> void init_log4cxx()
> {
>     log4cxx::LayoutPtr layout = std::static_pointer_cast<log4cxx::Layout>(std::make_shared<log4cxx::PatternLayout>(L"%d{yyyy/MM/dd HH:mm:ss.sssZ}  [3344:%.6t]  [%32F(%4L)]  [%-5p]  %m%n"));
>     log4cxx::RollingFileAppenderPtr appender = std::make_shared<log4cxx::RollingFileAppender>(layout, L"./debug_log4cxx.log");
>     appender->setName(LOG4CXX_STR("BENCH"));
>     appender->setMaxFileSize(LOG4CXX_STR("10MB"));
>     appender->setMaxBackupIndex(10);
>     appender->setEncoding(LOG4CXX_STR("utf-8"));
>     log4cxx::helpers::Pool pool;
>     appender->activateOptions(pool);
>     log4cxx::BasicConfigurator::configure(appender);
>     log4cxx::Logger::getRootLogger()->setLevel(log4cxx::Level::getAll());
> }
> void bench(int howmany, log4cxx::LoggerPtr log)
> {
>     using std::chrono::duration;
>     using std::chrono::duration_cast;
>     using std::chrono::high_resolution_clock;
>     auto start = high_resolution_clock::now();
>     for (auto i = 0; i < howmany; ++i)
>     {
>         log->forcedLog(log4cxx::Level::getInfo(), "Hello logger: msg number", log4cxx::spi::LocationInfo(__FILE__, "", __LINE__));
>     }
>     auto delta = high_resolution_clock::now() - start;
>     auto delta_d = duration_cast<duration<double>>(delta).count();
>     char res[1000] = { 0 };
>     sprintf_s(res, "{%s} Elapsed: {%f} secs {%d}/sec", "left", "right", "BENCH", delta_d, int(howmany / delta_d));
>     LOG4CXX_INFO(log, std::string(res));
> }
> void bench_mt(int howmany, log4cxx::LoggerPtr log, size_t thread_count)
> {
>     using std::chrono::duration;
>     using std::chrono::duration_cast;
>     using std::chrono::high_resolution_clock;
>     std::vector<std::thread> threads;
>     threads.reserve(thread_count);
>     auto start = high_resolution_clock::now();
>     for (size_t t = 0; t < thread_count; ++t)
>     {
>         threads.emplace_back([&]() {
>             for (int j = 0; j < howmany / static_cast<int>(thread_count); j++)
>             {
>                 log->forcedLog(log4cxx::Level::getInfo(), "Hello logger: msg number", log4cxx::spi::LocationInfo(__FILE__, "", __LINE__));
>             }
>         });
>     }
>     for (auto &t : threads)
>     {
>         t.join();
>     };
>     auto delta = high_resolution_clock::now() - start;
>     auto delta_d = duration_cast<duration<double>>(delta).count();
>     char res[1000] = { 0 };
>     sprintf_s(res, "mt {%s} Elapsed: {%f} secs {%d}/sec", "left", "right", "BENCH", delta_d, int(howmany / delta_d));
>     LOG4CXX_INFO(log, std::string(res));
> }
> void bench_single_threaded(int iters)
> {
>     log4cxx::LoggerPtr appLogger = log4cxx::Logger::getLogger(L"BENCH");
>     LOG4CXX_INFO(appLogger, "**************************************************************");
>     LOG4CXX_INFO(appLogger, "Single threaded: messages ");
>     LOG4CXX_INFO(appLogger, "**************************************************************");
>     bench(iters, appLogger);
> }
> int main(int argc, char *argv[])
> {
>     init_log4cxx();
>     log4cxx::LoggerPtr appLogger = log4cxx::Logger::getLogger(L"BENCH");
>     int iters = 250000;
>     size_t threads = 4;
>     int max_threads = 1000;
>     try
>     {
>         bench_single_threaded(iters);
>         bench_mt(iters, appLogger, 1);
>         bench_mt(iters, appLogger, 2);
>     }
>     catch (std::exception &ex)
>     {
>         // spdlog::error(ex.what());
>         return EXIT_FAILURE;
>     }
>     return EXIT_SUCCESS;
>     return 0;
> }
> {code}
> Thanks,
>  McGrady



--
This message was sent by Atlassian Jira
(v8.3.4#803005)