diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-11-16 22:28:09 -0800 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-11-16 22:28:09 -0800 |
| commit | eff14d6532ba5ef5bfceb7c9269252bc34f063f1 (patch) | |
| tree | 2764a46caa6cbd795968cd3219439ff9a38d003a /pkg/driver/controllerserver.go | |
| parent | 16a26404819644fda3afe173f578cb1b8ed3dcc6 (diff) | |
| download | seaweedfs-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.go | 14 |
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, |
