timeout.tv_sec = tv.tv_sec + 10; /* wait 10 seconds */
Dmsg0(300, "I'm waiting for message thread termination.\n");
pthread_cond_timedwait(&jcr->term_wait, &jcr->mutex, &timeout);
- if (job_cancelled(jcr)) {
+ if (job_canceled(jcr)) {
cancel_count++;
}
/* Give SD 30 seconds to clean up after cancel */
JCR *jcr = (JCR *)ijcr;
POOLMEM *msgsave;
- if (job_cancelled(jcr)) {
+ if (job_canceled(jcr)) {
return 0;
}
* or c. Possibly MD5 or SHA1 record
* 3. Repeat step 1
*/
- while (bnet_recv(sd) >= 0 && !job_cancelled(jcr)) {
+ while (bnet_recv(sd) >= 0 && !job_canceled(jcr)) {
/*
* First we expect a Stream Record Header
*/
BSOCK *dir;
JCR *jcr = (JCR *)pkt;
- if (job_cancelled(jcr)) {
+ if (job_canceled(jcr)) {
return 0;
}
/*
* Get a record from the Storage daemon
*/
- while (bnet_recv(sd) >= 0 && !job_cancelled(jcr)) {
+ while (bnet_recv(sd) >= 0 && !job_canceled(jcr)) {
/*
* First we expect a Stream Record Header
*/
/*
* Now we expect the Stream Data
*/
- if (bnet_recv(sd) < 0 && !job_cancelled(jcr)) {
+ if (bnet_recv(sd) < 0 && !job_canceled(jcr)) {
Jmsg1(jcr, M_FATAL, 0, _("Data record error. ERR=%s\n"), bnet_strerror(sd));
goto bail_out;
}
char *file;
struct s_included_file *inc = NULL;
- while (!job_cancelled(jcr) && (inc = get_next_included_file(ff, inc))) {
+ while (!job_canceled(jcr) && (inc = get_next_included_file(ff, inc))) {
file = inc->fname;
strcpy(ff->VerifyOpts, inc->VerifyOpts); /* Copy options for this file */
Dmsg1(50, "find_files: file=%s\n", file);
*/
rtn_stat = 1;
entry = (struct dirent *)malloc(sizeof(struct dirent) + name_max + 100);
- for ( ; !job_cancelled(jcr); ) {
+ for ( ; !job_canceled(jcr); ) {
char *p, *q;
int i;
#define JS_Error 'e' /* Non-fatal error */
#define JS_FatalError 'f' /* Fatal error */
#define JS_Differences 'D' /* Verify differences */
-#define JS_Cancelled 'A' /* cancelled by user */
#define JS_Canceled 'A' /* canceled by user */
#define JS_WaitFD 'F' /* waiting on File daemon */
#define JS_WaitSD 'S' /* waiting on the Storage daemon */
#define JS_WaitClientRes 'c' /* Waiting for Client resource */
#define JS_WaitMaxJobs 'd' /* Waiting for maximum jobs */
-#define job_cancelled(jcr) \
- (jcr->JobStatus == JS_Canceled || \
- jcr->JobStatus == JS_ErrorTerminated || \
- jcr->JobStatus == JS_FatalError)
-
#define job_canceled(jcr) \
(jcr->JobStatus == JS_Canceled || \
jcr->JobStatus == JS_ErrorTerminated || \
int fatal = 0;
for (i=0; (bsock = bnet_open(jcr, name, host, service, port, &fatal)) == NULL; i -= retry_interval) {
- if (fatal || (jcr && job_cancelled(jcr))) {
+ if (fatal || (jcr && job_canceled(jcr))) {
return NULL;
}
Dmsg4(100, "Unable to connect to %s on %s:%d. ERR=%s\n",
tape_previously_mounted = (dev->state & ST_READ) || (dev->state & ST_APPEND);
if (dev->state & ST_READ || dev->num_writers > 0) {
- Jmsg1(jcr, M_FATAL, 0, _("Device %s is busy. Job cancelled.\n"), dev_name(dev));
+ Jmsg1(jcr, M_FATAL, 0, _("Device %s is busy. Job canceled.\n"), dev_name(dev));
goto get_out;
}
/* Find next Volume, if any */
vol = jcr->VolList;
if (!vol) {
- Jmsg(jcr, M_FATAL, 0, _("No volumes specified. Job cancelled.\n"));
+ Jmsg(jcr, M_FATAL, 0, _("No volumes specified. Job canceled.\n"));
goto get_out;
}
jcr->CurVolume++;
pm_strcpy(&jcr->VolumeName, vol->VolumeName);
for (int i=0; i<5; i++) {
- if (job_cancelled(jcr)) {
- Mmsg0(&dev->errmsg, _("Job cancelled.\n"));
+ if (job_canceled(jcr)) {
+ Mmsg0(&dev->errmsg, _("Job canceled.\n"));
goto get_out; /* error return */
}
/*
*/
jcr->VolFirstFile = 0;
time(&jcr->run_time); /* start counting time for rates */
- for (last_file_index = 0; ok && !job_cancelled(jcr); ) {
+ for (last_file_index = 0; ok && !job_canceled(jcr); ) {
char info[100];
/* Read Stream header from the File daemon.
/* Read data stream from the File daemon.
* The data stream is just raw bytes
*/
- while ((n=bget_msg(ds)) > 0 && !job_cancelled(jcr)) {
+ while ((n=bget_msg(ds)) > 0 && !job_canceled(jcr)) {
rec.VolSessionId = jcr->VolSessionId;
rec.VolSessionTime = jcr->VolSessionTime;
ASSERT(dev->dev_blocked);
wait_sec = min_wait;
for ( ;; ) {
- if (job_cancelled(jcr)) {
- Mmsg(&dev->errmsg, _("Job %s cancelled while waiting for mount on Storage Device \"%s\".\n"),
+ if (job_canceled(jcr)) {
+ Mmsg(&dev->errmsg, _("Job %s canceled while waiting for mount on Storage Device \"%s\".\n"),
jcr->Job, jcr->dev_name);
Jmsg(jcr, M_FATAL, 0, "%s", dev->errmsg);
return 0;
jcr->JobStatus = jstat;
dir_send_job_status(jcr);
- for ( ;!job_cancelled(jcr); ) {
+ for ( ;!job_canceled(jcr); ) {
Dmsg1(190, "I'm going to sleep on device %s\n", dev->dev_name);
stat = pthread_cond_timedwait(&dev->wait_next_vol, &dev->mutex, &timeout);
if (dev->dev_blocked == BST_WAITING_FOR_SYSOP) {
ASSERT(dev->dev_blocked);
wait_sec = min_wait;
for ( ;; ) {
- if (job_cancelled(jcr)) {
- Mmsg(&dev->errmsg, _("Job %s cancelled while waiting for mount on Storage Device \"%s\".\n"),
+ if (job_canceled(jcr)) {
+ Mmsg(&dev->errmsg, _("Job %s canceled while waiting for mount on Storage Device \"%s\".\n"),
jcr->Job, jcr->dev_name);
return 0;
}
jcr->JobStatus = JS_WaitMount;
dir_send_job_status(jcr);
- for ( ;!job_cancelled(jcr); ) {
+ for ( ;!job_canceled(jcr); ) {
Dmsg1(190, "I'm going to sleep on device %s\n", dev->dev_name);
stat = pthread_cond_timedwait(&dev->wait_next_vol, &dev->mutex, &timeout);
if (dev->dev_blocked == BST_WAITING_FOR_SYSOP) {
*/
jcr->VolFirstFile = 0;
time(&jcr->run_time); /* start counting time for rates */
- for (file_index = 0; ok && !job_cancelled(jcr); ) {
+ for (file_index = 0; ok && !job_canceled(jcr); ) {
uint64_t *lp;
rec.VolSessionId = jcr->VolSessionId;
rec.VolSessionTime = jcr->VolSessionTime;
if (stop > 0) {
Dmsg0(000, "Write_end_session_label()\n");
/* Create Job status for end of session label */
- if (!job_cancelled(jcr) && ok) {
+ if (!job_canceled(jcr) && ok) {
set_jcr_job_status(jcr, JS_Terminated);
} else if (!ok) {
set_jcr_job_status(jcr, JS_ErrorTerminated);
dev_name(dev));
return 0;
}
- if (job_cancelled(jcr)) {
- Jmsg(jcr, M_FATAL, 0, _("Job cancelled.\n"));
+ if (job_canceled(jcr)) {
+ Jmsg(jcr, M_FATAL, 0, _("Job canceled.\n"));
return 0;
}
recycle = ask = autochanger = 0;
* matched.
*/
for ( ;ok && !done; ) {
- if (job_cancelled(jcr)) {
+ if (job_canceled(jcr)) {
ok = FALSE;
break;
}
block = new_block(dev);
rec = new_record();
for ( ;ok && !done; ) {
- if (job_cancelled(jcr)) {
+ if (job_canceled(jcr)) {
ok = FALSE;
break;
}