diff options
| author | chrislu <chris.lu@gmail.com> | 2024-09-07 12:38:34 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2024-09-07 12:38:34 -0700 |
| commit | ff3d46637d7adaf364f6384c3d631d16c9741363 (patch) | |
| tree | a64584b28b0f1b8c465d75f38ab146df16cb98b2 /weed/server | |
| parent | accba3070a4a82756835e00696cea0da9c7ff596 (diff) | |
| download | seaweedfs-ff3d46637d7adaf364f6384c3d631d16c9741363.tar.xz seaweedfs-ff3d46637d7adaf364f6384c3d631d16c9741363.zip | |
better logging for volume growth
Diffstat (limited to 'weed/server')
| -rw-r--r-- | weed/server/master_grpc_server_assign.go | 6 | ||||
| -rw-r--r-- | weed/server/master_grpc_server_volume.go | 3 | ||||
| -rw-r--r-- | weed/server/master_server_handlers.go | 1 |
3 files changed, 9 insertions, 1 deletions
diff --git a/weed/server/master_grpc_server_assign.go b/weed/server/master_grpc_server_assign.go index c45184541..a85045f7d 100644 --- a/weed/server/master_grpc_server_assign.go +++ b/weed/server/master_grpc_server_assign.go @@ -93,10 +93,11 @@ func (ms *MasterServer) Assign(ctx context.Context, req *master_pb.AssignRequest ms.volumeGrowthRequestChan <- &topology.VolumeGrowRequest{ Option: option, Count: req.WritableVolumeCount, + Reason: "grpc assign", } } if err != nil { - glog.V(0).Infof("assign %v %v: %v", req, option.String(), err) + glog.V(1).Infof("assign %v %v: %v", req, option.String(), err) stats.MasterPickForWriteErrorCounter.Inc() lastErr = err time.Sleep(200 * time.Millisecond) @@ -128,5 +129,8 @@ func (ms *MasterServer) Assign(ctx context.Context, req *master_pb.AssignRequest Replicas: replicas, }, nil } + if lastErr != nil { + glog.V(0).Infof("assign %v %v: %v", req, option.String(), lastErr) + } return nil, lastErr } diff --git a/weed/server/master_grpc_server_volume.go b/weed/server/master_grpc_server_volume.go index ec0dcf8a1..db0976fb7 100644 --- a/weed/server/master_grpc_server_volume.go +++ b/weed/server/master_grpc_server_volume.go @@ -51,6 +51,7 @@ func (ms *MasterServer) ProcessGrowRequest() { ms.volumeGrowthRequestChan <- &topology.VolumeGrowRequest{ Option: vlc.ToGrowOption(), Count: vl.GetLastGrowCount(), + Reason: "collection autogrow", } } else { for _, dc := range dcs { @@ -62,6 +63,7 @@ func (ms *MasterServer) ProcessGrowRequest() { Option: volumeGrowOption, Count: vl.GetLastGrowCount(), Force: true, + Reason: "per-dc autogrow", } } } @@ -108,6 +110,7 @@ func (ms *MasterServer) ProcessGrowRequest() { filter.Store(req, nil) // we have lock called inside vg + glog.V(0).Infof("volume grow %+v", req) go func(req *topology.VolumeGrowRequest, vl *topology.VolumeLayout) { ms.DoAutomaticVolumeGrow(req) vl.DoneGrowRequest() diff --git a/weed/server/master_server_handlers.go b/weed/server/master_server_handlers.go index 5e17bcca8..f49b04e8c 100644 --- a/weed/server/master_server_handlers.go +++ b/weed/server/master_server_handlers.go @@ -151,6 +151,7 @@ func (ms *MasterServer) dirAssignHandler(w http.ResponseWriter, r *http.Request) ms.volumeGrowthRequestChan <- &topology.VolumeGrowRequest{ Option: option, Count: uint32(writableVolumeCount), + Reason: "http assign", } } if err != nil { |