From 55a2221eba881304f8c5a877d1e72ba2829f5b5a Mon Sep 17 00:00:00 2001
From: Chris Lu <chris.lu@gmail.com>
Date: Fri, 25 Oct 2019 09:35:19 -0700
Subject: [PATCH] master: add logging for volume server disconnection

add logging for https://github.com/chrislusf/seaweedfs/issues/1093
---
 weed/server/master_grpc_server.go | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/weed/server/master_grpc_server.go b/weed/server/master_grpc_server.go
index 6fa509e77..cc1d656fa 100644
--- a/weed/server/master_grpc_server.go
+++ b/weed/server/master_grpc_server.go
@@ -49,6 +49,11 @@ func (ms *MasterServer) SendHeartbeat(stream master_pb.Seaweed_SendHeartbeatServ
 	for {
 		heartbeat, err := stream.Recv()
 		if err != nil {
+			if dn != nil {
+				glog.Warningf("SendHeartbeat.Recv server %s:%d : %v", dn.Ip, dn.Port, err)
+			} else {
+				glog.Warningf("SendHeartbeat.Recv: %v", dn.Ip, dn.Port, err)
+			}
 			return err
 		}
 
@@ -73,6 +78,7 @@ func (ms *MasterServer) SendHeartbeat(stream master_pb.Seaweed_SendHeartbeatServ
 			if err := stream.Send(&master_pb.HeartbeatResponse{
 				VolumeSizeLimit: uint64(ms.option.VolumeSizeLimitMB) * 1024 * 1024,
 			}); err != nil {
+				glog.Warningf("SendHeartbeat.Send volume size to %s:%d %v", dn.Ip, dn.Port, err)
 				return err
 			}
 		}
@@ -154,6 +160,7 @@ func (ms *MasterServer) SendHeartbeat(stream master_pb.Seaweed_SendHeartbeatServ
 		// tell the volume servers about the leader
 		newLeader, err := t.Leader()
 		if err != nil {
+			glog.Warningf("SendHeartbeat find leader: %v", err)
 			return err
 		}
 		if err := stream.Send(&master_pb.HeartbeatResponse{
@@ -161,6 +168,7 @@ func (ms *MasterServer) SendHeartbeat(stream master_pb.Seaweed_SendHeartbeatServ
 			MetricsAddress:         ms.option.MetricsAddress,
 			MetricsIntervalSeconds: uint32(ms.option.MetricsIntervalSec),
 		}); err != nil {
+			glog.Warningf("SendHeartbeat.Send response to to %s:%d %v", dn.Ip, dn.Port, err)
 			return err
 		}
 	}