aboutsummaryrefslogtreecommitdiff
path: root/weed/server/volume_grpc_admin.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2020-11-16 22:26:58 -0800
committerChris Lu <chris.lu@gmail.com>2020-11-16 22:26:58 -0800
commit6c9156b25f8b1c28fb0cc909310a20aeeec0e087 (patch)
tree343e30d98e46a081aa57adfc334b807d0b3255dc /weed/server/volume_grpc_admin.go
parent9add554feb53706d1d878cc9636d234e622b8a80 (diff)
downloadseaweedfs-origin/logrus.tar.xz
seaweedfs-origin/logrus.zip
switch to logrusorigin/logrus
losing filename and line number. Critical for debugging.
Diffstat (limited to 'weed/server/volume_grpc_admin.go')
-rw-r--r--weed/server/volume_grpc_admin.go36
1 files changed, 18 insertions, 18 deletions
diff --git a/weed/server/volume_grpc_admin.go b/weed/server/volume_grpc_admin.go
index 9296c63e9..77065c8bc 100644
--- a/weed/server/volume_grpc_admin.go
+++ b/weed/server/volume_grpc_admin.go
@@ -5,7 +5,7 @@ import (
"fmt"
"path/filepath"
- "github.com/chrislusf/seaweedfs/weed/glog"
+ "github.com/chrislusf/seaweedfs/weed/util/log"
"github.com/chrislusf/seaweedfs/weed/pb/volume_server_pb"
"github.com/chrislusf/seaweedfs/weed/stats"
"github.com/chrislusf/seaweedfs/weed/storage/needle"
@@ -20,9 +20,9 @@ func (vs *VolumeServer) DeleteCollection(ctx context.Context, req *volume_server
err := vs.store.DeleteCollection(req.Collection)
if err != nil {
- glog.Errorf("delete collection %s: %v", req.Collection, err)
+ log.Errorf("delete collection %s: %v", req.Collection, err)
} else {
- glog.V(2).Infof("delete collection %v", req)
+ log.Debugf("delete collection %v", req)
}
return resp, err
@@ -44,9 +44,9 @@ func (vs *VolumeServer) AllocateVolume(ctx context.Context, req *volume_server_p
)
if err != nil {
- glog.Errorf("assign volume %v: %v", req, err)
+ log.Errorf("assign volume %v: %v", req, err)
} else {
- glog.V(2).Infof("assign volume %v", req)
+ log.Debugf("assign volume %v", req)
}
return resp, err
@@ -60,9 +60,9 @@ func (vs *VolumeServer) VolumeMount(ctx context.Context, req *volume_server_pb.V
err := vs.store.MountVolume(needle.VolumeId(req.VolumeId))
if err != nil {
- glog.Errorf("volume mount %v: %v", req, err)
+ log.Errorf("volume mount %v: %v", req, err)
} else {
- glog.V(2).Infof("volume mount %v", req)
+ log.Debugf("volume mount %v", req)
}
return resp, err
@@ -76,9 +76,9 @@ func (vs *VolumeServer) VolumeUnmount(ctx context.Context, req *volume_server_pb
err := vs.store.UnmountVolume(needle.VolumeId(req.VolumeId))
if err != nil {
- glog.Errorf("volume unmount %v: %v", req, err)
+ log.Errorf("volume unmount %v: %v", req, err)
} else {
- glog.V(2).Infof("volume unmount %v", req)
+ log.Debugf("volume unmount %v", req)
}
return resp, err
@@ -92,9 +92,9 @@ func (vs *VolumeServer) VolumeDelete(ctx context.Context, req *volume_server_pb.
err := vs.store.DeleteVolume(needle.VolumeId(req.VolumeId))
if err != nil {
- glog.Errorf("volume delete %v: %v", req, err)
+ log.Errorf("volume delete %v: %v", req, err)
} else {
- glog.V(2).Infof("volume delete %v", req)
+ log.Debugf("volume delete %v", req)
}
return resp, err
@@ -113,21 +113,21 @@ func (vs *VolumeServer) VolumeConfigure(ctx context.Context, req *volume_server_
// unmount
if err := vs.store.UnmountVolume(needle.VolumeId(req.VolumeId)); err != nil {
- glog.Errorf("volume configure unmount %v: %v", req, err)
+ log.Errorf("volume configure unmount %v: %v", req, err)
resp.Error = fmt.Sprintf("volume configure unmount %v: %v", req, err)
return resp, nil
}
// modify the volume info file
if err := vs.store.ConfigureVolume(needle.VolumeId(req.VolumeId), req.Replication); err != nil {
- glog.Errorf("volume configure %v: %v", req, err)
+ log.Errorf("volume configure %v: %v", req, err)
resp.Error = fmt.Sprintf("volume configure %v: %v", req, err)
return resp, nil
}
// mount
if err := vs.store.MountVolume(needle.VolumeId(req.VolumeId)); err != nil {
- glog.Errorf("volume configure mount %v: %v", req, err)
+ log.Errorf("volume configure mount %v: %v", req, err)
resp.Error = fmt.Sprintf("volume configure mount %v: %v", req, err)
return resp, nil
}
@@ -143,9 +143,9 @@ func (vs *VolumeServer) VolumeMarkReadonly(ctx context.Context, req *volume_serv
err := vs.store.MarkVolumeReadonly(needle.VolumeId(req.VolumeId))
if err != nil {
- glog.Errorf("volume mark readonly %v: %v", req, err)
+ log.Errorf("volume mark readonly %v: %v", req, err)
} else {
- glog.V(2).Infof("volume mark readonly %v", req)
+ log.Debugf("volume mark readonly %v", req)
}
return resp, err
@@ -158,9 +158,9 @@ func (vs *VolumeServer) VolumeMarkWritable(ctx context.Context, req *volume_serv
err := vs.store.MarkVolumeWritable(needle.VolumeId(req.VolumeId))
if err != nil {
- glog.Errorf("volume mark writable %v: %v", req, err)
+ log.Errorf("volume mark writable %v: %v", req, err)
} else {
- glog.V(2).Infof("volume mark writable %v", req)
+ log.Debugf("volume mark writable %v", req)
}
return resp, err