From a7e5430cf06a82f7c17b6565bd9f1ce581187adb Mon Sep 17 00:00:00 2001
From: zhangqian <zhangqian@123.com>
Date: 星期六, 21 十月 2023 15:24:58 +0800
Subject: [PATCH] 打印数据同步日志
---
serf/sync.go | 8 ++++----
1 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/serf/sync.go b/serf/sync.go
index 829d412..c92fe96 100644
--- a/serf/sync.go
+++ b/serf/sync.go
@@ -371,7 +371,7 @@
}
func (ss *SyncServer) handleClusterMessage(msg []byte) {
- //fmt.Println("clusterMessage:", string(msg))
+ logx.Infof("clusterMessage:", string(msg))
sql := string(msg)
if len(sql) <= 0 {
@@ -419,13 +419,13 @@
err = ss.pubSyncSqlMessage([]byte(syncSql), targetId)
} else {
shard := ""
- for _, sql := range sqls{
- if len(shard) + len(sql) > sizeLimit {
+ for _, sql := range sqls {
+ if len(shard)+len(sql) > sizeLimit {
err = ss.pubSyncSqlMessage([]byte(shard), targetId)
shard = ""
}
- shard = fmt.Sprintf("%s%s;",shard,sql)
+ shard = fmt.Sprintf("%s%s;", shard, sql)
}
}
--
Gitblit v1.8.0