diff options
author | default <nobody@localhost> | 2023-02-02 04:47:59 +0100 |
---|---|---|
committer | default <nobody@localhost> | 2023-02-02 04:47:59 +0100 |
commit | 106c94ef86c5c8eb05c3e8ac62f1af3504d8aba0 (patch) | |
tree | 799ec3ee51df63ffcb9314965d54cab438770d4c | |
parent | ee77e45abbcdb51536ba8c1209bf0de7a2a2ab10 (diff) |
queue() renamed to user_queue().
-rw-r--r-- | activitypub.c | 2 | ||||
-rw-r--r-- | data.c | 11 | ||||
-rw-r--r-- | snac.h | 2 |
3 files changed, 8 insertions, 7 deletions
diff --git a/activitypub.c b/activitypub.c index bd99c26..b2f42f2 100644 --- a/activitypub.c +++ b/activitypub.c @@ -1163,7 +1163,7 @@ void process_queue_item(snac *snac, xs_dict *q_item) void process_queue(snac *snac) /* processes the queue */ { - xs *list = queue(snac); + xs *list = user_queue(snac); xs_list *p = list; xs_str *fn; @@ -1411,13 +1411,14 @@ void enqueue_message(snac *snac, xs_dict *msg) } -d_char *queue(snac *snac) +xs_list *user_queue(snac *snac) /* returns a list with filenames that can be dequeued */ { - xs *spec = xs_fmt("%s/queue/" "*.json", snac->basedir); - d_char *list = xs_list_new(); - time_t t = time(NULL); - char *p, *v; + xs *spec = xs_fmt("%s/queue/" "*.json", snac->basedir); + xs_list *list = xs_list_new(); + time_t t = time(NULL); + xs_list *p; + xs_val *v; xs *fns = xs_glob(spec, 0, 0); @@ -129,7 +129,7 @@ void enqueue_output_by_actor(snac *snac, xs_dict *msg, xs_str *actor, int retrie void enqueue_email(snac *snac, xs_str *msg, int retries); void enqueue_message(snac *snac, char *msg); -d_char *queue(snac *snac); +xs_list *user_queue(snac *snac); xs_dict *dequeue(const char *fn); void purge(snac *snac); |