package ceph_cluster

import (
	"github.com/sirupsen/logrus"
	"time"
)

func (cluster *CephCluster) ClearOsdLog(osdNums []int64) error {
	startTime := time.Now()
	logrus.Debugf("ClearOsdLog start. ")
	defer func() {
		cost := time.Now().Sub(startTime).Seconds()
		logrus.Debugf("ClearOsdLog end. cost:%f", cost)
	}()
	for _, client := range cluster.Clients {
		err := client.ClearOsdLog(osdNums)
		if err != nil {
			logrus.Errorf("host :%s, ExecCmd: err:%v", client.IpAddr, err)
			return err
		}
	}

	return nil
}

func (cluster *CephCluster) ClearCephLog() error {
	startTime := time.Now()
	logrus.Debugf("ClearCephLog start. ")
	defer func() {
		cost := time.Now().Sub(startTime).Seconds()
		logrus.Debugf("ClearCephLog end. cost:%f", cost)
	}()
	for _, client := range cluster.Clients {
		err := client.ClearCephLog()
		if err != nil {
			logrus.Errorf("host :%s, ExecCmd: err:%v", client.IpAddr, err)
			return err
		}
	}

	return nil
}

func (cluster *CephCluster) CollectOsdLog(dstDir string, osdNums []int64) error {
	var (
		err error
	)

	startTime := time.Now()
	logrus.Debugf("CollectOsdLog start. ")
	defer func() {
		cost := time.Now().Sub(startTime).Seconds()
		logrus.Debugf("CollectOsdLog end. cost:%f", cost)
	}()

	for _, client := range cluster.Clients {
		err = client.CollectOsdLog(dstDir, osdNums)
		if err != nil {
			return err
		}
	}
	return nil
}

func (cluster *CephCluster) CollectCephLog(dstDir string) error {
	var (
		err error
	)

	startTime := time.Now()
	logrus.Debugf("CollectCephLog start. ")
	defer func() {
		cost := time.Now().Sub(startTime).Seconds()
		logrus.Debugf("CollectCephLog end. cost:%f", cost)
	}()

	for _, client := range cluster.Clients {
		err = client.CollectCephLog(dstDir)
		if err != nil {
			return err
		}
	}
	return nil
}

func (cluster *CephCluster) BackupAndClearCephLog() error {
	startTime := time.Now()
	logrus.Debugf("BackupAndClearCephLog start. ")
	defer func() {
		cost := time.Now().Sub(startTime).Seconds()
		logrus.Debugf("BackupAndClearCephLog end. cost:%f", cost)
	}()

	for _, client := range cluster.Clients {
		err := client.BackupAndClearCephLog()
		if err != nil {
			return err
		}
	}
	return nil
}