/* /sccs/src/cmd/uucp/s.gnxseq.c gnxseq.c 1.1 8/30/84 17:37:25 */ #include "uucp.h" VERSION(@(#)gnxseq.c 1.1); /* * get next conversation sequence number * rmtname -> name of remote system * returns: * 0 -> no entery * 1 -> 0 sequence number */ gnxseq(rmtname) char *rmtname; { register FILE *fp0, *fp1; register struct tm *tp; extern struct tm *localtime(); int count = 0, ct, ret; char buf[BUFSIZ], name[NAMESIZE]; time_t clock, time(); if (access(SQFILE, 0) != 0) return(0); { register int i; for (i = 0; i < 5; i++) if ((ret = ulockf(SQLOCK, (time_t) SQTIME)) == 0) break; sleep(5); } if (ret != 0) { logent("CAN'T LOCK", SQLOCK); DEBUG(4, "can't lock %s\n", SQLOCK); return(0); } if ((fp0 = fopen(SQFILE, "r")) == NULL) return(0); if ((fp1 = fopen(SQTMP, "w")) == NULL) { fclose(fp0); return(0); } chmod(SQTMP, 0400); while (fgets(buf, BUFSIZ, fp0) != NULL) { ret = sscanf(buf, "%s%d", name, &ct); if (ret < 2) ct = 0; name[7] = '\0'; if (ct > 9998) ct = 0; if (strncmp(rmtname, name, SYSNSIZE) != SAME) { fputs(buf, fp1); continue; } /* * found name */ count = ++ct; time(&clock); tp = localtime(&clock); fprintf(fp1, "%s %d %d/%d-%d:%2.2d\n", name, ct, tp->tm_mon + 1, tp->tm_mday, tp->tm_hour, tp->tm_min); /* * write should be checked */ while (fgets(buf, BUFSIZ, fp0) != NULL) fputs(buf, fp1); } fclose(fp0); fclose(fp1); if (count == 0) { rmlock(SQLOCK); unlink(SQTMP); } return(count); } /* * commit sequence update * returns: * 0 -> ok * other -> link failed */ cmtseq() { register int ret; if ((ret = access(SQTMP, 0)) != 0) { rmlock(SQLOCK); return(0); } unlink(SQFILE); ret = link(SQTMP, SQFILE); unlink(SQTMP); rmlock(SQLOCK); return(ret); } /* * unlock sequence file */ ulkseq() { unlink(SQTMP); rmlock(SQLOCK); }