git.sur5r.net Git - bacula/bacula/blob - bacula/src/stored/status.c

   1 /*
   2  *  This file handles the status command
   3  *
   4  *     Kern Sibbald, May MMIII
   5  *
   6  *   Version $Id$
   7  *
   8  */
   9 /*
  10    Copyright (C) 2000-2004 Kern Sibbald and John Walker
  11
  12    This program is free software; you can redistribute it and/or
  13    modify it under the terms of the GNU General Public License as
  14    published by the Free Software Foundation; either version 2 of
  15    the License, or (at your option) any later version.
  16
  17    This program is distributed in the hope that it will be useful,
  18    but WITHOUT ANY WARRANTY; without even the implied warranty of
  19    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
  20    General Public License for more details.
  21
  22    You should have received a copy of the GNU General Public
  23    License along with this program; if not, write to the Free
  24    Software Foundation, Inc., 59 Temple Place - Suite 330, Boston,
  25    MA 02111-1307, USA.
  26
  27  */
  28
  29 #include "bacula.h"
  30 #include "stored.h"
  31
  32 /* Exported variables */
  33
  34 /* Imported variables */
  35 extern BSOCK *filed_chan;
  36 extern int r_first, r_last;
  37 extern struct s_res resources[];
  38 extern char my_name[];
  39 extern time_t daemon_start_time;
  40 extern int num_jobs_run;
  41
  42
  43 /* Static variables */
  44
  45
  46 /* Forward referenced functions */
  47 static void send_blocked_status(JCR *jcr, DEVICE *dev);
  48 static void list_terminated_jobs(void *arg);
  49 static void list_running_jobs(BSOCK *user);
  50 static void sendit(const char *msg, int len, void *arg);
  51 static const char *level_to_str(int level);
  52
  53
  54 /*
  55  * Status command from Director
  56  */
  57 int status_cmd(JCR *jcr)
  58 {
  59    DEVRES *device;
  60    DEVICE *dev;
  61    BSOCK *user = jcr->dir_bsock;
  62    char dt[MAX_TIME_LENGTH];
  63    char b1[30], b2[30], b3[30];
  64    int bpb;
  65
  66    bnet_fsend(user, "\n%s Version: " VERSION " (" BDATE ") %s %s %s\n", my_name,
  67               HOST_OS, DISTNAME, DISTVER);
  68    bstrftime_nc(dt, sizeof(dt), daemon_start_time);
  69    bnet_fsend(user, _("Daemon started %s, %d Job%s run since started.\n"), dt, num_jobs_run,
  70         num_jobs_run == 1 ? "" : "s");
  71    if (debug_level > 0) {
  72       char b1[35], b2[35], b3[35], b4[35];
  73       bnet_fsend(user, _(" Heap: bytes=%s max_bytes=%s bufs=%s max_bufs=%s\n"),
  74             edit_uint64_with_commas(sm_bytes, b1),
  75             edit_uint64_with_commas(sm_max_bytes, b2),
  76             edit_uint64_with_commas(sm_buffers, b3),
  77             edit_uint64_with_commas(sm_max_buffers, b4));
  78    }
  79
  80    /*
  81     * List running jobs
  82     */
  83    list_running_jobs(user);
  84
  85    /*
  86     * List terminated jobs
  87     */
  88    list_terminated_jobs(user);
  89
  90    /*
  91     * List devices
  92     */
  93    bnet_fsend(user, _("\nDevice status:\n"));
  94    LockRes();
  95    foreach_res(device, R_DEVICE) {
  96       for (dev=device->dev; dev; dev=dev->next) {
  97          if (dev_state(dev, ST_OPENED)) {
  98             if (dev_state(dev, ST_LABEL)) {
  99                bnet_fsend(user, _("Device \"%s\" is mounted with Volume \"%s\"\n"),
 100                   dev_name(dev), dev->VolHdr.VolName);
 101             } else {
 102                bnet_fsend(user, _("Device \"%s\" open but no Bacula volume is mounted.\n"), dev_name(dev));
 103             }
 104             send_blocked_status(jcr, dev);
 105             if (dev_state(dev, ST_APPEND)) {
 106                bpb = dev->VolCatInfo.VolCatBlocks;
 107                if (bpb <= 0) {
 108                   bpb = 1;
 109                }
 110                bpb = dev->VolCatInfo.VolCatBytes / bpb;
 111                bnet_fsend(user, _("    Total Bytes=%s Blocks=%s Bytes/block=%s\n"),
 112                   edit_uint64_with_commas(dev->VolCatInfo.VolCatBytes, b1),
 113                   edit_uint64_with_commas(dev->VolCatInfo.VolCatBlocks, b2),
 114                   edit_uint64_with_commas(bpb, b3));
 115             } else {  /* reading */
 116                bpb = dev->VolCatInfo.VolCatReads;
 117                if (bpb <= 0) {
 118                   bpb = 1;
 119                }
 120                if (dev->VolCatInfo.VolCatRBytes > 0) {
 121                   bpb = dev->VolCatInfo.VolCatRBytes / bpb;
 122                } else {
 123                   bpb = 0;
 124                }
 125                bnet_fsend(user, _("    Total Bytes Read=%s Blocks Read=%s Bytes/block=%s\n"),
 126                   edit_uint64_with_commas(dev->VolCatInfo.VolCatRBytes, b1),
 127                   edit_uint64_with_commas(dev->VolCatInfo.VolCatReads, b2),
 128                   edit_uint64_with_commas(bpb, b3));
 129             }
 130             bnet_fsend(user, _("    Positioned at File=%s Block=%s\n"),
 131                edit_uint64_with_commas(dev->file, b1),
 132                edit_uint64_with_commas(dev->block_num, b2));
 133
 134          } else {
 135             bnet_fsend(user, _("Device \"%s\" is not open.\n"), dev_name(dev));
 136             send_blocked_status(jcr, dev);
 137          }
 138       }
 139    }
 140    UnlockRes();
 141
 142
 143 #ifdef xfull_status
 144    bnet_fsend(user, "\n\n");
 145    dump_resource(R_DEVICE, resources[R_DEVICE-r_first].res_head, sendit, user);
 146 #endif
 147    bnet_fsend(user, "====\n\n");
 148
 149    list_spool_stats(user);
 150
 151    bnet_sig(user, BNET_EOD);
 152    return 1;
 153 }
 154
 155 static void send_blocked_status(JCR *jcr, DEVICE *dev)
 156 {
 157    BSOCK *user = jcr->dir_bsock;
 158
 159    switch (dev->dev_blocked) {
 160    case BST_UNMOUNTED:
 161       bnet_fsend(user, _("    Device is BLOCKED. User unmounted.\n"));
 162       break;
 163    case BST_UNMOUNTED_WAITING_FOR_SYSOP:
 164       bnet_fsend(user, _("    Device is BLOCKED. User unmounted during wait for media/mount.\n"));
 165       break;
 166    case BST_WAITING_FOR_SYSOP:
 167       if (jcr->JobStatus == JS_WaitMount) {
 168          bnet_fsend(user, _("    Device is BLOCKED waiting for mount of volume \"%s\".\n"),
 169             jcr->VolumeName);
 170       } else {
 171          bnet_fsend(user, _("    Device is BLOCKED waiting for appendable media.\n"));
 172       }
 173       break;
 174    case BST_DOING_ACQUIRE:
 175       bnet_fsend(user, _("    Device is being initialized.\n"));
 176       break;
 177    case BST_WRITING_LABEL:
 178       bnet_fsend(user, _("    Device is blocked labeling a Volume.\n"));
 179       break;
 180    default:
 181       break;
 182    }
 183    if (debug_level > 1) {
 184       bnet_fsend(user, _("Configured device capabilities:\n"));
 185       bnet_fsend(user, "%sEOF ", dev->capabilities & CAP_EOF ? "" : "!");
 186       bnet_fsend(user, "%sBSR ", dev->capabilities & CAP_BSR ? "" : "!");
 187       bnet_fsend(user, "%sBSF ", dev->capabilities & CAP_BSF ? "" : "!");
 188       bnet_fsend(user, "%sFSR ", dev->capabilities & CAP_FSR ? "" : "!");
 189       bnet_fsend(user, "%sFSF ", dev->capabilities & CAP_FSF ? "" : "!");
 190       bnet_fsend(user, "%sEOM ", dev->capabilities & CAP_EOM ? "" : "!");
 191       bnet_fsend(user, "%sREM ", dev->capabilities & CAP_REM ? "" : "!");
 192       bnet_fsend(user, "%sRACCESS ", dev->capabilities & CAP_RACCESS ? "" : "!");
 193       bnet_fsend(user, "%sAUTOMOUNT ", dev->capabilities & CAP_AUTOMOUNT ? "" : "!");
 194       bnet_fsend(user, "%sLABEL ", dev->capabilities & CAP_LABEL ? "" : "!");
 195       bnet_fsend(user, "%sANONVOLS ", dev->capabilities & CAP_ANONVOLS ? "" : "!");
 196       bnet_fsend(user, "%sALWAYSOPEN ", dev->capabilities & CAP_ALWAYSOPEN ? "" : "!");
 197       bnet_fsend(user, "\n");
 198
 199       bnet_fsend(user, _("Device status:\n"));
 200       bnet_fsend(user, "%sOPENED ", dev->state & ST_OPENED ? "" : "!");
 201       bnet_fsend(user, "%sTAPE ", dev->state & ST_TAPE ? "" : "!");
 202       bnet_fsend(user, "%sLABEL ", dev->state & ST_LABEL ? "" : "!");
 203       bnet_fsend(user, "%sMALLOC ", dev->state & ST_MALLOC ? "" : "!");
 204       bnet_fsend(user, "%sAPPEND ", dev->state & ST_APPEND ? "" : "!");
 205       bnet_fsend(user, "%sREAD ", dev->state & ST_READ ? "" : "!");
 206       bnet_fsend(user, "%sEOT ", dev->state & ST_EOT ? "" : "!");
 207       bnet_fsend(user, "%sWEOT ", dev->state & ST_WEOT ? "" : "!");
 208       bnet_fsend(user, "%sEOF ", dev->state & ST_EOF ? "" : "!");
 209       bnet_fsend(user, "%sNEXTVOL ", dev->state & ST_NEXTVOL ? "" : "!");
 210       bnet_fsend(user, "%sSHORT ", dev->state & ST_SHORT ? "" : "!");
 211       bnet_fsend(user, "\n");
 212
 213       bnet_fsend(user, _("Device parameters:\n"));
 214       bnet_fsend(user, "Device name: %s\n", dev->dev_name);
 215       bnet_fsend(user, "File=%u block=%u\n", dev->file, dev->block_num);
 216       bnet_fsend(user, "Min block=%u Max block=%u\n", dev->min_block_size, dev->max_block_size);
 217    }
 218
 219 }
 220
 221 static void list_running_jobs(BSOCK *user)
 222 {
 223    bool found = false;
 224    int bps, sec;
 225    JCR *jcr;
 226    char JobName[MAX_NAME_LENGTH];
 227    char b1[30], b2[30], b3[30];
 228
 229    bnet_fsend(user, _("\nRunning Jobs:\n"));
 230    lock_jcr_chain();
 231    foreach_jcr(jcr) {
 232       if (jcr->JobStatus == JS_WaitFD) {
 233          bnet_fsend(user, _("%s Job %s waiting for Client connection.\n"),
 234             job_type_to_str(jcr->JobType), jcr->Job);
 235       }
 236       if (jcr->device) {
 237          bstrncpy(JobName, jcr->Job, sizeof(JobName));
 238          /* There are three periods after the Job name */
 239          char *p;
 240          for (int i=0; i<3; i++) {
 241             if ((p=strrchr(JobName, '.')) != NULL) {
 242                *p = 0;
 243             }
 244          }
 245          bnet_fsend(user, _("%s %s job %s JobId=%d Volume=\"%s\" device=\"%s\"\n"),
 246                    job_level_to_str(jcr->JobLevel),
 247                    job_type_to_str(jcr->JobType),
 248                    JobName,
 249                    jcr->JobId,
 250                    jcr->VolumeName,
 251                    jcr->device->device_name);
 252          sec = time(NULL) - jcr->run_time;
 253          if (sec <= 0) {
 254             sec = 1;
 255          }
 256          bps = jcr->JobBytes / sec;
 257          bnet_fsend(user, _("    Files=%s Bytes=%s Bytes/sec=%s\n"),
 258             edit_uint64_with_commas(jcr->JobFiles, b1),
 259             edit_uint64_with_commas(jcr->JobBytes, b2),
 260             edit_uint64_with_commas(bps, b3));
 261          found = true;
 262 #ifdef DEBUG
 263          if (jcr->file_bsock) {
 264             bnet_fsend(user, "    FDReadSeqNo=%s in_msg=%u out_msg=%d fd=%d\n",
 265                edit_uint64_with_commas(jcr->file_bsock->read_seqno, b1),
 266                jcr->file_bsock->in_msg_no, jcr->file_bsock->out_msg_no,
 267                jcr->file_bsock->fd);
 268          } else {
 269             bnet_fsend(user, "    FDSocket closed\n");
 270          }
 271 #endif
 272       }
 273       free_locked_jcr(jcr);
 274    }
 275    unlock_jcr_chain();
 276    if (!found) {
 277       bnet_fsend(user, _("No Jobs running.\n"));
 278    }
 279    bnet_fsend(user, "====\n");
 280 }
 281
 282 static void list_terminated_jobs(void *arg)
 283 {
 284    char dt[MAX_TIME_LENGTH], b1[30], b2[30];
 285    char level[10];
 286    struct s_last_job *je;
 287    const char *msg;
 288
 289    if (last_jobs->size() == 0) {
 290       msg = _("No Terminated Jobs.\n");
 291       sendit(msg, strlen(msg), arg);
 292       return;
 293    }
 294    lock_last_jobs_list();
 295    msg =  _("\nTerminated Jobs:\n");
 296    sendit(msg, strlen(msg), arg);
 297    msg =  _(" JobId  Level   Files          Bytes Status   Finished        Name \n");
 298    sendit(msg, strlen(msg), arg);
 299    msg = _("======================================================================\n");
 300    sendit(msg, strlen(msg), arg);
 301    foreach_dlist(je, last_jobs) {
 302       char JobName[MAX_NAME_LENGTH];
 303       const char *termstat;
 304       char buf[1000];
 305
 306       bstrftime_nc(dt, sizeof(dt), je->end_time);
 307       switch (je->JobType) {
 308       case JT_ADMIN:
 309       case JT_RESTORE:
 310          bstrncpy(level, "    ", sizeof(level));
 311          break;
 312       default:
 313          bstrncpy(level, level_to_str(je->JobLevel), sizeof(level));
 314          level[4] = 0;
 315          break;
 316       }
 317       switch (je->JobStatus) {
 318       case JS_Created:
 319          termstat = "Created";
 320          break;
 321       case JS_FatalError:
 322       case JS_ErrorTerminated:
 323          termstat = "Error";
 324          break;
 325       case JS_Differences:
 326          termstat = "Diffs";
 327          break;
 328       case JS_Canceled:
 329          termstat = "Cancel";
 330          break;
 331       case JS_Terminated:
 332          termstat = "OK";
 333          break;
 334       default:
 335          termstat = "Other";
 336          break;
 337       }
 338       bstrncpy(JobName, je->Job, sizeof(JobName));
 339       /* There are three periods after the Job name */
 340       char *p;
 341       for (int i=0; i<3; i++) {
 342          if ((p=strrchr(JobName, '.')) != NULL) {
 343             *p = 0;
 344          }
 345       }
 346       bsnprintf(buf, sizeof(buf), _("%6d  %-6s %8s %14s %-7s  %-8s %s\n"),
 347          je->JobId,
 348          level,
 349          edit_uint64_with_commas(je->JobFiles, b1),
 350          edit_uint64_with_commas(je->JobBytes, b2),
 351          termstat,
 352          dt, JobName);
 353       sendit(buf, strlen(buf), arg);
 354    }
 355    sendit("====\n", 5, arg);
 356    unlock_last_jobs_list();
 357 }
 358
 359 /*
 360  * Convert Job Level into a string
 361  */
 362 static const char *level_to_str(int level)
 363 {
 364    const char *str;
 365
 366    switch (level) {
 367    case L_BASE:
 368       str = _("Base");
 369    case L_FULL:
 370       str = _("Full");
 371       break;
 372    case L_INCREMENTAL:
 373       str = _("Incremental");
 374       break;
 375    case L_DIFFERENTIAL:
 376       str = _("Differential");
 377       break;
 378    case L_SINCE:
 379       str = _("Since");
 380       break;
 381    case L_VERIFY_CATALOG:
 382       str = _("Verify Catalog");
 383       break;
 384    case L_VERIFY_INIT:
 385       str = _("Init Catalog");
 386       break;
 387    case L_VERIFY_VOLUME_TO_CATALOG:
 388       str = _("Volume to Catalog");
 389       break;
 390    case L_VERIFY_DISK_TO_CATALOG:
 391       str = _("Disk to Catalog");
 392       break;
 393    case L_VERIFY_DATA:
 394       str = _("Data");
 395       break;
 396    case L_NONE:
 397       str = " ";
 398       break;
 399    default:
 400       str = _("Unknown Job Level");
 401       break;
 402    }
 403    return str;
 404 }
 405
 406 /*
 407  * Send to Director
 408  */
 409 static void sendit(const char *msg, int len, void *arg)
 410 {
 411    BSOCK *user = (BSOCK *)arg;
 412
 413    memcpy(user->msg, msg, len+1);
 414    user->msglen = len+1;
 415    bnet_send(user);
 416 }