2 Bacula® - The Network Backup Solution
4 Copyright (C) 2000-2009 Free Software Foundation Europe e.V.
6 The main author of Bacula is Kern Sibbald, with contributions from
7 many others, a complete list can be found in the file AUTHORS.
8 This program is Free Software; you can redistribute it and/or
9 modify it under the terms of version two of the GNU General Public
10 License as published by the Free Software Foundation and included
13 This program is distributed in the hope that it will be useful, but
14 WITHOUT ANY WARRANTY; without even the implied warranty of
15 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
16 General Public License for more details.
18 You should have received a copy of the GNU General Public License
19 along with this program; if not, write to the Free Software
20 Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
23 Bacula® is a registered trademark of Kern Sibbald.
24 The licensor of Bacula is the Free Software Foundation Europe
25 (FSFE), Fiduciary Program, Sumatrastrasse 25, 8006 Zürich,
26 Switzerland, email:ftf@fsfeurope.org.
30 * Bacula Director -- fd_cmds.c -- send commands to File daemon
32 * Kern Sibbald, October MM
34 * This routine is run as a separate thread. There may be more
35 * work to be done to make it totally reentrant!!!!
37 * Utility functions for sending info to File Daemon.
38 * These functions are used by both backup and verify.
45 #include "findlib/find.h"
47 const int dbglvl = 400;
49 /* Commands sent to File daemon */
50 static char filesetcmd[] = "fileset%s\n"; /* set full fileset */
51 static char jobcmd[] = "JobId=%s Job=%s SDid=%u SDtime=%u Authorization=%s\n";
52 /* Note, mtime_only is not used here -- implemented as file option */
53 static char levelcmd[] = "level = %s%s%s mtime_only=%d\n";
54 static char runscript[] = "Run OnSuccess=%u OnFailure=%u AbortOnError=%u When=%u Command=%s\n";
55 static char runbeforenow[]= "RunBeforeNow\n";
57 /* Responses received from File daemon */
58 static char OKinc[] = "2000 OK include\n";
59 static char OKjob[] = "2000 OK Job";
60 static char OKlevel[] = "2000 OK level\n";
61 static char OKRunScript[] = "2000 OK RunScript\n";
62 static char OKRunBeforeNow[] = "2000 OK RunBeforeNow\n";
64 /* Forward referenced functions */
65 static bool send_list_item(JCR *jcr, const char *code, char *item, BSOCK *fd);
67 /* External functions */
68 extern DIRRES *director;
69 extern int FDConnectTimeout;
75 * Open connection with File daemon.
76 * Try connecting every retry_interval (default 10 sec), and
77 * give up after max_retry_time (default 30 mins).
80 int connect_to_file_daemon(JCR *jcr, int retry_interval, int max_retry_time,
83 BSOCK *fd = new_bsock();
87 if (jcr->client->heartbeat_interval) {
88 heart_beat = jcr->client->heartbeat_interval;
90 heart_beat = director->heartbeat_interval;
93 if (!jcr->file_bsock) {
94 char name[MAX_NAME_LENGTH + 100];
95 bstrncpy(name, _("Client: "), sizeof(name));
96 bstrncat(name, jcr->client->name(), sizeof(name));
98 fd->set_source_address(director->DIRsrc_addr);
99 if (!fd->connect(jcr,retry_interval,max_retry_time, heart_beat, name, jcr->client->address,
100 NULL, jcr->client->FDport, verbose)) {
106 set_jcr_job_status(jcr, JS_ErrorTerminated);
109 Dmsg0(10, "Opened connection with File daemon\n");
111 fd = jcr->file_bsock; /* use existing connection */
113 fd->res = (RES *)jcr->client; /* save resource in BSOCK */
114 jcr->file_bsock = fd;
115 set_jcr_job_status(jcr, JS_Running);
117 if (!authenticate_file_daemon(jcr)) {
118 set_jcr_job_status(jcr, JS_ErrorTerminated);
123 * Now send JobId and authorization key
125 fd->fsend(jobcmd, edit_int64(jcr->JobId, ed1), jcr->Job, jcr->VolSessionId,
126 jcr->VolSessionTime, jcr->sd_auth_key);
127 if (!jcr->keep_sd_auth_key && strcmp(jcr->sd_auth_key, "dummy")) {
128 memset(jcr->sd_auth_key, 0, strlen(jcr->sd_auth_key));
130 Dmsg1(100, ">filed: %s", fd->msg);
131 if (bget_dirmsg(fd) > 0) {
132 Dmsg1(110, "<filed: %s", fd->msg);
133 if (strncmp(fd->msg, OKjob, strlen(OKjob)) != 0) {
134 Jmsg(jcr, M_FATAL, 0, _("File daemon \"%s\" rejected Job command: %s\n"),
135 jcr->client->hdr.name, fd->msg);
136 set_jcr_job_status(jcr, JS_ErrorTerminated);
138 } else if (jcr->db) {
140 memset(&cr, 0, sizeof(cr));
141 bstrncpy(cr.Name, jcr->client->hdr.name, sizeof(cr.Name));
142 cr.AutoPrune = jcr->client->AutoPrune;
143 cr.FileRetention = jcr->client->FileRetention;
144 cr.JobRetention = jcr->client->JobRetention;
145 bstrncpy(cr.Uname, fd->msg+strlen(OKjob)+1, sizeof(cr.Uname));
146 if (!db_update_client_record(jcr, jcr->db, &cr)) {
147 Jmsg(jcr, M_WARNING, 0, _("Error updating Client record. ERR=%s\n"),
148 db_strerror(jcr->db));
152 Jmsg(jcr, M_FATAL, 0, _("FD gave bad response to JobId command: %s\n"),
154 set_jcr_job_status(jcr, JS_ErrorTerminated);
161 * This subroutine edits the last job start time into a
162 * "since=date/time" buffer that is returned in the
163 * variable since. This is used for display purposes in
164 * the job report. The time in jcr->stime is later
165 * passed to tell the File daemon what to do.
167 void get_level_since_time(JCR *jcr, char *since, int since_len)
171 bool do_full = false;
172 bool do_diff = false;
174 utime_t last_full_time = 0;
175 utime_t last_diff_time;
178 /* If job cloned and a since time already given, use it */
179 if (jcr->cloned && jcr->stime && jcr->stime[0]) {
180 bstrncpy(since, _(", since="), since_len);
181 bstrncat(since, jcr->stime, since_len);
184 /* Make sure stime buffer is allocated */
186 jcr->stime = get_pool_memory(PM_MESSAGE);
190 * Lookup the last FULL backup job to get the time/date for a
191 * differential or incremental save.
193 switch (jcr->getJobLevel()) {
196 POOLMEM *stime = get_pool_memory(PM_MESSAGE);
197 /* Look up start time of last Full job */
198 now = (utime_t)time(NULL);
199 jcr->jr.JobId = 0; /* flag to return since time */
201 * This is probably redundant, but some of the code below
202 * uses jcr->stime, so don't remove unless you are sure.
204 if (!db_find_job_start_time(jcr, jcr->db, &jcr->jr, &jcr->stime)) {
207 have_full = db_find_last_job_start_time(jcr, jcr->db, &jcr->jr, &stime, L_FULL);
209 last_full_time = str_to_utime(stime);
211 do_full = true; /* No full, upgrade to one */
213 Dmsg4(50, "have_full=%d do_full=%d now=%lld full_time=%lld\n", have_full,
214 do_full, now, last_full_time);
215 /* Make sure the last diff is recent enough */
216 if (have_full && jcr->getJobLevel() == L_INCREMENTAL && jcr->job->MaxDiffInterval > 0) {
217 /* Lookup last diff job */
218 if (db_find_last_job_start_time(jcr, jcr->db, &jcr->jr, &stime, L_DIFFERENTIAL)) {
219 last_diff_time = str_to_utime(stime);
220 /* If no Diff since Full, use Full time */
221 if (last_diff_time < last_full_time) {
222 last_diff_time = last_full_time;
224 Dmsg2(50, "last_diff_time=%lld last_full_time=%lld\n", last_diff_time,
227 /* No last differential, so use last full time */
228 last_diff_time = last_full_time;
229 Dmsg1(50, "No last_diff_time setting to full_time=%lld\n", last_full_time);
231 do_diff = ((now - last_diff_time) >= jcr->job->MaxDiffInterval);
232 Dmsg2(50, "do_diff=%d diffInter=%lld\n", do_diff, jcr->job->MaxDiffInterval);
234 /* Note, do_full takes precedence over do_diff */
235 if (have_full && jcr->job->MaxFullInterval > 0) {
236 do_full = ((now - last_full_time) >= jcr->job->MaxFullInterval);
238 free_pool_memory(stime);
241 /* No recent Full job found, so upgrade this one to Full */
242 Jmsg(jcr, M_INFO, 0, "%s", db_strerror(jcr->db));
243 Jmsg(jcr, M_INFO, 0, _("No prior or suitable Full backup found in catalog. Doing FULL backup.\n"));
244 bsnprintf(since, since_len, _(" (upgraded from %s)"),
245 level_to_str(jcr->getJobLevel()));
246 jcr->set_JobLevel(jcr->jr.JobLevel = L_FULL);
247 } else if (do_diff) {
248 /* No recent diff job found, so upgrade this one to Diff */
249 Jmsg(jcr, M_INFO, 0, _("No prior or suitable Differential backup found in catalog. Doing Differential backup.\n"));
250 bsnprintf(since, since_len, _(" (upgraded from %s)"),
251 level_to_str(jcr->getJobLevel()));
252 jcr->set_JobLevel(jcr->jr.JobLevel = L_DIFFERENTIAL);
254 if (jcr->job->rerun_failed_levels) {
255 if (db_find_failed_job_since(jcr, jcr->db, &jcr->jr, jcr->stime, JobLevel)) {
256 Jmsg(jcr, M_INFO, 0, _("Prior failed job found in catalog. Upgrading to %s.\n"),
257 level_to_str(JobLevel));
258 bsnprintf(since, since_len, _(" (upgraded from %s)"),
259 level_to_str(jcr->getJobLevel()));
260 jcr->set_JobLevel(jcr->jr.JobLevel = JobLevel);
261 jcr->jr.JobId = jcr->JobId;
265 bstrncpy(since, _(", since="), since_len);
266 bstrncat(since, jcr->stime, since_len);
268 jcr->jr.JobId = jcr->JobId;
271 Dmsg2(100, "Level=%c last start time=%s\n", jcr->getJobLevel(), jcr->stime);
274 static void send_since_time(JCR *jcr)
276 BSOCK *fd = jcr->file_bsock;
280 stime = str_to_utime(jcr->stime);
281 fd->fsend(levelcmd, "", NT_("since_utime "), edit_uint64(stime, ed1), 0);
282 while (bget_dirmsg(fd) >= 0) { /* allow him to poll us to sync clocks */
283 Jmsg(jcr, M_INFO, 0, "%s\n", fd->msg);
288 * Send level command to FD.
289 * Used for backup jobs and estimate command.
291 bool send_level_command(JCR *jcr)
293 BSOCK *fd = jcr->file_bsock;
294 const char *accurate = jcr->accurate?"accurate_":"";
295 const char *not_accurate = "";
297 * Send Level command to File daemon
299 switch (jcr->getJobLevel()) {
301 fd->fsend(levelcmd, not_accurate, "base", " ", 0);
303 /* L_NONE is the console, sending something off to the FD */
306 fd->fsend(levelcmd, not_accurate, "full", " ", 0);
309 fd->fsend(levelcmd, accurate, "differential", " ", 0);
310 send_since_time(jcr);
313 fd->fsend(levelcmd, accurate, "incremental", " ", 0);
314 send_since_time(jcr);
318 Jmsg2(jcr, M_FATAL, 0, _("Unimplemented backup level %d %c\n"),
319 jcr->getJobLevel(), jcr->getJobLevel());
322 Dmsg1(120, ">filed: %s", fd->msg);
323 if (!response(jcr, fd, OKlevel, "Level", DISPLAY_ERROR)) {
330 * Send either an Included or an Excluded list to FD
332 static bool send_fileset(JCR *jcr)
334 FILESET *fileset = jcr->fileset;
335 BSOCK *fd = jcr->file_bsock;
336 STORE *store = jcr->wstore;
342 num = fileset->num_includes;
344 num = fileset->num_excludes;
346 for (int i=0; i<num; i++) {
352 ie = fileset->include_items[i];
355 ie = fileset->exclude_items[i];
359 bnet_fsend(fd, "Z %s\n", ie->ignoredir);
361 for (j=0; j<ie->num_opts; j++) {
362 FOPTS *fo = ie->opts_list[j];
364 bool enhanced_wild = false;
365 for (k=0; fo->opts[k]!='\0'; k++) {
366 if (fo->opts[k]=='W') {
367 enhanced_wild = true;
372 /* Strip out compression option Zn if disallowed for this Storage */
373 if (store && !store->AllowCompress) {
374 char newopts[MAX_FOPTS];
376 for (k=0; fo->opts[k]!='\0'; k++) {
377 /* Z compress option is followed by the single-digit compress level */
378 if (fo->opts[k]=='Z') {
379 k++; /* skip option and level */
381 newopts[j] = fo->opts[k];
388 _("FD compression disabled for this Job because AllowCompress=No in Storage resource.\n") );
390 /* Send the new trimmed option set without overwriting fo->opts */
391 fd->fsend("O %s\n", newopts);
393 /* Send the original options */
394 fd->fsend("O %s\n", fo->opts);
397 for (k=0; k<fo->regex.size(); k++) {
398 fd->fsend("R %s\n", fo->regex.get(k));
400 for (k=0; k<fo->regexdir.size(); k++) {
401 fd->fsend("RD %s\n", fo->regexdir.get(k));
403 for (k=0; k<fo->regexfile.size(); k++) {
404 fd->fsend("RF %s\n", fo->regexfile.get(k));
406 for (k=0; k<fo->wild.size(); k++) {
407 fd->fsend("W %s\n", fo->wild.get(k));
409 for (k=0; k<fo->wilddir.size(); k++) {
410 fd->fsend("WD %s\n", fo->wilddir.get(k));
412 for (k=0; k<fo->wildfile.size(); k++) {
413 fd->fsend("WF %s\n", fo->wildfile.get(k));
415 for (k=0; k<fo->wildbase.size(); k++) {
416 fd->fsend("W%c %s\n", enhanced_wild ? 'B' : 'F', fo->wildbase.get(k));
418 for (k=0; k<fo->base.size(); k++) {
419 fd->fsend("B %s\n", fo->base.get(k));
421 for (k=0; k<fo->fstype.size(); k++) {
422 fd->fsend("X %s\n", fo->fstype.get(k));
424 for (k=0; k<fo->drivetype.size(); k++) {
425 fd->fsend("XD %s\n", fo->drivetype.get(k));
428 fd->fsend("G %s\n", fo->plugin);
431 fd->fsend("D %s\n", fo->reader);
434 fd->fsend("T %s\n", fo->writer);
439 for (j=0; j<ie->name_list.size(); j++) {
440 item = (char *)ie->name_list.get(j);
441 if (!send_list_item(jcr, "F ", item, fd)) {
446 for (j=0; j<ie->plugin_list.size(); j++) {
447 item = (char *)ie->plugin_list.get(j);
448 if (!send_list_item(jcr, "P ", item, fd)) {
454 if (!include) { /* If we just did excludes */
455 break; /* all done */
457 include = false; /* Now do excludes */
460 fd->signal(BNET_EOD); /* end of data */
461 if (!response(jcr, fd, OKinc, "Include", DISPLAY_ERROR)) {
467 set_jcr_job_status(jcr, JS_ErrorTerminated);
472 static bool send_list_item(JCR *jcr, const char *code, char *item, BSOCK *fd)
482 p++; /* skip over the | */
483 fd->msg = edit_job_codes(jcr, fd->msg, p, "");
484 bpipe = open_bpipe(fd->msg, 0, "r");
487 Jmsg(jcr, M_FATAL, 0, _("Cannot run program: %s. ERR=%s\n"),
491 bstrncpy(buf, code, sizeof(buf));
492 Dmsg1(500, "code=%s\n", buf);
493 optlen = strlen(buf);
494 while (fgets(buf+optlen, sizeof(buf)-optlen, bpipe->rfd)) {
495 fd->msglen = Mmsg(fd->msg, "%s", buf);
496 Dmsg2(500, "Inc/exc len=%d: %s", fd->msglen, fd->msg);
497 if (!bnet_send(fd)) {
498 Jmsg(jcr, M_FATAL, 0, _(">filed: write error on socket\n"));
502 if ((stat=close_bpipe(bpipe)) != 0) {
504 Jmsg(jcr, M_FATAL, 0, _("Error running program: %s. ERR=%s\n"),
505 p, be.bstrerror(stat));
510 p++; /* skip over < */
511 if ((ffd = fopen(p, "rb")) == NULL) {
513 Jmsg(jcr, M_FATAL, 0, _("Cannot open included file: %s. ERR=%s\n"),
517 bstrncpy(buf, code, sizeof(buf));
518 Dmsg1(500, "code=%s\n", buf);
519 optlen = strlen(buf);
520 while (fgets(buf+optlen, sizeof(buf)-optlen, ffd)) {
521 fd->msglen = Mmsg(fd->msg, "%s", buf);
522 if (!bnet_send(fd)) {
523 Jmsg(jcr, M_FATAL, 0, _(">filed: write error on socket\n"));
530 p++; /* skip over \ */
531 /* Note, fall through wanted */
533 pm_strcpy(fd->msg, code);
534 fd->msglen = pm_strcat(fd->msg, p);
535 Dmsg1(500, "Inc/Exc name=%s\n", fd->msg);
537 Jmsg(jcr, M_FATAL, 0, _(">filed: write error on socket\n"));
547 * Send include list to File daemon
549 bool send_include_list(JCR *jcr)
551 BSOCK *fd = jcr->file_bsock;
552 if (jcr->fileset->new_include) {
553 fd->fsend(filesetcmd, jcr->fileset->enable_vss ? " vss=1" : "");
554 return send_fileset(jcr);
561 * Send exclude list to File daemon
562 * Under the new scheme, the Exclude list
563 * is part of the FileSet sent with the
564 * "include_list" above.
566 bool send_exclude_list(JCR *jcr)
571 /* TODO: drop this with runscript.old_proto in bacula 1.42 */
572 static char runbefore[] = "RunBeforeJob %s\n";
573 static char runafter[] = "RunAfterJob %s\n";
574 static char OKRunBefore[] = "2000 OK RunBefore\n";
575 static char OKRunAfter[] = "2000 OK RunAfter\n";
577 int send_runscript_with_old_proto(JCR *jcr, int when, POOLMEM *msg)
580 Dmsg1(120, "bdird: sending old runcommand to fd '%s'\n",msg);
581 if (when & SCRIPT_Before) {
582 bnet_fsend(jcr->file_bsock, runbefore, msg);
583 ret = response(jcr, jcr->file_bsock, OKRunBefore, "ClientRunBeforeJob", DISPLAY_ERROR);
585 bnet_fsend(jcr->file_bsock, runafter, msg);
586 ret = response(jcr, jcr->file_bsock, OKRunAfter, "ClientRunAfterJob", DISPLAY_ERROR);
592 * Send RunScripts to File daemon
593 * 1) We send all runscript to FD, they can be executed Before, After, or twice
594 * 2) Then, we send a "RunBeforeNow" command to the FD to tell him to do the
595 * first run_script() call. (ie ClientRunBeforeJob)
597 int send_runscripts_commands(JCR *jcr)
599 POOLMEM *msg = get_pool_memory(PM_FNAME);
600 BSOCK *fd = jcr->file_bsock;
602 bool launch_before_cmd = false;
603 POOLMEM *ehost = get_pool_memory(PM_FNAME);
606 Dmsg0(120, "bdird: sending runscripts to fd\n");
608 foreach_alist(cmd, jcr->job->RunScripts) {
609 if (cmd->can_run_at_level(jcr->getJobLevel()) && cmd->target) {
610 ehost = edit_job_codes(jcr, ehost, cmd->target, "");
611 Dmsg2(200, "bdird: runscript %s -> %s\n", cmd->target, ehost);
613 if (strcmp(ehost, jcr->client->name()) == 0) {
614 pm_strcpy(msg, cmd->command);
617 Dmsg1(120, "bdird: sending runscripts to fd '%s'\n", cmd->command);
619 /* TODO: remove this with bacula 1.42 */
620 if (cmd->old_proto) {
621 result = send_runscript_with_old_proto(jcr, cmd->when, msg);
624 fd->fsend(runscript, cmd->on_success,
630 result = response(jcr, fd, OKRunScript, "RunScript", DISPLAY_ERROR);
631 launch_before_cmd = true;
638 /* TODO : we have to play with other client */
641 send command to an other client
647 /* Tell the FD to execute the ClientRunBeforeJob */
648 if (launch_before_cmd) {
649 fd->fsend(runbeforenow);
650 if (!response(jcr, fd, OKRunBeforeNow, "RunBeforeNow", DISPLAY_ERROR)) {
654 free_pool_memory(msg);
655 free_pool_memory(ehost);
659 Jmsg(jcr, M_FATAL, 0, _("Client \"%s\" RunScript failed.\n"), ehost);
660 free_pool_memory(msg);
661 free_pool_memory(ehost);
668 * Read the attributes from the File daemon for
669 * a Verify job and store them in the catalog.
671 int get_attributes_and_put_in_catalog(JCR *jcr)
676 char digest[MAXSTRING];
678 fd = jcr->file_bsock;
679 jcr->jr.FirstIndex = 1;
681 /* Start transaction allocates jcr->attr and jcr->ar if needed */
682 db_start_transaction(jcr, jcr->db); /* start transaction if not already open */
685 Dmsg0(120, "bdird: waiting to receive file attributes\n");
686 /* Pickup file attributes and digest */
687 while (!fd->errors && (n = bget_dirmsg(fd)) > 0) {
691 char Digest[MAXSTRING]; /* either Verify opts or MD5/SHA1 digest */
693 if ((len = sscanf(fd->msg, "%ld %d %s", &file_index, &stream, Digest)) != 3) {
694 Jmsg(jcr, M_FATAL, 0, _("<filed: bad attributes, expected 3 fields got %d\n"
695 "msglen=%d msg=%s\n"), len, fd->msglen, fd->msg);
696 set_jcr_job_status(jcr, JS_ErrorTerminated);
700 /* The following three fields were sscanf'ed above so skip them */
701 skip_nonspaces(&p); /* skip FileIndex */
703 skip_nonspaces(&p); /* skip Stream */
705 skip_nonspaces(&p); /* skip Opts_Digest */
706 p++; /* skip space */
707 Dmsg1(dbglvl, "Stream=%d\n", stream);
708 if (stream == STREAM_UNIX_ATTRIBUTES || stream == STREAM_UNIX_ATTRIBUTES_EX) {
709 if (jcr->cached_attribute) {
710 Dmsg3(dbglvl, "Cached attr. Stream=%d fname=%s\n", ar->Stream, ar->fname,
712 if (!db_create_file_attributes_record(jcr, jcr->db, ar)) {
713 Jmsg1(jcr, M_FATAL, 0, _("Attribute create error. %s"), db_strerror(jcr->db));
716 /* Any cached attr is flushed so we can reuse jcr->attr and jcr->ar */
717 fn = jcr->fname = check_pool_memory_size(jcr->fname, fd->msglen);
719 *fn++ = *p++; /* copy filename */
721 *fn = *p++; /* term filename and point p to attribs */
722 pm_strcpy(jcr->attr, p); /* save attributes */
724 jcr->FileIndex = file_index;
725 ar->attr = jcr->attr;
726 ar->fname = jcr->fname;
727 ar->FileIndex = file_index;
730 ar->JobId = jcr->JobId;
731 ar->ClientId = jcr->ClientId;
735 ar->DigestType = CRYPTO_DIGEST_NONE;
736 jcr->cached_attribute = true;
738 Dmsg2(dbglvl, "dird<filed: stream=%d %s\n", stream, jcr->fname);
739 Dmsg1(dbglvl, "dird<filed: attr=%s\n", ar->attr);
740 jcr->FileId = ar->FileId;
742 * First, get STREAM_UNIX_ATTRIBUTES and fill ATTR_DBR structure
743 * Next, we CAN have a CRYPTO_DIGEST, so we fill ATTR_DBR with it (or not)
744 * When we get a new STREAM_UNIX_ATTRIBUTES, we known that we can add file to the catalog
745 * At the end, we have to add the last file
747 } else if (crypto_digest_stream_type(stream) != CRYPTO_DIGEST_NONE) {
748 if (jcr->FileIndex != (uint32_t)file_index) {
749 Jmsg3(jcr, M_ERROR, 0, _("%s index %d not same as attributes %d\n"),
750 stream_to_ascii(stream), file_index, jcr->FileIndex);
754 ar->DigestType = crypto_digest_stream_type(stream);
755 db_escape_string(jcr, jcr->db, digest, Digest, strlen(Digest));
756 Dmsg4(dbglvl, "stream=%d DigestLen=%d Digest=%s type=%d\n", stream,
757 strlen(digest), digest, ar->DigestType);
759 jcr->jr.JobFiles = jcr->JobFiles = file_index;
760 jcr->jr.LastIndex = file_index;
762 if (is_bnet_error(fd)) {
763 Jmsg1(jcr, M_FATAL, 0, _("<filed: Network error getting attributes. ERR=%s\n"),
767 if (jcr->cached_attribute) {
768 Dmsg3(dbglvl, "Cached attr with digest. Stream=%d fname=%s attr=%s\n", ar->Stream,
769 ar->fname, ar->attr);
770 if (!db_create_file_attributes_record(jcr, jcr->db, ar)) {
771 Jmsg1(jcr, M_FATAL, 0, _("Attribute create error. %s"), db_strerror(jcr->db));
773 jcr->cached_attribute = false;
775 set_jcr_job_status(jcr, JS_Terminated);