1 change buf size from 4KB to 512KB

2 remove auto Flush() for every write
OpenAtomFoundation · Jul 22, 2024 · 009952c · 009952c
1 parent 8efcbf0
commit 009952c
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/include/pika_define.h b/include/pika_define.h
@@ -32,7 +32,7 @@
 class PikaServer;
 /* Global Const */
 constexpr int MAX_DB_NUM = 8;
-constexpr int FWRITE_USER_SPACE_BUF_SIZE = 4 << 10;//4KB
+constexpr int FWRITE_USER_SPACE_BUF_SIZE = 512LL << 10;//512KB
 
 /* Port shift */
 const int kPortShiftRSync = 1000;

diff --git a/src/pika_binlog.cc b/src/pika_binlog.cc
@@ -277,9 +277,9 @@ Status Binlog::EmitPhysicalRecord(RecordType t, const char* ptr, size_t n, int*
   s = queue_->Append(pstd::Slice(buf, kHeaderSize));
   if (s.ok()) {
     s = queue_->Append(pstd::Slice(ptr, n));
-    if (s.ok()) {
-      s = queue_->Flush();
-    }
+//    if (s.ok()) {
+//      s = queue_->Flush();
+//    }
   }
   block_offset_ += static_cast<int32_t>(kHeaderSize + n);