diff options
| author | chrislu <chris.lu@gmail.com> | 2023-05-09 22:54:23 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2023-05-09 22:54:23 -0700 |
| commit | d999f1f0e2a13deeb8d221009ac352d86095480d (patch) | |
| tree | 2f868c1db84d3e11da8cc4050eb78f1b1db09367 /weed/server/raft_server.go | |
| parent | 25b237b83ca38854154cf4ea3f76ae892fa88b12 (diff) | |
| download | seaweedfs-d999f1f0e2a13deeb8d221009ac352d86095480d.tar.xz seaweedfs-d999f1f0e2a13deeb8d221009ac352d86095480d.zip | |
update raft version
fix #4460
Diffstat (limited to 'weed/server/raft_server.go')
| -rw-r--r-- | weed/server/raft_server.go | 6 |
1 files changed, 2 insertions, 4 deletions
diff --git a/weed/server/raft_server.go b/weed/server/raft_server.go index 16736eb5b..d718ecac7 100644 --- a/weed/server/raft_server.go +++ b/weed/server/raft_server.go @@ -3,7 +3,6 @@ package weed_server import ( "encoding/json" transport "github.com/Jille/raft-grpc-transport" - "github.com/seaweedfs/raft/protobuf" "io" "math/rand" "os" @@ -34,8 +33,6 @@ type RaftServerOption struct { } type RaftServer struct { - protobuf.UnimplementedRaftServer - raftGrpcServer *raft.GrpcServer peers map[string]pb.ServerAddress // initial peers to join with raftServer raft.Server RaftHashicorp *hashicorpRaft.Raft @@ -43,6 +40,7 @@ type RaftServer struct { dataDir string serverAddr pb.ServerAddress topo *topology.Topology + *raft.GrpcServer } type StateMachine struct { @@ -164,7 +162,7 @@ func NewRaftServer(option *RaftServerOption) (*RaftServer, error) { } } - s.raftGrpcServer = raft.NewGrpcServer(s.raftServer) + s.GrpcServer = raft.NewGrpcServer(s.raftServer) glog.V(0).Infof("current cluster leader: %v", s.raftServer.Leader()) |