X-Git-Url: https://git.sur5r.net/?a=blobdiff_plain;f=bacula%2Fsrc%2Fdird%2Fmsgchan.c;h=43d859aa28cc9ced483c6879476e34f8de95287a;hb=82d827763eef307b073a05bc3114a0d1e2b57b14;hp=bca443577f536ad30bec94bf3a2a2e20af19a08e;hpb=e562ce77540cd3ab857fd6b3a88ae8a1093cb53b;p=bacula%2Fbacula diff --git a/bacula/src/dird/msgchan.c b/bacula/src/dird/msgchan.c index bca443577f..43d859aa28 100644 --- a/bacula/src/dird/msgchan.c +++ b/bacula/src/dird/msgchan.c @@ -51,7 +51,7 @@ static pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER; /* Commands sent to Storage daemon */ static char jobcmd[] = "JobId=%s job=%s job_name=%s client_name=%s " "type=%d level=%d FileSet=%s NoAttr=%d SpoolAttr=%d FileSetMD5=%s " - "SpoolData=%d SpoolSize=%s WritePartAfterJob=%d PreferMountedVols=%d\n"; + "SpoolData=%d WritePartAfterJob=%d PreferMountedVols=%d SpoolSize=%s\n"; static char use_storage[] = "use storage=%s media_type=%s pool_name=%s " "pool_type=%s append=%d copy=%d stripe=%d\n"; static char use_device[] = "use device=%s\n"; @@ -187,8 +187,8 @@ bool start_storage_daemon_job(JCR *jcr, alist *rstore, alist *wstore) jcr->JobType, jcr->JobLevel, fileset_name.c_str(), !jcr->pool->catalog_files, jcr->job->SpoolAttributes, jcr->fileset->MD5, jcr->spool_data, - edit_int64(jcr->spool_size, ed2), jcr->write_part_after_job, - jcr->job->PreferMountedVolumes); + jcr->write_part_after_job, jcr->job->PreferMountedVolumes, + edit_int64(jcr->spool_size, ed2)); Dmsg1(100, ">stored: %s\n", sd->msg); if (bget_dirmsg(sd) > 0) { Dmsg1(100, "msg); @@ -364,6 +364,7 @@ extern "C" void *msg_thread(void *arg) int stat; pthread_detach(pthread_self()); + set_jcr_in_tsd(jcr); jcr->SD_msg_chan = pthread_self(); pthread_cleanup_push(msg_thread_cleanup, arg); sd = jcr->store_bsock;