Ensure backup directory exists and manage logical backup state

Author: caffeinated92

cluster/cluster_bck.go

@@ -209,6 +209,14 @@ func (cluster *Cluster) CheckBackupFreeSpace(backtype string, backup bool) error
 	}
 
 	parentDir := cluster.Conf.WorkingDir + "/" + config.ConstStreamingSubDir + "/" + cluster.Name
+	_, err := os.Stat(parentDir)
+	if os.IsNotExist(err) {
+		err = os.MkdirAll(parentDir, os.ModePerm)
+		if err != nil {
+			cluster.LogModulePrintf(cluster.Conf.Verbose, config.ConstLogModTask, config.LvlErr, "Error creating directory %s: %s", parentDir, err)
+		}
+	}
+
 	diskstat, err := disk.Usage(parentDir)
 	if err != nil {
 		cluster.LogModulePrintf(cluster.Conf.Verbose, config.ConstLogModTask, config.LvlErr, "Error getting disk usage: %s", err)

cluster/srv_job.go

@@ -2062,6 +2062,8 @@ func (server *ServerMonitor) JobBackupLogical() error {
 	}
 
 	cluster.SetInLogicalBackupState(true)
+	defer cluster.SetInLogicalBackupState(false)
+
 	start := time.Now()
 	var prevId int64
 	prev := cluster.BackupMetaMap.GetPreviousBackup(cluster.Conf.BackupLogicalType, server.URL)