FastDFS是不是有个binlog_index同步的bug

koolcoy

在函数storage_binlog_fsync里面有下面几行代码。

1. 
   
2.                         g_binlog_index++;
   
3.                         if ((write_ret=write_to_binlog_index()) == 0)
   
4.                         {
   
5.                                 write_ret = open_next_writable_binlog();
   
6.                         }
   

复制代码

从上面可以看出来，写binlog的线程是先更新了g_binlog_index然后再创建的新binlog文件。
再看同步线程的代码（1.21版，2.08在这个地方有修改但是存在同样的问题）

1. 
   
2.                         if (pReader->binlog_index < g_binlog_index) //rotate
   
3.                         {
   
4.                                 pReader->binlog_index++;
   
5.                                 pReader->binlog_offset = 0;
   
6.                                 if ((result=storage_open_readable_binlog( \
   
7.                                                 pReader)) != 0)
   
8.                                 {
   
9.                                         return result;
   
10.                                 }
    

复制代码

bug：在写binlog的线程更新g_binlog_index后新的binlog文件创建完成之前，如果读binlog的线程就去打开新的binlog文件，storage_open_readable_binlog会失败，并且会将pReader->binlog_fd置成-1

修改建议：先创建新的binlog文件，再g_binlog_index++

happy_fish100

回复 1# koolcoy

的确存在你说的问题，已经修复了。非常感谢！

koolcoy

刚看了svn的代码，貌似并没有真正修改掉啊。你是在write_to_binlog_index里面给g_binlog_index赋值的，也就是说仍然是在创建新的binlog文件之前修改的g_binlog_index。

g_binlog_index的修改应该在系统调用

1. 
   
2. g_binlog_fd = open(full_filename, O_WRONLY | O_CREAT | O_APPEND, 0644);
   

复制代码

之后发生才正确{:3_190:}

happy_fish100

回复 3# koolcoy

灰常感谢，这次真正改好了！
大家都像koolcoy这么给力就好了！