diff options
| author | Chris Lu <chris.lu@gmail.com> | 2019-10-25 09:35:19 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2019-10-25 09:35:19 -0700 |
| commit | 55a2221eba881304f8c5a877d1e72ba2829f5b5a (patch) | |
| tree | dee84f606150a7d04117a8d42ce16d47d2f792ac | |
| parent | 69de05f6cbc5ed506a6f045c31823b5a0d844c03 (diff) | |
| download | seaweedfs-55a2221eba881304f8c5a877d1e72ba2829f5b5a.tar.xz seaweedfs-55a2221eba881304f8c5a877d1e72ba2829f5b5a.zip | |
master: add logging for volume server disconnection
add logging for https://github.com/chrislusf/seaweedfs/issues/1093
| -rw-r--r-- | weed/server/master_grpc_server.go | 8 |
1 files changed, 8 insertions, 0 deletions
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 } } |