* We get here because the Director has initiated a Job with
* the Storage daemon, then done the same with the File daemon,
* then when the Storage daemon receives a proper connection from
- * the File daemon, control is passed here to handle the
+ * the File daemon, control is passed here to handle the
* subsequent File daemon commands.
*
* Version $Id$
- *
+ *
*/
/*
Copyright (C) 2000-2004 Kern Sibbald and John Walker
bool (*func)(JCR *jcr);
};
-/*
+/*
* The following are the recognized commands from the File daemon
*/
static struct s_cmds fd_cmds[] = {
/* Information sent to the Director */
static char Job_start[] = "3010 Job %s start\n";
-static char Job_end[] =
+static char Job_end[] =
"3099 Job %s end JobStatus=%d JobFiles=%d JobBytes=%s\n";
/*
fd->jcr = jcr;
dir->jcr = jcr;
Dmsg1(120, "Start run Job=%s\n", jcr->Job);
- bnet_fsend(dir, Job_start, jcr->Job);
+ bnet_fsend(dir, Job_start, jcr->Job);
jcr->start_time = time(NULL);
jcr->run_time = jcr->start_time;
set_jcr_job_status(jcr, JS_Running);
}
}
if (!found) { /* command not found */
- Dmsg1(110, "<filed: Command not found: %s\n", fd->msg);
+ Dmsg1(110, "<filed: Command not found: %s\n", fd->msg);
bnet_fsend(fd, ferrmsg);
break;
}
return;
}
-
+
/*
* Append Data command
* Open Data Channel and receive Data for archiving
}
-/*
+/*
* Append Open session command
*
*/
/*
* Append Close session command
- * Close the append session and send back Statistics
+ * Close the append session and send back Statistics
* (need to fix statistics)
*/
static bool append_close_session(JCR *jcr)
Dmsg1(120, ">filed: %s", fd->msg);
bnet_sig(fd, BNET_EOD); /* send EOD to File daemon */
-
+
Dmsg1(110, "Append close session: %s\n", dev_name(jcr->device->dev));
jcr->session_opened = false;
/*
* Read Data command
- * Open Data Channel, read the data from
+ * Open Data Channel, read the data from
* the archive device and send to File
* daemon.
*/
}
}
-/*
+/*
* Read Open session command
*
* We need to scan for the parameters of the job
return false;
}
Dmsg4(100, "read_open_session got: JobId=%d Vol=%s VolSessId=%ld VolSessT=%ld\n",
- jcr->JobId, jcr->dcr->VolumeName, jcr->read_VolSessionId,
+ jcr->JobId, jcr->dcr->VolumeName, jcr->read_VolSessionId,
jcr->read_VolSessionTime);
Dmsg4(100, " StartF=%ld EndF=%ld StartB=%ld EndB=%ld\n",
jcr->read_StartFile, jcr->read_EndFile, jcr->read_StartBlock,
Dmsg1(160, ">filed: %s\n", fd->msg);
bnet_sig(fd, BNET_EOD); /* send EOD to File daemon */
-
+
jcr->session_opened = FALSE;
return true;
}