mirror of
https://github.com/XRPLF/rippled.git
synced 2025-11-20 11:05:54 +00:00
Performance test
Signed-off-by: JCW <a1q123456@users.noreply.github.com>
This commit is contained in:
@@ -155,7 +155,7 @@ private:
|
||||
mutable std::mutex batchMutex_;
|
||||
static constexpr size_t BATCH_BUFFER_SIZE = 64 * 1024; // 64KB buffer
|
||||
std::array<char, BATCH_BUFFER_SIZE> batchBuffer_{};
|
||||
std::span<char> writeBuffer_; // Points to available write space
|
||||
static thread_local std::span<char> writeBuffer_; // Points to available write space
|
||||
std::span<char> readBuffer_; // Points to data ready to flush
|
||||
std::chrono::steady_clock::time_point lastFlush_ =
|
||||
std::chrono::steady_clock::now();
|
||||
|
||||
@@ -37,6 +37,7 @@
|
||||
#include <vector>
|
||||
|
||||
namespace ripple {
|
||||
thread_local std::span<char> Logs::writeBuffer_{};
|
||||
|
||||
namespace {
|
||||
constexpr auto FLUSH_INTERVAL =
|
||||
@@ -129,8 +130,8 @@ Logs::File::write(std::string_view text)
|
||||
|
||||
Logs::Logs(beast::severities::Severity thresh)
|
||||
: thresh_(thresh) // default severity
|
||||
, writeBuffer_(
|
||||
batchBuffer_) // Initially, entire buffer is available for writing
|
||||
// , writeBuffer_(
|
||||
// batchBuffer_) // Initially, entire buffer is available for writing
|
||||
, readBuffer_(batchBuffer_.data(), 0) // No data ready to flush initially
|
||||
{
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user