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_binlog_indexes ignore file not exist

vote_node
YuQing 2022-06-03 15:32:07 +08:00
parent bcd1120617
commit 1d1d4c9f00
2 changed files with 16 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/sf_binlog_writer.h
View File

@ -263,6 +263,11 @@ static inline SFBinlogWriterBuffer *sf_binlog_writer_alloc_versioned_buffer_ex(
sf_file_writer_get_index_filename(data_path, \ sf_file_writer_get_index_filename(data_path, \
subdir_name, filename, size) subdir_name, filename, size)
#define sf_binlog_writer_get_binlog_indexes(data_path, \
subdir_name, start_index, last_index) \
sf_file_writer_get_binlog_indexes(data_path, \
subdir_name, start_index, last_index)
#define sf_binlog_writer_get_binlog_start_index(data_path, \ #define sf_binlog_writer_get_binlog_start_index(data_path, \
subdir_name, start_index) \ subdir_name, start_index) \
sf_file_writer_get_binlog_start_index(data_path, \ sf_file_writer_get_binlog_start_index(data_path, \

13
src/sf_file_writer.c
View File

@ -125,9 +125,17 @@ static int get_binlog_info_from_file(const char *data_path,
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)
{ {
int result;
int compress_index; int compress_index;
return get_binlog_info_from_file(data_path, subdir_name,
result = get_binlog_info_from_file(data_path, subdir_name,
start_index, last_index, &compress_index); start_index, last_index, &compress_index);
if (result == ENOENT) {
*start_index = *last_index = 0;
return 0;
} else {
return result;
}
} }
static inline int get_binlog_index_from_file(SFFileWriterInfo *writer) static inline int get_binlog_index_from_file(SFFileWriterInfo *writer)
@ -146,8 +154,9 @@ static inline int get_binlog_index_from_file(SFFileWriterInfo *writer)
} else { } else {
return 0; return 0;
} }
} else {
return result;
} }
return result;
} }
static int open_writable_binlog(SFFileWriterInfo *writer) static int open_writable_binlog(SFFileWriterInfo *writer)