]> git.sur5r.net Git - bacula/bacula/blobdiff - bacula/src/lib/bsock.c
Tweak mutex order for SD
[bacula/bacula] / bacula / src / lib / bsock.c
index d35da86409a243290e8288652bc7cc565579dc4b..a2e3bb275c47f9fa63ec0a7bb0f6df04b8f49459 100644 (file)
@@ -577,11 +577,11 @@ bool BSOCK::despool(void update_attr_spool_size(ssize_t size), ssize_t tsize)
       size += sizeof(int32_t);
       msglen = ntohl(pktsiz);
       if (msglen > 0) {
-         if (msglen > (int32_t) sizeof_pool_memory(msg)) {
+         if (msglen > (int32_t)sizeof_pool_memory(msg)) {
             msg = realloc_pool_memory(msg, msglen + 1);
          }
          nbytes = fread(msg, 1, msglen, m_spool_fd);
-         if (nbytes != (size_t) msglen) {
+         if (nbytes != (size_t)msglen) {
             berrno be;
             Dmsg2(400, "nbytes=%d msglen=%d\n", nbytes, msglen);
             Qmsg1(get_jcr(), M_FATAL, 0, _("fread attr spool error. ERR=%s\n"),
@@ -599,13 +599,10 @@ bool BSOCK::despool(void update_attr_spool_size(ssize_t size), ssize_t tsize)
       if (jcr && job_canceled(jcr)) {
          return false;
       }
-      send();
    }
    update_attr_spool_size(tsize - last);
    if (ferror(m_spool_fd)) {
-      berrno be;
-      Qmsg1(jcr, M_FATAL, 0, _("fread attr spool error. ERR=%s\n"),
-            be.bstrerror());
+      Qmsg(jcr, M_FATAL, 0, _("fread attr spool I/O error.\n"));
       return false;
    }
    return true;