monkee.ch/snac2
1
0
Fork 0
mirror of https://codeberg.org/grunfink/snac2.git synced 2024-11-25 14:35:04 +00:00
Code Issues Projects Releases Packages Wiki Activity

Added some tweaks to file locking.

Browse source
This commit is contained in:
default 2022-11-26 19:19:52 +01:00
parent 2ad703e520
commit e8c487add7
1 changed files with 8 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
data.c
View file

@ -218,6 +218,9 @@ int index_add_md5(const char *fn, const char *md5)
if ((f = fopen(fn, "a")) != NULL) { if ((f = fopen(fn, "a")) != NULL) {
flock(fileno(f), LOCK_EX); flock(fileno(f), LOCK_EX);
/* ensure the position is at the end after getting the lock */
fseek(f, 0, SEEK_END);
fprintf(f, "%s\n", md5); fprintf(f, "%s\n", md5);
fclose(f); fclose(f);
} }
@ -314,6 +317,8 @@ int index_first(const char *fn, char *line, int size)
int ret = 0; int ret = 0;
if ((f = fopen(fn, "r")) != NULL) { if ((f = fopen(fn, "r")) != NULL) {
flock(fileno(f), LOCK_SH);
if (fgets(line, size, f) != NULL) { if (fgets(line, size, f) != NULL) {
line[32] = '\0'; line[32] = '\0';
ret = 1; ret = 1;
@ -786,6 +791,9 @@ int timeline_del(snac *snac, char *id)
object_user_cache_del(snac, id, "public"); object_user_cache_del(snac, id, "public");
object_user_cache_del(snac, id, "private"); object_user_cache_del(snac, id, "private");
/* NOTE: this is a good place to count the # of links
of the object and object_del() it if it's < 2 */
return ret; return ret;
} }