metrics_demo.cpp File Reference

Logger performance metrics collection and multi-threaded throughput test. More...

#include <kcenon/logger/core/logger.h>
#include <kcenon/logger/writers/console_writer.h>
#include <kcenon/logger/interfaces/logger_types.h>
#include <kcenon/common/interfaces/logger_interface.h>
#include <thread>
#include <iostream>
#include <random>

Include dependency graph for metrics_demo.cpp:

Go to the source code of this file.

Functions
void	generate_logs (logger *log, int thread_id, int count)
void	print_metrics (const logger_metrics &metrics)
void	test_structured_logging ()
int	main ()

Detailed Description

Logger performance metrics collection and multi-threaded throughput test.

Definition in file metrics_demo.cpp.

Function Documentation

generate_logs()

void generate_logs	(	logger *	log,
		int	thread_id,
		int	count )

Examples

metrics_demo.cpp.

Definition at line 29 of file metrics_demo.cpp.

                                                          {
    std::random_device rd;
    std::mt19937 gen(rd());
    std::uniform_int_distribution<> level_dist(0, 5);
    std::uniform_int_distribution<> message_size_dist(10, 200);
 
    // Map integer to log level using ILogger interface
    static constexpr ci::log_level levels[] = {
        ci::log_level::trace,
        ci::log_level::debug,
        ci::log_level::info,
        ci::log_level::warning,
        ci::log_level::error,
        ci::log_level::critical
    };
 
    for (int i = 0; i < count; ++i) {
        auto level = levels[level_dist(gen)];
 
        // Generate message of random size
        std::string message = "Thread " + std::to_string(thread_id) + " - Message " + std::to_string(i);
        message.append(message_size_dist(gen), 'x');
 
        log->log(level, message);
 
        std::this_thread::sleep_for(std::chrono::milliseconds(10));
    }
}

References kcenon::logger::logger::log().

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

main()

int main

(

)

Definition at line 86 of file metrics_demo.cpp.

           {
    // Create logger with metrics enabled
    auto logger = std::make_unique<logger_module::logger>(true, 1024); // Small buffer to test dropping
    
    // Add console writer
    logger->add_writer(std::make_unique<console_writer>());
    
    // Enable metrics collection
    auto enable_result = logger->enable_metrics_collection(true);
    if (enable_result.is_err()) {
        std::cerr << "Failed to enable metrics collection" << std::endl;
    }
    
    // Start logger
    logger->start();
    
    std::cout << "Starting logger metrics demo..." << std::endl;
    std::cout << "Generating logs from multiple threads..." << std::endl;
    
    // Launch multiple threads to generate logs
    std::vector<std::thread> threads;
    for (int i = 0; i < 4; ++i) {
        threads.emplace_back(generate_logs, logger.get(), i, 100);
    }
    
    // Wait for threads to complete
    for (auto& t : threads) {
        t.join();
    }
    
    // Wait a bit for processing
    std::this_thread::sleep_for(std::chrono::seconds(1));
    
    // Get and display metrics
    auto metrics_result = logger->get_current_metrics();
    if (metrics_result.has_value()) {
        print_metrics(metrics_result.value());
    } else {
        std::cerr << "Failed to get metrics" << std::endl;
    }
    
    // Test basic logging functionality
    test_structured_logging();
    
    // Stop logger
    logger->stop();
    
    std::cout << "\nDemo completed!" << std::endl;
    
    return 0;
}

References generate_logs(), print_metrics(), and test_structured_logging().

Here is the call graph for this function:

print_metrics()

void print_metrics

(

const logger_metrics &

metrics

)

Examples

metrics_demo.cpp.

Definition at line 58 of file metrics_demo.cpp.

                                                  {
    std::cout << "\n=== Logger Performance Metrics ===" << std::endl;
    std::cout << "Messages logged: " << metrics.messages_logged.load() << std::endl;
    std::cout << "Messages dropped: " << metrics.messages_dropped.load() << std::endl;
    std::cout << "Total log time: " << metrics.total_log_time_ns.load() / 1000000.0 << " ms" << std::endl;
    std::cout << "Throughput: " << metrics.get_messages_per_second() << " msg/s" << std::endl;
    std::cout << "Queue utilization: " << metrics.get_queue_utilization_percent() << "%" << std::endl;
    std::cout << "Avg enqueue time: " << metrics.get_avg_enqueue_time_ns() << " ns" << std::endl;
    std::cout << "Writer errors: " << metrics.writer_errors.load() << std::endl;
    std::cout << "Flush operations: " << metrics.flush_operations.load() << std::endl;
}

References kcenon::logger::metrics::logger_performance_stats::flush_operations, kcenon::logger::metrics::logger_performance_stats::get_avg_enqueue_time_ns(), kcenon::logger::metrics::logger_performance_stats::get_messages_per_second(), kcenon::logger::metrics::logger_performance_stats::get_queue_utilization_percent(), kcenon::logger::metrics::logger_performance_stats::messages_dropped, kcenon::logger::metrics::logger_performance_stats::messages_logged, kcenon::logger::metrics::logger_performance_stats::total_log_time_ns, and kcenon::logger::metrics::logger_performance_stats::writer_errors.

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

test_structured_logging()

void test_structured_logging

(

)

Examples

metrics_demo.cpp.

Definition at line 71 of file metrics_demo.cpp.

                               {
    std::cout << "\n=== Testing Basic Logging ===" << std::endl;
 
    auto base_logger = std::make_shared<logger>(false); // Sync mode for testing
    base_logger->add_writer(std::make_unique<console_writer>());
    base_logger->start();
 
    // Test basic logging at different levels
    base_logger->log(ci::log_level::info, std::string("User logged in - user_id: 12345, ip: 192.168.1.100"));
    base_logger->log(ci::log_level::error, std::string("Database connection failed - host: db.example.com, port: 5432"));
    base_logger->log(ci::log_level::debug, std::string("Retry attempt 3 of 5"));
 
    base_logger->stop();
}

Referenced by main().

Here is the caller graph for this function: