git.sur5r.net Git - bacula/bacula/blob - bacula/src/dird/recycle.c

   1 /*
   2  *
   3  *   Bacula Director -- Automatic Recycling of Volumes
   4  *      Recycles Volumes that have been purged
   5  *
   6  *     Kern Sibbald, May MMII
   7  *
   8  *   Version $Id$
   9  */
  10
  11 /*
  12    Copyright (C) 2002 Kern Sibbald and John Walker
  13
  14    This program is free software; you can redistribute it and/or
  15    modify it under the terms of the GNU General Public License as
  16    published by the Free Software Foundation; either version 2 of
  17    the License, or (at your option) any later version.
  18
  19    This program is distributed in the hope that it will be useful,
  20    but WITHOUT ANY WARRANTY; without even the implied warranty of
  21    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
  22    General Public License for more details.
  23
  24    You should have received a copy of the GNU General Public
  25    License along with this program; if not, write to the Free
  26    Software Foundation, Inc., 59 Temple Place - Suite 330, Boston,
  27    MA 02111-1307, USA.
  28
  29  */
  30
  31 #include "bacula.h"
  32 #include "dird.h"
  33 #include "ua.h"
  34
  35 struct s_oldest_ctx {
  36    uint32_t MediaId;
  37    char LastWritten[30];
  38 };
  39
  40 static int oldest_handler(void *ctx, int num_fields, char **row)
  41 {
  42    struct s_oldest_ctx *oldest = (struct s_oldest_ctx *)ctx;
  43
  44    if (row[0]) {
  45       Dmsg2(100, "oldest_handler %s %s\n", row[0], row[1]);
  46    }
  47    /* Find oldest Media record */
  48    if (row[1] && strcmp(row[1], oldest->LastWritten) < 0) {
  49       oldest->MediaId = atoi(row[0]);
  50       strcpy(oldest->LastWritten, row[1]);
  51       Dmsg1(100, "New oldest %s\n", row[1]);
  52    }
  53    return 1;
  54 }
  55
  56 /* Forward referenced functions */
  57
  58 int find_recycled_volume(JCR *jcr, MEDIA_DBR *mr)
  59 {
  60    strcpy(mr->VolStatus, "Recycle");
  61    if (db_find_next_volume(jcr, jcr->db, 1, mr)) {
  62       jcr->MediaId = mr->MediaId;
  63       Dmsg1(20, "Find_next_vol MediaId=%d\n", jcr->MediaId);
  64       strcpy(jcr->VolumeName, mr->VolumeName);
  65       return 1;
  66    }
  67    return 0;
  68 }
  69
  70
  71 /*
  72  *   Look for oldest Purged volume
  73  */
  74 int recycle_oldest_purged_volume(JCR *jcr, MEDIA_DBR *mr)
  75 {
  76    struct s_oldest_ctx oldest;
  77    POOLMEM *query = get_pool_memory(PM_EMSG);
  78    char *select =
  79 "SELECT MediaId, LastWritten FROM Media "
  80 "WHERE PoolId=%d AND Recycle=1 AND VolStatus=\"Purged\" "
  81 "AND MediaType=\"%s\"";
  82
  83    Dmsg0(100, "Enter recycle_oldest_purged_volume\n");
  84    oldest.MediaId = 0;
  85    strcpy(oldest.LastWritten, "9999-99-99 99:99:99");
  86    Mmsg(&query, select, mr->PoolId, mr->MediaType);
  87    if (!db_sql_query(jcr->db, query, oldest_handler, (void *)&oldest)) {
  88       Jmsg(jcr, M_ERROR, 0, "%s", db_strerror(jcr->db));
  89       Dmsg0(100, "Exit 0  recycle_oldest_purged_volume query\n");
  90       free_pool_memory(query);
  91       return 0;
  92    }
  93    free_pool_memory(query);
  94    Dmsg1(100, "Oldest mediaid=%d\n", oldest.MediaId);
  95    if (oldest.MediaId != 0) {
  96       mr->MediaId = oldest.MediaId;
  97       if (db_get_media_record(jcr, jcr->db, mr)) {
  98          strcpy(mr->VolStatus, "Recycle");
  99          mr->VolJobs = mr->VolFiles = mr->VolBlocks = mr->VolErrors = 0;
 100          mr->VolBytes = 0;
 101          mr->FirstWritten = mr->LastWritten = 0;
 102          if (db_update_media_record(jcr, jcr->db, mr)) {
 103             Jmsg(jcr, M_INFO, 0, "Recycled volume \"%s\"\n", mr->VolumeName);
 104             Dmsg1(100, "Exit 1  recycle_oldest_purged_volume Vol=%s\n", mr->VolumeName);
 105             return 1;
 106          }
 107       }
 108       Jmsg(jcr, M_ERROR, 0, "%s", db_strerror(jcr->db));
 109    }
 110    Dmsg0(100, "Exit 0  recycle_oldest_purged_volume end\n");
 111    return 0;
 112 }