mirrors/ceph-csi
1
0
Fork 0
mirror of https://github.com/ceph/ceph-csi.git synced 2024-11-18 04:10:22 +00:00
Code Issues Packages Projects Releases Wiki Activity

skip redundant error check

Browse Source 
correct misspelled  word

Signed-off-by: Madhu Rajanna <mrajanna@redhat.com>
This commit is contained in:
Madhu Rajanna 2019-02-18 17:16:59 +05:30
parent 49f5d4a54e
commit 6fbde110cd
1 changed files with 3 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
pkg/cephfs/util.go
View File

@ -87,11 +87,8 @@ func execCommand(program string, args ...string) (stdout, stderr []byte, err err
} }
func execCommandErr(program string, args ...string) error { func execCommandErr(program string, args ...string) error {
if _, _, err := execCommand(program, args...); err != nil { _, _, err := execCommand(program, args...)
return err return err
}
return nil
} }
func execCommandJSON(v interface{}, program string, args ...string) error { func execCommandJSON(v interface{}, program string, args ...string) error {
@ -119,10 +116,7 @@ func isMountPoint(p string) (bool, error) {
return !notMnt, nil return !notMnt, nil
} }
//
// Controller service request validation // Controller service request validation
//
func (cs *ControllerServer) validateCreateVolumeRequest(req *csi.CreateVolumeRequest) error { func (cs *ControllerServer) validateCreateVolumeRequest(req *csi.CreateVolumeRequest) error {
if err := cs.Driver.ValidateControllerServiceRequest(csi.ControllerServiceCapability_RPC_CREATE_DELETE_VOLUME); err != nil { if err := cs.Driver.ValidateControllerServiceRequest(csi.ControllerServiceCapability_RPC_CREATE_DELETE_VOLUME); err != nil {
return fmt.Errorf("invalid CreateVolumeRequest: %v", err) return fmt.Errorf("invalid CreateVolumeRequest: %v", err)
@ -154,10 +148,7 @@ func (cs *ControllerServer) validateDeleteVolumeRequest() error {
return nil return nil
} }
//
// Node service request validation // Node service request validation
//
func validateNodeStageVolumeRequest(req *csi.NodeStageVolumeRequest) error { func validateNodeStageVolumeRequest(req *csi.NodeStageVolumeRequest) error {
if req.GetVolumeCapability() == nil { if req.GetVolumeCapability() == nil {
return errors.New("volume capability missing in request") return errors.New("volume capability missing in request")
@ -200,7 +191,7 @@ func validateNodePublishVolumeRequest(req *csi.NodePublishVolumeRequest) error {
} }
if req.GetTargetPath() == "" { if req.GetTargetPath() == "" {
return errors.New("varget path missing in request") return errors.New("target path missing in request")
} }
return nil return nil