addbinlogsender: check both filenum and offset

bill-wangbiao · May 31, 2016 · 21a889b · 21a889b
1 parent 6e2a268
commit 21a889b
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/pika_server.cc b/src/pika_server.cc
@@ -529,8 +529,8 @@ Status PikaServer::AddBinlogSender(SlaveItem &slave, uint32_t filenum, uint64_t
   uint32_t cur_filenum = 0;
   uint64_t cur_offset = 0;
   logger_->GetProducerStatus(&cur_filenum, &cur_offset);
-  if (cur_filenum < filenum) {
-    return Status::InvalidArgument("AddBinlogSender invalid filenum");
+  if (cur_filenum < filenum || (cur_filenum == filenum && cur_offset < con_offset)) {
+    return Status::InvalidArgument("AddBinlogSender invalid binlog offset");
   }
 
   std::string slave_ip = slave.ip_port.substr(0, slave.ip_port.find(':'));