#ident "%Z%%M% %I% %E% SMI"
#include "uucp.h"
#define NCSAVE 30
static int ncsave;
static struct cs_struct csave[NCSAVE];
int Dfileused = FALSE;
static char jobid[NAMESIZE];
extern void wfcommit(), wfremove(), putdfiles();
extern int job_size(), fgrade(), retseq();
void
commitall()
{
char sys[NAMESIZE+5];
char cmfile[NAMESIZE+5];
int i;
int n;
for (i = 0; i < ncsave; i++) {
if (Sgrades) {
if ((job_size(&csave[i]) == FAIL) ||
(fgrade(&csave[i]) == FAIL)) {
wfremove(csave[i].file);
continue;
}
}
else {
Dfileused = TRUE;
csave[i].grade = Grade;
}
if (Sgrades) {
n = retseq(csave[i].sys);
(void) sprintf(cmfile, "%c.%.*s%c%.4x", *csave[i].file,
SYSNSIZE, csave[i].sys, csave[i].grade, n);
}
else
(void) strncpy(cmfile, csave[i].file, NAMESIZE-1);
cmfile[NAMESIZE-1] = '\0';
DEBUG(9, "User job queued to %c queue\n", csave[i].grade);
(void) sprintf(sys, "/%c", csave[i].grade);
(void) strcat(csave[i].sys, sys);
if (Dfileused) {
putdfiles(csave[i]);
Dfileused = FALSE;
}
wfcommit(csave[i].file, cmfile, csave[i].sys);
(void) strncpy(csave[i].file, cmfile, NAMESIZE);
}
ncsave = 0;
(void) strncpy(jobid, BASENAME(csave[0].file, '.'), NAMESIZE);
return;
}
int
gtcfile(file, sys)
char *file, *sys;
{
register int i;
for (i = 0; i < ncsave; i++)
if (strncmp(sys, csave[i].sys, SYSNSIZE) == SAME) {
(void) strncpy(file, csave[i].file, NAMESIZE-1);
return(SUCCESS);
}
return(FAIL);
}
char *
jid()
{
return(jobid);
}
void
svcfile(file, sys, grd)
char *file, *sys, *grd;
{
ASSERT(ncsave < NCSAVE, "TOO MANY SAVED C FILES", "", ncsave);
(void) strncpy(csave[ncsave].file, BASENAME(file, '/'), NAMESIZE-1);
(void) strncpy(csave[ncsave].sys, sys, NAMESIZE-1);
(void) strncpy (csave[ncsave].sgrade, grd, NAMESIZE-1);
ncsave++;
return;
}
void
wfabort()
{
register int i;
for (i = 0; i < ncsave; i++)
wfremove(csave[i].file);
ncsave = 0;
return;
}
void
wfcommit(wfile1, wfile2, sys)
char *wfile1, *wfile2, *sys;
{
char cmitfile[MAXFULLNAME];
char remote[NAMESIZE];
char *fileBase;
char *p;
(void) strncpy(remote, sys, NAMESIZE);
if ((p = strchr(remote, '/')) != NULL) {
*p++ = '\0';
DEBUG(6, "create remote spool area %s\n", remote);
mkremdir(remote);
}
if (p != NULL)
DEBUG(6, "create service grade directory %s under remote spool\n", p);
else
DEBUG(6, "create remote spool area %s\n", sys);
mkremdir(sys);
DEBUG(6, "commit %s ", wfile1);
fileBase = BASENAME(wfile2, '/');
sprintf(cmitfile, "%s/%s", RemSpool, fileBase);
DEBUG(6, "to %s\n", cmitfile);
ASSERT(access(cmitfile, 0) != 0, Fl_EXISTS, cmitfile, 0);
ASSERT(xmv(wfile1, cmitfile) == 0, Ct_LINK, cmitfile, errno);
return;
}