bbs/magicka
Archived
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Update msgid generation

Browse Source
This commit is contained in:
Andrew Pamment 2017-03-21 10:47:51 +10:00
parent 4b6adbcbdc
commit 9a0347e47e
2 changed files with 20 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
mail_menu.c
View File

@ -44,6 +44,7 @@ s_JamBase *open_jam_base(char *path) {
unsigned long generate_msgid() { unsigned long generate_msgid() {
char buffer[1024]; char buffer[1024];
time_t unixtime;
unsigned long msgid; unsigned long msgid;
unsigned long lastid; unsigned long lastid;
@ -51,11 +52,18 @@ unsigned long generate_msgid() {
snprintf(buffer, 1024, "%s/msgserial", conf.bbs_path); snprintf(buffer, 1024, "%s/msgserial", conf.bbs_path);
unixtime = time(NULL);
fptr = fopen(buffer, "r+"); fptr = fopen(buffer, "r+");
if (fptr) { if (fptr) {
flock(fileno(fptr), LOCK_EX); flock(fileno(fptr), LOCK_EX);
fread(&lastid, sizeof(unsigned long), 1, fptr); fread(&lastid, sizeof(unsigned long), 1, fptr);
lastid++;
if (unixtime > lastid) {
lastid = unixtime;
} else {
lastid++;
}
rewind(fptr); rewind(fptr);
fwrite(&lastid, sizeof(unsigned long), 1, fptr); fwrite(&lastid, sizeof(unsigned long), 1, fptr);
flock(fileno(fptr), LOCK_UN); flock(fileno(fptr), LOCK_UN);
@ -63,7 +71,7 @@ unsigned long generate_msgid() {
} else { } else {
fptr = fopen(buffer, "w"); fptr = fopen(buffer, "w");
if (fptr) { if (fptr) {
lastid = 1; lastid = unixtime;
flock(fileno(fptr), LOCK_EX); flock(fileno(fptr), LOCK_EX);
fwrite(&lastid, sizeof(unsigned long), 1, fptr); fwrite(&lastid, sizeof(unsigned long), 1, fptr);
flock(fileno(fptr), LOCK_UN); flock(fileno(fptr), LOCK_UN);

12
utils/mgpost/mgpost.c
View File

@ -140,11 +140,19 @@ unsigned long generate_msgid(char *bbs_path) {
snprintf(buffer, 1024, "%s/msgserial", bbs_path); snprintf(buffer, 1024, "%s/msgserial", bbs_path);
unixtime = time(NULL);
fptr = fopen(buffer, "r+"); fptr = fopen(buffer, "r+");
if (fptr) { if (fptr) {
flock(fileno(fptr), LOCK_EX); flock(fileno(fptr), LOCK_EX);
fread(&lastid, sizeof(unsigned long), 1, fptr); fread(&lastid, sizeof(unsigned long), 1, fptr);
lastid++;
if (unixtime > lastid) {
lastid = unixtime;
} else {
lastid++;
}
rewind(fptr); rewind(fptr);
fwrite(&lastid, sizeof(unsigned long), 1, fptr); fwrite(&lastid, sizeof(unsigned long), 1, fptr);
flock(fileno(fptr), LOCK_UN); flock(fileno(fptr), LOCK_UN);
@ -152,7 +160,7 @@ unsigned long generate_msgid(char *bbs_path) {
} else { } else {
fptr = fopen(buffer, "w"); fptr = fopen(buffer, "w");
if (fptr) { if (fptr) {
lastid = 1; lastid = unixtime;
flock(fileno(fptr), LOCK_EX); flock(fileno(fptr), LOCK_EX);
fwrite(&lastid, sizeof(unsigned long), 1, fptr); fwrite(&lastid, sizeof(unsigned long), 1, fptr);
flock(fileno(fptr), LOCK_UN); flock(fileno(fptr), LOCK_UN);