diff options
| author | 2023-02-02 04:47:59 +0100 | |
|---|---|---|
| committer | 2023-02-02 04:47:59 +0100 | |
| commit | 106c94ef86c5c8eb05c3e8ac62f1af3504d8aba0 (patch) | |
| tree | 799ec3ee51df63ffcb9314965d54cab438770d4c | |
| parent | dequeue() does not need a snac argument. (diff) | |
| download | snac2-106c94ef86c5c8eb05c3e8ac62f1af3504d8aba0.tar.gz snac2-106c94ef86c5c8eb05c3e8ac62f1af3504d8aba0.tar.xz snac2-106c94ef86c5c8eb05c3e8ac62f1af3504d8aba0.zip | |
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) | |||
| 1163 | void process_queue(snac *snac) | 1163 | void process_queue(snac *snac) |
| 1164 | /* processes the queue */ | 1164 | /* processes the queue */ |
| 1165 | { | 1165 | { |
| 1166 | xs *list = queue(snac); | 1166 | xs *list = user_queue(snac); |
| 1167 | 1167 | ||
| 1168 | xs_list *p = list; | 1168 | xs_list *p = list; |
| 1169 | xs_str *fn; | 1169 | xs_str *fn; |
| @@ -1411,13 +1411,14 @@ void enqueue_message(snac *snac, xs_dict *msg) | |||
| 1411 | } | 1411 | } |
| 1412 | 1412 | ||
| 1413 | 1413 | ||
| 1414 | d_char *queue(snac *snac) | 1414 | xs_list *user_queue(snac *snac) |
| 1415 | /* returns a list with filenames that can be dequeued */ | 1415 | /* returns a list with filenames that can be dequeued */ |
| 1416 | { | 1416 | { |
| 1417 | xs *spec = xs_fmt("%s/queue/" "*.json", snac->basedir); | 1417 | xs *spec = xs_fmt("%s/queue/" "*.json", snac->basedir); |
| 1418 | d_char *list = xs_list_new(); | 1418 | xs_list *list = xs_list_new(); |
| 1419 | time_t t = time(NULL); | 1419 | time_t t = time(NULL); |
| 1420 | char *p, *v; | 1420 | xs_list *p; |
| 1421 | xs_val *v; | ||
| 1421 | 1422 | ||
| 1422 | xs *fns = xs_glob(spec, 0, 0); | 1423 | xs *fns = xs_glob(spec, 0, 0); |
| 1423 | 1424 | ||
| @@ -129,7 +129,7 @@ void enqueue_output_by_actor(snac *snac, xs_dict *msg, xs_str *actor, int retrie | |||
| 129 | void enqueue_email(snac *snac, xs_str *msg, int retries); | 129 | void enqueue_email(snac *snac, xs_str *msg, int retries); |
| 130 | void enqueue_message(snac *snac, char *msg); | 130 | void enqueue_message(snac *snac, char *msg); |
| 131 | 131 | ||
| 132 | d_char *queue(snac *snac); | 132 | xs_list *user_queue(snac *snac); |
| 133 | xs_dict *dequeue(const char *fn); | 133 | xs_dict *dequeue(const char *fn); |
| 134 | 134 | ||
| 135 | void purge(snac *snac); | 135 | void purge(snac *snac); |