From: Eric Bollengier <eric@eb.homelinux.org>
Date: Sat, 20 Nov 2010 17:56:03 +0000 (+0100)
Subject: Fix delta-test-fd
X-Git-Tag: Release-7.0.0~1371
X-Git-Url: https://git.sur5r.net/?a=commitdiff_plain;h=62b4d5b5c2c9d263148f8955aaab434a7bdbc473;p=bacula%2Fbacula

Fix delta-test-fd
---

diff --git a/bacula/src/plugins/fd/delta-test-fd.c b/bacula/src/plugins/fd/delta-test-fd.c
index 1753dac363..ce58587eca 100644
--- a/bacula/src/plugins/fd/delta-test-fd.c
+++ b/bacula/src/plugins/fd/delta-test-fd.c
@@ -348,7 +348,7 @@ static bRC pluginIO(bpContext *ctx, struct io_pkt *io)
    case IO_OPEN:
       Dmsg(ctx, dbglvl, "delta-fd: IO_OPEN\n");
       if (io->flags & (O_CREAT | O_WRONLY)) {
-         self->fd = fopen(self->fname, "w+");
+         self->fd = fopen(self->fname, "a+");
          if (!self->fd) {
             io->io_errno = errno;
             Jmsg(ctx, M_FATAL, 0, 
@@ -379,6 +379,7 @@ static bRC pluginIO(bpContext *ctx, struct io_pkt *io)
          io->offset = self->delta * 100;
          fseek(self->fd, io->offset, SEEK_SET);
          io->status = fread(io->buf, 1, 100, self->fd);
+         Dmsg(ctx, dbglvl, "delta-fd: READ offset=%lld\n", (int64_t)io->offset);
          self->done = true;
       }
       if (io->status == 0 && ferror(self->fd)) {
@@ -396,8 +397,8 @@ static bRC pluginIO(bpContext *ctx, struct io_pkt *io)
          Jmsg(ctx, M_FATAL, 0, "Logic error: NULL write FD\n");
          return bRC_Error;
       }
+      Dmsg(ctx, dbglvl, "delta-fd: WRITE count=%lld\n", (int64_t)io->count);
       io->status = fwrite(io->buf, 1, io->count, self->fd);
-
       if (io->status == 0 && ferror(self->fd)) {
          Jmsg(ctx, M_FATAL, 0, 
             "Pipe write error\n");
@@ -420,7 +421,7 @@ static bRC pluginIO(bpContext *ctx, struct io_pkt *io)
          Jmsg(ctx, M_FATAL, 0, "Logic error: NULL FD on delta close\n");
          return bRC_Error;
       }
-      Dmsg(ctx, dbglvl, "delta-fd: seek offset=%lld\n", (int64_t)io->offset);
+      Dmsg(ctx, dbglvl, "delta-fd: SEEK offset=%lld\n", (int64_t)io->offset);
       io->status = fseek(self->fd, io->offset, io->whence);
       break;
    }