mirror of
https://github.com/seaweedfs/seaweedfs.git
synced 2024-01-19 02:48:24 +00:00
Merge pull request #1419 from robin1900/master
fix bug: two same volumeId in different collections
This commit is contained in:
commit
f1b40567e3
|
@ -5,6 +5,7 @@ import (
|
|||
"fmt"
|
||||
"math/rand"
|
||||
"sync"
|
||||
"time"
|
||||
|
||||
"github.com/chrislusf/raft"
|
||||
|
||||
|
@ -65,26 +66,26 @@ func (t *Topology) IsLeader() bool {
|
|||
if t.RaftServer.State() == raft.Leader {
|
||||
return true
|
||||
}
|
||||
if t.RaftServer.Leader() == "" {
|
||||
return true
|
||||
}
|
||||
}
|
||||
return false
|
||||
}
|
||||
|
||||
func (t *Topology) Leader() (string, error) {
|
||||
l := ""
|
||||
count := 3
|
||||
for count > 0 {
|
||||
if t.RaftServer != nil {
|
||||
l = t.RaftServer.Leader()
|
||||
} else {
|
||||
return "", errors.New("Raft Server not ready yet!")
|
||||
}
|
||||
|
||||
if l == "" {
|
||||
// We are a single node cluster, we are the leader
|
||||
return t.RaftServer.Name(), nil
|
||||
if l != "" {
|
||||
break
|
||||
} else {
|
||||
time.Sleep(time.Duration(5-count) * time.Second)
|
||||
}
|
||||
count -= 1
|
||||
}
|
||||
|
||||
return l, nil
|
||||
}
|
||||
|
||||
|
|
Loading…
Reference in a new issue