add macro func: sf_file_writer_get_last_version_silence
parent
0328b32766
commit
2272bf2707
|
|
@ -211,6 +211,9 @@ int sf_binlog_writer_notify_exit(SFBinlogWriterInfo *writer);
|
||||||
#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)
|
||||||
|
|
||||||
|
#define sf_binlog_writer_get_last_version_silence(writer) \
|
||||||
|
sf_file_writer_get_last_version_silence(&(writer)->fw)
|
||||||
|
|
||||||
#define sf_binlog_get_indexes(writer, start_index, last_index) \
|
#define sf_binlog_get_indexes(writer, start_index, last_index) \
|
||||||
sf_file_writer_get_indexes(&(writer)->fw, start_index, last_index)
|
sf_file_writer_get_indexes(&(writer)->fw, start_index, last_index)
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -95,10 +95,9 @@ static inline int64_t sf_file_writer_get_last_version_ex(
|
||||||
return writer->last_versions.done;
|
return writer->last_versions.done;
|
||||||
} else {
|
} else {
|
||||||
if (FC_LOG_BY_LEVEL(log_level)) {
|
if (FC_LOG_BY_LEVEL(log_level)) {
|
||||||
log_it_ex(&g_log_context, log_level,
|
log_it_ex(&g_log_context, log_level, "file: %s, line: %d, "
|
||||||
"file: "__FILE__", line: %d, "
|
|
||||||
"writer: %s, should set writer flags to %d!",
|
"writer: %s, should set writer flags to %d!",
|
||||||
__LINE__, writer->cfg.subdir_name,
|
__FILE__, __LINE__, writer->cfg.subdir_name,
|
||||||
SF_FILE_WRITER_FLAGS_WANT_DONE_VERSION);
|
SF_FILE_WRITER_FLAGS_WANT_DONE_VERSION);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
@ -106,11 +105,11 @@ static inline int64_t sf_file_writer_get_last_version_ex(
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
static inline int64_t sf_file_writer_get_last_version(
|
#define sf_file_writer_get_last_version(writer) \
|
||||||
SFFileWriterInfo *writer)
|
sf_file_writer_get_last_version_ex(writer, LOG_ERR)
|
||||||
{
|
|
||||||
return sf_file_writer_get_last_version_ex(writer, LOG_ERR);
|
#define sf_file_writer_get_last_version_silence(writer) \
|
||||||
}
|
sf_file_writer_get_last_version_ex(writer, LOG_NOTHING)
|
||||||
|
|
||||||
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);
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue