Welcome to mirror list, hosted at ThFree Co, Russian Federation.

github.com/bareos/bareos.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAlaa Eddine Elamri <alaeddine.elamri@bareos.com>2022-10-28 14:00:42 +0300
committerAndreas Rogge <andreas.rogge@bareos.com>2022-11-07 19:16:29 +0300
commit61b44e4b967180c2eec19bda3934cc185b79f4b8 (patch)
tree9edb76806bcd767be637bf9c8fdab7892aad3939
parent65d3ad166f03a1b89c4ad15c973293702475aea6 (diff)
rename forceJobStatus to setJobStatus
-rw-r--r--core/src/dird/fd_cmds.cc2
-rw-r--r--core/src/include/jcr.h2
-rw-r--r--core/src/stored/spool.cc32
3 files changed, 18 insertions, 18 deletions
diff --git a/core/src/dird/fd_cmds.cc b/core/src/dird/fd_cmds.cc
index 146403e6d..422d3effa 100644
--- a/core/src/dird/fd_cmds.cc
+++ b/core/src/dird/fd_cmds.cc
@@ -294,7 +294,7 @@ bool ConnectToFileDaemon(JobControlRecord* jcr,
delete jcr->file_bsock;
jcr->file_bsock = nullptr;
}
- jcr->forceJobStatus(JS_Running);
+ jcr->setJobStatus(JS_Running);
jcr->impl->connection_handshake_try_
= ClientConnectionHandshakeMode::kCleartextFirst;
break;
diff --git a/core/src/include/jcr.h b/core/src/include/jcr.h
index 816aa1a92..13270d394 100644
--- a/core/src/include/jcr.h
+++ b/core/src/include/jcr.h
@@ -118,7 +118,7 @@ class JobControlRecord {
void setJobLevel(int32_t JobLevel) { JobLevel_ = JobLevel; }
void setJobType(int32_t JobType) { JobType_ = JobType; }
void setJobProtocol(int32_t JobProtocol) { Protocol_ = JobProtocol; }
- void forceJobStatus(int32_t aJobStatus) { JobStatus = aJobStatus; }
+ void setJobStatus(int32_t aJobStatus) { JobStatus = aJobStatus; }
void setJobStarted();
int32_t getJobType() const { return JobType_; }
int32_t getJobLevel() const { return JobLevel_; }
diff --git a/core/src/stored/spool.cc b/core/src/stored/spool.cc
index cb8148ee6..770421aa6 100644
--- a/core/src/stored/spool.cc
+++ b/core/src/stored/spool.cc
@@ -334,7 +334,7 @@ static bool DespoolData(DeviceControlRecord* dcr, bool commit)
Dmsg2(000, "Fatal append error on device %s: ERR=%s\n",
dcr->dev->print_name(), dcr->dev->bstrerror());
/* Force in case Incomplete set */
- jcr->forceJobStatus(JS_FatalError);
+ jcr->setJobStatus(JS_FatalError);
}
Dmsg3(800, "Write block ok=%d FI=%d LI=%d\n", ok, block->FirstIndex,
block->LastIndex);
@@ -354,7 +354,7 @@ static bool DespoolData(DeviceControlRecord* dcr, bool commit)
Jmsg2(jcr, M_FATAL, 0,
_("Could not create JobMedia record for Volume=\"%s\" Job=%s\n"),
dcr->getVolCatName(), jcr->Job);
- jcr->forceJobStatus(JS_FatalError); /* override any Incomplete */
+ jcr->setJobStatus(JS_FatalError); /* override any Incomplete */
}
/* Set new file/block parameters for current dcr */
SetNewFileParameters(dcr);
@@ -458,7 +458,7 @@ static int ReadBlockFromSpoolFile(DeviceControlRecord* dcr)
_("Spool header read error. Wanted %u bytes, got %d\n"), rlen,
status);
}
- jcr->forceJobStatus(JS_FatalError); /* override any Incomplete */
+ jcr->setJobStatus(JS_FatalError); /* override any Incomplete */
return RB_ERROR;
}
rlen = hdr.len;
@@ -467,7 +467,7 @@ static int ReadBlockFromSpoolFile(DeviceControlRecord* dcr)
rlen);
Jmsg2(jcr, M_FATAL, 0, _("Spool block too big. Max %u bytes, got %u\n"),
block->buf_len, rlen);
- jcr->forceJobStatus(JS_FatalError); /* override any Incomplete */
+ jcr->setJobStatus(JS_FatalError); /* override any Incomplete */
return RB_ERROR;
}
status = read(dcr->spool_fd, (char*)block->buf, (size_t)rlen);
@@ -476,7 +476,7 @@ static int ReadBlockFromSpoolFile(DeviceControlRecord* dcr)
status);
Jmsg2(dcr->jcr, M_FATAL, 0,
_("Spool data read error. Wanted %u bytes, got %d\n"), rlen, status);
- jcr->forceJobStatus(JS_FatalError); /* override any Incomplete */
+ jcr->setJobStatus(JS_FatalError); /* override any Incomplete */
return RB_ERROR;
}
/* Setup write pointers */
@@ -582,7 +582,7 @@ static bool WriteSpoolHeader(DeviceControlRecord* dcr)
Jmsg(jcr, M_FATAL, 0, _("Error writing header to spool file. ERR=%s\n"),
be.bstrerror());
- jcr->forceJobStatus(JS_FatalError); /* override any Incomplete */
+ jcr->setJobStatus(JS_FatalError); /* override any Incomplete */
}
if (status != (ssize_t)sizeof(hdr)) {
Jmsg(jcr, M_ERROR, 0,
@@ -607,7 +607,7 @@ static bool WriteSpoolHeader(DeviceControlRecord* dcr)
}
if (!DespoolData(dcr, false)) {
Jmsg(jcr, M_FATAL, 0, _("Fatal despooling error.\n"));
- jcr->forceJobStatus(JS_FatalError); /* override any Incomplete */
+ jcr->setJobStatus(JS_FatalError); /* override any Incomplete */
return false;
}
continue; /* try again */
@@ -615,7 +615,7 @@ static bool WriteSpoolHeader(DeviceControlRecord* dcr)
return true;
}
Jmsg(jcr, M_FATAL, 0, _("Retrying after header spooling error failed.\n"));
- jcr->forceJobStatus(JS_FatalError); /* override any Incomplete */
+ jcr->setJobStatus(JS_FatalError); /* override any Incomplete */
return false;
}
@@ -633,7 +633,7 @@ static bool WriteSpoolData(DeviceControlRecord* dcr)
Jmsg(jcr, M_FATAL, 0, _("Error writing data to spool file. ERR=%s\n"),
be.bstrerror());
- jcr->forceJobStatus(JS_FatalError); /* override any Incomplete */
+ jcr->setJobStatus(JS_FatalError); /* override any Incomplete */
}
if (status != (ssize_t)block->binbuf) {
// If we wrote something, truncate it and the header, then despool
@@ -654,7 +654,7 @@ static bool WriteSpoolData(DeviceControlRecord* dcr)
if (!DespoolData(dcr, false)) {
Jmsg(jcr, M_FATAL, 0, _("Fatal despooling error.\n"));
- jcr->forceJobStatus(JS_FatalError); /* override any Incomplete */
+ jcr->setJobStatus(JS_FatalError); /* override any Incomplete */
return false;
}
@@ -667,7 +667,7 @@ static bool WriteSpoolData(DeviceControlRecord* dcr)
}
Jmsg(jcr, M_FATAL, 0, _("Retrying after data spooling error failed.\n"));
- jcr->forceJobStatus(JS_FatalError); /* override any Incomplete */
+ jcr->setJobStatus(JS_FatalError); /* override any Incomplete */
return false;
}
@@ -739,7 +739,7 @@ static bool BlastAttrSpoolFile(JobControlRecord* jcr, boffset_t)
if (jcr->dir_bsock->recv() <= 0) {
Jmsg(jcr, M_FATAL, 0, _("Network error on BlastAttributes.\n"));
- jcr->forceJobStatus(JS_FatalError); /* override any Incomplete */
+ jcr->setJobStatus(JS_FatalError); /* override any Incomplete */
return false;
}
@@ -764,7 +764,7 @@ bool CommitAttributeSpool(JobControlRecord* jcr)
Jmsg(jcr, M_FATAL, 0, _("lseek on attributes file failed: ERR=%s\n"),
be.bstrerror());
- jcr->forceJobStatus(JS_FatalError); /* override any Incomplete */
+ jcr->setJobStatus(JS_FatalError); /* override any Incomplete */
goto bail_out;
}
@@ -779,7 +779,7 @@ bool CommitAttributeSpool(JobControlRecord* jcr)
Jmsg(jcr, M_FATAL, 0,
_("Truncate on attributes file failed: ERR=%s\n"),
be.bstrerror());
- jcr->forceJobStatus(JS_FatalError); /* override any Incomplete */
+ jcr->setJobStatus(JS_FatalError); /* override any Incomplete */
goto bail_out;
}
Dmsg2(100, "=== Attrib spool truncated from %lld to %lld\n", size,
@@ -793,7 +793,7 @@ bool CommitAttributeSpool(JobControlRecord* jcr)
Jmsg(jcr, M_FATAL, 0, _("Fseek on attributes file failed: ERR=%s\n"),
be.bstrerror());
- jcr->forceJobStatus(JS_FatalError); /* override any Incomplete */
+ jcr->setJobStatus(JS_FatalError); /* override any Incomplete */
goto bail_out;
}
@@ -835,7 +835,7 @@ static bool OpenAttrSpoolFile(JobControlRecord* jcr, BareosSocket* bs)
Jmsg(jcr, M_FATAL, 0, _("fopen attr spool file %s failed: ERR=%s\n"), name,
be.bstrerror());
- jcr->forceJobStatus(JS_FatalError); /* override any Incomplete */
+ jcr->setJobStatus(JS_FatalError); /* override any Incomplete */
FreePoolMemory(name);
return false;
}