diff options
Diffstat (limited to 'activitypub.c')
| -rw-r--r-- | activitypub.c | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/activitypub.c b/activitypub.c index f4c081b..5afe304 100644 --- a/activitypub.c +++ b/activitypub.c | |||
| @@ -2052,6 +2052,7 @@ void process_queue_item(xs_dict *q_item) | |||
| 2052 | xs *users = user_list(); | 2052 | xs *users = user_list(); |
| 2053 | xs_list *p = users; | 2053 | xs_list *p = users; |
| 2054 | char *v; | 2054 | char *v; |
| 2055 | int cnt = 0; | ||
| 2055 | 2056 | ||
| 2056 | while (xs_list_iter(&p, &v)) { | 2057 | while (xs_list_iter(&p, &v)) { |
| 2057 | snac user; | 2058 | snac user; |
| @@ -2064,6 +2065,8 @@ void process_queue_item(xs_dict *q_item) | |||
| 2064 | 2065 | ||
| 2065 | if (link(tmpfn, fn) < 0) | 2066 | if (link(tmpfn, fn) < 0) |
| 2066 | srv_log(xs_fmt("link(%s, %s) error", tmpfn, fn)); | 2067 | srv_log(xs_fmt("link(%s, %s) error", tmpfn, fn)); |
| 2068 | |||
| 2069 | cnt++; | ||
| 2067 | } | 2070 | } |
| 2068 | 2071 | ||
| 2069 | user_free(&user); | 2072 | user_free(&user); |
| @@ -2071,6 +2074,9 @@ void process_queue_item(xs_dict *q_item) | |||
| 2071 | } | 2074 | } |
| 2072 | 2075 | ||
| 2073 | unlink(tmpfn); | 2076 | unlink(tmpfn); |
| 2077 | |||
| 2078 | if (cnt == 0) | ||
| 2079 | srv_debug(1, xs_fmt("no valid recipients for %s", tmpfn)); | ||
| 2074 | } | 2080 | } |
| 2075 | else | 2081 | else |
| 2076 | srv_log(xs_fmt("unexpected q_item type '%s'", type)); | 2082 | srv_log(xs_fmt("unexpected q_item type '%s'", type)); |