mirror of
https://github.com/ceph/ceph-csi.git
synced 2024-12-18 11:00:25 +00:00
6618e2012d
This commit removes calling of .String() when logging since `%s`,`%v` or `%q` will call an existing .String() function automatically. Fixes: #2051 Signed-off-by: Rakshith R <rar@redhat.com>
162 lines
4.4 KiB
Go
162 lines
4.4 KiB
Go
/*
|
|
Copyright 2021 The Ceph-CSI 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 rbd
|
|
|
|
import (
|
|
"context"
|
|
"encoding/json"
|
|
"fmt"
|
|
"strings"
|
|
|
|
"github.com/ceph/ceph-csi/internal/util"
|
|
|
|
librbd "github.com/ceph/go-ceph/rbd"
|
|
)
|
|
|
|
// enableImageMirroring enables mirroring on an image.
|
|
func (ri *rbdImage) enableImageMirroring(mode librbd.ImageMirrorMode) error {
|
|
image, err := ri.open()
|
|
if err != nil {
|
|
return fmt.Errorf("failed to open image %q with error: %w", ri, err)
|
|
}
|
|
defer image.Close()
|
|
|
|
err = image.MirrorEnable(mode)
|
|
if err != nil {
|
|
return fmt.Errorf("failed to enable mirroring on %q with error: %w", ri, err)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// disableImageMirroring disables mirroring on an image.
|
|
func (ri *rbdImage) disableImageMirroring(force bool) error {
|
|
image, err := ri.open()
|
|
if err != nil {
|
|
return fmt.Errorf("failed to open image %q with error: %w", ri, err)
|
|
}
|
|
defer image.Close()
|
|
|
|
err = image.MirrorDisable(force)
|
|
if err != nil {
|
|
return fmt.Errorf("failed to disable mirroring on %q with error: %w", ri, err)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// getImageMirroringInfo gets mirroring information of an image.
|
|
func (ri *rbdImage) getImageMirroringInfo() (*librbd.MirrorImageInfo, error) {
|
|
image, err := ri.open()
|
|
if err != nil {
|
|
return nil, fmt.Errorf("failed to open image %q with error: %w", ri, err)
|
|
}
|
|
defer image.Close()
|
|
|
|
info, err := image.GetMirrorImageInfo()
|
|
if err != nil {
|
|
return nil, fmt.Errorf("failed to get mirroring info of %q with error: %w", ri, err)
|
|
}
|
|
return info, nil
|
|
}
|
|
|
|
// promoteImage promotes image to primary.
|
|
func (ri *rbdImage) promoteImage(force bool) error {
|
|
image, err := ri.open()
|
|
if err != nil {
|
|
return fmt.Errorf("failed to open image %q with error: %w", ri, err)
|
|
}
|
|
defer image.Close()
|
|
err = image.MirrorPromote(force)
|
|
if err != nil {
|
|
return fmt.Errorf("failed to promote image %q with error: %w", ri, err)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// demoteImage demotes image to secondary.
|
|
func (ri *rbdImage) demoteImage() error {
|
|
image, err := ri.open()
|
|
if err != nil {
|
|
return fmt.Errorf("failed to open image %q with error: %w", ri, err)
|
|
}
|
|
defer image.Close()
|
|
err = image.MirrorDemote()
|
|
if err != nil {
|
|
return fmt.Errorf("failed to demote image %q with error: %w", ri, err)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// resyncImage resync image to correct the split-brain.
|
|
func (ri *rbdImage) resyncImage() error {
|
|
image, err := ri.open()
|
|
if err != nil {
|
|
return fmt.Errorf("failed to open image %q with error: %w", ri, err)
|
|
}
|
|
defer image.Close()
|
|
err = image.MirrorResync()
|
|
if err != nil {
|
|
return fmt.Errorf("failed to resync image %q with error: %w", ri, err)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
type imageMirrorStatus struct {
|
|
Name string `json:"name"` // name of the rbd image
|
|
State string `json:"state"` // rbd image state
|
|
Description string `json:"description"`
|
|
LastUpdate string `json:"last_update"`
|
|
PeerSites []struct {
|
|
SiteName string `json:"site_name"`
|
|
State string `json:"state"`
|
|
Description string `json:"description"`
|
|
LastUpdate string `json:"last_update"`
|
|
} `json:"peer_sites"`
|
|
}
|
|
|
|
// FIXME: once https://github.com/ceph/go-ceph/issues/460 is fixed use go-ceph.
|
|
// getImageMirroingStatus get the mirroring status of an image.
|
|
func (ri *rbdImage) getImageMirroingStatus() (*imageMirrorStatus, error) {
|
|
// rbd mirror image status --format=json info [image-spec | snap-spec]
|
|
var imgStatus imageMirrorStatus
|
|
stdout, stderr, err := util.ExecCommand(
|
|
context.TODO(),
|
|
"rbd",
|
|
"-m", ri.Monitors,
|
|
"--id", ri.conn.Creds.ID,
|
|
"--keyfile="+ri.conn.Creds.KeyFile,
|
|
"-c", util.CephConfigPath,
|
|
"--format="+"json",
|
|
"mirror",
|
|
"image",
|
|
"status",
|
|
ri.String())
|
|
if err != nil {
|
|
if strings.Contains(stderr, "rbd: error opening image "+ri.RbdImageName+
|
|
": (2) No such file or directory") {
|
|
return nil, util.JoinErrors(ErrImageNotFound, err)
|
|
}
|
|
return nil, err
|
|
}
|
|
|
|
if stdout != "" {
|
|
err = json.Unmarshal([]byte(stdout), &imgStatus)
|
|
if err != nil {
|
|
return nil, fmt.Errorf("unmarshal failed (%w), raw buffer response: %s", err, stdout)
|
|
}
|
|
}
|
|
return &imgStatus, nil
|
|
}
|