mirror of
https://github.com/ceph/ceph-csi.git
synced 2024-12-22 04:50:23 +00:00
240 lines
6.6 KiB
Go
240 lines
6.6 KiB
Go
/*
|
|
Copyright 2017 The Kubernetes Authors.
|
|
|
|
Licensed under the Apache License, Version 2.0 (the "License");
|
|
you may not use this file except in compliance with the License.
|
|
You may obtain a copy of the License at
|
|
|
|
http://www.apache.org/licenses/LICENSE-2.0
|
|
|
|
Unless required by applicable law or agreed to in writing, software
|
|
distributed under the License is distributed on an "AS IS" BASIS,
|
|
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
See the License for the specific language governing permissions and
|
|
limitations under the License.
|
|
*/
|
|
|
|
package flexadapter
|
|
|
|
import (
|
|
"encoding/json"
|
|
"errors"
|
|
"fmt"
|
|
"os/exec"
|
|
"time"
|
|
|
|
"github.com/golang/glog"
|
|
)
|
|
|
|
const (
|
|
// Driver calls
|
|
initCmd = "init"
|
|
getVolumeNameCmd = "getvolumename"
|
|
|
|
isAttached = "isattached"
|
|
|
|
attachCmd = "attach"
|
|
waitForAttachCmd = "waitforattach"
|
|
mountDeviceCmd = "mountdevice"
|
|
|
|
detachCmd = "detach"
|
|
waitForDetachCmd = "waitfordetach"
|
|
unmountDeviceCmd = "unmountdevice"
|
|
|
|
mountCmd = "mount"
|
|
unmountCmd = "unmount"
|
|
|
|
// Option keys
|
|
optionFSType = "kubernetes.io/fsType"
|
|
optionReadWrite = "kubernetes.io/readwrite"
|
|
optionKeySecret = "kubernetes.io/secret"
|
|
optionFSGroup = "kubernetes.io/fsGroup"
|
|
optionMountsDir = "kubernetes.io/mountsDir"
|
|
optionPVorVolumeName = "kubernetes.io/pvOrVolumeName"
|
|
|
|
optionKeyPodName = "kubernetes.io/pod.name"
|
|
optionKeyPodNamespace = "kubernetes.io/pod.namespace"
|
|
optionKeyPodUID = "kubernetes.io/pod.uid"
|
|
|
|
optionKeyServiceAccountName = "kubernetes.io/serviceAccount.name"
|
|
)
|
|
|
|
const (
|
|
// StatusSuccess represents the successful completion of command.
|
|
StatusSuccess = "Success"
|
|
// StatusNotSupported represents that the command is not supported.
|
|
StatusNotSupported = "Not supported"
|
|
)
|
|
|
|
var (
|
|
TimeoutError = fmt.Errorf("Timeout")
|
|
)
|
|
|
|
// DriverCall implements the basic contract between FlexVolume and its driver.
|
|
// The caller is responsible for providing the required args.
|
|
type DriverCall struct {
|
|
driver *flexVolumeDriver
|
|
Command string
|
|
Timeout time.Duration
|
|
args []string
|
|
}
|
|
|
|
func (d *flexVolumeDriver) NewDriverCall(command string) *DriverCall {
|
|
return d.NewDriverCallWithTimeout(command, 0)
|
|
}
|
|
|
|
func (d *flexVolumeDriver) NewDriverCallWithTimeout(command string, timeout time.Duration) *DriverCall {
|
|
return &DriverCall{
|
|
driver: d,
|
|
Command: command,
|
|
Timeout: timeout,
|
|
args: []string{command},
|
|
}
|
|
}
|
|
|
|
func (dc *DriverCall) Append(arg string) {
|
|
dc.args = append(dc.args, arg)
|
|
}
|
|
|
|
func (dc *DriverCall) AppendSpec(volumeID, fsType string, readOnly bool, volumeAttributes map[string]string) error {
|
|
optionsForDriver := NewOptionsForDriver(volumeID, fsType, readOnly, volumeAttributes)
|
|
|
|
jsonBytes, err := json.Marshal(optionsForDriver)
|
|
if err != nil {
|
|
return fmt.Errorf("Failed to marshal spec, error: %s", err.Error())
|
|
}
|
|
|
|
dc.Append(string(jsonBytes))
|
|
return nil
|
|
}
|
|
|
|
func (dc *DriverCall) Run() (*DriverStatus, error) {
|
|
if dc.driver.isUnsupported(dc.Command) {
|
|
return nil, errors.New(StatusNotSupported)
|
|
}
|
|
execPath := dc.driver.getExecutable()
|
|
|
|
cmd := exec.Command(execPath, dc.args...)
|
|
|
|
timeout := false
|
|
if dc.Timeout > 0 {
|
|
timer := time.AfterFunc(dc.Timeout, func() {
|
|
timeout = true
|
|
//TODO: cmd.Stop()
|
|
})
|
|
defer timer.Stop()
|
|
}
|
|
|
|
output, execErr := cmd.CombinedOutput()
|
|
if execErr != nil {
|
|
if timeout {
|
|
return nil, TimeoutError
|
|
}
|
|
_, err := handleCmdResponse(dc.Command, output)
|
|
if err == nil {
|
|
glog.Errorf("FlexVolume: driver bug: %s: exec error (%s) but no error in response.", execPath, execErr)
|
|
return nil, execErr
|
|
}
|
|
if isCmdNotSupportedErr(err) {
|
|
dc.driver.unsupported(dc.Command)
|
|
} else {
|
|
glog.Warningf("FlexVolume: driver call failed: executable: %s, args: %s, error: %s, output: %q", execPath, dc.args, execErr.Error(), output)
|
|
}
|
|
return nil, err
|
|
}
|
|
|
|
status, err := handleCmdResponse(dc.Command, output)
|
|
if err != nil {
|
|
if isCmdNotSupportedErr(err) {
|
|
dc.driver.unsupported(dc.Command)
|
|
}
|
|
return nil, err
|
|
}
|
|
|
|
return status, nil
|
|
}
|
|
|
|
// OptionsForDriver represents the spec given to the driver.
|
|
type OptionsForDriver map[string]string
|
|
|
|
func NewOptionsForDriver(volumeID, fsType string, readOnly bool, volumeAttributes map[string]string) OptionsForDriver {
|
|
options := map[string]string{}
|
|
|
|
if readOnly {
|
|
options[optionReadWrite] = "ro"
|
|
} else {
|
|
options[optionReadWrite] = "rw"
|
|
}
|
|
|
|
options[optionFSType] = fsType
|
|
options[optionPVorVolumeName] = volumeID
|
|
|
|
for key, value := range volumeAttributes {
|
|
options[key] = value
|
|
}
|
|
|
|
return OptionsForDriver(options)
|
|
}
|
|
|
|
// DriverStatus represents the return value of the driver callout.
|
|
type DriverStatus struct {
|
|
// Status of the callout. One of "Success", "Failure" or "Not supported".
|
|
Status string `json:"status"`
|
|
// Reason for success/failure.
|
|
Message string `json:"message,omitempty"`
|
|
// Path to the device attached. This field is valid only for attach calls.
|
|
// ie: /dev/sdx
|
|
DevicePath string `json:"device,omitempty"`
|
|
// Cluster wide unique name of the volume.
|
|
VolumeName string `json:"volumeName,omitempty"`
|
|
// Represents volume is attached on the node
|
|
Attached bool `json:"attached,omitempty"`
|
|
// Returns capabilities of the driver.
|
|
// By default we assume all the capabilities are supported.
|
|
// If the plugin does not support a capability, it can return false for that capability.
|
|
Capabilities *DriverCapabilities `json:",omitempty"`
|
|
}
|
|
|
|
type DriverCapabilities struct {
|
|
Attach bool `json:"attach"`
|
|
SELinuxRelabel bool `json:"selinuxRelabel"`
|
|
}
|
|
|
|
func defaultCapabilities() *DriverCapabilities {
|
|
return &DriverCapabilities{
|
|
Attach: true,
|
|
SELinuxRelabel: true,
|
|
}
|
|
}
|
|
|
|
// isCmdNotSupportedErr checks if the error corresponds to command not supported by
|
|
// driver.
|
|
func isCmdNotSupportedErr(err error) bool {
|
|
if err != nil && err.Error() == StatusNotSupported {
|
|
return true
|
|
}
|
|
|
|
return false
|
|
}
|
|
|
|
// handleCmdResponse processes the command output and returns the appropriate
|
|
// error code or message.
|
|
func handleCmdResponse(cmd string, output []byte) (*DriverStatus, error) {
|
|
status := DriverStatus{
|
|
Capabilities: defaultCapabilities(),
|
|
}
|
|
if err := json.Unmarshal(output, &status); err != nil {
|
|
glog.Errorf("Failed to unmarshal output for command: %s, output: %q, error: %s", cmd, string(output), err.Error())
|
|
return nil, err
|
|
} else if status.Status == StatusNotSupported {
|
|
glog.V(5).Infof("%s command is not supported by the driver", cmd)
|
|
return nil, errors.New(status.Status)
|
|
} else if status.Status != StatusSuccess {
|
|
errMsg := fmt.Sprintf("%s command failed, status: %s, reason: %s", cmd, status.Status, status.Message)
|
|
glog.Errorf(errMsg)
|
|
return nil, fmt.Errorf("%s", errMsg)
|
|
}
|
|
|
|
return &status, nil
|
|
}
|