rename to sf_file_writer_deal_versioned_buffer

recovery_and_balance
YuQing 2022-03-22 08:23:03 +08:00
parent 1a03fec1f6
commit 68d41aa690
4 changed files with 8 additions and 4 deletions

View File

@ -46,7 +46,8 @@ static inline void binlog_writer_set_next_version(SFBinlogWriterInfo *writer,
}
#define deal_binlog_one_record(wb) \
sf_file_writer_deal_buffer(&wb->writer->fw, &wb->bf, wb->version.last)
sf_file_writer_deal_versioned_buffer(&wb->writer->fw, \
&wb->bf, wb->version.last)
#define GET_WBUFFER_VERSION_COUNT(wb) \
(((wb)->version.last - (wb)->version.first) + 1)

View File

@ -276,7 +276,7 @@ int sf_file_writer_get_current_index(SFFileWriterInfo *writer)
return writer->binlog.index;
}
int sf_file_writer_deal_buffer(SFFileWriterInfo *writer,
int sf_file_writer_deal_versioned_buffer(SFFileWriterInfo *writer,
BufferInfo *buffer, const int64_t version)
{
int result;

View File

@ -69,9 +69,12 @@ int sf_file_writer_init(SFFileWriterInfo *writer,
void sf_file_writer_destroy(SFFileWriterInfo *writer);
int sf_file_writer_deal_buffer(SFFileWriterInfo *writer,
int sf_file_writer_deal_versioned_buffer(SFFileWriterInfo *writer,
BufferInfo *buffer, const int64_t version);
#define sf_file_writer_deal_buffer(writer, buffer) \
sf_file_writer_deal_versioned_buffer(writer, buffer, 0)
int sf_file_writer_flush(SFFileWriterInfo *writer);
static inline void sf_file_writer_set_flags(

View File

@ -35,7 +35,7 @@
#include "sf_ordered_writer.h"
#define deal_binlog_one_record(writer, wb) \
sf_file_writer_deal_buffer(&(writer)->fw, &wb->bf, wb->version)
sf_file_writer_deal_versioned_buffer(&(writer)->fw, &wb->bf, wb->version)
static inline int flush_writer_files(SFOrderedWriterInfo *writer)
{