pdxx
/
libserverframe
mirror of https://github.com/happyfish100/libserverframe.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

sf_file_writer_get_last_version support log_level

fstore_storage_engine
YuQing 2023-03-14 09:48:22 +08:00
parent 404f374397
commit 0328b32766
2 changed files with 19 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/sf_binlog_writer.h
View File

@ -205,6 +205,9 @@ int sf_binlog_writer_notify_exit(SFBinlogWriterInfo *writer);
#define sf_binlog_writer_set_flags(writer, flags) \ #define sf_binlog_writer_set_flags(writer, flags) \
sf_file_writer_set_flags(&(writer)->fw, flags) sf_file_writer_set_flags(&(writer)->fw, flags)
#define sf_binlog_writer_get_last_version_ex(writer, log_level) \
sf_file_writer_get_last_version_ex(&(writer)->fw, log_level)
#define sf_binlog_writer_get_last_version(writer) \ #define sf_binlog_writer_get_last_version(writer) \
sf_file_writer_get_last_version(&(writer)->fw) sf_file_writer_get_last_version(&(writer)->fw)

22
src/sf_file_writer.h
View File

@ -88,20 +88,30 @@ static inline void sf_file_writer_set_flags(
writer->flags = flags; writer->flags = flags;
} }
static inline int64_t sf_file_writer_get_last_version( static inline int64_t sf_file_writer_get_last_version_ex(
SFFileWriterInfo *writer) SFFileWriterInfo *writer, const int log_level)
{ {
if (writer->flags & SF_FILE_WRITER_FLAGS_WANT_DONE_VERSION) { if (writer->flags & SF_FILE_WRITER_FLAGS_WANT_DONE_VERSION) {
return writer->last_versions.done; return writer->last_versions.done;
} else { } else {
logError("file: "__FILE__", line: %d, " if (FC_LOG_BY_LEVEL(log_level)) {
"writer: %s, should set writer flags to %d!", log_it_ex(&g_log_context, log_level,
__LINE__, writer->cfg.subdir_name, "file: "__FILE__", line: %d, "
SF_FILE_WRITER_FLAGS_WANT_DONE_VERSION); "writer: %s, should set writer flags to %d!",
__LINE__, writer->cfg.subdir_name,
SF_FILE_WRITER_FLAGS_WANT_DONE_VERSION);
}
return -1; return -1;
} }
} }
static inline int64_t sf_file_writer_get_last_version(
SFFileWriterInfo *writer)
{
return sf_file_writer_get_last_version_ex(writer, LOG_ERR);
}
int sf_file_writer_get_binlog_indexes(const char *data_path, int sf_file_writer_get_binlog_indexes(const char *data_path,
const char *subdir_name, int *start_index, int *last_index); const char *subdir_name, int *start_index, int *last_index);