pass reference of master server
SendHeartbeat passes lock by value: weed_server.MasterServer contains sync.Mutex
This commit is contained in:
@@ -11,7 +11,7 @@ import (
|
|||||||
"google.golang.org/grpc/peer"
|
"google.golang.org/grpc/peer"
|
||||||
)
|
)
|
||||||
|
|
||||||
func (ms MasterServer) SendHeartbeat(stream master_pb.Seaweed_SendHeartbeatServer) error {
|
func (ms *MasterServer) SendHeartbeat(stream master_pb.Seaweed_SendHeartbeatServer) error {
|
||||||
var dn *topology.DataNode
|
var dn *topology.DataNode
|
||||||
t := ms.Topo
|
t := ms.Topo
|
||||||
for {
|
for {
|
||||||
|
|||||||
Reference in New Issue
Block a user