|
@@ -8,14 +8,19 @@ import (
|
|
|
"fmt"
|
|
|
"strconv"
|
|
|
"strings"
|
|
|
+ "sync"
|
|
|
"time"
|
|
|
)
|
|
|
|
|
|
+var lockSyncDataNode sync.Mutex
|
|
|
+
|
|
|
func SyncDataNode(cont context.Context) (err error) {
|
|
|
fmt.Println("准备同步数据节点")
|
|
|
+ lockSyncDataNode.Lock()
|
|
|
utils.FileLog.Info("准备同步数据节点")
|
|
|
errMsgList := make([]string, 0)
|
|
|
defer func() {
|
|
|
+ lockSyncDataNode.Unlock()
|
|
|
fmt.Println("同步数据节点结束")
|
|
|
if err != nil {
|
|
|
tips := "SyncDataNode-同步数据节点到ETA失败, ErrMsg:\n" + err.Error()
|