verify that the connection is currently from the master in PikaBinlog…

…ReceiverThread::Handles::AccessHandle() (OpenAtomFoundation#410)
konkona · Nov 29, 2018 · 44b8868 · 44b8868
1 parent 150174e
commit 44b8868
Showing 1 changed file with 4 additions and 5 deletions.
diff --git a/src/pika_binlog_receiver_thread.cc b/src/pika_binlog_receiver_thread.cc
@@ -39,11 +39,10 @@ bool PikaBinlogReceiverThread::Handles::AccessHandle(std::string& ip) const {
     ip = g_pika_server->host();
   }
   LOG(INFO) << "Master Binlog Sender: " << ip << " connecting";
-  // if (binlog_receiver_->thread_rep_->conn_num() != 0 ||
-  // if (!g_pika_server->ShouldAccessConnAsMaster(ip)) {
-  //  LOG(WARNING) << "BinlogReceiverThread AccessHandle failed: " << ip;
-  //  return false;
-  // }
+  if (!g_pika_server->ShouldAccessConnAsMaster(ip)) {
+   LOG(WARNING) << "BinlogReceiverThread AccessHandle failed: " << ip;
+   return false;
+  }
   g_pika_server->PlusMasterConnection();
   return true;
 }