]> git.sur5r.net Git - bacula/bacula/blob - bacula/src/stored/askdir.c
- This version has a new DIR -- SD protocol. Both
[bacula/bacula] / bacula / src / stored / askdir.c
1 /*
2  *  Subroutines to handle Catalog reqests sent to the Director
3  *   Reqests/commands from the Director are handled in dircmd.c
4  *
5  *   Kern Sibbald, December 2000
6  *
7  *   Version $Id$
8  */
9 /*
10    Copyright (C) 2000-2005 Kern Sibbald
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"                   /* pull in global headers */
30 #include "stored.h"                   /* pull in Storage Deamon headers */
31
32 /* Requests sent to the Director */
33 static char Find_media[]   = "CatReq Job=%s FindMedia=%d pool_name=%s media_type=%s\n";
34 static char Get_Vol_Info[] = "CatReq Job=%s GetVolInfo VolName=%s write=%d\n";
35 static char Update_media[] = "CatReq Job=%s UpdateMedia VolName=%s"
36    " VolJobs=%u VolFiles=%u VolBlocks=%u VolBytes=%s VolMounts=%u"
37    " VolErrors=%u VolWrites=%u MaxVolBytes=%s EndTime=%d VolStatus=%s"
38    " Slot=%d relabel=%d InChanger=%d VolReadTime=%s VolWriteTime=%s"
39    " VolParts=%u\n";
40 static char Create_job_media[] = "CatReq Job=%s CreateJobMedia"
41    " FirstIndex=%u LastIndex=%u StartFile=%u EndFile=%u"
42    " StartBlock=%u EndBlock=%u\n";
43 static char FileAttributes[] = "UpdCat Job=%s FileAttributes ";
44 static char Job_status[]     = "Status Job=%s JobStatus=%d\n";
45
46
47
48 /* Responses received from the Director */
49 static char OK_media[] = "1000 OK VolName=%127s VolJobs=%u VolFiles=%u"
50    " VolBlocks=%u VolBytes=%" lld " VolMounts=%u VolErrors=%u VolWrites=%u"
51    " MaxVolBytes=%" lld " VolCapacityBytes=%" lld " VolStatus=%20s"
52    " Slot=%d MaxVolJobs=%u MaxVolFiles=%u InChanger=%d"
53    " VolReadTime=%" lld " VolWriteTime=%" lld " EndFile=%u EndBlock=%u"
54    " VolParts=%u LabelType=%d";
55
56
57 static char OK_create[] = "1000 OK CreateJobMedia\n";
58
59 #ifdef needed
60
61 static char Device_update[] = "DevUpd Job=%s device=%s "
62    "append=%d read=%d num_writers=%d "
63    "open=%d labeled=%d offline=%d "
64    "reserved=%d max_writers=%d "
65    "autoselect=%d autochanger=%d "
66    "changer_name=%s media_type=%s volume_name=%s\n";
67
68
69 /* Send update information about a device to Director */
70 bool dir_update_device(JCR *jcr, DEVICE *dev)
71 {
72    BSOCK *dir = jcr->dir_bsock;
73    POOL_MEM dev_name, VolumeName, MediaType, ChangerName;
74    DEVRES *device = dev->device;
75    bool ok;
76    
77    pm_strcpy(dev_name, device->hdr.name);
78    bash_spaces(dev_name);
79    if (dev->is_labeled()) {
80       pm_strcpy(VolumeName, dev->VolHdr.VolName);
81    } else {
82       pm_strcpy(VolumeName, "*");
83    }
84    bash_spaces(VolumeName);
85    pm_strcpy(MediaType, device->media_type);
86    bash_spaces(MediaType);
87    if (device->changer_res) {
88       pm_strcpy(ChangerName, device->changer_res->hdr.name);
89       bash_spaces(ChangerName);
90    } else {
91       pm_strcpy(ChangerName, "*");
92    }
93    ok =bnet_fsend(dir, Device_update, 
94       jcr->Job,
95       dev_name.c_str(),
96       dev->can_append()!=0,
97       dev->can_read()!=0, dev->num_writers, 
98       dev->is_open()!=0, dev->is_labeled()!=0,
99       dev->is_offline()!=0, dev->reserved_device, 
100       dev->is_tape()?100000:1,
101       dev->autoselect, 0, 
102       ChangerName.c_str(), MediaType.c_str(), VolumeName.c_str());
103    Dmsg1(100, ">dird: %s\n", dir->msg);
104    return ok;
105 }
106
107 bool dir_update_changer(JCR *jcr, AUTOCHANGER *changer)
108 {
109    BSOCK *dir = jcr->dir_bsock;
110    POOL_MEM dev_name, MediaType;
111    DEVRES *device;
112    bool ok;
113
114    pm_strcpy(dev_name, changer->hdr.name);
115    bash_spaces(dev_name);
116    device = (DEVRES *)changer->device->first();
117    pm_strcpy(MediaType, device->media_type);
118    bash_spaces(MediaType);
119    /* This is mostly to indicate that we are here */
120    ok = bnet_fsend(dir, Device_update,
121       jcr->Job,
122       dev_name.c_str(),         /* Changer name */
123       0, 0, 0,                  /* append, read, num_writers */
124       0, 0, 0,                  /* is_open, is_labeled, offline */
125       0, 0,                     /* reserved, max_writers */
126       0,                        /* Autoselect */
127       changer->device->size(),  /* Number of devices */
128       "0",                      /* PoolId */
129       "*",                      /* ChangerName */
130       MediaType.c_str(),        /* MediaType */
131       "*");                     /* VolName */
132    Dmsg1(100, ">dird: %s\n", dir->msg);
133    return ok;
134 }
135 #endif
136
137
138 /*
139  * Send current JobStatus to Director
140  */
141 bool dir_send_job_status(JCR *jcr)
142 {
143    return bnet_fsend(jcr->dir_bsock, Job_status, jcr->Job, jcr->JobStatus);
144 }
145
146 /*
147  * Common routine for:
148  *   dir_get_volume_info()
149  * and
150  *   dir_find_next_appendable_volume()
151  *
152  *  Returns: true  on success and vol info in dcr->VolCatInfo
153  *           false on failure
154  */
155 static bool do_get_volume_info(DCR *dcr)
156 {
157     JCR *jcr = dcr->jcr;
158     BSOCK *dir = jcr->dir_bsock;
159     VOLUME_CAT_INFO vol;
160     int n;
161     int InChanger;
162
163     dcr->VolumeName[0] = 0;           /* No volume */
164     if (bnet_recv(dir) <= 0) {
165        Dmsg0(200, "getvolname error bnet_recv\n");
166        Mmsg(jcr->errmsg, _("Network error on bnet_recv in req_vol_info.\n"));
167        return false;
168     }
169     memset(&vol, 0, sizeof(vol));
170     Dmsg1(100, "<dird %s", dir->msg);
171     n = sscanf(dir->msg, OK_media, vol.VolCatName,
172                &vol.VolCatJobs, &vol.VolCatFiles,
173                &vol.VolCatBlocks, &vol.VolCatBytes,
174                &vol.VolCatMounts, &vol.VolCatErrors,
175                &vol.VolCatWrites, &vol.VolCatMaxBytes,
176                &vol.VolCatCapacityBytes, vol.VolCatStatus,
177                &vol.Slot, &vol.VolCatMaxJobs, &vol.VolCatMaxFiles,
178                &InChanger, &vol.VolReadTime, &vol.VolWriteTime,
179                &vol.EndFile, &vol.EndBlock, &vol.VolCatParts,
180                &vol.LabelType);
181     if (n != 21) {
182        Dmsg2(100, "Bad response from Dir fields=%d: %s\n", n, dir->msg);
183        Mmsg(jcr->errmsg, _("Error getting Volume info: %s\n"), dir->msg);
184        return false;
185     }
186     vol.InChanger = InChanger;        /* bool in structure */
187     unbash_spaces(vol.VolCatName);
188     bstrncpy(dcr->VolumeName, vol.VolCatName, sizeof(dcr->VolumeName));
189     memcpy(&dcr->VolCatInfo, &vol, sizeof(dcr->VolCatInfo));
190
191     Dmsg2(300, "do_reqest_vol_info got slot=%d Volume=%s\n",
192           vol.Slot, vol.VolCatName);
193     return true;
194 }
195
196
197 /*
198  * Get Volume info for a specific volume from the Director's Database
199  *
200  * Returns: true  on success   (not Director guarantees that Pool and MediaType
201  *                             are correct and VolStatus==Append or
202  *                             VolStatus==Recycle)
203  *          false on failure
204  *
205  *          Volume information returned in jcr
206  */
207 bool dir_get_volume_info(DCR *dcr, enum get_vol_info_rw writing)
208 {
209     JCR *jcr = dcr->jcr;
210     BSOCK *dir = jcr->dir_bsock;
211
212     bstrncpy(dcr->VolCatInfo.VolCatName, dcr->VolumeName, sizeof(dcr->VolCatInfo.VolCatName));
213     bash_spaces(dcr->VolCatInfo.VolCatName);
214     bnet_fsend(dir, Get_Vol_Info, jcr->Job, dcr->VolCatInfo.VolCatName,
215        writing==GET_VOL_INFO_FOR_WRITE?1:0);
216     Dmsg1(100, ">dird: %s", dir->msg);
217     return do_get_volume_info(dcr);
218 }
219
220
221
222 /*
223  * Get info on the next appendable volume in the Director's database
224  * Returns: true  on success
225  *          false on failure
226  *
227  *          Volume information returned in dcr
228  *
229  */
230 bool dir_find_next_appendable_volume(DCR *dcr)
231 {
232     JCR *jcr = dcr->jcr;
233     BSOCK *dir = jcr->dir_bsock;
234     JCR *njcr;
235
236     Dmsg0(200, "dir_find_next_appendable_volume\n");
237     /*
238      * Try the three oldest or most available volumes.  Note,
239      *   the most available could already be mounted on another
240      *   drive, so we continue looking for a not in use Volume.
241      */
242     for (int vol_index=1;  vol_index < 3; vol_index++) {
243        bash_spaces(dcr->media_type);
244        bash_spaces(dcr->pool_name);
245        bnet_fsend(dir, Find_media, jcr->Job, vol_index, dcr->pool_name, dcr->media_type);
246        unbash_spaces(dcr->media_type);
247        unbash_spaces(dcr->pool_name);
248        Dmsg1(100, ">dird: %s", dir->msg);
249        if (do_get_volume_info(dcr)) {
250           Dmsg2(300, "JobId=%d got possible Vol=%s\n", jcr->JobId, dcr->VolumeName);
251           bool found = false;
252           /*
253            * Walk through all jobs and see if the volume is
254            *  already mounted. If so, try a different one.
255            * This would be better done by walking through
256            *  all the devices.
257            */
258           lock_jcr_chain();
259           foreach_jcr(njcr) {
260              if (jcr == njcr) {
261                 free_locked_jcr(njcr);
262                 continue;             /* us */
263              }
264              Dmsg2(300, "Compare to JobId=%d using Vol=%s\n", njcr->JobId, njcr->dcr->VolumeName);
265              if (njcr->dcr && strcmp(dcr->VolumeName, njcr->dcr->VolumeName) == 0) {
266                 found = true;
267                 Dmsg1(400, "Vol in use by JobId=%u\n", njcr->JobId);
268                 free_locked_jcr(njcr);
269                 break;
270              }
271              free_locked_jcr(njcr);
272           }
273           unlock_jcr_chain();
274           if (!found) {
275              Dmsg0(400, "dir_find_next_appendable_volume return true\n");
276              return true;             /* Got good Volume */
277           }
278        } else {
279           Dmsg0(200, "No volume info, return false\n");
280           return false;
281        }
282     }
283     Dmsg0(400, "dir_find_next_appendable_volume return true\n");
284     return true;
285 }
286
287
288 /*
289  * After writing a Volume, send the updated statistics
290  * back to the director. The information comes from the
291  * dev record.
292  */
293 bool dir_update_volume_info(DCR *dcr, bool label)
294 {
295    JCR *jcr = dcr->jcr;
296    BSOCK *dir = jcr->dir_bsock;
297    DEVICE *dev = dcr->dev;
298    time_t LastWritten = time(NULL);
299    char ed1[50], ed2[50], ed3[50], ed4[50];
300    VOLUME_CAT_INFO *vol = &dev->VolCatInfo;
301    int InChanger;
302    POOL_MEM VolumeName;
303
304    if (vol->VolCatName[0] == 0) {
305       Jmsg0(jcr, M_FATAL, 0, _("NULL Volume name. This shouldn't happen!!!\n"));
306       Pmsg0(000, "NULL Volume name. This shouldn't happen!!!\n");
307       return false;
308    }
309    if (dev->can_read()) {
310       Jmsg0(jcr, M_FATAL, 0, _("Attempt to update_volume_info in read mode!!!\n"));
311       Pmsg0(000, "Attempt to update_volume_info in read mode!!!\n");
312       return false;
313    }
314
315    Dmsg1(300, "Update cat VolFiles=%d\n", dev->file);
316    /* Just labeled or relabeled the tape */
317    if (label) {
318       bstrncpy(vol->VolCatStatus, "Append", sizeof(vol->VolCatStatus));
319       vol->VolCatBytes = 1;           /* indicates tape labeled */
320    }
321    pm_strcpy(VolumeName, vol->VolCatName);
322    bash_spaces(VolumeName);
323    InChanger = vol->InChanger;
324    bnet_fsend(dir, Update_media, jcr->Job,
325       VolumeName.c_str(), vol->VolCatJobs, vol->VolCatFiles,
326       vol->VolCatBlocks, edit_uint64(vol->VolCatBytes, ed1),
327       vol->VolCatMounts, vol->VolCatErrors,
328       vol->VolCatWrites, edit_uint64(vol->VolCatMaxBytes, ed2),
329       LastWritten, vol->VolCatStatus, vol->Slot, label,
330       InChanger,                      /* bool in structure */
331       edit_uint64(vol->VolReadTime, ed3),
332       edit_uint64(vol->VolWriteTime, ed4),
333       vol->VolCatParts);
334     Dmsg1(100, ">dird: %s", dir->msg);
335
336    if (!do_get_volume_info(dcr)) {
337       Jmsg(jcr, M_FATAL, 0, "%s", jcr->errmsg);
338       Pmsg2(000, "Didn't get vol info vol=%s: ERR=%s", 
339          vol->VolCatName, jcr->errmsg);
340       return false;
341    }
342    Dmsg1(420, "get_volume_info(): %s", dir->msg);
343    /* Update dev Volume info in case something changed (e.g. expired) */
344    memcpy(&dev->VolCatInfo, &dcr->VolCatInfo, sizeof(dev->VolCatInfo));
345    return true;
346 }
347
348 /*
349  * After writing a Volume, create the JobMedia record.
350  */
351 bool dir_create_jobmedia_record(DCR *dcr)
352 {
353    JCR *jcr = dcr->jcr;
354    BSOCK *dir = jcr->dir_bsock;
355
356    if (!dcr->WroteVol) {
357       return true;                    /* nothing written to tape */
358    }
359
360    dcr->WroteVol = false;
361    bnet_fsend(dir, Create_job_media, jcr->Job,
362       dcr->VolFirstIndex, dcr->VolLastIndex,
363       dcr->StartFile, dcr->EndFile,
364       dcr->StartBlock, dcr->EndBlock);
365     Dmsg1(100, ">dird: %s", dir->msg);
366    if (bnet_recv(dir) <= 0) {
367       Dmsg0(190, "create_jobmedia error bnet_recv\n");
368       Jmsg(jcr, M_FATAL, 0, _("Error creating JobMedia record: ERR=%s\n"),
369            bnet_strerror(dir));
370       return false;
371    }
372    Dmsg1(100, "<dir: %s", dir->msg);
373    if (strcmp(dir->msg, OK_create) != 0) {
374       Dmsg1(130, "Bad response from Dir: %s\n", dir->msg);
375       Jmsg(jcr, M_FATAL, 0, _("Error creating JobMedia record: %s\n"), dir->msg);
376       return false;
377    }
378    return true;
379 }
380
381
382 /*
383  * Update File Attribute data
384  */
385 bool dir_update_file_attributes(DCR *dcr, DEV_RECORD *rec)
386 {
387    JCR *jcr = dcr->jcr;
388    BSOCK *dir = jcr->dir_bsock;
389    ser_declare;
390
391 #ifdef NO_ATTRIBUTES_TEST
392    return true;
393 #endif
394
395    dir->msglen = sprintf(dir->msg, FileAttributes, jcr->Job);
396    dir->msg = check_pool_memory_size(dir->msg, dir->msglen +
397                 sizeof(DEV_RECORD) + rec->data_len);
398    ser_begin(dir->msg + dir->msglen, 0);
399    ser_uint32(rec->VolSessionId);
400    ser_uint32(rec->VolSessionTime);
401    ser_int32(rec->FileIndex);
402    ser_int32(rec->Stream);
403    ser_uint32(rec->data_len);
404    ser_bytes(rec->data, rec->data_len);
405    dir->msglen = ser_length(dir->msg);
406    Dmsg1(1800, ">dird: %s\n", dir->msg);    /* Attributes */
407    return bnet_send(dir);
408 }
409
410
411 /*
412  *   Request the sysop to create an appendable volume
413  *
414  *   Entered with device blocked.
415  *   Leaves with device blocked.
416  *
417  *   Returns: true  on success (operator issues a mount command)
418  *            false on failure
419  *              Note, must create dev->errmsg on error return.
420  *
421  *    On success, dcr->VolumeName and dcr->VolCatInfo contain
422  *      information on suggested volume, but this may not be the
423  *      same as what is actually mounted.
424  *
425  *    When we return with success, the correct tape may or may not
426  *      actually be mounted. The calling routine must read it and
427  *      verify the label.
428  */
429 bool dir_ask_sysop_to_create_appendable_volume(DCR *dcr)
430 {
431    int stat = 0, jstat;
432    bool unmounted;
433    bool first = true;
434    DEVICE *dev = dcr->dev;
435    JCR *jcr = dcr->jcr;
436
437    Dmsg0(400, "enter dir_ask_sysop_to_create_appendable_volume\n");
438    ASSERT(dev->dev_blocked);
439    for ( ;; ) {
440       if (job_canceled(jcr)) {
441          Mmsg(dev->errmsg,
442               _("Job %s canceled while waiting for mount on Storage Device \"%s\".\n"),
443               jcr->Job, dev->print_name());
444          Jmsg(jcr, M_INFO, 0, "%s", dev->errmsg);
445          return false;
446       }
447       /* First pass, we *know* there are no appendable volumes, so no need to call */
448       if (!first && dir_find_next_appendable_volume(dcr)) { /* get suggested volume */
449          unmounted = (dev->dev_blocked == BST_UNMOUNTED) ||
450                      (dev->dev_blocked == BST_UNMOUNTED_WAITING_FOR_SYSOP);
451          /*
452           * If we have a valid volume name and we are not
453           *   removable media, return now, or if we have a
454           *   Slot for an autochanger, otherwise wait
455           *   for the operator to mount the media.
456           */
457          if (!unmounted && ((dcr->VolumeName[0] && !dev_cap(dev, CAP_REM) &&
458                 dev_cap(dev, CAP_LABEL)) ||
459                  (dcr->VolumeName[0] && dcr->VolCatInfo.Slot))) {
460             Dmsg0(400, "Return 1 from mount without wait.\n");
461             return true;
462          }
463          jstat = JS_WaitMount;
464          if (!dev->poll) {
465             Jmsg(jcr, M_MOUNT, 0, _(
466 "Please mount Volume \"%s\" on Storage Device %s for Job %s\n"
467 "Use \"mount\" command to release Job.\n"),
468               dcr->VolumeName, dev->print_name(), jcr->Job);
469             Dmsg3(400, "Mount %s on %s for Job %s\n",
470                   dcr->VolumeName, dcr->dev_name, jcr->Job);
471          }
472       } else {
473          jstat = JS_WaitMedia;
474          if (!dev->poll) {
475             Jmsg(jcr, M_MOUNT, 0, _(
476 "Job %s waiting. Cannot find any appendable volumes.\n"
477 "Please use the \"label\"  command to create a new Volume for:\n"
478 "    Storage:      %s\n"
479 "    Media type:   %s\n"
480 "    Pool:         %s\n"),
481                jcr->Job,
482                dev->print_name(),
483                dcr->media_type,
484                dcr->pool_name);
485          }
486       }
487       first = false;
488
489       jcr->JobStatus = jstat;
490       dir_send_job_status(jcr);
491
492       stat = wait_for_sysop(dcr);
493       if (dev->poll) {
494          Dmsg1(400, "Poll timeout in create append vol on device %s\n", dev->print_name());
495          continue;
496       }
497
498       if (stat == ETIMEDOUT) {
499          if (!double_dev_wait_time(dev)) {
500             Mmsg(dev->errmsg, _("Max time exceeded waiting to mount Storage Device %s for Job %s\n"),
501                dev->print_name(), jcr->Job);
502             Jmsg(jcr, M_FATAL, 0, "%s", dev->errmsg);
503             Dmsg1(400, "Gave up waiting on device %s\n", dev->print_name());
504             return false;             /* exceeded maximum waits */
505          }
506          continue;
507       }
508       if (stat == EINVAL) {
509          berrno be;
510          Mmsg2(dev->errmsg, _("pthread error in mount_next_volume stat=%d ERR=%s\n"),
511                stat, be.strerror(stat));
512          Jmsg(jcr, M_FATAL, 0, "%s", dev->errmsg);
513          return false;
514       }
515       if (stat != 0) {
516          berrno be;
517          Jmsg(jcr, M_WARNING, 0, _("pthread error in mount_next_volume stat=%d ERR=%s\n"), stat,
518             be.strerror(stat));
519       }
520       Dmsg1(400, "Someone woke me for device %s\n", dev->print_name());
521
522       /* If no VolumeName, and cannot get one, try again */
523       if (dcr->VolumeName[0] == 0 && !job_canceled(jcr) &&
524           !dir_find_next_appendable_volume(dcr)) {
525          Jmsg(jcr, M_MOUNT, 0, _(
526 "Someone woke me up, but I cannot find any appendable\n"
527 "volumes for Job=%s.\n"), jcr->Job);
528          /* Restart wait counters after user interaction */
529          init_device_wait_timers(dcr);
530          continue;
531       }
532       unmounted = (dev->dev_blocked == BST_UNMOUNTED) ||
533                   (dev->dev_blocked == BST_UNMOUNTED_WAITING_FOR_SYSOP);
534       if (unmounted) {
535          continue;                    /* continue to wait */
536       }
537
538       /*
539        * Device mounted, we have a volume, break and return
540        */
541       break;
542    }
543    set_jcr_job_status(jcr, JS_Running);
544    dir_send_job_status(jcr);
545    Dmsg0(400, "leave dir_ask_sysop_to_mount_create_appendable_volume\n");
546    return true;
547 }
548
549 /*
550  *   Request to mount specific Volume
551  *
552  *   Entered with device blocked and dcr->VolumeName is desired
553  *      volume.
554  *   Leaves with device blocked.
555  *
556  *   Returns: true  on success (operator issues a mount command)
557  *            false on failure
558  *                  Note, must create dev->errmsg on error return.
559  *
560  */
561 bool dir_ask_sysop_to_mount_volume(DCR *dcr)
562 {
563    int stat = 0;
564    const char *msg;
565    DEVICE *dev = dcr->dev;
566    JCR *jcr = dcr->jcr;
567
568    Dmsg0(400, "enter dir_ask_sysop_to_mount_volume\n");
569    if (!dcr->VolumeName[0]) {
570       Mmsg0(dev->errmsg, _("Cannot request another volume: no volume name given.\n"));
571       return false;
572    }
573    ASSERT(dev->dev_blocked);
574    for ( ;; ) {
575       if (job_canceled(jcr)) {
576          Mmsg(dev->errmsg, _("Job %s canceled while waiting for mount on Storage Device %s.\n"),
577               jcr->Job, dev->print_name());
578          return false;
579       }
580
581       if (!dev->poll) {
582          msg = _("Please mount");
583          Jmsg(jcr, M_MOUNT, 0, _("%s Volume \"%s\" on Storage Device %s for Job %s\n"),
584               msg, dcr->VolumeName, dev->print_name(), jcr->Job);
585          Dmsg3(400, "Mount \"%s\" on device \"%s\" for Job %s\n",
586                dcr->VolumeName, dcr->dev_name, jcr->Job);
587       }
588
589       jcr->JobStatus = JS_WaitMount;
590       dir_send_job_status(jcr);
591
592       stat = wait_for_sysop(dcr);    ;     /* wait on device */
593       if (dev->poll) {
594          Dmsg1(400, "Poll timeout in mount vol on device %s\n", dev->print_name());
595          Dmsg1(400, "Blocked=%s\n", edit_blocked_reason(dev));
596          return true;
597       }
598
599       if (stat == ETIMEDOUT) {
600          if (!double_dev_wait_time(dev)) {
601             Mmsg(dev->errmsg, _("Max time exceeded waiting to mount Storage Device %s for Job %s\n"),
602                dev->print_name(), jcr->Job);
603             Jmsg(jcr, M_FATAL, 0, "%s", dev->errmsg);
604             Dmsg1(400, "Gave up waiting on device %s\n", dev->print_name());
605             return false;             /* exceeded maximum waits */
606          }
607          continue;
608       }
609       if (stat == EINVAL) {
610          berrno be;
611          Mmsg2(dev->errmsg, _("pthread error in mount_volume stat=%d ERR=%s\n"),
612                stat, be.strerror(stat));
613          Jmsg(jcr, M_FATAL, 0, "%s", dev->errmsg);
614          return false;
615       }
616       if (stat != 0) {
617          berrno be;
618          Jmsg(jcr, M_FATAL, 0, _("pthread error in mount_next_volume stat=%d: ERR=%s\n"), stat,
619             be.strerror(stat));
620       }
621       Dmsg1(400, "Someone woke me for device %s\n", dev->print_name());
622       break;
623    }
624    set_jcr_job_status(jcr, JS_Running);
625    dir_send_job_status(jcr);
626    Dmsg0(400, "leave dir_ask_sysop_to_mount_volume\n");
627    return true;
628 }