flushN()

fl::size fl::AsyncLogger::flushN

(

fl::size

maxMessages

)

Flush up to N messages from queue (bounded flush)

Parameters

maxMessages

Maximum number of messages to process

Returns

Number of messages actually flushed

Definition at line 120 of file async_logger.cpp.hpp.

                                             {
    fl::size flushed = 0;
    const char* msg;
    fl::u16 len;
 
    // 256-byte stack buffer - handles most messages in a single chunk
    // Avoids heap allocation entirely by chunking long messages
    char buffer[256];
 
    while (flushed < maxMessages && mQueue.tryPop(&msg, &len)) {
        fl::u16 offset = 0;
 
        // Process message in chunks to avoid heap allocation
        while (offset < len) {
            fl::u16 chunk_size = min(len - offset, static_cast<fl::u16>(sizeof(buffer) - 1));
            fl::memcpy(buffer, msg + offset, chunk_size);
            buffer[chunk_size] = '\0';  // Null-terminate
 
            offset += chunk_size;
 
            if (offset >= len) {
                // Last chunk or whole message - use println (adds newline)
                fl::println(buffer);
            } else {
                // Not last chunk - use print (no newline)
                fl::print(buffer);
            }
        }
 
        mQueue.commit();
        flushed++;
    }
 
    return flushed;
}

References fl::memcpy(), fl::min(), mQueue, offset(), fl::print(), and fl::println().

Referenced by ~AsyncLogger(), fl::async_log_service(), and fl::detail::AsyncLoggerServiceTask::serviceLoggers().

Here is the call graph for this function:

Here is the caller graph for this function: