if (re) {
Priority = re->jcr->JobPriority;
Dmsg2(2300, "JobId %d is running. Look for pri=%d\n",
- re->jcr->JobId, Priority);
- running_allow_mix = true;
- for ( ; re; ) {
- Dmsg2(2300, "JobId %d is also running with %s\n",
- re->jcr->JobId,
- re->jcr->job->allow_mixed_priority ? "mix" : "no mix");
- if (!re->jcr->job->allow_mixed_priority) {
- running_allow_mix = false;
- break;
- }
- re = (jobq_item_t *)jq->running_jobs->next(re);
- }
+ re->jcr->JobId, Priority);
+ running_allow_mix = true;
+ for ( ; re; ) {
+ Dmsg2(2300, "JobId %d is also running with %s\n",
+ re->jcr->JobId,
+ re->jcr->job->allow_mixed_priority ? "mix" : "no mix");
+ if (!re->jcr->job->allow_mixed_priority) {
+ running_allow_mix = false;
+ break;
+ }
+ re = (jobq_item_t *)jq->running_jobs->next(re);
+ }
Dmsg1(2300, "The running job(s) %s mixing priorities.\n",
- running_allow_mix ? "allow" : "don't allow");
+ running_allow_mix ? "allow" : "don't allow");
} else {
Priority = je->jcr->JobPriority;
Dmsg1(2300, "No job running. Look for Job pri=%d\n", Priority);
jobq_item_t *jn = (jobq_item_t *)jq->waiting_jobs->next(je);
Dmsg4(2300, "Examining Job=%d JobPri=%d want Pri=%d (%s)\n",
- jcr->JobId, jcr->JobPriority, Priority,
- jcr->job->allow_mixed_priority ? "mix" : "no mix");
+ jcr->JobId, jcr->JobPriority, Priority,
+ jcr->job->allow_mixed_priority ? "mix" : "no mix");
/* Take only jobs of correct Priority */
if (!(jcr->JobPriority == Priority
- || (jcr->JobPriority < Priority &&
- jcr->job->allow_mixed_priority && running_allow_mix))) {
+ || (jcr->JobPriority < Priority &&
+ jcr->job->allow_mixed_priority && running_allow_mix))) {
set_jcr_job_status(jcr, JS_WaitPriority);
break;
}
bool skip_this_jcr = false;
jcr->acquired_resource_locks = false;
+/*
+ * Turning this code off is likely to cause some deadlocks,
+ * but we do not really have enough information here to
+ * know if this is really a deadlock (it may be a dual drive
+ * autochanger), and in principle, the SD reservation system
+ * should detect these deadlocks, so push the work off on is.
+ */
+#ifdef xxx
if (jcr->rstore && jcr->rstore == jcr->wstore) { /* possible deadlock */
Jmsg(jcr, M_FATAL, 0, _("Job canceled. Attempt to read and write same device.\n"
" Read storage \"%s\" (From %s) -- Write storage \"%s\" (From %s)\n"),
set_jcr_job_status(jcr, JS_Canceled);
return false;
}
+#endif
if (jcr->rstore) {
Dmsg1(200, "Rstore=%s\n", jcr->rstore->name());
if (jcr->rstore->NumConcurrentJobs < jcr->rstore->MaxConcurrentJobs) {