diff options
| -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) | |||
| 1982 | while (xs_list_iter(&p, &fn)) { | 1982 | while (xs_list_iter(&p, &fn)) { |
| 1983 | xs *q_item = dequeue(fn); | 1983 | xs *q_item = dequeue(fn); |
| 1984 | 1984 | ||
| 1985 | if (q_item == NULL) { | 1985 | if (q_item == NULL) |
| 1986 | snac_log(snac, xs_fmt("process_user_queue q_item error")); | ||
| 1987 | continue; | 1986 | continue; |
| 1988 | } | ||
| 1989 | 1987 | ||
| 1990 | process_user_queue_item(snac, q_item); | 1988 | process_user_queue_item(snac, q_item); |
| 1991 | cnt++; | 1989 | cnt++; |
| @@ -2399,8 +2399,7 @@ xs_dict *dequeue(const char *fn) | |||
| 2399 | { | 2399 | { |
| 2400 | xs_dict *obj = queue_get(fn); | 2400 | xs_dict *obj = queue_get(fn); |
| 2401 | 2401 | ||
| 2402 | if (obj != NULL) | 2402 | unlink(fn); |
| 2403 | unlink(fn); | ||
| 2404 | 2403 | ||
| 2405 | return obj; | 2404 | return obj; |
| 2406 | } | 2405 | } |