]> git.sur5r.net Git - bacula/bacula/commitdiff
Apply Peter Eriksson's fixes
authorKern Sibbald <kern@sibbald.com>
Fri, 28 May 2004 20:51:19 +0000 (20:51 +0000)
committerKern Sibbald <kern@sibbald.com>
Fri, 28 May 2004 20:51:19 +0000 (20:51 +0000)
git-svn-id: https://bacula.svn.sourceforge.net/svnroot/bacula/trunk@1375 91ce42f0-d328-0410-95d8-f526ca767f89

bacula/src/dird/dird_conf.c
bacula/src/dird/ua_select.c
bacula/src/lib/edit.c
bacula/src/lib/parse_conf.c
bacula/src/stored/record.c
bacula/src/stored/spool.c

index 0511dc946f5dcefa033f99c2fad711adc435a3b3..491212b0f65b2e9f57cd49ef635a5da2ee6f3c43 100644 (file)
@@ -351,7 +351,7 @@ struct s_jl joblevels[] = {
    {"Data",          L_VERIFY_DATA,     JT_VERIFY},
    {" ",             L_NONE,            JT_ADMIN},
    {" ",             L_NONE,            JT_RESTORE},
-   {NULL,           0}
+   {NULL,           0,                          0}
 };
 
 /* Keywords (RHS) permitted in Job type records   
index 991af1fe191a89f17ebc807b3364afc4845e4154..8f4e255b18f21354eeb4ef9b1fecd7521fd31b51 100644 (file)
@@ -803,7 +803,7 @@ STORE *get_storage_resource(UAContext *ua, int use_default)
 
          } else if (strcasecmp(ua->argk[i], _("job")) == 0) {
            if (!ua->argv[i]) {
-               bsendmsg(ua, _("Job name not specified.\n"));
+               bsendmsg(ua, _("Expecting job=xxx, got: %s.\n"), ua->argk[i]);
               return NULL;
            }
            if (!(jcr=get_jcr_by_partial_name(ua->argv[i]))) {
index 77da413529d6db41adb7c7377d551c96973c4b70..d1ca7fefbfdeee04912cd07c901cc7818a4eedd5 100644 (file)
@@ -85,7 +85,7 @@ int64_t str_to_int64(char *str)
  */
 char *edit_uint64_with_commas(uint64_t val, char *buf)
 {
-   sprintf(buf, "%" lld, val);
+   sprintf(buf, "%" llu, val);
    return add_commas(buf, buf);
 }
 
@@ -96,7 +96,7 @@ char *edit_uint64_with_commas(uint64_t val, char *buf)
  */
 char *edit_uint64(uint64_t val, char *buf)
 {
-   sprintf(buf, "%" lld, val);
+   sprintf(buf, "%" llu, val);
    return buf;
 }
 
