diff options
| -rw-r--r-- | activitypub.c | 2 | ||||
| -rw-r--r-- | data.c | 4 | ||||
| -rw-r--r-- | snac.h | 2 |
3 files changed, 4 insertions, 4 deletions
diff --git a/activitypub.c b/activitypub.c index ba6e45e..bd99c26 100644 --- a/activitypub.c +++ b/activitypub.c | |||
| @@ -1169,7 +1169,7 @@ void process_queue(snac *snac) | |||
| 1169 | xs_str *fn; | 1169 | xs_str *fn; |
| 1170 | 1170 | ||
| 1171 | while (xs_list_iter(&p, &fn)) { | 1171 | while (xs_list_iter(&p, &fn)) { |
| 1172 | xs *q_item = dequeue(snac, fn); | 1172 | xs *q_item = dequeue(fn); |
| 1173 | 1173 | ||
| 1174 | if (q_item == NULL) { | 1174 | if (q_item == NULL) { |
| 1175 | snac_log(snac, xs_fmt("process_queue q_item error")); | 1175 | snac_log(snac, xs_fmt("process_queue q_item error")); |
| @@ -1439,11 +1439,11 @@ d_char *queue(snac *snac) | |||
| 1439 | } | 1439 | } |
| 1440 | 1440 | ||
| 1441 | 1441 | ||
| 1442 | d_char *dequeue(snac *snac, char *fn) | 1442 | xs_dict *dequeue(const char *fn) |
| 1443 | /* dequeues a message */ | 1443 | /* dequeues a message */ |
| 1444 | { | 1444 | { |
| 1445 | FILE *f; | 1445 | FILE *f; |
| 1446 | d_char *obj = NULL; | 1446 | xs_dict *obj = NULL; |
| 1447 | 1447 | ||
| 1448 | if ((f = fopen(fn, "r")) != NULL) { | 1448 | if ((f = fopen(fn, "r")) != NULL) { |
| 1449 | /* delete right now */ | 1449 | /* delete right now */ |
| @@ -130,7 +130,7 @@ 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 | d_char *queue(snac *snac); |
| 133 | d_char *dequeue(snac *snac, char *fn); | 133 | xs_dict *dequeue(const char *fn); |
| 134 | 134 | ||
| 135 | void purge(snac *snac); | 135 | void purge(snac *snac); |
| 136 | void purge_all(void); | 136 | void purge_all(void); |