diff options
| author | Chris Lu <chris.lu@gmail.com> | 2018-05-27 11:58:00 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2018-05-27 11:58:00 -0700 |
| commit | 5b844d70113c414724e7ada2d57c291087173a84 (patch) | |
| tree | 700b2f2e2ad833ea120ba87b95615be4fbfbc972 | |
| parent | 8b0718ac92ff7f54db5e98ff175c7ac302a00df2 (diff) | |
| download | seaweedfs-5b844d70113c414724e7ada2d57c291087173a84.tar.xz seaweedfs-5b844d70113c414724e7ada2d57c291087173a84.zip | |
pass reference of master server
SendHeartbeat passes lock by value: weed_server.MasterServer contains
sync.Mutex
| -rw-r--r-- | weed/server/master_grpc_server.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/server/master_grpc_server.go b/weed/server/master_grpc_server.go index 12ef9e927..d9b8f9e09 100644 --- a/weed/server/master_grpc_server.go +++ b/weed/server/master_grpc_server.go @@ -11,7 +11,7 @@ import ( "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 t := ms.Topo for { |