log_producer_result log_producer_global_send_thread_init()

in src/log_producer_client.c [224:240]

• 16 lines of code
• 5 McCabe index (conditional complexity)

log_producer_result log_producer_global_send_thread_init(int32_t log_global_send_thread_count, int32_t log_global_send_queue_size)
{
    if (log_global_send_thread_count <= 0  || log_global_send_queue_size <= 0 || g_send_threads != NULL) {
        return LOG_PRODUCER_INVALID;
    }
    g_send_thread_count = log_global_send_thread_count;
    g_send_threads = (THREAD *)malloc(sizeof(THREAD) * g_send_thread_count);

    g_sender_data_queue = log_queue_create(log_global_send_queue_size);
    g_send_thread_destroy = 0;
    int32_t threadId = 0;
    for (; threadId < g_send_thread_count; ++threadId)
    {
        THREAD_INIT(g_send_threads[threadId], log_producer_send_thread_global, g_sender_data_queue);
    }
    return LOG_PRODUCER_OK;
}