gsh-digital-services/seaweedFS
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

collect cluster node start time

Browse Source
This commit is contained in:
chrislu
2022-05-30 16:23:52 -07:00
parent 968ca95b49
commit 682382648e
5 changed files with 482 additions and 457 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
weed/cluster/cluster.go
View File

@@ -28,7 +28,7 @@ type ClusterNode struct {
Address pb.ServerAddress
Version string
counter int
createdTs time.Time
CreatedTs time.Time
}
type Cluster struct {
@@ -72,7 +72,7 @@ func (cluster *Cluster) AddClusterNode(ns, nodeType string, address pb.ServerAdd
Address: address,
Version: version,
counter: 1,
createdTs: time.Now(),
CreatedTs: time.Now(),
}
return cluster.ensureFilerLeaders(filers, true, filerGroup, nodeType, address)
case BrokerType:
@@ -86,7 +86,7 @@ func (cluster *Cluster) AddClusterNode(ns, nodeType string, address pb.ServerAdd
Address: address,
Version: version,
counter: 1,
createdTs: time.Now(),
CreatedTs: time.Now(),
}
return []*master_pb.KeepConnectedResponse{
{
@@ -238,7 +238,7 @@ func (cluster *Cluster) ensureFilerLeaders(filers *Filers, isAdd bool, filerGrou
if filers.leaders.isOneLeader(node.Address) {
continue
}
duration := now.Sub(node.createdTs).Nanoseconds()
duration := now.Sub(node.CreatedTs).Nanoseconds()
if duration < shortestDuration {
shortestDuration = duration
candidateAddress = node.Address