增加切换serf状态接口（调试用）

zhangqian

2023-10-21 2ea23e2364f742f528fb8b97657212c174d1bbd7

 serf/sync.go

@@ -20,7 +20,7 @@
)

var (
   agent = SyncServer{}
   agent       = SyncServer{}
   dependProcs = []string{
      bhomeclient.Proc_System_Service,
   }
@@ -124,7 +124,6 @@
                  }
               }
               if diff := arrayContains(existingProcs, dependProcs); diff == "" {
                  initChan <- true
                  break loop
               } else {
                  logx.Errorf("Proc: %s is not running!", diff)
@@ -403,8 +402,11 @@
   }
}

// serf 同步数据的限制为92160 byte
func (ss *SyncServer) handleSyncTableMessage(msg []byte) error {
   sizeLimit := 61440
   targetId := string(msg)

   //fmt.Println("同步全量数据给节点:", targetId)
   sqls, err := DumpTables(ss.sqlDB, ss.syncTables)
   if err != nil {
@@ -413,7 +415,19 @@
   }

   syncSql := strings.Join(sqls, ";")
   err = ss.pubSyncSqlMessage([]byte(syncSql), targetId)
   if len(syncSql) < sizeLimit {
      err = ss.pubSyncSqlMessage([]byte(syncSql), targetId)
   } else {
      shard := ""
      for _, sql := range sqls{
         if len(shard) + len(sql) > sizeLimit {
            err = ss.pubSyncSqlMessage([]byte(shard), targetId)
            shard = ""
         }

         shard = fmt.Sprintf("%s%s;",shard,sql)
      }
   }

   return err
}