+
+ /* Now we do the specific work for each file type */
+ switch(attr->type) {
+ case FT_REGE:
+ case FT_REG:
+ Dmsg1(100, "Create file %s\n", attr->ofname);
+ mode = O_WRONLY | O_CREAT | O_TRUNC | O_BINARY; /* O_NOFOLLOW; */
+ if (IS_CTG(attr->statp.st_mode)) {
+ mode |= O_CTG; /* set contiguous bit if needed */
+ }
+ Dmsg1(50, "Create file: %s\n", attr->ofname);
+ if (is_bopen(bfd)) {
+ Qmsg1(jcr, M_ERROR, 0, _("bpkt already open fid=%d\n"), bfd->fid);
+ bclose(bfd);
+ }
+
+
+ if ((bopen(bfd, attr->ofname, mode, S_IRUSR | S_IWUSR)) < 0) {
+ berrno be;
+ be.set_errno(bfd->berrno);
+ Qmsg2(jcr, M_ERROR, 0, _("Could not create %s: ERR=%s\n"),
+ attr->ofname, be.bstrerror());
+ return CF_ERROR;
+ }
+ return CF_EXTRACT;
+
+#ifndef HAVE_WIN32 // none of these exists on MS Windows
+ case FT_RAW: /* Bacula raw device e.g. /dev/sda1 */
+ case FT_FIFO: /* Bacula fifo to save data */
+ case FT_SPEC:
+ if (S_ISFIFO(attr->statp.st_mode)) {
+ Dmsg1(400, "Restore fifo: %s\n", attr->ofname);
+ if (mkfifo(attr->ofname, attr->statp.st_mode) != 0 && errno != EEXIST) {
+ berrno be;
+ Qmsg2(jcr, M_ERROR, 0, _("Cannot make fifo %s: ERR=%s\n"),
+ attr->ofname, be.bstrerror());
+ return CF_ERROR;
+ }
+ } else if (S_ISSOCK(attr->statp.st_mode)) {
+ Dmsg1(200, "Skipping restore of socket: %s\n", attr->ofname);
+#ifdef S_IFDOOR // Solaris high speed RPC mechanism
+ } else if (S_ISDOOR(attr->statp.st_mode)) {
+ Dmsg1(200, "Skipping restore of door file: %s\n", attr->ofname);
+#endif
+#ifdef S_IFPORT // Solaris event port for handling AIO
+ } else if (S_ISPORT(attr->statp.st_mode)) {
+ Dmsg1(200, "Skipping restore of event port file: %s\n", attr->ofname);
+#endif
+ } else {
+ Dmsg1(400, "Restore node: %s\n", attr->ofname);
+ if (mknod(attr->ofname, attr->statp.st_mode, attr->statp.st_rdev) != 0 && errno != EEXIST) {
+ berrno be;
+ Qmsg2(jcr, M_ERROR, 0, _("Cannot make node %s: ERR=%s\n"),
+ attr->ofname, be.bstrerror());
+ return CF_ERROR;
+ }
+ }
+ /*
+ * Here we are going to attempt to restore to a FIFO, which
+ * means that the FIFO must already exist, AND there must
+ * be some process already attempting to read from the
+ * FIFO, so we open it write-only.
+ */
+ if (attr->type == FT_RAW || attr->type == FT_FIFO) {
+ btimer_t *tid;
+ Dmsg1(400, "FT_RAW|FT_FIFO %s\n", attr->ofname);
+ mode = O_WRONLY | O_BINARY;
+ /* Timeout open() in 60 seconds */
+ if (attr->type == FT_FIFO) {
+ Dmsg0(400, "Set FIFO timer\n");
+ tid = start_thread_timer(jcr, pthread_self(), 60);
+ } else {
+ tid = NULL;
+ }
+ if (is_bopen(bfd)) {
+ Qmsg1(jcr, M_ERROR, 0, _("bpkt already open fid=%d\n"), bfd->fid);
+ }
+ Dmsg2(400, "open %s mode=0x%x\n", attr->ofname, mode);
+ if ((bopen(bfd, attr->ofname, mode, 0)) < 0) {
+ berrno be;
+ be.set_errno(bfd->berrno);
+ Qmsg2(jcr, M_ERROR, 0, _("Could not open %s: ERR=%s\n"),
+ attr->ofname, be.bstrerror());
+ Dmsg2(400, "Could not open %s: ERR=%s\n", attr->ofname, be.bstrerror());
+ stop_thread_timer(tid);
+ return CF_ERROR;
+ }
+ stop_thread_timer(tid);
+ return CF_EXTRACT;
+ }
+ Dmsg1(400, "FT_SPEC %s\n", attr->ofname);
+ return CF_CREATED;
+
+ case FT_LNK:
+ Dmsg2(130, "FT_LNK should restore: %s -> %s\n", attr->ofname, attr->olname);
+ if (symlink(attr->olname, attr->ofname) != 0 && errno != EEXIST) {
+ berrno be;
+ Qmsg3(jcr, M_ERROR, 0, _("Could not symlink %s -> %s: ERR=%s\n"),
+ attr->ofname, attr->olname, be.bstrerror());
+ return CF_ERROR;
+ }
+ return CF_CREATED;
+
+ case FT_LNKSAVED: /* Hard linked, file already saved */
+ Dmsg2(130, "Hard link %s => %s\n", attr->ofname, attr->olname);
+ if (link(attr->olname, attr->ofname) != 0) {
+ berrno be;
+#ifdef HAVE_CHFLAGS
+ struct stat s;
+
+ /*
+ * If using BSD user flags, maybe has a file flag
+ * preventing this. So attempt to disable, retry link,
+ * and reset flags.
+ * Note that BSD securelevel may prevent disabling flag.
+ */
+
+ if (stat(attr->olname, &s) == 0 && s.st_flags != 0) {
+ if (chflags(attr->olname, 0) == 0) {
+ if (link(attr->olname, attr->ofname) != 0) {
+ /* restore original file flags even when linking failed */
+ if (chflags(attr->olname, s.st_flags) < 0) {
+ Qmsg2(jcr, M_ERROR, 0, _("Could not restore file flags for file %s: ERR=%s\n"),
+ attr->olname, be.bstrerror());
+ }
+#endif /* HAVE_CHFLAGS */
+ Qmsg3(jcr, M_ERROR, 0, _("Could not hard link %s -> %s: ERR=%s\n"),
+ attr->ofname, attr->olname, be.bstrerror());
+ Dmsg3(200, "Could not hard link %s -> %s: ERR=%s\n",
+ attr->ofname, attr->olname, be.bstrerror());
+ return CF_ERROR;
+#ifdef HAVE_CHFLAGS
+ }
+ /* finally restore original file flags */
+ if (chflags(attr->olname, s.st_flags) < 0) {
+ Qmsg2(jcr, M_ERROR, 0, _("Could not restore file flags for file %s: ERR=%s\n"),
+ attr->olname, be.bstrerror());
+ }
+ } else {
+ Qmsg2(jcr, M_ERROR, 0, _("Could not reset file flags for file %s: ERR=%s\n"),
+ attr->olname, be.bstrerror());
+ }
+ } else {
+ Qmsg3(jcr, M_ERROR, 0, _("Could not hard link %s -> %s: ERR=%s\n"),
+ attr->ofname, attr->olname, be.bstrerror());
+ return CF_ERROR;
+ }
+#endif /* HAVE_CHFLAGS */
+
+ }
+ return CF_CREATED;
+#endif
+ } /* End inner switch */
+
+ case FT_REPARSE:
+ bfd->reparse_point = true;
+ /* Fall through wanted */
+ case FT_DIRBEGIN:
+ case FT_DIREND:
+ Dmsg2(200, "Make dir mode=%o dir=%s\n", new_mode, attr->ofname);
+ if (!makepath(attr, attr->ofname, new_mode, parent_mode, uid, gid, 0)) {
+ return CF_ERROR;