aboutsummaryrefslogtreecommitdiff
path: root/pkg/driver/controllerserver.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2020-11-16 22:28:09 -0800
committerChris Lu <chris.lu@gmail.com>2020-11-16 22:28:09 -0800
commiteff14d6532ba5ef5bfceb7c9269252bc34f063f1 (patch)
tree2764a46caa6cbd795968cd3219439ff9a38d003a /pkg/driver/controllerserver.go
parent16a26404819644fda3afe173f578cb1b8ed3dcc6 (diff)
downloadseaweedfs-csi-driver-origin/logrus.tar.xz
seaweedfs-csi-driver-origin/logrus.zip
trying logrusorigin/logrus
Diffstat (limited to 'pkg/driver/controllerserver.go')
-rw-r--r--pkg/driver/controllerserver.go14
1 files changed, 7 insertions, 7 deletions
diff --git a/pkg/driver/controllerserver.go b/pkg/driver/controllerserver.go
index 3ca456c..95aadf2 100644
--- a/pkg/driver/controllerserver.go
+++ b/pkg/driver/controllerserver.go
@@ -8,7 +8,7 @@ import (
"io"
"strings"
- "github.com/chrislusf/seaweedfs/weed/glog"
+ "github.com/chrislusf/seaweedfs/weed/util/log"
"github.com/chrislusf/seaweedfs/weed/pb/filer_pb"
"github.com/container-storage-interface/spec/lib/go/csi"
"google.golang.org/grpc/codes"
@@ -26,7 +26,7 @@ func (cs *ControllerServer) CreateVolume(ctx context.Context, req *csi.CreateVol
volumeId := sanitizeVolumeId(req.GetName())
if err := cs.Driver.ValidateControllerServiceRequest(csi.ControllerServiceCapability_RPC_CREATE_DELETE_VOLUME); err != nil {
- glog.V(3).Infof("invalid create volume req: %v", req)
+ log.Tracef("invalid create volume req: %v", req)
return nil, err
}
@@ -39,7 +39,7 @@ func (cs *ControllerServer) CreateVolume(ctx context.Context, req *csi.CreateVol
}
params := req.GetParameters()
- glog.V(4).Info("params:%v", params)
+ log.Trace("params:%v", params)
capacity := req.GetCapacityRange().GetRequiredBytes()
capacityGB := capacity >> 30
if capacityGB == 0 {
@@ -54,7 +54,7 @@ func (cs *ControllerServer) CreateVolume(ctx context.Context, req *csi.CreateVol
return nil, fmt.Errorf("Error setting bucket metadata: %v", err)
}
- glog.V(4).Infof("create volume %s", volumeId)
+ log.Tracef("create volume %s", volumeId)
return &csi.CreateVolumeResponse{
Volume: &csi.Volume{
@@ -75,10 +75,10 @@ func (cs *ControllerServer) DeleteVolume(ctx context.Context, req *csi.DeleteVol
}
if err := cs.Driver.ValidateControllerServiceRequest(csi.ControllerServiceCapability_RPC_CREATE_DELETE_VOLUME); err != nil {
- glog.V(3).Infof("Invalid delete volume req: %v", req)
+ log.Tracef("Invalid delete volume req: %v", req)
return nil, err
}
- glog.V(4).Infof("Deleting volume %s", volumeId)
+ log.Tracef("Deleting volume %s", volumeId)
if err := filer_pb.Remove(cs.Driver, "/buckets", volumeId, true, true, true, false, nil); err != nil {
return nil, fmt.Errorf("Error setting bucket metadata: %v", err)
@@ -151,7 +151,7 @@ func (cs *ControllerServer) GetCapacity(ctx context.Context, req *csi.GetCapacit
// ControllerGetCapabilities implements the default GRPC callout.
// Default supports all capabilities
func (cs *ControllerServer) ControllerGetCapabilities(ctx context.Context, req *csi.ControllerGetCapabilitiesRequest) (*csi.ControllerGetCapabilitiesResponse, error) {
- glog.V(3).Infof("Using default ControllerGetCapabilities")
+ log.Tracef("Using default ControllerGetCapabilities")
return &csi.ControllerGetCapabilitiesResponse{
Capabilities: cs.Driver.cscap,