mirrors/ceph-csi
1
0
Fork 0
mirror of https://github.com/ceph/ceph-csi.git synced 2024-12-18 02:50:30 +00:00
Code Issues Packages Projects Releases Wiki Activity

cephfs: implement getFscID() with go-ceph

Browse Source 
Fixes: #1550
Signed-off-by: Niels de Vos <ndevos@redhat.com>
This commit is contained in:
Niels de Vos 2020-10-02 10:14:17 +02:00 committed by mergify[bot]
parent b28ff63a29
commit f646840779
2 changed files with 18 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
internal/cephfs/cephfs_util.go
View File

@ -34,23 +34,27 @@ type CephFilesystemDetails struct {
MDSMap MDSMap `json:"mdsmap"`
}
func (vo *volumeOptions) getFscID(ctx context.Context, cr *util.Credentials) (int64, error) {
// ceph fs get myfs --format=json
// {"mdsmap":{...},"id":2}
var fsDetails CephFilesystemDetails
err := execCommandJSON(ctx, &fsDetails,
"ceph",
"-m", vo.Monitors,
"--id", cr.ID,
"--keyfile="+cr.KeyFile,
"-c", util.CephConfigPath,
"fs", "get", vo.FsName, "--format=json",
)
func (vo *volumeOptions) getFscID(ctx context.Context) (int64, error) {
fsa, err := vo.conn.GetFSAdmin()
if err != nil {
util.ErrorLog(ctx, "could not get FSAdmin, can not fetch filesystem ID for %s:", vo.FsName, err)
return 0, err
}
return fsDetails.ID, nil
volumes, err := fsa.EnumerateVolumes()
if err != nil {
util.ErrorLog(ctx, "could not list volumes, can not fetch filesystem ID for %s:", vo.FsName, err)
return 0, err
}
for _, vol := range volumes {
if vol.Name == vo.FsName {
return vol.ID, nil
}
}
util.ErrorLog(ctx, "failed to list volume %s", vo.FsName)
return 0, ErrVolumeNotFound
}
// CephFilesystem is a representation of the json structure returned by 'ceph fs ls'.

2
internal/cephfs/volumeoptions.go
View File

@ -215,7 +215,7 @@ func newVolumeOptions(ctx context.Context, requestName string, req *csi.CreateVo
return nil, err
}
opts.FscID, err = opts.getFscID(ctx, cr)
opts.FscID, err = opts.getFscID(ctx)
if err != nil {
return nil, err
}