github/csi-driver-nvmf
1
0
Fork 0
mirror of https://github.com/kubernetes-csi/csi-driver-nvmf.git synced 2025-06-22 12:37:03 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor: refactor createTrackingFiles() to reduce code duplication

Browse Source 
Signed-off-by: cheolho.kang <cheolho.kang@samsung.com>
This commit is contained in:
cheolho.kang 2025-03-20 15:31:04 +09:00
parent 8a4641f6e1
commit f3d036bb0f
1 changed files with 30 additions and 30 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

46
pkg/nvmf/fabrics.go
View File

@ -49,6 +49,8 @@ func getNvmfConnector(nvmfInfo *nvmfDiskInfo, hostnqn string) *Connector {
TargetPort: nvmfInfo.Port,
Transport: nvmfInfo.Transport,
HostNqn: hostnqn,
RetryCount: 10, // Default retry count
CheckInterval: 1, // Default check interval in seconds
}
}
@ -228,13 +230,6 @@ func disconnectByNqn(nqn, hostnqn string) int {
// connect to volume to this node and return devicePath
func (c *Connector) Connect() (string, error) {
if c.RetryCount == 0 {
c.RetryCount = 10
}
if c.CheckInterval == 0 {
c.CheckInterval = 1
}
if c.RetryCount < 0 || c.CheckInterval < 0 {
return "", fmt.Errorf("Invalid RetryCount and CheckInterval combinaitons "+
"RetryCount: %d, CheckInterval: %d ", c.RetryCount, c.CheckInterval)
@ -263,9 +258,8 @@ func (c *Connector) Connect() (string, error) {
return "", err
}
// create nqn directory
nqnPath := filepath.Join(RUN_NVMF, c.TargetNqn)
if err := os.MkdirAll(nqnPath, 0750); err != nil {
// create tracking files
if err := createTrackingFiles(c); err != nil {
klog.Errorf("create nqn directory %s error %v, rollback!!!", c.TargetNqn, err)
ret := disconnectByNqn(c.TargetNqn, c.HostNqn)
if ret < 0 {
@ -274,19 +268,6 @@ func (c *Connector) Connect() (string, error) {
return "", err
}
// create hostnqn file
hostnqnPath := filepath.Join(RUN_NVMF, c.TargetNqn, b64.StdEncoding.EncodeToString([]byte(c.HostNqn)))
file, err := os.Create(hostnqnPath)
if err != nil {
klog.Errorf("create hostnqn file %s:%s error %v, rollback!!!", c.TargetNqn, c.HostNqn, err)
ret := disconnectByNqn(c.TargetNqn, c.HostNqn)
if ret < 0 {
klog.Errorf("rollback error !!!")
}
return "", err
}
defer file.Close()
klog.Infof("After connect we're returning devicePath: %s", devicePath)
return devicePath, nil
}
@ -301,6 +282,25 @@ func (c *Connector) Disconnect() error {
return nil
}
// createTrackingFiles creates tracking files used by the disconnect process
func createTrackingFiles(c *Connector) error {
// create nqn directory
nqnPath := filepath.Join(RUN_NVMF, c.TargetNqn)
if err := os.MkdirAll(nqnPath, 0750); err != nil {
return fmt.Errorf("failed to create NQN directory: %v", err)
}
// create hostnqn file
hostnqnPath := filepath.Join(RUN_NVMF, c.TargetNqn, b64.StdEncoding.EncodeToString([]byte(c.HostNqn)))
file, err := os.Create(hostnqnPath)
if err != nil {
klog.Errorf("create hostnqn file %s:%s error %v", c.TargetNqn, c.HostNqn, err)
}
defer file.Close()
return nil
}
// PersistConnector persists the provided Connector to the specified file (ie /var/lib/pfile/myConnector.json)
func persistConnectorFile(c *Connector, filePath string) error {
f, err := os.Create(filePath)