Browse Source

adjust log level

pull/948/head
Chris Lu 6 years ago
parent
commit
108d0fb08d
  1. 1
      weed/filer2/filer_deletion.go
  2. 2
      weed/server/master_grpc_server.go
  3. 2
      weed/server/volume_grpc_client_to_master.go

1
weed/filer2/filer_deletion.go

@ -53,6 +53,7 @@ func (f *Filer) loopProcessingDeletion() {
func (f *Filer) DeleteChunks(fullpath FullPath, chunks []*filer_pb.FileChunk) { func (f *Filer) DeleteChunks(fullpath FullPath, chunks []*filer_pb.FileChunk) {
for _, chunk := range chunks { for _, chunk := range chunks {
glog.V(3).Infof("deleting %s chunk %s", fullpath, chunk.String())
f.fileIdDeletionChan <- chunk.FileId f.fileIdDeletionChan <- chunk.FileId
} }
} }

2
weed/server/master_grpc_server.go

@ -72,7 +72,7 @@ func (ms *MasterServer) SendHeartbeat(stream master_pb.Seaweed_SendHeartbeatServ
} }
} }
glog.V(2).Infof("master received heartbeat %s", heartbeat.String())
glog.V(4).Infof("master received heartbeat %s", heartbeat.String())
message := &master_pb.VolumeLocation{ message := &master_pb.VolumeLocation{
Url: dn.Url(), Url: dn.Url(),
PublicUrl: dn.PublicUrl, PublicUrl: dn.PublicUrl,

2
weed/server/volume_grpc_client_to_master.go

@ -120,7 +120,7 @@ func (vs *VolumeServer) doHeartbeat(ctx context.Context, masterNode, masterGrpcA
return "", err return "", err
} }
case <-tickChan: case <-tickChan:
glog.V(2).Infof("volume server %s:%d heartbeat", vs.store.Ip, vs.store.Port)
glog.V(4).Infof("volume server %s:%d heartbeat", vs.store.Ip, vs.store.Port)
if err = stream.Send(vs.store.CollectHeartbeat()); err != nil { if err = stream.Send(vs.store.CollectHeartbeat()); err != nil {
glog.V(0).Infof("Volume Server Failed to talk with master %s: %v", masterNode, err) glog.V(0).Infof("Volume Server Failed to talk with master %s: %v", masterNode, err)
return "", err return "", err

Loading…
Cancel
Save