commit 5e2f4e9

default  ·  2024-01-04 15:27:07 +0000 UTC
parent 2218889 
dequeue() unlinks the file, even if it's been unable to parse it.
2 files changed,  +2, -5
M activitypub.c
M data.c
M activitypub.c
+1, -3 
 1@@ -1982,10 +1982,8 @@ int process_user_queue(snac *snac)
 2     while (xs_list_iter(&p, &fn)) {
 3         xs *q_item = dequeue(fn);
 4 
 5-        if (q_item == NULL) {
 6-            snac_log(snac, xs_fmt("process_user_queue q_item error"));
 7+        if (q_item == NULL)
 8             continue;
 9-        }
10 
11         process_user_queue_item(snac, q_item);
12         cnt++;
M data.c
+1, -2 
 1@@ -2399,8 +2399,7 @@ xs_dict *dequeue(const char *fn)
 2 {
 3     xs_dict *obj = queue_get(fn);
 4 
 5-    if (obj != NULL)
 6-        unlink(fn);
 7+    unlink(fn);
 8 
 9     return obj;
10 }