2 * This file handles commands from the File daemon.
4 * We get here because the Director has initiated a Job with
5 * the Storage daemon, then done the same with the File daemon,
6 * then when the Storage daemon receives a proper connection from
7 * the File daemon, control is passed here to handle the
8 * subsequent File daemon commands.
14 Copyright (C) 2000, 2001, 2002 Kern Sibbald and John Walker
16 This program is free software; you can redistribute it and/or
17 modify it under the terms of the GNU General Public License as
18 published by the Free Software Foundation; either version 2 of
19 the License, or (at your option) any later version.
21 This program is distributed in the hope that it will be useful,
22 but WITHOUT ANY WARRANTY; without even the implied warranty of
23 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
24 General Public License for more details.
26 You should have received a copy of the GNU General Public
27 License along with this program; if not, write to the Free
28 Software Foundation, Inc., 59 Temple Place - Suite 330, Boston,
36 /* Imported variables */
39 /* Static variables */
40 static char ferrmsg[] = "3900 Invalid command\n";
42 /* Imported functions */
43 extern int do_append_data(JCR *jcr);
44 extern int do_read_data(JCR *jcr);
46 /* Forward referenced functions */
49 /* Forward referenced FD commands */
50 static int append_open_session(JCR *jcr);
51 static int append_close_session(JCR *jcr);
52 static int append_data_cmd(JCR *jcr);
53 static int append_end_session(JCR *jcr);
54 static int read_open_session(JCR *jcr);
55 static int read_data_cmd(JCR *jcr);
56 static int read_close_session(JCR *jcr);
57 static int bootstrap_cmd(JCR *jcr);
61 int (*func)(JCR *jcr);
65 * The following are the recognized commands from the File daemon
67 static struct s_cmds fd_cmds[] = {
68 {"append open", append_open_session},
69 {"append data", append_data_cmd},
70 {"append end", append_end_session},
71 {"append close", append_close_session},
72 {"read open", read_open_session},
73 {"read data", read_data_cmd},
74 {"read close", read_close_session},
75 {"bootstrap", bootstrap_cmd},
76 {NULL, NULL} /* list terminator */
79 /* Commands from the File daemon that require additional scanning */
80 static char read_open[] = "read open session = %s %ld %ld %ld %ld %ld %ld\n";
82 /* Responses sent to the File daemon */
83 static char NO_open[] = "3901 Error session already open\n";
84 static char NOT_opened[] = "3902 Error session not opened\n";
85 static char OK_end[] = "3000 OK end\n";
86 static char OK_close[] = "3000 OK close Volumes = %d\n";
87 static char OK_open[] = "3000 OK open ticket = %d\n";
88 static char OK_append[] = "3000 OK append data\n";
89 static char ERROR_append[] = "3903 Error append data\n";
90 static char OK_bootstrap[] = "3000 OK bootstrap\n";
91 static char ERROR_bootstrap[] = "3904 Error bootstrap\n";
93 /* Information sent to the Director */
94 static char Job_start[] = "3010 Job %s start\n";
95 static char Job_end[] =
96 "3099 Job %s end JobStatus=%d JobFiles=%d JobBytes=%s\n";
99 * Run a File daemon Job -- File daemon already authorized
101 * Basic task here is:
102 * - Read a command from the File daemon
106 void run_job(JCR *jcr)
109 BSOCK *fd = jcr->file_bsock;
110 BSOCK *dir = jcr->dir_bsock;
114 fd->jcr = (void *)jcr;
115 dir->jcr = (void *)jcr;
116 Dmsg1(120, "Start run Job=%s\n", jcr->Job);
117 bnet_fsend(dir, Job_start, jcr->Job);
118 time(&jcr->start_time);
119 jcr->run_time = jcr->start_time;
120 jcr->JobStatus = JS_Running;
121 dir_send_job_status(jcr); /* update director */
122 for (quit=0; !quit;) {
124 /* Read command coming from the File daemon */
125 if (bnet_recv(fd) <= 0) {
126 break; /* connection terminated */
128 Dmsg1(110, "<filed: %s", fd->msg);
130 for (i=0; fd_cmds[i].cmd; i++) {
131 if (strncmp(fd_cmds[i].cmd, fd->msg, strlen(fd_cmds[i].cmd)) == 0) {
132 found = 1; /* indicate command found */
133 if (!fd_cmds[i].func(jcr)) { /* do command */
134 jcr->JobStatus = JS_ErrorTerminated;
140 if (!found) { /* command not found */
141 Dmsg1(110, "<filed: Command not found: %s\n", fd->msg);
142 bnet_fsend(fd, ferrmsg);
146 time(&jcr->end_time);
147 if (!job_cancelled(jcr)) {
148 jcr->JobStatus = JS_Terminated;
150 bnet_fsend(dir, Job_end, jcr->Job, jcr->JobStatus, jcr->JobFiles,
151 edit_uint64(jcr->JobBytes, ec1));
153 bnet_sig(dir, BNET_EOD); /* send EOD to Director daemon */
159 * Append Data command
160 * Open Data Channel and receive Data for archiving
161 * Write the Data to the archive device
163 static int append_data_cmd(JCR *jcr)
165 BSOCK *fd = jcr->file_bsock;
167 Dmsg1(120, "Append data: %s", fd->msg);
168 if (jcr->session_opened) {
169 Dmsg1(110, "<bfiled: %s", fd->msg);
170 if (do_append_data(jcr)) {
171 bnet_fsend(fd, OK_append);
172 jcr->JobType = JT_BACKUP;
175 bnet_fsend(fd, ERROR_append);
179 bnet_fsend(fd, NOT_opened);
184 static int append_end_session(JCR *jcr)
186 BSOCK *fd = jcr->file_bsock;
188 Dmsg1(120, "store<file: %s", fd->msg);
189 if (!jcr->session_opened) {
190 bnet_fsend(fd, NOT_opened);
193 return bnet_fsend(fd, OK_end);
198 * Append Open session command
201 static int append_open_session(JCR *jcr)
203 BSOCK *fd = jcr->file_bsock;
205 Dmsg1(120, "Append open session: %s", fd->msg);
206 if (jcr->session_opened) {
207 bnet_fsend(fd, NO_open);
211 Dmsg1(110, "Append open session: %s\n", dev_name(jcr->device->dev));
212 jcr->session_opened = TRUE;
214 /* Send "Ticket" to File Daemon */
215 bnet_fsend(fd, OK_open, jcr->VolSessionId);
216 Dmsg1(110, ">filed: %s", fd->msg);
222 * Append Close session command
223 * Close the append session and send back Statistics
224 * (need to fix statistics)
226 static int append_close_session(JCR *jcr)
228 BSOCK *fd = jcr->file_bsock;
230 Dmsg1(120, "<filed: %s\n", fd->msg);
231 if (!jcr->session_opened) {
232 bnet_fsend(fd, NOT_opened);
235 /* Send final statistics to File daemon */
236 bnet_fsend(fd, OK_close, jcr->NumVolumes);
237 Dmsg1(160, ">filed: %s\n", fd->msg);
239 bnet_sig(fd, BNET_EOD); /* send EOD to File daemon */
241 Dmsg1(110, "Append close session: %s\n", dev_name(jcr->device->dev));
243 if (jcr->JobStatus != JS_ErrorTerminated) {
244 jcr->JobStatus = JS_Terminated;
246 jcr->session_opened = FALSE;
252 * Open Data Channel, read the data from
253 * the archive device and send to File
256 static int read_data_cmd(JCR *jcr)
258 BSOCK *fd = jcr->file_bsock;
260 Dmsg1(120, "Read data: %s\n", fd->msg);
261 if (jcr->session_opened) {
262 Dmsg1(120, "<bfiled: %s", fd->msg);
263 return do_read_data(jcr);
265 bnet_fsend(fd, NOT_opened);
271 * Read Open session command
273 * We need to scan for the parameters of the job
276 static int read_open_session(JCR *jcr)
278 BSOCK *fd = jcr->file_bsock;
280 Dmsg1(120, "%s\n", fd->msg);
281 if (jcr->session_opened) {
282 bnet_fsend(fd, NO_open);
286 if (sscanf(fd->msg, read_open, jcr->VolumeName, &jcr->read_VolSessionId,
287 &jcr->read_VolSessionTime, &jcr->read_StartFile, &jcr->read_EndFile,
288 &jcr->read_StartBlock, &jcr->read_EndBlock) == 7) {
289 if (jcr->session_opened) {
290 bnet_fsend(fd, NOT_opened);
293 Dmsg4(100, "read_open_session got: JobId=%d Vol=%s VolSessId=%ld VolSessT=%ld\n",
294 jcr->JobId, jcr->VolumeName, jcr->read_VolSessionId,
295 jcr->read_VolSessionTime);
296 Dmsg4(100, " StartF=%ld EndF=%ld StartB=%ld EndB=%ld\n",
297 jcr->read_StartFile, jcr->read_EndFile, jcr->read_StartBlock,
301 Dmsg1(110, "Read open session: %s\n", dev_name(jcr->device->dev));
303 jcr->session_opened = TRUE;
304 jcr->JobType = JT_RESTORE;
306 /* Send "Ticket" to File Daemon */
307 bnet_fsend(fd, OK_open, jcr->VolSessionId);
308 Dmsg1(110, ">filed: %s", fd->msg);
313 static int bootstrap_cmd(JCR *jcr)
315 BSOCK *fd = jcr->file_bsock;
316 POOLMEM *fname = get_pool_memory(PM_FNAME);
319 if (jcr->RestoreBootstrap) {
320 unlink(jcr->RestoreBootstrap);
321 free_pool_memory(jcr->RestoreBootstrap);
323 Mmsg(&fname, "%s/%s.%s.bootstrap", me->working_directory, me->hdr.name,
325 Dmsg1(400, "bootstrap=%s\n", fname);
326 jcr->RestoreBootstrap = fname;
327 bs = fopen(fname, "a+"); /* create file */
329 Jmsg(jcr, M_FATAL, 0, _("Could not create bootstrap file %s: ERR=%s\n"),
330 jcr->RestoreBootstrap, strerror(errno));
333 while (bnet_recv(fd) > 0) {
334 Dmsg1(400, "stored<filed: bootstrap file %s\n", fd->msg);
338 jcr->bsr = parse_bsr(jcr, jcr->RestoreBootstrap);
340 Jmsg(jcr, M_FATAL, 0, _("Error parsing bootstrap file.\n"));
343 if (debug_level > 20) {
346 return bnet_fsend(fd, OK_bootstrap);
349 unlink(jcr->RestoreBootstrap);
350 free_pool_memory(jcr->RestoreBootstrap);
351 jcr->RestoreBootstrap = NULL;
352 bnet_fsend(fd, ERROR_bootstrap);
359 * Read Close session command
360 * Close the read session
362 static int read_close_session(JCR *jcr)
364 BSOCK *fd = jcr->file_bsock;
366 Dmsg1(120, "Read close session: %s\n", fd->msg);
367 if (!jcr->session_opened) {
368 bnet_fsend(fd, NOT_opened);
371 /* Send final statistics to File daemon */
372 bnet_fsend(fd, OK_close);
373 Dmsg1(160, ">filed: %s\n", fd->msg);
375 bnet_sig(fd, BNET_EOD); /* send EOD to File daemon */
377 jcr->session_opened = FALSE;