Update Center.cpp

Author: Guo-Shiyu

Src/Center/Center.cpp

@@ -199,9 +199,9 @@ void center::wait_cli_login()
         if(cached == false)
         {
             if(this->mirs_data_.size() == 0)
-                memset(&available_mir, 0 sizeof(IP));
+                memset(&available_mir, 0, sizeof(IP));
             else if(this->mirs_data_.size() == 1)
-                available_mir = *mirs_data_.begin();
+                available_mir = mirs_data_.begin()->first;
             //回复可用mir地址
             int send_num = sendto(sock_fd, &available_mir, sizeof(available_mir), 0, (sockaddr*)&addr_cli, sizeof(addr_cli));
             login_count++;
@@ -312,28 +312,29 @@ void center::listen_mir_beat()
         if(mirs_data_.count(mir_ip) == 0)
         {
             mirs_data_.insert({mir_ip, MirDescript()});
+            LOG_INFO << "mirror : " << mir_ip.to_string() << " login";
             //dblog(MIR_LIGIN);
         }
         else
         {
             mirs_data_[mir_ip].reset_beat(telemeter::setting->mir_max_disbeat_time_);
             //记录负载情况到缓存
             //mirs_data_[mir_ip].recordLoad();
-            all_beat_count++;
-            if(all_beat_count >= mirs_data_.size() - 1)
-            {
-                for(auto& kvp : mirs_data_)
-                {
-                    if(kvp.second.decre_and_get_beat() <= 0);
-                    {
-                        //说明有mir掉线了
-                        int i = 3;  //占位避免编译器报warning
-                        //dblog(MIR_DISCONECT);
-                        mirs_data_.erase(kvp.first);
-                        LOG_INFO << "mirror disconnect: " << const_cast<IP*>(&kvp.first)->to_string();
-                    }
-                }
-            }
+            // all_beat_count++;
+            // if(all_beat_count >= mirs_data_.size() - 1)
+            // {
+            //     for(auto& kvp : mirs_data_)
+            //     {
+            //         if(kvp.second.decre_and_get_beat() <= 0);
+            //         {
+            //             //说明有mir掉线了
+            //             int i = 3;  //占位避免编译器报warning
+            //             //dblog(MIR_DISCONECT);
+            //             mirs_data_.erase(kvp.first);
+            //             LOG_INFO << "mirror disconnect: " << const_cast<IP*>(&kvp.first)->to_string();
+            //         }
+            //     }
+            // }
         }
 
     }