index 56d7696d5a70677764214afd6f9e9f30b125f9d0..8c4466051e2c4d09bf7450a6f03fffcbd5b025dd 100755 (executable)
@@ -103,7 +103,7 @@ RES_ITEM msgs_items[] = {
    {"director",    store_msgs, ITEM(res_msgs), MD_DIRECTOR, 0, 0},
    {"console",     store_msgs, ITEM(res_msgs), MD_CONSOLE,  0, 0},   
    {"operator",    store_msgs, ITEM(res_msgs), MD_OPERATOR, 0, 0},
-   {NULL, NULL,    NULL, 0}
+   {NULL, NULL,    NULL,       0,             0}
 };
 
 struct s_mtypes {      
@@ -701,8 +701,8 @@ parse_config(const char *cf, int exit_on_error)
    for (pass=1; pass <= 2; pass++) {
       Dmsg1(300, "parse_config pass %d\n", pass);
       if ((lc = lex_open_file(lc, cf, NULL)) == NULL) {
-         set_exit_on_error(1); /* Never reached if exit_on_error == 1 */
-         return 0;
+        set_exit_on_error(1); /* Never reached if exit_on_error == 1 */
+        return 0;
       }
       while ((token=lex_get_token(lc, T_ALL)) != T_EOF) {
          Dmsg1(300, "parse got token=%s\n", lex_tok_to_str(token));
@@ -713,8 +713,8 @@ parse_config(const char *cf, int exit_on_error)
               }
               if (token != T_IDENTIFIER) {
                   scan_err1(lc, _("Expected a Resource name identifier, got: %s"), lc->str);
-                  set_exit_on_error(1); /* Never reached if exit_on_error == 1 */
-                  return 0;
+                 set_exit_on_error(1); /* Never reached if exit_on_error == 1 */
+                 return 0;
               }
               for (i=0; resources[i].name; i++)
                  if (strcasecmp(resources[i].name, lc->str) == 0) {
@@ -726,8 +726,8 @@ parse_config(const char *cf, int exit_on_error)
                  }
               if (state == p_none) {
                   scan_err1(lc, _("expected resource name, got: %s"), lc->str);
-                  set_exit_on_error(1); /* Never reached if exit_on_error == 1 */
-                  return 0;
+                 set_exit_on_error(1); /* Never reached if exit_on_error == 1 */
+                 return 0;
               }
               break;
            case p_resource:
@@ -738,8 +738,8 @@ parse_config(const char *cf, int exit_on_error)
                  case T_IDENTIFIER:
                     if (level != 1) {
                         scan_err1(lc, _("not in resource definition: %s"), lc->str);
-                        set_exit_on_error(1); /* Never reached if exit_on_error == 1 */
-                        return 0;
+                       set_exit_on_error(1); /* Never reached if exit_on_error == 1 */
+                       return 0;
                     }
                     for (i=0; items[i].name; i++) {
                        if (strcasecmp(items[i].name, lc->str) == 0) {
@@ -750,8 +750,8 @@ parse_config(const char *cf, int exit_on_error)
                               Dmsg1 (300, "in T_IDENT got token=%s\n", lex_tok_to_str(token));
                              if (token != T_EQUALS) {
                                  scan_err1(lc, _("expected an equals, got: %s"), lc->str);
-                                 set_exit_on_error(1); /* Never reached if exit_on_error == 1 */
-                                 return 0;
+                                set_exit_on_error(1); /* Never reached if exit_on_error == 1 */
+                                return 0;
                              }
                           }
                            Dmsg1(300, "calling handler for %s\n", items[i].name);
@@ -766,8 +766,8 @@ parse_config(const char *cf, int exit_on_error)
                         Dmsg1(300, "Keyword = %s\n", lc->str);
                         scan_err1(lc, _("Keyword \"%s\" not permitted in this resource.\n"
                            "Perhaps you left the trailing brace off of the previous resource."), lc->str);
-                        set_exit_on_error(1); /* Never reached if exit_on_error == 1 */
-                        return 0;
+                       set_exit_on_error(1); /* Never reached if exit_on_error == 1 */
+                       return 0;
                     }
                     break;
 
@@ -784,20 +784,20 @@ parse_config(const char *cf, int exit_on_error)
                  default:
                      scan_err2(lc, _("unexpected token %d %s in resource definition"),    
                        token, lex_tok_to_str(token));
-                     set_exit_on_error(1); /* Never reached if exit_on_error == 1 */
-                     return 0;
+                    set_exit_on_error(1); /* Never reached if exit_on_error == 1 */
+                    return 0;
               }
               break;
            default:
                scan_err1(lc, _("Unknown parser state %d\n"), state);
-               set_exit_on_error(1); /* Never reached if exit_on_error == 1 */
-               return 0;
+              set_exit_on_error(1); /* Never reached if exit_on_error == 1 */
+              return 0;
         }
       }
       if (state != p_none) {
          scan_err0(lc, _("End of conf file reached with unclosed resource."));
-         set_exit_on_error(1); /* Never reached if exit_on_error == 1 */
-         return 0;
+        set_exit_on_error(1); /* Never reached if exit_on_error == 1 */
+        return 0;
       }
       if (debug_level > 50 && pass == 2) {
         int i;
index b5bdcf34284220eab2d79f37c4619c434049bfb9..cc8ea04b7150b867c452ef4b33abfdf972e4baf5 100644 (file)
@@ -193,7 +193,7 @@ int write_record_to_block(DEV_BLOCK *block, DEV_RECORD *rec)
    remlen = block->buf_len - block->binbuf;
 
    ASSERT(block->binbuf == (uint32_t) (block->bufp - block->buf));
-   ASSERT(remlen >= 0);
+   ASSERT(block->buf_len >= block->binbuf);
 
    Dmsg6(190, "write_record_to_block() FI=%s SessId=%d Strm=%s len=%d\n\
 rem=%d remainder=%d\n",
index 65e86d3384d043acd476a7a34e8ad5b33a5310bf..ad1e4c0b059d8fa7404061c3d00e06c60527326e 100644 (file)
@@ -164,9 +164,10 @@ static bool close_data_spool_file(JCR *jcr)
    P(mutex);
    spool_stats.data_jobs--;
    spool_stats.total_data_jobs++;
-   spool_stats.data_size -= jcr->dcr->spool_size;
-   if (spool_stats.data_size < 0) {
+   if (spool_stats.data_size < jcr->dcr->spool_size) {
       spool_stats.data_size = 0;
+   } else {
+      spool_stats.data_size -= jcr->dcr->spool_size;
    }
    jcr->dcr->spool_size = 0;
    V(mutex);
@@ -237,9 +238,10 @@ static bool despool_data(DCR *dcr)
    }
 
    P(mutex);
-   spool_stats.data_size -= dcr->spool_size;
-   if (spool_stats.data_size < 0) {
+   if (spool_stats.data_size < dcr->spool_size) {
       spool_stats.data_size = 0;
+   } else {
+      spool_stats.data_size -= dcr->spool_size;
    }
    V(mutex);
    P(dcr->dev->spool_mutex);