diff options
author | default <nobody@localhost> | 2024-01-04 16:27:07 +0100 |
---|---|---|
committer | default <nobody@localhost> | 2024-01-04 16:27:07 +0100 |
commit | 5e2f4e9902c5ae15bd55da99a28b1de61a6f4293 (patch) | |
tree | e3c551e5b7b30f0347ed24dec39757f7f9a48edf | |
parent | 2218889b43f0393c1d41be62669d3be8389a3779 (diff) |
dequeue() unlinks the file, even if it's been unable to parse it.
-rw-r--r-- | activitypub.c | 4 | ||||
-rw-r--r-- | data.c | 3 |
2 files changed, 2 insertions, 5 deletions
diff --git a/activitypub.c b/activitypub.c index 1b98829..b658fbc 100644 --- a/activitypub.c +++ b/activitypub.c @@ -1982,10 +1982,8 @@ int process_user_queue(snac *snac) while (xs_list_iter(&p, &fn)) { xs *q_item = dequeue(fn); - if (q_item == NULL) { - snac_log(snac, xs_fmt("process_user_queue q_item error")); + if (q_item == NULL) continue; - } process_user_queue_item(snac, q_item); cnt++; @@ -2399,8 +2399,7 @@ xs_dict *dequeue(const char *fn) { xs_dict *obj = queue_get(fn); - if (obj != NULL) - unlink(fn); + unlink(fn); return obj; } |